package com.fastbee.mqtt.service.impl;

import com.fastbee.common.core.mq.DeviceReport;
import com.fastbee.common.core.mq.DeviceReportBo;
import com.fastbee.common.core.mq.message.DeviceData;
import com.fastbee.common.enums.ServerType;
import com.fastbee.common.enums.ThingsModelType;
import com.fastbee.common.enums.TopicType;
import com.fastbee.common.exception.ServiceException;
import com.fastbee.common.utils.gateway.mq.TopicsUtils;
import com.fastbee.iot.domain.Device;
import com.fastbee.iot.service.IDeviceService;
import com.fastbee.json.JsonProtocolService;
import com.fastbee.mq.model.ReportDataBo;
import com.fastbee.mq.service.IDataHandler;
import com.fastbee.mq.service.IDeviceReportMessageService;
import io.netty.buffer.Unpooled;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.Optional;

/**
 * 处理类 处理设备主动上报和设备回调信息
 *
 * @author bill
 */
@Service
@Slf4j
public class DeviceReportMessageServiceImpl implements IDeviceReportMessageService {

    @Autowired
    private IDeviceService deviceService;
    @Autowired
    private JsonProtocolService jsonProtocolService;
    @Resource
    private TopicsUtils topicsUtils;
    @Resource
    private IDataHandler dataHandler;


    /**
     * 处理设备主动上报数据
     */
    @Override
    public void parseReportMsg(DeviceReportBo bo) {
        if (bo.getServerType() == ServerType.MQTT) {
            //构建消息
            Device report = buildReport(bo);
            /*获取协议处理器*/
            DeviceData data = DeviceData.builder()
                    .serialNumber(bo.getSerialNumber())
                    .topicName(bo.getTopicName())
                    .productId(report.getProductId())
                    .data(bo.getData())
                    .prop(bo.getProp())
                    .buf(Unpooled.wrappedBuffer(bo.getData()))
                    .build();
            /*根据协议解析后的数据*/
            DeviceReport reportMessage = jsonProtocolService.decode(data, null);

            reportMessage.setSerialNumber(bo.getSerialNumber());
            reportMessage.setProductId(bo.getProductId());
            reportMessage.setPlatformDate(bo.getPlatformDate());
            reportMessage.setServerType(bo.getServerType());
            reportMessage.setUserId(report.getUserId());
            reportMessage.setUserName(report.getUserName());
            reportMessage.setDeviceName(report.getDeviceName());
            processNoSub(reportMessage, bo.getTopicName());
        }
    }

    /**
     * 构建消息
     *
     * @param bo
     */
    @Override
    public Device buildReport(DeviceReportBo bo) {
        String serialNumber = topicsUtils.parseSerialNumber(bo.getTopicName());
        Device device = deviceService.selectDeviceBySerialNumber(serialNumber);
        Optional.ofNullable(device).orElseThrow(() -> new ServiceException("设备不存在"));
        //设置物模型
        String thingsModel = topicsUtils.getThingsModel(bo.getTopicName());
        ThingsModelType thingsModelType = ThingsModelType.getType(thingsModel);
        bo.setType(thingsModelType);
        //产品id
        bo.setProductId(device.getProductId());
        //设备编号
        bo.setSerialNumber(serialNumber);
        return device;
    }


    /**
     * 处理网关设备
     *
     * @param message
     * @param topicName
     */
    private void processNoSub(DeviceReport message, String topicName) {
        //处理设备上报数据
        handlerReportMessage(message, topicName);
    }


    /**
     * 处理设备主动上报属性
     *
     * @param topicName
     * @param message
     */
    public void handlerReportMessage(DeviceReport message, String topicName) {

        if (message.getServerType().equals(ServerType.MQTT)){
            //处理topic以prop结尾上报的数据 (属性)
            if (message.getServerType().equals(ServerType.MQTT)) {
                if (!topicName.endsWith(TopicType.PROPERTY_POST.getTopicSuffix())
                        && !topicName.endsWith(TopicType.PROPERTY_POST_SIMULATE.getTopicSuffix())) {
                    return;
                }
            }
        }

        ReportDataBo report = new ReportDataBo();
        report.setSerialNumber(message.getSerialNumber());
        report.setProductId(message.getProductId());
        report.setDataList(message.getValuesInput().getThingsModelValueRemarkItem());
        report.setType(1);
        report.setSlaveId(message.getSlaveId());
        report.setUserId(message.getUserId());
        report.setUserName(message.getUserName());
        report.setDeviceName(message.getDeviceName());
        //属性上报执行规则引擎
        report.setRuleEngine(true);
        dataHandler.reportData(report);
    }

}