From 5931c2e6c45452e05b46b00ed5f35ebace24e799 Mon Sep 17 00:00:00 2001 From: zjh <zjh@888> Date: 星期三, 31 一月 2024 14:31:38 +0800 Subject: [PATCH] zjh 本地 2024/01/31 -2 --- ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java | 177 ++++++++++++++++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 163 insertions(+), 14 deletions(-) diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java index caeb0e6..bc74ee9 100644 --- a/ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java +++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java @@ -1,11 +1,16 @@ package com.ltkj.web.controller.sqlserver; 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; import com.ltkj.hosp.domain.TjOrderRemark; import com.ltkj.hosp.service.*; @@ -37,7 +42,7 @@ @RestController @RequestMapping("/sqlserver/getdata") -@Api(tags = "鑾峰彇浠庡簱鏁版嵁") +@Api(tags = "AAAAAAAAAAA鑾峰彇浠庡簱鏁版嵁") public class TjSqlController extends BaseController { @Resource private TestMapper testMapper; @@ -61,6 +66,8 @@ @Autowired public RedisTemplate<Object,Object> redisTemplate; @Resource + private ITjCustomerService tjCustomerService; + @Resource private RedisCache redisCache; @Resource private TjAsyncService asyncService; @@ -70,6 +77,34 @@ private ITjOrderService orderService; @Resource private ISysDeptService deptService; + @Resource + private LtkjHisUserService hisUserService; + + @GetMapping("/getTjHyBgList") + @ApiOperation(value = "鏌ヨlis鏁版嵁搴撻」鐩俊鎭帴鍙�") + public AjaxResult getTjHyBgList(@RequestParam(required = false)String pacCode, + @RequestParam(required = false)String pacName, + @RequestParam(required = false)String pacRemark) { + List<Map<String, Object>> maps = testMapper.getTjHyBgList(pacCode,pacName,pacRemark); + DynamicDataSourceContextHolder.clearDataSourceType(); + return AjaxResult.success(maps); + } + + + @GetMapping("/newGetTjPat") + @ApiOperation(value = "鏂扮殑鏌ヨ浣撴淇℃伅鎺ュ彛") + public AjaxResult newGetTjPat(@RequestParam(required = false)String pacCode, + @RequestParam(required = false)String pacName, + @RequestParam(required = false)String pacRemark) { +// List<Map<String, Object>> maps = testMapper.newGetTjPat111111(pacName); + List<Map<String, Object>> maps = testMapper.newGetTjPat(pacCode,pacName,pacRemark); + DynamicDataSourceContextHolder.clearDataSourceType(); + return AjaxResult.success(maps); + } + + + + @GetMapping("/getRedisValue") @ApiOperation(value = "娴嬭瘯redis妯$硦鏌ヨ") public AjaxResult getRedisValue(@RequestParam int aa, @@ -77,7 +112,7 @@ @RequestParam(defaultValue = "10") Integer pageSize, @RequestParam(required = false) String deptId, @RequestParam(required = false) String tjName, - @RequestParam(required = false) String tjNum) throws SQLException { + @RequestParam(required = false) String tjNum) throws SQLException, JsonProcessingException { // long start = System.currentTimeMillis(); // //闇�瑕佸尮閰嶇殑key // ScanOptions options = ScanOptions.scanOptions() @@ -112,16 +147,19 @@ // List<Map<String, Object>> map = deptService.getSysDeptYjWjCustomerList(deptId, tjName, tjNum, aa, page, pageSize); // List<ResultSet> map = deptService.getSysDeptYjWjCustomerList1(deptId, tjName, tjNum, aa, page, pageSize); - ResultSet resultSet = deptService.getSysDeptYjWjCustomerList12(deptId, tjName, tjNum, aa, page, pageSize); - while (resultSet.next()){ - String anInt = resultSet.getString(1); - System.out.println(anInt); - } - return AjaxResult.success(); +// ResultSet resultSet = deptService.getSysDeptYjWjCustomerList12(deptId, tjName, tjNum, aa, page, pageSize); +// while (resultSet.next()){ +// String anInt = resultSet.getString(1); +// System.out.println(anInt); +// } + + Map<String,Object> map = deptService.getSysDeptYjWjCustomerList13(deptId, tjName, tjNum, aa, page, pageSize); + return AjaxResult.success(map); } @GetMapping("/getMiddleDetail") + @ApiOperation(value = "鏌ヨ鏀惰垂椤圭洰璇︽儏") public AjaxResult getMiddleDetail() { List<LtkjMiddleDetail> list = testMapper.getMiddleDetail(); DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); @@ -134,6 +172,7 @@ @GetMapping("/getMiddleHead") + @ApiOperation(value = "鏌ヨ鏀惰垂淇℃伅") public AjaxResult getMiddleHead() { List<LtkjMiddleHead> list = testMapper.getMiddleHead(); DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); @@ -144,15 +183,32 @@ return AjaxResult.success(list); } -// @GetMapping("/getVbjitem") -// @ApiOperation(value = "鏌ョ湅鍒楄〃") -// public AjaxResult getVbjitem() { -// List<LtkjVbjitem> list = testMapper.getVbjitem(); -// return AjaxResult.success(list); -// } + @GetMapping("/getMiddleHeadByPartId") + @ApiOperation(value = "鏍规嵁韬唤璇佸彿鏌ヨ鏀惰垂淇℃伅") + public AjaxResult getMiddleHeadByPartId(@RequestParam String partId) { + TjCustomer customer = tjCustomerService.getTjCustomerByCusIdCard(partId); + LtkjMiddleHead pat = testMapper.getMiddleHeadByPartId(customer.getCardId()); + if (null != pat) { + List<LtkjMiddleDetail> list = testMapper.getMiddleDetailByFeadId(pat.getFeadId()); + DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); + LtkjMiddleHead o = headService.getMiddleHeadByPartId(customer.getCardId()); + if(o==null){ + headService.save(pat); + for (LtkjMiddleDetail ltkjMiddleDetail : list) { + middleDetailService.save(ltkjMiddleDetail); + } + testMapper.saveTjProByCusId(customer.getCardId(),customer.getCusIdcard()); + } + testMapper.saveTjProByCusId(customer.getCardId(),customer.getCusIdcard()); + } + DynamicDataSourceContextHolder.clearDataSourceType(); + return AjaxResult.success(); + } + @GetMapping("/getTjPat") + @ApiOperation(value = "娴嬭瘯getTjPat") public AjaxResult getTjPat() { List<LtkjTjPat> list = testMapper.getTjPat(); DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); @@ -161,6 +217,31 @@ } DynamicDataSourceContextHolder.clearDataSourceType(); return AjaxResult.success(list); + } + + + @GetMapping("/getTjPatByIdCard") + @ApiOperation(value = "鏍规嵁韬唤璇佸彿娴嬭瘯getTjPat") + public AjaxResult getTjPatByIdCard(@RequestParam String idCard) { + LtkjTjPat tjPatByIdCard = testMapper.getTjPatByIdCard(idCard.trim()); + if(null != tjPatByIdCard){ + String fcardNo = tjPatByIdCard.getFcardNo(); + if(null !=fcardNo){ + fcardNo=fcardNo.trim(); + tjPatByIdCard.setFcardNo(fcardNo); + } + LtkjTjPat ltkjTjPat = tjvLtkjvtjpatService.getLtkjTjPatByCusIdCard(idCard); + if(null==ltkjTjPat){ + tjvLtkjvtjpatService.save(tjPatByIdCard); + } + } + DynamicDataSourceContextHolder.clearDataSourceType(); + //鍐嶆牴鎹韩浠借瘉鍙峰啓customer琛� + TjCustomer tjCustomer = tjCustomerService.getTjCustomerByCusIdCard(idCard); + if(null == tjCustomer){ + testMapper.getTjPatByCusId(idCard); + } + return AjaxResult.success(tjPatByIdCard); } @GetMapping("/getExamJcbgd") @@ -256,5 +337,73 @@ } + @GetMapping("/getLtkjHisUser") + @ApiOperation(value = "鍚屾his鐢ㄦ埛") + public AjaxResult getLtkjHisUser() { + List<LtkjHisUser> list = testMapper.getLtkjHisUser(); + if(null !=list && list.size()>0){ + DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name()); + for (LtkjHisUser user : list) { + LtkjHisUser hisUser= hisUserService.getHisUserByHisGh(user.getHisgh()); + if(null == hisUser){ + hisUserService.save(user); + } + } + DynamicDataSourceContextHolder.clearDataSourceType(); + } + 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("鍚屾鎴愬姛"); + } } -- Gitblit v1.8.0