| | |
| | | public List<ArdAlarmCamera> selectListAllByCommand(@Param("refreshTime")String refreshTime); |
| | | |
| | | int selectCountByAlarmTime(@Param("refreshTime")String refreshTime); |
| | | |
| | | int updateViewTimeByCameraName(@Param("cameraName")String cameraName,@Param("alarmTime") String alarmTime,@Param("viewTime") String viewTime); |
| | | } |
| | |
| | | ardAlarmStealelecMapper.updateViewTimeByDescribe(describe, startTime, DateUtils.getTime()); |
| | | return ardAlarmStealelec; |
| | | } |
| | | case 1002: |
| | | ArdAlarmCamera ardAlarmCamera = ardAlarmCameraMapper.selectArdAlarmCameraById(condition.getId()); |
| | | if (StringUtils.isNotNull(ardAlarmCamera)) { |
| | | String cameraName = ardAlarmCamera.getCameraName(); |
| | | String alarmTime = fmt.format(ardAlarmCamera.getAlarmTime()); |
| | | ardAlarmCameraMapper.updateViewTimeByCameraName(cameraName, alarmTime, DateUtils.getTime()); |
| | | return ardAlarmCamera; |
| | | } |
| | | case 1003: |
| | | case 1004: |
| | | case 1007: |
| | |
| | | log.info("MQTT连接断开,发起重连......"); |
| | | while (!client.isConnected()) { |
| | | try { |
| | | |
| | | Thread.sleep(5000); |
| | | Thread.sleep(10000); |
| | | if (null != client && !client.isConnected()) { |
| | | client.reconnect(); |
| | | log.error("尝试重新连接"); |
| | |
| | | WHERE aac.alarm_time >= CURRENT_TIMESTAMP - INTERVAL '%${refreshTime}%' MINUTE |
| | | and aac.view_time is null |
| | | </select> |
| | | <update id="updateViewTimeByCameraName" parameterType="String"> |
| | | update ard_alarm_camera |
| | | set view_time=#{viewTime} |
| | | where camera_name = #{cameraName} |
| | | and alarm_time<=#{alarmTime} |
| | | and view_time is null |
| | | </update> |
| | | </mapper> |