户用光伏mapper文件位置错误问题解决

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

+package com.yeejoin.amos.boot.module.hygf.api.dto;
+
+import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
+import io.swagger.annotations.ApiModel;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value="HYGFMaintenanceTicketsDto", description="运维工单")
+public class HYGFMaintenanceTicketsDto extends BaseDto {
+
+}

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

@@ -99,7 +99,7 @@ public class HYGFMaintenanceTickets extends BaseEntity {
      * 场站运维人员id
      */
     @TableField("maintenance_person_id")
-    private String opreaterPersonId;
+    private String maintenancePersonId;
     /**
      * 场站经度
      */
@@ -109,17 +109,17 @@ public class HYGFMaintenanceTickets extends BaseEntity {
      * 场站纬度
      */
     @TableField("station_latitude")
-    private String staionLatitude;
+    private String stationLatitude;
     /**
      * 运维人员名称
      */
     @TableField("maintenance_person_name")
-    private String opreaterPersonName;
+    private String maintenancePersonName;
     /**
      * 运维人员手机号
      */
     @TableField("maintenance_person_phone")
-    private String opreatePersonPhone;
+    private String maintenancePersonPhone;
     /**
      * tdengine告警id
      */

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 cn.hutool.core.util.ObjectUtil;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.yeejoin.amos.boot.module.hygf.api.entity.HYGFMaintenanceTickets;
+import com.yeejoin.amos.boot.module.hygf.api.entity.JpStation;
+import com.yeejoin.amos.boot.module.hygf.api.entity.Maintenance;
+import com.yeejoin.amos.boot.module.hygf.api.entity.TdHygfJpInverterWarn;
+import com.yeejoin.amos.boot.module.hygf.api.mapper.HYGFMaintenanceTicketsMapper;
+import com.yeejoin.amos.boot.module.hygf.api.mapper.JpStationMapper;
+import com.yeejoin.amos.boot.module.hygf.api.mapper.MaintenanceMapper;
+import com.yeejoin.amos.boot.module.hygf.api.tdenginemapper.TdHygfJpInverterWarnMapper;
 import lombok.extern.slf4j.Slf4j;
 import org.eclipse.paho.client.mqttv3.MqttMessage;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
+import org.typroject.tyboot.component.emq.EmqKeeper;
 import org.typroject.tyboot.component.emq.EmqxListener;
+
+import javax.annotation.PostConstruct;
+
 @Component
 @Slf4j
 public class MaintenanceResultHandlerMessage extends EmqxListener {
+    public static final String WARNING_RESULT_MESSAGE = "+/warning/result";
+    public static final String HYGF_MAINTENANCE_RESULT_MESSAGE = "hygfmaintenance";
+
+    @Autowired
+    EmqKeeper emqKeeper;
+    //工单mapper
+    @Autowired
+    HYGFMaintenanceTicketsMapper hygfMaintenanceTicketsMapper;
+    @Autowired
+    JpStationMapper jpStationMapper;
+    @Autowired
+    TdHygfJpInverterWarn tdHygfJpInverterWarn;
+    @Autowired
+    TdHygfJpInverterWarnMapper tdHygfJpInverterWarnMapper;
+    @Autowired
+    MaintenanceMapper maintenanceMapper;
+
+    @PostConstruct
+    void init() throws Exception {
+        emqKeeper.subscript(WARNING_RESULT_MESSAGE, 2, this);
+    }
 
     @Override
-    public void processMessage(String s, MqttMessage mqttMessage) throws Exception {
+    public void processMessage(String topic, MqttMessage message) throws Exception {
+        if (topic.contains(HYGF_MAINTENANCE_RESULT_MESSAGE)) {
+            log.info("收到户用光伏工单推送-消息{}", new String(message.getPayload()));
+            JSONObject jsonObject = JSON.parseObject(new String(message.getPayload()));
+            JxiopUpdateMaintenance(jsonObject);
+        }
+    }
 
+    @Async("async")
+    public void JxiopUpdateMaintenance(JSONObject jsonObject) {
+        JSONObject rawData = jsonObject.getJSONObject("rawData");
+        JSONObject bizInfo = rawData.getJSONObject("bizInfo");
+        HYGFMaintenanceTickets hygfMaintenanceTickets = new HYGFMaintenanceTickets();
+        String warningObjectName = "";
+        String warningObjectCode = "";//station_id@inverter_sn@maintenance_id@warn_id
+        String[] codes = warningObjectCode.split("@");
+        JpStation jpStation = jpStationMapper.selectOne(new QueryWrapper<JpStation>().eq("station_id", codes[0]));
+        TdHygfJpInverterWarn tdHygfJpInverterWarn = tdHygfJpInverterWarnMapper.selectOne(new QueryWrapper<TdHygfJpInverterWarn>()
+                .eq("thrid_station_id", codes[0])
+                .eq("sn_code", codes[1])
+                .eq("created_time", codes[3])
+        );
+        hygfMaintenanceTickets.setHandlerStatus("未处理");
+        Maintenance maintenance = maintenanceMapper.selectById(codes[2]);
+        if(ObjectUtil.isNotEmpty(maintenance)){
+            hygfMaintenanceTickets.setMaintenancePersonId(codes[2]);
+            hygfMaintenanceTickets.setMaintenancePersonName(maintenance.getName());
+            hygfMaintenanceTickets.setMaintenancePersonPhone(maintenance.getTelephone());
+        }
+        if (ObjectUtil.isNotEmpty(jpStation)) {
+            //场站名称
+            hygfMaintenanceTickets.setStationName(jpStation.getName());
+            //区域公司编码
+            hygfMaintenanceTickets.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
+            //经销商orgCode
+            hygfMaintenanceTickets.setAmosCompanyCode(jpStation.getAmosCompanyCode());
+            //地址
+            hygfMaintenanceTickets.setStationAddress(jpStation.getAddress());
+            //经度
+            hygfMaintenanceTickets.setStationLongitude(jpStation.getLongitude());
+            //纬度
+            hygfMaintenanceTickets.setStationLatitude(jpStation.getLatitude());
+            //电站联系人电话
+//            hygfMaintenanceTickets.setStationContactPhone(jpStation.getContactPhone());
+            //电站联系人
+//            hygfMaintenanceTickets.setStationContact();
+        }
+        if (ObjectUtil.isNotEmpty(tdHygfJpInverterWarn)) {
+            //snCode
+            hygfMaintenanceTickets.setInverterSn(codes[1]);
+            //告警等级
+            hygfMaintenanceTickets.setWarningLevel(tdHygfJpInverterWarn.getLevel());
+
+        }
+        hygfMaintenanceTicketsMapper.insert(hygfMaintenanceTickets);
+        log.info("创建运维工单成功{}", JSON.toJSONString(hygfMaintenanceTickets));
     }
 }