|
|
@ -91,18 +91,16 @@ public abstract class SyncAccountsJobAbstract {
|
|
|
|
//执行分页同步
|
|
|
|
//执行分页同步
|
|
|
|
sync(context);
|
|
|
|
sync(context);
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
log.error("{} 执行失败 request:{}"
|
|
|
|
log.error("{} 执行失败"
|
|
|
|
, getClassName()
|
|
|
|
, getClassName()
|
|
|
|
, JSONObject.toJSONString(req)
|
|
|
|
|
|
|
|
, e);
|
|
|
|
, e);
|
|
|
|
larkRobotHelper.sendMessageByBot(ROBOT_GROUP, buildRobotErrorMessage(req,e));
|
|
|
|
larkRobotHelper.sendMessageByBot(ROBOT_GROUP, buildRobotErrorMessage(e));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private String buildRobotErrorMessage(CJTJobRequest req,Exception e){
|
|
|
|
private String buildRobotErrorMessage(CJTJobRequest req,Exception e){
|
|
|
|
JSONObject jsonObject = new JSONObject();
|
|
|
|
JSONObject jsonObject = new JSONObject();
|
|
|
|
jsonObject.put("同步任务",getClassName());
|
|
|
|
jsonObject.put("同步任务",getClassName());
|
|
|
|
jsonObject.put("请求参数",JSONObject.toJSONString(req));
|
|
|
|
|
|
|
|
jsonObject.put("异常信息",e.getMessage());
|
|
|
|
jsonObject.put("异常信息",e.getMessage());
|
|
|
|
return jsonObject.toJSONString();
|
|
|
|
return jsonObject.toJSONString();
|
|
|
|
}
|
|
|
|
}
|
|
|
|