增加冒烟告警视频

src/main/java/com/chuanghai/travelbigdata/disease/command/dao/WarningOfSmokeRecordDao.java

@@ -7,8 +7,10 @@ import com.chuanghai.travelbigdata.disease.command.entity.WarningOfSmokeRecordEn
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * 冒烟警告记录 
@@ -23,4 +25,8 @@ public interface WarningOfSmokeRecordDao extends BaseMapper<WarningOfSmokeRecord
     IPage<WarningOfSmokeRecordEntity> getRecords(@Param("page") IPage<WarningOfSmokeRecordEntity> page, @Param("queryDTO") WarningOfSmokeQueryDTO queryDTO);
 
     List<WarningOfSmokePushRecordEntity> getPushRecords(@Param("recordId") Long recordId);
+
+    @Select("insert into warning_of_smoke_video (id,video,images) values \n" +
+            "(uuid(),#{video},#{pic})")
+    Integer insertVideoByPic(@Param("video") String video,@Param("pic") String pic);
 }

src/main/java/com/chuanghai/travelbigdata/disease/command/service/impl/WarningOfSmokeRecordServiceImpl.java

@@ -79,7 +79,9 @@ public class WarningOfSmokeRecordServiceImpl extends ServiceImpl<WarningOfSmokeR
             entity.setPublishTime(cameraAlarmMessageDTO.getCreated_at());
             entity.setImages(cameraAlarmMessageDTO.getImage());
             entity.setHandleStatus("1"); // 1未处理、2已处理
-
+            //2024年5月30日新增保存视频
+            int count=this.baseMapper.insertVideoByPic(cameraAlarmMessageDTO.getVideo(),cameraAlarmMessageDTO.getImage());
+            log.info("保存视频【{}】条", count);
             this.save(entity);
 
             // 冒烟统计数据+1