package com.ard.alarm.apponekey.service.impl;
|
|
import java.util.Date;
|
|
import com.alibaba.fastjson2.JSON;
|
import com.ard.utils.mqtt.MqttProducer;
|
import com.ard.utils.util.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);
|
MqttProducer.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());
|
}
|
|
}
|
