package com.moral.service.impl;
|
|
import com.alibaba.fastjson.JSON;
|
import com.moral.common.bean.PageBean;
|
import com.moral.common.util.RedisUtils;
|
import com.moral.entity.Device;
|
import com.moral.entity.DeviceAdjustValue;
|
import com.moral.entity.DeviceAdjustValueLog;
|
import com.moral.mapper.DeviceAdjustValueLogMapper;
|
import com.moral.mapper.DeviceAdjustValueMapper;
|
import com.moral.mapper.DeviceMapper;
|
import com.moral.service.DeviceAdjustValueService;
|
import org.springframework.stereotype.Service;
|
import tk.mybatis.mapper.entity.Example;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
public class DeviceAdjustValueServiceImpl implements DeviceAdjustValueService{
|
@Resource
|
DeviceAdjustValueMapper adjustValueMapper;
|
@Resource
|
DeviceAdjustValueLogMapper adjustValueLogMapper;
|
@Resource
|
DeviceMapper deviceMapper;
|
@Resource
|
RedisUtils redisUtils;
|
private static Class ENTITY_CLASS = DeviceAdjustValue.class;
|
@Override
|
public PageBean queryByPageBean(PageBean pageBean) {
|
return null;
|
}
|
@Override
|
public DeviceAdjustValue SelectByDeviceId(int deviceId) {
|
DeviceAdjustValue adjustValue = adjustValueMapper.selectByDeviceId(deviceId);
|
return adjustValue;
|
}
|
@Override
|
public void deleteByIds(Integer[] ids) {
|
|
}
|
|
@Override
|
public void addOrModify(DeviceAdjustValue adjustValue) {
|
try{
|
if(adjustValue.getId()==null){
|
adjustValue.setCreateTime(new Date());
|
adjustValueMapper.insertSelective(adjustValue);
|
}else{
|
adjustValue.setUpdateTime(new Date());
|
adjustValueMapper.updateByPrimaryKeySelective(adjustValue);
|
}
|
// 存储到redis
|
Map<String,String> adjustMap = new HashMap<>();
|
if(adjustValue.getValue()!=null&&!adjustValue.getValue().isEmpty()){
|
for(Map.Entry<String,String> entry:adjustValue.getValue().entrySet()){
|
adjustMap.put(entry.getKey(),entry.getValue());
|
if(entry.getValue()!=null){
|
}
|
}
|
if(!adjustMap.isEmpty()){
|
Device device = deviceMapper.selectByPrimaryKey(adjustValue.getDeviceId());
|
String key = RedisUtils.getAdjustKey(device.getMac());
|
redisUtils.set(key,adjustMap);
|
}
|
}
|
// 校正值日志
|
DeviceAdjustValueLog adjustValueLog = new DeviceAdjustValueLog();
|
adjustValueLog.setDeviceId(adjustValue.getDeviceId());
|
adjustValueLog.setCreateTime(adjustValue.getCreateTime());
|
adjustValueLog.setValue(JSON.toJSONString(adjustValue.getValue()));
|
adjustValueLogMapper.insert(adjustValueLog);
|
}
|
catch (Exception ex){
|
throw ex;
|
}
|
}
|
}
|
