| | |
| | | @Value("${syCar.password}") |
| | | private String password; |
| | | |
| | | private Timer lockStateTimer; |
| | | |
| | | @PostConstruct |
| | | public void init(){ |
| | | ardSyCarController = this; |
| | |
| | | //删除结束时间为null的记录 |
| | | int result = ardTankAbnormalParkAlarmService.deleteArdTankAbnormalParkAlarmByEndTime(); |
| | | |
| | | this.lockStateTimer = new Timer();//定时获取各个锁的状态 |
| | | Timer lockStateTimer = new Timer();//定时获取各个锁的状态 |
| | | TimerTask lockStateTask =new TimerTask(){ |
| | | @Override |
| | | public void run(){ |
| | |
| | | |
| | | 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); |
| | |
| | | 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(); |
| | | } |
| | | } |
| | | }; |
| | |
| | | |
| | | List<ArdTankLock> result = ardTankLockService.getArdTankLockAll();//查询全部电磁锁 |
| | | for(ArdTankLock ardTankLock : result){ |
| | | Thread LockThread = new Thread(finalSyURL){ |
| | | Thread lockThread = new Thread(finalSyURL){ |
| | | @Override |
| | | public void run() { |
| | | //获取时间并拆分年月日时分秒 |
| | |
| | | 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(); |
| | | } |
| | | } |
| | | }; |
| | |
| | | } |
| | | |
| | | |
| | | Timer alarmTimer = new Timer();//定时获取报警 |
| | | /*Timer alarmTimer = new Timer();//定时获取报警 |
| | | TimerTask alarmTask = new TimerTask(){ |
| | | @Override |
| | | public void run() { |
| | |
| | | alarmThread.start(); |
| | | } |
| | | }; |
| | | alarmTimer.scheduleAtFixedRate(alarmTask,date,3000); |
| | | alarmTimer.scheduleAtFixedRate(alarmTask,date,3000);*/ |
| | | |
| | | } |
| | | |