查询余额

cooleshow-user/user-admin/src/main/java/com/yonge/cooleshow/admin/controller/CourseGroupController.java

@@ -4,6 +4,7 @@ import com.yonge.cooleshow.auth.api.client.SysUserFeignService;
 import com.yonge.cooleshow.biz.dal.dto.search.CourseGroupDetailSearch;
 import com.yonge.cooleshow.biz.dal.dto.search.CourseGroupSearch;
 import com.yonge.cooleshow.biz.dal.entity.VideoLessonGroupDetail;
+import com.yonge.cooleshow.biz.dal.sdk.WithdrawSdk;
 import com.yonge.cooleshow.biz.dal.service.CourseGroupService;
 import com.yonge.cooleshow.biz.dal.service.CourseScheduleService;
 import com.yonge.toolset.mybatis.support.PageUtil;
@@ -35,6 +36,8 @@ public class CourseGroupController extends BaseController {
     private SysUserFeignService sysUserFeignService;
     @Autowired
     private CourseScheduleService courseScheduleService;
+    @Autowired
+    private WithdrawSdk sdk;
 
     @ApiOperation(value = "课程组管理-陪练课", notes = "{\n" +
             "    \"subjectId\":20,\n" +
@@ -213,4 +216,9 @@ public class CourseGroupController extends BaseController {
     public HttpResponseResult<PageInfo<CourseGroupPianoDetailVo>> selectPianoGroupTeacherDetail(@Validated @RequestBody CourseGroupDetailSearch search) {
         return succeed(PageUtil.pageInfo(courseGroupService.selectPianoGroupTeacherDetail(PageUtil.getPage(search), search)));
     }
+
+    @GetMapping("/test")
+    public HttpResponseResult test() {
+        return succeed(sdk.balanceQuery());
+    }
 }

cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/sdk/WithdrawSdk.java

@@ -50,6 +50,8 @@ public class WithdrawSdk {
     //结算第三方url
     @Value("${withdraw.apiUrl}")
     private String apiUrl;
+    @Value("${withdraw.privateKey}")
+    private String privateKey;
 
     /**
      * 签署协议
@@ -243,4 +245,33 @@ public class WithdrawSdk {
         }
         return null;
     }
+
+    public String balanceQuery(){
+        Map<String, Object> requestMap = new HashMap<>();
+        requestMap.put("outMemberNo", memberNo);
+        requestMap.put("charset", "UTF-8");
+        requestMap.put("service", "bpotop.zx.pay.order");
+        requestMap.put("version", "2.0");
+        requestMap.put("signType", "RSA");
+
+        String jsonStr = JSONObject.toJSONString(requestMap);
+        String encryptStr = null;
+        try {
+            encryptStr = RSA.encryptPub(jsonStr, publicKey);
+            requestMap.put("sign", encryptStr);
+            logger.info("查询余额请求参数：{}", requestMap);
+        } catch (Exception e) {
+            throw new ThirdpartyException("加密失败：{}", e.getMessage());
+        }
+
+        String resultJsonStr = null;
+        try {
+            resultJsonStr = HttpUtil.postForHttp(apiUrl + "/bpotop_trade/balance_query", JSONObject.toJSONString(requestMap), null);
+            logger.info("查询余额响应参数：{}", resultJsonStr);
+            return resultJsonStr;
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
 }