From 4e76b9737e036c18e8a9e840dc443615ffcec348 Mon Sep 17 00:00:00 2001
From: zhanzhiqin <895896009@qq.com>
Date: 星期四, 20 十月 2022 12:20:18 +0800
Subject: [PATCH] 大气农耕

---
 ximon-admin/src/main/java/com/sandu/ximon/admin/service/XiXunPlayerService.java |   65 +++++++++++++++++++++++---------
 1 files changed, 47 insertions(+), 18 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 86d507b..102a414 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
@@ -1,11 +1,14 @@
 package com.sandu.ximon.admin.service;
 
+import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.github.pagehelper.PageHelper;
 import com.google.gson.Gson;
 import com.google.gson.GsonBuilder;
 import com.sandu.common.execption.BusinessException;
+import com.sandu.common.object.BaseConditionVO;
 import com.sandu.common.service.impl.BaseServiceImpl;
 import com.sandu.ximon.admin.config.RealtimeServerBean;
 import com.sandu.ximon.admin.entity.*;
@@ -20,6 +23,7 @@
 import com.sandu.ximon.dao.domain.Pole;
 import com.sandu.ximon.dao.domain.PoleLightemitEntity;
 import com.sandu.ximon.dao.domain.PoleXixunPlayerEntity;
+import com.sandu.ximon.dao.enums.OrderByEnums;
 import com.sandu.ximon.dao.mapper.PoleXixunPlayerEntityMapper;
 import lombok.AllArgsConstructor;
 import org.apache.commons.lang.StringUtils;
@@ -63,6 +67,40 @@
                         }).like(PoleXixunPlayerEntity::getProgramName, keyword);
             }
         }
+    }
+
+    public List<PoleXixunPlayerEntity> listProgram(BaseConditionVO baseConditionVO, Integer order, Integer seq, String keyword) {
+        LambdaQueryWrapper<PoleXixunPlayerEntity> wrapper = XixunPlayerList(keyword);
+        //鎺掑簭瀛楁
+        String orderByResult = "program_id";
+        //姝e簭銆佸�掑彊
+        String orderBySeq = OrderByEnums.ASC.getCode();
+        if (order != null) {
+            switch (order) {
+                case 1:
+                    orderByResult = OrderByEnums.LED_S_PROGRAM_CREATE_TIME.getCode();
+                    break;
+                default:
+            }
+        }
+        if (seq != null) {
+            switch (seq) {
+                case 1:
+                    orderBySeq = " ASC";
+                    break;
+                case 2:
+                    orderBySeq = " DESC";
+                    break;
+                default:
+                    break;
+            }
+        }
+        //鎺掑簭鏂瑰紡
+        String orderBy = orderByResult + " " + orderBySeq;
+        if (baseConditionVO != null) {
+            PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize(), orderBy);
+        }
+        return list(wrapper);
     }
 
     public boolean insert(ProgramPro programPro) {
@@ -167,7 +205,7 @@
         try {
             Gson gson = new GsonBuilder().disableHtmlEscaping().create();
 //            programPro = JsonUtil.convertJsonStringToObject(json, ProgramPro.class);
-            programPro=gson.fromJson(json,ProgramPro.class);
+            programPro = gson.fromJson(json, ProgramPro.class);
             programPro.setProgramId(pid);
             programPro.setScreenShot(byId.getScreenShot());
             programPro.getLayers().forEach(
@@ -225,10 +263,12 @@
                 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());
+                    if (file != null) {
+                        String fileUrl = file.getFileUrl();
+                        String[] split = fileUrl.split("/");
+                        sourcePro.setId(split[split.length - 1]);
+                        sourcePro.setMd5(file.getMd5());
+                    }
                 });
             });
         } catch (Exception e) {
@@ -262,6 +302,8 @@
 
         Gson gson = new GsonBuilder().disableHtmlEscaping().create();
         String jsondata = gson.toJson(xixun);
+        System.out.println("鎺ㄩ�佸唴瀹�" + JSONUtil.toJsonStr(jsondata));
+
 
         Collection<PoleLightemitEntity> poleLightemitEntities = poleLightemitService.listByIds(lightemitIds);
 
@@ -366,19 +408,6 @@
                     lightemitUtils.clearPlayerTask(lightemitControlCode);
                     //鎺ㄩ�佹渶鍚庡懡浠�
                     lightemitUtils.sendLastCommand(lightemitControlCode);
-
-                    /**
-                     * 鐔欐睕澶ф皵鏁版嵁鎺ㄩ�佹棩蹇楄褰曞紑濮�
-                     //                     */
-//                    String content = "{璁惧code锛�" + lightemitControlCode
-//                            + "锛� 鎺ㄩ�佸唴瀹癸細" + body
-//                            + " }";
-//                    List<String> listCode = new ArrayList<>();
-//                    listCode.add(lightemitControlCode);
-//                    StoreOperationRecordsUtils.storeOperationData(listCode, null, "鐔欐睕澶ф皵鏁版嵁鎺ㄩ��", content);
-                    /**
-                     * 鐔欐睕澶ф皵鏁版嵁鎺ㄩ�佹棩蹇楄褰曠粨鏉�
-                     */
                 }
             }, 60 * 1000);
         }

--
Gitblit v1.9.3