From df987258dcdc0c093ecffea9631912df7821c416 Mon Sep 17 00:00:00 2001
From: lige <bestlige@outlook.com>
Date: 星期四, 21 十二月 2023 17:38:39 +0800
Subject: [PATCH] 补录后

---
 ltkj-admin/src/main/java/com/ltkj/web/controller/sqlserver/TjSqlController.java |  114 ++++++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 92 insertions(+), 22 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 cdb13b2..4031f4c 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,13 +1,20 @@
 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.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.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.*;
 import com.ltkj.hosp.sqlDomain.*;
 import com.ltkj.hosp.mapper.TestMapper;
+import com.ltkj.system.service.ISysDeptService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.checkerframework.checker.units.qual.A;
@@ -20,6 +27,8 @@
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
+import java.sql.ResultSet;
+import java.sql.SQLException;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
@@ -55,31 +64,66 @@
     @Autowired
     public RedisTemplate<Object,Object> redisTemplate;
     @Resource
+    private ITjCustomerService tjCustomerService;
+    @Resource
     private RedisCache redisCache;
-
+    @Resource
+    private TjAsyncService asyncService;
+    @Resource
+    private ITjOrderRemarkService remarkService;
+    @Resource
+    private ITjOrderService orderService;
+    @Resource
+    private ISysDeptService deptService;
     @GetMapping("/getRedisValue")
     @ApiOperation(value = "娴嬭瘯redis妯$硦鏌ヨ")
-    public AjaxResult getRedisValue(@RequestParam String aa) {
-        long start = System.currentTimeMillis();
-        //闇�瑕佸尮閰嶇殑key
-        ScanOptions options = ScanOptions.scanOptions()
-                //杩欓噷鎸囧畾姣忔鎵弿key鐨勬暟閲�(寰堝鍗氬鐬庤瑕佹寚瀹欼nteger.MAX_VALUE锛岃繖鏍风殑璇濊窡        keys鏈変粈涔堝尯鍒紵)
-                .count(10000)
-                .match(aa+"*").build();
-        RedisSerializer<String> redisSerializer = (RedisSerializer<String>) redisTemplate.getKeySerializer();
-        Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize));
-        List<Object> result = new ArrayList<>();
-        while(cursor.hasNext()){
-            String s = cursor.next().toString();
-          redisCache.deleteObject(s);
-        }
-        //鍒囪杩欓噷涓�瀹氳鍏抽棴锛屽惁鍒欎細鑰楀敖杩炴帴鏁般�傛姤Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a
-        cursor.close();
-//        System.out.println(result);
-        log.info("scan鎵弿鍏辫�楁椂锛歿} ms key鏁伴噺锛歿}",System.currentTimeMillis()-start,result.size());
-        Map<String,Object>map=new HashMap<>();
-        map.put("result",result);
-        map.put("scan鎵弿鍏辫�楁椂锛歿} ms key鏁伴噺锛歿}",System.currentTimeMillis()-start+result.size());
+    public AjaxResult getRedisValue(@RequestParam int aa,
+                                    @RequestParam(defaultValue = "1") Integer page,
+                                    @RequestParam(defaultValue = "10") Integer pageSize,
+                                    @RequestParam(required = false) String deptId,
+                                    @RequestParam(required = false) String tjName,
+                                    @RequestParam(required = false) String tjNum) throws SQLException, JsonProcessingException {
+//        long start = System.currentTimeMillis();
+//        //闇�瑕佸尮閰嶇殑key
+//        ScanOptions options = ScanOptions.scanOptions()
+//                //杩欓噷鎸囧畾姣忔鎵弿key鐨勬暟閲�(寰堝鍗氬鐬庤瑕佹寚瀹欼nteger.MAX_VALUE锛岃繖鏍风殑璇濊窡        keys鏈変粈涔堝尯鍒紵)
+//                .count(10000)
+//                .match(aa+"*").build();
+//        RedisSerializer<String> redisSerializer = (RedisSerializer<String>) redisTemplate.getKeySerializer();
+//        Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize));
+//        List<Object> result = new ArrayList<>();
+//        while(cursor.hasNext()){
+//            String s = cursor.next().toString();
+//          redisCache.deleteObject(s);
+//        }
+//        //鍒囪杩欓噷涓�瀹氳鍏抽棴锛屽惁鍒欎細鑰楀敖杩炴帴鏁般�傛姤Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a
+//        cursor.close();
+////        System.out.println(result);
+//        log.info("scan鎵弿鍏辫�楁椂锛歿} ms key鏁伴噺锛歿}",System.currentTimeMillis()-start,result.size());
+//        Map<String,Object>map=new HashMap<>();
+//        map.put("result",result);
+//        map.put("scan鎵弿鍏辫�楁椂锛歿} ms key鏁伴噺锛歿}",System.currentTimeMillis()-start+result.size());
+//        List<TjOrderRemark> list = remarkService.list(new LambdaQueryWrapper<TjOrderRemark>().ne(TjOrderRemark::getType,2).groupBy(TjOrderRemark::getTjNumber));
+//        for (TjOrderRemark remark : list) {
+//            TjOrder orderByTjNum = orderService.getOrderByTjNum(remark.getTjNumber());
+//            if(null !=orderByTjNum){
+//                asyncService.dockerSetWjCustomerByRedis(orderByTjNum.getOrderId(),remark.getDeptId());
+//                asyncService.dockerSetYjCustomerByRedis(orderByTjNum.getOrderId(),remark.getDeptId());
+//            }
+//        }
+        if(null==deptId) deptId="";
+        if(null==tjName) tjName="";
+        if(null==tjNum) tjNum="";
+
+//        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);
+//        }
+
+        Map<String,Object> map = deptService.getSysDeptYjWjCustomerList13(deptId, tjName, tjNum, aa, page, pageSize);
         return AjaxResult.success(map);
     }
 
@@ -116,6 +160,7 @@
 
 
     @GetMapping("/getTjPat")
+    @ApiOperation(value = "娴嬭瘯getTjPat")
     public AjaxResult getTjPat() {
         List<LtkjTjPat> list = testMapper.getTjPat();
         DynamicDataSourceContextHolder.setDataSourceType(DataSourceType.MASTER.name());
@@ -126,6 +171,31 @@
         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")
     public AjaxResult getExamJcbgd() {
         List<LtkjExamJcbgd> list = testMapper.getExamJcbgd();

--
Gitblit v1.8.0