| | |
|---|
| | | import com.dsh.account.feignclient.competition.DeductionCompetitionsClient; |
|---|
| | | import com.dsh.account.feignclient.competition.model.PaymentCompetition; |
|---|
| | | import com.dsh.account.feignclient.course.CoursePackageClient; |
|---|
| | | import com.dsh.account.feignclient.course.CoursePackageConfigClient; |
|---|
| | | import com.dsh.account.feignclient.course.CoursePaymentClient; |
|---|
| | | import com.dsh.account.feignclient.course.model.*; |
|---|
| | | import com.dsh.account.feignclient.other.ImgConfigClient; |
|---|
| | | import com.dsh.account.feignclient.other.RechargeConfigClient; |
|---|
| | | import com.dsh.account.feignclient.other.StoreClient; |
|---|
| | | import com.dsh.account.feignclient.other.model.*; |
|---|
| | | import com.dsh.account.feignclient.other.model.Store; |
|---|
| | | import com.dsh.account.feignclient.other.model.StoreDetailOfCourse; |
|---|
| | | import com.dsh.account.feignclient.other.model.TImgConfig; |
|---|
| | | import com.dsh.account.mapper.*; |
|---|
| | | import com.dsh.account.model.AddAppUserVo; |
|---|
| | | import com.dsh.account.model.JoinPlayPaiVo; |
|---|
| | |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private MerChandiseStoreClient mcsClient; |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private CoursePackageConfigClient cpconClient; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private PayMoneyUtil payMoneyUtil; |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public ClassInfoVo queryUserOfStus(Integer id,String latitude,String longitude) { |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public ResultUtil productRedemptionOperation(Integer userIdFormRedis, Integer goodId, Integer goodsType,Integer nums,Integer exchangeType,Integer payType) { |
|---|
| | | public ResultUtil productRedemptionOperation(Integer userIdFormRedis, Integer goodId, Integer goodsType,Integer nums,Integer exchangeType,Integer payType,List<Integer> stuIds) { |
|---|
| | | PointsMerchandise merchandise = mcClient.selectPointsMerchandiseById(goodId); |
|---|
| | | SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS"); |
|---|
| | | String code = sdf.format(new Date()) + UUIDUtil.getNumberRandom(5); |
|---|
| | |
|---|
| | | |
|---|
| | | this.baseMapper.updateById(tAppUser); |
|---|
| | | // 现金支付 |
|---|
| | | if (exchangeType == 1){ |
|---|
| | | // 积分兑换 |
|---|
| | | if (exchangeType == 2) { |
|---|
| | | switch (goodsType){ |
|---|
| | | case 2: |
|---|
| | | for (int i = 0; i < nums; i++) { |
|---|
| | | for (int i = 0; i < stuIds.size(); i++) { |
|---|
| | | List<CoursePackagePaymentConfig> courseConfigList = cpconClient.getCourseConfigList(merchandise.getCoursePackageId()); |
|---|
| | | |
|---|
| | | TCoursePackagePayment packagePayment = new TCoursePackagePayment(); |
|---|
| | | // packagePayment.setAppUserId(); |
|---|
| | | // TODO: 2023/7/14 |
|---|
| | | packagePayment.setAppUserId(userIdFormRedis); |
|---|
| | | packagePayment.setStudentId(stuIds.get(i)); |
|---|
| | | packagePayment.setCoursePackageId(merchandise.getCoursePackageId()); |
|---|
| | | for (CoursePackagePaymentConfig coursePackagePaymentConfig : courseConfigList) { |
|---|
| | | if (Objects.equals(coursePackagePaymentConfig.getId(),merchandise.getCoursePackageConfigId())){ |
|---|
| | | packagePayment.setClassHours(coursePackagePaymentConfig.getClassHours()); |
|---|
| | | packagePayment.setTotalClassHours(coursePackagePaymentConfig.getClassHours()); |
|---|
| | | packagePayment.setLaveClassHours(coursePackagePaymentConfig.getClassHours()); |
|---|
| | | packagePayment.setOriginalPrice(coursePackagePaymentConfig.getCashPayment()); |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | packagePayment.setPlayPaiCoin(merchandise.getIntegral()); |
|---|
| | | packagePayment.setAbsencesNumber(0); |
|---|
| | | packagePayment.setPayUserType(1); |
|---|
| | | packagePayment.setPayStatus(1); |
|---|
| | | packagePayment.setPayUserId(userIdFormRedis); |
|---|
| | | packagePayment.setStatus(1); |
|---|
| | | packagePayment.setState(1); |
|---|
| | | packagePayment.setInsertTime(new Date()); |
|---|
| | | packagePayment.setCode(code); |
|---|
| | | paymentClient.savePaymentCoursePackage(packagePayment); |
|---|
| | | } |
|---|
| | | break; |
|---|
| | |
|---|
| | | default: |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | }else { |
|---|
| | | |
|---|
| | | switch (payType){ |
|---|
| | | case 1: |
|---|
| | | return WechatPayment(merchandise.getCash(),code); |
|---|
| | | try { |
|---|
| | | if (merchandise.getType() == 2){ |
|---|
| | | return WechatPayment(merchandise.getCash().multiply(new BigDecimal(stuIds.size())),code); |
|---|
| | | }else { |
|---|
| | | return WechatPayment(merchandise.getCash().multiply(new BigDecimal(nums)),code); |
|---|
| | | } |
|---|
| | | }catch (Exception e){ |
|---|
| | | return ResultUtil.runErr(); |
|---|
| | | } |
|---|
| | | case 2: |
|---|
| | | return AlipayPayment(merchandise.getCash(),code); |
|---|
| | | if (merchandise.getType() == 2){ |
|---|
| | | AlipayPayment(merchandise.getCash().multiply(new BigDecimal(stuIds.size())),code); |
|---|
| | | }else { |
|---|
| | | AlipayPayment(merchandise.getCash().multiply(new BigDecimal(nums)),code); |
|---|
| | | } |
|---|
| | | break; |
|---|
| | | default: |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | return null; |
|---|
| | | return ResultUtil.success(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | private ResultUtil AlipayPayment(BigDecimal cash, String code) { |
|---|
| | | |
|---|
| | | return ResultUtil.success(); |
|---|
| | | ResultUtil alipay = payMoneyUtil.alipay("课包续费", "", "", code, cash.toString(), |
|---|
| | | "/base/pointMer/exchangeGoodPaymentAliCallback"); |
|---|
| | | if(alipay.getCode() == 200){ |
|---|
| | | new Thread(new Runnable() { |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | | try { |
|---|
| | | int num = 1; |
|---|
| | | int wait = 0; |
|---|
| | | while (num <= 10){ |
|---|
| | | int min = 5000; |
|---|
| | | wait += (min * num); |
|---|
| | | Thread.sleep(wait); |
|---|
| | | List<UserPointsMerchandise> userPointsMerchandises = mcClient.queryUserPointMerchaseByCode(code); |
|---|
| | | if(userPointsMerchandises.get(0).getPayStatus() == 2){ |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryALIOrder(code); |
|---|
| | | if(resultUtil.getCode() == 200 && userPointsMerchandises.get(0).getPayStatus() == 1){ |
|---|
| | | /** |
|---|
| | | * WAIT_BUYER_PAY（交易创建，等待买家付款）、 |
|---|
| | | * TRADE_CLOSED（未付款交易超时关闭，或支付完成后全额退款）、 |
|---|
| | | * TRADE_SUCCESS（交易支付成功）、 |
|---|
| | | * TRADE_FINISHED（交易结束，不可退款） |
|---|
| | | */ |
|---|
| | | Map<String, String> data1 = resultUtil.getData(); |
|---|
| | | String s = data1.get("tradeStatus"); |
|---|
| | | String tradeNo = data1.get("tradeNo"); |
|---|
| | | // if("TRADE_CLOSED".equals(s) || "TRADE_FINISHED".equals(s) || num == 10){ |
|---|
| | | // coursePackagePayment.setState(3); |
|---|
| | | // couPayClient.delPaymentCoursePackage(coursePackagePayment.getId()); |
|---|
| | | // break; |
|---|
| | | // } |
|---|
| | | if("TRADE_SUCCESS".equals(s)){ |
|---|
| | | for (UserPointsMerchandise userPointsMerchandise : userPointsMerchandises) { |
|---|
| | | userPointsMerchandise.setPayStatus(2); |
|---|
| | | userPointsMerchandise.setOrderNumber(tradeNo); |
|---|
| | | userPointsMerchandise.setPayType(2); |
|---|
| | | mcClient.updateDetailsUserPointMercase(userPointsMerchandise); |
|---|
| | | } |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | if("WAIT_BUYER_PAY".equals(s)){ |
|---|
| | | num++; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }catch (Exception e){ |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }).start(); |
|---|
| | | } |
|---|
| | | return alipay; |
|---|
| | | } |
|---|
| | | |
|---|
| | | private ResultUtil WechatPayment(BigDecimal cash, String code) { |
|---|
| | | |
|---|
| | | return ResultUtil.success(); |
|---|
| | | private ResultUtil WechatPayment(BigDecimal cash, String code) throws Exception { |
|---|
| | | ResultUtil weixinpay = payMoneyUtil.weixinpay("课包", "", code, cash.toString(), |
|---|
| | | "/base/pointMer/exchangeGoodPaymentWeChatCallback", "APP", ""); |
|---|
| | | if(weixinpay.getCode() == 200){ |
|---|
| | | new Thread(new Runnable() { |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | | try { |
|---|
| | | int num = 1; |
|---|
| | | int wait = 0; |
|---|
| | | while (num <= 10){ |
|---|
| | | int min = 5000; |
|---|
| | | wait += (min * num); |
|---|
| | | Thread.sleep(wait); |
|---|
| | | List<UserPointsMerchandise> userPointsMerchandises = mcClient.queryUserPointMerchaseByCode(code); |
|---|
| | | if(userPointsMerchandises.get(0).getPayStatus() == 2){ |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryWXOrder(code, ""); |
|---|
| | | if(resultUtil.getCode() == 200 && userPointsMerchandises.get(0).getPayStatus() == 1){ |
|---|
| | | /** |
|---|
| | | * SUCCESS—支付成功， |
|---|
| | | * REFUND—转入退款， |
|---|
| | | * NOTPAY—未支付， |
|---|
| | | * CLOSED—已关闭， |
|---|
| | | * REVOKED—已撤销（刷卡支付）， |
|---|
| | | * USERPAYING--用户支付中， |
|---|
| | | * PAYERROR--支付失败(其他原因，如银行返回失败) |
|---|
| | | */ |
|---|
| | | Map<String, String> data1 = resultUtil.getData(); |
|---|
| | | String s = data1.get("trade_state"); |
|---|
| | | String transaction_id = data1.get("transaction_id"); |
|---|
| | | // if("REFUND".equals(s) || "NOTPAY".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10){ |
|---|
| | | // coursePackagePayment.setState(3); |
|---|
| | | // couPayClient.delPaymentCoursePackage(coursePackagePayment.getId()); |
|---|
| | | // break; |
|---|
| | | // } |
|---|
| | | if("SUCCESS".equals(s)){ |
|---|
| | | for (UserPointsMerchandise userPointsMerchandise : userPointsMerchandises) { |
|---|
| | | userPointsMerchandise.setPayStatus(2); |
|---|
| | | userPointsMerchandise.setOrderNumber(transaction_id); |
|---|
| | | userPointsMerchandise.setPayType(1); |
|---|
| | | mcClient.updateDetailsUserPointMercase(userPointsMerchandise); |
|---|
| | | } |
|---|
| | | break; |
|---|
| | | } |
|---|
| | | if("USERPAYING".equals(s)){ |
|---|
| | | num++; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }catch (Exception e){ |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }).start(); |
|---|
| | | } |
|---|
| | | return weixinpay; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | |
|---|
| | | if (userPointsMerchandises.size() > 1){ |
|---|
| | | for (int i = 0; i < userPointsMerchandises.size(); i++) { |
|---|
| | | userPointsMerchandises.get(i).setOrderNumber(orderNumber+ "-" + (i+1)); |
|---|
| | | userPointsMerchandises.get(i).setPayType(payType); |
|---|
| | | userPointsMerchandises.get(i).setPayStatus(2); |
|---|
| | | mcClient.updateDetailsUserPointMercase(userPointsMerchandises.get(i)); |
|---|
| | | |
|---|
| | | Integer pointsMerchandiseId = userPointsMerchandises.get(i).getPointsMerchandiseId(); |
|---|
| | | PointsMerchandise pointsMerchandise = mcClient.selectPointsMerchandiseById(pointsMerchandiseId); |
|---|
| | | switch (pointsMerchandise.getType()){ |
|---|
| | | case 2: |
|---|
| | | TCoursePackagePayment packagePayment = new TCoursePackagePayment(); |
|---|
| | | |
|---|
| | | // packagePayment.setAppUserId(); |
|---|
| | | |
|---|
| | | paymentClient.savePaymentCoursePackage(packagePayment); |
|---|
| | | List<TCoursePackagePayment> coursePackagePaymentOfCode = paymentClient.getCoursePackagePaymentOfCode(code); |
|---|
| | | for (TCoursePackagePayment coursePackagePayment : coursePackagePaymentOfCode) { |
|---|
| | | coursePackagePayment.setPayStatus(2); |
|---|
| | | coursePackagePayment.setPayType(payType); |
|---|
| | | coursePackagePayment.setOrderNumber(orderNumber); |
|---|
| | | coursePackagePayment.setCashPayment(pointsMerchandise.getCash()); |
|---|
| | | paymentClient.updatePaymentCoursePackage(coursePackagePayment); |
|---|
| | | } |
|---|
| | | break; |
|---|
| | | case 4: |
|---|
| | | UserCoupon coupon = new UserCoupon(); |
|---|
| | |
|---|
| | | } |
|---|
| | | }else { |
|---|
| | | userPointsMerchandises.get(0).setOrderNumber(orderNumber); |
|---|
| | | userPointsMerchandises.get(0).setPayType(payType); |
|---|
| | | userPointsMerchandises.get(0).setPayStatus(2); |
|---|
| | | mcClient.updateDetailsUserPointMercase(userPointsMerchandises.get(0)); |
|---|
| | | |
|---|
| | | Integer pointsMerchandiseId = userPointsMerchandises.get(0).getPointsMerchandiseId(); |
|---|
| | | PointsMerchandise pointsMerchandise = mcClient.selectPointsMerchandiseById(pointsMerchandiseId); |
|---|
| | | switch (pointsMerchandise.getType()){ |
|---|
| | | case 2: |
|---|
| | | TCoursePackagePayment packagePayment = new TCoursePackagePayment(); |
|---|
| | | List<TCoursePackagePayment> coursePackagePaymentOfCode = paymentClient.getCoursePackagePaymentOfCode(code); |
|---|
| | | |
|---|
| | | // packagePayment.setAppUserId(); |
|---|
| | | |
|---|
| | | paymentClient.savePaymentCoursePackage(packagePayment); |
|---|
| | | TCoursePackagePayment packagePayment =coursePackagePaymentOfCode.get(0); |
|---|
| | | packagePayment.setPayStatus(2); |
|---|
| | | packagePayment.setPayType(payType); |
|---|
| | | packagePayment.setOrderNumber(orderNumber); |
|---|
| | | packagePayment.setCashPayment(pointsMerchandise.getCash()); |
|---|
| | | paymentClient.updatePaymentCoursePackage(packagePayment); |
|---|
| | | break; |
|---|
| | | case 4: |
|---|
| | | UserCoupon coupon = new UserCoupon(); |
|---|
