wms任务转日志后上报

Junjie

2023-05-23 802ac9d66a0201f01644a70d7a29556224432ce7

wms任务转日志后上报

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

@@ -1,10 +1,14 @@
package com.zy.asrs.task;

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;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@@ -20,6 +24,9 @@
    @Autowired
    private WmsWrkLogService wmsWrkLogService;

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

    @Scheduled(cron = "0/3 * * * * ? ")
    public void execute() {
        for (WmsWrk wmsWrk : wmsWrkService.selectToBeHistoryData()) {
@@ -28,6 +35,26 @@
            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();
            }
        }
    }