#联机

zjj

2023-11-21 16441fe63adf04e0c434377f7da0fd05ba155eb6

 src/main/java/com/zy/asrs/controller/OpenController.java

@@ -16,6 +16,7 @@
import com.zy.common.web.BaseController;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
@@ -121,6 +122,9 @@
        }
        TaskWrk taskWrk = taskWrkService.selectByTaskNo(param.getTaskNo());

        if (Cools.isEmpty(taskWrk)){
            return R.error("未查询到任务，任务号："+param.getTaskNo());
        }
        return R.ok(taskWrk.getStartPoint());
    }

@@ -136,38 +140,48 @@
        } else if (Cools.isEmpty(param.getWharfCode())){
            return R.error("码头编号为空！");
        }
        BasDevp basDevp = basDevpService.selectById(param.getWharfCode());
        if (basDevp.getAutoing().equals("Y") && basDevp.getLoading().equals("N")){
            return R.ok();
        }else {
            return R.error();

        try{
            BasDevp basDevp = basDevpService.selectById(param.getWharfCode());
            if (basDevp.getAutoing().equals("Y") && basDevp.getLoading().equals("N")){
                return R.ok();
            }else {
                return R.error();
            }
        }catch (Exception e){
            log.error("AGV请求动作接口报错:"+e);
            return R.error("程序报错，未查询到站点");
        }

    }

    //任务下发接口
    @PostMapping("/outboundTaskSend")
    @Transactional
    public R outboundTaskSend(@RequestHeader String appkey,
                              @RequestBody WMSAndAGVInterfaceParam param,
                              @RequestBody List<WMSAndAGVInterfaceParam> params,
                              HttpServletRequest request) {
        try {
            if (Cools.isEmpty(param)){
                return R.error("参数为空！");
            } else if (Cools.isEmpty(param.getTaskNo())){
                return R.error("任务号为空！");
            } else if (Cools.isEmpty(param.getTaskType())){
                return R.error("任务类型为空！");
            } else if (Cools.isEmpty(param.getWarehouseId())){
                return R.error("仓库标识为空！");
            }
            if (Cools.isEmpty(param.getTaskPriority())){
                param.setTaskPriority(1);
            }
            if (Cools.isEmpty(param.getContainerCode())){
                return R.error("容器编码(托盘码)为空！");
            }
            if (Cools.isEmpty(param.getEmptyContainer())){
                return R.error("是否空托盘信号为空！");
            }
        List<WMSAndAGVInterfaceParam> params1 =new ArrayList<>();
        for (WMSAndAGVInterfaceParam param:params){
            try {
                if (Cools.isEmpty(param)){
                    return R.error("参数为空！");
                } else if (Cools.isEmpty(param.getTaskNo())){
                    return R.error("任务号为空！");
                } else if (Cools.isEmpty(param.getTaskType())){
                    return R.error("任务类型为空！");
                } else if (Cools.isEmpty(param.getWarehouseId())){
                    return R.error("仓库标识为空！");
                }
                if (Cools.isEmpty(param.getTaskPriority())){
                    param.setTaskPriority(1);
                }
                if (Cools.isEmpty(param.getContainerCode())){
                    return R.error("容器编码(托盘码)为空！");
                }
                if (Cools.isEmpty(param.getEmptyContainer())){
                    return R.error("是否空托盘信号为空！");
                }
//        if (Cools.isEmpty(param.getTaskTunnel())){
//            return R.error("任务巷道为空！");
//        }
@@ -177,17 +191,20 @@
//        if (Cools.isEmpty(param.getTaskSerialNo())){
//            return R.error("任务执行顺序为空！");
//        }
            if (Cools.isEmpty(param.getTargetWharf())){
                return R.error("目标码头区域为空！");//G开头=7车间，H开头=8层，J开头=9车间
                if (Cools.isEmpty(param.getTargetWharf())){
                    return R.error("目标码头区域为空！");//G开头=7车间，H开头=8层，J开头=9车间
                }

                openService.taskCreate(new taskCreateParam(param));

                params1.add(param);
//                return R.ok(param);
            }catch (Exception e){
                String errorMsg = Cools.isEmpty(e.getLocalizedMessage()) ? "" : e.getLocalizedMessage();
                return R.error("生成任务失败，请联系管理员!"+ errorMsg);
            }

            openService.taskCreate(new taskCreateParam(param));

            return R.ok(param);
        }catch (Exception e){
            String errorMsg = Cools.isEmpty(e.getLocalizedMessage()) ? "" : e.getLocalizedMessage();
            return R.ok("生成任务失败，请联系管理员!"+ errorMsg);
        }
        return R.ok(params1);
    }

    //任务取消接口
@@ -212,20 +229,20 @@
        }
        boolean sign =false;
        switch (param.getTaskStatus()){
            case "1"://正常取消
            case 1://正常取消
                if (taskWrk.getWrkSts()>1){
                    return R.error("任务已开始执行");
                }
            case "2"://强制取消
            case 2://强制取消
                if (taskWrk.getWrkSts()>3){
                    return R.error("任务已执行完成");
                }
                break;
            case "3"://正常完成
            case 3://正常完成
                if (taskWrk.getWrkSts()>11){
                    return R.error("任务已开始执行");
                }
            case "4"://强制完成
            case 4://强制完成
                if (taskWrk.getWrkSts()>14){
                    return R.error("任务已执行完成");
                }