#

Junjie

2025-09-21 dbfbc8f19dc5751b6dec442aff24463f1084a3d9

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

@@ -2,14 +2,9 @@

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.zy.asrs.entity.LocMast;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.entity.param.CarryParam;
import com.zy.asrs.service.ApiLogService;
import com.zy.asrs.service.LocMastService;
import com.zy.asrs.service.WrkMastService;
import com.zy.asrs.service.impl.LocMastServiceImpl;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
import com.zy.common.utils.HttpHandler;
@@ -19,17 +14,13 @@
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

@Slf4j
@Service
@Transactional
public class OutWorkHandler extends AbstractHandler<String> {

    @Autowired
    private LocMastService locMastService;
    @Autowired
    private ApiLogService apiLogService;
    @Value("${wcs.address.URL}")
@@ -41,29 +32,18 @@


    public synchronized ReturnT<String> start(WrkMast wrkMast) {
        //优先级
        LocMast locMast=locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", wrkMast.getSourceLocNo()));
        int Priority = locMast.getLocAttribute() == null ? 0 : locMast.getLocAttribute();

        HashMap<String, Object> map = new HashMap<>();
        CarryParam carryParam = new CarryParam();
        carryParam.setBoxNo(wrkMast.getBarcode());//托盘码
        carryParam.setTaskNo(wrkMast.getWrkNo()+"");//任务号
        carryParam.setStereoscopicTaskType(2);//2.出库
        carryParam.setPriority(10+Priority);//优先级
        carryParam.setOriginalRowNo(locMast.getRow1());//源库位排
        carryParam.setOriginalColumnNo(locMast.getBay1());//源库位列
        carryParam.setOriginalFloorNo(locMast.getLev1());//源库位层
        carryParam.setStartPoint(wrkMast.getStaNo()+""+locMast.getLev1());//源站
        carryParam.setTerminalNo(wrkMast.getStaNo()+"");//目标站
        List<CarryParam> carryParamList=new ArrayList<>();
        carryParamList.add(carryParam);
        map.put("TaskList",carryParamList);
        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.getLocNo());
        map.put("barcode", wrkMast.getBarcode());

        String response ="";
        Boolean bool =false;
        boolean bool =false;
        try {
            log.info("wms派发任务给wcs出库={}", map);
            log.info("wms派发任务给wcs出库={}", JSON.toJSONString(map));
            response = new HttpHandler.Builder()
                    // .setHeaders(headParam)
                    .setUri(addrs)
@@ -72,15 +52,17 @@
                    .build()
                    .doPost();
            JSONObject jsonObject = JSON.parseObject(response);
            if(jsonObject.get("Code").equals("1")){
            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("wcs派发任务给RCS出库失败{},返回值={}", wrkMast, response);
            log.error("wms派发任务给wcs出库失败{},返回值={}", JSON.toJSONString(wrkMast), response);
        } finally {
            apiLogService.save("wcs派发任务给RCS出库"
            apiLogService.save("wms派发任务给wcs出库"
                    , addrs + outboundTaskSend
                    , null
                    , "127.0.0.1"