From d6f43fd47497989f60856bc2ebf87d824c965a20 Mon Sep 17 00:00:00 2001 From: YXY <932687738@qq.com> Date: Wed, 27 Sep 2023 19:49:53 +0800 Subject: [PATCH] =?UTF-8?q?odoo=E5=A2=9E=E5=8A=A0=E5=AD=97=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../quartz/task/CJT/SyncAccountsJobAbstract.java | 14 ++++++++++++++ .../ruoyi/quartz/task/odoo/AccountMoveLineJob.java | 3 ++- 2 files changed, 16 insertions(+), 1 deletion(-) diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java index 19850b2..f1a935f 100644 --- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java +++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/CJT/SyncAccountsJobAbstract.java @@ -183,6 +183,7 @@ public abstract class SyncAccountsJobAbstract { String asynchronous = getAsynchronousKey(cjt); redisCache.deleteObject(asynchronous); } else { + larkRobotHelper.sendMessageByBot(ROBOT_GROUP, buildRobotErrorCountMessage2(e, queryFromTime,queryToTime)); CJTRetryRequest request = new CJTRetryRequest(now, 1, cjt); redisCache.rightPush(getRetryKey(cjt), request); } @@ -245,6 +246,19 @@ public abstract class SyncAccountsJobAbstract { return jsonObject.toJSONString(); } + private String buildRobotErrorCountMessage2(Exception e, String queryFrom, String queryEnd) { + JSONObject jsonObject = new JSONObject(); + jsonObject.put("同步任务", getClassName()); + jsonObject.put("同步开始时间", queryFrom); + jsonObject.put("同步结束时间", queryEnd); + String errorMessage = e.getMessage(); + if (org.apache.commons.lang3.StringUtils.isNotBlank(errorMessage)) { + errorMessage = errorMessage.replaceAll("\\\\", ""); + } + jsonObject.put("异常信息", errorMessage); + return jsonObject.toJSONString(); + } + private String buildRobotErrorMessage(Exception e) { JSONObject jsonObject = new JSONObject(); jsonObject.put("同步任务(待重试)", getClassName()); diff --git a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/odoo/AccountMoveLineJob.java b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/odoo/AccountMoveLineJob.java index 7bd9d1c..d057891 100644 --- a/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/odoo/AccountMoveLineJob.java +++ b/ruoyi-quartz/src/main/java/com/ruoyi/quartz/task/odoo/AccountMoveLineJob.java @@ -52,7 +52,7 @@ public class AccountMoveLineJob extends OdooAbstrackob { // , "quantity", "unit_price", "company_id.display_name","product_id.categ_id.name")); // }}; return new HashMap() {{ - put("fields", Arrays.asList("id", "date", "quantity","partner_id","product_id","price_unit","company_id")); + put("fields", Arrays.asList("id", "date", "quantity","partner_id","product_id","price_unit","company_id","move_name")); }}; } @@ -72,6 +72,7 @@ public class AccountMoveLineJob extends OdooAbstrackob { JSONArray companyArr = parseJsonArray(date.getString("company_id"),2); map.put("company_id",companyArr.getString(0)); map.put("company_name",companyArr.getString(1)); + map.put("move_name",date.getString("move_name")); return map; }