工单推送

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/dto/HYGFMaintenanceTicketsDto.java

@@ -9,6 +9,7 @@ import lombok.Data;
 import lombok.EqualsAndHashCode;
 import org.joda.time.DateTime;
 
+import java.util.Date;
 import java.util.List;
 
 @Data
@@ -44,12 +45,12 @@ public class HYGFMaintenanceTicketsDto extends BaseDto {
      * 告警开始时间
      */
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
-    private String warningStartTime;
+    private Date warningStartTime;
     /**
      * 告警开始时间
      */
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
-    private String warningEndTime;
+    private Date warningEndTime;
     /**
      * 告警时长
      */

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/entity/TdHygfJpInverterWarn.java

@@ -19,6 +19,8 @@ import java.util.Date;
 public class TdHygfJpInverterWarn {
 
 	private static final long serialVersionUID = 1L;
+	@TableField("created_time")
+	private Long createdTime;
 
 	/**
 	 * sn编码
@@ -48,13 +50,13 @@ public class TdHygfJpInverterWarn {
 	 * 起始时间
 	 */
 	@TableField("start_time")
-	private Date startTime;
+	private Long startTime;
 
 	/**
 	 * 恢复时间
 	 */
 	@TableField("recover_time")
-	private Date recoverTime;
+	private Long recoverTime;
 
 	/**
 	 * 处理方法
@@ -62,11 +64,11 @@ public class TdHygfJpInverterWarn {
 	@TableField("treatment")
 	private String treatment;
 
-	/**
-	 * 逆变器id
-	 */
-	@TableField("inverter_id")
-	private Long inverterId;
+//	/**
+//	 * 逆变器id
+//	 */
+//	@TableField("inverter_id")
+//	private Long inverterId;
 
 	/**
 	 * 第三方电站id
@@ -91,5 +93,10 @@ public class TdHygfJpInverterWarn {
 	 */
 	@TableField("time")
 	private Long time;
+	/**
+	 * 处理状态
+	 */
+	@TableField("handler_status")
+	private String handlerStatus ;
 
 }

amos-boot-system-jxiop/amos-boot-module-hygf-biz/src/main/java/com/yeejoin/amos/boot/module/hygf/biz/emqx/MaintenanceResultHandlerMessage.java

@@ -111,10 +111,11 @@ public class MaintenanceResultHandlerMessage extends EmqxListener {
                 hygfMaintenanceTickets.setWarningLevel(tdHygfJpInverterWarn.getLevel());
                 hygfMaintenanceTickets.setWarningContent(tdHygfJpInverterWarn.getContent());
                 hygfMaintenanceTickets.setWarningStatus(tdHygfJpInverterWarn.getState());
-                hygfMaintenanceTickets.setWarningStartTime(tdHygfJpInverterWarn.getStartTime());
-
+                hygfMaintenanceTickets.setWarningStartTime(new Date(tdHygfJpInverterWarn.getStartTime()));
             }
             hygfMaintenanceTicketsMapper.insert(hygfMaintenanceTickets);
+            tdHygfJpInverterWarn.setHandlerStatus("未处理");
+            tdHygfJpInverterWarnMapper.insert(tdHygfJpInverterWarn);
             log.info("创建运维工单成功{}", JSON.toJSONString(hygfMaintenanceTickets));
         }
     }