#

lty

3 天以前 4f2b7db1184798a55046f04e17d5540b4a7e19f4

 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;
@@ -50,6 +52,8 @@
    private WaitPakinService waitPakinService;
    @Autowired
    private WrkDetlService wrkDetlService;
    @Autowired
    private AutoEmptyOutHandler autoEmptyOutHandler;

    @PostMapping("/order/matSync/default/v2")
//    @AppAuth(memo = "商品信息同步接口")
@@ -181,6 +185,23 @@
        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) {
        log.info("{}接口被访问；appkey:{}；请求数据：{}", "open/sensorType/list/auth/v1", appkey, JSON.toJSONString(obj));
        request.setAttribute("cache", obj);