发货：要车单经营办审核人问题处理

@@ -641,6 +641,9 @@ create table if not exists shipments_plan (
     update_time datetime default now() comment '更新时间'
 );
 
+ALTER TABLE `shipments_plan`
+    ADD COLUMN `business_office_auditor` varchar(32) DEFAULT NULL COMMENT '经营办审核人(发货计划提交人)';
+
 -- 发货明细
 drop table if exists `shipments_plan_detail`;
 create table if not exists `shipments_plan_detail` (

@@ -249,6 +249,7 @@ public class ShipmentsOrderInfoController extends DefaultBaseController {
     @Scheduled(cron = "0 8 0 * * ?")
     public InvokeResult<Void> dataHandler() {
         // 只处理今日应该发货但状态仍是未发货的数据，避免已签收/已发货的数据被重复处理
+        log.info("=========定时任务开始执行========");
         List<ShipmentsOrderInfo> shipmentsOrderInfoList = shipmentsOrderInfoService.queryUnShipmentsByShipmentDate(LocalDate.now());
         if (CollectionUtils.isNotEmpty(shipmentsOrderInfoList)) {
             for (ShipmentsOrderInfo  orderInfo : shipmentsOrderInfoList) {

@@ -58,6 +58,11 @@ public class ShipmentsPlan extends BaseEntity implements BaseDto {
     private Boolean autoGenerate;
 
     /**
+     * 经营办审核人(发货计划提交人)
+     */
+    private String businessOfficeAuditor;
+
+    /**
      * 创建人ID
      */
     @TableField(fill = FieldFill.INSERT)

@@ -116,6 +116,10 @@ public class ShipmentsPlanServiceImpl extends BaseMpServiceImpl<ShipmentsPlanMap
         LambdaUpdateWrapper<ShipmentsPlan> updateWrapper = Wrappers.lambdaUpdate(ShipmentsPlan.class)
                 .set(ShipmentsPlan::getStatus, vo.getStatus())
                 .eq(ShipmentsPlan::getId, vo.getId());
+        // 状态为审核中(CHECKING)时，记录当前提交人作为经营办审核人
+        if ("CHECKING".equals(vo.getStatus())) {
+            updateWrapper.set(ShipmentsPlan::getBusinessOfficeAuditor, SecurityUtil.getCurrentUser().getId());
+        }
 
         getBaseMapper().update(updateWrapper);
 

@@ -20,6 +20,7 @@ import com.lframework.starter.common.utils.Assert;
 import com.lframework.starter.web.inner.components.oplog.OtherOpLogType;
 import com.lframework.xingyun.sc.entity.*;
 import com.lframework.xingyun.sc.mappers.CarRequestPlanMapper;
+import com.lframework.xingyun.sc.service.shipments.ShipmentsPlanService;
 import com.lframework.xingyun.sc.service.shipments.car.CarRequestPlanService;
 import com.lframework.xingyun.sc.service.shipments.car.DraftRequestCarTicketService;
 import com.lframework.xingyun.sc.service.shipments.car.RequestCarTicketService;
@@ -44,6 +45,8 @@ public class CarRequestPlanServiceImpl extends BaseMpServiceImpl<CarRequestPlanM
     private RequestCarTicketService requestCarTicketService;
     @Resource
     private DraftRequestCarTicketService draftRequestCarTicketService;
+    @Resource
+    private ShipmentsPlanService shipmentsPlanService;
 
     @Override
     public PageResult<CarRequestPlan> query(Integer pageIndex, Integer pageSize, QueryCarRequestPlanVo vo) {
@@ -157,6 +160,11 @@ public class CarRequestPlanServiceImpl extends BaseMpServiceImpl<CarRequestPlanM
         List<DraftRequestCarTicket> draftTickets = draftRequestCarTicketService.listByOrderId(orderIds);
         Map<String, DraftRequestCarTicket> draftTicketMap = draftTickets.stream().collect(Collectors.toMap(DraftRequestCarTicket::getPurchaseOrderId, Function.identity()
                 , (v1, v2) -> v2));
+        // 获取发货计划，取经营办审核人(发货计划提交人)
+        ShipmentsPlan shipmentsPlan = null;
+        if (StringUtil.isNotBlank(shipmentsOrderInfo.getPlanId())) {
+            shipmentsPlan = shipmentsPlanService.findById(shipmentsOrderInfo.getPlanId());
+        }
         for (PurchaseOrderInfo orderInfo : orderInfoList) {
             // 生成要车计划
             LocalDate requestCarDate = shipmentsOrderInfo.getShipmentsDate();
@@ -185,8 +193,8 @@ public class CarRequestPlanServiceImpl extends BaseMpServiceImpl<CarRequestPlanM
             ticketVo.setShipmentsOrderId(shipmentsOrderInfo.getId());
             // 外办审核人(草稿要车单审核人)
             ticketVo.setExternalAuditor(draftTicket.getExternalAuditor());
-            // 经营办审核人(发货计划提交人)
-            ticketVo.setBusinessOfficeAuditor(SecurityUtil.getCurrentUser().getId());
+            // 经营办审核人(发货计划提交人，取自发货计划)
+            ticketVo.setBusinessOfficeAuditor(shipmentsPlan != null ? shipmentsPlan.getBusinessOfficeAuditor() : null);
             ticketVo.setDestination(draftTicket.getDestination());
             ticketVo.setConsignee(draftTicket.getConsignee());
             ticketVo.setPhone(draftTicket.getPhone());

@@ -10,6 +10,7 @@
         <result column="tomo_pre_ship_date" property="tomoPreShipDate"/>
         <result column="af_tomo_pre_ship_date" property="afTomoPreShipDate"/>
         <result column="auto_generate" property="autoGenerate"/>
+        <result column="business_office_auditor" property="businessOfficeAuditor"/>
         <result column="create_by_id" property="createById"/>
         <result column="update_by_id" property="updateById"/>
         <result column="create_time" property="createTime"/>
@@ -25,6 +26,7 @@
             tb.tomo_pre_ship_date,
             tb.af_tomo_pre_ship_date,
             tb.auto_generate,
+            tb.business_office_auditor,
             tb.create_by_id,
             tb.update_by_id,
             tb.create_time,
@@ -58,7 +60,7 @@
         ORDER BY tb.create_time DESC
     </select>
 
-    <select id="getById" resultType="com.lframework.xingyun.sc.entity.ShipmentsPlan">
+    <select id="getById" resultMap="ShipmentsPlan">
         <include refid="ShipmentsPlan_sql"/>
         <where>
             AND tb.id = #{id}