From 77b51f625a13a8254eb2e8a9aa53bacf575f7274 Mon Sep 17 00:00:00 2001
From: lige <bestlige@outlook.com>
Date: 星期一, 04 十二月 2023 18:13:49 +0800
Subject: [PATCH] 1

---
 ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java |  158 ++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 157 insertions(+), 1 deletions(-)

diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java
index 36e068a..ac5be6f 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java
@@ -12,6 +12,8 @@
 import com.ltkj.hosp.domain.*;
 import com.ltkj.hosp.service.*;
 import com.ltkj.hosp.vodomain.AddNewReservationConfirm;
+import com.ltkj.hosp.vodomain.LineChartsVo;
+import com.ltkj.hosp.vodomain.PieChartVo;
 import com.ltkj.hosp.vodomain.QjDomainVo;
 import com.ltkj.mall.mallOrderUtils.TjConstants;
 import com.ltkj.system.service.ISysUserService;
@@ -26,6 +28,7 @@
 import java.util.*;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
@@ -913,6 +916,7 @@
     @Async("async")
     public void updateCheckType(String tjNum) {
         redisCache.setCacheMapValue("updateCheckType"+tjNum,tjNum,getAjaxResult(tjNum));
+        redisCache.setHashKeyExpireTime("updateCheckType"+tjNum,7L, TimeUnit.DAYS);
     }
 
     @Override
@@ -939,7 +943,148 @@
         }else {
             redisCache.setCacheMapValue("getOrderDetailByProParentId"+tjNumber,proParentId,getOrderDetailByProParentId(proParentId,tjNumber));
         }
+        redisCache.setHashKeyExpireTime("getOrderDetailByProParentId"+tjNumber,7L,TimeUnit.DAYS);
 
+    }
+
+    @Override
+    @Async("async")
+    public void getLineChart() {
+        redisCache.setCacheObject("getLineChart",getLineCharts());
+    }
+
+    @Override
+    @Async("async")
+    public void getPieChart() {
+        redisCache.setCacheObject("getPieChart",getPieCharts());
+    }
+
+    //棣栭〉楗肩姸鍥剧櫥璁颁汉鏁版帴鍙�
+    private AjaxResult getPieCharts() {
+        Map<String, Object> map = new HashMap<>();
+
+        //鑾峰彇浣撴鐧昏鏁�
+        LambdaQueryWrapper<TjOrder> wq0 = new LambdaQueryWrapper<>();
+        wq0.between(TjOrder::getCreateTime, DateUtil.lastMonth(), DateUtil.now());
+        List<TjOrder> orderCountList = orderService.list(wq0);
+        if (null != orderCountList && orderCountList.size() > 0) {
+            List<PieChartVo> pieChartVoList = getTjorderCountMap(orderCountList);
+            map.put("tjdj", pieChartVoList);
+        } else {
+            map.put("tjdj", 0);
+        }
+        //鑾峰彇浣撴寮傚父鏁�
+        LambdaQueryWrapper<TjOrder> wq1 = new LambdaQueryWrapper<>();
+        wq1.between(TjOrder::getFinishTime, DateUtil.lastMonth(), DateUtil.now());
+        wq1.eq(TjOrder::getCheckStatus, 1);
+        List<TjOrder> orderAbnormalCountList = orderService.list(wq1);
+        if (null != orderAbnormalCountList && orderAbnormalCountList.size() > 0) {
+            List<PieChartVo> pieChartVoList = getTjorderAbnormalCountMap(orderAbnormalCountList);
+            map.put("tjyc", pieChartVoList);
+        } else {
+            map.put("tjyc", 0);
+        }
+
+        return AjaxResult.success(map);
+    }
+
+    //棣栭〉鎶樼嚎鍥炬暟鎹�
+    private AjaxResult getLineCharts() {
+//        List<Map<Object, Object>> line = orderService.getLine();
+        List<LineChartsVo> line = orderService.getLine();
+        Collections.reverse(line);
+        return AjaxResult.success("鎶樼嚎鍥炬暟鎹�", line);
+    }
+
+
+    //鑾峰彇浣撴鐧昏鏁�
+    private List<PieChartVo> getTjorderCountMap(List<TjOrder> orderList) {
+        int a = 0;
+        int b = 0;
+        int c = 0;
+        int d = 0;
+        int e = 0;
+        Map<String, Object> map = null;
+        for (TjOrder tjOrder : orderList) {
+            map = new HashMap<>();
+            TjCustomer customer = tjCustomerService.getById(tjOrder.getUserId());
+            if (null != customer) {
+                int age = DateUtil.ageOfNow(customer.getCusBrithday());
+                if (age >= 0 && age <= 3) {
+                    a += 1;
+                } else if (age > 3 && age <= 16) {
+                    b += 1;
+                } else if (age > 16 && age <= 40) {
+                    c += 1;
+                } else if (age > 40 && age <= 60) {
+                    d += 1;
+                } else {
+                    e += 1;
+                }
+            }
+            map.put("0-3宀�", a);
+            map.put("3-16宀�", b);
+            map.put("16-40宀�", c);
+            map.put("40-60宀�", d);
+            map.put("60宀佷互涓�", e);
+        }
+        List<PieChartVo> pieChartVoList = new ArrayList<>();
+        assert map != null;
+        for (Map.Entry<String, Object> entry : map.entrySet()) {
+            PieChartVo pieChartVo = new PieChartVo();
+            pieChartVo.setName(entry.getKey());
+            pieChartVo.setCount((Integer) entry.getValue());
+            pieChartVoList.add(pieChartVo);
+        }
+        return pieChartVoList;
+    }
+
+    //鑾峰彇浣撴寮傚父鏁�
+    private List<PieChartVo> getTjorderAbnormalCountMap(List<TjOrder> orderList) {
+        int a = 0;
+        int b = 0;
+        int c = 0;
+        int d = 0;
+        int e = 0;
+        Map<String, Object> map = null;
+        for (TjOrder tjOrder : orderList) {
+            map = new HashMap<>();
+            LambdaQueryWrapper<TjOrderDetail> wq = new LambdaQueryWrapper<>();
+            wq.eq(TjOrderDetail::getOrderId, tjOrder.getOrderId());
+            wq.eq(TjOrderDetail::getExceptionDesc, 1);
+            List<TjOrderDetail> list = tjOrderDetailService.list(wq);
+            if (null != list && list.size() > 0) {
+                TjCustomer customer = tjCustomerService.getById(tjOrder.getUserId());
+                if (null != customer) {
+                    int age = DateUtil.ageOfNow(customer.getCusBrithday());
+                    if (age >= 0 && age <= 3) {
+                        a += 1;
+                    } else if (age > 3 && age <= 16) {
+                        b += 1;
+                    } else if (age > 16 && age <= 40) {
+                        c += 1;
+                    } else if (age > 40 && age <= 60) {
+                        d += 1;
+                    } else {
+                        e += 1;
+                    }
+                }
+                map.put("0-3宀�", a);
+                map.put("3-16宀�", b);
+                map.put("16-40宀�", c);
+                map.put("40-60宀�", d);
+                map.put("60宀佷互涓�", e);
+            }
+        }
+        List<PieChartVo> pieChartVoList = new ArrayList<>();
+        assert map != null;
+        for (Map.Entry<String, Object> entry : map.entrySet()) {
+            PieChartVo pieChartVo = new PieChartVo();
+            pieChartVo.setName(entry.getKey());
+            pieChartVo.setCount((Integer) entry.getValue());
+            pieChartVoList.add(pieChartVo);
+        }
+        return pieChartVoList;
     }
 
     private List<DictSfxm> getDictSfxm() {
@@ -1157,6 +1302,8 @@
                         customer.setTjTime(order.getCreateTime());
                         customer.setTjNumber(order.getTjNumber());
                         customer.setTjStatus(1L);
+                        customer.setOrderId(order.getOrderId());
+                        customer.setIsHz(order.getIsHz());
                         LambdaQueryWrapper<TjOrderRemark> wq = new LambdaQueryWrapper<>();
                         wq.eq(TjOrderRemark::getTjNumber, order.getTjNumber());
                         wq.in(TjOrderRemark::getType, 0,3);
@@ -1211,6 +1358,8 @@
                         }
                         customer.setTjTime(order.getCreateTime());
                         customer.setTjNumber(order.getTjNumber());
+                        customer.setOrderId(order.getOrderId());
+                        customer.setIsHz(order.getIsHz());
                         customer.setTjStatus(0L);
                         LambdaQueryWrapper<TjOrderRemark> wq = new LambdaQueryWrapper<>();
                         wq.eq(TjOrderRemark::getTjNumber, order.getTjNumber());
@@ -1352,7 +1501,14 @@
                     String summary = remark.getSummary();
                     if (null != summary) {
                         String[] split = summary.split(";");
-                        parent.put("parentAdvice", tjAdviceService.getAdviceStringByIds(Arrays.asList(split)));
+//                        List<Long> longList = new ArrayList<>();
+//                        for (String str : split) {
+//                            if(!"".equals(str)){
+//                                longList.add(Long.valueOf(str));
+//                            }
+//                        }
+//                        parent.put("parentAdvice", tjAdviceService.getAdviceStringByIds(longList));
+                        parent.put("parentAdvice", tjAdviceService.getAdviceStringsByIds(Arrays.asList(split)));
 
                     } else {
                         parent.put("parentAdvice", null);

--
Gitblit v1.8.0