#

zwl

2026-02-09 ad79ba405b2d1ac96423f88f4e8a76c584b9d38a

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

@@ -5,13 +5,16 @@
import com.core.common.R;
import com.core.exception.CoolException;
import com.zy.asrs.domain.param.*;
import com.zy.asrs.entity.BasDevp;
import com.zy.asrs.entity.DeviceConfig;
import com.zy.asrs.entity.LocMast;
import com.zy.asrs.entity.WrkMast;
import com.zy.asrs.service.BasDevpService;
import com.zy.asrs.service.DeviceConfigService;
import com.zy.asrs.service.LocMastService;
import com.zy.asrs.service.WrkMastService;
import com.zy.common.annotations.OpenApiLog;
import com.zy.common.model.MonitorParam;
import com.zy.common.service.CommonService;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.SlaveType;
@@ -58,6 +61,8 @@
    private ConfigService configService;
    @Autowired
    private DeviceConfigService deviceConfigService;
    @Autowired
    private BasDevpService basDevpService;

    // 移库任务
    @PostMapping("/createLocMoveTask")
@@ -352,4 +357,41 @@
        return R.ok();
    }

    // 反馈任务执行结果
    @PostMapping("/stationStatus")
    public R stationStatus(@RequestBody MonitorParam param){
        if(param == null || param.getStationIds().length == 0){
            return R.error("输入的参数为空");
        }
        List<StationProtocol> basDevps  =  new ArrayList<>();
        Boolean flag = false;
        // 获取输送站点数据
        ArrayList<StationProtocol> stationProtocols = new ArrayList<>();
        List<DeviceConfig> stationList = deviceConfigService.selectList(new EntityWrapper<DeviceConfig>()
                .eq("device_type", String.valueOf(SlaveType.Devp)));
        for (DeviceConfig device : stationList) {
            StationThread stationThread = (StationThread) SlaveConnection.get(SlaveType.Devp, device.getDeviceNo());
            if (stationThread == null) {
                continue;
            }

            List<StationProtocol> stationProtocolList = stationThread.getStatus();
            if (stationProtocolList == null) {
                continue;
            }
            for (StationProtocol stationProtocol : stationProtocolList) {
                for (int i = 0; i < param.getStationIds().length; i++) {
                    if (stationProtocol.getStationId().equals(param.getStationIds()[i])){
                        flag = true;
                        basDevps.add(stationProtocol);
                    }
                }
            }
        }
        if(flag){
            return R.ok().add(basDevps);
        }
        return null;
    }

}