package com.java110.acct.cmd.payment; import com.alibaba.fastjson.JSONObject; import com.java110.acct.payment.IPaymentBusiness; import com.java110.core.annotation.Java110Cmd; import com.java110.core.context.CmdContextUtils; import com.java110.core.context.ICmdDataFlowContext; import com.java110.core.event.cmd.Cmd; import com.java110.core.event.cmd.CmdEvent; import com.java110.core.factory.CommunitySettingFactory; import com.java110.core.factory.GenerateCodeFactory; import com.java110.core.factory.WechatFactory; import com.java110.core.log.LoggerFactory; import com.java110.dto.payment.*; import com.java110.dto.wechat.SmallWeChatDto; import com.java110.intf.acct.IPaymentKeyV1InnerServiceSMO; import com.java110.intf.acct.IPaymentPoolConfigV1InnerServiceSMO; import com.java110.intf.acct.IPaymentPoolV1InnerServiceSMO; import com.java110.intf.acct.IPaymentPoolValueV1InnerServiceSMO; import com.java110.intf.fee.IPayFeeV1InnerServiceSMO; import com.java110.utils.cache.CommonCache; import com.java110.utils.cache.MappingCache; import com.java110.utils.cache.UrlCache; import com.java110.utils.constant.MappingConstant; import com.java110.utils.constant.WechatConstant; import com.java110.utils.exception.CmdException; import com.java110.utils.factory.ApplicationContextFactory; import com.java110.utils.util.Assert; import com.java110.utils.util.DateUtil; import com.java110.utils.util.PayUtil; import com.java110.vo.ResultVo; import org.slf4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.http.*; import org.springframework.web.client.RestTemplate; import java.text.ParseException; import java.util.List; import java.util.Map; import java.util.stream.Collectors; /** * native qrcode 支付 * add by wuxw 2023-06-25 */ @Java110Cmd(serviceCode = "payment.nativeQrcodePayment") public class NativeQrcodePaymentCmd extends Cmd { private static final Logger logger = LoggerFactory.getLogger(NativeQrcodePaymentCmd.class); protected static final String DEFAULT_PAYMENT_ADAPT = "wechatNativeQrcodePaymentFactory";// 默认微信通用支付 @Autowired private IPaymentKeyV1InnerServiceSMO paymentKeyV1InnerServiceSMOImpl; @Autowired private IPaymentPoolValueV1InnerServiceSMO paymentPoolValueV1InnerServiceSMOImpl; @Autowired private IPaymentPoolConfigV1InnerServiceSMO paymentPoolConfigV1InnerServiceSMOImpl; @Autowired private IPaymentPoolV1InnerServiceSMO paymentPoolV1InnerServiceSMOImpl; @Autowired private IPayFeeV1InnerServiceSMO payFeeV1InnerServiceSMOImpl; @Override public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException { Assert.hasKeyAndValue(reqJson, "business", "未包含业务"); Assert.hasKeyAndValue(reqJson, "communityId", "未包含小区"); } private static final String VERSION = "1.0"; @Value("${fuiou.pay.unified-order-url}") public String PAY_UNIFIED_ORDER_URL; @Autowired private RestTemplate outRestTemplate; @Override public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException { // if (!(reqJson.containsKey("communityId"))){ // reqJson.put("communityId","2025062600070012"); // } PaymentPoolDto paymentPoolDto = new PaymentPoolDto(); paymentPoolDto.setCommunityId(reqJson.getString("communityId")); paymentPoolDto.setPage(1); paymentPoolDto.setRow(10); List paymentPoolDtos = paymentPoolV1InnerServiceSMOImpl.queryPaymentPools(paymentPoolDto); List collect = paymentPoolDtos.stream().filter(e -> e.getPaymentType().equals("FUIOU")).collect(Collectors.toList()); PaymentPoolValueDto paymentPoolValueDto = new PaymentPoolValueDto(); paymentPoolValueDto.setPpId(collect.get(0).getPpId()); paymentPoolValueDto.setCommunityId(reqJson.getString("communityId")); List values = paymentPoolValueV1InnerServiceSMOImpl.queryPaymentPoolValues(paymentPoolValueDto); Map> payMap = values.stream().collect(Collectors.groupingBy(PaymentPoolValueDto::getColumnKey)); SmallWeChatDto smallWeChatDto = new SmallWeChatDto(); if(payMap.containsKey("FUIOU_APP_ID")){ smallWeChatDto.setAppId(payMap.get("FUIOU_APP_ID").get(0).getColumnValue()); }else{ smallWeChatDto.setAppId(MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, "appId")); } if(payMap.containsKey("FUIOU_MCHNT_KEY")){ smallWeChatDto.setAppSecret(payMap.get("FUIOU_MCHNT_KEY").get(0).getColumnValue()); }else{ smallWeChatDto.setAppSecret(MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, "appSecret")); } if(payMap.containsKey("FUIOU_ORDER_PRE")){ smallWeChatDto.setOrderPre(payMap.get("FUIOU_ORDER_PRE").get(0).getColumnValue()); } if(payMap.containsKey("FUIOU_MERCHANT_ID")){ smallWeChatDto.setMchId(payMap.get("FUIOU_MERCHANT_ID").get(0).getColumnValue()); }else{ smallWeChatDto.setMchId(MappingCache.getValue(MappingConstant.WECHAT_STORE_DOMAIN, "mchId")); } logger.debug(">>>>>>>>>>>>>>>>支付参数报文,{}", reqJson.toJSONString()); String appId = context.getReqHeaders().get("app-id"); String userId = context.getReqHeaders().get("user-id"); reqJson.put("createUserId", userId); reqJson.put("storeId", CmdContextUtils.getStoreId(context)); //1.0 查询当前支付的业务 IPaymentBusiness paymentBusiness = ApplicationContextFactory.getBean(reqJson.getString("business"), IPaymentBusiness.class); if (paymentBusiness == null) { throw new CmdException("当前支付业务不支持"); } //2.0 相应业务 下单 返回 单号 ，金额， PaymentOrderDto paymentOrderDto = paymentBusiness.unified(context, reqJson); paymentOrderDto.setAppId(appId); paymentOrderDto.setUserId(userId); reqJson.put("money", paymentOrderDto.getMoney()); String token = GenerateCodeFactory.getUUID(); // redis 中 保存 请求参数 CommonCache.setValue("nativeQrcodePayment_" + token, reqJson.toJSONString(), CommonCache.PAY_DEFAULT_EXPIRE_TIME); JSONObject result = new JSONObject(); // // // List paymentKeyDtos = null; // // PaymentKeyDto paymentKeyDto = new PaymentKeyDto(); // paymentKeyDto.setPaymentType("FUIOU"); // paymentKeyDtos = paymentKeyV1InnerServiceSMOImpl.queryPaymentKeys(paymentKeyDto); // String systemName = MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, WechatConstant.PAY_GOOD_NAME); JSONObject paramMap = new JSONObject(); paramMap.put("version", VERSION); paramMap.put("mchnt_cd", smallWeChatDto.getMchId()); // 富友分配给二级商户的商户号 paramMap.put("random_str", PayUtil.makeUUID(32)); paramMap.put("order_amt", (int)(paymentOrderDto.getMoney()*100)); String generatorId = GenerateCodeFactory.getGeneratorId("81"); paramMap.put("mchnt_order_no", smallWeChatDto.getOrderPre() + generatorId); paramMap.put("txn_begin_ts", DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_DEFAULT)); paramMap.put("goods_des", systemName + "测试"); paramMap.put("term_id", "abcdefgh"); paramMap.put("term_ip", PayUtil.getLocalIp()); paramMap.put("notify_url", "?wId=" + WechatFactory.getWId(smallWeChatDto.getAppId())); paramMap.put("trade_type", "WXBXLET"); paramMap.put("order_type", "WECHAT"); // paramMap.put("sub_openid", openid); // paramMap.put("sub_appid", smallWeChatDto.getAppId()); paramMap.put("sign", createSign(paramMap, smallWeChatDto.getAppSecret())); logger.debug("调用支付统一下单接口" + paramMap.toJSONString()); HttpHeaders headers = new HttpHeaders(); headers.add("Content-Type", "application/json"); HttpEntity httpEntity = new HttpEntity(paramMap.toJSONString(), headers); ResponseEntity responseEntity = outRestTemplate.exchange(PAY_UNIFIED_ORDER_URL , HttpMethod.POST, httpEntity, String.class); if(JSONObject.parseObject(responseEntity.getBody()).get("result_msg").equals("SUCCESS")){ result.put("codeUrl", JSONObject.parseObject(responseEntity.getBody()).get("qr_code")); ResponseEntity responseEntity2 = ResultVo.createResponseEntity(result); logger.debug("调用支付厂家返回,{}", responseEntity2); context.setResponseEntity(responseEntity2); }else{ result.put("codeUrl", JSONObject.parseObject(responseEntity.getBody()).get("qr_code")); ResponseEntity responseEntity2 = ResultVo.createResponseEntity(responseEntity); logger.debug("调用支付厂家返回,{}", responseEntity); context.setResponseEntity(responseEntity2); } } private String createSign(JSONObject paramMap, String payPassword) { String str = paramMap.getString("mchnt_cd") + "|" + paramMap.getString("order_type") + "|" + paramMap.getString("order_amt") + "|" + paramMap.getString("mchnt_order_no") + "|" + paramMap.getString("txn_begin_ts") + "|" + paramMap.getString("goods_des") + "|" + paramMap.getString("term_id") + "|" + paramMap.getString("term_ip") + "|" + paramMap.getString("notify_url") + "|" + paramMap.getString("random_str") + "|" + paramMap.getString("version") + "|" + payPassword; return PayUtil.md5(str); } }