电磁锁串口协议发送加入线程排队提交

zhangnaisong

2024-08-01 93cecfaf0fae080ebd0212adea714726290d0d4a

 ard-work/src/main/java/com/ruoyi/sy/controller/ArdSyCarController.java

@@ -153,6 +153,17 @@
        //删除结束时间为null的记录
        int result = ardTankAbnormalParkAlarmService.deleteArdTankAbnormalParkAlarmByEndTime();

        List<ArdSyCar> ardSyCarAndLockList = ardSyCarService.selectArdSyCarAndTankLock();//查询全部罐车及下挂电磁锁

        for(ArdSyCar ardSyCar : ardSyCarAndLockList){//构造容器
            Map<String,Map<String,Thread>> carMap = new HashMap();//车辆容器
            for(ArdTankLock ardTankLock : ardSyCar.getArdTankLockList()){
                Map<String,Thread> lockMap = new HashMap();//锁容器
                carMap.put(ardTankLock.getLockNum(),lockMap);
            }
            PositionContainer.getCarLockProcessThreadMap().put(ardSyCar.getCarId(),carMap);
        }

        Timer lockStateTimer = new Timer();//定时获取各个锁的状态
        TimerTask lockStateTask =new TimerTask(){
            @Override
@@ -193,11 +204,17 @@
                                    }

                                    String paramsStr = "%7B%22type%22%3A%22ff%22%2C%22dataCnt%22%3A%22" + ardTankLock.getLockNum() + "01" + checkNum + "%22%7D";

                                    try{
                                    sendCmd(finalSyURL,userId,ardTankLock.getCarId(),199,"DataDownTransfer", paramsStr,sessionId);
                                        PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).remove("lockState");
                                    }catch(Exception e){
                                        PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).remove("lockState");
                                    }
                                }
                            };
                            lockThread.start();
                            //lockThread.start();
                            //将状态线程放入容器
                            PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).put("lockState",lockThread);
                        }
                    }
                };
@@ -280,15 +297,21 @@
                            checkNum = checkNum.substring(checkNum.length() - 2,checkNum.length());
                        }
                        String paramsStr = "%7B%22type%22%3A%22ff%22%2C%22dataCnt%22%3A%22" + ardTankLock.getLockNum() + "08" + timeHex + checkNum + "%22%7D";

                            try{
                        sendCmd(finalSyURL,userId,ardTankLock.getCarId(),199,"DataDownTransfer", paramsStr,sessionId);
                    }
                };
                lockThread.start();
                                PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).remove("lockTime");
                            }catch(Exception e){
                                PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).remove("lockTime");
            }
            }
        };
        lockCheckTimeTimer.scheduleAtFixedRate(lockCheckTimeTask,date,7000);
                    //lockThread.start();
                    PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).put("lockTime",lockThread);
                }
            }
        };
        //lockCheckTimeTimer.scheduleAtFixedRate(lockCheckTimeTask,date,7000);
        lockCheckTimeTimer.scheduleAtFixedRate(lockCheckTimeTask,date,67000);

        Timer sendTimer = new Timer();//定时发送锁状态
        TimerTask sendLockStateTask = new TimerTask(){
@@ -314,7 +337,8 @@
                ardTankLockService.readPassword(userId,password);
            }
        };
        passwordTimer.scheduleAtFixedRate(passwordTask,date,11000);
        //passwordTimer.scheduleAtFixedRate(passwordTask,date,11000);
        passwordTimer.scheduleAtFixedRate(passwordTask,date,13000);

        Timer lockRestartStateTimer = new Timer();//定时各个锁的复位状态
        TimerTask lockRestartStateTask =new TimerTask(){
@@ -376,11 +400,16 @@
                                            }

                                            String paramsStr = "%7B%22type%22%3A%22ff%22%2C%22dataCnt%22%3A%22" + ardTankLock.getLockNum() + "03" + process + checkNum + "%22%7D";

                                            try{
                                            sendCmd(finalSyURL,userId,ardTankLock.getCarId(),199,"DataDownTransfer", paramsStr,sessionId);
                                                PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).remove("lockRestart");
                                            }catch (Exception e){
                                                PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).remove("lockRestart");
                                            }
                                        }
                                    };
                                    lockThread.start();
                                    //lockThread.start();
                                    PositionContainer.getCarLockProcessThreadMap().get(ardTankLock.getCarId()).get(ardTankLock.getLockNum()).put("lockRestart",lockThread);
                                }
                            }
                        }
@@ -389,7 +418,82 @@
                thread.start();
            }
        };
        lockRestartStateTimer.scheduleAtFixedRate(lockRestartStateTask,date,9000);
        lockRestartStateTimer.scheduleAtFixedRate(lockRestartStateTask,date,17000);

        Set<String> lockNumSet = new HashSet();//存放发送过的锁编号

        Timer mainLockTimer = new Timer();//主定时器
        TimerTask mainLockTask = new TimerTask(){
            @Override
            public void run() {
                Long count = ardTankLockService.getArdTankLockCount();
                if(lockNumSet.size() >= count){//防止锁被删除，采用大于等于
                    lockNumSet.clear();//全部执行过，清空容器
                }
                for(String carId : PositionContainer.getCarLockProcessThreadMap().keySet()){
                    Thread thread = new Thread(){
                        @Override
                        public void run() {
                            Map<String, Map<String,Thread>> lockMap = PositionContainer.getCarLockProcessThreadMap().get(carId);
                            for(String lockNum : lockMap.keySet()){
                                if(lockNumSet.contains(lockNum)){//若执行过，本次忽略
                                    continue;
                                }
                                if(lockMap.get(lockNum).get("lockProcess") != null){
                                    break;//锁操作级别最高
                                }else{
                                    if(lockMap.get(lockNum).get("lockTime") != null){
                                        if(lockMap.get(lockNum).get("lockTime").isAlive()){
                                            lockNumSet.add(lockNum);
                                            break;//锁校时次之
                                        }else{
                                            lockMap.get(lockNum).get("lockTime").start();
                                            lockNumSet.add(lockNum);
                                            break;//锁校时次之
                                        }
                                    }else{
                                        if(lockMap.get(lockNum).get("lockPassword") != null){
                                            if(lockMap.get(lockNum).get("lockPassword").isAlive()){
                                                lockNumSet.add(lockNum);
                                                break;//锁密码次之
                                            }else{
                                                lockMap.get(lockNum).get("lockPassword").start();
                                                lockNumSet.add(lockNum);
                                                break;//锁密码次之
                                            }
                                        }else{
                                            if(lockMap.get(lockNum).get("lockRestart") != null) {
                                                if(lockMap.get(lockNum).get("lockRestart").isAlive()){
                                                    lockNumSet.add(lockNum);
                                                }else{
                                                    lockMap.get(lockNum).get("lockRestart").start();
                                                    lockNumSet.add(lockNum);
                                                    break;//锁复位次之
                                                }
                                            }else{
                                                if(lockMap.get(lockNum).get("lockState") != null) {
                                                    if(lockMap.get(lockNum).get("lockState").isAlive()){
                                                        lockNumSet.add(lockNum);
                                                    }else{
                                                        lockMap.get(lockNum).get("lockState").start();
                                                        lockNumSet.add(lockNum);
                                                        break;//锁状态次之
                                                    }
                                                }else{
                                                    break;
                                                }
                                            }
                                        }
                                    }
                                }
                            }
                        }
                    };
                    thread.start();
                }
            }
        };
        mainLockTimer.scheduleAtFixedRate(mainLockTask,date,2000);

    }