|
|
@@ -184,17 +184,17 @@ public class ConsumeBusiness {
|
|
|
int total = list.size();
|
|
|
AtomicInteger success = new AtomicInteger();
|
|
|
AtomicInteger fail = new AtomicInteger();
|
|
|
- //list.forEach(p->{
|
|
|
- // R<ErrorInfo> result = fullOrder(p, "", "");
|
|
|
- // if (R.isSuccess(result)) {
|
|
|
- // doMessage.add(MessageFormat.format("[入账成功]-[{0}]", JsonUtils.toJsonString(p)));
|
|
|
- // success.getAndIncrement();
|
|
|
- // } else {
|
|
|
- // doMessage.add(MessageFormat.format("[入账失败]-[{0}]-[{1}]", JsonUtils.toJsonString(p),JSONUtil.toJsonStr(result.getData())));
|
|
|
- // fail.getAndIncrement();
|
|
|
- // }
|
|
|
- //});
|
|
|
- //doMessage.forEach(System.out::println);
|
|
|
+ list.forEach(p->{
|
|
|
+ R<ErrorInfo> result = fullOrder(p, "", "");
|
|
|
+ if (R.isSuccess(result)) {
|
|
|
+ doMessage.add(MessageFormat.format("[入账成功]-[{0}]", JsonUtils.toJsonString(p)));
|
|
|
+ success.getAndIncrement();
|
|
|
+ } else {
|
|
|
+ doMessage.add(MessageFormat.format("[入账失败]-[{0}]-[{1}]", JsonUtils.toJsonString(p),JSONUtil.toJsonStr(result.getData())));
|
|
|
+ fail.getAndIncrement();
|
|
|
+ }
|
|
|
+ });
|
|
|
+ doMessage.forEach(System.out::println);
|
|
|
return R.ok(MessageFormat.format("[对账处理完成]-[待处理:{0}条,成功:{1}条,失败:{2}条]", total, success.get(), fail.get()));
|
|
|
}
|
|
|
}
|