补充提交吸虫塔的订阅topic

src/main/java/com/yunfeiyun/agmp/iots/core/mqtt/DeviceTopicService.java

@@ -96,6 +96,8 @@ public class DeviceTopicService {
                 return getYrSfDeviceBatchSubTopic(deviceId);
             case ServiceNameConst.SERVICE_YF_XYCB_III:
                 return getYfXycbIIIBatchSubTopic(deviceId);
+            case ServiceNameConst.SERVICE_YF_XCT:
+                return getYfXctDeviceBatchSubTopic(deviceId);
             default: {
                 throw new IotBizException(IotErrorCode.FAILURE.getCode(), serviceName + "不存在对应topic 解析");
             }
@@ -138,6 +140,19 @@ public class DeviceTopicService {
         return getTopics(deviceId, topicArray);
     }
 
+    // 吸虫塔是另类的测报灯，多订阅一个图片
+    private String[] getYfXctDeviceBatchSubTopic(String[] deviceId) {
+        String[] topicArray = {
+                IotMqttConstant.YFCbdTopic.TOPIC_CBD_REPORT_PREFIX,
+                IotMqttConstant.YFCbdTopic.TOPIC_CBD_OFFLINE_PREFIX,
+                IotMqttConstant.YFCbdTopic.TOPIC_CBD_PHOTO_PREFIX,
+                IotMqttConstant.YFCbdTopic.TOPIC_CBD_HISTORY_REPORT_PREFIX,
+                IotMqttConstant.YFCbdTopic.TOPIC_CBD_PHOTO_HISTORY_REPORT_PREFIX,
+                IotMqttConstant.YFXctTopic.TOPIC_XCT_PEST_IMG
+        };
+        return getTopics(deviceId, topicArray);
+    }
+
     private String[] getBySfBatchSubTopic(String[] deviceId) {
 
         String[] topics = new String[0];