#1

yrwcs

2026-01-12 2f07377862da775c3fa4a7b7d20d8a011df85060

 src/main/java/com/zy/asrs/task/NotifyScheduler.java

@@ -39,19 +39,19 @@

    @Scheduled(cron = "0/3 * * * * ? ")
    public synchronized void notifyShuttle(){
        List<DeviceConfig> shuttleList = deviceConfigService.selectList(new EntityWrapper<DeviceConfig>()
                .eq("device_type", String.valueOf(SlaveType.Shuttle)));
        for (DeviceConfig device : shuttleList) {
            notifyMsg(String.valueOf(SlaveType.Shuttle), device.getDeviceNo());
        List<DeviceConfig> deviceList = deviceConfigService.selectList(new EntityWrapper<DeviceConfig>()
                .eq("device_type", String.valueOf(SlaveType.Crn)));
        for (DeviceConfig device : deviceList) {
            notifyMsg(String.valueOf(SlaveType.Crn), device.getDeviceNo());
        }
    }

    @Scheduled(cron = "0/3 * * * * ? ")
    public synchronized void notifyForkLift(){
        List<DeviceConfig> forkLiftList = deviceConfigService.selectList(new EntityWrapper<DeviceConfig>()
                .eq("device_type", String.valueOf(SlaveType.ForkLift)));
        for (DeviceConfig device : forkLiftList) {
            notifyMsg(String.valueOf(SlaveType.ForkLift), device.getDeviceNo());
        List<DeviceConfig> deviceList = deviceConfigService.selectList(new EntityWrapper<DeviceConfig>()
                .eq("device_type", String.valueOf(SlaveType.Rgv)));
        for (DeviceConfig device : deviceList) {
            notifyMsg(String.valueOf(SlaveType.Rgv), device.getDeviceNo());
        }
    }

@@ -123,6 +123,8 @@
                    //通知成功
                    redisUtil.del(key);

                    httpRequestLog.setResult(1);

                    continue;
                }
            }catch (Exception e){