From 1b38ecedf47d040b6b28348c1bc03b89224a35a9 Mon Sep 17 00:00:00 2001 From: "lisai17@sina.com" Date: Tue, 22 Jun 2021 16:10:45 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BA=BF=E4=B8=8A=E8=B0=83=E8=AF=95=EF=BC=8C?= =?UTF-8?q?=E6=8E=92=E6=9F=A5=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cowr/service/ssjygl/jobs/CheckExceptionDataJob.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) 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") + "在线砂站信息。";