java/PlayPai.git

			@@ -12,12 +12,15 @@
			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;
			@@ -112,6 +115,12 @@

			@Resource
			private MerChandiseStoreClient mcsClient;

			@Resource
			private CoursePackageConfigClient cpconClient;

			@Autowired
			private PayMoneyUtil payMoneyUtil;

			@Override
			public ClassInfoVo queryUserOfStus(Integer id,String latitude,String longitude) {
			@@ -536,6 +545,8 @@
			}
			}
			// 4.场地预约
			// TODO: 2023/7/14 账单的场地预约查询

			// 5.智慧球场
			// 6.年度会员
			List<VipPayment> vipPayments = vipPaymentMapper.selectList(new QueryWrapper<VipPayment>()
			@@ -784,7 +795,7 @@
			}

			@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);
			@@ -812,14 +823,34 @@

			this.baseMapper.updateById(tAppUser);
			// 现金支付
			if (exchangeType == 1){
			// 积分兑换
			switch (goodsType){
			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;
			@@ -836,29 +867,149 @@
			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
			@@ -867,17 +1018,22 @@
			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();
			@@ -893,16 +1049,22 @@
			}
			}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();