初始化

dubin

1 天以前 dd76858f35bb4fdd76d5976465e9bd96267b0f0b

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

@@ -16,6 +16,7 @@
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;

/**
 * Created by vincent on 2022/4/8
@@ -32,6 +33,49 @@

    @Autowired
    private OpenService openService;

    @PostMapping("/agv/queryMatByBatch")
    @AppAuth(memo = "根据批号查询立库是否存在库存")
    public synchronized R queryMatByBatch(@RequestHeader(required = false) String appkey,
                                               @RequestBody(required = false) Map<String,Object> param,
                                               HttpServletRequest request){
        auth(appkey, param, request);
        String batch = (String) param.get("batch");
        if (Cools.isEmpty(batch)) {
            throw new CoolException("批号不能为空");
        }
        return openService.queryMatByBatch(batch);
    }

    @PostMapping("/agv/allowWarehousing")
    @AppAuth(memo = "是否允许agv申请入库接口")
    public synchronized R synCallowWarehousing(@RequestHeader(required = false) String appkey,
                                               @RequestBody(required = false) Map<String,Object> param,
                                               HttpServletRequest request){
        auth(appkey, param, request);
        return openService.synCallowWarehousing();
    }

    @PostMapping("/agv/warehousing")
    @AppAuth(memo = "agv申请入库接口")
    public synchronized R syncWarehousing(@RequestHeader(required = false) String appkey,
                                          @RequestBody CombParam param,
                                          HttpServletRequest request){
        auth(appkey, param, request);
        return openService.syncWarehousing(param);
    }

    @PostMapping("/agv/agvAskOpen")
    @AppAuth(memo = "agv出入库请求wms开门")
    public synchronized R agvAskOpen(@RequestHeader(required = false) String appkey,
                                     @RequestBody AgvAskOpenParam param,
                                     HttpServletRequest request) {
        auth(appkey, param, request);
        if(Cools.isEmpty(param)) {
            throw new CoolException("请检测入库参数：" + param);
        }
        return openService.agvAskOpen(param);
    }

    @PostMapping("/order/matSync/default/v1")
    @AppAuth(memo = "商品信息同步接口")
@@ -152,7 +196,7 @@
    }

    private void auth(String appkey, Object obj, HttpServletRequest request) {
        log.info("{}接口被访问；appkey:{}；请求数据：{}", "open/sensorType/list/auth/v1", appkey, JSON.toJSONString(obj));
        log.info("{}接口被访问；appkey:{}；请求数据：{}", request.getRequestURI(), appkey, JSON.toJSONString(obj));
        request.setAttribute("cache", obj);
        if (!auth) {
            return;