接收MES下发，余料回库任务

skyouc

2 天以前 88155592a3433104c12880fdd6d58cee0dedd3c7

 src/main/java/com/zy/api/service/impl/WcsApiServiceImpl.java

@@ -6,12 +6,15 @@
import com.core.common.R;
import com.core.exception.CoolException;
import com.zy.api.controller.params.ReceviceTaskParams;
import com.zy.api.controller.params.WorkTaskParams;
import com.zy.api.service.WcsApiService;
import com.zy.asrs.entity.BasDevice;
import com.zy.asrs.entity.LocAroundBind;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.service.BasDeviceService;
import com.zy.asrs.service.LocAroundBindService;
import com.zy.asrs.service.LocMastService;
import com.zy.asrs.service.WrkMastService;
import com.zy.common.constant.MesConstant;
import com.zy.common.utils.HttpHandler;
import org.springframework.beans.factory.annotation.Autowired;
@@ -33,6 +36,8 @@
    private LocAroundBindService locAroundBindService;
    @Autowired
    private LocMastService locMastService;
    @Autowired
    private WrkMastService wrkMastService;

    /**
     * 通知WCS锁定库位，及禁止当前库位的一切操作
@@ -62,17 +67,40 @@
    }

    /**
     * 搬运回库指令
     * 余料回库 （搬运余料回库）
     * @author Ryan
     * @date 2026/1/10 13:11
     * @date 2026/1/10 13:19
     * @param params
     * @return com.core.common.R
     */
    @Override
    public R backLocs(ReceviceTaskParams params) {
        return null;
    @Transactional(rollbackFor = Exception.class)
    public R backLocs(WorkTaskParams params) {
        if (Objects.isNull(params.getWrkCode())) {
            throw new CoolException("工作号不能为空！！");
        }
        String wrkCode = params.getWrkCode();
       if (wrkCode.contains("-1")) {
           throw new CoolException("配对任务编码错误，请检查后重新上传！！");
       }

        WrkMast mast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_code", params.getWrkCode()));

       if (Objects.isNull(mast)) {
           throw new CoolException("任务不存在！！");
       }
       if (!mast.getWrkSts().equals(103L)) {
           throw new CoolException("当前任务并非余料出库任务！！");
       }
        mast.setWrkSts(53L);
       if (!wrkMastService.updateById(mast)) {
           throw new CoolException("任务状态更新失败！！");
       }

       return R.ok("接收成功，执行回库中...");
    }


    /**
     * 上报锁定库位信息
     * @author Ryan