From d2d61c085089c52d723d4a7473e92c51aea2d924 Mon Sep 17 00:00:00 2001
From: bai <1643359946@qq.com>
Date: Tue, 24 Oct 2023 21:21:17 +0800
Subject: [PATCH] =?UTF-8?q?2023=E5=B9=B410=E6=9C=8824=E6=97=A5=20=E7=A6=81?=
 =?UTF-8?q?=E6=AD=A2=E5=B9=B6=E4=BF=AE=E5=A4=8D=E7=A6=81=E6=AD=A2=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9=E6=98=AF=E5=90=A6=E6=9C=89=E6=95=88=E5=AD=97=E6=AE=B5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../RefreshCloseLiveServer.java               | 30 +++++++++----------
 .../RefreshLiveServer.java                    | 30 +++++++++----------
 2 files changed, 30 insertions(+), 30 deletions(-)

diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/RefreshCloseLiveServer.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/RefreshCloseLiveServer.java
index 70de09d7..46eeef16 100644
--- a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/RefreshCloseLiveServer.java
+++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/RefreshCloseLiveServer.java
@@ -4,10 +4,10 @@ import cn.hutool.core.convert.Convert;
 import cn.hutool.core.net.url.UrlBuilder;
 import cn.hutool.core.util.CharsetUtil;
 import cn.hutool.crypto.SecureUtil;
+import cn.hutool.http.HttpUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.beust.jcommander.internal.Sets;
-import com.xkcoding.http.HttpUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync;
 import org.jeecg.modules.kc.jiaoshi.entity.KcZhihuijiaoshi;
@@ -55,7 +55,7 @@ public class RefreshCloseLiveServer extends BaseSync {
         Set<Integer> outList = Sets.newHashSet();
         list.forEach(x -> {
             try{
-                String res = HttpUtil.get(x.getPullUrl());
+                String res = com.xkcoding.http.HttpUtil.get(x.getPullUrl());
 //                liveOnMap.put(x.getId(),true);
                 onList.add(x.getId());
                 log.info("返回内容：" + res);//live_setParam_ret=ok
@@ -110,19 +110,19 @@ public class RefreshCloseLiveServer extends BaseSync {
 
             }
         });
-        if(!onList.isEmpty()){
-            UpdateWrapper<KcZhihuijiaoshi> onUw = new UpdateWrapper<>();
-            onUw.set("sfyx",0);
-            onUw.in("id",onList);
-            kcZhihuijiaoshiService.update(onUw);
-        }
-
-        if(!outList.isEmpty()) {
-            UpdateWrapper<KcZhihuijiaoshi> outUw = new UpdateWrapper<>();
-            outUw.set("sfyx", 1);
-            outUw.in("id", outList);
-            kcZhihuijiaoshiService.update(outUw);
-        }
+//        if(!onList.isEmpty()){
+//            UpdateWrapper<KcZhihuijiaoshi> onUw = new UpdateWrapper<>();
+//            onUw.set("sfyx",0);
+//            onUw.in("id",onList);
+//            kcZhihuijiaoshiService.update(onUw);
+//        }
+//
+//        if(!outList.isEmpty()) {
+//            UpdateWrapper<KcZhihuijiaoshi> outUw = new UpdateWrapper<>();
+//            outUw.set("sfyx", 1);
+//            outUw.in("id", outList);
+//            kcZhihuijiaoshiService.update(outUw);
+//        }
     }
 
     /**
diff --git a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/RefreshLiveServer.java b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/RefreshLiveServer.java
index dab93774..f5f42b9a 100644
--- a/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/RefreshLiveServer.java
+++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/RefreshLiveServer.java
@@ -4,10 +4,10 @@ import cn.hutool.core.convert.Convert;
 import cn.hutool.core.net.url.UrlBuilder;
 import cn.hutool.core.util.CharsetUtil;
 import cn.hutool.crypto.SecureUtil;
+import cn.hutool.http.HttpUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
 import com.beust.jcommander.internal.Sets;
-import com.xkcoding.http.HttpUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.jeecg.modules.kc.grab.SynchronizationService.base.BaseSync;
 import org.jeecg.modules.kc.jiaoshi.entity.KcZhihuijiaoshi;
@@ -55,7 +55,7 @@ public class RefreshLiveServer extends BaseSync {
         Set<Integer> outList = Sets.newHashSet();
         list.forEach(x -> {
             try{
-                String res = HttpUtil.get(x.getPullUrl());
+                String res = com.xkcoding.http.HttpUtil.get(x.getPullUrl());
 //                liveOnMap.put(x.getId(),true);
                 onList.add(x.getId());
                 log.info("返回内容：" + res);//live_setParam_ret=ok
@@ -110,19 +110,19 @@ public class RefreshLiveServer extends BaseSync {
 
             }
         });
-        if(!onList.isEmpty()){
-            UpdateWrapper<KcZhihuijiaoshi> onUw = new UpdateWrapper<>();
-            onUw.set("sfyx",0);
-            onUw.in("id",onList);
-            kcZhihuijiaoshiService.update(onUw);
-        }
-
-        if(!outList.isEmpty()) {
-            UpdateWrapper<KcZhihuijiaoshi> outUw = new UpdateWrapper<>();
-            outUw.set("sfyx", 1);
-            outUw.in("id", outList);
-            kcZhihuijiaoshiService.update(outUw);
-        }
+//        if(!onList.isEmpty()){
+//            UpdateWrapper<KcZhihuijiaoshi> onUw = new UpdateWrapper<>();
+//            onUw.set("sfyx",0);
+//            onUw.in("id",onList);
+//            kcZhihuijiaoshiService.update(onUw);
+//        }
+//
+//        if(!outList.isEmpty()) {
+//            UpdateWrapper<KcZhihuijiaoshi> outUw = new UpdateWrapper<>();
+//            outUw.set("sfyx", 1);
+//            outUw.in("id", outList);
+//            kcZhihuijiaoshiService.update(outUw);
+//        }
     }
 
     /**