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

skyouc

2 天以前 88155592a3433104c12880fdd6d58cee0dedd3c7

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

 src/main/java/com/zy/api/controller/WcsApiController.java

@@ -4,6 +4,7 @@
import com.core.annotations.ManagerAuth;
import com.core.common.R;
import com.zy.api.controller.params.ReceviceTaskParams;
import com.zy.api.controller.params.WorkTaskParams;
import com.zy.api.service.WcsApiService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
@@ -54,7 +55,7 @@
    @ManagerAuth
    @ApiOperation("堆垛机回库搬运指令")
    @PostMapping("/back/loc")
    public R backLoc(@RequestBody ReceviceTaskParams params) {
    public R backLoc(@RequestBody WorkTaskParams params) {
        if (Objects.isNull(params)) {
            return R.error("参数不能为空！！");
        }

 src/main/java/com/zy/api/controller/params/WorkTaskParams.java

New file
@@ -0,0 +1,27 @@
package com.zy.api.controller.params;


import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.experimental.Accessors;

import java.io.Serializable;

@Data
@Accessors(chain = true)
@ApiModel(value = "WorkTaskParams", description = "执行任务参数")
public class WorkTaskParams implements Serializable {

    private static final long serialVersionUID = 1L;

    @ApiModelProperty("协议任务编号(对应出库任务号)")
    private String wrkCode;

    @ApiModelProperty("工作档任务号")
    private String wrkNo;

    @ApiModelProperty("是否完成")
    private Integer isComplete;

}

 src/main/java/com/zy/api/service/WcsApiService.java

@@ -2,6 +2,7 @@

import com.core.common.R;
import com.zy.api.controller.params.ReceviceTaskParams;
import com.zy.api.controller.params.WorkTaskParams;

public interface WcsApiService {

@@ -21,5 +22,5 @@
     * @param params
     * @return com.core.common.R
     */
    R backLocs(ReceviceTaskParams params);
    R backLocs(WorkTaskParams params);
}

 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