package com.whyc.service;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.whyc.dto.Response;
|
import com.whyc.mapper.AlarmVoiceSetMapper;
|
import com.whyc.pojo.AlarmVoiceSet;
|
import com.whyc.util.ActionUtil;
|
import com.whyc.util.CommonUtil;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
|
@Service
|
public class AlarmVoiceSetService {
|
|
@Resource
|
private AlarmVoiceSetMapper mapper;
|
|
public Response InsertNextTimeInterval(AlarmVoiceSet set) {
|
int userId = ActionUtil.getUser().getUId().intValue();
|
set.setUserId(userId);
|
Integer battGroupId = set.getBattGroupId();
|
Long deviceId = set.getDeviceId();
|
Long powerDeviceId = set.getPowerDeviceId();
|
Integer alarmType = set.getAlarmType();
|
//判断新增还是修改
|
//查询表中是否存在 设备id+告警类型一致的,存在则修改;不存在则新增
|
QueryWrapper<AlarmVoiceSet> query = Wrappers.query();
|
query.select("id").eq("alarm_type",alarmType).eq("user_id",userId);
|
if(battGroupId!=null){
|
query.eq("batt_group_id",battGroupId);
|
}else if(deviceId!=null){
|
query.eq("device_id",deviceId);
|
}else{
|
query.eq("power_device_id",powerDeviceId);
|
}
|
query.last(" limit 1");
|
AlarmVoiceSet alarmVoiceSetDb = mapper.selectOne(query);
|
if(alarmVoiceSetDb!=null){ //修改
|
UpdateWrapper<AlarmVoiceSet> update = Wrappers.update();
|
update.set("next_time_interval",set.getNextTimeInterval()).eq("id",alarmVoiceSetDb.getId());
|
mapper.update(null,update);
|
}else{ //新增
|
mapper.insert(set);
|
}
|
return new Response().set(1,true,"设置完成");
|
|
}
|
}
|