#

Administrator

3 天以前 e955eb6077fc28f0ad379af45c5adec1962eeff6

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

@@ -11,6 +11,8 @@
import com.zy.asrs.entity.param.*;
import com.zy.asrs.mapper.ReportQueryMapper;
import com.zy.asrs.service.*;
import com.zy.asrs.task.core.ReturnT;
import com.zy.asrs.task.handler.AutoEmptyOutHandler;
import com.zy.common.model.DetlDto;
import com.zy.common.web.BaseController;
import lombok.extern.slf4j.Slf4j;
@@ -47,7 +49,11 @@
    @Autowired
    private WrkMastService wrkMastService;
    @Autowired
    private WaitPakinService waitPakinService;
    @Autowired
    private WrkDetlService wrkDetlService;
    @Autowired
    private AutoEmptyOutHandler autoEmptyOutHandler;

    @PostMapping("/order/matSync/default/v2")
//    @AppAuth(memo = "商品信息同步接口")
@@ -177,6 +183,23 @@
                        HttpServletRequest request) {
        auth(appkey, null, request);
        return R.ok().add(openService.queryStock());
    }

    @PostMapping("/task/autoEmptyOut/run/v1")
    public synchronized R runAutoEmptyOut(@RequestHeader(required = false) String appkey,
                                          @RequestParam(required = false) Integer crnNo,
                                          @RequestParam(required = false) Integer max,
                                          @RequestParam(required = false) Long userId,
                                          HttpServletRequest request) {
        // auth(appkey, null, request);
        ReturnT<String> res = autoEmptyOutHandler.moveOldestInventory(crnNo, max, userId);
        if (res == null) {
            return R.error("执行失败").add(null);
        }
        if (res.isSuccess()) {
            return R.ok().add(res);
        }
        return R.error(res.getMsg()).add(res);
    }

    private void auth(String appkey, Object obj, HttpServletRequest request) {
@@ -366,4 +389,29 @@
        map.put("wrkDetls", wrkDetls);
        return R.ok().add(map);
    }


    /**
     * 任务查询接口
     */
    @PostMapping("/queryTaskByBarcode")
    public synchronized R queryTask(@RequestBody QueryTaskByBarcodeParam param) {
        if (Cools.isEmpty(param)) {
            return R.parse(BaseRes.PARAM);
        }
        if (Cools.isEmpty(param.getBarcode())) {
            return R.error("条码不能为空");
        }


        List<WaitPakin> waitPakins = waitPakinService.selectList(new EntityWrapper<WaitPakin>().eq("zpallet", param.getBarcode()));
        if (waitPakins.isEmpty()) {
            return R.error("数据不存在");
        }
        HashMap<String, Object> map = new HashMap<>();
        map.put("taskNo", null);
        map.put("ioType", "1");
        map.put("waitPakins", waitPakins);
        return R.ok().add(map);
    }
}