保存疾病

src/main/java/thyyxxk/simzfeeoprnsystm/dao/SiMenDiseDao.java

@@ -0,0 +1,9 @@
+package thyyxxk.simzfeeoprnsystm.dao;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+import thyyxxk.simzfeeoprnsystm.pojo.SiMenDise;
+
+@Mapper
+public interface SiMenDiseDao extends BaseMapper<SiMenDise> {
+}

src/main/java/thyyxxk/simzfeeoprnsystm/pojo/SiMenDise.java

@@ -0,0 +1,19 @@
+package thyyxxk.simzfeeoprnsystm.pojo;
+
+import lombok.Data;
+
+@Data
+public class SiMenDise {
+
+    private String id;
+
+    private String mdtrtId;
+
+    private String patNo;
+
+    private String times;
+
+    private String diseCodg;
+
+    private String diseName;
+}

src/main/java/thyyxxk/simzfeeoprnsystm/service/SiMzFeeService.java

@@ -3,6 +3,7 @@ package thyyxxk.simzfeeoprnsystm.service;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson2.JSON;
+import org.springframework.util.StringUtils;
 import org.springframework.web.client.RestTemplate;
 import thyyxxk.simzfeeoprnsystm.config.HisApiConfig;
 import thyyxxk.simzfeeoprnsystm.dao.*;
@@ -27,6 +28,7 @@ public class SiMzFeeService {
     private final SiMzDao mzDao;
     private final SiSetlinfoDao setlinfoDao;
     private final SiSetldetailDao setldetailDao;
+    private final SiMenDiseDao siMenDiseDao;
     private final ScheduledDao scheduledDao;
     private final ExecService exec;
     private final WebHisService webHisService;
@@ -38,11 +40,12 @@ public class SiMzFeeService {
 
     @Autowired
     public SiMzFeeService(SiMzDao mzDao, SiSetlinfoDao setlinfoDao,
-                          SiSetldetailDao setldetailDao, ScheduledDao scheduledDao, ExecService exec,
+                          SiSetldetailDao setldetailDao, SiMenDiseDao siMenDiseDao, ScheduledDao scheduledDao, ExecService exec,
                           WebHisService webHisService, SiLogDao logDao, HisApiConfig hisApi) {
         this.mzDao = mzDao;
         this.setlinfoDao = setlinfoDao;
         this.setldetailDao = setldetailDao;
+        this.siMenDiseDao = siMenDiseDao;
         this.scheduledDao = scheduledDao;
         this.exec = exec;
         this.webHisService = webHisService;
@@ -311,6 +314,19 @@ public class SiMzFeeService {
         if (result.getIntValue(RESULT_CODE) == 0) {
             Diagnoses main = diagnosesList.get(0);
             mzDao.updatePatDiseinfo(siPatInfo.getPatNo(), siPatInfo.getTimes(), main.getDiagCode(), main.getDiagName());
+
+            // 将就诊信息里上传的疾病持久化保存
+            if(StringUtil.isNotEmpty(spcChrDiseAcct.getOpspDiseCode())) {
+                SiMenDise siMenDise = new SiMenDise();
+                siMenDise.setId(UUID.randomUUID().toString().replace("-", ""));
+                siMenDise.setMdtrtId(siPatInfo.getMdtrtId());
+                siMenDise.setPatNo(siPatInfo.getPatNo());
+                siMenDise.setTimes(String.valueOf(siPatInfo.getTimes()));
+                siMenDise.setDiseCodg(spcChrDiseAcct.getOpspDiseCode());
+                siMenDise.setDiseName(spcChrDiseAcct.getOpspDiseName());
+                siMenDiseDao.insert(siMenDise);
+            }
+
             return ResultVoUtil.success("门诊就诊信息上传成功。");
         }
         return ResultVoUtil.fail(ExceptionEnum.LOGICAL_ERROR, result.getString(ERROR_MESSAGE));