package com.stylefeng.guns.modular.cloudPayment.example;
|
|
import com.stylefeng.guns.modular.cloudPayment.req.BalanceAcctFreezeReq;
|
import com.stylefeng.guns.modular.cloudPayment.req.BalanceAcctReq;
|
import com.unionpay.upyzt.Upyzt;
|
import com.unionpay.upyzt.exception.UpyztException;
|
import com.unionpay.upyzt.model.BalanceAcct;
|
import com.unionpay.upyzt.model.BalanceAcctFreeze;
|
import com.unionpay.upyzt.model.BalanceTransaction;
|
import com.unionpay.upyzt.resp.*;
|
import com.unionpay.upyzt.util.StringUtils;
|
import lombok.extern.slf4j.Slf4j;
|
|
import java.io.Serializable;
|
import java.time.OffsetDateTime;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Slf4j
|
public class BalanceAcctExample implements Serializable {
|
|
/**
|
* 新增电子账簿
|
*
|
* @return 返回参数
|
* @throws UpyztException 异常
|
*/
|
public static BalanceAcctStoreResp create(BalanceAcctReq balanceAcctReq) throws UpyztException {
|
Map<String, Object> params = new HashMap<>();
|
params.put("out_request_no", balanceAcctReq.getOutRequestNo());
|
if (!StringUtils.isBlank(balanceAcctReq.getCusId())) {
|
params.put("cus_id", balanceAcctReq.getCusId());
|
}
|
if (!StringUtils.isBlank(balanceAcctReq.getMchId())) {
|
params.put("mch_id", balanceAcctReq.getMchId());
|
}
|
params.put("password", Upyzt.encryptField(balanceAcctReq.getPassword()));
|
params.put("remark", balanceAcctReq.getRemark());
|
|
return BalanceAcct.create(params);
|
}
|
|
/**
|
* 电子账簿查询(电子账簿ID)
|
*
|
* @param balanceAcctId 绑定账户编号
|
* @return 返回参数
|
* @throws UpyztException 异常
|
*/
|
public static BalanceAcctResp retrieveById(String balanceAcctId) throws UpyztException {
|
return BalanceAcct.retrieveById(balanceAcctId);
|
}
|
|
|
/**
|
* 电子账簿查询(用户ID或二级商户ID)
|
*
|
* @return 返回参数
|
* @throws UpyztException 异常
|
*/
|
public static BalanceAcctListResp retrieveByUserId(BalanceAcctReq balanceAcctReq) throws UpyztException {
|
Map<String, Object> params = new HashMap<>();
|
if (!StringUtils.isBlank(balanceAcctReq.getCusId())) {
|
params.put("cus_id", balanceAcctReq.getCusId());
|
}
|
if (!StringUtils.isBlank(balanceAcctReq.getMchId())) {
|
params.put("mch_id", balanceAcctReq.getMchId());
|
}
|
return BalanceAcct.retrieveByUserId(params);
|
}
|
|
|
/**
|
* 冻结/解冻电子账簿
|
*
|
* @param balanceAcctFreezeReq 电子账簿ID
|
* @return 返回参数
|
* @throws UpyztException 异常
|
*/
|
public static BalanceAcctFreezeResp freeze(BalanceAcctFreezeReq balanceAcctFreezeReq) throws UpyztException {
|
Map<String, Object> params = new HashMap<>();
|
params.put("out_request_no", balanceAcctFreezeReq.getOutRequestNo());
|
params.put("balance_acct_id", balanceAcctFreezeReq.getBalanceAcctId());
|
params.put("freeze", balanceAcctFreezeReq.getFreeze());
|
if(!StringUtils.isBlank(balanceAcctFreezeReq.getRemark())){
|
params.put("remark", balanceAcctFreezeReq.getRemark());
|
}
|
|
return BalanceAcctFreeze.create(params);
|
}
|
|
/**
|
* 冻结/解冻结果查询(系统订单号)
|
*
|
* @param balanceAcctFreezeId 系统订单号
|
* @return 返回参数
|
* @throws UpyztException 异常
|
*/
|
public static BalanceAcctFreezeResp retrieveFreezeById(String balanceAcctFreezeId) throws UpyztException {
|
return BalanceAcctFreeze.retrieveById(balanceAcctFreezeId);
|
}
|
|
|
/**
|
* 冻结/解冻结果查询(平台订单号)
|
*
|
* @param outRequestNo 平台订单号
|
* @return 返回参数
|
* @throws UpyztException 异常
|
*/
|
public static BalanceAcctFreezeResp retrieveFreezeByOutRequestNo(String outRequestNo) throws UpyztException {
|
return BalanceAcctFreeze.retrieveByOutRequestNo(outRequestNo);
|
}
|
|
|
/**
|
* 注销电子账簿
|
*
|
* @param balanceAcctId 电子账簿ID
|
* @return 返回参数
|
* @throws UpyztException 异常
|
*/
|
public static BalanceAcctDeleteResp removeById(String balanceAcctId) throws UpyztException {
|
return BalanceAcct.removeById(balanceAcctId);
|
}
|
|
|
|
/**
|
* 电子账簿流水查询
|
*
|
* @param balanceAcctId 电子账簿ID
|
* @return 返回参数
|
* @throws UpyztException 异常
|
*/
|
public static BalanceTxnPaginationResp page(String balanceAcctId) throws UpyztException {
|
Map<String, Object> params = new HashMap<>();
|
params.put("balance_acct_id", balanceAcctId);
|
params.put("start_at", OffsetDateTime.now().toString());
|
return BalanceTransaction.page(params);
|
}
|
|
}
|