新增 批量退款临时接口

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

@@ -13,15 +13,20 @@ import com.jsowell.common.util.DateUtils;
 import com.jsowell.pile.domain.AdapayMemberAccount;
 import com.jsowell.pile.domain.MemberPlateNumberRelation;
 import com.jsowell.pile.domain.OrderBasicInfo;
+import com.jsowell.pile.dto.ApplyRefundDTO;
 import com.jsowell.pile.dto.CarVinDTO;
 import com.jsowell.pile.dto.QueryOrderDTO;
 import com.jsowell.pile.service.IAdapayMemberAccountService;
+import com.jsowell.pile.service.IMemberBasicInfoService;
 import com.jsowell.pile.service.IMemberPlateNumberRelationService;
 import com.jsowell.pile.service.IOrderBasicInfoService;
+import com.jsowell.pile.vo.MemberBalanceVO;
+import com.jsowell.service.OrderService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
 import javax.servlet.http.HttpServletRequest;
+import java.math.BigDecimal;
 import java.util.List;
 
 /**
@@ -44,9 +49,16 @@ public class TempController extends BaseController {
     @Autowired
     private AdapayMemberService adapayMemberService;
 
+    @Autowired
+    private IMemberBasicInfoService memberBasicInfoService;
+
+    @Autowired
+    private OrderService orderService;
+
     /**
      * 临时刷数据接口
      * http://localhost:8080/temp/tempUpdateVirtualAmount
+     *
      * @param request
      * @return
      */
@@ -71,6 +83,7 @@ public class TempController extends BaseController {
     /**
      * 临时订单退款
      * http://localhost:8080/temp/tempOrderRefund
+     *
      * @return
      */
     @GetMapping("tempOrderRefund")
@@ -93,6 +106,7 @@ public class TempController extends BaseController {
     /**
      * 批量退款接口
      * http://localhost:8080/temp/batchRefund
+     *
      * @param dto
      * @return
      */
@@ -116,6 +130,7 @@ public class TempController extends BaseController {
     /**
      * 临时接口，计算站点订单报表
      * http://localhost:8080/temp/tempGenerateDailyOrderReports
+     *
      * @param dto
      * @return
      */
@@ -148,6 +163,7 @@ public class TempController extends BaseController {
 
     /**
      * 临时接口测试vin查询方法
+     *
      * @param dto
      * @return
      */
@@ -190,6 +206,7 @@ public class TempController extends BaseController {
     /**
      * 运营商分账手动接口
      * http://localhost:8080/temp/orderSplittingOperations
+     *
      * @return
      */
     @PostMapping("/orderSplittingOperations")
@@ -239,4 +256,36 @@ public class TempController extends BaseController {
         logger.info("测试余额支付接口result:{}", JSONObject.toJSONString(response));
         return response;
     }
+
+
+    /**
+     * 批量退款接口
+     *
+     * @param dto
+     * @return
+     */
+    @PostMapping("/batchRefund")
+    public RestApiResponse<?> batchRefund(@RequestBody ApplyRefundDTO dto) {
+        logger.info("批量退款接口 params:{}", JSONObject.toJSONString(dto));
+        RestApiResponse<?> response = null;
+        List<String> memberIdList = dto.getMemberIdList();
+        try {
+            // 查询出本金金额
+            List<MemberBalanceVO> memberRefundAmount = memberBasicInfoService.getMemberRefundAmount(memberIdList);
+            // ApplyRefundDTO refundDTO;
+            for (MemberBalanceVO memberBalanceVO : memberRefundAmount) {
+                dto = new ApplyRefundDTO();
+                dto.setMemberId(memberBalanceVO.getMemberId());
+                dto.setRefundType("2");
+                dto.setRefundAmount(new BigDecimal(memberBalanceVO.getPrincipalAmount()));
+                // 调用退款接口
+                orderService.weChatRefund(dto);
+            }
+            response = new RestApiResponse<>();
+        } catch (Exception e) {
+            logger.error("批量退款接口 error,", e);
+            response = new RestApiResponse<>(e);
+        }
+        return response;
+    }
 }