java/PlayPai.git

			@@ -3,6 +3,7 @@

			import cn.hutool.core.date.DateUtil;
			import cn.hutool.poi.excel.ExcelUtil;
			import com.alibaba.fastjson.JSONObject;
			import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
			import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
			import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
			@@ -25,23 +26,26 @@
			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 com.dsh.competition.util.wx.WxV3PayConfig;
			import com.wechat.pay.contrib.apache.httpclient.util.AesUtil;
			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;
			import javax.servlet.http.HttpServletRequest;
			import javax.servlet.http.HttpServletResponse;
			import java.io.BufferedReader;
			import java.io.OutputStream;
			import java.io.PrintWriter;
			import java.math.BigDecimal;
			import java.nio.charset.StandardCharsets;
			import java.text.DateFormat;
			import java.text.SimpleDateFormat;
			import java.util.*;
			@@ -110,11 +114,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 +138,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<>();
			@@ -419,6 +438,61 @@
			}


			/**
			* 报名赛事微信支付回调
			*
			* @param request
			* @param response
			*/
			@ResponseBody
			@PostMapping("/base/competition/weChatPaymentCompetitionCallback1")
			public void weChatPaymentCompetitionCallback1(HttpServletRequest request, HttpServletResponse response) {
			try {
			System.err.println("微信回调");
			System.err.println("请求" + request);
			BufferedReader reader = request.getReader();
			String string1 = reader.toString();
			System.err.println("请求reader" + string1);
			StringBuilder requestBody = new StringBuilder();
			String line;
			while ((line = reader.readLine()) != null) {
			requestBody.append(line);
			}
			System.err.println("全部请求体" + requestBody);
			JSONObject jsonObject = JSONObject.parseObject(requestBody.toString());
			JSONObject resource = jsonObject.getJSONObject("resource");

			AesUtil aesUtil = new AesUtil(WxV3PayConfig.apiV3Key.getBytes(StandardCharsets.UTF_8));
			String decryptedData = aesUtil.decryptToString(resource.getString("associated_data").getBytes(StandardCharsets.UTF_8), resource.getString("nonce").getBytes(StandardCharsets.UTF_8),
			resource.getString("ciphertext"));
			System.err.println("微信解密的字符串信息" + decryptedData);
			JSONObject jsonInfo = (JSONObject) JSONObject.parse(decryptedData);
			String code = jsonInfo.getString("out_trade_no");
			String transaction_id = jsonInfo.getString("transaction_id");
			String trade_state = jsonInfo.getString("trade_state");
			if (trade_state.equals("SUCCESS")) {
			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);
			}


			PrintWriter out = response.getWriter();
			out.write("SUCCESS");
			out.flush();
			out.close();
			}
			} catch (Exception e) {
			e.printStackTrace();
			}
			}
			/**
			* 报名赛事微信支付回调
			*
			@@ -789,6 +863,29 @@

			String payOrderNo = paymentCompetition.getPayOrderNo();
			if (paymentCompetition.getPayType() == 1) {//微信支付
			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");