承运与无车承运对接

performance-web/src/main/java/com/clx/performance/dao/impl/settle/SettlementOwnerDaoImpl.java

@@ -273,6 +273,15 @@ public class SettlementOwnerDaoImpl extends BaseDaoImpl<SettlementOwnerMapper, S
                 .set(SettlementOwner::getStatus, toStatus)
         );
     }
+    @Override
+    public boolean updateDailyLock(Integer settlementPeriodType, LocalDateTime settlementPeriodTime, Integer fromStatus,Integer toStatus){
+        return update(lUdWrapper()
+                .eq(SettlementOwner::getSettlementPeriodType, settlementPeriodType)
+                .eq(SettlementOwner::getSettlementPeriodTime, settlementPeriodTime)
+                .eq(SettlementOwner::getStatus, fromStatus)
+                .set(SettlementOwner::getStatus, toStatus)
+        );
+    }
 
     @Override
     public void updateSettlementMerge(@Param("settlementNo")String settlementNo,

performance-web/src/main/java/com/clx/performance/dao/settle/SettlementOwnerDao.java

@@ -69,6 +69,9 @@ public interface SettlementOwnerDao extends BaseDao<SettlementOwnerMapper, Settl
                                   @Param("fromStatus")Integer fromStatus,
                                   @Param("toStatus")Integer toStatus);
 
+    boolean updateDailyLock(Integer settlementPeriodType, LocalDateTime settlementPeriodTime,
+                            Integer fromStatus, Integer toStatus);
+
     void updateSettlementMerge(@Param("settlementNo")String settlementNo,
             @Param("settlementNos")List<String> settlementNos,
             @Param("mergedBy") String mergedBy,

performance-web/src/main/java/com/clx/performance/job/SettlementOwnerMontnJob.java

 package com.clx.performance.job;
 
+import com.clx.performance.dao.settle.SettlementOwnerDao;
 import com.clx.performance.enums.settle.SettlementOwnerEnum;
 import com.clx.performance.service.settle.SettlementOwnerService;
+import com.clx.performance.utils.LocalDateTimeUtils;
 import com.msl.common.job.JobLog;
 import com.xxl.job.core.handler.annotation.XxlJob;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.time.LocalDateTime;
+
 @Slf4j
 @Component
 public class SettlementOwnerMontnJob {
 
     @Autowired
     SettlementOwnerService settlementOwnerService;
+    @Autowired
+    private SettlementOwnerDao settlementOwnerDao;
 
     /**
      * 月结货主结算单状态变更为锁定
@@ -32,7 +38,25 @@ public class SettlementOwnerMontnJob {
         }
     }
 
+    /**
+     * 日结货主结算单状态变更为锁定
+     */
+    @XxlJob("settlementOwnerDailyInit")
+    public void settlementOwnerDailyInit() {
+        try {
+            // 锁定前一天数据
+            LocalDateTime settlementPeriodTime = LocalDateTimeUtils.getDayStart().minusDays(1);
 
-
+            //所有日结的待锁定的货主结算单修改状态为锁定
+            settlementOwnerDao.updateDailyLock(
+                    SettlementOwnerEnum.SettlementPeriodType.DAILY.getCode(),
+                    settlementPeriodTime,
+                    SettlementOwnerEnum.Status.TO_BE_LOCKED.getCode(),
+                    SettlementOwnerEnum.Status.TO_BE_ACCOUNT.getCode());
+        } catch (Exception e) {
+            log.warn("日结货主结算单状态变更为锁定，异常原因:{}",e);
+            JobLog.error("日结货主结算单状态变更为锁定，异常原因=====================", e);
+        }
+    }
 
 }