package com.genersoft.iot.vmp.netty.business.service.impl;
|
|
import com.genersoft.iot.vmp.netty.business.entity.TalkBackEquipment;
|
import com.genersoft.iot.vmp.netty.business.entity.TalkBackEquipmentRecord;
|
import com.genersoft.iot.vmp.netty.business.mapper.TalkBackEquipmentMapper;
|
import com.genersoft.iot.vmp.netty.business.service.TalkBackEquipmentService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.Date;
|
|
/**
|
* 对讲设备服务实现层
|
* @author zhongrj
|
* @date 2023-03-02
|
*/
|
@Service
|
public class TalkBackEquipmentServiceImpl implements TalkBackEquipmentService {
|
|
@Autowired
|
private TalkBackEquipmentMapper talkBackEquipmentMapper;
|
|
/**
|
* 保存对讲设备数据
|
* @param talkBackEquipment
|
*/
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void save(TalkBackEquipment talkBackEquipment) {
|
//判断设备是否已存在,如果存在则更新,不存在则新增
|
TalkBackEquipment backEquipment = talkBackEquipmentMapper.getTalkBackEquipment(talkBackEquipment.getTerminalNumber());
|
if (null==backEquipment) {
|
talkBackEquipment.setCreateTime(new Date());
|
//新增对接设备数据
|
talkBackEquipmentMapper.saveTalkBackEquipment(talkBackEquipment);
|
}else {
|
talkBackEquipment.setId(backEquipment.getId());
|
//修改
|
talkBackEquipmentMapper.updateTalkBackEquipment(talkBackEquipment);
|
}
|
//判断是否存在设备id
|
if (null != talkBackEquipment.getId()) {
|
TalkBackEquipmentRecord equipmentRecord = new TalkBackEquipmentRecord();
|
equipmentRecord.setTalkBackEquipmentId(talkBackEquipment.getId());
|
equipmentRecord.setStatus(talkBackEquipment.getStatus());
|
// equipmentRecord.setUnitName(talkBackEquipment.getUnitName());
|
// equipmentRecord.setUnitCode(talkBackEquipment.getUnitCode());
|
// equipmentRecord.setPoliceName(talkBackEquipment.getPoliceName());
|
// equipmentRecord.setPoliceCode(talkBackEquipment.getPoliceCode());
|
equipmentRecord.setTerminalNumber(talkBackEquipment.getTerminalNumber());
|
equipmentRecord.setLongitude(talkBackEquipment.getLongitude());
|
equipmentRecord.setLatitude(talkBackEquipment.getLatitude());
|
equipmentRecord.setSpeed(talkBackEquipment.getSpeed());
|
equipmentRecord.setDirection(talkBackEquipment.getDirection());
|
equipmentRecord.setElevation(talkBackEquipment.getElevation());
|
equipmentRecord.setPrecisions(talkBackEquipment.getPrecisions());
|
equipmentRecord.setReceiveTime(talkBackEquipment.getReceiveTime());
|
equipmentRecord.setCreateTime(new Date());
|
//新增记录信息
|
talkBackEquipmentMapper.saveTalkBackEquipmentRecord(equipmentRecord);
|
}
|
}
|
}
|