package com.ruoyi.system.utils; import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSONObject; import com.icbc.api.DefaultIcbcClient; import com.icbc.api.IcbcApiException; import com.icbc.api.request.CardbusinessAggregatepayB2cOnlineConsumepurchaseRequestV1; import com.icbc.api.response.CardbusinessAggregatepayB2cOnlineConsumepurchaseResponseV1; import com.ruoyi.common.exception.ServiceException; import com.ruoyi.common.utils.DateUtils; import com.ruoyi.common.utils.WebUtils; import com.ruoyi.common.utils.ip.IpUtils; import com.ruoyi.system.config.ICBCConfig; import com.ruoyi.system.enums.ICBCRespOrderErrorEnum; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.math.BigDecimal; @Slf4j @Component public class ICBCPayUtil { @Autowired private ICBCConfig icbcConfig; public JSONObject wechatPay(String outTradeNo, BigDecimal totalPrice, String goodsName,String openid, String notifyUrl, String merId, String merPrtclNo){ CardbusinessAggregatepayB2cOnlineConsumepurchaseRequestV1.CardbusinessAggregatepayB2cOnlineConsumepurchaseRequestV1Biz bizContent = new CardbusinessAggregatepayB2cOnlineConsumepurchaseRequestV1.CardbusinessAggregatepayB2cOnlineConsumepurchaseRequestV1Biz(); bizContent.setMer_id(StringUtils.isBlank(merId) ? icbcConfig.getMerId() : merId); bizContent.setMer_prtcl_no(StringUtils.isBlank(merPrtclNo) ? icbcConfig.getMerPrtclNo() : merPrtclNo); bizContent.setDecive_info(icbcConfig.getDeciveInfo()); bizContent.setOut_trade_no(outTradeNo); bizContent.setOrig_date_time(DateUtils.getCurrentDateTimeWithT()); //交易币种,目前工行只支持使用人民币(001)支付 bizContent.setFee_type("001"); bizContent.setSpbill_create_ip(IpUtils.getIpAddr(WebUtils.request())); //金额,单位分 bizContent.setTotal_fee(String.valueOf(totalPrice.multiply(new BigDecimal(100)).intValue())); //支付成功后回调url bizContent.setMer_url(notifyUrl); bizContent.setBody(goodsName); //收单接入方式,5-APP,7-微信公众号,8-支付宝生活号,9-微信小程序 bizContent.setAccess_type("9"); //支付方式,9-微信;10-支付宝; bizContent.setPay_mode("9"); //商户在微信开放平台注册的APPID,支付方式为微信时不能为空 bizContent.setShop_appid(icbcConfig.getWxAppId()); //第三方用户标识,商户在微信公众号内或微信小程序内接入时必送,即access_type为7或9时,上送用户在商户APPID下的唯一标识;商户通过支付宝生活号接入时不送 bizContent.setOpen_id(openid); bizContent.setIcbc_appid(icbcConfig.getAppId()); bizContent.setExpire_time(icbcConfig.getExpireTime()); //通知类型,表示在交易处理完成后把交易结果通知商户的处理模式。取值“HS”:在交易完成后将通知信息,主动发送给商户,发送地址为notify_url指定地址; 取值“AG”:在交易完成后不通知商户。不送或送空,默认为"HS" bizContent.setNotify_type("HS"); //结果发送类型,通知方式为HS时有效。取值“0”:无论支付成功或者失败,银行都向商户发送交易通知信息;取值“1”,银行只向商户发送交易成功的通知信息。默认是"0" bizContent.setResult_type("0"); CardbusinessAggregatepayB2cOnlineConsumepurchaseRequestV1 request = new CardbusinessAggregatepayB2cOnlineConsumepurchaseRequestV1(); request.setServiceUrl(icbcConfig.getApiPayUrl()); request.setBizContent(bizContent); DefaultIcbcClient client = ICBCConfig.getInstance(icbcConfig); CardbusinessAggregatepayB2cOnlineConsumepurchaseResponseV1 response; JSONObject responsePackage = new JSONObject(); try { log.info("准备调用工行支付成功,请求参数:{}", JSON.toJSONString(request)); response = client.execute(request); if (response.isSuccess()) { log.info("调用工行支付成功,返回信息:{}", JSON.toJSONString(response)); responsePackage = JSONObject.parseObject(response.getWx_data_package()); } else { log.info("调用工行支付失败,返回信息:{}", JSON.toJSONString(response)); throw new ServiceException(ICBCRespOrderErrorEnum.fromCode(String.valueOf(response.getReturnCode())).getErrorMsg()); } } catch (IcbcApiException e) { log.error(e.toString(), e); } return responsePackage; } }