yangjun
/
dbsd_kczx_java
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

2023年10月24日 禁止并修复禁止修改是否有效字段

This commit is contained in:
bai 2023-10-24 21:21:17 +08:00
parent 871cd07712
commit d2d61c0850
2 changed files with 30 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/RefreshCloseLiveServer.java
View File

@ -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);
// }
}
/**

30
jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/RefreshLiveServer.java
View File

@ -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);
// }
}
/**