| | |
| | | import com.dsh.competition.service.IPaymentCompetitionService; |
| | | import com.dsh.competition.service.UserCompetitionService; |
| | | import com.dsh.competition.util.*; |
| | | import org.checkerframework.checker.units.qual.A; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | |
| | | private String alipayPublicKey = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAouYvZ1v4RiydwNOnGcU0Hb4hQu0x6XUooaE2Bi6/atNOobtFdunnATGP6OMOW7yF9DpP8qH5mbFXAiaQD721y/7qlayI50UcV4mngRU4ZcaAVE3bp721Eg2H85RISa+Tb1CiOh+pc9p4l5UBseKsvB2ruHHForfZDPI8FL7AVUKBYCQPsa4zL6KAO2C6KULaTg/lCa+bYQKU0n9ca569VtdsqJUyxB9eSZjVd+9nKl62FLqp2NELGj7cXqiVBgDnBnVS5ZUO3mrBM5z/AxQbw3RwE3JqdkhzUA1BFjejAlT2zIGNOjUFagF8ao0wGElYfuk0bum6Hz5qWAt02QdNNwIDAQAB";//支付宝应用公钥 |
| | | |
| | | private String alipay_public_key = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAmu8n/4yTHWbn7VOrNc9OsLtDL1bEQ8gC1dHkj8Wy5z0mkaOsjJRIG/28ze12M0V8jdCKuuDr5Z1OPKiqf+XO3ypguEh+mYUVMBM/cZodDFQfTY1TKLWjvQCuaqlA+QUTCK6f7T7stsgyQ1o9Jj0rXZDz6PM4QHSTzjrLIBaeqM5WIBvH+fy/X+QG5Utd+/UT0kc0JyvuKhZ65yVUd/C9VcwJJAPliRsAQNrqYterwAJ9zvw9tF11wj9W0XgJ8Ccu4x3gR1vrlLRJJo/OA97RmxPQ+5hSacWQZCUd1dwiBq+YCrKVHGTj14izRHXrLc0yBlRXo7tBOIqcy3IsvKVthQIDAQAB";//支付宝支付公钥 |
| | | |
| | | private String smid = "2088330203191220";//平台支付宝商户号 |
| | | |
| | | /** |
| | | * 获取赛事列表 |
| | |
| | | if (paymentCompetitionVo.getPayType() == 3) {//玩湃币 |
| | | money = new BigDecimal(competition.getPlayPaiCoin()).multiply(new BigDecimal(split.length)).setScale(2, RoundingMode.HALF_EVEN); |
| | | if (money.compareTo(new BigDecimal(appUser.getPlayPaiCoins())) > 0) { |
| | | |
| | | return new ResultUtil(2, "报名失败,玩湃币不足,请充值"); |
| | | } |
| | | } |
| | |
| | | } |
| | | |
| | | if (paymentCompetitionVo.getPayType() == 2) {//支付宝 |
| | | return aliPaymentCompetition(code, money); |
| | | // 判断当前赛事属于哪个运营商 |
| | | Competition byId = competitionService.getById(paymentCompetitionVo.getId()); |
| | | Integer operatorId = byId.getOperatorId(); |
| | | if (operatorId == null || operatorId == 0 ){ |
| | | // 说明是平台 |
| | | return aliPaymentCompetition(operatorId,smid,code, money); |
| | | } |
| | | // 获取该运营商的商户号 |
| | | String smid = storeClient.getSMIDByOperatorId(operatorId); |
| | | return aliPaymentCompetition(operatorId,smid,code, money); |
| | | } |
| | | if (paymentCompetitionVo.getPayType() == 3) {//玩湃币 |
| | | appUser.setPlayPaiCoins(appUser.getPlayPaiCoins() - money.intValue()); |
| | |
| | | * @return |
| | | * @throws Exception |
| | | */ |
| | | public ResultUtil aliPaymentCompetition(String code, BigDecimal money) throws Exception { |
| | | ResultUtil alipay = payMoneyUtil.alipay("报名赛事", "", "", code, money.toString(), "/base/competition/aliPaymentCompetitionCallback"); |
| | | public ResultUtil aliPaymentCompetition(Integer operatorId,String smid,String code, BigDecimal money) throws Exception { |
| | | ResultUtil alipay = payMoneyUtil.alipay |
| | | (smid,"报名赛事", "", "", code, money.toString(), "/base/competition/aliPaymentCompetitionCallback"); |
| | | if (alipay.getCode() == 200) { |
| | | new Thread(new Runnable() { |
| | | @Override |
| | |
| | | paymentCompetition.setAppUserId(null); |
| | | paymentCompetition.setState(3); |
| | | userCompetitionService.remove(new QueryWrapper<UserCompetition>().eq("paymentCompetitionId", paymentCompetition.getId())); |
| | | |
| | | break; |
| | | } |
| | | if ("TRADE_SUCCESS".equals(s)) { |
| | |
| | | paymentCompetition.setPayTime(new Date()); |
| | | paymentCompetition.setPayOrderNo(tradeNo); |
| | | paymentCompetitionService.updateById(paymentCompetition); |
| | | |
| | | if (operatorId == null || operatorId == 0){ |
| | | // 属于平台的赛事 资金不做冻结 不做分账处理 |
| | | payMoneyUtil.confirm1(smid,code,tradeNo,money.toString()); |
| | | }else{ |
| | | // 资金冻结 |
| | | payMoneyUtil.confirm(smid,code,tradeNo,money.toString()); |
| | | // 分账处理 |
| | | extracted(operatorId, money, tradeNo); |
| | | } |
| | | // 结算资金到商户账号 |
| | | //分账 |
| | | moneyOut(tradeNo, tradeNo); |
| | | |
| | | // moneyOut(tradeNo, tradeNo,code); |
| | | break; |
| | | } |
| | | if ("WAIT_BUYER_PAY".equals(s)) { |
| | |
| | | } |
| | | return alipay; |
| | | } |
| | | |
| | | private void extracted(Integer operatorId, BigDecimal money, String tradeNo) throws Exception { |
| | | // 分账 |
| | | AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", |
| | | "2021004105665036", |
| | | "MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQCi5i9nW/hGLJ3A06cZxTQdviFC7THpdSihoTYGLr9q006hu0V26ecBMY/o4w5bvIX0Ok/yofmZsVcCJpAPvbXL/uqVrIjnRRxXiaeBFThlxoBUTdunvbUSDYfzlEhJr5NvUKI6H6lz2niXlQGx4qy8Hau4ccWit9kM8jwUvsBVQoFgJA+xrjMvooA7YLopQtpOD+UJr5thApTSf1xrnr1W12yolTLEH15JmNV372cqXrYUuqnY0QsaPtxeqJUGAOcGdVLllQ7easEznP8DFBvDdHATcmp2SHNQDUEWN6MCVPbMgY06NQVqAXxqjTAYSVh+6TRu6bofPmpYC3TZB003AgMBAAECggEBAJAcR2+PA3NBYUYHeFrqBRMS8uX8ZR19kjZ7IgoSLTFaQsP9opRylPSPXhrPVBKAE5leRQAHn4MCSlESwHvMfxo7KFjFTFAc6dffZZpipYQUOc9bGampwJh58/3e/pyBgVMG6J23CPf/HJQtNFSkjd/V9+ayb/9l2dUEL3bC0fAZ/dbx8HsxdLw8wn3fLlWLj68hOMqa2deCZe3JdSVsPbeWqkh56FFsMLug0Nd+Ar4TgRl9/jnhXF0JWiD0LmPUYLhboY7EfUBzN4w1iYbDi1P+3zvoOYsiVKAXox9GMhQ2VzOO2UcSTuizSza2e98mGpabl/GpKmCz+RDFjtkX6eECgYEA2MyCij65eO3aGIm3FUe93DULRBYTfX8qJQSJq2WOWA3mmQlEW6L3O2B5/lG2h+8WmN6iLEs9eHpgycGYp7vAqgrANEn16ACVcuyx0scFtrZfZ+kmHMzFfiUWxJjVYk/6YngsGVBLdw6ueM42C8TTP67X9tU5TdVGoGWuqEj4W98CgYEAwFqwprXOch5Pqk/RPbb49r0Ou03K/UbciWnWWKzUhFFNS8MdlQPoDvQZbMwHLeWsa2VhaKITK3x5biLQb3U+0GLOn6lTvEyrEUH+ucREyLgVYTRAvwBPtnvlrzpyxPk2HnslQjju8WrvvLLBMKWUjlTrTOzhaHT21gz3pHMiOakCgYEAhLmfaXdBITGshb054sNLDtdCkGpbgEcrzAHdLps769iGxkYQHXHFngpQZUwtTUcoNGqIKknd1jZFrv7gsD+XkgKG7PwimehRlkwmCX5ilxtLiVgJRzRt6+5U5AMVD90a0tHzXYP0z2yjj73fBJF5KtGl0a10KZxaYrQdm1UhB00CgYBZZgzx/k9rtHC8LAqIj1CYhHejT92G53c6Gkl3vyOqN4sgKhfGmSEySfrDGPRBPZxr8ZtbIPCd5mUdberH0osWGMYFaJI1UsCy7aQwvGpniz7MhZeN7dweaOjwDs8mgtjHQ96mL4XGCDhR0BZ/wIURvZ/6iaGdhbbu9unlsWj3uQKBgQCmZYdsbbZkd3ev6f8rwyvMz+DrCQyYpY44cegBYuJgrZiQnL2fJioeN7ixX0UM48SfwsZEIrzshP/LGAwnc2MdjxKUl4jLN8SEe0NAjXOnz9Zaw740+aOmLpXcLWdP4uM2gIhWsvW1tEkQZCXmm7c9s/RsU8Pmzv+YL3+fSijOzA==", |
| | | "json", "GBK", |
| | | "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAmu8n/4yTHWbn7VOrNc9OsLtDL1bEQ8gC1dHkj8Wy5z0mkaOsjJRIG/28ze12M0V8jdCKuuDr5Z1OPKiqf+XO3ypguEh+mYUVMBM/cZodDFQfTY1TKLWjvQCuaqlA+QUTCK6f7T7stsgyQ1o9Jj0rXZDz6PM4QHSTzjrLIBaeqM5WIBvH+fy/X+QG5Utd+/UT0kc0JyvuKhZ65yVUd/C9VcwJJAPliRsAQNrqYterwAJ9zvw9tF11wj9W0XgJ8Ccu4x3gR1vrlLRJJo/OA97RmxPQ+5hSacWQZCUd1dwiBq+YCrKVHGTj14izRHXrLc0yBlRXo7tBOIqcy3IsvKVthQIDAQAB", |
| | | "RSA2"); |
| | | AlipayTradeOrderSettleRequest request = new AlipayTradeOrderSettleRequest(); |
| | | String randomCode = UUIDUtil.getRandomCode(16); |
| | | String proportionByOperatorId = storeClient.getProportionByOperatorId(operatorId); |
| | | // 支付宝分账比例 |
| | | String s1 = proportionByOperatorId.split(",")[1]; |
| | | double i = Double.parseDouble(s1); |
| | | double v = i * 0.01; |
| | | BigDecimal bigDecimal1 = new BigDecimal(String.valueOf(v)); |
| | | BigDecimal cashPayment = money; |
| | | // 分账金额 |
| | | BigDecimal bigDecimal2 = cashPayment.multiply(bigDecimal1).setScale(2, RoundingMode.DOWN); |
| | | request.setBizContent("{" + |
| | | " \"out_request_no\":\"" + randomCode + "\"," + |
| | | " \"trade_no\":\"" + tradeNo + "\"," + |
| | | " \"royalty_parameters\":[" + |
| | | " {" + |
| | | " \"royalty_type\":\"transfer\"," + |
| | | " \"trans_out\":\"" + storeClient.getSMIDByOperatorId(operatorId) + "\"," + |
| | | " \"trans_out_type\":\"userId\"," + |
| | | " \"trans_in_type\":\"userId\"," + |
| | | " \"trans_in\":\"" + smid + "\"," + |
| | | " \"amount\":" + bigDecimal2 + "," + |
| | | " \"desc\":\"平台服务费\"," + |
| | | " \"royalty_scene\":\"平台服务费\"," + |
| | | " }" + |
| | | " ]," + |
| | | " \"extend_params\":{" + |
| | | " \"royalty_finish\":\"true\"" + |
| | | " }," + |
| | | " \"royalty_mode\":\"async\"" + |
| | | "}"); |
| | | AlipayTradeOrderSettleResponse response = alipayClient.execute(request); |
| | | if (response.isSuccess()) { |
| | | System.out.println("调用成功"); |
| | | } else { |
| | | System.out.println("调用失败"); |
| | | } |
| | | } |
| | | // @Autowired |
| | | //private IPaymentCompetitionService paymentCompetitionService; |
| | | |
| | | @Autowired |
| | | private CompetitionService competitionService; |
| | | |
| | | public void moneyOut(String outNum, String tradeNo) throws AlipayApiException { |
| | | public void moneyOut(String outNum, String tradeNo,String code) throws AlipayApiException { |
| | | AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", aliAppid, appPrivateKey, "json", "UTF-8", alipay_public_key, "RSA2"); |
| | | AlipayTradeOrderSettleRequest request = new AlipayTradeOrderSettleRequest(); |
| | | AlipayTradeOrderSettleModel model = new AlipayTradeOrderSettleModel(); |
| | | model.setOutRequestNo(outNum); |
| | | model.setTradeNo(tradeNo); |
| | | List<RoyaltyDetailInfos> royaltyDetailInfos = new ArrayList<>(); |
| | | // |
| | | |
| | | |
| | | AlipayTradeRoyaltyRelationBindRequest request1 = new AlipayTradeRoyaltyRelationBindRequest(); |
| | | |
| | |
| | | } |
| | | |
| | | |
| | | // RoyaltyDetailInfos royaltyDetailInfos1 = new RoyaltyDetailInfos(); |
| | | // royaltyDetailInfos1.setTransOutType("loginName"); |
| | | // royaltyDetailInfos1.setTransOut("happysports@weparklife.com"); |
| | | // royaltyDetailInfos1.setTransInType("loginName"); |
| | | // royaltyDetailInfos1.setTransIn("19522115070"); |
| | | //// royaltyDetailInfos1.setAmount("0.01"); |
| | | // royaltyDetailInfos1.setAmountPercentage("100"); |
| | | |
| | | // royaltyDetailInfos.add(royaltyDetailInfos1); |
| | | |
| | | |
| | | PaymentCompetition code = paymentCompetitionService.getOne(new QueryWrapper<PaymentCompetition>().eq("code", outNum)); |
| | | Competition byId1 = competitionService.getById(code.getCompetitionId()); |
| | | PaymentCompetition code1 = paymentCompetitionService.getOne(new QueryWrapper<PaymentCompetition>().eq("code", code)); |
| | | Competition byId1 = competitionService.getById(code1.getCompetitionId()); |
| | | |
| | | // TCoursePackage byId = coursePackageService.getById(one.getCoursePackageId()); |
| | | OperatorUser operatorUser = storeClient.queryByStoreId(byId1.getOperatorId()); |
| | | |
| | | |
| | | // Integer paymentCompetitions = competitionsClient.queryByCode(outTradeNo); |
| | | // Integer siteBookings = siteClient.queryByCode(outTradeNo); |
| | | // List<Integer> stores = new ArrayList<>(); |
| | | // stores.add(coursePackagePayments); |
| | | // stores.add(paymentCompetitions); |
| | | // stores.add(siteBookings); |
| | | // OperatorUser operatorUser = siteClient.queryOperator(stores); |
| | | |
| | | |
| | | OpenApiRoyaltyDetailInfoPojo op = new OpenApiRoyaltyDetailInfoPojo(); |
| | | op.setTransOutType("loginName"); |
| | | op.setTransOut("happysports@weparklife.com"); |
| | | op.setTransInType("userId"); |
| | | op.setTransIn(operatorUser.getAlipayNum()); |
| | | op.setAmountPercentage(Long.valueOf(operatorUser.getAlipayProportion())); |
| | | op.setTransInType("loginName"); |
| | | // op.setTransInType("userId"); |
| | | op.setTransIn("19522115070"); |
| | | // op.setTransIn(operatorUser.getAlipayNum()); |
| | | // op.setAmountPercentage(Long.valueOf(operatorUser.getAlipayProportion())); |
| | | op.setAmountPercentage(100L); |
| | | |
| | | List<OpenApiRoyaltyDetailInfoPojo> ops = new ArrayList<>(); |
| | | ops.add(op); |
| | |
| | | List<PayCourseRes> list = coursePackagePaymentClient.paymentCompetitionCourseList(uid + "_" + storeId); |
| | | return ResultUtil.success(list); |
| | | } |
| | | |
| | | @Override |
| | | public void moneyOut() throws AlipayApiException { |
| | | Date date = new Date(); |
| | | List<Competition> list = competitionService.list(new QueryWrapper<Competition>().lt("endTime",date).ne("isOut",1)); |
| | | List<Integer> coms = new ArrayList<>(); |
| | | for (Competition competition : list) { |
| | | coms.add(competition.getId()); |
| | | competition.setIsOut(1); |
| | | } |
| | | List<PaymentCompetition> pays = paymentCompetitionService.list(new QueryWrapper<PaymentCompetition>().in("competitionId", coms)); |
| | | for (PaymentCompetition pay : pays) { |
| | | moneyOut(pay.getPayOrderNo(),pay.getPayOrderNo(),pay.getCode()); |
| | | } |
| | | competitionService.updateBatchById(list); |
| | | |
| | | |
| | | } |
| | | } |