package com.ld.igds.common.impl;
|
|
import com.ld.igds.common.CoreSnapService;
|
import com.ld.igds.common.mapper.SnapSerMapper;
|
import com.ld.igds.constant.Constant;
|
import com.ld.igds.models.SnapSer;
|
import com.ld.igds.util.ContextUtil;
|
import com.ld.igds.util.RedisUtil;
|
import org.apache.commons.lang3.time.DateFormatUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.*;
|
|
@Component(CoreSnapService.BEAN_ID)
|
public class CoreSnapServiceImpl implements CoreSnapService {
|
|
|
/**
|
* 抓拍分机缓存前缀
|
*/
|
private String CACHE_KEY_PRE = "SNAP_SER";
|
|
/**
|
* 断电抓拍标记前缀
|
*/
|
private String CACHE_KEY_TAG = "SNAP_TAG";
|
|
@Autowired
|
private SnapSerMapper snapSerMapper;
|
|
@Autowired
|
private RedisUtil redisUtil;
|
|
|
@Override
|
public void setCacheSer(SnapSer snapSer) {
|
if (null == snapSer.getDeptId()) snapSer.setDeptId("0000");
|
String key = CACHE_KEY_PRE + ":" + snapSer.getDeptId() + ":" + snapSer.getSn();
|
redisUtil.set(key, snapSer);
|
}
|
|
@Override
|
public SnapSer getCacheSer(String deptId) {
|
String patten = Constant.APP_NAME + ":" + CACHE_KEY_PRE;
|
Set<String> keys = redisUtil.keys(patten);
|
for (String key : keys) {
|
if (key.indexOf(deptId) >= 0) {
|
return (SnapSer) redisUtil.get(key);
|
}
|
}
|
return null;
|
}
|
|
@Override
|
public SnapSer getCacheSerBySn(String sn) {
|
Set<String> keys = redisUtil.keys(CACHE_KEY_PRE);
|
for (String key : keys) {
|
if (key.indexOf(sn) >= 0) {
|
return (SnapSer) redisUtil.get(key);
|
}
|
}
|
return null;
|
}
|
|
@Override
|
public int updateBySn(String status, String ip, Integer port, String sn) {
|
return snapSerMapper.updateBySn(status, ip, port, sn);
|
}
|
|
@Override
|
public void allOffLine(String companyId) {
|
snapSerMapper.allOffLine(companyId);
|
}
|
|
@Override
|
public void offLine(String sn) {
|
snapSerMapper.offLine(sn);
|
}
|
|
@Override
|
public void connectAdd(String sn, String ip, int port) {
|
int result = updateBySn(Constant.YN_Y, ip, port, sn);
|
|
if (result == 0) {
|
SnapSer ser = new SnapSer();
|
ser.setCompanyId(ContextUtil.getDefaultCompanyId());
|
ser.setId(ContextUtil.getUUID());
|
ser.setName("自动添加");
|
ser.setPort(port);
|
ser.setSn(sn);
|
ser.setIp(ip);
|
ser.setStatus(Constant.YN_Y);
|
ser.setUpdateTime(new Date());
|
snapSerMapper.addSer(ser);
|
|
//添加设备
|
this.setCacheSer(ser);
|
}
|
}
|
|
@Override
|
public void setSnapTag(SnapSer snapSer, String warnId) {
|
String key = CACHE_KEY_TAG + ":" + snapSer.getSn();
|
Map<String, String> map = new HashMap<>();
|
map.put("deptId", snapSer.getCompanyId());
|
map.put("companyId", snapSer.getCompanyId());
|
map.put("outId", warnId);
|
map.put("snapSn", snapSer.getSn());
|
map.put("start", DateFormatUtils.format(new Date(), "yyyy-MM-dd HH:mm"));
|
|
//默认存8个小时，后面不管上不上电不在抓拍
|
redisUtil.set(key, map, 8 * 60 * 60);
|
}
|
|
@Override
|
public void removeSnapTag(SnapSer snapSer) {
|
String key = CACHE_KEY_TAG + ":" + snapSer.getSn();
|
redisUtil.del(key);
|
}
|
|
@SuppressWarnings("unchecked")
|
@Override
|
public List<Map<String, String>> getCacheSnapTag() {
|
List<Map<String, String>> array = new ArrayList<>();
|
Set<String> keys = redisUtil.keys(CACHE_KEY_TAG);
|
Map<String, String> result;
|
for (String key : keys) {
|
result = (Map<String, String>) redisUtil.get(key);
|
if (null != result) array.add(result);
|
}
|
return array.size() > 0 ? array : null;
|
}
|
}
|
