是否重症病人的状态修改

src/main/java/com/docus/server/message/busservice/SdBusinessService.java

@@ -19,4 +19,19 @@ public interface SdBusinessService {
      * @return 消息处理结果
      */
     MessageResponse wsNurseSubmitHandle(Message message);
+
+    /**
+     * 同步患者是否重症病人,住院号+住院次数
+     * @param inpatientNo 住院号
+     * @param admissTimes 住院次数
+     */
+    void updIcuRecordState(String inpatientNo, Integer admissTimes);
+
+    /**
+     * 是否是重症病人(重症视图是否有数据)
+     * @param inpatientNo 住院号
+     * @param admissTimes 住院次数
+     * @return 是 true 否 false
+     */
+    boolean isIcuRecord(String inpatientNo, Integer admissTimes);
 }

src/main/java/com/docus/server/message/busservice/impl/SdBusinessServiceImpl.java

@@ -14,6 +14,7 @@ import com.docus.server.message.dto.RecordSubmitDTO;
 import com.docus.server.message.dto.WsNurseSubmitDTO;
 import com.docus.server.message.feign.dto.CompensateTasRequest;
 import com.docus.server.message.feign.service.CollectTaskService;
+import com.docus.server.message.mapper.SdRyIcuMapper;
 import com.docus.server.message.mapper.TBasicMapper;
 import com.docus.server.message.rpc.ShunDePeopleRpc;
 import com.docus.server.message.rpc.dto.HisZyCyYzDTO;
@@ -36,6 +37,7 @@ public class SdBusinessServiceImpl implements SdBusinessService {
     private CollectTaskService collectTaskService;
     private TBasicMapper tBasicMapper;
     private ShunDePeopleRpc shunDePeopleRpc;
+    private SdRyIcuMapper sdRyIcuMapper;
 
     @Autowired
     public void setCollectTaskService(CollectTaskService collectTaskService) {
@@ -52,6 +54,11 @@ public class SdBusinessServiceImpl implements SdBusinessService {
         this.shunDePeopleRpc = shunDePeopleRpc;
     }
 
+    @Autowired
+    public void setSdRyIcuMapper(SdRyIcuMapper sdRyIcuMapper) {
+        this.sdRyIcuMapper = sdRyIcuMapper;
+    }
+
     @Override
     public MessageResponse recordSubmitHandle(Message message) {
         try {
@@ -123,6 +130,18 @@ public class SdBusinessServiceImpl implements SdBusinessService {
     }
 
 
+    @Override
+    public void updIcuRecordState(String inpatientNo, Integer admissTimes) {
+        int state = isIcuRecord(inpatientNo, admissTimes) ? 1 : 0;
+        tBasicMapper.updIcuRecordState(inpatientNo, admissTimes, state);
+    }
+
+    @Override
+    public boolean isIcuRecord(String inpatientNo, Integer admissTimes) {
+        Integer exists = sdRyIcuMapper.isExists(inpatientNo, admissTimes);
+        return !Objects.isNull(exists);
+    }
+
     private void compensateTask(List<String> patientIds, List<String> collectorIds) {
         CompensateTasRequest dto = new CompensateTasRequest();
         dto.setPatientIds(patientIds);

src/main/java/com/docus/server/message/controller/DynamicDatasourceTestController.java

@@ -1,37 +0,0 @@
-package com.docus.server.message.controller;
-
-import com.docus.server.message.mapper.SdRyIcuMapper;
-import com.docus.server.message.mapper.TBasicMapper;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
-
-import java.util.HashMap;
-
-/**
- * @author WYBDEV
- */
-@Api("多数据源测试")
-@RestController
-@Slf4j
-@RequestMapping("/dynamic/test")
-public class DynamicDatasourceTestController {
-    @Autowired
-    TBasicMapper tBasicMapper;
-    @Autowired
-    SdRyIcuMapper sdRyIcuMapper;
-
-
-    @ApiOperation("根据病案主键")
-    @GetMapping("/getPatient")
-    public Object getPatient(@RequestParam("patientId") String patientId,@RequestParam("db")String db){
-        HashMap<String, Object> stringObjectHashMap = new HashMap<>();
-
-        stringObjectHashMap.put(sdRyIcuMapper.getClass().getName(), sdRyIcuMapper.getById(patientId));
-        stringObjectHashMap.put( tBasicMapper.getClass().getName(),tBasicMapper.getDischargeCount(patientId));
-        return stringObjectHashMap;
-    }
-
-}

src/main/java/com/docus/server/message/controller/SdRyHospitalController.java

@@ -0,0 +1,36 @@
+package com.docus.server.message.controller;
+
+import com.docus.infrastructure.web.api.CommonResult;
+import com.docus.server.message.busservice.SdBusinessService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author WYBDEV
+ */
+@Api("顺德人医医院")
+@RestController
+@Slf4j
+@RequestMapping("/hospital/sdRy")
+public class SdRyHospitalController {
+
+    @Autowired
+    private SdBusinessService sdBusinessService;
+
+
+    @ApiOperation("同步患者是否重症病人,住院号+住院次数")
+    @GetMapping("/updIcuRecordState")
+    public CommonResult<String> updIcuRecordState(@RequestParam("inpatientNo") String inpatientNo, @RequestParam("admissTimes") Integer admissTimes) {
+        log.info("顺德人医，同步患者是否重症病人，住院号:{},住院次数：{}",inpatientNo,admissTimes);
+        sdBusinessService.updIcuRecordState(inpatientNo, admissTimes);
+        return CommonResult.success("成功！");
+    }
+
+
+}

src/main/java/com/docus/server/message/mapper/SdRyIcuMapper.java

@@ -10,4 +10,7 @@ import java.util.Map;
 @Mapper
 public interface SdRyIcuMapper {
     Map<String,Object> getById(@Param("id") String patientId);
+
+
+    Integer isExists(@Param("inpatientNo")String inpatientNo,@Param("admissTimes") Integer admissTimes);
 }

src/main/java/com/docus/server/message/mapper/TBasicMapper.java

@@ -53,4 +53,13 @@ public interface TBasicMapper {
      * @return database操作行
      */
     int updateDisDateTime(@Param("patientId") String patientId,@Param("disDate") String disDate);
+
+    /**
+     * 更新基础信息，是否重症患者
+     * @param inpatientNo 病案号
+     * @param admissTimes 住院次数
+     * @param state 状态 1是，0否
+     * @return 数据库操作行
+     */
+    int updIcuRecordState(@Param("inpatientNo") String inpatientNo, @Param("admissTimes") Integer admissTimes, @Param("state") int state);
 }

src/main/resources/bootstrap.yml

@@ -33,7 +33,8 @@ spring:
           test-on-return: false
           validation-query: select 1
         icu:
-          url: jdbc:log4jdbc:mysql://192.168.31.233:3306/docus_medicalrecord?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
+#          url: jdbc:log4jdbc:mysql://192.168.31.233:3306/docus_medicalrecord?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
+          url: jdbc:log4jdbc:mysql://192.168.16.228:3306/sdyy_icu?autoReconnect=true&allowMultiQueries=true&useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
           username: docus
           password: docus702
           driver-class-name: net.sf.log4jdbc.sql.jdbcapi.DriverSpy

src/main/resources/mapper/SdRyIcuMapper.xml

@@ -9,4 +9,11 @@
         FROM `docus_medicalrecord`.t_basic tb
         WHERE tb.patient_id=#{id}
     </select>
+    <select id="isExists" resultType="java.lang.Integer">
+        select 1
+        from smtz_10
+        where 住院号 = #{inpatientNo}
+          and 住院次数 = #{admissTimes}
+        limit 1
+    </select>
 </mapper>

src/main/resources/mapper/TBasicMapper.xml

@@ -20,6 +20,12 @@
         set `dis_date`=#{disDate}
         where `patient_id`=#{patientId}
     </update>
+    <update id="updIcuRecordState">
+        update `docus_medicalrecord`.`t_basic`
+        set `is_icu`=#{state}
+        where inpatient_no=#{inpatientNo}
+            and admiss_times=#{admissTimes}
+    </update>
 
 
     <select id="getPatientIdsByInpatientNoAndTimes" resultType="java.lang.String">