ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjCheckController.java
@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.ltkj.common.annotation.RepeatSubmit; import com.ltkj.common.core.domain.AjaxResult; import com.ltkj.common.core.domain.entity.SysUser; import com.ltkj.common.core.redis.RedisCache; @@ -12,6 +13,7 @@ import com.ltkj.common.utils.SecurityUtils; import com.ltkj.common.utils.StringUtils; import com.ltkj.framework.config.MatchUtils; import com.ltkj.framework.config.UserHoder; import com.ltkj.framework.datasource.DynamicDataSourceContextHolder; import com.ltkj.hosp.domain.*; import com.ltkj.hosp.mapper.TestMapper; @@ -37,6 +39,7 @@ import java.util.stream.Collectors; import static org.apache.poi.hemf.record.emfplus.HemfPlusRecordType.save; import static org.apache.poi.hemf.record.emfplus.HemfPlusRecordType.setClipRect; /** * @Author: 西安路泰科技有限公司/赵佳豪 @@ -304,18 +307,21 @@ */ @GetMapping("/dataSynchronization") @ApiOperation(value = "同步sql server数据到本地数据库数据接口") @RepeatSubmit public AjaxResult dataSynchronization(@RequestParam String tjNumber) { //根据配置调取存储过程 将临时表数据存入预约表2023.12.12 final String getInfoFromSqlData = configService.selectConfigByKey("getInfoFromSqlData"); if ("Y".equals(getInfoFromSqlData)) { List<LtkjHysqd> one = testMapper.getHysqdByTmh(tjNumber); if (one != null) { TjOrder order = orderService.getOrderByTjNum(tjNumber); if (null != order) { List<LtkjHysqd> one = testMapper.getHysqdByTmh(order.getCardId()); if (one != null && one.size() > 0) { DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); ltkjHysqdService.saveBatch(one); DynamicDataSourceContextHolder.clearDataSourceType(); for (LtkjHysqd ltkjHysqd : one) { List<LtkjHybgd> one1 = testMapper.getHybgdByTmh(ltkjHysqd.getTmh()); if (one1 != null) { if (one1 != null && one1.size() > 0) { DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); ltkjHybgdService.saveBatch(one1); DynamicDataSourceContextHolder.clearDataSourceType(); @@ -323,19 +329,21 @@ } } List<LtkjExamJcsqd> one2 = testMapper.getExamJcsqdTmh(tjNumber); if (one2 != null) { DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); ltkjExamJcsqdService.saveBatch(one2); DynamicDataSourceContextHolder.clearDataSourceType(); for (LtkjExamJcsqd ltkjExamJcsqd : one2) { List<LtkjExamJcbgd> one3 = testMapper.getExamJcbgdByTjh(ltkjExamJcsqd.getTmh()); if (one3 != null) { DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); ltkjExamJcbgdService.saveBatch(one3); DynamicDataSourceContextHolder.clearDataSourceType(); } } // List<LtkjExamJcsqd> one2 = testMapper.getExamJcsqdTmh(tjNumber); // if (one2 != null && one2.size() > 0) { // DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); // ltkjExamJcsqdService.saveBatch(one2); // DynamicDataSourceContextHolder.clearDataSourceType(); // for (LtkjExamJcsqd ltkjExamJcsqd : one2) { // List<LtkjExamJcbgd> one3 = testMapper.getExamJcbgdByTjh(ltkjExamJcsqd.getTmh()); // if (one3 != null && one3.size() > 0) { // DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); // ltkjExamJcbgdService.saveBatch(one3); // DynamicDataSourceContextHolder.clearDataSourceType(); // } // } // } testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()),order.getTjNumber(),UserHoder.getLoginUser().getUserId()); } } return AjaxResult.success("同步成功"); @@ -356,7 +364,6 @@ @ApiParam(value = "姓名)") @RequestParam(required = false) String name, @ApiParam(value = "开始时间") @RequestParam(required = false) String beginTime, @ApiParam(value = "结束时间") @RequestParam(required = false) String endTime) { // String config = configService.selectConfigByKey("tj_confirm"); // DateTime beginTimes = null; // DateTime endTimes = null; ltkj-common/src/main/java/com/ltkj/common/annotation/RepeatSubmit.java
@@ -20,7 +20,7 @@ /** * 间隔时间(ms)，小于此时间视为重复提交 */ int interval() default 200; int interval() default 10000; /** * 提示消息 ltkj-hosp/src/main/java/com/ltkj/hosp/domain/TjProject.java
@@ -244,6 +244,12 @@ @ApiModelProperty(value = "是否打报告'Y/N'") private String needReport; @ApiModelProperty(value = "lis项目编码") private String lisXmbm; @ApiModelProperty(value = "lis项目名称") private String lisXmmc; /** * 子项目 */ ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/TestMapper.java
@@ -1,13 +1,11 @@ package com.ltkj.hosp.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.ltkj.common.annotation.DataSource; import com.ltkj.common.enums.DataSourceType; import com.ltkj.hosp.sqlDomain.*; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Select; import java.util.List; import java.util.Map; @@ -76,6 +74,14 @@ @Select("call pro_his_middle(#{sfzh,mode=IN},#{sfzbm,mode=IN})") public void saveTjProByCusId(@Param("sfzh") String sfzh,@Param("sfzbm")String sfzbm); @DataSource(value = DataSourceType.MASTER) @Select("call tj_update_detatil(#{cardId,mode=IN},#{orderId,mode=IN},#{tjnum,mode=IN},#{dockerId,mode=IN})") public void updateDetailByCall(@Param("cardId") String cardId, @Param("orderId")String orderId, @Param("tjnum")String tjnum, @Param("dockerId")String dockerId); @DataSource(value = DataSourceType.SLAVE_HIS) @Select("SELECT * FROM histjv_exam_jcbgd") public List<LtkjExamJcbgd> getExamJcbgd(); @@ -84,7 +90,6 @@ @Select("SELECT * FROM histjv_exam_jcsqd") public List<LtkjExamJcsqd> getExamJcsqd(); @DataSource(value = DataSourceType.SLAVE_HIS) @Select("SELECT * FROM histjv_Ltkj_hybgd") public List<LtkjHybgd> getHybgd(); @@ -92,7 +97,6 @@ @DataSource(value = DataSourceType.SLAVE_HIS) @Select("SELECT * FROM histjv_Ltkj_hysqd") public List<LtkjHysqd> getHysqd(); @DataSource(value = DataSourceType.SLAVE_HIS) @Select("SELECT * FROM histjv_LTKJVTJPAT where pat_id=#{id}") @@ -114,7 +118,6 @@ @Select("SELECT * FROM histjv_exam_jcsqd where tjh=#{id}") public LtkjExamJcsqd getExamJcsqdById(String id); @DataSource(value = DataSourceType.SLAVE_HIS) @Select("SELECT * FROM histjv_Ltkj_hybgd where tmh=#{id}") public LtkjHybgd getHybgdById(String id); @@ -122,7 +125,6 @@ @DataSource(value = DataSourceType.SLAVE_HIS) @Select("SELECT * FROM histjv_Ltkj_hysqd where tmh=#{id}") public LtkjHysqd getHysqdById(String id); //体检登记接口 调用后 查询收费单据和详情 @DataSource(value = DataSourceType.SLAVE_HIS) @@ -132,7 +134,6 @@ @DataSource(value = DataSourceType.SLAVE_HIS) @Select("SELECT * FROM histjv_Ltkj_middle_detail where fead_id=#{id}") public List<LtkjMiddleDetail> getMiddleDetailByHeadId(String id); //根据体检号 对应的 化验项目 +标本 @DataSource(value = DataSourceType.SLAVE_HIS) @@ -144,10 +145,9 @@ @Select("SELECT * FROM histjv_Ltkj_hybgd where tmh=#{id}") public List<LtkjHybgd> getHybgdByTmh(String id); //根据体检号 对应的 检查项目 @DataSource(value = DataSourceType.SLAVE_HIS) @Select("SELECT * FROM histjv_exam_jcsqd where tjh=#{id}") @Select("SELECT * FROM histjv_Ltkj_hybgd where tjh=#{id}") public List<LtkjExamJcsqd> getExamJcsqdTmh(String id); //检查项目对应的检查结果 传上面的接口的结果tmh @@ -155,4 +155,25 @@ @Select("SELECT * FROM histjv_exam_jcbgd where tmh=#{id}") public List<LtkjExamJcbgd> getExamJcbgdByTjh(String id); @DataSource(value = DataSourceType.SLAVE_PACS) @Select({"<script> select isnull(fcard_no,'不详') xh,fcard_iD pacCode,pat_name pacName,\n" + " (case when patsex_id='0' then '男' when patsex_id='1' then '女' else '未知' end )+';'+brnl detail,\n" + " pat_id price , mobile pacRemark" + " from histjv_ltkjvtjpat where 1=1 "+ " <when test='pacCode!=null'>" + " AND fcard_no = #{pacCode}" + "</when>" + " <when test='pacName!=null'>" + " AND pat_name = #{pacName}" + "</when>" + " <when test='pacRemark!=null'>" + " AND mobile = #{pacRemark}" + "</when>" + "</script>"}) public List<Map<String,Object>> getTjHyBgList(@Param("pacCode")String pacCode, @Param("pacName")String pacName, @Param("pacRemark")String pacRemark); } ltkj-hosp/src/main/java/com/ltkj/hosp/sqlDomain/LtkjHysqd.java
@@ -11,6 +11,7 @@ public class LtkjHysqd { private String tjh; private String tmh; //标本号 private String bbbh; private String bbmc; private String xmid;
