package com.moral.api.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.moral.api.entity.Sensor;
import com.moral.api.mapper.SensorMapper;
import com.moral.api.service.SensorService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.moral.api.util.LogUtils;
import com.moral.constant.Constants;
import com.moral.constant.ResponseCodeEnum;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import javax.servlet.http.HttpServletRequest;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
*
* 服务实现类
*
*
* @author moral
* @since 2021-05-06
*/
@Service
@Transactional
public class SensorServiceImpl extends ServiceImpl implements SensorService {
@Autowired(required = false)
private SensorMapper sensorMapper;
@Autowired
LogUtils logUtils;
@Override
public Map insertOne(Sensor sensor) {
Map resultMap = new HashMap<>();
if (sensor.getName()==null || sensor.getSensorKey()==null){
resultMap.put("code",ResponseCodeEnum.PARAMETERS_IS_MISSING.getCode());
resultMap.put("msg",ResponseCodeEnum.PARAMETERS_IS_MISSING.getMsg());
return resultMap;
}
QueryWrapper wrapper_name = new QueryWrapper<>();
wrapper_name.eq("name",sensor.getName());
wrapper_name.eq("is_delete","0");
if (sensorMapper.selectCount(wrapper_name)!=0){
resultMap.put("code",ResponseCodeEnum.SENSOR_IS_EXIST.getCode());
resultMap.put("msg",ResponseCodeEnum.SENSOR_IS_EXIST.getMsg());
return resultMap;
}
QueryWrapper wrapper_sensorKey = new QueryWrapper<>();
wrapper_sensorKey.eq("sensor_key",sensor.getSensorKey());
wrapper_sensorKey.eq("is_delete","0");
if (sensorMapper.selectCount(wrapper_sensorKey)!=0){
resultMap.put("code",ResponseCodeEnum.SENSOR_KEY_IS_EXIST.getCode());
resultMap.put("msg",ResponseCodeEnum.SENSOR_KEY_IS_EXIST.getMsg());
return resultMap;
}
//sensorMapper.insertOne(sensor);
//操作插入日志
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
String content = "添加因子:"+sensor.getName()+";";
//logUtils.saveOperationForManage(request,content,Constants.INSERT_OPERATE_TYPE);
resultMap.put("code",ResponseCodeEnum.SUCCESS.getCode());
resultMap.put("msg",ResponseCodeEnum.SUCCESS.getMsg());
return resultMap;
}
}