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