package com.zy.asrs.task;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
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;

/**
 * 定时将WMS任务(完成、取消)转成日志
 */
@Slf4j
@Component
public class WmsWrkLogScheduler {

    @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();
//            }
//        }
    }

}