#

Junjie

2023-08-04 9101ad488486cd57be5f27ca4ad6071c07ab9557

 src/main/java/com/zy/asrs/task/WmsWrkLogScheduler.java

@@ -2,9 +2,6 @@

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.zy.asrs.entity.WmsWrk;
import com.zy.asrs.service.WmsWrkLogService;
import com.zy.asrs.service.WmsWrkService;
import com.zy.common.utils.HttpHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -19,43 +16,38 @@
@Component
public class WmsWrkLogScheduler {

    @Autowired
    private WmsWrkService wmsWrkService;
    @Autowired
    private WmsWrkLogService wmsWrkLogService;

    @Value("${wms.url}")
    private String wmsUrl;

    @Scheduled(cron = "0/3 * * * * ? ")
    public void execute() {
        for (WmsWrk wmsWrk : wmsWrkService.selectToBeHistoryData()) {
            boolean save = wmsWrkLogService.save(wmsWrk.getWmsWrkNo());
            boolean delete = wmsWrkService.deleteById(wmsWrk.getWmsWrkNo());
            if (!save || !delete) {
                log.error("任务[wmsWrkNo={}]历史处理失败", wmsWrk.getWmsWrkNo());
            }

            try {
                //任务上报
                String response = new HttpHandler.Builder()
                        .setUri(wmsUrl)
                        .setPath("/wmsWrk/test")
                        .setJson(JSON.toJSONString(wmsWrk))
                        .build()
                        .doPost();
                JSONObject jsonObject = JSON.parseObject(response);
                if (jsonObject.getInteger("code").equals(200)) {
                    //todo
//                    StartupDto dto = jsonObject.getObject("data", StartupDto.class);

                } else {
                    log.error("请求接口失败！！！url：{}；request：{}；response：{}", wmsUrl + "/wmsWrk/test", JSON.toJSONString(wmsWrk), response);
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
//        for (WmsWrk wmsWrk : wmsWrkService.selectToBeHistoryData()) {
//            boolean save = wmsWrkLogService.save(wmsWrk.getWmsWrkNo());
//            boolean delete = wmsWrkService.deleteById(wmsWrk.getWmsWrkNo());
//            if (!save || !delete) {
//                log.error("任务[wmsWrkNo={}]历史处理失败", wmsWrk.getWmsWrkNo());
//            }
//
//            try {
//                //任务上报
//                String response = new HttpHandler.Builder()
//                        .setUri(wmsUrl)
//                        .setPath("/wmsWrk/test")
//                        .setJson(JSON.toJSONString(wmsWrk))
//                        .build()
//                        .doPost();
//                JSONObject jsonObject = JSON.parseObject(response);
//                if (jsonObject.getInteger("code").equals(200)) {
//                    //todo
////                    StartupDto dto = jsonObject.getObject("data", StartupDto.class);
//
//                } else {
//                    log.error("请求接口失败！！！url：{}；request：{}；response：{}", wmsUrl + "/wmsWrk/test", JSON.toJSONString(wmsWrk), response);
//                }
//            } catch (Exception e) {
//                e.printStackTrace();
//            }
//        }
    }

}