package com.sandu.ximon.admin.service;
|
|
import com.sandu.common.execption.BusinessException;
|
import com.sandu.common.util.SpringContextHolder;
|
import com.sandu.ximon.admin.config.VnnoxConstant;
|
import com.sandu.ximon.admin.dto.nova.AirDataProgram;
|
import com.sandu.ximon.admin.dto.nova.PlayerLayout;
|
import com.sandu.ximon.admin.dto.nova.PlayerPage;
|
import com.sandu.ximon.admin.dto.nova.PlayerWidget;
|
import com.sandu.ximon.admin.manager.iot.frame.inner.report.A5AtmosphereHeartbeatReportInnerFrame;
|
import com.sandu.ximon.admin.security.SecurityUtils;
|
import com.sandu.ximon.admin.utils.RedisUtils;
|
import com.sandu.ximon.admin.utils.StoreOperationRecordsUtils;
|
import com.sandu.ximon.admin.utils.VnnoxAPIUtil;
|
import com.sandu.ximon.admin.utils.VnnoxProgramAPIUtil;
|
import com.sandu.ximon.admin.utils.request.VnnoxScreenStatusType;
|
import com.sandu.ximon.admin.utils.response.VnnoxPlayerListResponse;
|
import com.sandu.ximon.admin.utils.response.VnnoxPlayerResponse;
|
import com.sandu.ximon.admin.utils.response.VnnoxResult;
|
import com.sandu.ximon.admin.vo.NovaPushResultVO;
|
import com.sandu.ximon.dao.domain.LedPlayerEntity;
|
import com.sandu.ximon.dao.domain.LedPlayerInfoEntity;
|
import com.sandu.ximon.dao.domain.LedV2RegisterResultEntity;
|
import com.sandu.ximon.dao.enums.PoleBindingEnums;
|
import lombok.AllArgsConstructor;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.net.URISyntaxException;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* @Author liuhaonan
|
* @Date 2021/12/22 14:18
|
* @Version 1.0
|
*/
|
@Service
|
@AllArgsConstructor
|
public class VnnoxService {
|
|
|
private VnnoxAPIUtil vnnoxAPIUtil;
|
|
private RedisUtils redisUtils;
|
|
private LedPlayerEntityService ledPlayerEntityService;
|
|
private VnnoxProgramAPIUtil vnnoxProgramAPIUtil;
|
|
/**
|
* 设备校验注册
|
*
|
* @param sn
|
* @return
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
public LedV2RegisterResultEntity validateSN(String name, String sn) throws URISyntaxException {
|
LedV2RegisterResultEntity ledV2RegisterResultEntity = new LedV2RegisterResultEntity();
|
|
// 判断数据库是否存在，若不存在，判断是否已经注册到Vnnox服务器
|
//LedPlayerEntity ledPlayerEntity = vnnoxDao.getBySN(sn);
|
// LambdaQueryWrapper<LedPlayerEntity> eq = Wrappers.lambdaQuery(LedPlayerEntity.class).eq(LedPlayerEntity::getSn, sn);
|
LedPlayerEntity ledPlayerEntity = ledPlayerEntityService.getBySn(sn);
|
if (null != ledPlayerEntity) {
|
ledV2RegisterResultEntity.setRegister(1);
|
ledV2RegisterResultEntity.setMsg("设备已存在!");
|
return ledV2RegisterResultEntity;
|
}
|
|
Integer page = 0;
|
Integer limit = 100;
|
List<VnnoxPlayerResponse> playerList;
|
// 获取Vnnox服务器列表
|
VnnoxPlayerListResponse response = vnnoxAPIUtil.getPlayerList(limit, page, name);
|
playerList = response.getRows();
|
Integer total = response.getTotal() - limit;
|
while (total > 0) {
|
page = page + 1;
|
total = total - limit;
|
response = vnnoxAPIUtil.getPlayerList(limit, page, name);
|
playerList.addAll(response.getRows());
|
}
|
ledPlayerEntity = new LedPlayerEntity();
|
for (VnnoxPlayerResponse res : playerList) {
|
if (res.getSn().equals(sn)) {
|
ledPlayerEntity.setSn(sn);
|
ledPlayerEntity.setPlayerId(res.getPlayerId());
|
ledPlayerEntity.setPlayerName(res.getName());
|
ledPlayerEntity.setCreateTimestamp(new Date().getTime());
|
ledPlayerEntityService.saveLed(ledPlayerEntity);
|
ledV2RegisterResultEntity.setRegister(1);
|
ledV2RegisterResultEntity.setMsg("设备校验通过，设备注册成功!");
|
return ledV2RegisterResultEntity;
|
}
|
}
|
|
ledV2RegisterResultEntity.setRegister(0);
|
ledV2RegisterResultEntity.setMsg("设备未注册到平台!");
|
return ledV2RegisterResultEntity;
|
}
|
|
|
/**
|
* 屏幕状态调整-POST-JSON
|
*
|
* @param playerList
|
* @param screenStatus
|
* @return
|
*/
|
public Map<String, Object> screenStatusChange(List<LedPlayerEntity> playerList, Integer screenStatus) {
|
playerList.forEach(item -> {
|
if (item.getName() == null || item.getPlayerId() == null) {
|
throw new BusinessException("playerId或playerName为空");
|
}
|
if (item.getPlayerId().isEmpty() || item.getName().isEmpty()) {
|
throw new BusinessException("playerId或playerName为空");
|
}
|
});
|
VnnoxScreenStatusType type;
|
if (screenStatus.equals(0)) {
|
type = VnnoxScreenStatusType.CLOSE;
|
} else {
|
type = VnnoxScreenStatusType.OPEN;
|
}
|
|
VnnoxResult vnnoxResult = vnnoxAPIUtil.screenStatus(playerList.stream().map(item -> item.getPlayerId()).collect(Collectors.toList()), type);
|
|
|
List<String> success = vnnoxResult.getSuccess();
|
List<String> fail = vnnoxResult.getFail();
|
//拼接成功失败的结果
|
Map<String, Object> result = new HashMap<>();
|
List<NovaPushResultVO> successList = new ArrayList<>();
|
List<NovaPushResultVO> faileList = new ArrayList<>();
|
List<String> finalSuccess = success;
|
List<String> finalFail = fail;
|
playerList.forEach(n -> {
|
if (finalSuccess.contains(n.getPlayerId())) {
|
NovaPushResultVO vo = new NovaPushResultVO();
|
vo.setName(n.getName());
|
vo.setPlayerId(n.getPlayerId());
|
successList.add(vo);
|
} else if (finalFail.contains(n.getPlayerId())) {
|
NovaPushResultVO vo = new NovaPushResultVO();
|
vo.setName(n.getName());
|
vo.setPlayerId(n.getPlayerId());
|
faileList.add(vo);
|
}
|
});
|
|
result.put("success", successList);
|
result.put("fail", faileList);
|
|
// 根据屏幕状态调整REDIS标识位
|
for (String playerId : vnnoxResult.getSuccess()) {
|
redisUtils.set(VnnoxConstant.REDIS_SCREEN_STATUS + playerId, screenStatus, VnnoxConstant.REDIS_MAX_SAVE_TIME);
|
}
|
return result;
|
}
|
|
public Map<String, Object> volChange(List<LedPlayerEntity> playerList, Integer vol) {
|
playerList.forEach(item -> {
|
if (item.getName() == null || item.getPlayerId() == null) {
|
throw new BusinessException("playerId或playerName为空");
|
}
|
if (item.getPlayerId().isEmpty() || item.getName().isEmpty()) {
|
throw new BusinessException("playerId或playerName为空");
|
}
|
});
|
VnnoxResult vnnoxResult = vnnoxAPIUtil.volChange(playerList.stream().map(item -> item.getPlayerId()).collect(Collectors.toList()), vol);
|
// 根据音量调整REDIS标识位
|
for (String playerId : vnnoxResult.getSuccess()) {
|
redisUtils.set(VnnoxConstant.REDIS_VOL + playerId, vol, VnnoxConstant.REDIS_MAX_SAVE_TIME);
|
}
|
List<String> success = vnnoxResult.getSuccess();
|
List<String> fail = vnnoxResult.getFail();
|
//拼接成功失败的结果
|
Map<String, Object> result = new HashMap<>();
|
List<NovaPushResultVO> successList = new ArrayList<>();
|
List<NovaPushResultVO> faileList = new ArrayList<>();
|
List<String> finalSuccess = success;
|
List<String> finalFail = fail;
|
playerList.forEach(n -> {
|
if (finalSuccess.contains(n.getPlayerId())) {
|
NovaPushResultVO vo = new NovaPushResultVO();
|
vo.setName(n.getName());
|
vo.setPlayerId(n.getPlayerId());
|
successList.add(vo);
|
} else if (finalFail.contains(n.getPlayerId())) {
|
NovaPushResultVO vo = new NovaPushResultVO();
|
vo.setName(n.getName());
|
vo.setPlayerId(n.getPlayerId());
|
faileList.add(vo);
|
}
|
});
|
|
result.put("success", successList);
|
result.put("fail", faileList);
|
return result;
|
}
|
|
public Map<String, Object> brightnessChange(List<LedPlayerEntity> playerList, Integer brightness) {
|
playerList.forEach(item -> {
|
if (item.getName() == null || item.getPlayerId() == null) {
|
throw new BusinessException("playerId或playerName为空");
|
}
|
if (item.getPlayerId().isEmpty() || item.getName().isEmpty()) {
|
throw new BusinessException("playerId或playerName为空");
|
}
|
});
|
VnnoxResult vnnoxResult = vnnoxAPIUtil.brightnessChange(playerList.stream().map(item -> item.getPlayerId()).collect(Collectors.toList()), brightness);
|
// 根据亮度调整REDIS标识位
|
for (String playerId : vnnoxResult.getSuccess()) {
|
redisUtils.set(VnnoxConstant.REDIS_BRIGHTNESS + playerId, brightness, VnnoxConstant.REDIS_MAX_SAVE_TIME);
|
}
|
List<String> success = vnnoxResult.getSuccess();
|
List<String> fail = vnnoxResult.getFail();
|
//拼接成功失败的结果
|
Map<String, Object> result = new HashMap<>();
|
List<NovaPushResultVO> successList = new ArrayList<>();
|
List<NovaPushResultVO> faileList = new ArrayList<>();
|
List<String> finalSuccess = success;
|
List<String> finalFail = fail;
|
playerList.forEach(n -> {
|
if (finalSuccess.contains(n.getPlayerId())) {
|
NovaPushResultVO vo = new NovaPushResultVO();
|
vo.setName(n.getName());
|
vo.setPlayerId(n.getPlayerId());
|
successList.add(vo);
|
} else if (finalFail.contains(n.getPlayerId())) {
|
NovaPushResultVO vo = new NovaPushResultVO();
|
vo.setName(n.getName());
|
vo.setPlayerId(n.getPlayerId());
|
faileList.add(vo);
|
}
|
});
|
|
result.put("success", successList);
|
result.put("fail", faileList);
|
return result;
|
|
}
|
|
//截屏
|
public Map<String, String> getScreenShotUrl(Integer id) {
|
Map<String, String> map = new HashMap();
|
|
LedPlayerEntity playerEntity = ledPlayerEntityService.getById(id);
|
try {
|
redisUtils.delete(VnnoxConstant.REDIS_SCREEN_SHOT + playerEntity.getPlayerId());
|
} catch (Exception e) {
|
|
}
|
VnnoxResult vnnoxResult = vnnoxAPIUtil.screenShot(playerEntity.getPlayerId());
|
|
if (null == vnnoxResult) {
|
map.put("code", "500");
|
map.put("msg", "设备已下线");
|
return map;
|
}
|
|
if (vnnoxResult.getSuccess().size() == 0) {
|
map.put("code", "500");
|
map.put("msg", "获取缩略图失败!");
|
return map;
|
}
|
String url = null;
|
Integer checkCount = 0;
|
while (checkCount < 10) {
|
url = redisUtils.get(VnnoxConstant.REDIS_SCREEN_SHOT + playerEntity.getPlayerId());
|
if (null != url) {
|
break;
|
}
|
try {
|
Thread.sleep(2000);
|
checkCount = checkCount + 1;
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
map.put("url", url);
|
map.put("code", "200");
|
return map;
|
}
|
|
|
// 批量截屏
|
public Map<String, String> getScreenShotUrl(List<String> playerIds) {
|
Map<String, String> map = new HashMap();
|
|
playerIds.forEach(
|
playId->{
|
try {
|
redisUtils.delete(VnnoxConstant.REDIS_SCREEN_SHOT + playId);
|
} catch (Exception e) {
|
|
}
|
}
|
);
|
|
VnnoxResult vnnoxResult = vnnoxAPIUtil.screenShot(playerIds);
|
|
if (null == vnnoxResult) {
|
map.put("code", "500");
|
map.put("msg", "设备已下线");
|
return map;
|
}
|
|
if (vnnoxResult.getSuccess().size() == 0) {
|
map.put("code", "500");
|
map.put("msg", "获取缩略图失败!");
|
return map;
|
}
|
String url = null;
|
Integer checkCount = 0;
|
while (checkCount < 10) {
|
url = redisUtils.get(VnnoxConstant.REDIS_SCREEN_SHOT + playerIds.get(0));
|
if (null != url) {
|
break;
|
}
|
try {
|
Thread.sleep(2000);
|
checkCount = checkCount + 1;
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
map.put("url", url);
|
map.put("code", "200");
|
return map;
|
}
|
|
|
// //重启
|
// public VnnoxResult reboot(List<LedPlayerEntity> playerList) {
|
// return vnnoxAPIUtil.reboot(
|
// playerList.stream().map(
|
// item -> item.getPlayerId()
|
// ).collect(Collectors.toList())
|
// );
|
// }
|
|
//重启
|
public Map<String, Object> reboot(List<NovaPushResultVO> nova) {
|
List<String> playerIds = new ArrayList<>();
|
nova.forEach(item -> {
|
if (item.getName() == null || item.getPlayerId() == null) {
|
throw new BusinessException("playerId或playerName为空");
|
}
|
if (item.getPlayerId().isEmpty() || item.getName().isEmpty()) {
|
throw new BusinessException("playerId或playerName为空");
|
}
|
playerIds.add(item.getPlayerId());
|
});
|
|
VnnoxResult reboot = vnnoxAPIUtil.reboot(playerIds);
|
|
|
List<String> success = reboot.getSuccess();
|
List<String> fail = reboot.getFail();
|
//拼接成功失败的结果
|
Map<String, Object> result = new HashMap<>();
|
List<NovaPushResultVO> successList = new ArrayList<>();
|
List<NovaPushResultVO> faileList = new ArrayList<>();
|
List<String> finalSuccess = success;
|
List<String> finalFail = fail;
|
nova.forEach(n -> {
|
if (finalSuccess.contains(n.getPlayerId())) {
|
successList.add(n);
|
} else if (finalFail.contains(n.getPlayerId())) {
|
faileList.add(n);
|
}
|
});
|
|
result.put("success", successList);
|
result.put("fail", faileList);
|
return result;
|
}
|
|
/**
|
* 同步播放
|
*
|
* @param
|
* @return
|
*/
|
public Map<String, Object> syncPlay(List<NovaPushResultVO> nova, Integer option) {
|
List<String> playerIds = new ArrayList<>();
|
nova.forEach(item -> {
|
if (item.getName() == null || item.getPlayerId() == null) {
|
throw new BusinessException("playerId或playerName为空");
|
}
|
if (item.getPlayerId().isEmpty() || item.getName().isEmpty()) {
|
throw new BusinessException("playerId或playerName为空");
|
}
|
playerIds.add(item.getPlayerId());
|
});
|
VnnoxResult vnnoxResult = vnnoxAPIUtil.syncPlay(playerIds, option);
|
|
List<String> success = vnnoxResult.getSuccess();
|
List<String> fail = vnnoxResult.getFail();
|
//拼接成功失败的结果
|
Map<String, Object> result = new HashMap<>();
|
List<NovaPushResultVO> successList = new ArrayList<>();
|
List<NovaPushResultVO> faileList = new ArrayList<>();
|
List<String> finalSuccess = success;
|
List<String> finalFail = fail;
|
nova.forEach(n -> {
|
if (finalSuccess.contains(n.getPlayerId())) {
|
successList.add(n);
|
} else if (finalFail.contains(n.getPlayerId())) {
|
faileList.add(n);
|
}
|
});
|
|
result.put("success", successList);
|
result.put("fail", faileList);
|
return result;
|
}
|
|
/**
|
* 对时
|
*
|
* @param
|
* @return
|
*/
|
public Map<String, Object> ntpSync(List<NovaPushResultVO> nova, boolean enable) {
|
List<String> playerIds = new ArrayList<>();
|
nova.forEach(item -> {
|
if (item.getName() == null || item.getPlayerId() == null) {
|
throw new BusinessException("playerId或playerName为空");
|
}
|
if (item.getPlayerId().isEmpty() || item.getName().isEmpty()) {
|
throw new BusinessException("playerId或playerName为空");
|
}
|
playerIds.add(item.getPlayerId());
|
});
|
VnnoxResult vnnoxResult = vnnoxAPIUtil.ntpSync(playerIds, enable);
|
|
List<String> success = vnnoxResult.getSuccess();
|
List<String> fail = vnnoxResult.getFail();
|
//拼接成功失败的结果
|
Map<String, Object> result = new HashMap<>();
|
List<NovaPushResultVO> successList = new ArrayList<>();
|
List<NovaPushResultVO> faileList = new ArrayList<>();
|
List<String> finalSuccess = success;
|
List<String> finalFail = fail;
|
nova.forEach(n -> {
|
if (finalSuccess.contains(n.getPlayerId())) {
|
successList.add(n);
|
} else if (finalFail.contains(n.getPlayerId())) {
|
faileList.add(n);
|
}
|
});
|
|
result.put("success", successList);
|
result.put("fail", faileList);
|
return result;
|
}
|
|
|
public boolean updateDataName(Long id, String name) {
|
LedPlayerEntity byId = ledPlayerEntityService.getById(id);
|
if (byId == null) {
|
throw new BusinessException("未找到该设备");
|
}
|
if (SecurityUtils.getClientId() != null) {
|
boolean belong = SpringContextHolder.getBean(PoleBindingService.class).isBelong(byId.getSn(), PoleBindingEnums.VONNOX);
|
if (!belong) {
|
throw new BusinessException("该设备不属于您,不能修改设备信息");
|
}
|
}
|
LedPlayerEntity led = new LedPlayerEntity();
|
led.setId(id);
|
led.setName(name);
|
/**
|
* 诺瓦设备编辑 日志记录开始
|
*/
|
List<String> listCode = new ArrayList<>(1);
|
listCode.add(byId.getSn());
|
String content = "{ 设备id:" + led.getId() + "设备code：" + byId.getSn() + "诺瓦playId:" + led.getPlayerId() + "诺瓦设备原名:" + byId.getName() + "诺瓦设备更改后的名称:" + led.getName() + "}";
|
|
StoreOperationRecordsUtils.storeOperationData(listCode, null, "诺瓦设备编辑", content);
|
/**
|
* 诺瓦设备编辑 日志记录结束
|
*/
|
return ledPlayerEntityService.updateById(led);
|
}
|
|
/**
|
* 获取缓存数据
|
*
|
* @param list
|
* @return
|
*/
|
public List<LedPlayerEntity> setCacheInfo(List<LedPlayerEntity> list) {
|
for (LedPlayerEntity playerEntity : list) {
|
String playerId = playerEntity.getPlayerId();
|
LedPlayerInfoEntity cache = new LedPlayerInfoEntity();
|
// 设置屏幕状态
|
String result = redisUtils.get(VnnoxConstant.REDIS_SCREEN_STATUS + playerId);
|
Integer screenStatus = 1;
|
if (null != result) {
|
screenStatus = Integer.parseInt(result);
|
}
|
cache.setScreenStatus(screenStatus);
|
// 设置屏幕音量
|
result = redisUtils.get(VnnoxConstant.REDIS_VOL + playerId);
|
Integer vol = 0;
|
if (null != result) {
|
vol = Integer.parseInt(result);
|
}
|
cache.setVol(vol);
|
// 设置屏幕亮度
|
result = redisUtils.get(VnnoxConstant.REDIS_BRIGHTNESS + playerId);
|
Integer brightness = 0;
|
if (null != result) {
|
brightness = Integer.parseInt(result);
|
}
|
cache.setBrightness(brightness);
|
|
// 设置缩略图访问路径
|
result = redisUtils.get(VnnoxConstant.REDIS_SCREEN_SHOT + playerId);
|
if (null != result) {
|
playerEntity.setScreenShotUrl(result);
|
} else {
|
playerEntity.setScreenShotUrl("");
|
}
|
|
playerEntity.setPlayerInfo(cache);
|
}
|
return list;
|
}
|
|
|
public VnnoxResult publishWaterData(String playerId, A5AtmosphereHeartbeatReportInnerFrame.HeartBeatDataPackage poleSensorEntity) {
|
List<String> playerIds = new ArrayList<>();
|
playerIds.add(playerId);
|
AirDataProgram playerProgram = new AirDataProgram();
|
playerProgram.setPlayerIds(playerIds);
|
PlayerPage playerPage = new PlayerPage();
|
playerPage.setName("AirData page");
|
List<PlayerWidget> widgetList = generateWaterAndSensorWidget(poleSensorEntity);
|
playerPage.setWidgets(widgetList);
|
List<PlayerPage> list = new ArrayList<>();
|
list.add(playerPage);
|
playerProgram.setPages(list);
|
playerProgram.setNoticeUrl(VnnoxConstant.NOTIFY_URL);
|
/**
|
* 诺瓦推送大气数据 日志记录开始
|
//// */
|
// String content = "{诺瓦playerId：" + playerId + ",节目内容：" + JSON.toJSONString(playerProgram) + " }";
|
// StoreOperationRecordsUtils.storeOperationData(null, null, "大气数据推送到诺瓦", content);
|
/**
|
* 诺瓦推送大气数据 日志记录结束
|
*/
|
|
return vnnoxProgramAPIUtil.normalProgram(playerProgram).getData();
|
}
|
|
|
private List<PlayerWidget> generateWaterAndSensorWidget(A5AtmosphereHeartbeatReportInnerFrame.HeartBeatDataPackage poleSensorEntity) {
|
//TODO
|
List widgetList = new ArrayList<>();
|
List<String> list = new ArrayList<>();
|
if (Objects.nonNull(poleSensorEntity)) {
|
list.add("环境监测：");
|
list.add("温度：" + poleSensorEntity.getTemperature() + "°");
|
list.add("湿度：" + poleSensorEntity.getHumidity() + "%");
|
list.add("pm25：" + poleSensorEntity.getPm25() + "μg/m³");
|
list.add("pm10：" + poleSensorEntity.getPm10() + "μg/m³");
|
list.add("甲醛：" + poleSensorEntity.getEch2o() + "μg/m³");
|
list.add("CO2：" + poleSensorEntity.getCo2() + "ppm");
|
}
|
|
widgetList.add(new PlayerWidget().generateScrollUpTextWidget("weather", 1, 100000L, list, "#FFFFFF", 15, new PlayerLayout("0%", "5%", "100%", "100%")));
|
|
return widgetList;
|
}
|
|
}
|
