ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java
@@ -3,10 +3,12 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import com.ltkj.common.annotation.RepeatSubmit; import com.ltkj.common.core.controller.BaseController; import com.ltkj.common.core.domain.AjaxResult; import com.ltkj.common.core.redis.RedisCache; import com.ltkj.common.enums.DataSourceType; import com.ltkj.framework.config.UserHoder; import com.ltkj.framework.datasource.DynamicDataSourceContextHolder; import com.ltkj.hosp.domain.TjCustomer; import com.ltkj.hosp.domain.TjOrder; @@ -351,4 +353,57 @@ } return AjaxResult.success(); } @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)) { TjOrder order = orderService.getOrderByTjNum(tjNumber); if (null != order) { List<LtkjHysqd> one = testMapper.getHysqdByTmh(order.getCardId()); if (one != null && one.size() > 0) { for (LtkjHysqd ltkjHysqd : one) { // DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); LtkjHysqd hysqd = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(ltkjHysqd.getTjh(), ltkjHysqd.getTmh()); if(hysqd==null){ ltkjHysqdService.save(ltkjHysqd); DynamicDataSourceContextHolder.clearDataSourceType(); List<LtkjHybgd> one1 = testMapper.getHybgdByTmh(ltkjHysqd.getTmh()); if (one1 != null && one1.size() > 0) { DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); ltkjHybgdService.saveBatch(one1); 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(), "1"); //同步检查项目 testMapper.updateDetailByTjJcCall(order.getCardId(), String.valueOf(order.getOrderId()),order.getTjNumber(),"1"); } // } return AjaxResult.success("同步成功"); } } ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjCheckController.java
@@ -316,15 +316,18 @@ 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) { // DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); LtkjHysqd hysqd = ltkjHysqdService.getLtkjHysqdByTjhAndTmh(ltkjHysqd.getTjh(), ltkjHysqd.getTmh()); if(hysqd==null){ ltkjHysqdService.save(ltkjHysqd); DynamicDataSourceContextHolder.clearDataSourceType(); List<LtkjHybgd> one1 = testMapper.getHybgdByTmh(ltkjHysqd.getTmh()); if (one1 != null && one1.size() > 0) { DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); ltkjHybgdService.saveBatch(one1); DynamicDataSourceContextHolder.clearDataSourceType(); } } } } @@ -347,6 +350,7 @@ testMapper.updateDetailByCall(order.getCardId(), String.valueOf(order.getOrderId()),order.getTjNumber(),UserHoder.getLoginUser().getUserId()); //同步检查项目 testMapper.updateDetailByTjJcCall(order.getCardId(), String.valueOf(order.getOrderId()),order.getTjNumber(),UserHoder.getLoginUser().getUserId()); asyncService.updateCheckType(order.getTjNumber()); } } return AjaxResult.success("同步成功"); @@ -527,10 +531,10 @@ @GetMapping("/updateCheckType") @ApiOperation(value = "总检点击体检信息详情") public AjaxResult updateCheckType(@ApiParam(value = "客户体检号") @RequestParam String tjNumber) { if (redisCache.hasKey("updateCheckType" + tjNumber)) { List<Map<String, Object>> cacheMapValue = redisCache.getCacheMapValue("updateCheckType" + tjNumber, tjNumber); return AjaxResult.success(cacheMapValue); } // if (redisCache.hasKey("updateCheckType" + tjNumber)) { // List<Map<String, Object>> cacheMapValue = redisCache.getCacheMapValue("updateCheckType" + tjNumber, tjNumber); // return AjaxResult.success(cacheMapValue); // } return getAjaxResult(tjNumber); }
@@ -73,15 +73,15 @@ # redis 配置 redis: # 地址 host: 101.42.27.146 # host: localhost # host: 101.42.27.146 host: localhost # 端口，默认为6379 port: 6379 # 数据库索引 database: 0 # 密码 password: 654321 # password: 123456 # password: 654321 password: 123456 # 连接超时时间 timeout: 120s lettuce: @@ -226,3 +226,8 @@ size: - 40 - 60 # ip = 101.42.27.146 # prot = 3306 # name = ltkjpeis10 # username = root # password = Root_ltkj123 ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/LtkjHysqdMapper.java
@@ -6,6 +6,8 @@ import com.ltkj.hosp.sqlDomain.LtkjExamJcsqd; import com.ltkj.hosp.sqlDomain.LtkjHysqd; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Select; /** * @Company: 西安路泰科技有限公司 @@ -13,6 +15,9 @@ * @Date: 2023/12/11 17:56 */ @Mapper @DataSource(value = DataSourceType.MASTER) //@DataSource(value = DataSourceType.MASTER) public interface LtkjHysqdMapper extends BaseMapper<LtkjHysqd> { @Select("SELECT * FROM ltkj_hysqd a WHERE a.tjh=#{tjh} AND a.tmh=#{tmh} ") LtkjHysqd getLtkjHysqdByTjhAndTmh(@Param("tjh") String tjh,@Param("tmh") String tmh); } ltkj-hosp/src/main/java/com/ltkj/hosp/service/LtkjHysqdService.java
@@ -10,4 +10,6 @@ * @Date: 2023/12/11 17:57 */ public interface LtkjHysqdService extends IService<LtkjHysqd> { LtkjHysqd getLtkjHysqdByTjhAndTmh(String tjh,String tmh); } ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/LtkjHysqdServiceImpl.java
@@ -9,6 +9,8 @@ import com.ltkj.hosp.sqlDomain.LtkjHysqd; import org.springframework.stereotype.Service; import javax.annotation.Resource; /** * 病种+意见Service业务层处理 * @@ -18,4 +20,11 @@ @Service public class LtkjHysqdServiceImpl extends ServiceImpl<LtkjHysqdMapper, LtkjHysqd> implements LtkjHysqdService { @Resource private LtkjHysqdMapper mapper; @Override public LtkjHysqd getLtkjHysqdByTjhAndTmh(String tjh, String tmh) { return mapper.getLtkjHysqdByTjhAndTmh(tjh,tmh); } }
