1、传输kafka数据添加字段归属矿场

src/main/java/com/censoft/flink/StreamingJob.java

@@ -84,6 +84,9 @@ public class StreamingJob {
             //获取摄像头名称
             warnPushBase.setAlarmDeviceName(getAlgorithmCameraPoByRtsp(algorithmCameraPoList,algorithmPushDto.getCameraName())
                     .getCameraName());
+            //获取摄像头归属
+            warnPushBase.setBelong(getAlgorithmCameraPoByRtsp(algorithmCameraPoList,algorithmPushDto.getCameraName())
+                    .getBelong());
             warnPushBase.setGradeName("二级预警");
             //获取摄像头名称
             warnPushBase.setGradeType(getAlgorithmPoById(algorithmPoList,Long.valueOf(algorithmPushDto.getAlgorithmName()))

src/main/java/com/censoft/flink/domain/AlgorithmCameraPo.java

@@ -27,6 +27,9 @@ public class AlgorithmCameraPo implements Serializable {
     /** 帐号状态（0正常 */
     private String status;
 
+    /** 归属矿场 */
+    private String belong;
+
     /** 删除标志（0代表存在 */
     private String delFlag;
 }

src/main/java/com/censoft/flink/domain/AlgorithmWarnPushDto.java

@@ -37,6 +37,9 @@ public class AlgorithmWarnPushDto {
     /** 删除标记 */
     private Integer delFlag;
 
+    /** 归属矿场 */
+    private String belong;
+
     /** 备注 */
     private String remark;
 }

src/main/java/com/censoft/flink/mapper/AlgorithmSceneDao.xml

@@ -51,6 +51,7 @@
             camera_name as cameraName,
             rtsp,
             sort,
+            belong,
             STATUS,
             del_flag as delFlag
         FROM