全文检索

src/main/java/com/yihu/ehr/resolve/config/TextSearchConfig.java

@@ -0,0 +1,43 @@
package com.yihu.ehr.resolve.config;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import javax.annotation.PostConstruct;
import java.util.HashMap;
import java.util.Map;
/**
 * @author progr1mmer.
 * @date Created on 2018/9/17.
 */
@Configuration
@ConfigurationProperties(prefix = "ehr.text-search")
public class TextSearchConfig {
    private Map<String, String> master = new HashMap<>();
    private Map<String, String> sub = new HashMap<>();
    @PostConstruct
    public void init(){
        System.out.println(master.toString());
        System.out.println(sub.toString());
    }
    public Map<String, String> getMaster() {
        return master;
    }
    public void setMaster(Map<String, String> master) {
        this.master = master;
    }
    public Map<String, String> getSub() {
        return sub;
    }
    public void setSub(Map<String, String> sub) {
        this.sub = sub;
    }
}

src/main/java/com/yihu/ehr/resolve/controller/ResolveEndPoint.java

@@ -18,10 +18,7 @@ import com.yihu.ehr.resolve.model.stage1.OriginalPackage;
import com.yihu.ehr.resolve.model.stage1.StandardPackage;
import com.yihu.ehr.resolve.model.stage2.ResourceBucket;
import com.yihu.ehr.resolve.service.resource.stage1.ResolveService;
import com.yihu.ehr.resolve.service.resource.stage2.IdentifyService;
import com.yihu.ehr.resolve.service.resource.stage2.PackMillService;
import com.yihu.ehr.resolve.service.resource.stage2.ResourceService;
import com.yihu.ehr.resolve.service.resource.stage2.StatusReportService;
import com.yihu.ehr.resolve.service.resource.stage2.*;
import com.yihu.ehr.resolve.util.LocalTempPathUtil;
import com.yihu.ehr.util.datetime.DateUtil;
import io.swagger.annotations.Api;
@@ -62,6 +59,8 @@ public class ResolveEndPoint extends EnvelopRestEndPoint {
    private IdentifyService identifyService;
    @Autowired
    private StatusReportService statusReportService;
    @Autowired
    private TextSearchService textSearchService;
    @ApiOperation(value = "健康档案包入库", notes = "若包ID为空，则取最旧的未解析健康档案包", produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
    @RequestMapping(value = ServiceApi.PackageResolve.Resolve, method = RequestMethod.GET)
@@ -83,10 +82,12 @@ public class ResolveEndPoint extends EnvelopRestEndPoint {
            OriginalPackage originalPackage = resolveService.doResolve(pack, downloadTo(pack.getRemote_path()));
            ResourceBucket resourceBucket = packMillService.grindingPackModel(originalPackage);
            identifyService.identify(resourceBucket, originalPackage);
            textSearchService.generateSearchField(resourceBucket, originalPackage);
            resourceService.save(resourceBucket, originalPackage);
            //回填入库状态
            Map<String, Object> map = new HashMap();
            map.put("defect", resourceBucket.getQcMetadataRecords().getRecords().isEmpty() ? 0 : 1); //是否解析异常
            //是否解析异常
            map.put("defect", resourceBucket.getQcMetadataRecords().getRecords().isEmpty() ? 0 : 1);
            map.put("patient_name", resourceBucket.getBasicRecord(ResourceCells.PATIENT_NAME));
            map.put("profile_id", resourceBucket.getId());
            map.put("demographic_id", resourceBucket.getBasicRecord(ResourceCells.DEMOGRAPHIC_ID));
@@ -121,7 +122,8 @@ public class ResolveEndPoint extends EnvelopRestEndPoint {
            } else if (e instanceof IllegalJsonDataException) {
                errorType = 3;
            } else if (e instanceof ResolveException) {
                errorType = 21; //21以下为质控和解析的公共错误
                //21以下为质控和解析的公共错误
                errorType = 21;
            }
            if (StringUtils.isBlank(e.getMessage())) {
                statusReportService.reportStatus(pack.get_id(), ArchiveStatus.Failed, errorType, "Internal Server Error", null);
@@ -168,8 +170,9 @@ public class ResolveEndPoint extends EnvelopRestEndPoint {
            pack.setClient_id(clientId);
            OriginalPackage originalPackage = resolveService.doResolve(pack, zipFile);
            ResourceBucket resourceBucket = packMillService.grindingPackModel(originalPackage);
            identifyService.identify(resourceBucket, originalPackage);
            textSearchService.generateSearchField(resourceBucket, originalPackage);
            if (persist) {
                identifyService.identify(resourceBucket, originalPackage);
                resourceService.save(resourceBucket, originalPackage);
            }
            return new ResponseEntity<>(originalPackage.toJson(), HttpStatus.OK);

src/main/java/com/yihu/ehr/resolve/dao/MasterResourceDao.java

@@ -36,9 +36,9 @@ public class MasterResourceDao {
    public void saveOrUpdate(ResourceBucket resourceBucket, OriginalPackage originalPackage) throws Exception {
        //如果是非结构化档案, 或者是 影像档案, 通过rowkey 判断结构化档案 是否有数据
        if(originalPackage instanceof FilePackage || originalPackage instanceof LinkPackage){
        if (originalPackage instanceof FilePackage || originalPackage instanceof LinkPackage){
            String profileId = originalPackage.getProfileId().toString();
            String rowkey = profileId.substring(2,profileId.length());
            String rowkey = profileId.substring(2, profileId.length());
            Map<String, String> originResult = hbaseDao.get(ResourceCore.MasterTable, rowkey, resourceBucket.getdFamily());
            if (!originResult.isEmpty()) {
                throw new IllegalJsonFileException("Please upload the struct package(" + rowkey + ") first !");
@@ -46,7 +46,8 @@ public class MasterResourceDao {
        }
        String rowKey = resourceBucket.getId();
        TableBundle bundle = new TableBundle();
        if (originalPackage.isReUploadFlg()) { //补传处理
        //补传处理
        if (originalPackage.isReUploadFlg()) {
            Map<String, String> originResult = hbaseDao.get(resourceBucket.getMaster(), rowKey, resourceBucket.getdFamily());
            if (!originResult.isEmpty()) {
                MasterRecord masterRecord = resourceBucket.getMasterRecord();
@@ -55,10 +56,11 @@ public class MasterResourceDao {
                bundle.addValues(rowKey, resourceBucket.getdFamily(), originResult);
                hbaseDao.save(resourceBucket.getMaster(), bundle);
                Map<String, String> basicResult = hbaseDao.get(resourceBucket.getMaster(), rowKey, resourceBucket.getBasicFamily());
                updateFile(resourceBucket,originalPackage,basicResult);
                updateFile(resourceBucket, originalPackage, basicResult);
                if (StringUtils.isNotEmpty(basicResult.get(ResourceCells.EVENT_TYPE))) {
                    EventType eventType = EventType.create(basicResult.get(ResourceCells.EVENT_TYPE));
                    originalPackage.setEventType(eventType);
                    resourceBucket.insertBasicRecord(ResourceCells.EVENT_TYPE, Integer.toString(eventType.ordinal()));
                }
                resourceBucket.insertBasicRecord(ResourceCells.DEMOGRAPHIC_ID, basicResult.get(ResourceCells.DEMOGRAPHIC_ID));
            } else {
@@ -94,7 +96,7 @@ public class MasterResourceDao {
     * @param basicResult
     */
    private void updateFile(ResourceBucket resourceBucket, OriginalPackage originalPackage,Map<String, String> basicResult){
        if(originalPackage instanceof FilePackage){
        if (originalPackage instanceof FilePackage) {
            String file_list = basicResult.get("file_list");
            JsonArray oldFileArray = new JsonParser().parse(file_list).getAsJsonArray();
            JsonArray newFileArray = new JsonArray();
@@ -103,28 +105,28 @@ public class MasterResourceDao {
            String file_list1 = resourceBucket.getBasicRecord("file_list");
            JsonArray waitAddFileArray = new JsonParser().parse(file_list1).getAsJsonArray();
            for(JsonElement waitAdd :waitAddFileArray){
            for (JsonElement waitAdd :waitAddFileArray){
                String cdaId = ((JsonObject) waitAdd).get("cda_document_id").getAsString();
                for(JsonElement oldFile :oldFileArray){
                for (JsonElement oldFile :oldFileArray){
                    String oldCdaId = ((JsonObject) oldFile).get("cda_document_id").getAsString();
                    if(cdaId.equalsIgnoreCase(oldCdaId)){
                    if (cdaId.equalsIgnoreCase(oldCdaId)){
                        newFileArray.remove(oldFile);
                    }
                }
            }
            newFileArray.addAll(waitAddFileArray);
            basicResult.put("file_list",newFileArray.toString());
            basicResult.put("file_list", newFileArray.toString());
            TableBundle bundle = new TableBundle();
            bundle.addValues(resourceBucket.getId(), resourceBucket.getBasicFamily(), basicResult);
            hbaseDao.save(resourceBucket.getMaster(), bundle);
        }else if (originalPackage instanceof LinkPackage){
        } else if (originalPackage instanceof LinkPackage) {
            String file_list = basicResult.get("file_list");
            JsonArray oldFileArray = new JsonParser().parse(file_list).getAsJsonArray();
            //新上报的数据
            String file_list1 = resourceBucket.getBasicRecord("file_list");
            JsonArray waitAddFileArray = new JsonParser().parse(file_list1).getAsJsonArray();
            oldFileArray.addAll(waitAddFileArray);
            basicResult.put("file_list",oldFileArray.toString());
            basicResult.put("file_list", oldFileArray.toString());
            TableBundle bundle = new TableBundle();
            bundle.addValues(resourceBucket.getId(), resourceBucket.getBasicFamily(), basicResult);
            hbaseDao.save(resourceBucket.getMaster(), bundle);

src/main/java/com/yihu/ehr/resolve/dao/SubResourceDao.java

@@ -26,7 +26,8 @@ public class SubResourceDao {
    public void saveOrUpdate(ResourceBucket resourceBucket, OriginalPackage originalPackage) throws Exception {
        String rowKey = resourceBucket.getId();
        TableBundle bundle = new TableBundle();
        if (originalPackage.isReUploadFlg()) { //补传处理
        //补传处理
        if (originalPackage.isReUploadFlg()) {
            List<SubRecord> subRecordList = resourceBucket.getSubRecords();
            if (subRecordList.size() > 0) {
                //先删除

src/main/java/com/yihu/ehr/resolve/job/PackageResolveJob.java

@@ -14,11 +14,8 @@ import com.yihu.ehr.profile.exception.IllegalJsonFileException;
import com.yihu.ehr.resolve.model.stage1.OriginalPackage;
import com.yihu.ehr.resolve.model.stage2.ResourceBucket;
import com.yihu.ehr.resolve.service.resource.stage1.ResolveService;
import com.yihu.ehr.resolve.service.resource.stage2.IdentifyService;
import com.yihu.ehr.resolve.service.resource.stage2.PackMillService;
import com.yihu.ehr.resolve.service.resource.stage2.ResourceService;
import com.yihu.ehr.resolve.service.resource.stage2.*;
import com.yihu.ehr.resolve.log.PackResolveLogger;
import com.yihu.ehr.resolve.service.resource.stage2.StatusReportService;
import com.yihu.ehr.resolve.util.LocalTempPathUtil;
import com.yihu.ehr.util.datetime.DateUtil;
import net.lingala.zip4j.exception.ZipException;
@@ -72,7 +69,7 @@ public class PackageResolveJob implements InterruptableJob {
            if (pack != null) {
                //判断是否已经解析成功,或者正在解析(由于部署多个服务,运行的时间差可能导致多次加入队列,造成多次解析)
                Map<String, Object> map = statusReportService.getJsonArchiveById(pack.get_id());
                if(map != null && ("3".equals(map.get("archive_status")+"") || "1".equals(map.get("archive_status")+""))){
                if (map != null && ("3".equals(map.get("archive_status") + "") || "1".equals(map.get("archive_status") + ""))){
                    return;
                }
                PackResolveLogger.info("开始入库:" + pack.get_id() + ", Timestamp:" + new Date());
@@ -95,7 +92,8 @@ public class PackageResolveJob implements InterruptableJob {
            } else if (e instanceof IllegalJsonDataException) {
                errorType = 3;
            } else if (e instanceof ResolveException) {
                errorType = 21; //21以下为质控和解析的公共错误
                //21以下为质控和解析的公共错误
                errorType = 21;
            }
            if (pack != null) {
                if (StringUtils.isNotBlank(e.getMessage())) {
@@ -115,14 +113,17 @@ public class PackageResolveJob implements InterruptableJob {
        ResolveService resolveEngine = SpringContext.getService(ResolveService.class);
        PackMillService packMill = SpringContext.getService(PackMillService.class);
        IdentifyService identifyService = SpringContext.getService(IdentifyService.class);
        TextSearchService textSearchService = SpringContext.getService(TextSearchService.class);
        ResourceService resourceService = SpringContext.getService(ResourceService.class);
        OriginalPackage originalPackage = resolveEngine.doResolve(pack, downloadTo(pack.getRemote_path()));
        ResourceBucket resourceBucket = packMill.grindingPackModel(originalPackage);
        identifyService.identify(resourceBucket, originalPackage);
        textSearchService.generateSearchField(resourceBucket, originalPackage);
        resourceService.save(resourceBucket, originalPackage);
        //回填入库状态
        Map<String, Object> map = new HashMap();
        map.put("defect", resourceBucket.getQcMetadataRecords().getRecords().isEmpty() ? 0 : 1); //是否解析异常
        //是否解析异常
        map.put("defect", resourceBucket.getQcMetadataRecords().getRecords().isEmpty() ? 0 : 1);
        map.put("patient_name", resourceBucket.getBasicRecord(ResourceCells.PATIENT_NAME));
        map.put("profile_id", resourceBucket.getId());
        map.put("demographic_id", resourceBucket.getBasicRecord(ResourceCells.DEMOGRAPHIC_ID));

src/main/java/com/yihu/ehr/resolve/model/stage2/ResourceBucket.java

@@ -13,28 +13,50 @@ import java.util.*;
 */
public class ResourceBucket {
    //档案包ID
    /**
     * 档案包ID
     */
    private final String packId;
    //档案包接收时间
    /**
     * 档案包接收时间
     */
    private final Date receiveDate;
    //主键
    /**
     * 主键
     */
    private final String id;
    //主表
    /**
     * 主表
     */
    private final String master;
    //细表
    /**
     * 细表
     */
    private final String slave;
    //基础列族
    /**
     * 基础列族
     */
    private final String basicFamily;
    //数据列族
    /**
     * 数据列族
     */
    private final String dFamily;
    //基础索引字段
    /**
     * 基础索引字段
     */
    private Map<String, String> basicRecord = new HashMap<>();
    //主记录
    /**
     * 主记录
     */
    private MasterRecord masterRecord = new MasterRecord();
    //子记录
    /**
     * 子记录
     */
    private List<SubRecord> subRecords = new ArrayList<>();
    //质控数据
    /**
     * 质控数据
     */
    private QcMetadataRecords qcMetadataRecords = new QcMetadataRecords();
    public ResourceBucket(

src/main/java/com/yihu/ehr/resolve/service/profile/ArchiveRelationService.java

@@ -23,8 +23,8 @@ import java.util.Map;
/**
 * 档案关联
 * Created by hzp on 2017/4/11.
 * Modified by Progr1mmer
 * @author progr1mmer
 * @date Created on 2018/4/11.
*/
@Service
public class ArchiveRelationService {
@@ -76,7 +76,7 @@ public class ArchiveRelationService {
            relation.setEvent_no(resourceBucket.getBasicRecord(ResourceCells.EVENT_NO));
            relation.setEvent_date(DateUtil.strToDate(resourceBucket.getBasicRecord(ResourceCells.EVENT_DATE)));
            char prefix = CHARS.charAt((int)(Math.random() * 26));
            relation.setSn(prefix + "" + new Date().getTime());
            relation.setSn(prefix + "" + System.currentTimeMillis());
            relation.setRelation_date(new Date());
            relation.setCreate_date(new Date());
            //relation.setApply_id(null);

src/main/java/com/yihu/ehr/resolve/service/resource/stage2/PackMillService.java

@@ -202,7 +202,8 @@ public class PackMillService {
                Set<String> healthProblem = new HashSet<>();
                Set<String> healthProblemName = new HashSet<>();
                standardPackage.getDiagnosisCode().forEach(item -> {
                    String _healthProblem = redisService.getHpCodeByIcd10(item);//通过ICD10获取健康问题
                    //通过ICD10获取健康问题
                    String _healthProblem = redisService.getHpCodeByIcd10(item);
                    if (!StringUtils.isEmpty(_healthProblem)) {
                        String [] hpCodes = _healthProblem.split(";");
                        for (String hpCode : hpCodes) {
@@ -213,8 +214,10 @@ public class PackMillService {
                });
                resourceBucket.insertBasicRecord(ResourceCells.DIAGNOSIS, StringUtils.join(standardPackage.getDiagnosisCode(), ";"));
                resourceBucket.insertBasicRecord(ResourceCells.DIAGNOSIS_NAME, StringUtils.join(standardPackage.getDiagnosisName(), ";"));
                resourceBucket.insertBasicRecord(ResourceCells.HEALTH_PROBLEM, StringUtils.join(healthProblem, ";"));//健康问题
                resourceBucket.insertBasicRecord(ResourceCells.HEALTH_PROBLEM_NAME, StringUtils.join(healthProblemName, ";"));//健康问题名称
                //健康问题
                resourceBucket.insertBasicRecord(ResourceCells.HEALTH_PROBLEM, StringUtils.join(healthProblem, ";"));
                //健康问题名称
                resourceBucket.insertBasicRecord(ResourceCells.HEALTH_PROBLEM_NAME, StringUtils.join(healthProblemName, ";"));
            }
            return resourceBucket;
        } else if (originalPackage.getProfileType() == ProfileType.File) {
@@ -371,9 +374,12 @@ public class PackMillService {
             qcMetadataRecord.put("dataset", srcDataSetCode);
             qcMetadataRecord.put("metadata", srcMetadataCode);
             qcMetadataRecord.put("value", value);
             qcMetadataRecord.put("qc_step", 2); //资源化质控环节
             qcMetadataRecord.put("qc_error_type", ErrorType.FieldAdaptationError.getType()); //资源适配错误
             qcMetadataRecord.put("qc_error_name", ErrorType.FieldAdaptationError.getName()); //资源适配错误
             //资源化质控环节
             qcMetadataRecord.put("qc_step", 2);
             //资源适配错误
             qcMetadataRecord.put("qc_error_type", ErrorType.FieldAdaptationError.getType());
             //资源适配错误
             qcMetadataRecord.put("qc_error_name", ErrorType.FieldAdaptationError.getName());
             qcMetadataRecord.put("qc_error_message", String.format("Unable to get resource meta data code for ehr meta data %s of %s in %s", srcMetadataCode, srcDataSetCode, cdaVersion));
             qcMetadataRecord.put("create_date", DATE_FORMAT.format(new Date()));
             resourceBucket.getQcMetadataRecords().addRecord(qcMetadataRecord);

src/main/java/com/yihu/ehr/resolve/service/resource/stage2/TextSearchService.java

@@ -0,0 +1,98 @@
package com.yihu.ehr.resolve.service.resource.stage2;
import com.yihu.ehr.profile.ProfileType;
import com.yihu.ehr.profile.family.ResourceCells;
import com.yihu.ehr.resolve.config.TextSearchConfig;
import com.yihu.ehr.resolve.model.stage1.OriginalPackage;
import com.yihu.ehr.resolve.model.stage1.StandardPackage;
import com.yihu.ehr.resolve.model.stage2.ResourceBucket;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.*;
/**
 * @author progr1mmer.
 * @date Created on 2018/9/17.
 */
@Service
public class TextSearchService {
    @Autowired
    private TextSearchConfig textSearchConfig;
    @Autowired
    private RedisService redisService;
    /**
     * 生成检索字段
     * @param resourceBucket
     * @param originalPackage
     */
    public void generateSearchField(ResourceBucket resourceBucket, OriginalPackage originalPackage) {
        if (originalPackage.getProfileType() != ProfileType.Standard) {
            return;
        }
        StringBuilder stringBuilder = new StringBuilder();
        Map<String, String> master = textSearchConfig.getMaster();
        master.forEach((key, val) -> {
            String diagnosisName = "diagnosis_name";
            String chronicDiagnosis = "chronic_diagnosis";
            if (diagnosisName.equals(key)) {
                StandardPackage standardPackage = (StandardPackage)originalPackage;
                stringBuilder.append(val + ":" + StringUtils.join(standardPackage.getDiagnosisName(), ",") + ";");
            } else if (chronicDiagnosis.equals(key)) {
                StandardPackage standardPackage = (StandardPackage)originalPackage;
                Set<String> chronicNames = new HashSet<>();
                standardPackage.getDiagnosisCode().forEach(code -> {
                    String chronicInfo = redisService.getChronicInfo(code);
                    if (!StringUtils.isEmpty(chronicInfo)) {
                        String [] _chronicInfo = chronicInfo.split("-");
                        String flag = "0";
                        if (!flag.equals(_chronicInfo[1])) {
                            String healthProblem = redisService.getHpCodeByIcd10(code);
                            if (!StringUtils.isEmpty(healthProblem)) {
                                String separator = ";";
                                for (String hpCode : healthProblem.split(separator)) {
                                    String hpName = redisService.getHealthProblem(hpCode);
                                    if (StringUtils.isNotEmpty(hpName)) {
                                        chronicNames.add(hpName);
                                    }
                                }
                            }
                        }
                    }
                });
                stringBuilder.append(val + ":" + StringUtils.join(chronicNames, ",") + ";");
            } else {
                if (resourceBucket.getBasicRecord(key) != null) {
                    stringBuilder.append(val + ":" + resourceBucket.getBasicRecord(key) + ";");
                }
                if (resourceBucket.getMasterRecord().getDataGroup().get(key) != null) {
                    stringBuilder.append(val + ":" + resourceBucket.getMasterRecord().getDataGroup().get(key) + ";");
                }
            }
        });
        Map<String, String> sub = textSearchConfig.getSub();
        Map<String, Set<String>> datas = new HashMap<>(sub.size());
        resourceBucket.getSubRecords().forEach(subRecord ->
            sub.keySet().forEach(key -> {
                if (subRecord.getDataGroup().containsKey(key)) {
                    if (datas.containsKey(key)) {
                        datas.get(key).add(subRecord.getDataGroup().get(key));
                    } else {
                        Set<String> vals = new HashSet<>();
                        vals.add(subRecord.getDataGroup().get(key));
                        datas.put(key, vals);
                    }
                }
            })
        );
        sub.forEach((key, val) -> {
            if (datas.containsKey(key)) {
                stringBuilder.append(val + ":" + StringUtils.join(datas.get(key), ",") + ";");
            }
        });
        resourceBucket.insertBasicRecord(ResourceCells.SEARCH_FIELD, stringBuilder.toString());
    }
}

src/main/resources/application.yml

@@ -21,9 +21,9 @@ spring:
    port: 6379 # Redis server port.
    password: # Login password of the redis server.
    timeout: 0 # Connection timeout in milliseconds.
    #sentinel:
    #  master: # Name of Redis server.
    #  nodes: # Comma-separated list of host:port pairs.
    # sentinel:
      # master: # Name of Redis server.
      # nodes: # Comma-separated list of host:port pairs.
    pool:
      max-active: 8 # Max number of connections that can be allocated by the pool at a given time. Use a negative value for no limit.
      max-idle: 8 # Max number of "idle" connections in the pool. Use a negative value to indicate an unlimited number of idle connections.
@@ -135,6 +135,28 @@ ehr:
      - HDSD00_13_057 #入院日期时间 v1.3
      - HDSD00_01_185 #出院日期 v1.0
      - HDSD00_16_005 #出院日期时间 v1.3
  text-search:
    master:
      EHR_000004: 本人姓名
      EHR_000019_VALUE: 性别
      EHR_000014_VALUE: 婚姻状况
      EHR_000011: 过敏源
      event_date: 事件时间
      org_name: 机构名称
      EHR_000082: 门诊科室
      EHR_006209: 入院科室
      EHR_000222_VALUE: 出院科室
      diagnosis_name: 诊断
      chronic_diagnosis: 慢病名称
      EHR_000154: 出院情况
    sub:
      EHR_004971: 过敏药物
      EHR_002883: 检查名称
      EHR_000347: 检查结果
      EHR_000352: 检验项目
      EHR_000418: 手术名称
      EHR_000100: 西药
      EHR_000131: 中药
eip:
  schemaVersion: 5a6951bff0bb