xjm
/
ssjygl-xsct-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

线上调试，排查问题

dev
lisai17@sina.com 2021-06-22 16:10:45 +08:00
parent 1188bdad47
commit 1b38ecedf4
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ssjygl-xsx-service/src/main/java/com/cowr/service/ssjygl/jobs/CheckExceptionDataJob.java
View File

@ -1,5 +1,6 @@
package com.cowr.service.ssjygl.jobs; package com.cowr.service.ssjygl.jobs;
import com.alibaba.fastjson.JSON;
import com.cowr.common.Const; import com.cowr.common.Const;
import com.cowr.service.ssjygl.main.Config; import com.cowr.service.ssjygl.main.Config;
import com.cowr.service.ssjygl.main.SvrCacheData; import com.cowr.service.ssjygl.main.SvrCacheData;
@ -53,13 +54,17 @@ public class CheckExceptionDataJob implements Job {
int sync = 0; int sync = 0;
if (!onlineids.isEmpty()) { if (!onlineids.isEmpty()) {
sync = Db.queryInt("select count(t.id) cnt from sync_task t \n" + List<Record> tbyc = Db.query("select * from sync_task t \n" +
" where t.state = 0 \n" + " where t.state = 0 \n" +
" and t.create_time < date_add(now(), interval -5 minute) \n" + " and t.create_time < date_add(now(), interval -5 minute) \n" +
" and t.supermarket_id in(" + StrKit.join(onlineids, ",") + ") "); " and t.supermarket_id in(" + StrKit.join(onlineids, ",") + ") ");
sync = tbyc.size();
if (sync > 0) { if (sync > 0) {
content += "浠水砂石系统有 " + sync + " 条数据下发失败。"; content += "浠水砂石系统有 " + sync + " 条数据下发失败。";
log.debug("同步异常数据：%s", JSON.toJSONString(tbyc));
} }
} else { } else {
content += "没有找到" + Config.configprop.get("print.vendor") + "在线砂站信息。"; content += "没有找到" + Config.configprop.get("print.vendor") + "在线砂站信息。";