From 4e91adbb41c89688fe5b0ef03807cfe748a7d59d Mon Sep 17 00:00:00 2001
From: zhanzhiqin <895896009@qq.com>
Date: 星期四, 26 五月 2022 17:17:02 +0800
Subject: [PATCH] 角色
---
ximon-admin/src/main/java/com/sandu/ximon/admin/service/XiXunPlayerService.java | 96 +++++++++++++++++++++++++----------------------
1 files changed, 51 insertions(+), 45 deletions(-)
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/XiXunPlayerService.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/XiXunPlayerService.java
index 5db192b..7b30ecd 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/service/XiXunPlayerService.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/service/XiXunPlayerService.java
@@ -69,6 +69,20 @@
}
public boolean insert(ProgramPro programPro) {
+ programPro.getLayers().forEach(
+ layerPro -> {
+ layerPro.getSources().forEach(
+ sourcePro -> {
+ long fileId = Long.parseLong(sourcePro.getId());
+ LedSFile file = xiXunFileService.getById(fileId);
+ String fileUrl = file.getFileUrl();
+ String[] split = fileUrl.split("/");
+ sourcePro.setId(split[split.length - 1]);
+ sourcePro.setMd5(file.getMd5());
+ }
+ );
+ }
+ );
String json = JsonUtil.jsonObj2Sting(programPro);
PoleXixunPlayerEntity poleXixunPlayer = new PoleXixunPlayerEntity();
poleXixunPlayer.setProgramCode(programPro.get_id());
@@ -148,43 +162,15 @@
}
-// public Object getProgram(String json) {
-//// PoleXixunPlayerEntity byId = getById(pid);
-// List<Long> fileIds = new ArrayList<>();
-// List<LedSFile> file = new ArrayList<>();
-// if (json == null) {
-// throw new BusinessException("鏈壘鍒拌鑺傜洰");
-// }
-// ProgramPro programPro = new ProgramPro();
-// try {
-// programPro = JsonUtil.convertJsonStringToObject(json, ProgramPro.class);
-// programPro.setProgramId(pid);
-// programPro.setScreenShot(byId.getScreenShot());
-// programPro.getLayers().forEach(
-// layerPro -> {
-// layerPro.getSources().forEach(
-// sourcePro -> {
-// long fileId = Long.parseLong(sourcePro.getId());
-// file.add(xiXunFileService.getById(fileId));
-// }
-// );
-// }
-// );
-// programPro.setFileList(file);
-// } catch (Exception e) {
-// e.printStackTrace();
-// }
-// return programPro;
-// }
-
-
/**
* 鎺ㄩ�佽妭鐩�
*
* @param programId
* @param lightemitIds
*/
- public void videoXixunPlayer(long programId, List<Long> lightemitIds) {
+ public List<Map> videoXixunPlayer(long programId, List<Long> lightemitIds) {
+ //璁板綍鎿嶄綔缁撴灉
+ List<Map> mapList = new ArrayList<>();
ProgramPro pro = new ProgramPro();
ItemPro items = new ItemPro();
@@ -214,10 +200,10 @@
list2.add(items);
taskPro.setItems(list2);
command.setId(UUID.randomUUID().toString());
- //杩欓噷鏄笅鏂圭殑post鍥炶皟鍦板潃锛岄渶瑕佷慨鏀笽P鍦板潃
- command.setNotificationURL("http://" + config.getIp() + ":" + config.getPort() + "/machine-fast/serv/download/getJSON");
+// //杩欓噷鏄笅鏂圭殑post鍥炶皟鍦板潃锛岄渶瑕佷慨鏀笽P鍦板潃
+ command.setNotificationURL("");
//璧勬簮涓嬭浇閾炬帴鐨勮姹傚ご
- command.setPreDownloadURL("http://" + config.getIp() + ":" + config.getPort() + "/machine-fast/serv/download/downliadFileById/");
+ command.setPreDownloadURL("https://ximonsmart.oss-cn-shanghai.aliyuncs.com/");
command.setTask(taskPro);
xixun.set_id(UUID.randomUUID().toString());
xixun.setCommand(command);
@@ -231,11 +217,29 @@
Collection<PoleLightemitEntity> poleLightemitEntities = poleLightemitService.listByIds(lightemitIds);
if (poleLightemitEntities != null) {
+ Map map;
for (PoleLightemitEntity entity : poleLightemitEntities) {
- lightemitUtils.clear(entity.getLightemitControlCode());
- poleLightemitService.updateRequestBody(entity.getLightemitControlCode(), jsondata);
- String post = lightemitUtils.post(realtimeServerBean.getCommand() + entity.getLightemitControlCode(), jsondata);
- LogUtils.error("缁撴灉:" + post);
+ map = new LinkedHashMap();
+ String clearResult = lightemitUtils.clear(entity.getLightemitControlCode());
+ if (clearResult.contains("does not exist")) {
+ map.put("LightemitId", entity.getLightemitId());
+ map.put("Result", "澶辫触");
+ mapList.add(map);
+ } else {
+ poleLightemitService.updateRequestBody(entity.getLightemitControlCode(), jsondata);
+ String post = lightemitUtils.post(realtimeServerBean.getCommand() + entity.getLightemitControlCode(), jsondata);
+ //{"_type":"success","_id":"ce8dc3ff-dc88-43b7-8f55-60abd8700f1a","timestamp":1653555160535}
+ if (post.startsWith("{") && post.endsWith("}") && post.contains("_type\":\"success")) {
+ map.put("LightemitId", entity.getLightemitId());
+ map.put("Result", "鎴愬姛");
+ mapList.add(map);
+ } else {
+ map.put("LightemitId", entity.getLightemitId());
+ map.put("Result", "澶辫触");
+ mapList.add(map);
+ }
+ LogUtils.error("缁撴灉:" + post);
+ }
}
}
@@ -255,6 +259,8 @@
/**
* 鐔欐睕鑺傜洰鎺ㄩ�佹棩蹇楄褰曠粨鏉�
*/
+
+ return mapList;
}
@@ -314,13 +320,13 @@
/**
* 鐔欐睕澶ф皵鏁版嵁鎺ㄩ�佹棩蹇楄褰曞紑濮�
- */
- String content = "{璁惧code锛�" + lightemitControlCode
- + "锛� 鎺ㄩ�佸唴瀹癸細" + body
- + " }";
- List<String> listCode = new ArrayList<>();
- listCode.add(lightemitControlCode);
- StoreOperationRecordsUtils.storeOperationData(listCode, null, "鐔欐睕澶ф皵鏁版嵁鎺ㄩ��", content);
+ // */
+// String content = "{璁惧code锛�" + lightemitControlCode
+// + "锛� 鎺ㄩ�佸唴瀹癸細" + body
+// + " }";
+// List<String> listCode = new ArrayList<>();
+// listCode.add(lightemitControlCode);
+// StoreOperationRecordsUtils.storeOperationData(listCode, null, "鐔欐睕澶ф皵鏁版嵁鎺ㄩ��", content);
/**
* 鐔欐睕澶ф皵鏁版嵁鎺ㄩ�佹棩蹇楄褰曠粨鏉�
*/
--
Gitblit v1.9.3