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