| | |
|---|
| | | * 2、开启线程进行处理 |
|---|
| | | * 3、贴异步注解方式(@Async) |
|---|
| | | */ |
|---|
| | | // OrdersTotal ordersTotalSync = ordersTotal; |
|---|
| | | // JSONArray hisPayListSync = hisPayList; |
|---|
| | | OrdersTotal ordersTotalSync = ordersTotal; |
|---|
| | | JSONArray hisPayListSync = hisPayList; |
|---|
| | | orderNodeBuilder.append("-开始处理老带新"); |
|---|
| | | // CompletableFuture<JSONObject> commissionObjectFuture = CompletableFuture.supplyAsync(() -> { |
|---|
| | | // return OrderPayMoneyUtil.handPayOldNew(ordersTotalSync, user, hisPayListSync, commonService); |
|---|
| | | // }, threadPool); |
|---|
| | | // // get 线程返回结果 |
|---|
| | | // commissionObject = commissionObjectFuture.get(); |
|---|
| | | orderService.handPayOldNew(ordersTotal,user,hisPayList,commonService); |
|---|
| | | CompletableFuture<JSONObject> commissionObjectFuture = CompletableFuture.supplyAsync(() -> { |
|---|
| | | return OrderPayMoneyUtil.handPayOldNew(ordersTotalSync, user, hisPayListSync, commonService); |
|---|
| | | }, threadPool); |
|---|
| | | // get 线程返回结果 |
|---|
| | | commissionObject = commissionObjectFuture.get(); |
|---|
| | | // orderService.handPayOldNew(ordersTotal,user,hisPayList,commonService); |
|---|
| | | |
|---|
| | | orderNodeBuilder.append("-结束处理老带新"); |
|---|
| | | }catch (Exception e){ |
|---|
