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);
+
+    //    查询未出库状态,出库单存在的数据
+    List<String> selectWaitOutIds();
+
+    //    根据主表id修改出库状态
+    int updateOutStatus(@Param("storeId") String storeId);
 }

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;
 
@@ -54,6 +55,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) {
@@ -357,4 +360,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/resource/mapper/ware/DistributionMapper.xml

@@ -269,4 +269,24 @@ where substring(t.distribution_no,3,8) = DATE_FORMAT(NOW(), '%Y%m%d')) temp))
     order by t.add_time desc
   </select>
 
+    <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="updateOutStatus" parameterType="java.lang.String">
+        update t_ware_store
+        set out_flag = '1'
+        where id = #{storeId}
+    </update>
 </mapper>