1.新增定时任务,每日零点自动排查已出库的库存出库状态未更新的库存,自动更新出库状态

src/main/java/com/th/demo/mapping/ware/DistributionMapper.java

@@ -24,4 +24,10 @@ public interface DistributionMapper {
 
 //    取消出库修改cancle_flag字段
     int updateCancleFlag(@Param("distributionId") String distributionId,@Param("outId") String outId);
+
+//    根据主表id修改出库状态
+    int updateOutStatus(@Param("storeId") String storeId);
+
+//    查询未出库状态,出库单存在的数据
+    List<String> selectWaitOutIds();
 }

src/main/java/com/th/demo/service/impl/ware/OutServiceImpl.java

@@ -19,6 +19,7 @@ import com.th.demo.service.ware.OutService;
 import com.th.demo.tools.JSONTools;
 import com.th.demo.tools.Tools;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -55,6 +56,8 @@ public class OutServiceImpl implements OutService {
 
     String result = Type.FAIL;
     int num = 0;
+//    定时任务执行统计
+    int count = 0;
 
     @Override
     public String out(String json, String userId, String belongId) {
@@ -171,6 +174,7 @@ public class OutServiceImpl implements OutService {
         distribution.setOutFlag("1");
         if(distribution.getTransportName().equals("")||distribution.getTransportName() == null){
             result = JSONTools.toString(ResponseCodeMsg.CODE_EX, "承运单位不可为空！");
+            return result;
         }
         num += distributionMapper.updateByPrimaryKey(distribution);
         List<String> listStoreId = new ArrayList<String>();
@@ -344,4 +348,22 @@ public class OutServiceImpl implements OutService {
     }
 
 
+    /**
+     * 库存状态检测方法(定时)
+     */
+    @Scheduled(cron = "0 * * * * *")
+    public void checkStock() {
+        count += 1;
+//      查询未出库状态,出库单存在的数据
+        List<String> list = distributionMapper.selectWaitOutIds();
+        if(!list.isEmpty()){
+            for (String storeId : list) {
+//                根据id修改主表出库状态
+                distributionMapper.updateOutStatus(storeId);
+            }
+        }
+        System.out.println("执行定时任务_______"+count);
+
+    }
+
 }

src/main/java/com/th/demo/tools/ScheduledTools.java

@@ -0,0 +1,10 @@
+package com.th.demo.tools;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableScheduling;
+
+@Configuration
+@EnableScheduling
+public class ScheduledTools {
+
+}

src/main/resource/mapper/ware/DistributionMapper.xml

@@ -230,6 +230,26 @@
             WHERE
                 out_id = #{outId})
     </update>
+    <update id="updateOutStatus" parameterType="java.lang.String">
+        update t_ware_store
+        set out_flag = '1'
+        where id = #{storeId}
+    </update>
+    <select id="selectWaitOutIds" parameterType="java.lang.String">
+        SELECT
+            b.id
+        FROM
+            t_ware_distribution_detail a
+                LEFT JOIN t_ware_store b ON a.store_id = b.id
+                LEFT JOIN t_ware_distribution c ON c.id = a.distribution_id
+        WHERE
+--             未出库
+            b.out_flag = '0'
+          AND b.cancel_flag = '0'
+          AND a.cancel_flag = '0'
+--           出库单已存在
+          AND c.out_flag = '1'
+    </select>
   <update id="updateByPrimaryKey" parameterType="com.th.demo.model.ware.Distribution" >
     update t_ware_distribution
     set truck_no = #{truckNo,jdbcType=VARCHAR},