From 23cbab8e322e7aa6fda98dde4540b01ecf3c4fd1 Mon Sep 17 00:00:00 2001
From: lige <bestlige@outlook.com>
Date: 星期三, 28 二月 2024 12:18:18 +0800
Subject: [PATCH] 1

---
 ltkj-admin/src/main/java/com/ltkj/web/controller/system/SysDeptController.java |  575 ++++++++++++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 525 insertions(+), 50 deletions(-)

diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/system/SysDeptController.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/system/SysDeptController.java
index 9bf3804..ac3f3de 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/controller/system/SysDeptController.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/system/SysDeptController.java
@@ -10,12 +10,14 @@
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.google.common.base.Joiner;
+import com.ltkj.common.core.domain.TreeSelect;
 import com.ltkj.common.core.domain.entity.SysUser;
 import com.ltkj.common.core.redis.RedisCache;
 import com.ltkj.common.utils.SecurityUtils;
 import com.ltkj.common.utils.bean.BeanUtils;
 import com.ltkj.framework.config.MatchUtils;
 import com.ltkj.hosp.domain.*;
+import com.ltkj.hosp.mapper.TestMapper;
 import com.ltkj.hosp.service.*;
 import com.ltkj.system.domain.SysPost;
 import com.ltkj.system.domain.SysUserPost;
@@ -97,6 +99,8 @@
     private ITjRulesService tjRulesService;
     @Autowired
     public RedisTemplate<Object,Object> redisTemplate;
+    @Resource
+    private TestMapper testMapper;
 
 
     /**
@@ -122,7 +126,6 @@
             return AjaxResult.error("璇疯緭鍏ョ瀹d");
         }
         //鏍规嵁褰撳墠鐧婚檰鐨勪汉鐨勭瀹d锛岃幏鍙栬绉戝涓嬬殑鎵�鏈夐」鐩�
-        // TODO: 2023/3/24  缁欒秴绾х鐞嗗憳璧嬪尰鐢熸鏌ユ潈闄�
         List<Long> postIds = sysUser.getPostIds();
         List<Long> ksproList = null;
         if (postIds != null) {
@@ -392,7 +395,9 @@
                             StringBuilder stringBuilder = new StringBuilder();
                             for (TjOrderRemark remark : list) {
                                 TjProject byId = projectService.getById(remark.getProId());
-                                stringBuilder.append(byId.getProName()).append(";");
+                                if(null !=byId){
+                                    stringBuilder.append(byId.getProName()).append(";");
+                                }
                             }
                             customer.setNotCheckeds(String.valueOf(stringBuilder));
                             if (null == customer.getNotCheckeds()) customer.setNotCheckeds("鍏ㄩ儴宸叉");
@@ -417,50 +422,63 @@
      * 鍖栭獙妫�鏌ラ〉闈㈠垪琛�
      */
     @GetMapping("/huaYangetProList")
-    @ApiOperation("褰卞儚/鍖栭獙妫�鏌ラ〉闈㈠垪琛�")
+    @ApiOperation("鍖栭獙妫�鏌ラ〉闈㈠垪琛�")
     public AjaxResult huaYangetProList(@ApiParam(value = "浣撴鍗曞彿") @RequestParam(required = false) String tjNumber,
                                  @ApiParam(value = "0鏈,1宸叉") @RequestParam(defaultValue = "0") Integer type,
                                  @ApiParam(value = "濮撳悕)") @RequestParam(required = false) String name,
                                  @ApiParam(value = "椤电爜鏁�(榛樿1)") @RequestParam(defaultValue = "1") Integer page,
                                  @ApiParam(value = "鏄剧ず鏉℃暟(榛樿10)") @RequestParam(defaultValue = "10") Integer pageSize) {
-        String userId = SecurityUtils.getLoginUser().getUserId();
-        Integer ksId = null;
-        SysUser sysUser = null;
-        if (null != userId) {
-            sysUser = userService.getById(Long.valueOf(userId));
-            if (null != sysUser) {
-                ksId = Math.toIntExact(sysUser.getDeptId());
-            }
-        }
-        if (ksId == null) {
-            return AjaxResult.error("璇疯緭鍏ョ瀹d");
-        }
+//        String userId = SecurityUtils.getLoginUser().getUserId();
+//        Integer ksId = null;
+//        SysUser sysUser = null;
+//        if (null != userId) {
+//            sysUser = userService.getById(Long.valueOf(userId));
+//            if (null != sysUser) {
+//                ksId = Math.toIntExact(sysUser.getDeptId());
+//            }
+//        }
+//        if (ksId == null) {
+//            return AjaxResult.error("璇疯緭鍏ョ瀹d");
+//        }
+
+        //A30鍖栭獙
         //鏍规嵁褰撳墠鐧婚檰鐨勪汉鐨勭瀹d锛岃幏鍙栬绉戝涓嬬殑鎵�鏈夐」鐩�
-        // TODO: 2023/3/24  缁欒秴绾х鐞嗗憳璧嬪尰鐢熸鏌ユ潈闄�
-        List<Long> postIds = sysUser.getPostIds();
+//        List<Long> postIds = sysUser.getPostIds();
         List<Long> ksproList = null;
-        if (postIds != null) {
-            for (Long postId : postIds) {
-                LambdaQueryWrapper<SysUserPost> wq111 = new LambdaQueryWrapper<>();
-                wq111.eq(SysUserPost::getPostId, postId);
-                SysUserPost one = userPostService.getOne(wq111);
-                if (one != null) {
-                    SysPost byId = postService.getById(one.getPostId());
-                    if (byId.getPostName().equals("褰曞叆鍛�")) {
-                        ksproList = projectService.getKsTjProjectIdListBydeptId(String.valueOf(ksId));
-                    }
-                }
-            }
-        } else {
-            ksproList = projectService.getKsTjProjectIdList();
-        }
+//        if (postIds != null) {
+//            for (Long postId : postIds) {
+//                LambdaQueryWrapper<SysUserPost> wq111 = new LambdaQueryWrapper<>();
+//                wq111.eq(SysUserPost::getPostId, postId);
+//                SysUserPost one = userPostService.getOne(wq111);
+//                if (one != null) {
+//                    SysPost byId = postService.getById(one.getPostId());
+//                    if (byId.getPostName().equals("褰曞叆鍛�")) {
+//                        ksproList = projectService.getKsTjProjectIdListBydeptId(String.valueOf(ksId));
+//                    }
+//                }
+//            }
+//        } else {
+//            ksproList = projectService.getKsTjProjectIdList();
+//        }
+
+//        if(sysUser.getUserName().equals("10001")){
+            ksproList = projectService.getHuaYanProId();
+//        }
+//        else {
+//            ksproList = projectService.getKsTjProjectIdListBydeptId(String.valueOf(ksId));
+//        }
 
         if (ksproList == null || ksproList.size() == 0) {
             return AjaxResult.error("璇峰畬鍠勭瀹ら」鐩俊鎭�");
         }
+        //绛涢�夊寲楠岀殑椤圭洰銆�
+//        ksproList = ksproList.stream()
+//                .filter(element -> element ==1633660948860522629L)
+//                .collect(Collectors.toList());
+
         List<TjCustomer> customerLis = new ArrayList<>();
 
-        //鏍规嵁浣撴鍙锋煡
+/*        //鏍规嵁浣撴鍙锋煡
         if (null != tjNumber) {
             List<TjOrder> orderList = orderService.getOrderListByLikeTjNum(tjNumber);
             if (null == orderList) {
@@ -596,27 +614,477 @@
                 return AjaxResult.success("鏆傛棤鏁版嵁");
             }
         }
-        List<TjCustomer> customerLists = new ArrayList<>();
+        List<TjCustomer> customerLists = null;*/
+//        //鏍规嵁浣撴鍙锋煡
+//        if (null != tjNumber) {
+//            List<TjOrder> orderList = orderService.getOrderListByLikeTjNum(tjNumber);
+//            if (null == orderList) {
+//                return AjaxResult.success("鏆傛椂娌℃湁鏁版嵁");
+//            }
+//            for (TjOrder order : orderList) {
+//                List<TjOrderDetail> list = Optional.ofNullable(detailService.getTjOrderDetailListByOrderId(String.valueOf(order.getOrderId()))).get();
+//                if (list.size() == 0) {
+//                    continue;
+//                }
+//                LambdaQueryWrapper<TjOrderRemark> wqs = new LambdaQueryWrapper<>();
+//                wqs.eq(TjOrderRemark::getTjNumber, order.getTjNumber());
+//                wqs.in(TjOrderRemark::getType, 0,3);
+//                List<TjOrderRemark> lists = remarkService.list(wqs);
+//                TjCustomer customer = customerService.getById(order.getUserId());
+//
+//                //閬嶅巻椤圭洰 鍒ゆ柇鏄惁鏈夐噸澶ч槼鎬�  鏍囪
+//                for (TjOrderDetail tjOrderDetail11 : list) {
+//                    customer.setIsPositive(tjOrderDetail11.getIsPositive());
+//                    if (tjOrderDetail11.getIsPositive()==1){
+//                        break;
+//                    }
+//                }
+//
+//                customer.setCusName(MatchUtils.hideCusName(customer.getCusName()));
+//                customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone()));
+//                customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard()));
+//                if (null != lists && lists.size() > 0) {
+//                    StringBuilder stringBuilder = new StringBuilder();
+//                    for (TjOrderRemark remark : lists) {
+//                        TjProject byId = projectService.selectTjProjectByProId(remark.getProId());
+//                        TjOrderDetail one = detailService.getTjOrderDetailByOrderId(String.valueOf(order.getOrderId()), String.valueOf(byId.getProId()));
+//                        if (one.getFlowingWaterId() != null) {
+//                            stringBuilder.append(byId.getProName()).append(";");
+//                        }
+//
+//                    }
+//                    customer.setNotCheckeds(String.valueOf(stringBuilder));
+//                    customer.setTjStatus(0L);
+//                } else {
+//                    customer.setTjStatus(1L);
+//                    customer.setNotCheckeds("鏃�");
+//                }
+//                if (order.getTjType().equals("1")) {
+//                    customer.setTjType("鍥綋");
+//                }
+//                if (order.getTjType().equals("2")) {
+//                    customer.setTjType("涓汉");
+//                }
+//                customer.setTjTime(order.getCreateTime());
+//                customer.setTjNumber(order.getTjNumber());
+//                customer.setOrderId(order.getOrderId());
+//                customer.setIsHz(order.getIsHz());
+//                customer.setTjCategory(order.getTjCategory());
+//                customerLis.add(customer);
+//            }
+//            if (customerLis.size() > 0) {
+//                List<TjCustomer> customerList = customerLis.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList());
+//                Collections.reverse(customerList);
+//                Map<String, Object> map = new HashMap<>();
+//                map.put("date", customerList);
+//                map.put("total", customerLis.size());
+//                return AjaxResult.success(map);
+//            } else {
+//                return AjaxResult.success("鏆傛棤鏁版嵁");
+//            }
+//        }
+//
+//        //鏍规嵁濮撳悕鏌ヨ
+//        if (null != name && !"".equals(name)) {
+//            LambdaQueryWrapper<TjCustomer> wq = new LambdaQueryWrapper<>();
+//            wq.like(TjCustomer::getCusName, name);
+//            List<TjCustomer> list = customerService.list(wq);
+//            List<TjCustomer> list11111 = new ArrayList<>();
+//            if (null != list && list.size() > 0) {
+//                for (TjCustomer customer : list) {
+//                    customer.setCusName(MatchUtils.hideCusName(customer.getCusName()));
+//                    customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone()));
+//                    customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard()));
+//                    List<TjOrder> orderList = orderService.getOrderListByCusId(String.valueOf(customer.getCusId()));
+//                    if (null != orderList && orderList.size() > 0) {
+//                        for (TjOrder order : orderList) {
+//                            List<TjOrderDetail> list111 = Optional.ofNullable(detailService.getTjOrderDetailListByOrderId(String.valueOf(order.getOrderId()))).get();
+//                            if (list111.size() == 0) {
+//                                continue;
+//                            }
+//                            //閬嶅巻椤圭洰 鍒ゆ柇鏄惁鏈夐噸澶ч槼鎬�  鏍囪
+//                            for (TjOrderDetail tjOrderDetail11 : list111) {
+//                                customer.setIsPositive(tjOrderDetail11.getIsPositive());
+//                                if (tjOrderDetail11.getIsPositive()==1){
+//                                    break;
+//                                }
+//                            }
+//                            List<TjOrderRemark> lists = remarkService.getTjOrderRemarkListByYjNum(order.getTjNumber());
+//                            if (null != lists && lists.size() > 0) {
+//                                StringBuilder stringBuilder = new StringBuilder();
+//                                for (TjOrderRemark remark : lists) {
+//                                    TjProject byId = projectService.selectTjProjectByProId(remark.getProId());
+//                                    TjOrderDetail one = detailService.getTjOrderDetailByOrderId(String.valueOf(order.getOrderId()), String.valueOf(byId.getProId()));
+//                                    if (one.getFlowingWaterId() != null) {
+//                                        stringBuilder.append(byId.getProName()).append(";");
+//                                    }
+//                                }
+//                                customer.setNotCheckeds(String.valueOf(stringBuilder));
+//                                if (null == customer.getNotCheckeds()) customer.setNotCheckeds("鍏ㄩ儴宸叉");
+//                                customer.setTjStatus(0L);
+//                            } else {
+//                                customer.setNotCheckeds("鏃�");
+//                                customer.setTjStatus(1L);
+//                            }
+//                            if (order.getTjType().equals("1")) {
+//                                customer.setTjType("鍥綋");
+//                            }
+//                            if (order.getTjType().equals("2")) {
+//                                customer.setTjType("涓汉");
+//                            }
+//                            customer.setTjTime(order.getCreateTime());
+//                            customer.setTjNumber(order.getTjNumber());
+//                            customer.setOrderId(order.getOrderId());
+//                            customer.setIsHz(order.getIsHz());
+//                            customer.setTjCategory(order.getTjCategory());
+//                            list11111.add(customer);
+//                        }
+//                    }
+//                }
+//                if (list11111.size() == 0) {
+//                    return AjaxResult.success("鏆傛棤鏁版嵁");
+//                }
+//                Map<String, Object> map = new HashMap<>();
+//                List<TjCustomer> customers = list11111.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList());
+//                Collections.reverse(customers);
+//                map.put("customers", customers);
+//                map.put("total", list11111.size());
+//                return AjaxResult.success(map);
+//            } else {
+//                return AjaxResult.success("鏆傛棤鏁版嵁");
+//            }
+//        }
+//        List<TjCustomer> customerLists = new ArrayList<>();
+
+//        String key="*";
+//        if(sysUser.isAdmin()){
+//            key="ks"+":*";
+//        }else {
+//            key="ks:"+ksId+":*";
+//        }
+//        ScanOptions options = ScanOptions.scanOptions()
+//                //杩欓噷鎸囧畾姣忔鎵弿key鐨勬暟閲�(寰堝鍗氬鐬庤瑕佹寚瀹欼nteger.MAX_VALUE锛岃繖鏍风殑璇濊窡        keys鏈変粈涔堝尯鍒紵)
+//                .count(10000)
+//                .match(key).build();
+//        RedisSerializer<String> redisSerializer = (RedisSerializer<String>) redisTemplate.getKeySerializer();
+//        0鏈,1宸叉
+        Map<String,Object> map=null;
         if (type == 0) {
-            customerLists = redisCache.getCacheMapValue(ksId + "ks", "wj");
+//            Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize));
+//            List<TjCustomer> customers = new ArrayList<>();
+//            while(cursor.hasNext()){
+//                String s = cursor.next().toString();
+//                TjCustomer wj = redisCache.getCacheMapValue(s,"0");
+//                if(null !=wj){
+//                    customers.add(wj);
+//                }
+//            }
+////            //鍒囪杩欓噷涓�瀹氳鍏抽棴锛屽惁鍒欎細鑰楀敖杩炴帴鏁般�傛姤Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a
+//            cursor.close();
+//            customerLists = redisCache.getCacheMapValue(ksId + "ks", "wj");
+            map = deptService.getSysDeptHyAndYxYjWjCustomerList13("A30", name, tjNumber, 0, page, pageSize);
+//            customerLists = customers;
         }
         if (type == 1) {
-            customerLists = redisCache.getCacheMapValue(ksId + "ks", "yj");
+//            Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize));
+//            List<TjCustomer> customers = new ArrayList<>();
+//            while(cursor.hasNext()){
+//                String s = cursor.next().toString();
+//                TjCustomer wj = redisCache.getCacheMapValue(s,"1");
+//                if(null !=wj){
+//                    customers.add(wj);
+//                }
+//            }
+////            //鍒囪杩欓噷涓�瀹氳鍏抽棴锛屽惁鍒欎細鑰楀敖杩炴帴鏁般�傛姤Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a
+//            cursor.close();
+//            customerLists = redisCache.getCacheMapValue(ksId + "ks", "yj");
+            map = deptService.getSysDeptHyAndYxYjWjCustomerList13("A30", name, tjNumber, 1, page, pageSize);
+//            customerLists = customers;
         }
-        asyncService.dockerSetCustomerLisByRedis(ksproList, String.valueOf(ksId));
-        if (customerLists != null && customerLists.size() > 0) {
-            Collections.reverse(customerLists);
-            List<TjCustomer> customerList = customerLists.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList());
-            Map<String, Object> map = new HashMap<>();
-            map.put("date", customerList);
-            map.put("total", customerLists.size());
-            return AjaxResult.success(map);
-        } else {
-            AjaxResult map = getAjaxResult(type, page, pageSize, ksproList, customerLis);
-            if (map != null) return map;
-            return AjaxResult.success("鏆傛椂娌℃湁鏁版嵁");
-        }
+//        asyncService.dockerSetCustomerLisByRedis(ksproList, String.valueOf(ksId));
+//        AjaxResult map = getAjaxResult(type, page, pageSize, ksproList, customerLis);
+//        if (map != null) return map;
+        return AjaxResult.success(map);
     }
+
+
+    /**
+     * 褰卞儚妫�鏌ラ〉闈㈠垪琛�
+     */
+    @GetMapping("/yingXiangGetProList")
+    @ApiOperation("褰卞儚妫�鏌ラ〉闈㈠垪琛�")
+    public AjaxResult yingXiangGetProList(@ApiParam(value = "浣撴鍗曞彿") @RequestParam(required = false) String tjNumber,
+                                       @ApiParam(value = "0鏈,1宸叉") @RequestParam(defaultValue = "0") Integer type,
+                                       @ApiParam(value = "濮撳悕)") @RequestParam(required = false) String name,
+                                       @ApiParam(value = "椤电爜鏁�(榛樿1)") @RequestParam(defaultValue = "1") Integer page,
+                                       @ApiParam(value = "鏄剧ず鏉℃暟(榛樿10)") @RequestParam(defaultValue = "10") Integer pageSize) {
+/*        String userId = SecurityUtils.getLoginUser().getUserId();
+        Integer ksId = null;
+        SysUser sysUser = null;
+        if (null != userId) {
+            sysUser = userService.getById(Long.valueOf(userId));
+            if (null != sysUser) {
+                ksId = Math.toIntExact(sysUser.getDeptId());
+            }
+        }
+        if (ksId == null) {
+            return AjaxResult.error("璇疯緭鍏ョ瀹d");
+        }
+        //鏍规嵁褰撳墠鐧婚檰鐨勪汉鐨勭瀹d锛岃幏鍙栬绉戝涓嬬殑鎵�鏈夐」鐩�
+        List<Long> postIds = sysUser.getPostIds();
+        List<Long> ksproList = null;
+        if (postIds != null) {
+            for (Long postId : postIds) {
+                LambdaQueryWrapper<SysUserPost> wq111 = new LambdaQueryWrapper<>();
+                wq111.eq(SysUserPost::getPostId, postId);
+                SysUserPost one = userPostService.getOne(wq111);
+                if (one != null) {
+                    SysPost byId = postService.getById(one.getPostId());
+                    if (byId.getPostName().equals("褰曞叆鍛�")) {
+                        ksproList = projectService.getKsTjProjectIdListBydeptId(String.valueOf(ksId));
+
+                    }
+                }
+            }
+        } else {
+            ksproList = projectService.getKsTjProjectIdList();
+        }
+        //绛涢�夊奖鍍忕殑椤圭洰銆� A32褰卞儚
+        if (ksproList.size() == 0) {
+            return AjaxResult.error("璇峰畬鍠勭瀹ら」鐩俊鎭�");
+        }
+        ksproList = ksproList.stream()
+                .filter(element -> element ==1633660948860522589L
+//                        ||  element ==1633660948860522504L
+//                        ||
+//                        element ==1633660948860522507L||  element ==1633660948860522508L
+//                        ||
+//                        element ==1633660948860522515L||  element ==1633660948860522516L
+//                        ||
+//                        element ==1633660948860522517L||  element ==1633660948860522519L
+//                        ||
+//                        element ==1633660948860522524L||  element ==1633660948860522530L
+//                        ||
+//                        element ==1633660948860522531L||  element ==1633660948860522533L
+                )
+                .collect(Collectors.toList());*/
+
+
+//        List<Long> ksproList  = projectService.getYingXiangProId();
+//        List<TjCustomer> customerLis = new ArrayList<>();
+//
+//        //鏍规嵁浣撴鍙锋煡
+//        if (null != tjNumber) {
+//            List<TjOrder> orderList = orderService.getOrderListByLikeTjNum(tjNumber);
+//            if (null == orderList) {
+//                return AjaxResult.success("鏆傛椂娌℃湁鏁版嵁");
+//            }
+//            for (TjOrder order : orderList) {
+//                List<TjOrderDetail> list = Optional.ofNullable(detailService.getTjOrderDetailListByOrderId(String.valueOf(order.getOrderId()))).get();
+//                if (list.size() == 0) {
+//                    continue;
+//                }
+//                LambdaQueryWrapper<TjOrderRemark> wqs = new LambdaQueryWrapper<>();
+//                wqs.eq(TjOrderRemark::getTjNumber, order.getTjNumber());
+//                wqs.in(TjOrderRemark::getType, 0,3);
+//                List<TjOrderRemark> lists = remarkService.list(wqs);
+//                TjCustomer customer = customerService.getById(order.getUserId());
+//                //閬嶅巻椤圭洰 鍒ゆ柇鏄惁鏈夐噸澶ч槼鎬�  鏍囪
+//                for (TjOrderDetail tjOrderDetail11 : list) {
+//                    customer.setIsPositive(tjOrderDetail11.getIsPositive());
+//                    if (tjOrderDetail11.getIsPositive()==1){
+//                        break;
+//                    }
+//                }
+//                customer.setCusName(MatchUtils.hideCusName(customer.getCusName()));
+//                customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone()));
+//                customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard()));
+//                if (null != lists && lists.size() > 0) {
+//                    StringBuilder stringBuilder = new StringBuilder();
+//                    for (TjOrderRemark remark : lists) {
+//                        TjProject byId = projectService.selectTjProjectByProId(remark.getProId());
+//                        TjOrderDetail one = detailService.getTjOrderDetailByOrderId(String.valueOf(order.getOrderId()), String.valueOf(byId.getProId()));
+//                        if (one.getFlowingWaterId() != null) {
+//                            stringBuilder.append(byId.getProName()).append(";");
+//                        }
+//
+//                    }
+//                    customer.setNotCheckeds(String.valueOf(stringBuilder));
+//                    customer.setTjStatus(0L);
+//                } else {
+//                    customer.setTjStatus(1L);
+//                    customer.setNotCheckeds("鏃�");
+//                }
+//                if (order.getTjType().equals("1")) {
+//                    customer.setTjType("鍥綋");
+//                }
+//                if (order.getTjType().equals("2")) {
+//                    customer.setTjType("涓汉");
+//                }
+//                customer.setTjTime(order.getCreateTime());
+//                customer.setTjNumber(order.getTjNumber());
+//                customer.setOrderId(order.getOrderId());
+//                customer.setIsHz(order.getIsHz());
+//                customerLis.add(customer);
+//
+//            }
+//            if (customerLis.size() > 0) {
+//                List<TjCustomer> customerList = customerLis.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList());
+//                Collections.reverse(customerList);
+//                Map<String, Object> map = new HashMap<>();
+//                map.put("date", customerList);
+//                map.put("total", customerLis.size());
+//                return AjaxResult.success(map);
+//            } else {
+//                return AjaxResult.success("鏆傛棤鏁版嵁");
+//            }
+//        }
+//
+//        //鏍规嵁濮撳悕鏌ヨ
+//        if (null != name && !"".equals(name)) {
+//            LambdaQueryWrapper<TjCustomer> wq = new LambdaQueryWrapper<>();
+//            wq.like(TjCustomer::getCusName, name);
+//            List<TjCustomer> list = customerService.list(wq);
+//            List<TjCustomer> list11111 = new ArrayList<>();
+//            if (null != list && list.size() > 0) {
+//                for (TjCustomer customer : list) {
+//                    customer.setCusName(MatchUtils.hideCusName(customer.getCusName()));
+//                    customer.setCusPhone(MatchUtils.hidePhoneNum(customer.getCusPhone()));
+//                    customer.setCusIdcard(MatchUtils.hideIdCardNum(customer.getCusIdcard()));
+//                    List<TjOrder> orderList = orderService.getOrderListByCusId(String.valueOf(customer.getCusId()));
+//                    if (null != orderList && orderList.size() > 0) {
+//                        for (TjOrder order : orderList) {
+//                            List<TjOrderDetail> list111 = Optional.ofNullable(detailService.getTjOrderDetailListByOrderId(String.valueOf(order.getOrderId()))).get();
+//                            if (list111.size() == 0) {
+//                                continue;
+//                            }
+//                            //閬嶅巻椤圭洰 鍒ゆ柇鏄惁鏈夐噸澶ч槼鎬�  鏍囪
+//                            for (TjOrderDetail tjOrderDetail11 : list111) {
+//                                customer.setIsPositive(tjOrderDetail11.getIsPositive());
+//                                if (tjOrderDetail11.getIsPositive()==1){
+//                                    break;
+//                                }
+//                            }
+//                            List<TjOrderRemark> lists = remarkService.getTjOrderRemarkListByYjNum(order.getTjNumber());
+//                            if (null != lists && lists.size() > 0) {
+//                                StringBuilder stringBuilder = new StringBuilder();
+//                                for (TjOrderRemark remark : lists) {
+//                                    TjProject byId = projectService.selectTjProjectByProId(remark.getProId());
+//                                    TjOrderDetail one = detailService.getTjOrderDetailByOrderId(String.valueOf(order.getOrderId()), String.valueOf(byId.getProId()));
+//                                    if (one.getFlowingWaterId() != null) {
+//                                        stringBuilder.append(byId.getProName()).append(";");
+//                                    }
+//                                }
+//                                customer.setNotCheckeds(String.valueOf(stringBuilder));
+//                                if (null == customer.getNotCheckeds()) customer.setNotCheckeds("鍏ㄩ儴宸叉");
+//                                customer.setTjStatus(0L);
+//                            } else {
+//                                customer.setNotCheckeds("鏃�");
+//                                customer.setTjStatus(1L);
+//                            }
+//                            if (order.getTjType().equals("1")) {
+//                                customer.setTjType("鍥綋");
+//                            }
+//                            if (order.getTjType().equals("2")) {
+//                                customer.setTjType("涓汉");
+//                            }
+//                            customer.setTjTime(order.getCreateTime());
+//                            customer.setTjNumber(order.getTjNumber());
+//                            customer.setOrderId(order.getOrderId());
+//                            customer.setIsHz(order.getIsHz());
+//                            list11111.add(customer);
+//                        }
+//                    }
+//                }
+//                if (list11111.size() == 0) {
+//                    return AjaxResult.success("鏆傛棤鏁版嵁");
+//                }
+//                Map<String, Object> map = new HashMap<>();
+//                List<TjCustomer> customers = list11111.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList());
+//                Collections.reverse(customers);
+//                map.put("customers", customers);
+//                map.put("total", list11111.size());
+//                return AjaxResult.success(map);
+//            } else {
+//                return AjaxResult.success("鏆傛棤鏁版嵁");
+//            }
+//        }
+//        List<TjCustomer> customerLists = null;
+        Map<String,Object> map=null;
+        if (type == 0) {
+//            Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize));
+//            List<TjCustomer> customers = new ArrayList<>();
+//            while(cursor.hasNext()){
+//                String s = cursor.next().toString();
+//                TjCustomer wj = redisCache.getCacheMapValue(s,"0");
+//                if(null !=wj){
+//                    customers.add(wj);
+//                }
+//            }
+////            //鍒囪杩欓噷涓�瀹氳鍏抽棴锛屽惁鍒欎細鑰楀敖杩炴帴鏁般�傛姤Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a
+//            cursor.close();
+//            customerLists = redisCache.getCacheMapValue(ksId + "ks", "wj");
+            map = deptService.getSysDeptHyAndYxYjWjCustomerList13("A32", name, tjNumber, 0, page, pageSize);
+//            customerLists = customers;
+        }
+        if (type == 1) {
+//            Cursor cursor = redisTemplate.executeWithStickyConnection(redisConnection -> new ConvertingCursor<>(redisConnection.scan(options), redisSerializer::deserialize));
+//            List<TjCustomer> customers = new ArrayList<>();
+//            while(cursor.hasNext()){
+//                String s = cursor.next().toString();
+//                TjCustomer wj = redisCache.getCacheMapValue(s,"1");
+//                if(null !=wj){
+//                    customers.add(wj);
+//                }
+//            }
+////            //鍒囪杩欓噷涓�瀹氳鍏抽棴锛屽惁鍒欎細鑰楀敖杩炴帴鏁般�傛姤Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisException: Could not get a
+//            cursor.close();
+//            customerLists = redisCache.getCacheMapValue(ksId + "ks", "yj");
+            map = deptService.getSysDeptHyAndYxYjWjCustomerList13("A32", name, tjNumber, 1, page, pageSize);
+//            customerLists = customers;
+        }
+//        asyncService.dockerSetCustomerLisByRedis(ksproList, String.valueOf(ksId));
+//        if (customerLists.size() > 0) {
+//            Collections.reverse(customerLists);
+//            List<TjCustomer> customerList = customerLists.stream().skip((long) (page - 1) * pageSize).limit(pageSize).collect(Collectors.toList());
+//            Map<String, Object> map = new HashMap<>();
+//            map.put("date", customerList);
+//            map.put("total", customerLists.size());
+//            return AjaxResult.success(map);
+//        } else {
+//            AjaxResult map = getAjaxResult(type, page, pageSize, ksproList, customerLis);
+//            if (map != null) return map;
+//            return AjaxResult.success("鏆傛椂娌℃湁鏁版嵁");
+        return AjaxResult.success(map);
+//        }
+    }
+
+
+    @GetMapping("/getTjYxjcList")
+    @ApiOperation("鏌ヨ涓汉褰卞搷妫�鏌ラ」鐩粨鏋滈泦")
+    public AjaxResult getTjYxjcList(@ApiParam(value = "濮撳悕") @RequestParam String patname,
+                                    @ApiParam(value = "鎬у埆") @RequestParam String sex,
+                                    @ApiParam(value = "骞撮緞") @RequestParam String patage,
+                                    @ApiParam(value = "骞撮緞鍗曚綅") @RequestParam String patagename,
+                                    @ApiParam(value = "鐢熸棩)") @RequestParam Date patbirth) {
+
+        String format = DateUtil.format(patbirth, "yyyy.MM.dd");
+
+        List<Map<String, Object>> tjYxjcList = testMapper.getTjYxjcList(patname,sex,null);
+        return AjaxResult.success(tjYxjcList);
+    }
+
+
+//    @GetMapping("/getSsTjYxjcList")
+//    @ApiOperation("鏌ヨ涓汉褰卞搷妫�鏌ラ」鐩粨鏋滈泦(鎼滅礌鐢�)")
+//    public AjaxResult getSsTjYxjcList(@ApiParam(value = "濮撳悕") @RequestParam String patname,
+//                                    @ApiParam(value = "鎬у埆") @RequestParam String sex,
+//                                    @ApiParam(value = "骞撮緞") @RequestParam String patage) {
+//
+//
+//        List<Map<String, Object>> tjYxjcList = testMapper.getTjYxjcList(patname,sex,null,null);
+//        return AjaxResult.success(tjYxjcList);
+//    }
 
 
 
@@ -837,7 +1305,6 @@
 
             final TjCustomer byId1 = customerService.getById(order.getUserId());
             if (null != tjOrderDetailList && tjOrderDetailList.size() > 0) {
-                // TODO: 2023/8/31 瀛樺叆姣忎竴灏忛」鐨勭粨鏋滃拰缁撹
                 //----------------------------------start
                 for (TjOrderDetail tjOrderDetail : tjOrderDetailList) {
                     final TjProject byId = projectService.getById(tjOrderDetail.getProId());
@@ -1171,6 +1638,14 @@
     }
 
 
+    @GetMapping("/deptTree111")
+    @ApiOperation("鑾峰彇閮ㄩ棬鏍戝垪琛�1111111111")
+    public AjaxResult deptTree111(SysDept dept) {
+        final List<TreeSelect> treeSelects = deptService.selectDeptTreeList1(dept);
+        return success(treeSelects);
+    }
+
+
     /**
      * 鑾峰彇瀛愮瀹ら儴闂ㄥ垪琛�
      */

--
Gitblit v1.8.0