mirror of
https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git
synced 2026-04-20 02:55:04 +08:00
update 临时分账接口
This commit is contained in:
@@ -351,12 +351,25 @@ public class TempController extends BaseController {
|
||||
logger.info("手动接口执行订单分账逻辑-param:{}", JSON.toJSONString(dto));
|
||||
RestApiResponse<?> response = null;
|
||||
try {
|
||||
// 查询运营商列表
|
||||
List<String> merchantIdList = dto.getMerchantIdList();
|
||||
if (CollectionUtils.isEmpty(merchantIdList)) {
|
||||
List<PileMerchantInfo> pileMerchantInfos = pileMerchantInfoService.selectPileMerchantInfoList(null);
|
||||
merchantIdList = pileMerchantInfos.stream().map(x -> x.getId() + "").collect(Collectors.toList());
|
||||
}
|
||||
String startTime = dto.getStartTime();
|
||||
String endTime = dto.getEndTime();
|
||||
// 获取日期区间内所有日期
|
||||
List<String> dateList = DateUtils.getAllDatesInTheDateRange(startTime, endTime);
|
||||
for (String tradeDate : dateList) {
|
||||
orderBasicInfoService.orderSplittingOperations(dto.getMerchantId(), tradeDate);
|
||||
merchantIdList.parallelStream().forEach(merchantId -> {
|
||||
try {
|
||||
orderBasicInfoService.orderSplittingOperations(merchantId, tradeDate);
|
||||
} catch (Exception e) {
|
||||
logger.error("手动接口执行订单分账逻辑 error, merchantId:{}", merchantId, e);
|
||||
}
|
||||
});
|
||||
|
||||
}
|
||||
response = new RestApiResponse<>();
|
||||
} catch (BusinessException e) {
|
||||
|
||||
Reference in New Issue
Block a user