定时检测超时任务

chenhang4442024
1 parent 43458e11
Showing 1 changed file with 109 additions and 62 deletions
src/main/java/com/order/erp/job/OrderOverTimeEventJob.java
 package com.order.erp.job;
 import cn.hutool.core.bean.BeanUtil;
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.TypeReference;
+import com.alibaba.fastjson.*;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.order.erp.common.constant.Constant;
-import com.order.erp.common.utils.EmailSendUtils;
-import com.order.erp.common.utils.RedisUtils;
-import com.order.erp.common.utils.StringUtils;
-import com.order.erp.common.utils.TransactionHelper;
+import com.order.erp.common.utils.*;
 import com.order.erp.domain.EmailTemplateEnum;
 import com.order.erp.domain.OrderEventEnum;
 import com.order.erp.domain.dto.order.OrderBaseInfoDO;
@@ -25,10 +21,13 @@ import javax.annotation.Resource;
 import javax.mail.MessagingException;
 import java.io.IOException;
 import java.time.LocalDate;
+import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoUnit;
 import java.util.*;
 import java.util.function.Function;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
 import java.util.stream.Collectors;
@@ -70,22 +69,29 @@ public class OrderOverTimeEventJob {
     @Resource
     private RedisUtils redisUtils;
+    String dateFormatDay= com.order.erp.common.excel4j.utils.DateUtils.DATE_FORMAT_DAY;
+    String dateFormatSEC= com.order.erp.common.excel4j.utils.DateUtils.DATE_FORMAT_SEC;
+
     /**
      * 凌晨1点执行，一天一次
      */
-        @Scheduled(cron = "0 0 2 * * ?")
+        @Scheduled(cron = "0 0 1 * * ?")
+        //存储的日期都必须为yyyy-MM-dd HH:mm:ss。
     public void checkOverTimeExecuteV2() throws MessagingException, TemplateException, IOException {
         List<OrderBaseInfoDO> orderBaseInfoDOList = orderBaseInfoService.getEventList();
-        Set<Long> orderIds = orderBaseInfoDOList.stream().map(OrderBaseInfoDO::getId).collect(Collectors.toSet());
-        List<OrderInspectionStageDO> orderInspectionStageDOList = inspectionStageService.list(new LambdaQueryWrapper<OrderInspectionStageDO>()
-                .in(OrderInspectionStageDO::getOrderId, orderIds));
-        List<OrderTrackStageDO> orderTrackStageDOList = trackStageService.list(new LambdaQueryWrapper<OrderTrackStageDO>()
-                .in(OrderTrackStageDO::getOrderId, orderIds));
-        List<OrderEventJobVO> jobVOList = transfer2OrderEventList(orderBaseInfoDOList, orderInspectionStageDOList, orderTrackStageDOList);
-        Map<String, List<OrderEventJobVO>> map = handlerOrderEvent(jobVOList);
-        for (Map.Entry<String, List<OrderEventJobVO>> entry : map.entrySet()) {
-            sendEmail4OrderEvent(OrderEventEnum.getEvent(entry.getKey()), entry.getValue());
+        if(CollectionUtils.isNotEmpty(orderBaseInfoDOList)){
+            Set<Long> orderIds = orderBaseInfoDOList.stream().map(OrderBaseInfoDO::getId).collect(Collectors.toSet());
+            List<OrderInspectionStageDO> orderInspectionStageDOList = inspectionStageService.list(new LambdaQueryWrapper<OrderInspectionStageDO>()
+                    .in(OrderInspectionStageDO::getOrderId, orderIds));
+            List<OrderTrackStageDO> orderTrackStageDOList = trackStageService.list(new LambdaQueryWrapper<OrderTrackStageDO>()
+                    .in(OrderTrackStageDO::getOrderId, orderIds));
+            List<OrderEventJobVO> jobVOList = transfer2OrderEventList(orderBaseInfoDOList, orderInspectionStageDOList, orderTrackStageDOList);
+            Map<String, List<OrderEventJobVO>> map = handlerOrderEvent(jobVOList);
+            for (Map.Entry<String, List<OrderEventJobVO>> entry : map.entrySet()) {
+                sendEmail4OrderEvent(OrderEventEnum.getEvent(entry.getKey()), entry.getValue());
+            }
         }
+
     }
     /**
@@ -94,28 +100,28 @@ public class OrderOverTimeEventJob {
      */
     //发送邮件。
     private void sendEmail4OrderEvent(OrderEventEnum eventEnum, List<OrderEventJobVO> eventJobVOS) throws MessagingException, TemplateException, IOException {
-        HashSet<String> strings = new HashSet<>();
+        List<ReceiveEmailMappingDO> allMappings = receiveEmailMappingService.list();
+        //存储 customerCode
+        Set<String> customerCodes = new HashSet<>();
+        // 遍历 eventJobVOS，添加不在 Redis 中的 customerCode
         for (OrderEventJobVO orderEventJob : eventJobVOS) {
-            if (!redisUtils.hasKey(EmailTemplateEnum.byTemplate(
-                    eventEnum.getTemplateId()) + Constant.POINT_BAR_CHARACTER + orderEventJob.getBaseInfo().getId())){
-                strings.add(orderEventJob.getBaseInfo().getCustomerCode());
+            String cacheKey = EmailTemplateEnum.byTemplate(eventEnum.getTemplateId())
+                    + Constant.CROSS_BAR_CHARACTER
+                    + orderEventJob.getBaseInfo().getId();
+            if (!redisUtils.hasKey(cacheKey)) {
+                customerCodes.add(orderEventJob.getBaseInfo().getCustomerCode());
             }
         }
-        LambdaQueryWrapper<ReceiveEmailMappingDO> queryWrapper = new LambdaQueryWrapper<>();
-        queryWrapper.eq(ReceiveEmailMappingDO::getEnableFlag, Constant.ENABLE_TEN);
-        if (strings == null || strings.isEmpty()) {
-            queryWrapper.eq(ReceiveEmailMappingDO::getTypeValue,  " ");
-        } else {
-            queryWrapper.in(ReceiveEmailMappingDO::getTypeValue, strings);
-        }
-        queryWrapper.apply("JSON_CONTAINS(JSON_EXTRACT(config_infos, '$[*].event'), JSON_QUOTE({0}), '$')", eventEnum.getEvent());
-       List<ReceiveEmailMappingDO> receiveEmailMappingDOList = receiveEmailMappingService.list(queryWrapper);
-       /* List<ReceiveEmailMappingDO> receiveEmailMappingDOList = receiveEmailMappingService.list(
-                new LambdaQueryWrapper<ReceiveEmailMappingDO>()
-                .eq(ReceiveEmailMappingDO::getEnableFlag, Constant.ENABLE_TEN)
-                .in(CollectionUtils.isNotEmpty(strings),ReceiveEmailMappingDO::getTypeValue, strings)
-                .apply("JSON_CONTAINS(JSON_EXTRACT(config_infos, '$[*].event'), JSON_QUOTE({0}), '$')", eventEnum.getEvent()));*/
+        // 过滤 ReceiveEmailMappingDO
+        List<ReceiveEmailMappingDO> receiveEmailMappingDOList = allMappings.stream()
+                .filter(mapping -> customerCodes.isEmpty() || customerCodes.contains(mapping.getTypeValue()))
+                .filter(mapping -> {
+                    // 检查 config_infos 是否包含 eventEnum.getEvent()
+                    String configInfos = mapping.getConfigInfos();
+                    return configInfos != null && configInfos.contains(eventEnum.getEvent());
+                })
+                .collect(Collectors.toList());
         Set<Map<String, List<String>>> set = receiveEmailMappingDOList.stream().map(x -> {
             Map<String, List<String>> map = new HashMap<>();
@@ -138,11 +144,10 @@ public class OrderOverTimeEventJob {
                     emailSendUtils.sendEmail(EmailTemplateEnum.byTemplate(eventEnum.getTemplateId()),
                             map.get(map.keySet().iterator().next()), orderEventJob);
                     redisUtils.set(EmailTemplateEnum.byTemplate(
-                                    eventEnum.getTemplateId()) + Constant.POINT_BAR_CHARACTER + orderEventJob.getBaseInfo().getId(),
+                                    eventEnum.getTemplateId()) + Constant.CROSS_BAR_CHARACTER + orderEventJob.getBaseInfo().getId(),
                             orderEventJob);
                 }
             }
-
         }
     }
@@ -159,8 +164,7 @@ public class OrderOverTimeEventJob {
         Map<Long, OrderTrackStageDO> OrderTrackStageMap = orderTrackStageList.stream().collect(Collectors.toMap(OrderTrackStageDO::getOrderId, Function.identity(), (x, y) -> x));
         List<OrderEventJobVO> orderEventJobVOList = orderBaseInfoList.stream().map(x -> {
                     OrderEventJobVO orderEventJobVO = new OrderEventJobVO();
-                    if (x.getId() == OrderInspectionStageMap.get(x.getId()).getOrderId() &&
-                            x.getId() == OrderTrackStageMap.get(x.getId()).getOrderId()) {
+                    if (OrderInspectionStageMap.containsKey(x.getId()) && OrderTrackStageMap.containsKey(x.getId())) {
                         OrderBaseInfoVO orderBaseInfoVO = new OrderBaseInfoVO();
                         OrderTrackStageVO orderTrackStageVO = new OrderTrackStageVO();
                         OrderInspectionStageVO orderInspectionStageVO = new OrderInspectionStageVO();
@@ -171,8 +175,10 @@ public class OrderOverTimeEventJob {
                         orderEventJobVO.setInspectionStageInfo(orderInspectionStageVO);
                         orderEventJobVO.setBaseInfo(orderBaseInfoVO);
                         orderEventJobVO.setTrackStageInfo(orderTrackStageVO);
+                        return orderEventJobVO;
+                    }else{
+                        return null;
                     }
-                    return orderEventJobVO;
                 }).filter(Objects::nonNull)
                 .collect(Collectors.toList());
         return orderEventJobVOList;
@@ -248,13 +254,15 @@ public class OrderOverTimeEventJob {
             if (!ppConfirmResult.contains("ok") && org.apache.commons.lang3.StringUtils.countMatches(ppConfirmResult, "fail") == 3) {
                 return true;
             } else if (ppConfirmResult.contains("ok") || org.apache.commons.lang3.StringUtils.countMatches(ppConfirmResult, "fail") < 3) {
-                String[] parats = ppConfirmResult.split("\\+");
-                String lastTime = parats[parats.length - 3];
-                LocalDate parse1 = LocalDate.parse(lastTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
-                LocalDate parse2 = LocalDate.parse(orderHodTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
+                LocalDate parse1 = findLatestDateBeforeOk(ppConfirmResult);
+                //把订单中的Hod时间yyyy-mm-dd HH:mm:ss改成yyyy-mm-dd。
+                String[] hodTime = orderHodTime.split(" ");
+                String orderhodTime = hodTime[0];
+                LocalDate parse2 = DateUtils.parseDate(orderhodTime, dateFormatDay);
                 long daysBetween = ChronoUnit.DAYS.between(parse1, parse2);
                 if (daysBetween == 21) {
                     return true;
+
                 }
             }
         }
@@ -265,8 +273,13 @@ public class OrderOverTimeEventJob {
         String orderHodTime = eventJobVO.getBaseInfo().getOrderHodTime();
         String esoSampleSendTime = eventJobVO.getTrackStageInfo().getEsoSampleSendTime();
         if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(esoSampleSendTime)) {
-            LocalDate parse1 = LocalDate.parse(esoSampleSendTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
-            LocalDate parse2 = LocalDate.parse(orderHodTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
+            //把订单中的Hod时间yyyy-mm-dd HH:mm:ss改成yyyy-mm-dd。
+            String[] hodTime = orderHodTime.split(" ");
+            String orderhodTime = hodTime[0];
+            LocalDate parse2 = DateUtils.parseDate(orderhodTime, dateFormatDay);
+            LocalDateTime dateTime=LocalDateTime.parse(esoSampleSendTime, DateTimeFormatter.ofPattern(dateFormatSEC));
+            String parse=dateTime.format(DateTimeFormatter.ofPattern(dateFormatDay));
+            LocalDate parse1=DateUtils.parseDate(parse,dateFormatDay);
             if (ChronoUnit.DAYS.between(parse1, parse2) == 7) {
                 return true;
             }
@@ -281,10 +294,11 @@ public class OrderOverTimeEventJob {
             if (!shippmentSampleConfirmResult.contains("ok") && org.apache.commons.lang3.StringUtils.countMatches(shippmentSampleConfirmResult, "fail") == 3) {
                 return true;
             } else if (shippmentSampleConfirmResult.contains("ok") || org.apache.commons.lang3.StringUtils.countMatches(shippmentSampleConfirmResult, "fail") < 3) {
-                String[] parats = shippmentSampleConfirmResult.split("\\+");
-                String lastTime = parats[parats.length - 3];
-                LocalDate parse1 = LocalDate.parse(lastTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
-                LocalDate parse2 = LocalDate.parse(orderHodTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
+                //把订单中的Hod时间yyyy-mm-dd HH:mm:ss改成yyyy-mm-dd。
+                String[] hodTime = orderHodTime.split(" ");
+                String orderhodTime = hodTime[0];
+                LocalDate parse2 = DateUtils.parseDate(orderhodTime, dateFormatDay);
+                LocalDate parse1 = findLatestDateBeforeOk(shippmentSampleConfirmResult);
                 long daysBetween = ChronoUnit.DAYS.between(parse1, parse2);
                 if (daysBetween == 7) {
                     return true;
@@ -306,13 +320,11 @@ public class OrderOverTimeEventJob {
                 return true;
             } else if ((shippmentSampleConfirmResult.contains("ok") || org.apache.commons.lang3.StringUtils.countMatches(shippmentSampleConfirmResult, "fail") < 3) ||
                     (sgsTestFinishResult.contains("ok") || org.apache.commons.lang3.StringUtils.countMatches(sgsTestFinishResult, "fail") < 3)) {
-                String[] parats = shippmentSampleConfirmResult.split("\\+");
-                String lastTime = parats[parats.length - 3];
-                String[] parats1 = sgsTestFinishResult.split("\\+");
-                String lastTime1 = parats1[parats1.length - 3];
-                LocalDate parse1 = LocalDate.parse(lastTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
-                LocalDate parse2 = LocalDate.parse(orderHodTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
-                LocalDate parse3 = LocalDate.parse(lastTime1, DateTimeFormatter.ofPattern("yyyy-M-d"));
+                String[] hodTime = orderHodTime.split(" ");
+                String orderhodTime=hodTime[0];
+                LocalDate parse1 = findLatestDateBeforeOk(shippmentSampleConfirmResult);
+                LocalDate parse2 =  DateUtils.parseDate(orderhodTime, dateFormatDay);
+                LocalDate parse3 = findLatestDateBeforeOk(sgsTestFinishResult);
                 long daysBetween = ChronoUnit.DAYS.between(parse1, parse2);
                 long daysBetween1 = ChronoUnit.DAYS.between(parse3, parse2);
                 if (daysBetween == 3 || daysBetween1 == 3) {
@@ -328,8 +340,12 @@ public class OrderOverTimeEventJob {
         String orderHodTime = eventJobVO.getBaseInfo().getOrderHodTime();
         String lastArrivalTime = eventJobVO.getTrackStageInfo().getLatestArrivalTime();
         if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(lastArrivalTime)) {
-            LocalDate parse1 = LocalDate.parse(lastArrivalTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
-            LocalDate parse2 = LocalDate.parse(orderHodTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
+            String[] hodTime = orderHodTime.split(" ");
+            String orderhodTime=hodTime[0];
+            LocalDate parse2 =  DateUtils.parseDate(orderhodTime, dateFormatDay);
+            LocalDateTime dateTime=LocalDateTime.parse(lastArrivalTime, DateTimeFormatter.ofPattern(dateFormatSEC));
+            String parse=dateTime.format(DateTimeFormatter.ofPattern(dateFormatDay));
+            LocalDate parse1=DateUtils.parseDate(parse,dateFormatDay);
             if (ChronoUnit.DAYS.between(parse1, parse2) == 7) {
                 return true;
             }
@@ -341,8 +357,12 @@ public class OrderOverTimeEventJob {
         String orderHodTime = eventJobVO.getBaseInfo().getOrderHodTime();
         String latestBkTime = eventJobVO.getTrackStageInfo().getLatestBkTime();
         if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(latestBkTime)) {
-            LocalDate parse1 = LocalDate.parse(latestBkTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
-            LocalDate parse2 = LocalDate.parse(orderHodTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
+            String[] hodTime = orderHodTime.split(" ");
+            String orderhodTime=hodTime[0];
+            LocalDate parse2 =  DateUtils.parseDate(orderhodTime, dateFormatDay);
+            LocalDateTime dateTime=LocalDateTime.parse(latestBkTime, DateTimeFormatter.ofPattern(dateFormatSEC));
+            String parse=dateTime.format(DateTimeFormatter.ofPattern(dateFormatDay));
+            LocalDate parse1=DateUtils.parseDate(parse,dateFormatDay);
             if (ChronoUnit.DAYS.between(parse1, parse2) == 10) {
                 return true;
             }
@@ -354,12 +374,39 @@ public class OrderOverTimeEventJob {
         String orderHodTime = eventJobVO.getBaseInfo().getOrderHodTime();
         String endCheckApplyTime = eventJobVO.getInspectionStageInfo().getEndCheckApplyTime();
         if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(endCheckApplyTime)) {
-            LocalDate parse1 = LocalDate.parse(endCheckApplyTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
-            LocalDate parse2 = LocalDate.parse(orderHodTime, DateTimeFormatter.ofPattern("yyyy-M-d"));
+            String[] hodTime = orderHodTime.split(" ");
+            String orderhodTime=hodTime[0];
+            LocalDate parse2 =  DateUtils.parseDate(orderhodTime, dateFormatDay);
+            LocalDateTime dateTime=LocalDateTime.parse(endCheckApplyTime, DateTimeFormatter.ofPattern(dateFormatSEC));
+            String parse=dateTime.format(DateTimeFormatter.ofPattern(dateFormatDay));
+            LocalDate parse1=DateUtils.parseDate(parse,dateFormatDay);
             if (ChronoUnit.DAYS.between(parse1, parse2) == 2) {
                 return true;
             }
         }
         return false;
     }
+
+    public LocalDate findLatestDateBeforeOk(String data){
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern(dateFormatSEC);
+        LocalDateTime latestDateBeforeOk = null;
+        // 正则表达式提取日期和状态
+        Pattern pattern = Pattern.compile("(\\d{4}-\\d{2}-\\d{2} \\d{2}:\\d{2}:\\d{2})\\s+(.*?)(?=\\d{4}-\\d{2}-\\d{2} \\d{2}:\\d{2}:\\d{2}|$)");
+        Matcher matcher = pattern.matcher(data);
+        while (matcher.find()) {
+            LocalDateTime eventDate = LocalDateTime.parse(matcher.group(1), formatter);
+            String status = matcher.group(2);
+            // 查找 "ok" 的位置
+            int okIndex = data.indexOf("ok");
+            if (okIndex != -1 && matcher.start() < okIndex) {
+                // 更新 latestDateBeforeOk 为当前事件的日期，如果当前日期晚于已知的日期
+                if (latestDateBeforeOk == null || eventDate.isAfter(latestDateBeforeOk)) {
+                    latestDateBeforeOk = eventDate;
+                }
+            }
+        }
+        // 转换为 LocalDate，去掉时分秒
+       return  (latestDateBeforeOk != null) ? latestDateBeforeOk.toLocalDate() : null;
+    }
+
 }