|
|
@ -183,6 +183,7 @@ public abstract class SyncAccountsJobAbstract {
|
|
|
|
String asynchronous = getAsynchronousKey(cjt);
|
|
|
|
String asynchronous = getAsynchronousKey(cjt);
|
|
|
|
redisCache.deleteObject(asynchronous);
|
|
|
|
redisCache.deleteObject(asynchronous);
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
|
|
|
|
larkRobotHelper.sendMessageByBot(ROBOT_GROUP, buildRobotErrorCountMessage2(e, queryFromTime,queryToTime));
|
|
|
|
CJTRetryRequest request = new CJTRetryRequest(now, 1, cjt);
|
|
|
|
CJTRetryRequest request = new CJTRetryRequest(now, 1, cjt);
|
|
|
|
redisCache.rightPush(getRetryKey(cjt), request);
|
|
|
|
redisCache.rightPush(getRetryKey(cjt), request);
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -245,6 +246,19 @@ public abstract class SyncAccountsJobAbstract {
|
|
|
|
return jsonObject.toJSONString();
|
|
|
|
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) {
|
|
|
|
private String buildRobotErrorMessage(Exception e) {
|
|
|
|
JSONObject jsonObject = new JSONObject();
|
|
|
|
JSONObject jsonObject = new JSONObject();
|
|
|
|
jsonObject.put("同步任务(待重试)", getClassName());
|
|
|
|
jsonObject.put("同步任务(待重试)", getClassName());
|
|
|
|