package com.ard.alarm.apponekey.service.impl;

import java.util.Date;
import java.util.List;

import com.alibaba.fastjson2.JSON;
import com.ard.utils.mqtt.MqttConsumer;
import com.ard.utils.uuid.IdUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import com.ard.alarm.apponekey.domain.ArdAlarmApponekey;
import com.ard.alarm.apponekey.service.IArdAlarmApponekeyService;


/**
 * app一键报警Service业务层处理
 *
 * @author ard
 * @date 2023-07-21
 */
@Service
@Slf4j(topic = "apponekey")
public class ArdAlarmApponekeyServiceImpl implements IArdAlarmApponekeyService {

    /**
     * 新增app一键报警
     *
     * @param ardAlarmApponekey app一键报警
     * @return 结果
     */
    @Override
    public int insertArdAlarmApponekey(ArdAlarmApponekey ardAlarmApponekey) {
        try {
            ardAlarmApponekey.setId(IdUtils.fastSimpleUUID());
            ardAlarmApponekey.setCreateTime(new Date());
            printLog(ardAlarmApponekey);
            MqttConsumer.publish(2, false, "apponekey", JSON.toJSONString(ardAlarmApponekey));
            return 1;
        } catch (Exception ex) {
            log.error("一键报警处理异常:" + ex.getMessage());
            return 0;
        }
    }

    private void printLog(ArdAlarmApponekey ardAlarmApponekey) {
        log.debug("收到数据:" + "【ID】" + ardAlarmApponekey.getId() + "【userId】" + ardAlarmApponekey.getUserId()
                + "【经度】" + ardAlarmApponekey.getLongitude() + "【纬度】" + ardAlarmApponekey.getLatitude()
                + "【高层】" + ardAlarmApponekey.getAltitude() + "【创建时间】" + ardAlarmApponekey.getCreateTime());
    }

}