BM自动发卡售卡系统全新

package com.bomaos.reception.controller; import cn.hutool.crypto.SecureUtil; import com.alibaba.fastjson.JSON; import com.alipay.easysdk.factory.Factory; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.bomaos.carmi.entity.Cards; import com.bomaos.carmi.service.CardsService; import com.bomaos.common.core.pays.epusdt.entity.EpusdtNotify; import com.bomaos.common.core.pays.epusdt.sendPay; import com.bomaos.common.core.pays.mqpay.mqPay; import com.bomaos.common.core.pays.payjs.SignUtil; import com.bomaos.common.core.pays.paypal.PaypalSend; import com.bomaos.common.core.pays.xunhupay.PayUtils; import com.bomaos.common.core.pays.epay.EpayUtil; import com.bomaos.common.core.utils.DateUtil; import com.bomaos.common.core.utils.FormCheckUtil; import com.bomaos.common.core.utils.RequestParamsUtil; import com.bomaos.common.core.utils.StringUtil; import com.bomaos.common.core.web.JsonResult; import com.bomaos.common.system.service.EmailService; import com.bomaos.orders.entity.Orders; import com.bomaos.orders.service.OrdersService; import com.bomaos.products.entity.Products; import com.bomaos.products.service.ProductsService; import com.bomaos.reception.dto.NotifyDTO; import com.bomaos.reception.entity.XunhuNotIfy; import com.bomaos.reception.util.SynchronizedByKeyService; import com.bomaos.settings.entity.Pays; import com.bomaos.settings.entity.ShopSettings; import com.bomaos.settings.service.PaysService; import com.bomaos.settings.service.ShopSettingsService; import com.bomaos.website.entity.Website; import com.bomaos.website.service.WebsiteService; import com.github.wxpay.sdk.WXPayUtil; import com.google.common.collect.Maps; import com.paypal.api.payments.Payment; import com.paypal.api.payments.Transaction; import com.paypal.base.rest.PayPalRESTException; import com.zjiecode.wxpusher.client.WxPusher; import com.zjiecode.wxpusher.client.bean.Message; import lombok.SneakyThrows; import org.apache.commons.codec.Charsets; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.StringUtils; import org.springframework.web.bind.annotation.*; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.*; import java.math.BigDecimal; import java.math.BigInteger; import java.math.RoundingMode; import java.net.URLEncoder; import java.nio.charset.StandardCharsets; import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import java.text.DecimalFormat; import java.text.SimpleDateFormat; import java.util.*; import java.util.concurrent.atomic.AtomicReference; @Controller @Transactional public class NotifyController { @Autowired private PaysService paysService; @Autowired private OrdersService ordersService; @Autowired private ProductsService productsService; @Autowired private CardsService cardsService; @Autowired private EmailService emailService; @Autowired private WebsiteService websiteService; @Autowired private ShopSettingsService shopSettingsService; @Autowired private SynchronizedByKeyService synchronizedByKeyService; /** * 返回成功xml */ private final String WxpayresXml = "<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>"; private final String WxpayH5resXml = "<xml><return_code><![CDATA[SUCCESS]]></return_code><return_msg><![CDATA[OK]]></return_msg></xml>"; private final String resFailXml = "<xml><return_code><![CDATA[FAIL]]></return_code><return_msg><![CDATA[报文为空]]></return_msg></xml>"; @RequestMapping("/mqpay/notifyUrl") @ResponseBody public String notifyUrl(HttpServletRequest request) { Map<String, String> params = RequestParamsUtil.getParameterMap(request); String param = params.get("param"); String price = params.get("price"); String money = params.get("reallyPrice"); String sign = params.get("sign"); String payId = params.get("payId"); String type = params.get("type"); String key = null; Orders orders = ordersService.getOne(new QueryWrapper<Orders>().eq("member", payId)); if (Integer.parseInt(type) == 1) { // wxpay Pays wxPays = paysService.getOne(new QueryWrapper<Pays>().eq("driver", "mqpay_wxpay")); /** * 防止破解 */ if (!orders.getPayType().equals(wxPays.getDriver())) { return "不要搞我啦！！"; } Map mapTypes = JSON.parseObject(wxPays.getConfig()); key = mapTypes.get("key").toString(); } else if (Integer.parseInt(type) == 2) { // alipay Pays aliPays = paysService.getOne(new QueryWrapper<Pays>().eq("driver", "mqpay_alipay")); /** * 防止破解 */ if (!orders.getPayType().equals(aliPays.getDriver())) { return "不要搞我啦！！"; } Map mapTypes = JSON.parseObject(aliPays.getConfig()); key = mapTypes.get("key").toString(); } String mysign = mqPay.md5(payId + param + type + price + money + key); if (mysign.equals(sign)) { String date = new SimpleDateFormat("yyyyMMdd").format(new Date()); String seconds = new SimpleDateFormat("HHmmss").format(new Date()); String number = StringUtil.getRandomNumber(6); String payNo = date + seconds + number; AtomicReference<String> notifyText = new AtomicReference<>(); synchronizedByKeyService.exec(payId, () -> { String returnBig1 = returnBig(money, price, payId, payNo, param, "success", "fiald"); notifyText.set(returnBig1); }); return notifyText.get(); } else { return "fiald"; } } @RequestMapping("/mqpay/returnUrl") public void returnUrl(HttpServletRequest request, HttpServletResponse response) throws IOException { /** *验证通知 处理自己的业务 */ Map<String, String> params = RequestParamsUtil.getParameterMap(request); String param = params.get("param"); String price = params.get("price"); String reallyPrice = params.get("reallyPrice"); String sign = params.get("sign"); String payId = params.get("payId"); String type = params.get("type"); String key = null; if (Integer.parseInt(type) == 1) { // wxpay Pays wxPays = paysService.getOne(new QueryWrapper<Pays>().eq("driver", "mqpay_wxpay")); Map mapTypes = JSON.parseObject(wxPays.getConfig()); key = mapTypes.get("key").toString(); } else if (Integer.parseInt(type) == 2) { // alipay Pays aliPays = paysService.getOne(new QueryWrapper<Pays>().eq("driver", "mqpay_alipay")); Map mapTypes = JSON.parseObject(aliPays.getConfig()); key = mapTypes.get("key").toString(); } String mysign = mqPay.md5(payId + param + type + price + reallyPrice + key); if (mysign.equals(sign)) { String url = "/pay/state/" + payId; response.sendRedirect(url); } } @RequestMapping("/epay/notifyUrl") @ResponseBody public String zlianpNotify(HttpServletRequest request) { Map<String, String> parameterMap = RequestParamsUtil.getParameterMap(request); String pid = parameterMap.get("pid"); String type = parameterMap.get("type"); String