autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-04-20 02:55:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

查询支付确认对象列表

Browse Source
This commit is contained in:
autumn.g@foxmail.com
2023-08-21 08:52:32 +08:00
parent c0deb56964
commit 3035fdb08f
5 changed files with 172 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
jsowell-pile/src/main/java/com/jsowell/adapay/dto/QueryAcctFlowDTO.java Normal file
View File

@@ -0,0 +1,41 @@
package com.jsowell.adapay.dto;
import lombok.Data;
@Data
public class QueryAcctFlowDTO {
/**
* 控制台 主页面应用的app_id
*/
private String wechatAppId;
/**
* 用户对象的member_id，若查询商户本身时，传入值0
*/
private String adapayMemberId;
/**
* 账户类型，01-基本户，02-手续费账户，03-临时过渡户，若查询主体为用户，则只支持查询基本户
*/
private String acctType;
/**
* 当前页码，取值范围1~10000，默认值为1
*/
private Integer pageNo;
/**
* 页面容量，取值范围1~100，默认值为10
*/
private Integer pageSize;
/**
* 查询起始日期，格式为 yyyyMMdd
*/
private String beginDate;
/**
* 查询结束日期，格式为 yyyyMMdd，日期间隔必须小于等于7天
*/
private String endDate;
}

16
jsowell-pile/src/main/java/com/jsowell/adapay/dto/QueryPaymentConfirmDTO.java Normal file
View File

@@ -0,0 +1,16 @@
package com.jsowell.adapay.dto;
import lombok.Data;
@Data
public class QueryPaymentConfirmDTO {
/**
* 控制台 主页面应用的app_id
*/
private String wechatAppId;
/**
* Adapay生成的支付对象id
*/
private String paymentId;
}

32
jsowell-pile/src/main/java/com/jsowell/adapay/response/QueryPaymentConfirmDetailResponse.java Normal file
View File

@@ -0,0 +1,32 @@
package com.jsowell.adapay.response;
import com.alibaba.fastjson2.annotation.JSONField;
import lombok.Data;
@Data
public class QueryPaymentConfirmDetailResponse {
@JSONField(name = "payment_id")
private String paymentId;
@JSONField(name = "prod_mode")
private String prodMode;
@JSONField(name = "payment_confirms")
private String paymentConfirms;
@JSONField(name = "has_more")
private Boolean hasMore;
@JSONField(name = "app_id")
private String appId;
@JSONField(name = "object")
private String object;
@JSONField(name = "status")
private String status;
static class PaymentConfirm {
}
}

47
jsowell-pile/src/main/java/com/jsowell/adapay/service/AdapayService.java
View File

@@ -11,9 +11,7 @@ import com.huifu.adapay.model.*;
import com.jsowell.adapay.common.CreateAdaPaymentParam;
import com.jsowell.adapay.common.DivMember;
import com.jsowell.adapay.config.AbstractAdapayConfig;
import com.jsowell.adapay.dto.SettleAccountDTO;
import com.jsowell.adapay.dto.UpdateAccountConfigDTO;
import com.jsowell.adapay.dto.WithdrawDTO;
import com.jsowell.adapay.dto.*;
import com.jsowell.adapay.factory.AdapayConfigFactory;
import com.jsowell.adapay.response.*;
import com.jsowell.adapay.vo.AdapayAccountBalanceVO;
@@ -868,4 +866,47 @@ public class AdapayService {
List<PaymentReverseResponse> payment_reverses = jsonObject.getList("payment_reverses", PaymentReverseResponse.class);
return payment_reverses;
}
/**
* 查询支付确认对象列表
*/
public void queryPaymentConfirmList(QueryPaymentConfirmDTO dto) {
AbstractAdapayConfig config = AdapayConfigFactory.getConfig(dto.getWechatAppId());
if (config == null) {
throw new BusinessException(ReturnCodeEnum.CODE_ADAPAY_CONFIG_IS_NULL_ERROR);
}
Map<String, Object> param = Maps.newHashMap();
param.put("payment_id", dto.getPaymentId());
param.put("app_id", config.getAdapayAppId());
try {
Map<String, Object> map = PaymentConfirm.queryList(param, config.getWechatAppId());
QueryPaymentConfirmDetailResponse queryPaymentConfirmDetailResponse = JSON.parseObject(JSON.toJSONString(map), QueryPaymentConfirmDetailResponse.class);
log.info("queryPaymentConfirmDetailResponse:{}", JSON.toJSONString(queryPaymentConfirmDetailResponse));
} catch (BaseAdaPayException e) {
log.error("查询支付确认对象列表error", e);
}
}
/**
* 查询账务流水
*/
public void queryAcctFlowList(QueryAcctFlowDTO dto) throws BaseAdaPayException {
AbstractAdapayConfig config = AdapayConfigFactory.getConfig(dto.getWechatAppId());
if (config == null) {
throw new BusinessException(ReturnCodeEnum.CODE_ADAPAY_CONFIG_IS_NULL_ERROR);
}
Map<String, Object> acctFlowParams = Maps.newHashMap();
acctFlowParams.put("adapay_func_code", "acct.flow.list");
acctFlowParams.put("app_id", config.getAdapayAppId());
acctFlowParams.put("member_id", dto.getAdapayMemberId());
acctFlowParams.put("acct_type", dto.getAcctType());
acctFlowParams.put("page_index", dto.getPageNo());
acctFlowParams.put("page_size", dto.getPageSize());
acctFlowParams.put("begin_date", dto.getBeginDate());
acctFlowParams.put("end_date", dto.getEndDate());
Map<String, Object> acctFlowList = AdapayCommon.queryAdapay(acctFlowParams, config.getWechatAppId());
log.info("查询账务流水param:{}, result:{}", JSON.toJSONString(dto), JSON.toJSONString(acctFlowList));
}
}