|
- package com.yzx;
-
- import com.yzx.callback.AlarmCallback;
- import com.yzx.impl.HKVersion;
- import com.yzx.impl.HardwareEquipmentInfo;
- import com.yzx.pojo.AlarmDataInfo;
-
- import java.util.ArrayList;
- import java.util.List;
-
- public class Main {
-
- private static List<IHardwareEquipment> hardwareEquipmentList = new ArrayList<>();
-
- private static AlarmCallback alarmCallback = new AlarmCallbackImpl();
- public static void main(String[] args) {
- new Main().run();
- }
-
- public void run(){
- //定时任务每分钟执行一次
- //问题 人员名称获取不到?
- //1.通过isapi 的方式获取设备布防状态,如果没有布防,则更新数据库,并重新布防
- //2.一个设备开一个线程处理数据
- //3.如果文件上传失败,需要重试,如果失败了,先存在本地,利用数据库的id作为标识,写一个定时任务,重新更新和上传.
-
- new Thread(() -> {
- IHardwareEquipment hardwareEquipment1 = new HKVersion(new HardwareEquipmentInfo("192.168.69.64",(short) 8000,"admin","yzx123456.",alarmCallback),true,0);
- while (true){}
- // if(hardwareEquipment1.getStatus() == 1){
- // String deployInfo1 = hardwareEquipment1.getDeployInfo();
- // System.out.println("deployInfo = " + deployInfo1);
- // hardwareEquipmentList.add(hardwareEquipment1);
- // while(true){}
- // }
- }).start();
-
- // new Thread(() -> {
- // IHardwareEquipment hardwareEquipment2 = new HKVersion(new HardwareEquipmentInfo("192.168.69.140",(short) 8000,"admin","yzx123456",alarmCallback));
- // if(hardwareEquipment2.getStatus() == 1){
- // String deployInfo2 = hardwareEquipment2.getDeployInfo();
- // System.out.println("deployInfo = " + deployInfo2);
- // hardwareEquipmentList.add(hardwareEquipment2);
- // while(true){}
- // }
- // }).start();
- }
-
- private static class AlarmCallbackImpl implements AlarmCallback{
- @Override
- public void process(AlarmDataInfo info) {
- System.out.println(" 告警回调触发......");
- System.out.println("info = " + info);
- }
- };
- }
|