zhangnaisong
2024-07-26 b468cde8bfd9d6e1d7ae7ccc535fc7e8ffb9f818
ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java
@@ -104,8 +104,6 @@
    @Value("${syCar.password}")
    private String password;
    private Timer lockStateTimer;
    @PostConstruct
    public void init(){
        ardSyCarController = this;
@@ -155,7 +153,7 @@
        //删除结束时间为null的记录
        int result = ardTankAbnormalParkAlarmService.deleteArdTankAbnormalParkAlarmByEndTime();
        this.lockStateTimer = new Timer();//定时获取各个锁的状态
        Timer lockStateTimer = new Timer();//定时获取各个锁的状态
        TimerTask lockStateTask =new TimerTask(){
            @Override
            public void run(){
@@ -180,7 +178,7 @@
                        List<ArdTankLock> result = ardTankLockService.getArdTankLockAll();//查询全部电磁锁
                        for(ArdTankLock ardTankLock : result){
                            Thread LockThread = new Thread(finalSyURL){
                            Thread lockThread = new Thread(finalSyURL){
                                @Override
                                public void run() {
                                    String lockNumHead = ardTankLock.getLockNum().substring(0,2);
@@ -197,9 +195,13 @@
                                    String paramsStr = "%7B%22type%22%3A%22ff%22%2C%22dataCnt%22%3A%22" + ardTankLock.getLockNum() + "01" + checkNum + "%22%7D";
                                    sendCmd(finalSyURL,userId,ardTankLock.getCarId(),199,"DataDownTransfer", paramsStr,sessionId);
                                    PositionContainer.getCarThreadMap().remove(ardTankLock.getCarId());//发送完,从容器去除
                                }
                            };
                            LockThread.start();
                            if(PositionContainer.getCarThreadMap().get(ardTankLock.getCarId()) != null){//容器中无线程,放入容器
                                PositionContainer.getCarThreadMap().put(ardTankLock.getCarId(),lockThread);
                            }
                            lockThread.start();
                        }
                    }
                };
@@ -232,7 +234,7 @@
                List<ArdTankLock> result = ardTankLockService.getArdTankLockAll();//查询全部电磁锁
                for(ArdTankLock ardTankLock : result){
                    Thread LockThread = new Thread(finalSyURL){
                Thread lockThread = new Thread(finalSyURL){
                        @Override
                        public void run() {
                            //获取时间并拆分年月日时分秒
@@ -284,9 +286,13 @@
                            String paramsStr = "%7B%22type%22%3A%22ff%22%2C%22dataCnt%22%3A%22" + ardTankLock.getLockNum() + "08" + timeHex + checkNum + "%22%7D";
                            sendCmd(finalSyURL,userId,ardTankLock.getCarId(),199,"DataDownTransfer", paramsStr,sessionId);
                        PositionContainer.getCarThreadMap().remove(ardTankLock.getCarId());//发送完,从容器去除
                        }
                    };
                    LockThread.start();
                if(PositionContainer.getCarThreadMap().get(ardTankLock.getCarId()) != null){//容器中无线程,放入容器
                    PositionContainer.getCarThreadMap().put(ardTankLock.getCarId(),lockThread);
                }
                lockThread.start();
                }
            }
        };
@@ -316,7 +322,7 @@
        }
        Timer alarmTimer = new Timer();//定时获取报警
        /*Timer alarmTimer = new Timer();//定时获取报警
        TimerTask alarmTask = new TimerTask(){
            @Override
            public void run() {
@@ -329,7 +335,7 @@
                alarmThread.start();
            }
        };
        alarmTimer.scheduleAtFixedRate(alarmTask,date,3000);
        alarmTimer.scheduleAtFixedRate(alarmTask,date,3000);*/
    }