#

Junjie

2025-04-23 3f0537d8c82eec18fc5e3adc52118efc5e474b77

#

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

@@ -8,14 +8,17 @@
import com.zy.asrs.domain.param.*;
import com.zy.asrs.entity.ApiLog;
import com.zy.asrs.entity.LocMast;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.service.ApiLogService;
import com.zy.asrs.service.LocMastService;
import com.zy.asrs.service.WrkMastService;
import com.zy.asrs.utils.NotifyUtils;
import com.zy.common.annotations.OpenApiLog;
import com.zy.common.service.CommonService;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.dispatcher.ShuttleDispatchUtils;
import com.zy.core.enums.SlaveType;
import com.zy.core.enums.WrkIoType;
import com.zy.core.model.ForkLiftSlave;
import com.zy.core.model.ShuttleSlave;
import com.zy.core.model.protocol.ForkLiftProtocol;
@@ -49,6 +52,8 @@
    private ApiLogService apiLogService;
    @Autowired
    private LocMastService locMastService;
    @Autowired
    private WrkMastService wrkMastService;

    @PostMapping("/createMoveTask")
    @OpenApiLog(memo = "小车移动任务")
@@ -337,8 +342,8 @@

        apiLogService.insert(new ApiLog(
                null
                , "获取指定库位信息"
                , "/getLocInformation"
                , "获取全部库位信息"
                , "/getAllLocInformation"
                , null
                , null
                , null
@@ -362,8 +367,8 @@

        apiLogService.insert(new ApiLog(
                null
                , "获取指定库位信息"
                , "/getLocInformation"
                , "小车集合"
                , "/shuttleGather"
                , null
                , null
                , null
@@ -380,6 +385,42 @@
        return R.ok().add(shuttleGather);
    }

    @PostMapping("/queryTask")
    @OpenApiLog(memo = "查询任务")
    public R queryTask(@RequestBody QueryTaskParam param) {
        EntityWrapper<WrkMast> wrapper = new EntityWrapper<>();
        if(param.getTaskNo() != null) {
            wrapper.eq("wms_wrk_no", param.getTaskNo());
        }

        if(param.getTaskType() != null) {
            WrkIoType ioType = WrkIoType.get(param.getTaskType());
            if(ioType == null) {
                return R.error("任务类型不存在");
            }
            wrapper.eq("io_type", ioType.id);
        }
        List<WrkMast> wrkMasts = wrkMastService.selectList(wrapper);
        apiLogService.insert(new ApiLog(
                null
                , "查询任务"
                , "/queryTask"
                , null
                , null
                , null
                , null
                , JSON.toJSONString(wrkMasts)
                , null
                , null
                , 1
                , new Date()
                , null
                , null
        ));

        return R.ok().add(wrkMasts);
    }

    @GetMapping("/test")
    public R test() {
        notifyUtils.notify("task", 1, "9999", "W9999", NotifyMsgType.SHUTTLE_MOVING, "data");

 src/main/java/com/zy/asrs/domain/param/QueryTaskParam.java

New file
@@ -0,0 +1,14 @@
package com.zy.asrs.domain.param;

import lombok.Data;

@Data
public class QueryTaskParam {

    //任务类型
    private Integer taskType;

    //任务号
    private String taskNo;

}

 src/main/resources/docs/ËÄÏò³µ»õ²æʽÌáÉý»úWCS½Ó¿ÚV1.3.docx

Binary files differ