自动化立体仓库 - WMS系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
mrzhssss
2023-06-19 9cd62b954e152eb2675ea458570d55ecaddd4f74 
 src/main/java/com/zy/asrs/task/OrderSyncScheduler.java


@@ -1,6 +1,5 @@


package com.zy.asrs.task;




import com.baomidou.mybatisplus.mapper.EntityWrapper;


import com.core.common.Cools;


import com.zy.asrs.entity.Order;


import com.zy.asrs.service.ApiLogService;


@@ -10,6 +9,7 @@


import com.zy.common.entity.Parameter;


import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.scheduling.annotation.Async;


import org.springframework.scheduling.annotation.Scheduled;


import org.springframework.stereotype.Component;


@@ -30,6 +30,10 @@


    @Autowired


    private ApiLogService apiLogService;






    @Value("${erp.enable}")


    private Boolean erpEnable;




    @Scheduled(cron = "0 0 1 * * ? ")


    public void clearApiLog(){


        try {


@@ -39,12 +43,13 @@


        }


    }




    @Scheduled(cron = "0/5 * * * * ? ")


//    @Scheduled(cron = "0/5 * * * * ? ")


    @Async("orderThreadPool")


    public void completeAndReport(){


        if (!erpEnable) return;


        String erpReport = Parameter.get().getErpReport();


        if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) {


            List<Order> orders = orderService.selectList(new EntityWrapper<Order>().eq("settle", 4L).eq("status", 1));


            List<Order> orders = orderService.selectComplete();


            for (Order order : orders) {


                ReturnT<String> result = orderSyncHandler.start(order);


                if (!result.isSuccess()) {