#

zjj

2025-07-02 d3f3d4b309cfb285fcbbc48b91c4046111c7e9cd

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

@@ -1,7 +1,6 @@
package com.zy.asrs.controller;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.annotations.AppAuth;
import com.core.common.BaseRes;
@@ -14,7 +13,6 @@
import com.zy.asrs.entity.param.WMSAndAGVInterfaceParam;
import com.zy.asrs.entity.param.taskCreateParam;
import com.zy.asrs.service.*;
import com.zy.common.utils.HttpHandler;
import com.zy.common.web.BaseController;
import com.zy.core.CrnThread;
import com.zy.core.cache.SlaveConnection;
@@ -28,6 +26,8 @@

import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -80,8 +80,16 @@
        if (Cools.isEmpty(param.getStatus())){
            return R.error("完成标记[status]不能为空");
        }
        openService.getAgvTaskOver(param);
        return R.ok();
        R agvTaskOver = openService.getAgvTaskOver(param);
        apiLogService.save("AGV请求任务完成"
                ,request.getRemoteAddr()+request.getRequestURI()
                ,appkey
                ,request.getRemoteAddr()
                ,JSON.toJSONString(param)
                ,agvTaskOver.toString()
                ,true
        );
        return agvTaskOver;
    }

    //创建任务
@@ -152,6 +160,7 @@
                              @RequestBody WMSAndAGVInterfaceParam param,
                              HttpServletRequest request) throws IOException {
        auth(appkey,param,request);
        log.warn("请求入库码头时间：{}", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));

        if (Cools.isEmpty(param)){
            return R.error("参数为空！");
@@ -161,9 +170,10 @@
            return R.error("托盘编码为空！");
        } else if (Cools.isEmpty(param.getWharfSource())){
            return R.error("源码头为空！");
        } else if (Cools.isEmpty(param.getFreeWharfs()) || param.getFreeWharfs().size()==0){
            return R.error("空闲的入库码头（AGV）为空！");
        }
//        else if (Cools.isEmpty(param.getFreeWharfs()) || param.getFreeWharfs().size()==0){
//            return R.error("空闲的入库码头（AGV）为空！");
//        }
        R r = openService.AgvToWCSToWms(param);
        apiLogService.save("AGV请求入库码头接口"
                ,request.getRemoteAddr()+request.getRequestURI()
@@ -173,6 +183,7 @@
                ,r.toString()
                ,true
        );
        log.warn("请求入库码头完成时间：{}", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
        return r;
    }

@@ -230,7 +241,7 @@
                    ,R.error("站点状态不可入").toString()
                    ,true
            );
            return R.error("站点状态不可入");
            return R.error("站点状态不可入,自动信号:"+basDevp.getAutoing()+";可入信号:"+basDevp.getInEnable()+";可出信号:"+basDevp.getOutEnable());
        }


@@ -245,6 +256,7 @@
    public R outboundTaskSend(@RequestHeader String appkey,
                              @RequestBody List<WMSAndAGVInterfaceParam> params,
                              HttpServletRequest request) {
        log.warn("收到下发任务时间：{}", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
        auth(appkey, params, request);
        List<WMSAndAGVInterfaceParam> params1 =new ArrayList<>();
        for (WMSAndAGVInterfaceParam param:params){
@@ -308,7 +320,7 @@


        }

        log.warn("下发任务解析完成时间：{}", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
        return R.ok();
    }