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 new file mode 100644 index 00000000..0b3f21c0 --- /dev/null +++ b/jeecg-module-main/src/main/java/org/jeecg/modules/kc/grab/SynchronizationService/RefreshLiveServer.java @@ -0,0 +1,76 @@ +package org.jeecg.modules.kc.grab.SynchronizationService; + +import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; +import com.beust.jcommander.internal.Sets; +import com.google.common.collect.Maps; +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; +import org.jeecg.modules.kc.jiaoshi.service.IKcZhihuijiaoshiService; +import org.quartz.JobExecutionContext; +import org.springframework.beans.factory.annotation.Autowired; + +import java.util.List; +import java.util.Map; +import java.util.Set; + +@Slf4j +public class RefreshLiveServer extends BaseSync { + + @Autowired + private IKcZhihuijiaoshiService kcZhihuijiaoshiService; + + + /** + * 若参数变量名修改 QuartzJobController中也需对应修改 + */ + + @Override + public void execute(JobExecutionContext jobExecutionContext) { + start(); + run(getParamMap()); + end(); + } + + + /** + * 有参定时任务实现 + * @param param + */ + public void run(Map param){ + List list = kcZhihuijiaoshiService.list(); +// Map liveOnMap = Maps.newHashMap(); + Set onList = Sets.newHashSet(); + Set outList = Sets.newHashSet(); + list.forEach(x -> { + try{ + String res = HttpUtil.get(x.getPullUrl()); +// liveOnMap.put(x.getId(),true); + onList.add(x.getId()); + log.info("返回内容:" + res);//live_setParam_ret=ok + } catch (Exception e){ +// liveOnMap.put(x.getId(),false); + outList.add(x.getId()); + log.error(e.getMessage(),e); + } + }); + UpdateWrapper onUw = new UpdateWrapper(); + onUw.set("sfyx",0); + onUw.in("id",onList); + kcZhihuijiaoshiService.update(onUw); + + UpdateWrapper outUw = new UpdateWrapper(); + outUw.set("sfyx",1); + outUw.in("id",outList); + kcZhihuijiaoshiService.update(outUw); + } + + /** + * 无参定时任务实现 + */ + public void run(){ + run(null); + } + +}