#

Junjie

3 天以前 78067a1c03707766f3d6561c22e165af68ad36b9

 src/main/java/com/zy/asrs/task/handler/OutWorkHandler.java

@@ -7,6 +7,8 @@
import com.zy.asrs.service.WrkMastService;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.utils.Utils;
import com.zy.common.model.StartupDto;
import com.zy.common.utils.HttpHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -21,57 +23,88 @@
@Transactional
public class OutWorkHandler extends AbstractHandler<String> {

    @Autowired
    private ApiLogService apiLogService;
    @Value("${wcs.address.URL}")
    private String addrs;
    @Value("${wcs.address.outboundTaskSend}")
    private String outboundTaskSend;
    @Value("${wcs.address.createOutTask}")
    private String outTask;
    @Value("${wcs.address.createLocMoveTask}")
    private String locMoveTask;

    @Autowired
    private ApiLogService apiLogService;
    @Autowired
    private WrkMastService wrkMastService;


    public synchronized ReturnT<String> start(WrkMast wrkMast) {
        HashMap<String, Object> map = new HashMap<>();
        map.put("taskNo", wrkMast.getWrkNo());
        map.put("taskPriority", 10);
        map.put("taskType", wrkMast.getIoType() == 11 ? 3 : 2);
        map.put("startPoint", wrkMast.getSourceLocNo());
        map.put("targetPoint", wrkMast.getSourceStaNo() + "-" + wrkMast.getStaNo());
        map.put("barcode", wrkMast.getBarcode());
        StartupDto startupDto = new StartupDto();
        startupDto.setTaskNo(wrkMast.getWrkNo());
        startupDto.setStaNo(wrkMast.getStaNo());
        startupDto.setLocNo(Utils.locToLocNo(wrkMast.getSourceLocNo()));
        startupDto.setTaskPri(wrkMast.getIoPri());

        String response ="";
        boolean bool =false;
        try {
            log.info("wms派发任务给wcs出库={}", JSON.toJSONString(map));
            response = new HttpHandler.Builder()
                    // .setHeaders(headParam)
                    .setUri(addrs)
                    .setPath(outboundTaskSend)
                    .setJson(JSON.toJSONString(map))
                    .build()
                    .doPost();
            JSONObject jsonObject = JSON.parseObject(response);
            if(jsonObject.getInteger("code") == 200){
                wrkMast.setWrkSts(12L);
                wrkMastService.updateById(wrkMast);
                bool = true;
            }else {
                log.error("wms派发任务给wcs出库失败{},返回值={}", JSON.toJSONString(wrkMast), response);
        if (wrkMast.getIoType() == 11) {
            String response = "";
            boolean bool = false;
            try {
                log.info("wms派发任务给wcs移库={}", JSON.toJSONString(startupDto));
                response = new HttpHandler.Builder()
                        .setUri(addrs)
                        .setPath(locMoveTask)
                        .setJson(JSON.toJSONString(startupDto))
                        .build()
                        .doPost();
                JSONObject jsonObject = JSON.parseObject(response);
                if (jsonObject.getInteger("code") == 200) {
                    wrkMast.setWrkSts(12L);
                    wrkMastService.updateById(wrkMast);
                    bool = true;
                } else {
                    log.error("wms派发任务给wcs移库失败{},返回值={}", JSON.toJSONString(wrkMast), response);
                }
            } catch (Exception e) {
                log.error("wms派发任务给wcs移库失败{},返回值={}", JSON.toJSONString(wrkMast), response);
            } finally {
                apiLogService.save("wms派发任务给wcs移库"
                        , addrs + locMoveTask
                        , null
                        , "127.0.0.1"
                        , JSON.toJSONString(startupDto)
                        , response
                        , bool
                );
            }
        } catch (Exception e) {
            log.error("wms派发任务给wcs出库失败{},返回值={}", JSON.toJSONString(wrkMast), response);
        } finally {
            apiLogService.save("wms派发任务给wcs出库"
                    , addrs + outboundTaskSend
                    , null
                    , "127.0.0.1"
                    , JSON.toJSONString(map)
                    , response
                    , bool
            );
        } else {
            String response ="";
            boolean bool =false;
            try {
                log.info("wms派发任务给wcs出库={}", JSON.toJSONString(startupDto));
                response = new HttpHandler.Builder()
                        .setUri(addrs)
                        .setPath(outTask)
                        .setJson(JSON.toJSONString(startupDto))
                        .build()
                        .doPost();
                JSONObject jsonObject = JSON.parseObject(response);
                if(jsonObject.getInteger("code") == 200){
                    wrkMast.setWrkSts(12L);
                    wrkMastService.updateById(wrkMast);
                    bool = true;
                }else {
                    log.error("wms派发任务给wcs出库失败{},返回值={}", JSON.toJSONString(wrkMast), response);
                }
            } catch (Exception e) {
                log.error("wms派发任务给wcs出库失败{},返回值={}", JSON.toJSONString(wrkMast), response);
            } finally {
                apiLogService.save("wms派发任务给wcs出库"
                        , addrs + outTask
                        , null
                        , "127.0.0.1"
                        , JSON.toJSONString(startupDto)
                        , response
                        , bool
                );
            }
        }
        return SUCCESS;

    }
}