package com.ruoyi.system.service.impl;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
import java.util.stream.IntStream;
|
|
import com.ruoyi.common.core.redis.RedisCache;
|
import com.ruoyi.common.utils.DateUtils;
|
import com.ruoyi.common.utils.StringUtils;
|
import com.ruoyi.common.utils.netty.ConcurrentHashMapBean;
|
import com.ruoyi.common.utils.netty.NettyTool;
|
import io.netty.util.internal.ObjectUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import com.ruoyi.system.mapper.NettyUpgradeStcdInfoMapper;
|
import com.ruoyi.system.domain.NettyUpgradeStcdInfo;
|
import com.ruoyi.system.service.INettyUpgradeStcdInfoService;
|
|
/**
|
* 设备信息Service业务层处理
|
*
|
* @author ruoyi
|
* @date 2022-10-11
|
*/
|
@Service
|
public class NettyUpgradeStcdInfoServiceImpl implements INettyUpgradeStcdInfoService {
|
|
@Autowired
|
private RedisCache redisCache;
|
@Autowired
|
private NettyUpgradeStcdInfoMapper nettyUpgradeStcdInfoMapper;
|
|
/**
|
* 查询设备信息
|
*
|
* @param id 设备信息主键
|
* @return 设备信息
|
*/
|
@Override
|
public NettyUpgradeStcdInfo selectNettyUpgradeStcdInfoById(Integer id) {
|
return nettyUpgradeStcdInfoMapper.selectNettyUpgradeStcdInfoById(id);
|
}
|
|
/**
|
* 查询设备信息列表
|
*
|
* @param nettyUpgradeStcdInfo 设备信息
|
* @return 设备信息
|
*/
|
@Override
|
public List<NettyUpgradeStcdInfo> selectNettyUpgradeStcdInfoList(NettyUpgradeStcdInfo nettyUpgradeStcdInfo) {
|
return nettyUpgradeStcdInfoMapper.selectNettyUpgradeStcdInfoList(nettyUpgradeStcdInfo);
|
}
|
|
|
/**
|
* 新增设备信息
|
*
|
* @param nettyUpgradeStcdInfo 设备信息
|
* @return 结果
|
*/
|
@Override
|
public int insertNettyUpgradeStcdInfo(NettyUpgradeStcdInfo nettyUpgradeStcdInfo) {
|
return nettyUpgradeStcdInfoMapper.insertNettyUpgradeStcdInfo(nettyUpgradeStcdInfo);
|
}
|
|
/**
|
* 修改设备信息
|
*
|
* @param nettyUpgradeStcdInfo 设备信息
|
* @return 结果
|
*/
|
@Override
|
public int updateNettyUpgradeStcdInfo(NettyUpgradeStcdInfo nettyUpgradeStcdInfo) {
|
nettyUpgradeStcdInfo.setUpdateTime(DateUtils.getNowDate());
|
return nettyUpgradeStcdInfoMapper.updateNettyUpgradeStcdInfo(nettyUpgradeStcdInfo);
|
}
|
|
/**
|
* 批量删除设备信息
|
*
|
* @param ids 需要删除的设备信息主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteNettyUpgradeStcdInfoByIds(Integer[] ids) {
|
return nettyUpgradeStcdInfoMapper.deleteNettyUpgradeStcdInfoByIds(ids);
|
}
|
|
/**
|
* 删除设备信息信息
|
*
|
* @param id 设备信息主键
|
* @return 结果
|
*/
|
@Override
|
public int deleteNettyUpgradeStcdInfoById(Integer id) {
|
return nettyUpgradeStcdInfoMapper.deleteNettyUpgradeStcdInfoById(id);
|
}
|
|
@Override
|
public List<NettyUpgradeStcdInfo> list(NettyUpgradeStcdInfo nettyUpgradeStcdInfo) {
|
//获取redis上的数据
|
Map<String, NettyUpgradeStcdInfo> map = redisCache.getCacheMap("NettyUpgradeStcdInfo");
|
List<NettyUpgradeStcdInfo> list = new ArrayList<>();
|
|
// if (StringUtils.isNotEmpty(nettyUpgradeStcdInfo.getStcd()) ){
|
// Integer stcdint=Integer.parseInt(nettyUpgradeStcdInfo.getStcd());
|
// String hexStr=Integer.toHexString(stcdint);
|
// hexStr= NettyTool.addleftForNum(hexStr,6);
|
// String stcdHexStr=hexStr.substring(4,6)+hexStr.substring(2,4)+hexStr.substring(0,2);
|
// if (map.containsKey(stcdHexStr)){
|
// //补位
|
// Map<String, NettyUpgradeStcdInfo> nettymap=new HashMap<>();
|
// nettymap.put(stcdHexStr,map.get(stcdHexStr));
|
// map=nettymap;
|
// }else {
|
// return list;
|
// }
|
// }
|
if (nettyUpgradeStcdInfo.getStartNumber()!=null && nettyUpgradeStcdInfo.getEndNumber()!=null){
|
Map<String, NettyUpgradeStcdInfo> nettymap=new HashMap<>();
|
List<Integer> numberList = IntStream.rangeClosed(nettyUpgradeStcdInfo.getStartNumber(), nettyUpgradeStcdInfo.getEndNumber()).boxed().collect(Collectors.toList());
|
for (Integer number:numberList){
|
String hexStr=Integer.toHexString(number);
|
hexStr= NettyTool.addleftForNum(hexStr,6);
|
String stcdHexStr=hexStr.substring(4,6)+hexStr.substring(2,4)+hexStr.substring(0,2);
|
if (map.containsKey(stcdHexStr)){
|
//补位
|
nettymap.put(stcdHexStr,map.get(stcdHexStr));
|
}
|
}
|
map=nettymap;
|
if (map.keySet().size()==0){
|
return list;
|
}
|
}
|
|
for (String stcd : map.keySet()) {
|
NettyUpgradeStcdInfo nettyUpgradeStcdInfo1 = map.get(stcd);
|
if (!ConcurrentHashMapBean.channelMap.keySet().contains(stcd)) {
|
//离线
|
nettyUpgradeStcdInfo1.setState(2);
|
} else {
|
nettyUpgradeStcdInfo1.setState(0);
|
}
|
Integer stcdInt = Integer.parseInt(stcd.substring(4, 6) + stcd.substring(2, 4) + stcd.substring(0, 2), 16);
|
nettyUpgradeStcdInfo1.setStcd(stcdInt.toString());
|
if (nettyUpgradeStcdInfo1.getState() != 2) {
|
list.add(nettyUpgradeStcdInfo1);
|
}
|
}
|
return list;
|
}
|
}
|
