定时检测超时任务

chenhang4442024
1 parent 672e7fe2
Showing 1 changed file with 62 additions and 122 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.*;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -17,6 +18,7 @@ import freemarker.template.TemplateException;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
+
 import javax.annotation.Resource;
 import javax.mail.MessagingException;
 import java.io.IOException;
@@ -25,13 +27,13 @@ import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.time.temporal.ChronoUnit;
 import java.util.*;
+import java.util.concurrent.TimeUnit;
 import java.util.function.Function;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.stream.Collectors;
-
 /**
  * @author: xms
  * @description: TODO
@@ -69,17 +71,14 @@ 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 1 * * ?")
-        //存储的日期都必须为yyyy-MM-dd HH:mm:ss。
+    @Scheduled(cron = "0 0 1 * * ?")
+    //存储的日期都必须为yyyy-MM-dd HH:mm:ss。
     public void checkOverTimeExecuteV2() throws MessagingException, TemplateException, IOException {
         List<OrderBaseInfoDO> orderBaseInfoDOList = orderBaseInfoService.getEventList();
-        if(CollectionUtils.isNotEmpty(orderBaseInfoDOList)){
+        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));
@@ -100,28 +99,23 @@ public class OrderOverTimeEventJob {
      */
     //发送邮件。
     private void sendEmail4OrderEvent(OrderEventEnum eventEnum, List<OrderEventJobVO> eventJobVOS) throws MessagingException, TemplateException, IOException {
-        List<ReceiveEmailMappingDO> allMappings = receiveEmailMappingService.list();
-        //存储 customerCode
-        Set<String> customerCodes = new HashSet<>();
-        // 遍历 eventJobVOS，添加不在 Redis 中的 customerCode
+
+        HashSet<String> strings = new HashSet<>();
         for (OrderEventJobVO orderEventJob : eventJobVOS) {
-            String cacheKey = EmailTemplateEnum.byTemplate(eventEnum.getTemplateId())
-                    + Constant.CROSS_BAR_CHARACTER
-                    + orderEventJob.getBaseInfo().getId();
-            if (!redisUtils.hasKey(cacheKey)) {
-                customerCodes.add(orderEventJob.getBaseInfo().getCustomerCode());
+            if (!redisUtils.hasKey(EmailTemplateEnum.byTemplate(
+                    eventEnum.getTemplateId()) + Constant.CROSS_BAR_CHARACTER + orderEventJob.getBaseInfo().getId())) {
+                strings.add(orderEventJob.getBaseInfo().getCustomerCode());
             }
         }
-
-        // 过滤 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());
+        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);
         Set<Map<String, List<String>>> set = receiveEmailMappingDOList.stream().map(x -> {
             Map<String, List<String>> map = new HashMap<>();
@@ -145,7 +139,7 @@ public class OrderOverTimeEventJob {
                             map.get(map.keySet().iterator().next()), orderEventJob);
                     redisUtils.set(EmailTemplateEnum.byTemplate(
                                     eventEnum.getTemplateId()) + Constant.CROSS_BAR_CHARACTER + orderEventJob.getBaseInfo().getId(),
-                            orderEventJob);
+                            orderEventJob, 90, TimeUnit.DAYS);
                 }
             }
         }
@@ -176,7 +170,7 @@ public class OrderOverTimeEventJob {
                         orderEventJobVO.setBaseInfo(orderBaseInfoVO);
                         orderEventJobVO.setTrackStageInfo(orderTrackStageVO);
                         return orderEventJobVO;
-                    }else{
+                    } else {
                         return null;
                     }
                 }).filter(Objects::nonNull)
@@ -237,7 +231,6 @@ public class OrderOverTimeEventJob {
         if (filterEndCheckDateEvent(eventJobVO)) {
             map.put(OrderEventEnum.END_CHECK_DATE_EVENT.getEvent(), eventJobVO);
         }
-        // todo 其他订单超期事件判断  中期验货报告和尾期验货报告。
         return map;
     }
@@ -246,24 +239,13 @@ public class OrderOverTimeEventJob {
      * @return
      */
     private Boolean filterConfirmSampleOrderEvent(OrderEventJobVO eventJobVO) {
-
-        // todo 判断是否未能在规定的期限内完成以下货号的确认样确认
         String orderHodTime = eventJobVO.getBaseInfo().getOrderHodTime();
+        String ppConfirmTime = eventJobVO.getTrackStageInfo().getPpConfirmTime();
         String ppConfirmResult = eventJobVO.getTrackStageInfo().getPpConfirmResult();
-        if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(ppConfirmResult)) {
-            if (!ppConfirmResult.contains("ok") && org.apache.commons.lang3.StringUtils.countMatches(ppConfirmResult, "fail") == 3) {
+        if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(ppConfirmResult) && StringUtils.isNotBlank(ppConfirmTime)) {
+            int daysBetween = getDaysBetween(ppConfirmResult, ppConfirmTime, orderHodTime);
+            if (daysBetween == Constant.TWENTY_FIRST || daysBetween == Constant.NEGATIVE_ONE) {
                 return true;
-            } else if (ppConfirmResult.contains("ok") || org.apache.commons.lang3.StringUtils.countMatches(ppConfirmResult, "fail") < 3) {
-                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;
-
-                }
             }
         }
         return false;
@@ -273,16 +255,12 @@ public class OrderOverTimeEventJob {
         String orderHodTime = eventJobVO.getBaseInfo().getOrderHodTime();
         String esoSampleSendTime = eventJobVO.getTrackStageInfo().getEsoSampleSendTime();
         if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(esoSampleSendTime)) {
-            //把订单中的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) {
+            LocalDate orderHodTimelocalDate = DateUtils.parseDate(orderHodTime);
+            LocalDate esoSampleSendTimelocalDate = DateUtils.parseDate(esoSampleSendTime);
+            if (ChronoUnit.DAYS.between(esoSampleSendTimelocalDate, orderHodTimelocalDate) == Constant.SEVEN) {
                 return true;
             }
+
         }
         return false;
     }
@@ -290,19 +268,11 @@ public class OrderOverTimeEventJob {
     private Boolean filterBigSampleEvent(OrderEventJobVO eventJobVO) {
         String orderHodTime = eventJobVO.getBaseInfo().getOrderHodTime();
         String shippmentSampleConfirmResult = eventJobVO.getTrackStageInfo().getShippmentSampleConfirmResult();
-        if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(shippmentSampleConfirmResult)) {
-            if (!shippmentSampleConfirmResult.contains("ok") && org.apache.commons.lang3.StringUtils.countMatches(shippmentSampleConfirmResult, "fail") == 3) {
+        String shippmentSampleConfirmTime = eventJobVO.getTrackStageInfo().getShippmentSampleSendTime();
+        if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(shippmentSampleConfirmResult) && StringUtils.isNotBlank(shippmentSampleConfirmTime)) {
+            int daysBetween = getDaysBetween(shippmentSampleConfirmResult, shippmentSampleConfirmTime, orderHodTime);
+            if (daysBetween == Constant.SEVEN || daysBetween == Constant.NEGATIVE_ONE) {
                 return true;
-            } else if (shippmentSampleConfirmResult.contains("ok") || org.apache.commons.lang3.StringUtils.countMatches(shippmentSampleConfirmResult, "fail") < 3) {
-                //把订单中的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;
-                }
             }
         }
         return false;
@@ -311,28 +281,20 @@ public class OrderOverTimeEventJob {
     private Boolean filterAITEXSGSTestEvent(OrderEventJobVO eventJobVO) {
         String orderHodTime = eventJobVO.getBaseInfo().getOrderHodTime();
-        String shippmentSampleConfirmResult = eventJobVO.getTrackStageInfo().getAitexTestFinishResult();
+        String aitexTestFinishResult = eventJobVO.getTrackStageInfo().getAitexTestFinishResult();
         String sgsTestFinishResult = eventJobVO.getTrackStageInfo().getSgsTestFinishResult();
-        if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(shippmentSampleConfirmResult) ||
-                StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(sgsTestFinishResult)) {
-            if (!shippmentSampleConfirmResult.contains("ok") && org.apache.commons.lang3.StringUtils.countMatches(shippmentSampleConfirmResult, "fail") == 3 ||
-                    !shippmentSampleConfirmResult.contains("ok") && org.apache.commons.lang3.StringUtils.countMatches(sgsTestFinishResult, "fail") == 3) {
+        String sgsTestFinishTime = eventJobVO.getTrackStageInfo().getSgsTestFinishTime();
+        String aitexTestFinishTime = eventJobVO.getTrackStageInfo().getAitexTestFinishTime();
+        if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(aitexTestFinishResult) && StringUtils.isNotBlank(aitexTestFinishTime) ||
+                StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(sgsTestFinishResult) && StringUtils.isNotBlank(sgsTestFinishTime)) {
+            int aitextestDaysBetween = getDaysBetween(aitexTestFinishResult, aitexTestFinishTime, orderHodTime);
+            int sgstestDaysBetween = getDaysBetween(sgsTestFinishResult, sgsTestFinishTime, orderHodTime);
+            if (aitextestDaysBetween == Constant.THREE || sgstestDaysBetween == Constant.LOCK_ERROR_TIMES || aitextestDaysBetween == Constant.NEGATIVE_ONE || sgstestDaysBetween == Constant.NEGATIVE_ONE) {
                 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[] 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) {
-                    return true;
-                }
             }
         }
         return false;
+
     }
@@ -340,13 +302,9 @@ public class OrderOverTimeEventJob {
         String orderHodTime = eventJobVO.getBaseInfo().getOrderHodTime();
         String lastArrivalTime = eventJobVO.getTrackStageInfo().getLatestArrivalTime();
         if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(lastArrivalTime)) {
-            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) {
+            LocalDate orderHodTimelocalDate = DateUtils.parseDate(orderHodTime);
+            LocalDate lastArrivalTimelocalDate = DateUtils.parseDate(lastArrivalTime);
+            if (ChronoUnit.DAYS.between(lastArrivalTimelocalDate, orderHodTimelocalDate) == Constant.SEVEN) {
                 return true;
             }
         }
@@ -357,56 +315,38 @@ public class OrderOverTimeEventJob {
         String orderHodTime = eventJobVO.getBaseInfo().getOrderHodTime();
         String latestBkTime = eventJobVO.getTrackStageInfo().getLatestBkTime();
         if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(latestBkTime)) {
-            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) {
+            LocalDate latestBkTimelocalDate = DateUtils.parseDate(latestBkTime);
+            LocalDate orderHodTimelocalDate = DateUtils.parseDate(orderHodTime);
+            if (ChronoUnit.DAYS.between(latestBkTimelocalDate, orderHodTimelocalDate) == Constant.ENABLE_TEN) {
                 return true;
             }
         }
         return false;
+
     }
     private Boolean filterEndCheckDateEvent(OrderEventJobVO eventJobVO) {
         String orderHodTime = eventJobVO.getBaseInfo().getOrderHodTime();
         String endCheckApplyTime = eventJobVO.getInspectionStageInfo().getEndCheckApplyTime();
         if (StringUtils.isNotBlank(orderHodTime) && StringUtils.isNotBlank(endCheckApplyTime)) {
-            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) {
+            LocalDate endCheckApplyTimelocalDate = DateUtils.parseDate(endCheckApplyTime);
+            LocalDate orderHodTimelocalDate = DateUtils.parseDate(orderHodTime);
+            if (ChronoUnit.DAYS.between(endCheckApplyTimelocalDate, orderHodTimelocalDate) == Constant.TWO) {
                 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;
-                }
-            }
+
+    public int getDaysBetween(String resultStatus, String startDateStr, String orderHodTime) {
+        if (!resultStatus.contains("ok") && resultStatus.startsWith("3")) {
+            return Constant.NEGATIVE_ONE;
+        } else if (!resultStatus.contains("ok") && (resultStatus.startsWith("2") || resultStatus.startsWith("1"))) {
+            LocalDate ppConfirmTimeDate = DateUtils.parseDate(startDateStr);
+            LocalDate orderHodTimeDate = DateUtils.parseDate(orderHodTime);
+            return (int) ChronoUnit.DAYS.between(ppConfirmTimeDate, orderHodTimeDate);
         }
-        // 转换为 LocalDate，去掉时分秒
-       return  (latestDateBeforeOk != null) ? latestDateBeforeOk.toLocalDate() : null;
+        return Constant.ZERO;
     }
-
 }