*

lsh

1 天以前 3759a40aad8191f82f4a2eac54c9045dcf6a0fb3

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

@@ -3,6 +3,7 @@
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.core.exception.CoolException;
import com.zy.asrs.domain.enums.TaskStatusType;
import com.zy.asrs.entity.*;
@@ -19,6 +20,7 @@
import org.springframework.stereotype.Component;

import java.io.IOException;
import java.time.LocalDateTime;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
@@ -56,51 +58,59 @@
    public void execute() throws IOException {
        List<TaskWrk> taskWrkList = taskWrkService.selectToBeHistoryData();
        for (TaskWrk taskWrk : taskWrkList) {
            JSONObject jsonObject = null;
            String response = null;
            boolean success = false;
            HashMap<String, Object> map = new HashMap<>();
            try {
                map.put("taskNo",taskWrk.getTaskNo());
                map.put("taskStatus",taskWrk.getStatus());
                map.put("ioType",taskWrk.getIoTypeWms());
                map.put("barCode",taskWrk.getBarcode());
                map.put("reportTime",new Date());
                map.put("weight",taskWrk.getScWeight().doubleValue());
                response = new HttpHandler.Builder()
                        .setUri(wmsUrl)
                        .setPath(taskStatusFeedbackPath)
                        .setJson(JSON.toJSONString(map))
                        .build()
                        .doPost();
                jsonObject = JSON.parseObject(response);

                if (jsonObject.getInteger("code").equals(200)) {
                    if (taskWrkService.saveToHistory(taskWrk.getTaskNo()) == 0) {
                        log.error("任务档转任务历史档失败" + taskWrk);
                        return ;
                    }
                    success = true;
                    //删除任务
                    taskWrkService.delete(new EntityWrapper<TaskWrk>().eq("task_no", taskWrk.getTaskNo()));
                } else {
                    log.error("wms入库出库完成上报失败" + taskWrk);
            if (taskWrk.getIoType()==4){
                if (taskWrkService.saveToHistory(taskWrk.getTaskNo()) == 0) {
                    log.error("任务档转任务历史档失败" + taskWrk);
                    return ;
                }
            } catch (Exception e) {
                log.error("wms通讯失败," + e.getMessage());
            } finally {
                apiLogService.save("wms入库出库完成上报"
                        , wmsUrl + taskStatusFeedbackPath
                        , null
                        , "127.0.0.1"
                        , JSON.toJSONString(map)
                        , response
                        , success
                );
                success = true;
                //删除任务
                taskWrkService.delete(new EntityWrapper<TaskWrk>().eq("task_no", taskWrk.getTaskNo()));
            } else {
                JSONObject jsonObject = null;
                String response = null;
                HashMap<String, Object> map = new HashMap<>();
                try {
                    map.put("taskNo",taskWrk.getTaskNo());
                    map.put("taskStatus",taskWrk.getStatusWms());
                    map.put("ioType",taskWrk.getIoTypeWms());
                    map.put("barCode",taskWrk.getBarcode());
                    map.put("reportTime", LocalDateTime.now());
                    map.put("weight",taskWrk.getScWeight().doubleValue());
                    response = new HttpHandler.Builder()
                            .setUri(wmsUrl)
                            .setPath(taskStatusFeedbackPath)
                            .setJson(JSON.toJSONString(map))
                            .build()
                            .doPost();
                    jsonObject = JSON.parseObject(response);

                    if (!Cools.isEmpty(jsonObject.getInteger("code")) && jsonObject.getInteger("code").equals(200)) {
                        if (taskWrkService.saveToHistory(taskWrk.getTaskNo()) == 0) {
                            log.error("任务档转任务历史档失败" + taskWrk);
                            return ;
                        }
                        success = true;
                        //删除任务
                        taskWrkService.delete(new EntityWrapper<TaskWrk>().eq("task_no", taskWrk.getTaskNo()));
                    } else {
                        log.error("wms入库出库完成上报失败" + taskWrk);
                    }
                } catch (Exception e) {
                    log.error("wms通讯失败," + e.getMessage());
                } finally {
                    apiLogService.save("wms入库出库完成上报"
                            , wmsUrl + taskStatusFeedbackPath
                            , null
                            , "127.0.0.1"
                            , JSON.toJSONString(map)
                            , response
                            , success
                    );
                }
            }
        }


    }

}