lisai17@sina.com 2020-11-17 09:19:49 +08:00
parent 258d6d7882
commit 0ce568d273
2 changed files with 19 additions and 18 deletions

View File

@ -47,7 +47,7 @@ public class CustomerStatService {
" a.total_cnt,\n" +
" b.amount,\n" +
" b.refund_amount,\n" +
" b.amount - a.total_price - b.refund_amount then_surplus\n" +
" b.amount - ifnull(a.total_price,0) - b.refund_amount then_surplus\n" +
" from prepay_customer t\n" +
" left join customer c on c.id= t.customer_id\n" +
" left join(\n" +
@ -93,7 +93,7 @@ public class CustomerStatService {
" a.total_cnt,\n" +
" b.amount,\n" +
" b.refund_amount,\n" +
" b.amount - a.total_price - b.refund_amount then_surplus\n" +
" b.amount - ifnull(a.total_price,0) - b.refund_amount then_surplus\n" +
" from prepay_customer t\n" +
" left join customer c on c.id= t.customer_id\n" +
" left join(\n" +

View File

@ -35,28 +35,29 @@ public class CheckExceptionDataJob implements Job {
}
}
int cnt = 0;
if (!onlineids.isEmpty()) {
cnt = Db.queryInt("select count(t.sn) cnt from order_temp t\n" +
int cnt = Db.queryInt("select count(t.sn) cnt from order_temp t\n" +
" left join transport p on t.sn = p.order_sn\n" +
" where t.state = 5 \n" +
" and t.supermarket_id in(" + StrKit.join(onlineids, ",") + ") \n" +
" and p.id is null");
} else {
content += "没有找到在线砂站信息。";
log.error("没有找到在线砂站信息。");
}
int sync = Db.queryInt("select count(t.id) cnt from sync_task t where t.state = 0");
if (cnt > 0) {
content += "浠水砂石系统有 " + cnt + " 条订单异常数据。";
}
int sync = 0;
if (!onlineids.isEmpty()) {
sync = Db.queryInt("select count(t.id) cnt from sync_task t \n" +
" where t.state = 0 \n" +
" and t.supermarket_id in(" + StrKit.join(onlineids, ",") + ") ");
if (sync > 0) {
content += "浠水砂石系统有 " + sync + " 条数据下发失败。";
}
} else {
content += "没有找到在线砂站信息。";
log.error("没有找到在线砂站信息。");
}
if (StrKit.notBlank(content) && content.length() > 1) {
log.debug(content);