Skip to content

Commit f80a803

Browse files
author
guorutao
committed
mod
1 parent 172691e commit f80a803

2 files changed

Lines changed: 6 additions & 2 deletions

File tree

src/main/java/com/unfbx/zdm_push/processor/ZdmPageProcessor.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,11 +32,13 @@ public void process(Page page) {
3232
//默认不推送
3333
page.putField("flag",false);
3434
if(StringUtils.isNotBlank(page.getHtml().xpath("/html/body/div[1]/div[1]/div[3]/div[2]/div[1]/a").$("a","href").toString())){
35-
page.putField("flag",true);
3635
String[] split = url.split("/");
3736
if(data.equals(split[split.length-1])){
3837
page.putField("flag",false);
38+
return;
3939
}
40+
page.putField("flag",true);
41+
data = split[split.length-1];
4042
}
4143

4244
}

src/main/java/com/unfbx/zdm_push/task/ZdmTask.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,12 +22,14 @@ public class ZdmTask {
2222
@Value("${uid}")
2323
private String uid;
2424

25+
ZdmPageProcessor zdmPageProcessor = new ZdmPageProcessor();
26+
2527
/**
2628
* 十分钟执行一次
2729
*/
2830
@Scheduled(cron = "${corn}")
2931
public void execute() {
30-
Spider.create(new ZdmPageProcessor())
32+
Spider.create(zdmPageProcessor)
3133
.addUrl("https://zhiyou.smzdm.com/member/"+uid+"/baoliao/")
3234
.addPipeline(zdmPipeline)
3335
.thread(1)

0 commit comments

Comments
 (0)