From 9101ad488486cd57be5f27ca4ad6071c07ab9557 Mon Sep 17 00:00:00 2001 From: Junjie <fallin.jie@qq.com> Date: 星期五, 04 八月 2023 13:55:10 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/task/WmsWrkLogScheduler.java | 62 +++++++++++++----------------- 1 files changed, 27 insertions(+), 35 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/WmsWrkLogScheduler.java b/src/main/java/com/zy/asrs/task/WmsWrkLogScheduler.java index a2be235..14cd36e 100644 --- a/src/main/java/com/zy/asrs/task/WmsWrkLogScheduler.java +++ b/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("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", 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("璇锋眰鎺ュ彛澶辫触锛侊紒锛乽rl锛歿}锛況equest锛歿}锛況esponse锛歿}", wmsUrl + "/wmsWrk/test", JSON.toJSONString(wmsWrk), response); +// } +// } catch (Exception e) { +// e.printStackTrace(); +// } +// } } } -- Gitblit v1.9.1