feat: 问题修复项

1、修改订单数量更新总价等信息

feat: 问题修复项
1、修改订单数量更新总价等信息
谢茂盛
1 parent 5dd2ab6b
Showing 1 changed file with 70 additions and 3 deletions
src/main/java/com/order/erp/job/OrderJob.java
@@ -5,11 +5,13 @@ import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
 import com.order.erp.common.constant.Constant;
 import com.order.erp.common.utils.DateUtils;
+import com.order.erp.common.utils.ProfitUtils;
 import com.order.erp.common.utils.TransactionHelper;
 import com.order.erp.domain.OrderStatusEnum;
 import com.order.erp.domain.dto.BaseDO;
 import com.order.erp.domain.dto.order.*;
 import com.order.erp.domain.vo.order.OrderInfoResultVO;
+import com.order.erp.domain.vo.order.ProfitCalculateVO;
 import com.order.erp.service.order.*;
 import lombok.extern.slf4j.Slf4j;
 import org.joda.time.DateTime;
@@ -17,9 +19,10 @@ import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import javax.annotation.Resource;
-import java.util.List;
-import java.util.Objects;
-import java.util.Set;
+import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.util.*;
+import java.util.function.Function;
 import java.util.stream.Collectors;
 /**
@@ -95,4 +98,68 @@ public class OrderJob {
         log.info("执行结束时间：{}", DateTime.now().toString("yyyy-MM-dd HH:mm:ss"));
     }
+    /**
+     * 每隔5分执行一次
+     */
+    @Scheduled(cron = "0 */1 * * * ?")
+//    @Scheduled(cron = "*/5 * * * * ?")
+    public void checkChargeOrderCount() {
+        log.info("执行开始时间：{}", DateTime.now().toString("yyyy-MM-dd HH:mm:ss"));
+        LambdaQueryWrapper<OrderBaseInfoDO> queryWrapper = new LambdaQueryWrapper<OrderBaseInfoDO>()
+                .eq(BaseDO::getEnableFlag, Constant.ENABLE_TEN)
+                .ge(OrderBaseInfoDO::getCreateTime, DateUtils.format(DateTime.now().minusMonths(Constant.ONE).toDate(), DateUtils.DATE_TIME))
+                .le(OrderBaseInfoDO::getCreateTime, DateUtils.format(DateTime.now().toDate(), DateUtils.DATE_TIME))
+                .ne(OrderBaseInfoDO::getOrderStatus, OrderStatusEnum.ORDER_FINISH.getStatus());
+        List<OrderBaseInfoDO> ordersDOS = orderBaseInfoService.list(queryWrapper);
+
+        List<OrderInfoResultVO> orderInfoResultVOS = orderBaseInfoService.wrapperOrderResultList(false, ordersDOS);
+        if (CollectionUtils.isNotEmpty(orderInfoResultVOS)) {
+            Set<Long> orderIds = orderInfoResultVOS.stream().map(OrderInfoResultVO::getId).collect(Collectors.toSet());
+            if (CollectionUtils.isNotEmpty(orderIds)) {
+                List<OrderProfitAnalysisDO> profitAnalysisDOS = profitAnalysisService.list(new LambdaQueryWrapper<OrderProfitAnalysisDO>()
+                        .eq(BaseDO::getEnableFlag, Constant.ENABLE_TEN)
+                        .in(OrderProfitAnalysisDO::getOrderId, orderIds));
+
+                Map<Long, OrderProfitAnalysisDO> profitAnalysisDOMap = new HashMap<>();
+                if (CollectionUtils.isNotEmpty(profitAnalysisDOS)) {
+                    profitAnalysisDOMap = profitAnalysisDOS.stream().collect(Collectors.toMap(OrderProfitAnalysisDO::getOrderId, Function.identity(), (x, y) -> y));
+                }
+
+                for (OrderInfoResultVO resultVO : orderInfoResultVOS) {
+                    if (profitAnalysisDOMap.containsKey(resultVO.getId())) {
+                        OrderProfitAnalysisDO profitAnalysisDO = profitAnalysisDOMap.get(resultVO.getId());
+                        Integer orderCount = resultVO.getOrderCount();
+                        BigDecimal customerTotalPrice = new BigDecimal(profitAnalysisDO.getCustomerTotalPrice()).setScale(Constant.TWO, RoundingMode.HALF_UP);
+                        BigDecimal customerPrice = new BigDecimal(profitAnalysisDO.getCustomerPrice()).setScale(Constant.TWO, RoundingMode.HALF_UP);
+
+                        BigDecimal calculateTotalPrice = new BigDecimal(orderCount).multiply(customerPrice).setScale(Constant.TWO, RoundingMode.HALF_UP);
+                        if (customerTotalPrice.compareTo(calculateTotalPrice) != Constant.ZERO) {
+                            BigDecimal customerRmbPrice = new BigDecimal(profitAnalysisDO.getCustomerRmbPrice());
+                            BigDecimal customerRmbTotalPrice = new BigDecimal(orderCount).multiply(customerRmbPrice).setScale(Constant.TWO, RoundingMode.HALF_UP);
+                            BigDecimal productionDepartmentPrice = new BigDecimal(profitAnalysisDO.getProductionDepartmentPrice());
+                            BigDecimal productionDepartmentTotalPrice = new BigDecimal(orderCount).multiply(productionDepartmentPrice).setScale(Constant.TWO, RoundingMode.HALF_UP);
+                            BigDecimal packetPrice = new BigDecimal(profitAnalysisDO.getPacketPrice());
+                            BigDecimal packetTotalPrice = new BigDecimal(orderCount).multiply(packetPrice).setScale(Constant.TWO, RoundingMode.HALF_UP);
+                            Double profitRate = ProfitUtils.calculateProfitRate(ProfitCalculateVO.builder()
+                                    .exchangeRate(profitAnalysisDO.getExchangeRate())
+                                    .profitType(profitAnalysisDO.getProfitType())
+                                    .customerTotalPrice(calculateTotalPrice.doubleValue())
+                                    .productionDepartmentTotalPrice(productionDepartmentTotalPrice.doubleValue())
+                                    .packetTotalPrice(packetTotalPrice.doubleValue()).build());
+
+                            profitAnalysisDO.setCustomerTotalPrice(calculateTotalPrice.doubleValue());
+                            profitAnalysisDO.setCustomerRmbTotalPrice(customerRmbTotalPrice.doubleValue());
+                            profitAnalysisDO.setProductionDepartmentTotalPrice(productionDepartmentTotalPrice.doubleValue());
+                            profitAnalysisDO.setPacketTotalPrice(packetTotalPrice.doubleValue());
+                            profitAnalysisDO.setProfitRate(profitRate);
+                            profitAnalysisService.updateById(profitAnalysisDO);
+                        }
+                    }
+                }
+            }
+        }
+        log.info("执行结束时间：{}", DateTime.now().toString("yyyy-MM-dd HH:mm:ss"));
+    }
+
+
 }