增加mq消息日志打印

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

@@ -5,6 +5,7 @@ import com.chuanghai.travelbigdata.disease.command.dto.WarningOfSmokeQueryDTO;
 import com.chuanghai.travelbigdata.disease.command.entity.WarningOfSmokePushRecordEntity;
 import com.chuanghai.travelbigdata.disease.command.entity.WarningOfSmokeRecordEntity;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Insert;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.Select;
@@ -26,7 +27,7 @@ public interface WarningOfSmokeRecordDao extends BaseMapper<WarningOfSmokeRecord
 
     List<WarningOfSmokePushRecordEntity> getPushRecords(@Param("recordId") Long recordId);
 
-    @Select("insert into warning_of_smoke_video (id,video,images) values \n" +
+    @Insert("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

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