java/PlayPai.git

			@@ -25,16 +25,14 @@
			import com.dsh.competition.service.IParticipantService;
			import com.dsh.competition.service.IPaymentCompetitionService;
			import com.dsh.competition.service.UserCompetitionService;
			import com.dsh.competition.util.PayMoneyUtil;
			import com.dsh.competition.util.ResultUtil;
			import com.dsh.competition.util.TokenUtil;
			import com.dsh.competition.util.ToolUtil;
			import com.dsh.competition.util.*;
			import io.swagger.annotations.ApiImplicitParam;
			import io.swagger.annotations.ApiImplicitParams;
			import io.swagger.annotations.ApiOperation;

			import lombok.Synchronized;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.util.StringUtils;
			import org.springframework.web.bind.annotation.*;

			import javax.annotation.Resource;
			@@ -42,6 +40,7 @@
			import javax.servlet.http.HttpServletResponse;
			import java.io.OutputStream;
			import java.io.PrintWriter;
			import java.math.BigDecimal;
			import java.text.DateFormat;
			import java.text.SimpleDateFormat;
			import java.util.*;
			@@ -110,11 +109,12 @@
			// 获取到赛事id集合去重
			List<Integer> collect = comIds.stream().distinct().collect(Collectors.toList());
			// 根据赛事id 查询赛事支付记录获取用户ids
			if (collect.size() == 0) {
			if (collect.isEmpty()) {
			return new ArrayList<>();
			} else {
			List<Integer> userIds = paymentCompetitionService.list(new QueryWrapper<PaymentCompetition>()
			.in("competitionId", collect)).stream()
			.in("competitionId", collect)
			.eq("payStatus",2)).stream()
			.map(PaymentCompetition::getAppUserId).collect(Collectors.toList());
			return userIds;
			}
			@@ -133,6 +133,20 @@
			List<Integer> operatorId = cttService.list(new QueryWrapper<Competition>()
			.eq("operatorId", operatorId1)).stream().map(Competition::getId).collect(Collectors.toList());
			query.setUserIds(operatorId);
			} else if (query.getStoreId() != null) {
			List<Competition> list = cttService.list(new QueryWrapper<Competition>());
			List<Integer> integers = new ArrayList<>();
			for (Competition competition : list) {
			for (String s : competition.getStoreId().split(",")) {
			if (s.equals(""+query.getStoreId())){
			integers.add(competition.getId());
			}
			}
			}
			if (integers.isEmpty()){
			integers.add(-1);
			}
			query.setUserIds(integers);
			}
			List<PaymentCompetition> paymentCompetitions = paymentCompetitionService.listAll(query);
			List<PaymentCompetition> result = new ArrayList<>();
			@@ -435,18 +449,46 @@
			String transaction_id = map.get("transaction_id");
			String result = map.get("result");

			PaymentCompetition paymentCompetition = paymentCompetitionService.getOne(new QueryWrapper<PaymentCompetition>().eq("code", code)
			.eq("payType", 1));
			PaymentCompetition paymentCompetition = paymentCompetitionService.getOne(new QueryWrapper<PaymentCompetition>().eq("code", code).eq("payType", 1));
			if (paymentCompetition.getPayStatus() == 1) {
			paymentCompetition.setAppUserId(null);
			paymentCompetition.setPayStatus(2);
			paymentCompetition.setPayTime(new Date());
			paymentCompetition.setPayOrderNo(transaction_id);
			paymentCompetitionService.updateById(paymentCompetition);

			Competition competition = cttService.getById(paymentCompetition.getCompetitionId());
			competition.setApplicantsNumber(competition.getApplicantsNumber() + 1);
			cttService.updateById(competition);
			if (competition.getOperatorId()!=null && competition.getOperatorId()!=0){
			// 休眠两分钟后再调用分账接口避免提示订单正在处理中
			Thread.sleep(120000);
			// 根据运营商id获取对应运营商分账比例返回格式: 微信分账比例,支付宝分账比例
			String proportionByOperatorId = storeClient.getProportionByOperatorId(competition.getOperatorId());
			String[] split = proportionByOperatorId.split(",");
			String s1 = split[0];
			if (!s1.equals("未设置")){
			BigDecimal bigDecimal = new BigDecimal(s1);
			// 分账比例
			BigDecimal bigDecimal1 = bigDecimal.divide(new BigDecimal(100)).setScale(2);
			// 微信商户号
			String s2 = storeClient.getmerchantNumberByOperatorId(competition.getOperatorId());
			String nonce_str = UUIDUtil.getRandomCode(16);
			paymentCompetition.setFenzhangOrderNo(nonce_str);
			BigDecimal bigDecimal2 = new BigDecimal(paymentCompetition.getAmount());
			ResultUtil fenzhang = payMoneyUtil.fenzhang(transaction_id, bigDecimal2.multiply(bigDecimal1), s2,nonce_str,"报名赛事分账");
			if (!fenzhang.getCode().equals(200)){
			System.err.println("分账失败原因是:"+fenzhang.getData()+"-"+fenzhang.getMsg());
			}else{
			paymentCompetition.setFenzhangNo(fenzhang.getData().toString());
			paymentCompetition.setFenzhangAmount(bigDecimal2.multiply(bigDecimal1));
			paymentCompetitionService.updateById(paymentCompetition);
			}
			}
			}
			}


			PrintWriter out = response.getWriter();
			out.write(result);
			out.flush();
			@@ -569,8 +611,9 @@
			String code = map.get("out_refund_no");
			String refund_id = map.get("refund_id");
			String result = map.get("result");
			PaymentCompetition paymentCompetition = paymentCompetitionService.getOne(new QueryWrapper<PaymentCompetition>().eq("code", code).eq("payType", 1));
			if (paymentCompetition.getPayStatus() == 1) {
			PaymentCompetition paymentCompetition = paymentCompetitionService.getOne(new QueryWrapper<PaymentCompetition>()
			.eq("code", code).eq("payType", 1));
			if (paymentCompetition.getPayStatus() == 2) {
			paymentCompetition.setPayStatus(3);
			paymentCompetition.setRefundTime(new Date());
			paymentCompetition.setRefundOrderNo(refund_id);
			@@ -580,11 +623,12 @@
			Competition competition = cttService.getById(paymentCompetition.getCompetitionId());
			competition.setApplicantsNumber(competition.getApplicantsNumber() - 1);
			cttService.updateById(competition);

			PrintWriter out = response.getWriter();
			out.write(result);
			out.flush();
			out.close();
			}
			PrintWriter out = response.getWriter();
			out.write(result);
			out.flush();
			out.close();
			}
			} catch (Exception e) {
			e.printStackTrace();
			@@ -786,7 +830,31 @@

			String payOrderNo = paymentCompetition.getPayOrderNo();
			if (paymentCompetition.getPayType() == 1) {//微信支付
			Map<String, String> map = payMoneyUtil.wxRefund(payOrderNo, code, amount.toString(), amount.toString(), "/base/competition/weChatCancelPaymentCompetitionCallback");
			if (StringUtils.hasLength(paymentCompetition.getFenzhangNo())){
			// 是分账订单如果分账金额不为0 那么回退分账金额
			if (paymentCompetition.getFenzhangAmount()!=null && paymentCompetition.getFenzhangAmount().compareTo(BigDecimal.ZERO)>0){
			String randomCode = UUIDUtil.getRandomCode(16);
			String randomCode1 = UUIDUtil.getRandomCode(16);
			if (competition.getOperatorId()!=null && competition.getOperatorId()!=0){
			// 微信商户号
			String s2 =storeClient.getmerchantNumberByOperatorId(competition.getOperatorId());
			ResultUtil resultUtil = payMoneyUtil.fenzhangRefund(paymentCompetition.getFenzhangNo(), paymentCompetition.getFenzhangAmount(), s2, randomCode, randomCode1);
			if (!resultUtil.getCode().equals(200)){
			System.err.println("分账回退失败原因是:"+resultUtil.getMsg());
			}else{
			paymentCompetition.setFenzhangRefundNo(resultUtil.getData().toString());
			paymentCompetitionService.updateById(paymentCompetition);
			}

			}
			}
			}




			Map<String, String> map = payMoneyUtil.wxRefund(payOrderNo, code, amount.toString(), amount.toString(),
			"/base/competition/weChatCancelPaymentCompetitionCallback");
			String return_code = map.get("return_code");
			if (!"SUCCESS".equals(return_code)) {
			// return ResultUtil.error(map.get("return_msg"));
			@@ -794,6 +862,7 @@
			}
			String refund_id = map.get("refund_id");
			paymentCompetition.setRefundOrderNo(refund_id);
			paymentCompetition.setAppUserId(null);
			paymentCompetitionService.updateById(paymentCompetition);
			storeClient.addBackRecord(paymentCompetition.getAmount() + "_" + paymentCompetition.getAppUserId());