楚江ERP-自动生成发货计划

@@ -2,6 +2,7 @@ package com.lframework.xingyun.sc.controller.shipments;
 
 import com.lframework.starter.web.core.controller.DefaultBaseController;
 import com.lframework.xingyun.sc.bo.shipments.plan.ShipmentsPlanBo;
+import com.lframework.xingyun.sc.service.shipments.ShipmentsPlanDetailService;
 import com.lframework.xingyun.sc.vo.shipments.plan.QueryShipmentsPlanVo;
 import com.lframework.xingyun.sc.service.shipments.ShipmentsPlanService;
 import com.lframework.xingyun.sc.vo.shipments.plan.UpdateShipmentsPlanVo;
@@ -19,6 +20,7 @@ import io.swagger.annotations.ApiOperation;
 import com.lframework.starter.common.utils.CollectionUtil;
 import io.swagger.annotations.Api;
 import com.lframework.starter.web.core.annotations.security.HasPermission;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
@@ -39,6 +41,8 @@ public class ShipmentsPlanController extends DefaultBaseController {
 
     @Resource
     private ShipmentsPlanService shipmentsPlanService;
+    @Resource
+    private ShipmentsPlanDetailService shipmentsPlanDetailService;
 
 
     /**
@@ -84,4 +88,13 @@ public class ShipmentsPlanController extends DefaultBaseController {
         shipmentsPlanService.update(vo);
         return InvokeResultBuilder.success();
     }
+
+    /**
+     * 自动生成发货计划
+     */
+    @Scheduled(cron = "0 10 1 * * ?")
+    @GetMapping("/autoCreateShipmentPlan")
+    public void autoCreateShipmentPlan() {
+        shipmentsPlanDetailService.autoCreateShipmentPlan();
+    }
 }

@@ -30,8 +30,8 @@ import org.springframework.transaction.annotation.Transactional;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
-import java.util.Collections;
-import java.util.List;
+import java.time.LocalDate;
+import java.util.*;
 
 @Service
 public class PurchaseOrderLineServiceImpl extends BaseMpServiceImpl<PurchaseOrderLineMapper, PurchaseOrderLine> implements PurchaseOrderLineService {
@@ -282,6 +282,18 @@ public class PurchaseOrderLineServiceImpl extends BaseMpServiceImpl<PurchaseOrde
     }
 
     @Override
+    public List<PurchaseOrderLine> listByShipmentDate(List<LocalDate> shipmentDateList) {
+        if (CollectionUtils.isEmpty(shipmentDateList)) {
+            return Collections.emptyList();
+        }
+        // 根据日期批量查询
+        LambdaQueryWrapper<PurchaseOrderLine> queryWrapper = Wrappers.lambdaQuery(PurchaseOrderLine.class);
+        queryWrapper.in(PurchaseOrderLine::getDeliveryDate, shipmentDateList);
+
+        return getBaseMapper().selectList(queryWrapper);
+    }
+
+    @Override
     public void cleanCacheByKey(Serializable key) {
 
     }

@@ -5,6 +5,10 @@ import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.pagehelper.PageInfo;
 import com.lframework.starter.web.core.components.security.SecurityUtil;
+import com.lframework.xingyun.basedata.entity.Workshop;
+import com.lframework.xingyun.basedata.service.workshop.WorkshopService;
+import com.lframework.xingyun.basedata.vo.workshop.QueryWorkshopVo;
+import com.lframework.xingyun.sc.entity.PurchaseOrderInfo;
 import com.lframework.xingyun.sc.entity.PurchaseOrderLine;
 import com.lframework.xingyun.sc.entity.ShipmentsPlan;
 import com.lframework.xingyun.sc.entity.ShipmentsPlanDetail;
@@ -20,6 +24,7 @@ import com.lframework.starter.web.core.utils.PageHelperUtil;
 import com.lframework.starter.common.utils.Assert;
 import com.lframework.starter.web.inner.components.oplog.OtherOpLogType;
 import com.lframework.xingyun.sc.mappers.ShipmentsPlanDetailMapper;
+import com.lframework.xingyun.sc.service.order.PurchaseOrderInfoService;
 import com.lframework.xingyun.sc.service.order.PurchaseOrderLineService;
 import com.lframework.xingyun.sc.service.shipments.ShipmentsPlanDetailService;
 import com.lframework.xingyun.sc.service.shipments.ShipmentsPlanService;
@@ -36,8 +41,10 @@ import javax.annotation.Resource;
 import java.math.BigDecimal;
 import java.time.LocalDate;
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.function.Function;
 import java.util.stream.Collectors;
 
 @Service
@@ -48,6 +55,10 @@ public class ShipmentsPlanDetailServiceImpl extends BaseMpServiceImpl<ShipmentsP
     private PurchaseOrderLineService purchaseOrderLineService;
     @Resource
     private ShipmentsPlanService shipmentsPlanService;
+    @Resource
+    private WorkshopService workshopService;
+    @Resource
+    private PurchaseOrderInfoService purchaseOrderInfoService;
 
 
     @Override
@@ -207,6 +218,69 @@ public class ShipmentsPlanDetailServiceImpl extends BaseMpServiceImpl<ShipmentsP
         purchaseOrderLineService.batchAdd(orderLineList);
     }
 
+    @Override
+    public void autoCreateShipmentPlan() {
+        // 获取所有厂房
+        List<Workshop> workshopList = workshopService.query(new QueryWorkshopVo());
+        LocalDate tomorrow = LocalDate.now().plusDays(1);
+        LocalDate afTomorrow = LocalDate.now().plusDays(2);
+        // 获取所有明日、后日需要发货的订货单规格数据
+        List<LocalDate> dateList = new ArrayList<>();
+        dateList.add(tomorrow);
+        dateList.add(afTomorrow);
+        List<PurchaseOrderLine> orderLineList = purchaseOrderLineService.listByShipmentDate(dateList);
+        // 获取订货单数据
+        Map<String, PurchaseOrderInfo> orderInfoMap = new HashMap<>();
+        if (CollectionUtils.isNotEmpty(orderLineList)) {
+            List<String> orderIds = orderLineList.stream().map(PurchaseOrderLine::getPurchaseOrderId).collect(Collectors.toList());
+            List<PurchaseOrderInfo> orderInfoList = purchaseOrderInfoService.listByIds(orderIds);
+            if (CollectionUtils.isNotEmpty(orderInfoList)) {
+                orderInfoMap = orderInfoList.stream().collect(Collectors.toMap(PurchaseOrderInfo::getId, Function.identity()));
+            }
+        }
+        for (Workshop workshop : workshopList) {
+            // 生成发货计划
+            ShipmentsPlan plan = new ShipmentsPlan();
+            plan.setId(IdUtil.getId());
+            plan.setStatus("DRAFT");
+            plan.setWorkshopId(workshop.getId());
+            plan.setTomoPreShipDate(tomorrow);
+            plan.setAfTomoPreShipDate(afTomorrow);
+
+            shipmentsPlanService.getBaseMapper().insert(plan);
+            // 生成发货计划明细
+            if (CollectionUtils.isNotEmpty(orderLineList)) {
+                List<ShipmentsPlanDetail> planDetails = new ArrayList<>();
+                for (PurchaseOrderLine line : orderLineList) {
+                    ShipmentsPlanDetail detail = new ShipmentsPlanDetail();
+                    detail.setId(IdUtil.getId());
+                    detail.setPlanId(plan.getId());
+                    String orderId = line.getPurchaseOrderId();
+                    detail.setOrderId(orderId);
+                    PurchaseOrderInfo orderInfo = orderInfoMap.get(orderId);
+                    if (orderInfo == null) {
+                        continue;
+                    }
+                    String workshopId = orderInfo.getWorkshopId();
+                    if (!workshop.getId().equals(workshopId)) {
+                        continue;
+                    }
+                    detail.setOrderSpecId(line.getId());
+                    detail.setShipmentsDate(line.getDeliveryDate());
+                    detail.setPreShipments(afTomorrow.equals(line.getDeliveryDate()));
+                    detail.setDelFlag(Boolean.FALSE);
+                    detail.setCreateById("1");
+                    detail.setUpdateById("1");
+
+                    planDetails.add(detail);
+                }
+                if (CollectionUtils.isNotEmpty(planDetails)) {
+                    getBaseMapper().batchAdd(planDetails);
+                }
+            }
+        }
+    }
+
 
     /**
      * 封装发货计划明细数据
@@ -224,6 +298,8 @@ public class ShipmentsPlanDetailServiceImpl extends BaseMpServiceImpl<ShipmentsP
         data.setOrderSpecId(IdUtil.getId());
         data.setParentId(detail.getId());
         data.setShipmentsDate(detail.getShipmentsDate());
+        data.setShipmentsTime(detail.getShipmentsTime());
+        data.setCanShipments(detail.getCanShipments());
         data.setQuantity(quantity);
         data.setPreShipments(Boolean.FALSE);
         data.setCreateById(userId);

@@ -8,6 +8,7 @@ import com.lframework.xingyun.sc.vo.order.QueryPurchaseOrderLineVo;
 import com.lframework.xingyun.sc.vo.order.UpdatePurchaseOrderLineVo;
 
 import java.math.BigDecimal;
+import java.time.LocalDate;
 import java.util.List;
 
 /**
@@ -106,4 +107,12 @@ public interface PurchaseOrderLineService extends BaseMpService<PurchaseOrderLin
      * @param id    主键ID
      */
     void logicDelById(String id);
+
+    /**
+     * 根据发货日期批量查询
+     *
+     * @param shipmentDateList  发货日期
+     * @return                  List<PurchaseOrderLine>
+     */
+    List<PurchaseOrderLine> listByShipmentDate(List<LocalDate> shipmentDateList);
 }

@@ -68,4 +68,9 @@ public interface ShipmentsPlanDetailService extends BaseMpService<ShipmentsPlanD
      * @param vo    条件
      */
     void planDetailSplit(ShipmentsPlanDetailSplitVo vo);
+
+    /**
+     * 自动生成发货计划
+     */
+    void autoCreateShipmentPlan();
 }