package com.tievd.jyz.mqtt;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.tievd.jyz.handler.BaseDataSyncHandler;
|
import com.tievd.jyz.handler.DeviceStatusHandler;
|
import com.tievd.jyz.handler.EventInfoHandler;
|
import com.tievd.jyz.handler.PatrolConfigHandler;
|
import com.tievd.jyz.mqtt.dto.MqttParamDTO;
|
import com.tievd.jyz.service.IDeviceService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* mqtt消息接收分发者
|
* @author timi
|
*/
|
@Component
|
@Slf4j
|
public class MqttMsgReceiver {
|
|
/** 一体机注册 */
|
public static final String REGISTER = "register";
|
/** aibox按定时周期上报状态数据，状态数据均为周期内的平均值 */
|
public static final String HEARTBEAT = "heartbeat";
|
/** aibox初始化完成后，上报终端和加油位的修改时间 */
|
public static final String BASE_UPDATE_CHECK = "baseUpdateCheck";
|
/** aibox上报终端/加油位信息至业务平台 */
|
public static final String BASE_UPDATE = "baseUpdate";
|
/** aaibox上报检测事件到业务平台 */
|
public static final String EVENT_INFO = "eventInfo";
|
/** aaibox检测卸油事件到业务平台 */
|
public static final String OIL_OUT_EVENT = "oilOutEventInfo";
|
/** 业务平台根据业务流转需求，获取事件相关资源 */
|
public static final String EVENT_RESOURCE = "eventResource";
|
/** 业务平台根据业务流转需求，获取事件相关资源 */
|
public static final String CUT_VIDEO = "cutVideo";
|
/** aobox上报巡查配置 */
|
public static final String PATROL_CONFIG = "patrolConfig";
|
|
@Autowired
|
private IDeviceService deviceService;
|
@Autowired
|
private BaseDataSyncHandler baseDataSyncHandler;
|
@Autowired
|
private EventInfoHandler eventInfoHandler;
|
@Autowired
|
private PatrolConfigHandler patrolConfigHandler;
|
|
|
/**
|
* 处理mqtt接收到的指令消息
|
*
|
* @param message
|
*/
|
@Async("commandTaskAsyncPool")
|
public void dealCommandMsg(String message) {
|
MqttParamDTO mqttParamDTO = JSONObject.parseObject(message, MqttParamDTO.class);
|
String type = mqttParamDTO.getType();
|
switch (type) {
|
case REGISTER:
|
log.info("接收到一体机注册信息,msg:{}",message);
|
deviceService.register(mqttParamDTO);
|
break;
|
case HEARTBEAT:
|
log.info("接收到一体机心跳信息,msg:{}", message.length() > 100 ? message.substring(0, 100) : message);
|
DeviceStatusHandler.heartbeat(mqttParamDTO);
|
break;
|
case BASE_UPDATE_CHECK:
|
log.info("aibox初始化完成后，上报终端和加油位的修改时间,msg:{}",message);
|
baseDataSyncHandler.baseUpdateCheck(mqttParamDTO);
|
break;
|
case BASE_UPDATE:
|
log.info("aibox上报终端/加油位信息至业务平台,msg:{}",message);
|
baseDataSyncHandler.baseInfoUpdate(mqttParamDTO);
|
break;
|
case EVENT_RESOURCE:
|
log.info("接收事件相关资源,msg:{}",message);
|
eventInfoHandler.resource(mqttParamDTO);
|
break;
|
case PATROL_CONFIG:
|
log.info("接收巡查配置,msg:{}",message);
|
patrolConfigHandler.configPatrol(mqttParamDTO);
|
break;
|
case CUT_VIDEO:
|
log.info("获取截取的视频录像");
|
//TODimgUidO
|
break;
|
default:
|
break;
|
}
|
}
|
|
/**
|
* 处理mqtt接收到的事件消息
|
*
|
* @param message
|
*/
|
@Async("eventTaskAsyncPool")
|
public void dealEventMsg(String message) {
|
log.info("------------------> 接受到事件信息：{}", message);
|
MqttParamDTO mqttParamDTO = JSONObject.parseObject(message, MqttParamDTO.class);
|
String type = mqttParamDTO.getType();
|
switch (type) {
|
case EVENT_INFO:
|
eventInfoHandler.event(mqttParamDTO);
|
break;
|
default:
|
break;
|
}
|
}
|
}
|
