dev
parent
4fdefe5389
commit
3066cd08e8
|
|
@ -2,8 +2,10 @@ package com.cowr.service.ssjygl.jobs;
|
||||||
|
|
||||||
import com.cowr.service.ssjygl.main.Config;
|
import com.cowr.service.ssjygl.main.Config;
|
||||||
import com.jfinal.kit.HttpKit;
|
import com.jfinal.kit.HttpKit;
|
||||||
|
import com.jfinal.kit.StrKit;
|
||||||
import com.jfinal.log.Log;
|
import com.jfinal.log.Log;
|
||||||
import com.jfinal.plugin.activerecord.Db;
|
import com.jfinal.plugin.activerecord.Db;
|
||||||
|
import javafx.scene.control.Skin;
|
||||||
import org.quartz.Job;
|
import org.quartz.Job;
|
||||||
import org.quartz.JobExecutionContext;
|
import org.quartz.JobExecutionContext;
|
||||||
|
|
||||||
|
|
@ -18,10 +20,19 @@ public class CheckExceptionDataJob implements Job {
|
||||||
" left join transport p on t.sn = p.order_sn\n" +
|
" left join transport p on t.sn = p.order_sn\n" +
|
||||||
" where t.state = 5 \n" +
|
" where t.state = 5 \n" +
|
||||||
" and p.id is null");
|
" and p.id is null");
|
||||||
|
int sync = Db.queryInt("select count(t.id) cnt from sync_task t\n" +
|
||||||
|
" where t.state = 0");
|
||||||
|
String content = "";
|
||||||
|
|
||||||
if (cnt > 0) {
|
if (cnt > 0) {
|
||||||
String content = "浠水砂石系统有 " + cnt + " 条异常数据。";
|
content += "浠水砂石系统有 " + cnt + " 条异常数据。";
|
||||||
|
}
|
||||||
|
|
||||||
|
if (sync > 0) {
|
||||||
|
content += "浠水砂石系统有 " + sync + " 条数据下发失败。";
|
||||||
|
}
|
||||||
|
|
||||||
|
if (StrKit.notBlank(content) && content.length() > 1) {
|
||||||
log.debug(content);
|
log.debug(content);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue