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; } }