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 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 onUw = new UpdateWrapper<>(); - onUw.set("sfyx",0); - onUw.in("id",onList); - kcZhihuijiaoshiService.update(onUw); - } - - if(!outList.isEmpty()) { - UpdateWrapper outUw = new UpdateWrapper<>(); - outUw.set("sfyx", 1); - outUw.in("id", outList); - kcZhihuijiaoshiService.update(outUw); - } +// if(!onList.isEmpty()){ +// UpdateWrapper onUw = new UpdateWrapper<>(); +// onUw.set("sfyx",0); +// onUw.in("id",onList); +// kcZhihuijiaoshiService.update(onUw); +// } +// +// if(!outList.isEmpty()) { +// UpdateWrapper 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 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 onUw = new UpdateWrapper<>(); - onUw.set("sfyx",0); - onUw.in("id",onList); - kcZhihuijiaoshiService.update(onUw); - } - - if(!outList.isEmpty()) { - UpdateWrapper outUw = new UpdateWrapper<>(); - outUw.set("sfyx", 1); - outUw.in("id", outList); - kcZhihuijiaoshiService.update(outUw); - } +// if(!onList.isEmpty()){ +// UpdateWrapper onUw = new UpdateWrapper<>(); +// onUw.set("sfyx",0); +// onUw.in("id",onList); +// kcZhihuijiaoshiService.update(onUw); +// } +// +// if(!outList.isEmpty()) { +// UpdateWrapper outUw = new UpdateWrapper<>(); +// outUw.set("sfyx", 1); +// outUw.in("id", outList); +// kcZhihuijiaoshiService.update(outUw); +// } } /**