autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-06-13 03:39:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

批量会员余额退款

Browse Source
This commit is contained in:
autumn.g@foxmail.com
2023-08-11 17:13:43 +08:00
parent 7d4a3540e6
commit 94c20bbc68
3 changed files with 14 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
jsowell-admin/src/main/java/com/jsowell/api/uniapp/TempController.java
View File

@@ -22,6 +22,7 @@ import com.jsowell.pile.service.IMemberPlateNumberRelationService;
import com.jsowell.pile.service.IOrderBasicInfoService; import com.jsowell.pile.service.IOrderBasicInfoService;
import com.jsowell.pile.vo.MemberBalanceVO; import com.jsowell.pile.vo.MemberBalanceVO;
import com.jsowell.service.OrderService; import com.jsowell.service.OrderService;
import org.apache.commons.collections4.CollectionUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
@@ -259,27 +260,28 @@ public class TempController extends BaseController {
/** /**
* 批量退款接口 * 批量余额退款接口
* *
* @param dto * @param dto
* @return * @return
*/ */
@PostMapping("/batchWechatRefund") @PostMapping("/batchWechatRefund")
public RestApiResponse<?> batchWechatRefund(@RequestBody ApplyRefundDTO dto) { public RestApiResponse<?> batchWechatRefund(@RequestBody ApplyRefundDTO dto) {
logger.info("批量退款接口 params:{}", JSONObject.toJSONString(dto)); logger.info("批量余额退款接口 params:{}", JSONObject.toJSONString(dto));
RestApiResponse<?> response = null; RestApiResponse<?> response = null;
List<String> memberIdList = dto.getMemberIdList(); List<String> memberIdList = dto.getMemberIdList();
try { try {
// 查询出本金金额 // 查询出本金金额
List<MemberBalanceVO> memberRefundAmount = memberBasicInfoService.getMemberRefundAmount(memberIdList); List<MemberBalanceVO> memberRefundAmount = memberBasicInfoService.getMemberRefundAmount(memberIdList);
// ApplyRefundDTO refundDTO; if (CollectionUtils.isNotEmpty(memberRefundAmount)) {
for (MemberBalanceVO memberBalanceVO : memberRefundAmount) { memberRefundAmount.parallelStream().forEach(memberBalanceVO -> {
dto = new ApplyRefundDTO(); ApplyRefundDTO refundDTO = new ApplyRefundDTO();
dto.setMemberId(memberBalanceVO.getMemberId()); refundDTO.setMemberId(memberBalanceVO.getMemberId());
dto.setRefundType("2"); refundDTO.setRefundType("2");
dto.setRefundAmount(new BigDecimal(memberBalanceVO.getPrincipalAmount())); refundDTO.setRefundAmount(new BigDecimal(memberBalanceVO.getPrincipalAmount()));
// 调用退款接口 // 调用退款接口
orderService.weChatRefund(dto); orderService.weChatRefund(refundDTO);
});
} }
response = new RestApiResponse<>(); response = new RestApiResponse<>();
} catch (Exception e) { } catch (Exception e) {

4
jsowell-pile/src/main/java/com/jsowell/pile/service/impl/OrderBasicInfoServiceImpl.java
View File

@@ -1803,8 +1803,8 @@ public class OrderBasicInfoServiceImpl implements IOrderBasicInfoService {
if (CollectionUtils.isNotEmpty(requestList)) { if (CollectionUtils.isNotEmpty(requestList)) {
for (WechatPayRefundRequest refundRequest : requestList) { for (WechatPayRefundRequest refundRequest : requestList) {
try { try {
return wechatPayService.ApplyForWechatPayRefundV3(refundRequest); WechatPayRefundResponse wechatPayRefundResponse = wechatPayService.ApplyForWechatPayRefundV3(refundRequest);
// logger.info("调微信退款API退款====={}", JSONObject.toJSONString(refundRequest)); logger.info("调微信退款API退款====={}", JSONObject.toJSONString(wechatPayRefundResponse));
} catch (Exception e) { } catch (Exception e) {
logger.error("调微信退款API发生异常", e); logger.error("调微信退款API发生异常", e);
} }

7
jsowell-thirdparty/src/main/java/com/jsowell/thirdparty/amap/service/impl/AMapServiceImpl.java vendored
View File

@@ -111,13 +111,6 @@ public class AMapServiceImpl implements AMapService {
}).collect(Collectors.toList()) }).collect(Collectors.toList())
).fork().join(); ).fork().join();
// List<AMapStationInfo> resultList = pageInfo.getList().parallelStream().map(x -> {
// try {
// return assembleAMapData(x);
// } catch (ExecutionException | InterruptedException e) {
// throw new RuntimeException(e);
// }
// }).collect(Collectors.toList());
sw.stop(); sw.stop();
log.info("接口耗时：{}, 详情:{}", sw.getTotalTimeMillis(), sw.prettyPrint()); log.info("接口耗时：{}, 详情:{}", sw.getTotalTimeMillis(), sw.prettyPrint());
return resultList; return resultList;