代码调整

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

@@ -11,8 +11,8 @@ import org.joda.time.DateTime;
 @Data
 @EqualsAndHashCode(callSuper = true)
 @Accessors(chain = true)
-@TableName("hygf_om_tickets")
-public class HYGFOMTickets extends BaseEntity {
+@TableName("hygf_maintenance_tickets")
+public class HYGFMaintenanceTickets extends BaseEntity {
     private static final long serialVersionUID = 1L;
     /**
      * 工单处理状态
@@ -22,7 +22,7 @@ public class HYGFOMTickets extends BaseEntity {
     /**
      * 场站名称
      */
-    @TableField("staion_name")
+    @TableField("station_name")
     private String stationName;
     /**
      * 逆变器sn编码
@@ -92,7 +92,7 @@ public class HYGFOMTickets extends BaseEntity {
     /**
      * 场站运维人员id
      */
-    @TableField("opreater_person_id")
+    @TableField("maintenance_person_id")
     private String opreaterPersonId;
     /**
      * 场站经度
@@ -107,17 +107,30 @@ public class HYGFOMTickets extends BaseEntity {
     /**
      * 运维人员名称
      */
-    @TableField("opreater_person_name")
+    @TableField("maintenance_person_name")
     private String opreaterPersonName;
     /**
      * 运维人员手机号
      */
-    @TableField("opreate_person_phone")
+    @TableField("maintenance_person_phone")
     private String opreatePersonPhone;
     /**
      * tdengine告警id
      */
     @TableField("warning_id")
     private Long warningId;
+    /**
+     * 区域公司orgCode
+     */
+    @TableField("regional_companies_code")
+    private Long regionalCompaniesCode;
+
+    /**
+     * 经销商orgcode
+     */
+    @TableField("amos_company_code")
+    private Long amosCompanyCode;
+
+
 
 }

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/mapper/HYGFOMTicketsMapper.java → amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/mapper/HYGFMaintenanceTicketsMapper.java

 package com.yeejoin.amos.boot.module.hygf.api.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.yeejoin.amos.boot.module.hygf.api.entity.HYGFOMTickets;
+import com.yeejoin.amos.boot.module.hygf.api.entity.HYGFMaintenanceTickets;
 
-public interface HYGFOMTicketsMapper extends BaseMapper<HYGFOMTickets> {
+public interface HYGFMaintenanceTicketsMapper extends BaseMapper<HYGFMaintenanceTickets> {
 }

amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/service/HYGFOMTicketsService.java → amos-boot-system-jxiop/amos-boot-module-hygf-api/src/main/java/com/yeejoin/amos/boot/module/hygf/api/service/IHYGFMaintenanceTicketsService.java

 package com.yeejoin.amos.boot.module.hygf.api.service;
 
-public interface HYGFOMTicketsService {
+public interface IHYGFMaintenanceTicketsService {
 }

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

+package com.yeejoin.amos.boot.module.hygf.biz.emqx;
+
+import lombok.extern.slf4j.Slf4j;
+import org.eclipse.paho.client.mqttv3.MqttMessage;
+import org.springframework.stereotype.Component;
+import org.typroject.tyboot.component.emq.EmqxListener;
+@Component
+@Slf4j
+public class MaintenanceResultHandlerMessage extends EmqxListener {
+
+    @Override
+    public void processMessage(String s, MqttMessage mqttMessage) throws Exception {
+
+    }
+}