|
|
@ -182,6 +182,7 @@ public abstract class SyncAccountsJobAbstract {
|
|
|
|
* @param context
|
|
|
|
* @param context
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
protected void sync(CJTJobContext context) {
|
|
|
|
protected void sync(CJTJobContext context) {
|
|
|
|
|
|
|
|
String errorMessage = null;
|
|
|
|
CJTRequest cjtRequest = null;
|
|
|
|
CJTRequest cjtRequest = null;
|
|
|
|
CJTRequestBody cjtRequestBody = null;
|
|
|
|
CJTRequestBody cjtRequestBody = null;
|
|
|
|
Integer page = 0;
|
|
|
|
Integer page = 0;
|
|
|
@ -216,11 +217,14 @@ public abstract class SyncAccountsJobAbstract {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
} catch (Exception e) {
|
|
|
|
} catch (Exception e) {
|
|
|
|
log.error("{} exception", this.getClassName(), e);
|
|
|
|
log.error("{} exception", this.getClassName(), e);
|
|
|
|
throw new RuntimeException(buildErrorBody(cjtRequest, e.getMessage()));
|
|
|
|
errorMessage = buildErrorBody(cjtRequest, e.getMessage());
|
|
|
|
} finally {
|
|
|
|
} finally {
|
|
|
|
page++;
|
|
|
|
page++;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}while (!CollectionUtils.isEmpty(rows));
|
|
|
|
}while (!CollectionUtils.isEmpty(rows));
|
|
|
|
|
|
|
|
if (!StringUtils.isEmpty(errorMessage)){
|
|
|
|
|
|
|
|
throw new RuntimeException(errorMessage);
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private List<String> getUniqueKey(List<String> keyList,List<List<String>> rows) {
|
|
|
|
private List<String> getUniqueKey(List<String> keyList,List<List<String>> rows) {
|
|
|
|