| | |
| | | import com.ard.alarm.camera.domain.ArdCameras;
|
| | | import com.ard.alarm.camera.mapper.ArdCamerasMapper;
|
| | | import com.ard.alarm.camera.service.IArdCamerasService;
|
| | | import com.ard.alarm.external.domain.ArdEquipExternal;
|
| | | import com.ard.alarm.external.mapper.ArdEquipExternalMapper;
|
| | | import com.ard.utils.hiksdk.service.impl.HikClientUtil;
|
| | | import com.ard.utils.sdk.hiksdk.common.GlobalVariable;
|
| | | import com.ard.utils.sdk.hiksdk.service.impl.HikClientUtil;
|
| | | import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
| | | import lombok.extern.slf4j.Slf4j;
|
| | |
| | | import org.springframework.core.annotation.Order;
|
| | | import org.springframework.stereotype.Service;
|
| | |
|
| | | import javax.annotation.PostConstruct;
|
| | | import javax.annotation.Resource;
|
| | |
|
| | | /**
|
| | |
| | | //初始化执行
|
| | | @Override
|
| | | public void run(ApplicationArguments args) {
|
| | | //获取小光电尝试登录
|
| | | ardCameraList = selectArdCamerasList(new ArdCameras());
|
| | | HikClientUtil.loginAllCamera(ardCameraList);
|
| | | syncCameraListTask();
|
| | | syncCameraTask();
|
| | | }
|
| | |
|
| | | /**
|
| | |
| | | * 刘苏义
|
| | | * 2023/8/11 9:09:27
|
| | | */
|
| | | private void syncCameraListTask() {
|
| | | private void syncCameraTask() {
|
| | | scheduler.scheduleAtFixedRate(() -> {
|
| | | try {
|
| | | //region 定时同步小光电
|
| | | //region 定时同步光电设备
|
| | | List<ArdCameras> newArdCameraList = selectArdCamerasList(new ArdCameras());
|
| | | //需要更新的数据
|
| | | List<ArdCameras> updateList = sameListWithDifferent(ardCameraList, newArdCameraList);
|
| | |
| | | */
|
| | | @Override
|
| | | public List<ArdCameras> selectArdCamerasList(ArdCameras ardCamera) {
|
| | | ardCamera.setGdType("0");
|
| | | ardCamera.setFactory("1");
|
| | | Wrapper<ArdCameras> queryWrapper=new QueryWrapper<>(ardCamera);
|
| | | return ardCamerasMapper.selectList(queryWrapper);
|
| | | }
|