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