autumn/jsowell-charger-web
1
0
Fork 0
mirror of https://codeup.aliyun.com/67c68d4e484ca2f0a13ac3c1/ydc/jsowell-charger-web.git synced 2026-04-21 19:45:09 +08:00
Code Issues Packages Projects Releases Wiki Activity
Files
ff9f4faecb8631c32074cec77c341165d9d58114
jsowell-charger-web/jsowell-admin/src/test/java/SpringBootTestController.java

2835 lines
127 KiB
Java
Raw Normal View History

提供给lianlian获取token
2023-05-26 19:25:35 +08:00
import cn.hutool.json.JSONUtil;
update 联联
2023-05-27 11:55:45 +08:00
import com.alibaba.fastjson2.JSON;
update 计算退款金额
2023-09-14 17:36:45 +08:00
import com.alibaba.fastjson2.JSONArray;
commit
2023-03-04 16:29:55 +08:00
import com.alibaba.fastjson2.JSONObject;
import com.fasterxml.jackson.core.JsonProcessingException;
保存汇付支付退款回调记录
2023-05-31 16:05:18 +08:00
import com.fasterxml.jackson.databind.DeserializationFeature;
加日志
2023-05-30 16:33:49 +08:00
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.PropertyNamingStrategies;
commit
2023-03-04 16:29:55 +08:00
import com.google.common.collect.ImmutableMap;
update 高德
2023-06-26 17:10:36 +08:00
import com.google.common.collect.Lists;
汇付支付 执行退款
2023-05-27 16:01:27 +08:00
import com.google.common.collect.Maps;
update
2023-07-17 16:44:04 +08:00
import com.google.common.collect.Sets;
update 0x31报文回复不足位数补零
2023-06-12 17:38:16 +08:00
import com.google.common.primitives.Bytes;
update 汇付会员逻辑修改
2023-06-15 14:06:33 +08:00
import com.huifu.adapay.core.exception.BaseAdaPayException;
update 实时分账
2023-08-25 16:07:15 +08:00
import com.huifu.adapay.model.Payment;
update
2023-10-08 16:42:56 +08:00
import com.huifu.adapay.model.PaymentReverse;
汇付支付 执行退款
2023-05-27 16:01:27 +08:00
import com.huifu.adapay.model.Refund;
commit
2023-03-04 16:29:55 +08:00
import com.jsowell.JsowellApplication;
update 支付 占桩订单 后面拼上时间戳
2023-11-03 16:07:28 +08:00
import com.jsowell.adapay.common.AdaPayment;
多商户配置
2023-08-15 11:02:02 +08:00
import com.jsowell.adapay.config.AbstractAdapayConfig;
查询支付确认对象列表
2023-08-21 08:52:32 +08:00
import com.jsowell.adapay.dto.QueryAcctFlowDTO;
查询支付确认对象列表
2023-08-21 16:19:33 +08:00
import com.jsowell.adapay.dto.QueryPaymentConfirmDTO;
手动变更银行卡信息
2023-08-21 15:37:00 +08:00
import com.jsowell.adapay.dto.SettleAccountDTO;
多商户配置
2023-08-15 11:02:02 +08:00
import com.jsowell.adapay.factory.AdapayConfigFactory;
优化余额支付订单
2023-09-28 16:48:24 +08:00
import com.jsowell.adapay.operation.PaymentReverseOperation;
update
2023-09-28 09:16:44 +08:00
import com.jsowell.adapay.response.PaymentConfirmResponse;
优化余额支付订单
2023-09-28 16:48:24 +08:00
import com.jsowell.adapay.response.PaymentReverseResponse;
查询支付确认对象列表
2023-08-21 16:19:33 +08:00
import com.jsowell.adapay.response.QueryPaymentConfirmDetailResponse;
优化余额支付订单
2023-09-28 16:48:24 +08:00
import com.jsowell.adapay.response.RefundResponse;
支付占桩订单
2023-08-18 09:52:12 +08:00
import com.jsowell.adapay.service.AdapayService;
汇付基础响应
2023-08-21 13:20:17 +08:00
import com.jsowell.adapay.vo.DrawCashDetailVO;
commit
2023-03-04 16:29:55 +08:00
import com.jsowell.common.constant.CacheConstants;
import com.jsowell.common.constant.Constants;
update 汇付支付 支付回调
2023-05-30 13:45:56 +08:00
import com.jsowell.common.core.domain.entity.SysDictData;
commit
2023-03-04 16:29:55 +08:00
import com.jsowell.common.core.domain.ykc.LoginRequestData;
import com.jsowell.common.core.domain.ykc.TransactionRecordsData;
import com.jsowell.common.core.redis.RedisCache;
新增 订单流程测试方法
2023-08-30 10:13:56 +08:00
import com.jsowell.common.enums.AcquirerEnum;
update 保存提现信息
2023-08-01 16:16:34 +08:00
import com.jsowell.common.enums.DelFlagEnum;
update 卡启动、vin启动逻辑修改
2023-07-08 11:33:45 +08:00
import com.jsowell.common.enums.ykc.*;
commit
2023-03-04 16:29:55 +08:00
import com.jsowell.common.exception.BusinessException;
add 联联平台相关工具类
2023-05-10 08:49:01 +08:00
import com.jsowell.common.util.*;
update
2023-07-08 09:58:20 +08:00
import com.jsowell.common.util.Cp56Time2a.Cp56Time2aUtil;
update 联联
2023-05-30 14:22:34 +08:00
import com.jsowell.common.util.http.HttpUtils;
update
2023-07-08 09:58:20 +08:00
import com.jsowell.common.util.id.IdUtils;
commit
2023-03-04 16:29:55 +08:00
import com.jsowell.common.util.id.SnowflakeIdWorker;
import com.jsowell.common.util.ip.AddressUtils;
import com.jsowell.netty.handler.HeartbeatRequestHandler;
update
2023-07-08 09:58:20 +08:00
import com.jsowell.netty.handler.TransactionRecordsRequestHandler;
commit
2023-03-04 16:29:55 +08:00
import com.jsowell.netty.service.yunkuaichong.YKCBusinessService;
提供给lianlian获取token
2023-05-26 19:25:35 +08:00
import com.jsowell.pile.domain.*;
update 高德
2023-06-26 17:10:36 +08:00
import com.jsowell.pile.domain.ykcCommond.IssueQRCodeCommand;
import com.jsowell.pile.domain.ykcCommond.ProofreadTimeCommand;
add 联联平台相关工具类
2023-05-10 08:49:01 +08:00
import com.jsowell.pile.dto.*;
update 高德
2023-06-26 17:10:36 +08:00
import com.jsowell.pile.dto.amap.GetStationInfoDTO;
新增 路通云停平台 给车辆绑定优惠券接口
2023-08-24 10:33:26 +08:00
import com.jsowell.pile.dto.lutongyunting.BindCouponDTO;
commit
2023-03-04 16:29:55 +08:00
import com.jsowell.pile.mapper.MemberBasicInfoMapper;
import com.jsowell.pile.mapper.PileBillingTemplateMapper;
提供给lianlian获取token
2023-05-26 19:25:35 +08:00
import com.jsowell.pile.service.*;
改名
2023-12-07 11:01:45 +08:00
import com.jsowell.pile.service.programlogic.AbstractProgramLogic;
import com.jsowell.pile.service.programlogic.ProgramLogicFactory;
交易分账 重构
2023-08-29 16:03:43 +08:00
import com.jsowell.pile.transaction.dto.OrderTransactionDTO;
import com.jsowell.pile.transaction.service.TransactionService;
import com.jsowell.pile.util.SnUtils;
update 会员钱包
2023-11-21 14:57:58 +08:00
import com.jsowell.pile.vo.base.MemberWalletVO;
update
2023-06-26 14:40:03 +08:00
import com.jsowell.pile.vo.base.PileInfoVO;
update 卡启动、vin启动逻辑修改
2023-07-08 11:33:45 +08:00
import com.jsowell.pile.vo.uniapp.MemberVO;
新增 订单流程测试方法
2023-08-30 10:13:56 +08:00
import com.jsowell.pile.vo.uniapp.PileConnectorDetailVO;
计算余额扣除金额
2023-08-11 11:04:28 +08:00
import com.jsowell.pile.vo.web.BalanceDeductionAmountVO;
单元测试
2023-03-07 16:55:03 +08:00
import com.jsowell.pile.vo.web.BillingTemplateVO;
import com.jsowell.pile.vo.web.OrderListVO;
import com.jsowell.pile.vo.web.PileDetailVO;
commit
2023-03-04 16:29:55 +08:00
import com.jsowell.service.MemberService;
import com.jsowell.service.OrderService;
import com.jsowell.service.PileService;
update 校验支付单
2023-10-24 13:14:33 +08:00
import com.jsowell.service.TempService;
update 高德地图
2023-06-17 10:37:02 +08:00
import com.jsowell.thirdparty.amap.service.AMapService;
update 联联接口
2023-05-27 15:56:26 +08:00
import com.jsowell.thirdparty.lianlian.dto.CommonParamsDTO;
update lianlian
2023-05-26 16:14:45 +08:00
import com.jsowell.thirdparty.lianlian.service.LianLianService;
提供给lianlian获取token
2023-05-26 19:25:35 +08:00
import com.jsowell.thirdparty.lianlian.util.Cryptos;
import com.jsowell.thirdparty.lianlian.util.Encodes;
import com.jsowell.thirdparty.lianlian.util.GBSignUtils;
新增 路通云停系统获取令牌接口
2023-08-23 14:13:11 +08:00
import com.jsowell.thirdparty.lutongyunting.service.LTYTService;
commit
2023-03-04 16:29:55 +08:00
import com.jsowell.wxpay.common.WeChatPayParameter;
import com.jsowell.wxpay.dto.AppletTemplateMessageSendDTO;
import com.jsowell.wxpay.response.WechatPayRefundRequest;
import com.jsowell.wxpay.service.WxAppletRemoteService;
import org.apache.commons.collections4.CollectionUtils;
新增 微信第三方平台 获取令牌接口
2023-07-28 14:47:26 +08:00
import org.apache.commons.lang3.RandomStringUtils;
commit
2023-03-04 16:29:55 +08:00
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.util.StopWatch;
提供给lianlian获取token
2023-05-26 19:25:35 +08:00
import java.io.UnsupportedEncodingException;
commit
2023-03-04 16:29:55 +08:00
import java.math.BigDecimal;
update
2023-06-08 11:50:06 +08:00
import java.nio.charset.StandardCharsets;
commit
2023-03-04 16:29:55 +08:00
import java.text.ParseException;
import java.text.SimpleDateFormat;
add 联联平台相关工具类
2023-05-10 08:49:01 +08:00
import java.util.*;
update
2023-12-01 13:29:35 +08:00
import java.util.stream.Collectors;
commit
2023-03-04 16:29:55 +08:00
@ActiveProfiles("dev")
@SpringBootTest(classes = JsowellApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
@RunWith(SpringRunner.class)
public class SpringBootTestController {
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
private static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
commit
2023-03-04 16:29:55 +08:00
update
2023-10-31 15:17:39 +08:00
String wechatAppId1 = "wxbb3e0d474569481d"; // 万车充
String wechatAppId2 = "wx20abc5210391649c"; // 嘉佳充电
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private SnUtils snUtils;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private PileService pileService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private YKCPushCommandService ykcPushCommandService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
汇付会员表加备注字段
2023-11-29 11:55:33 +08:00
private AdapayMemberAccountService adapayMemberAccountService;
update
2023-07-13 15:27:09 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private IPileMsgRecordService pileMsgRecordService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private IPileStationInfoService pileStationInfoService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private YKCPushCommandService ykcPushBusinessService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private HeartbeatRequestHandler heartbeatRequestHandler;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private YKCBusinessService ykcBusinessService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private PileBillingTemplateMapper pileBillingTemplateMapper;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private PileRemoteService pileRemoteService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private MemberService memberService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private OrderService orderService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private IPileBillingTemplateService pileBillingTemplateService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private MemberBasicInfoMapper memberBasicInfoMapper;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private SimCardService simCardService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private IPileBasicInfoService pileBasicInfoService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private WechatPayService wechatPayService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private IOrderBasicInfoService orderBasicInfoService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private WxpayCallbackRecordService wxpayCallbackRecordService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private WxAppletRemoteService wxAppletRemoteService;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private RedisCache redisCache;
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
update
2023-12-01 13:29:35 +08:00
private PileAuthCardService pileAuthCardService;
update
2023-04-01 15:33:36 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private LianLianService lianLianService;
add 联联平台相关工具类
2023-05-10 08:49:01 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private IMemberPlateNumberRelationService memberPlateNumberRelationService;
update 0x31报文回复不足位数补零
2023-06-12 17:38:16 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
static final String MAC_KEY = "53TtFpc4gdVZbF3x";
add 联联平台相关工具类
2023-05-10 08:49:01 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
static final String ALGORITHM_MAC = "HmacMD5";
add 联联平台相关工具类
2023-05-10 08:49:01 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private AdapayCallbackRecordService adapayCallbackRecordService;
update 汇付支付回调
2023-05-27 11:20:43 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private IAdapayRefundRecordService adapayRefundRecordService;
保存汇付支付退款回调记录
2023-05-31 16:05:18 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private AdapayService adapayService;
update 汇付会员逻辑修改
2023-06-15 14:06:33 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private AMapService aMapService;
update 高德地图
2023-06-17 10:37:02 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private IPileConnectorInfoService pileConnectorInfoService;
update
2023-07-08 15:37:53 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private TransactionRecordsRequestHandler transactionRecordsRequestHandler;
update
2023-07-08 09:58:20 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private IMemberBasicInfoService memberBasicInfoService;
update 卡启动、vin启动逻辑修改
2023-07-08 11:33:45 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private ClearingWithdrawInfoService clearingWithdrawInfoService;
update 保存提现信息
2023-08-01 16:16:34 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private OrderPileOccupyService orderPileOccupyService;
update 生成占桩订单
2023-08-08 08:43:50 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Autowired
private LTYTService ltytService;
@Autowired
private IPileMerchantInfoService pileMerchantInfoService;
@Autowired
private MemberAdapayRecordService memberAdapayRecordService;
@Autowired
private TransactionService transactionService;
@Autowired
private OrderPayRecordService orderPayRecordService;
update 校验支付单
2023-10-24 13:14:33 +08:00
@Autowired
private TempService tempService;
update 会员钱包
2023-11-21 14:57:58 +08:00
@Autowired
private MemberWalletInfoService memberWalletInfoService;
@Test
public void selectByMemberWalletListTest() {
String memberId = "12345678";
List<MemberWalletVO> memberWalletVOS = memberWalletInfoService.selectByMemberWalletList(memberId);
System.out.println(JSON.toJSONString(memberWalletVOS));
}
update 支付 占桩订单 后面拼上时间戳
2023-11-03 16:07:28 +08:00
@Test
public void queryPaymentByOrderNoTest() {
String orderNo = "C44903356969";
update校验未支付订单
2023-11-03 16:43:33 +08:00
String wechatAppId = "wxbb3e0d474569481d";
update 支付 占桩订单 后面拼上时间戳
2023-11-03 16:07:28 +08:00
try {
update校验未支付订单
2023-11-03 16:43:33 +08:00
List<AdaPayment> adaPayments = adapayService.queryPaymentByOrderNo(orderNo, wechatAppId);
update 支付 占桩订单 后面拼上时间戳
2023-11-03 16:07:28 +08:00
System.out.println(JSON.toJSONString(adaPayments));
} catch (BaseAdaPayException e) {
throw new RuntimeException(e);
}
}
update 校验支付单
2023-10-24 13:14:33 +08:00
@Test
public void checkPaymentTest() {
QueryOrderDTO dto = new QueryOrderDTO();
update
2023-10-26 16:54:50 +08:00
String startTime = "2023-09-01 00:00:00";
String endTime = "2023-09-30 23:59:59";
update 校验支付单
2023-10-24 14:49:49 +08:00
dto.setStartTime(startTime);
dto.setEndTime(endTime);
update 校验支付单
2023-10-24 13:14:33 +08:00
try {
tempService.checkPayment(dto);
} catch (BaseAdaPayException e) {
throw new RuntimeException(e);
}
}
update
2023-10-13 14:57:28 +08:00
@Test
public void toStringTest() {
String jsonString = "{\"business\":\"00\",\"communicationVersion\":\"v1.5\",\"connectorNum\":\"01\",\"iccid\":\"89860620180085681816\",\"internetConnection\":\"00\",\"pileSn\":\"88230000000259\",\"pileType\":\"01\",\"programVersion\":\"gyk-V29\\u0000\"}";
LoginRequestData loginRequestData = JSONObject.parseObject(jsonString, LoginRequestData.class);
System.out.println(loginRequestData.toString());
}
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
/**
* 单元测试，测试订单流程
*/
@Test
public void testTheOrderProcess() throws Exception {
// 生成订单
// OrderBasicInfo orderBasicInfo = generateAnOrder();
// System.out.println(orderBasicInfo);
// // 支付订单
// int a = payOrder(orderBasicInfo);
// System.out.println(a);
// 结算订单
OrderBasicInfo orderBasicInfo = orderBasicInfoService.getOrderInfoByOrderCode("C46006767636");
settleOrder(orderBasicInfo);
// 订单退款
BigDecimal payAmount = orderBasicInfo.getPayAmount();
BigDecimal settleAmount = orderBasicInfo.getSettleAmount();
BigDecimal refundAmt = payAmount.subtract(settleAmount);
// 延时分账的，可以部分解冻
memberAdapayRecordService.updateRefundAmountFromFreezeAmount("1234", refundAmt);
// 实时分账，全部解冻
// memberAdapayRecordService.unfreezeAmountAndUpdateSpendAmount("test01", payAmount, refundAmt);
}
// 生成订单
private OrderBasicInfo generateAnOrder() throws ParseException {
GenerateOrderDTO dto = new GenerateOrderDTO();
PileConnectorDetailVO vo = new PileConnectorDetailVO();
vo.setStationId("2");
dto.setPileConnector(vo);
dto.setMemberId("1");
dto.setStartMode("1");
dto.setPayMode("4");
dto.setPileSn("88000000000001");
dto.setConnectorCode("01");
dto.setChargeAmount(new BigDecimal("10"));
// 查询充电桩的计费模板
BillingTemplateVO billingTemplateVO = pileBillingTemplateService.selectBillingTemplateDetailByPileSn(dto.getPileSn());
dto.setBillingTemplate(billingTemplateVO);
OrderBasicInfo orderBasicInfo = orderBasicInfoService.saveOrder2Database(dto);
return orderBasicInfo;
}
// 支付订单
private int payOrder(OrderBasicInfo orderBasicInfo) throws Exception {
// PayOrderDTO dto = new PayOrderDTO();
// dto.setMemberId(orderBasicInfo.getMemberId());
// dto.setOrderCode(orderBasicInfo.getOrderCode());
// dto.setStartMode(orderBasicInfo.getStartMode());
// dto.setPayMode(orderBasicInfo.getPayMode());
// dto.setPayAmount(orderBasicInfo.getPayAmount());
//
// Map<String, Object> map = orderBasicInfoService.payOrder(dto);
// return map;
String paymentId = "1234";
BigDecimal amount = orderBasicInfo.getPayAmount();
String orderCode = orderBasicInfo.getOrderCode();
JSONObject json = new JSONObject();
json.put("paymentId", paymentId);
json.put("amount", amount);
// 记录订单支付流水
OrderPayRecord orderPayRecord = OrderPayRecord.builder()
.orderCode(orderCode)
.payMode(OrderPayRecordEnum.WECHATPAY_PAYMENT.getValue())
.payAmount(amount)
.acquirer(AcquirerEnum.ADAPAY.getValue())
.deductionRecord(json.toJSONString())
.createBy(null)
订单支付记录 给默认值
2023-08-31 10:30:05 +08:00
.delFlag(DelFlagEnum.NORMAL.getValue())
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
.build();
orderPayRecordService.batchInsert(Lists.newArrayList(orderPayRecord));
// 更新冻结金额 支付成功后全部冻结
memberAdapayRecordService.updateFreezeAmount(paymentId, amount);
// 支付订单成功
PayOrderSuccessCallbackDTO callbackDTO = PayOrderSuccessCallbackDTO.builder()
.orderCode(orderCode)
.payAmount(amount)
.payMode(OrderPayModeEnum.PAYMENT_OF_WECHATPAY.getValue())
.acquirer(AcquirerEnum.ADAPAY.getValue())
.build();
// 订单支付成功 支付回调
// orderBasicInfoService.payOrderSuccessCallback(callbackDTO);
OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByOrderCode(callbackDTO.getOrderCode());
// 修改订单
orderInfo.setPayMode(callbackDTO.getPayMode());
orderInfo.setPayStatus(Constants.ONE);
orderInfo.setPayAmount(callbackDTO.getPayAmount());
orderInfo.setPayTime(new Date());
orderInfo.setChargeStartTime(new Date());
orderInfo.setOrderStatus(OrderStatusEnum.IN_THE_CHARGING.getValue());
return orderBasicInfoService.updateOrderBasicInfo(orderInfo);
}
// 结算订单
private void settleOrder(OrderBasicInfo orderBasicInfo) {
TransactionRecordsData data = TransactionRecordsData.builder()
.transactionCode(orderBasicInfo.getTransactionCode())
.pileSn(orderBasicInfo.getPileSn())
.connectorCode(orderBasicInfo.getConnectorCode())
.startTime("2023-03-10 17:10:24")
.endTime("2023-03-10 17:10:46")
.sharpPrice("1.10000")
.sharpUsedElectricity("2.0000")
.sharpAmount("2.2000")
.peakPrice("1.20000")
.peakUsedElectricity("0")
.peakAmount("0")
.flatPrice("1.30000")
.flatUsedElectricity("0")
.flatAmount("0")
.valleyPrice("1.40000")
.valleyUsedElectricity("0")
.valleyAmount("0")
.totalElectricity("2")
.consumptionAmount("5.3000")
.vinCode("\\u0000\\u0000\\u0000\\u0000\\u0000\\u0000\\u0000\\u0000\\u0000\\u0000\\u0000\\u0000\\u0000\\u0000\\u0000\\u0000\\u0000")
.transactionIdentifier("01")
.transactionTime("2023-03-10 17:10:46")
.stopReasonMsg("结束充电，APP远程停止")
.logicCard("0")
.createTime(new Date())
.build();
// orderBasicInfoService.settleOrder(data, orderBasicInfo);
// 获取更新数据后的orderBasicInfo对象
orderBasicInfoService.returnUpdateOrderBasicInfo(orderBasicInfo, data);
// 获取更新数据后的orderDetail对象/更新订单详情 查询订单详情 修改订单数据
OrderDetail orderDetail = orderBasicInfoService.returnUpdateOrderDetail(orderBasicInfo, data);
// 更新数据库
OrderTransactionDTO dto = new OrderTransactionDTO();
dto.setOrderBasicInfo(orderBasicInfo);
dto.setOrderDetail(orderDetail);
transactionService.doUpdateOrder(dto);
}
update 计算退款金额
2023-09-14 17:36:45 +08:00
public static List<BigDecimal> calculateRefund(BigDecimal totalAmount, List<BigDecimal> payments) {
List<BigDecimal> refundList = new ArrayList<>();
BigDecimal remainingAmount = totalAmount;
for (BigDecimal payment : payments) {
if (remainingAmount.compareTo(BigDecimal.ZERO) <= 0) {
// refundList.add(BigDecimal.ZERO);
refundList.add(payment);
} else {
BigDecimal refundPerPayment = remainingAmount.min(payment);
// refundList.add(refundPerPayment);
refundList.add(payment.subtract(refundPerPayment));
remainingAmount = remainingAmount.subtract(refundPerPayment);
}
}
return refundList;
}
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
update 计算退款金额
2023-09-14 17:36:45 +08:00
public static void main(String[] args) {
BigDecimal totalAmount = new BigDecimal("0.1");
List<BigDecimal> payments = Lists.newArrayList(new BigDecimal("0.97"), new BigDecimal("1.00"));
List<BigDecimal> refunds = calculateRefund(totalAmount, payments);
System.out.println("每笔单需要退还的金额: " + refunds);
}
/**
* 测试多笔支付情况，解冻部分金额
*/
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Test
public void calculateUnfreezeAmountTest() {
update 计算退款金额
2023-09-14 17:36:45 +08:00
BigDecimal orderAmount = new BigDecimal("0.06");
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
List<OrderPayRecord> payRecordList = Lists.newArrayList();
// 第一笔支付记录
JSONObject jsonObject = new JSONObject();
update 计算解冻金额逻辑
2023-08-31 18:35:16 +08:00
jsonObject.put("paymentId", "002212023083114213410543206907226374144");
update 计算退款金额
2023-09-14 17:36:45 +08:00
jsonObject.put("amount", "0.97");
JSONObject jsonObject2 = new JSONObject();
jsonObject2.put("paymentId", "002212023083114213410543206907226374144");
jsonObject2.put("amount", "1");
JSONArray jsonArray = new JSONArray();
jsonArray.add(jsonObject);
jsonArray.add(jsonObject2);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
OrderPayRecord build = OrderPayRecord.builder()
update 计算退款金额
2023-09-14 17:36:45 +08:00
.payAmount(new BigDecimal("1.97"))
.deductionRecord(jsonArray.toJSONString())
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
.build();
payRecordList.add(build);
改名
2023-12-07 11:01:45 +08:00
AbstractProgramLogic orderLogic = ProgramLogicFactory.getProgramLogic("1");
update 计算退款金额
2023-09-14 17:36:45 +08:00
List<Map<String, Object>> maps = orderLogic.calculateUnfreezeAmount(orderAmount, payRecordList);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
System.out.println(maps);
}
@Test
public void unfreezeAmountAndUpdateSpendAmountTest() {
String paymentId = "123";
memberAdapayRecordService.updateRefundAmount(paymentId, new BigDecimal("5"));
// memberAdapayRecordService.updateRefundAmountFromFreezeAmount(paymentId, new BigDecimal("20"));
// BigDecimal unfreezeAmount = new BigDecimal("32");
// BigDecimal spendAmount = new BigDecimal("10");
// memberAdapayRecordService.unfreezeAmountAndUpdateSpendAmount(paymentId, unfreezeAmount, spendAmount);
// memberAdapayRecordService.updateRefundAmountFromFreezeAmount(paymentId, new BigDecimal("2"));
}
@Test
public void getFirstLevelMerchantByMerchantIdTest() {
String merchantId = "13";
PileMerchantInfo merchantInfo = pileMerchantInfoService.getFirstLevelMerchantByMerchantId(merchantId);
System.out.println(JSON.toJSONString(merchantInfo));
}
@Test
public void queryPaymentInfoTest() throws BaseAdaPayException {
String paymentId = "002212023082514501110541039779091623936";
// 在完成初始化设置情况下，调用查询方法，获取 Payment 查询结果
update
2023-10-31 15:17:39 +08:00
Map<String, Object> response = Payment.query(paymentId, wechatAppId1);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
System.out.println(response);
}
/**
* 手动变更银行卡信息
*/
@Test
public void createSettleAccountRequestTest() throws BaseAdaPayException {
SettleAccountDTO dto = new SettleAccountDTO();
update
2023-09-05 08:42:05 +08:00
dto.setCardId("31050180460000002469");
dto.setCardName("上海擎昆物业管理有限公司");
update 后管订单详情页面中 实时订单数据添加字段
2023-08-31 10:29:17 +08:00
dto.setTelNo("18021373333");
update
2023-09-05 08:42:05 +08:00
dto.setBankCode("01050000");
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
dto.setBankAcctType("1");
update
2023-09-05 08:42:05 +08:00
dto.setProvCode("0031");
dto.setAreaCode("3100");
String adapayMemberId = "ACM80899105";
update
2023-10-31 15:17:39 +08:00
adapayService.createSettleAccountRequest(dto, adapayMemberId, wechatAppId1);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
}
@Test
public void createDeleteSettleAccountRequestTest() throws BaseAdaPayException {
String adapayMemberId = "ACM69424215";
String settleAccountId = "0498291998695360";
update
2023-10-31 15:17:39 +08:00
adapayService.createDeleteSettleAccountRequest(adapayMemberId, settleAccountId, wechatAppId1);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
}
@Test
public void queryDrawcashDetailTest() throws BaseAdaPayException {
String orderNo = "drawcash_1692339516947";
update
2023-10-31 15:17:39 +08:00
DrawCashDetailVO drawCashDetailVO = adapayService.queryDrawCashDetail(orderNo, wechatAppId1);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
System.out.println(drawCashDetailVO);
}
@Test
public void queryPaymentConfirmListTest() {
QueryPaymentConfirmDTO dto = new QueryPaymentConfirmDTO();
update
2023-10-31 15:17:39 +08:00
dto.setWechatAppId(wechatAppId1);
update
2023-09-25 16:08:30 +08:00
// dto.setPaymentId("0022120230910032226990546664907296944128");
update 修改校验分账的方法
2023-10-11 17:01:23 +08:00
dto.setPaymentConfirmId("0022120231009032351990557174514064834560");
update
2023-09-25 16:08:30 +08:00
QueryPaymentConfirmDetailResponse.PaymentConfirmInfo paymentConfirmInfo = adapayService.queryPaymentConfirmDetail(dto);
System.out.println(JSON.toJSONString(paymentConfirmInfo));
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
}
@Test
public void queryAcctFlowListTest() {
QueryAcctFlowDTO dto = new QueryAcctFlowDTO();
try {
dto.setPageNo(1);
dto.setPageSize(100);
dto.setAcctType("01");
update
2023-10-31 15:17:39 +08:00
dto.setWechatAppId(wechatAppId1);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
dto.setAdapayMemberId("ACM69424215");
dto.setBeginDate("20230823");
dto.setEndDate("20230823");
adapayService.queryAcctFlowList(dto);
} catch (BaseAdaPayException e) {
throw new RuntimeException(e);
}
}
@Test
public void testCalculateTheBalanceDeductionAmount() {
String memberId = "123456";
BigDecimal amount = new BigDecimal("20");
List<BalanceDeductionAmountVO> resultList = Lists.newArrayList();
// 查询会员的余额充值记录 按照充值时间正序
List<MemberAdapayRecord> memberAdapayRecords = Lists.newArrayList();
memberAdapayRecords.add(MemberAdapayRecord.builder().paymentId("1").balanceAmt(new BigDecimal("50")).build());
memberAdapayRecords.add(MemberAdapayRecord.builder().paymentId("2").balanceAmt(new BigDecimal("60")).build());
memberAdapayRecords.add(MemberAdapayRecord.builder().paymentId("3").balanceAmt(new BigDecimal("10")).build());
// 定义一个临时金额等于消费金额
BigDecimal tempAmount = new BigDecimal(amount.toString());
for (MemberAdapayRecord memberAdapayRecord : memberAdapayRecords) {
// 该笔支付剩余金额 取出一笔判断是否剩余金额够支付订单消费吗
BigDecimal balanceAmt = memberAdapayRecord.getBalanceAmt();
// 该笔支付扣除金额
BigDecimal deductionAmount;
// 获取延时分账模式 延时分账的使用撤销方法退款，实时分账的使用退款方法
// AdapayCallbackRecord callbackRecord = adapayCallbackRecordService.selectByPaymentId(memberAdapayRecord.getPaymentId());
// String payMode = null;
// if (callbackRecord != null) {
// JSONObject expendJsonObject = JSON.parseObject(callbackRecord.getExpend());
// payMode = expendJsonObject.getString("payMode");
// }
// 消费金额 - 剩余金额
tempAmount = tempAmount.subtract(balanceAmt);
if (tempAmount.compareTo(BigDecimal.ZERO) >= 0) {
// 计算以后，大于等于0，说明这笔支付剩余金额需要扣完
deductionAmount = balanceAmt;
BalanceDeductionAmountVO build = BalanceDeductionAmountVO.builder()
.memberId(memberId)
.paymentId(memberAdapayRecord.getPaymentId())
.deductionAmount(deductionAmount)
.build();
resultList.add(build);
} else {
// 如果小于0，则说明剩余的钱用不完，扣除金额等于消费金额，并结束循环
deductionAmount = balanceAmt.add(tempAmount);
BalanceDeductionAmountVO build = BalanceDeductionAmountVO.builder()
.memberId(memberId)
.paymentId(memberAdapayRecord.getPaymentId())
.deductionAmount(deductionAmount)
.build();
resultList.add(build);
break;
}
}
System.out.println(JSON.toJSONString(resultList));
}
@Test
public void testGenerateOccupyPileOrder() {
String memberId = "67569684";
String pileSn = "88230000000135";
String connectorCode = "01";
GenerateOccupyOrderDTO dto = new GenerateOccupyOrderDTO();
dto.setMemberId(memberId);
dto.setPileSn(pileSn);
dto.setConnectorCode(connectorCode);
orderPileOccupyService.generateOccupyPileOrder(dto);
}
@Test
public void testStopOccupyPileOrder() {
String wechatAppId = "54135135";
AbstractAdapayConfig config = AdapayConfigFactory.getConfig(wechatAppId);
System.out.println(JSON.toJSONString(config));
update
2023-10-31 15:17:39 +08:00
AbstractAdapayConfig config2 = AdapayConfigFactory.getConfig(wechatAppId1);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
System.out.println(JSON.toJSONString(config2));
}
update 分账逻辑
2023-09-20 14:57:59 +08:00
/**
* 查询分账信息
* @throws BaseAdaPayException
*/
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
@Test
update
2023-09-11 16:43:26 +08:00
public void queryCreateConfirmReverse() throws BaseAdaPayException {
update 查询分账情况工具
2023-12-13 17:11:35 +08:00
List<String> paymentIdList = getPaymentIdList(); // 查询分账信息
update
2023-09-28 09:16:44 +08:00
// 用于verify的汇付会员id
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
// String verifyAdapayMemberId = "AM27665969";
update
2023-09-11 16:43:26 +08:00
update
2023-12-14 20:17:15 +08:00
List<String> unSplitList = Lists.newArrayList(); //
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
// List<QueryPaymentConfirmDetailResponse.PaymentConfirmInfo> successList= Lists.newArrayList();
update
2023-09-06 14:30:06 +08:00
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
BigDecimal total = BigDecimal.ZERO;
update
2023-12-14 20:17:15 +08:00
List<String> selfList = Lists.newArrayList();
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
Map<String, BigDecimal> map = Maps.newHashMap();
update 查询分账情况工具
2023-12-13 17:11:35 +08:00
for (String paymentId : paymentIdList) {
if (StringUtils.isBlank(paymentId)) {
continue;
}
update
2023-09-06 14:30:06 +08:00
// 查询支付确认id
QueryPaymentConfirmDTO dto = new QueryPaymentConfirmDTO();
update 查询分账情况工具
2023-12-13 17:11:35 +08:00
dto.setPaymentId(paymentId);
update
2023-10-31 15:17:39 +08:00
dto.setWechatAppId(wechatAppId1);
update
2023-09-06 14:30:06 +08:00
QueryPaymentConfirmDetailResponse response = adapayService.queryPaymentConfirmList(dto);
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
// System.out.println("response==" + JSON.toJSONString(response));
update
2023-09-06 14:30:06 +08:00
if (response != null) {
List<QueryPaymentConfirmDetailResponse.PaymentConfirmInfo> confirms = response.getPaymentConfirms();
update
2023-09-08 14:26:13 +08:00
if (CollectionUtils.isEmpty(confirms)) {
update
2023-12-14 20:17:15 +08:00
unSplitList.add(paymentId);
update
2023-09-27 11:25:01 +08:00
} else {
update
2023-09-28 09:16:44 +08:00
for (QueryPaymentConfirmDetailResponse.PaymentConfirmInfo confirm : confirms) {
JSONObject jsonObject = JSON.parseObject(confirm.getDescription());
String adapayMemberId = jsonObject.getString("adapayMemberId");
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
BigDecimal confirmedAmt = new BigDecimal(confirm.getConfirmedAmt());
total = total.add(confirmedAmt);
// 放map
map.merge(adapayMemberId, confirmedAmt, BigDecimal::add);
update
2023-12-14 20:17:15 +08:00
if (StringUtils.equals(adapayMemberId, "0")) {
selfList.add(paymentId);
}
update
2023-09-28 09:16:44 +08:00
}
update
2023-09-06 14:30:06 +08:00
}
}
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
}
update
2023-12-14 20:17:15 +08:00
System.out.println("=================未分账:" + JSON.toJSONString(unSplitList));
update 查询分账情况工具
2023-12-13 17:11:35 +08:00
System.out.println("=================已分账:" + JSON.toJSONString(map) + ", 总分账:" + total);
update
2023-12-14 20:17:15 +08:00
System.out.println("=================自己:" + JSON.toJSONString(selfList));
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
}
update
2023-10-27 16:37:04 +08:00
/**
* 测试分账
*/
update
2023-09-28 09:16:44 +08:00
@Test
public void test() {
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
String paymentId = "002212023102621451610563612286923030528";
update
2023-09-28 09:16:44 +08:00
AdapayMemberAccount adapayMemberAccount = new AdapayMemberAccount();
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
adapayMemberAccount.setAdapayMemberId("0");
BigDecimal deductionAmount = new BigDecimal("23.78");
String orderCode = "C23610900688";
update
2023-09-28 09:16:44 +08:00
// 延时分账，使用确认交易API
PaymentConfirmResponse paymentConfirmResponse = adapayService.createPaymentConfirmRequest(paymentId,
update
2023-10-31 15:17:39 +08:00
adapayMemberAccount, deductionAmount, orderCode, wechatAppId1);
update
2023-09-28 09:16:44 +08:00
System.out.println(JSON.toJSONString(paymentConfirmResponse));
}
update 查询分账情况工具
2023-12-13 17:11:35 +08:00
/**
* 批量执行分账
*/
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
@Test
public void batchCreatePaymentConfirm() {
JSONArray paymentList = getPaymentList();
update 查询分账情况工具
2023-12-13 17:11:35 +08:00
// TODO 获取默认结算账户，如需分给对应商户就填写正确的汇付会员id
update
2023-12-14 20:17:15 +08:00
// AdapayMemberAccount adapayMemberAccount = adapayMemberAccountService.getDefault();
AdapayMemberAccount adapayMemberAccount = new AdapayMemberAccount();
adapayMemberAccount.setAdapayMemberId("ACM69460507");
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
for (int i = 0; i < paymentList.size(); i++) {
JSONObject jsonObject = (JSONObject) paymentList.get(i);
update 查询分账情况工具
2023-12-13 17:11:35 +08:00
BigDecimal confirmAmt = jsonObject.getBigDecimal("settleAmount"); // 确认金额就是结算金额
String paymentId = jsonObject.getString("paymentId"); // 支付id
String orderCode = jsonObject.getString("orderCode"); // 订单编号
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
// 延时分账，使用确认交易API
PaymentConfirmResponse paymentConfirmResponse = adapayService.createPaymentConfirmRequest(paymentId,
update 查询分账情况工具
2023-12-13 17:11:35 +08:00
adapayMemberAccount, confirmAmt, orderCode, wechatAppId1);
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
}
}
// 需要重新分账的订单信息（针对未分账的订单）
public JSONArray getPaymentList() {
String jsonArrayString = "[" +
update
2023-12-14 20:17:15 +08:00
"{\"orderCode\":\"C42071068210\", \"settleAmount\":\"1.85\", \"paymentId\":\"002212023102519093110563210700862242816\"}" +
"{\"orderCode\":\"C48910624476\", \"settleAmount\":\"64.39\", \"paymentId\":\"002212023102523125710563271965594312704\"}" +
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
"]";
return JSONArray.parseArray(jsonArrayString);
}
update
2023-10-08 16:42:56 +08:00
/**
* 延迟分账未确认调撤销调撤销接口退款
*/
优化余额支付订单
2023-09-28 16:48:24 +08:00
@Test
public void createPaymentReverseRequestTest() {
update
2023-10-08 16:42:56 +08:00
String paymentId = "002212023082409392010540599165461884928";
BigDecimal refundAmount = new BigDecimal("0.09");
String memberId = null;
优化余额支付订单
2023-09-28 16:48:24 +08:00
// 延迟分账未确认调撤销调撤销接口退款
PaymentReverseOperation operation = new PaymentReverseOperation();
operation.setPaymentId(paymentId);
operation.setReverseAmt(refundAmount);
update
2023-10-31 15:17:39 +08:00
operation.setMerchantKey(wechatAppId2);
优化余额支付订单
2023-09-28 16:48:24 +08:00
operation.setMemberId(memberId);
operation.setScenarioType(ScenarioEnum.ORDER.getValue());
operation.setOrderCode(null);
PaymentReverseResponse response = adapayService.createPaymentReverseRequest(operation);
System.out.println(JSON.toJSONString(response));
}
update
2023-10-31 15:17:39 +08:00
/**
* 测试创建退款请求
*/
优化余额支付订单
2023-09-28 16:48:24 +08:00
@Test
public void createRefundRequestTest() {
update
2023-10-31 15:17:39 +08:00
String paymentId = "0022120231026150915990563512626531311616";
BigDecimal refundAmount = new BigDecimal("30.53");
String memberId = "65879222";
String orderCode = "C61028961274";
优化余额支付订单
2023-09-28 16:48:24 +08:00
// 调汇付的交易退款接口
RefundResponse response = adapayService.createRefundRequest(paymentId, refundAmount,
update
2023-10-31 15:17:39 +08:00
wechatAppId1, memberId, ScenarioEnum.ORDER.getValue(), orderCode);
优化余额支付订单
2023-09-28 16:48:24 +08:00
System.out.println(JSON.toJSONString(response));
}
update
2023-09-25 15:05:12 +08:00
/**
* 批量支付确认撤销
* @throws BaseAdaPayException
*/
update
2023-09-08 14:26:13 +08:00
@Test
update
2023-09-11 16:43:26 +08:00
public void testCreateConfirmReverse() throws BaseAdaPayException {
update 查询分账情况工具
2023-12-13 17:11:35 +08:00
List<String> list = getPaymentIdList(); // 批量支付确认撤销
update
2023-10-31 15:17:39 +08:00
for (String paymentId : list) {
update
2023-09-08 14:26:13 +08:00
// 查询支付确认id
QueryPaymentConfirmDTO dto = new QueryPaymentConfirmDTO();
update
2023-10-31 15:17:39 +08:00
dto.setPaymentId(paymentId);
dto.setWechatAppId(wechatAppId1);
update
2023-09-08 14:26:13 +08:00
QueryPaymentConfirmDetailResponse response = adapayService.queryPaymentConfirmList(dto);
if (response != null) {
List<QueryPaymentConfirmDetailResponse.PaymentConfirmInfo> confirms = response.getPaymentConfirms();
update
2023-10-31 15:17:39 +08:00
System.out.println("支付id:" + paymentId + ", 确认信息:" + JSON.toJSONString(confirms));
update 修改校验分账的方法
2023-10-11 17:01:23 +08:00
if (CollectionUtils.isNotEmpty(confirms)) {
for (QueryPaymentConfirmDetailResponse.PaymentConfirmInfo confirm : confirms) {
update
2023-10-31 15:17:39 +08:00
adapayService.createConfirmReverse(confirm.getId(), wechatAppId1);
update 修改校验分账的方法
2023-10-11 17:01:23 +08:00
}
}
update
2023-09-08 14:26:13 +08:00
}
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
}
update
2023-09-08 14:26:13 +08:00
}
update
2023-10-31 15:17:39 +08:00
/**
* 查询撤销列表
* @throws BaseAdaPayException
*/
@Test
public void queryPaymentReverseListTest() throws BaseAdaPayException {
JSONArray jsonList = getJsonList();
List<String> idList = Lists.newArrayList();
for (int i = 0; i < jsonList.size(); i++) {
JSONObject jsonObject = (JSONObject) jsonList.get(i);
// System.out.println(jsonObject.toJSONString());
BigDecimal refundAmount = jsonObject.getBigDecimal("refundAmount");
String paymentId = jsonObject.getString("paymentId");
update
2023-11-24 15:40:26 +08:00
adapayService.createPaymentReverseRequest(paymentId, refundAmount, wechatAppId1, "", ScenarioEnum.ORDER.getValue(), "");
update
2023-10-31 15:17:39 +08:00
}
System.out.println("需要撤销idList:" + idList);
}
public JSONArray getJsonList() {
update
2023-11-24 15:40:26 +08:00
String jsonArrayString = "[{\"refundAmount\":\"354.84\", \"paymentId\":\"002212023102509474610563069333816762368\"}]";
update
2023-10-31 15:17:39 +08:00
JSONArray jsonArray = JSONArray.parseArray(jsonArrayString);
return jsonArray;
}
update 查询分账情况工具
2023-12-13 17:11:35 +08:00
public List<String> getPaymentIdList() {
update
2023-09-08 14:26:13 +08:00
List<String> list = Lists.newArrayList();
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
update
2023-12-14 20:17:15 +08:00
list.add("002212023092801520310553165141723283456");
list.add("002212023092811091910553305382405005312");
list.add("002212023092811235310553309048023994368");
list.add("002212023092812445910553329459010056192");
list.add("002212023092814104110553351026408398848");
list.add("002212023092814445110553359623697707008");
list.add("002212023092814473010553360293270908928");
list.add("002212023092817164710553397861546725376");
list.add("002212023092817330110553401947190427648");
list.add("002212023092818283410553415923165016064");
list.add("002212023092820224510553444660131581952");
list.add("002212023092821415510553464584249442304");
list.add("002212023092823382610553493904175493120");
list.add("002212023092900012810553499701715918848");
list.add("002212023092901092010553516781936267264");
list.add("002212023092901093310553516837121515520");
list.add("002212023092901120910553517491280244736");
list.add("002212023092904211410553565074622676992");
list.add("002212023092907133610553608452456308736");
list.add("002212023092907203810553610223823536128");
list.add("002212023092907281110553612123309699072");
list.add("002212023092908112610553623007171964928");
list.add("002212023092908112910553623018447548416");
list.add("002212023092908591810553635053632581632");
list.add("002212023092909413610553645698847084544");
list.add("002212023092910073010553652216317702144");
list.add("002212023092910533510553663811638530048");
list.add("002212023092912153810553684462249361408");
list.add("002212023092912265610553687306045321216");
list.add("002212023092912345310553689307484774400");
list.add("002212023092912463510553692248350240768");
list.add("002212023092913335110553704143197470720");
list.add("002212023092913433710553706604303966208");
list.add("002212023092914023410553711371876511744");
list.add("002212023092914253210553717151736782848");
list.add("002212023092914382710553720403785633792");
list.add("002212023092915580110553740427089932288");
list.add("002212023092916420010553751493846720512");
list.add("002212023092917292010553763406462431232");
list.add("002212023092917332110553764416218722304");
list.add("002212023092918094510553773578282516480");
list.add("002212023092918310210553778935583420416");
list.add("002212023092918314310553779107688296448");
list.add("002212023092918582610553785829843173376");
list.add("002212023092919125310553789463490719744");
list.add("002212023092919283510553793418670354432");
list.add("002212023092919505710553799044960071680");
list.add("002212023092919572910553800688183795712");
list.add("002212023092920173710553805755954327552");
list.add("002212023092921155510553820426846257152");
list.add("002212023092922151010553835337755488256");
list.add("002212023092922315910553839571063193600");
list.add("002212023092923384610553856375818993664");
list.add("002212023093001524010553890076190474240");
list.add("002212023093006101210553954882689089536");
list.add("002212023093007163910553971609490153472");
list.add("002212023093007291310553974771647242240");
list.add("002212023093007462010553979078091649024");
list.add("002212023093008231410553988364764278784");
list.add("002212023093009164210554001819323047936");
list.add("002212023093010332210554021114364739584");
list.add("002212023093010365610554022009948524544");
list.add("002212023093010422710554023399512506368");
list.add("002212023093010470410554024561826775040");
list.add("002212023093010472710554024655182266368");
list.add("002212023093010512610554025660374036480");
list.add("002212023093010555810554026800528973824");
list.add("002212023093011010410554028083960832000");
list.add("002212023093011032310554028665843404800");
list.add("002212023093011082910554029949795356672");
list.add("002212023093011090210554030087632769024");
list.add("002212023093011282010554034945829056512");
list.add("002212023093011434310554038815179374592");
list.add("002212023093011450210554039148654366720");
list.add("002212023093012103110554045561296289792");
list.add("002212023093013351810554066898548654080");
list.add("002212023093014264810554079858466185216");
list.add("002212023093014272910554080030117847040");
list.add("002212023093014290210554080419239645184");
list.add("002212023093014332810554081536812507136");
list.add("002212023093014360610554082199805853696");
list.add("002212023093014373610554082576978329600");
list.add("002212023093014410610554083458460676096");
list.add("002212023093014444410554084373029634048");
list.add("002212023093014504510554085885124456448");
list.add("002212023093015110610554091007246249984");
list.add("002212023093016343210554112002851262464");
list.add("002212023093017080210554120434900451328");
list.add("002212023093017374010554127889414754304");
list.add("002212023093017391810554128300554694656");
list.add("002212023093017425010554129193153290240");
list.add("002212023093017472710554130354222919680");
list.add("002212023093017502810554131110972837888");
list.add("002212023093017551310554132308086710273");
list.add("002212023093018145710554137272674103296");
list.add("002212023093018191410554138352891932672");
list.add("002212023093018550110554147359195246592");
list.add("002212023093019314710554156610637262848");
list.add("002212023093020271110554170553580564480");
list.add("002212023093022325210554202180929421312");
list.add("002212023093022581810554208582794743808");
list.add("002212023100100074710554226069293977600");
list.add("002212023100100172710554228499856187392");
list.add("002212023100101120710554242258988904448");
list.add("002212023100101130710554242507884900352");
list.add("002212023100102030410554255079339290624");
list.add("002212023100102245010554260559017111552");
list.add("002212023100102542810554268016505171968");
list.add("002212023100103384610554279161515991040");
list.add("002212023100103494210554281914606661632");
list.add("002212023100107391910554339699281584128");
list.add("002212023100108162610554349042003865600");
list.add("002212023100108340110554353467098312704");
list.add("002212023100109271910554366879417475072");
list.add("002212023100110000310554375117640519680");
list.add("002212023100110334310554383589203750912");
list.add("002212023100110551210554388996314624000");
list.add("002212023100111063110554391842281193472");
list.add("002212023100111165010554394440767873024");
list.add("002212023100113225210554426156150378496");
list.add("002212023100113375910554429961592320000");
list.add("002212023100113422510554431077667274752");
list.add("002212023100113474910554432435648671744");
list.add("002212023100117300410554488367576346624");
list.add("002212023100117461010554492417930604544");
list.add("002212023100117522410554493986932424704");
list.add("002212023100119073710554512915569750016");
list.add("002212023100120032410554526956017111040");
list.add("002212023100120233010554532011070169088");
list.add("002212023100120512910554539055563927552");
list.add("002212023100121302010554548832462393344");
list.add("002212023100121392710554551125633052672");
list.add("002212023100123065510554573136545951744");
list.add("002212023100123504310554584161477885952");
list.add("002212023100207292410554699590692876288");
list.add("002212023100209175610554726906553430016");
list.add("002212023100209333610554730849793650688");
list.add("002212023100210480310554749582065524736");
list.add("002212023100211545910554766426625269760");
list.add("002212023100212134310554771141028655104");
list.add("002212023100212233110554773606751248384");
list.add("002212023100214001210554797938460573696");
list.add("002212023100214011810554798216714596352");
list.add("002212023100214213210554803306741608448");
list.add("002212023100214393510554807851637895168");
list.add("002212023100214422310554808553520209920");
list.add("002212023100216312810554836006762872832");
list.add("002212023100217100910554845742331023360");
list.add("002212023100217383210554852886961721344");
list.add("002212023100217491010554855559270682624");
list.add("002212023100218213010554863696490258432");
list.add("002212023100221121110554906653205168128");
list.add("002212023100221263610554910277998325760");
list.add("002212023100222472410554930613812969472");
list.add("002212023100306120310555042511912644608");
list.add("002212023100308311910555077560020492288");
list.add("002212023100309044110555085957690458112");
list.add("002212023100310062010555101473246781440");
list.add("002212023100310272710555106786838552576");
list.add("002212023100311032210555115828190113792");
list.add("002212023100311043210555116121780371456");
list.add("002212023100312144210555133775927406592");
list.add("002212023100312300610555137654131970048");
list.add("002212023100312392910555140015923036160");
list.add("002212023100312435310555141121895530496");
list.add("002212023100312582610555144784859811840");
list.add("002212023100312585110555144889106116608");
list.add("002212023100313200310555150224604483584");
list.add("002212023100313204410555150394641821696");
list.add("002212023100313432410555156100153262080");
list.add("002212023100314011210555160577862479872");
list.add("002212023100314045710555161522650591232");
list.add("002212023100314575210555174840524861440");
list.add("002212023100315255410555181895819407360");
list.add("002212023100315572410555189822708961280");
list.add("002212023100317005610555205809335087104");
list.add("002212023100317362110555214724800692224");
list.add("002212023100319491410555248162869850112");
list.add("002212023100321472110555277888967782400");
list.add("002212023100402222610555347116097490944");
list.add("002212023100409353310555456112857968640");
list.add("002212023100409471510555459060649934848");
list.add("002212023100410531410555475662023667712");
list.add("002212023100411225610555483140026191872");
list.add("002212023100413121510555510646494904320");
list.add("002212023100413373410555517020819861504");
list.add("002212023100413492610555520007639584768");
list.add("002212023100414303410555530357295800320");
list.add("002212023100414393010555532603711991808");
list.add("002212023100415401910555547910929297408");
list.add("002212023100415430010555548587771027456");
list.add("002212023100417294310555575444184154112");
list.add("002212023100417445810555579281492938752");
list.add("002212023100417513910555580961380851712");
list.add("002212023100417530110555581306390888448");
list.add("002212023100418191810555587921182416896");
list.add("002212023100418231610555588918201204736");
list.add("002212023100418564010555597323989110784");
list.add("002212023100420001310555613316929773568");
list.add("002212023100423154910555662541473939456");
list.add("002212023100500245910555679946258997248");
list.add("002212023100500340310555682230757470208");
list.add("002212023100501593210555703741647863808");
list.add("002212023100503010810555719245146324992");
list.add("002212023100503064110555720640053211136");
list.add("002212023100505502210555761834524065792");
list.add("002212023100507392410555789273283936256");
list.add("002212023100507494510555791877099204608");
list.add("002212023100509251910555815928513409024");
list.add("002212023100509582710555824264892387328");
list.add("002212023100510410810555835004652310528");
list.add("002212023100512393110555864799549841408");
list.add("002212023100514251910555891425754722304");
list.add("002212023100514295910555892596623757312");
list.add("002212023100515302810555907820753956864");
list.add("002212023100515373110555909595573694464");
list.add("002212023100516065810555917003403743232");
list.add("002212023100517401110555940463974187008");
list.add("002212023100517534610555943883319533568");
list.add("002212023100519083210555962697146662912");
list.add("002212023100521035310555991728217395200");
list.add("002212023100521322010555998888021700608");
list.add("002212023100521442710556001936017899520");
list.add("002212023100521551310556004643412226048");
list.add("002212023100522321610556013971174768640");
list.add("002212023100606133910556130078262218752");
list.add("002212023100609425210556182732384235520");
list.add("002212023100611381810556211781815160832");
list.add("002212023100611425110556212926612598784");
list.add("002212023100611572810556216603259883520");
list.add("002212023100612154210556221191055712256");
list.add("002212023100612230510556223050451628032");
list.add("002212023100612552910556231206643175424");
list.add("002212023100615354610556271540531281920");
list.add("002212023100617282310556299881091411968");
list.add("002212023100620341910556346672205484032");
list.add("002212023100700013310556398826898509824");
list.add("002212023100700471310556410317572911104");
list.add("002212023100702192810556433535354961920");
list.add("002212023100702325910556436935540420608");
list.add("002212023100705470010556485759965024256");
list.add("002212023100707531510556517534112362496");
list.add("002212023100710280810556556511357935616");
list.add("002212023100718113410556673138059751424");
list.add("002212023100718431810556681125109137408");
list.add("002212023100719422910556696019258814464");
list.add("002212023100806585710556866254434562048");
list.add("002212023100814234210556978182537302016");
list.add("002212023100815210410556992619290013696");
list.add("002212023100821262810557084575764525056");
list.add("002212023100902284010557160626708201472");
list.add("002212023100906160710557217862431019008");
list.add("002212023100912393910557314383834488832");
list.add("002212023100914004310557334785172414464");
list.add("002212023100914173410557339026316308480");
list.add("002212023100916330710557373139144376320");
list.add("002212023100918192210557399876784087040");
list.add("002212023100919251510557416454458699776");
list.add("002212023101002155010557519782858964992");
list.add("002212023101012491410557679184989364224");
list.add("002212023101017500410557754891570757632");
list.add("002212023101018330110557765700525232128");
list.add("002212023101118465410558131579994984448");
list.add("002212023101119254110558141339304464384");
list.add("002212023101119351610558143752408313856");
list.add("002212023101207495410558328629654286336");
list.add("002212023101209182110558350888149979136");
list.add("002212023101221070810558529258848239616");
list.add("002212023101315372910558808688995078144");
list.add("002212023101316274410558821335937765376");
list.add("002212023101320435610558885809672663040");
list.add("002212023101410485910559098472540139520");
list.add("002212023101413010810559131727536771072");
list.add("002212023101417452910559203287215378432");
list.add("002212023101418075710559208941910601728");
list.add("002212023101420224810559242878298533888");
list.add("002212023101509363610559442645505388544");
list.add("002212023101517284110559561449773944832");
list.add("002212023101517473210559566193945997312");
list.add("002212023101518163110559573484292370432");
list.add("002212023101612175310559845619980038144");
list.add("002212023101616242110559907645127090176");
list.add("002212023101700184510560027034521616384");
list.add("002212023101715520210560261900026728448");
list.add("002212023101722134110560357948799799296");
list.add("002212023101722570910560368885034622976");
list.add("002212023101722582310560369196298567680");
list.add("002212023101810172410560540076308262912");
list.add("002212023101816405310560636582655606784");
list.add("002212023101821230510560707600085676032");
list.add("002212023101913140910560946945874624512");
list.add("002212023101913573810560957886104342528");
list.add("002212023101914495610560971047638872064");
list.add("002212023101920321310561057188736393216");
list.add("002212023102007482910561227375237058560");
list.add("002212023102022135710561445175577059328");
list.add("002212023102118255410561750174421000192");
list.add("002212023102119341710561767384231141376");
list.add("002212023102119364610561768008238718976");
list.add("002212023102119591710561773674642759680");
list.add("002212023102120062310561775464014237696");
list.add("002212023102210373610561994711616741376");
list.add("002212023102311485910562375063079264256");
list.add("002212023102313001410562392993900249088");
list.add("002212023102317084410562455532422361088");
list.add("002212023102317575310562467898022387712");
list.add("002212023102320172210562503002558648320");
list.add("002212023102411451710562736518311428096");
list.add("002212023102412124210562743420364218368");
list.add("002212023102413060010562756833391894528");
list.add("002212023102413532410562768759794495488");
list.add("002212023102417115610562818723768651776");
list.add("002212023102418125710562834080087392256");
list.add("002212023102418170410562835115967336448");
list.add("002212023102418205010562836063672561664");
list.add("002212023102508421310563052836774551552");
list.add("002212023102509362810563066489487794176");
list.add("002212023102510470210563084247632244736");
list.add("002212023102513005610563117945544810496");
list.add("002212023102513093010563120101605810176");
list.add("002212023102516213910563168456627417088");
list.add("002212023102518204110563198413298692096");
list.add("002212023102519093110563210700862242816");
list.add("002212023102520101910563226004196913152");
list.add("002212023102523125710563271965594312704");
list.add("002212023102602094310563316447897477120");
list.add("002212023102602354910563323018109591552");
list.add("002212023102602523910563327253555671040");
list.add("002212023102602555610563328081129078784");
list.add("002212023102603235510563335124342497280");
list.add("002212023102603410110563339424225251328");
list.add("002212023102603505710563341925407322112");
list.add("002212023102605023510563359953041973248");
list.add("002212023102610091810563437141797412864");
list.add("002212023102616131510563528732401164288");
list.add("002212023102617525910563553830608531456");
list.add("002212023102619154410563574653746638848");
list.add("002212023102619212810563576096891060224");
list.add("002212023102623533310563644571881816064");
list.add("002212023102711420510563822879976304640");
list.add("002212023102716191010563892608645304320");
list.add("002212023102810154210564163525227728896");
list.add("002212023102812020010564190278571630592");
list.add("002212023102812260810564196351366500352");
list.add("002212023102812303810564197485917487104");
list.add("002212023102813242510564211017945280512");
list.add("002212023102814214010564225426915131392");
list.add("002212023102814404110564230211771809792");
list.add("002212023102816330210564258487109304320");
list.add("002212023102916091910564614904765370368");
list.add("002212023103102540710565139563870003200");
list.add("002212023103110002010565246823995162624");
list.add("002212023103110563810565260991393951744");
list.add("002212023103116222410565342973800214528");
list.add("002212023110114213910565674974983208960");
list.add("002212023110114235610565675547743481856");
list.add("002212023110213280110566023865940557824");
list.add("002212023110222001410566152769157734400");
list.add("002212023110318220410566460254192467968");
list.add("002212023110318245810566460982688227328");
list.add("002212023110322214710566520577620013056");
list.add("002212023110410171910566700650346311680");
list.add("002212023110410554810566710334026305536");
list.add("002212023110505584210566997955710558208");
list.add("002212023110512590310567103736774242304");
list.add("002212023110513090810567106277749813248");
list.add("002212023110514220410567124628823076864");
list.add("002212023110515351610567143053622095872");
list.add("002212023110516053110567150665865166848");
list.add("002212023110517220610567169935790350336");
list.add("002212023110606371710567370050395684864");
list.add("002212023110607164810567379995092840448");
list.add("002212023110711031610567799377812148224");
list.add("002212023110714111110567846666083041280");
list.add("002212023110717323910567897369621184512");
list.add("002212023110809404510568140998325370880");
list.add("002212023110811511310568173829271998464");
list.add("002212023110817381010568261142414462976");
list.add("002212023110909443510568504349089603584");
list.add("002212023110910461910568519886268514304");
list.add("002212023110913114810568556498163400704");
list.add("002212023110913213110568558942329499648");
list.add("002212023110915230710568589544573673472");
list.add("002212023110916232910568604735079550976");
list.add("002212023111015232210568951997472272384");
list.add("002212023111020360910569030710998315008");
list.add("002212023111113571610569292714933727232");
list.add("002212023111115465510569320310498435072");
list.add("002212023111116142010569327211546189824");
list.add("002212023111217141310569704666336047104");
list.add("002212023111219364310569740529861627904");
list.add("002212023111219574910569745838103285760");
list.add("002212023111301363510569831090843975680");
list.add("002212023111301403310569832092287324160");
list.add("002212023111301471810569833791360307200");
list.add("002212023111301510510569834742136602624");
list.add("002212023111302040110569837996229562368");
list.add("002212023111302101110569839546799013888");
list.add("002212023111302174010569841430896791552");
list.add("002212023111302212410569842369864302592");
list.add("002212023111302254010569843445091831808");
list.add("002212023111302332610569845400453206016");
list.add("002212023111311175210569977379474288640");
list.add("002212023111313351710570011960154415104");
list.add("002212023111314024510570018873872928768");
list.add("002212023111317072310570065338149683200");
list.add("002212023111321475210570135923648925696");
list.add("002212023111322255010570145477282660352");
list.add("002212023111322554210570152991463927808");
list.add("002212023111323261310570160674841473024");
list.add("002212023111400271810570176044025753600");
list.add("002212023111410001110570320216773001216");
list.add("002212023111415220910570401242683518976");
list.add("002212023111418034110570441893560492032");
list.add("002212023111515152710570761942994149376");
list.add("002212023111517541510570801908418912256");
list.add("002212023111600264710570900689805856768");
list.add("002212023111605581510570984105411133440");
list.add("002212023111606100510570987085818269696");
list.add("002212023111619261010571187427752259584");
list.add("002212023111718173110571532536838086656");
list.add("002212023111815365810571854523538767872");
list.add("002212023111906210310572077009953136640");
list.add("002212023111912064210572163994857603072");
list.add("002212023111915060810572209150859837440");
list.add("002212023111916192410572227589105029120");
list.add("002212023112004253510572410336381075456");
list.add("002212023112018342510572623955041931264");
list.add("002212023112022141110572679260327632896");
list.add("002212023112103060610572752723779817472");
list.add("002212023112104594810572781337180090368");
list.add("002212023112107174510572816051365052416");
list.add("002212023112108581910572841361090060288");
list.add("002212023112214565410573293989684412416");
list.add("002212023112216330710573318204809990144");
list.add("002212023112220574410573384795366400000");
list.add("002212023112221145710573389127425294336");
list.add("002212023112311572310573611200902254592");
list.add("002212023112407535710573912328871325696");
list.add("002212023112411140610573962696900718592");
list.add("002212023112507434710574272156631257088");
list.add("002212023112510451910574317840629714944");
list.add("002212023112513132910574355129729073152");
list.add("002212023112614001710574729293071618048");
list.add("002212023112710491410575043602871980032");
list.add("002212023112713022110575077103967191040");
list.add("002212023112718182110575156627955154944");
list.add("002212023112911242210575777219416797184");
list.add("002212023112917053410575863083550904320");
list.add("002212023112919165610575896144829177856");
list.add("002212023113014271010576185610669109248");
list.add("002212023113015153310576197787270664192");
list.add("002212023113015244110576200083760590848");
list.add("002212023120109261710576472279582658560");
list.add("002212023120208384910576822719554818048");
list.add("002212023120214253310576909980889210880");
list.add("002212023120215405210576928934469287936");
list.add("002212023120216523510576946980892139520");
list.add("002212023120309005910577190686992478208");
list.add("002212023120310192610577210431147175936");
list.add("002212023120312542810577249443939573760");
list.add("002212023120319142010577345042282819584");
list.add("002212023120401321210577440136878395392");
list.add("002212023120413290210577620533455097856");
list.add("002212023120417401710577683762487709696");
list.add("002212023120700504110578516852425076736");
list.add("002212023120701010110578519449407066112");
list.add("002212023120706414710578605209170698240");
list.add("002212023120716213610578751124000980992");
list.add("002212023120716451710578757082883776512");
list.add("002212023120717471310578772670495543296");
list.add("002212023120822393310579208625503150080");
update 查询分账情况工具
2023-12-13 16:48:07 +08:00
update
2023-09-08 14:26:13 +08:00
return list;
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
}
@Test
public void testClearingWithdraw() {
// 保存提现记录
ClearingWithdrawInfo record = new ClearingWithdrawInfo();
record.setWithdrawCode("132321354");
record.setWithdrawStatus(Constants.ZERO);
Date now = new Date();
record.setApplicationTime(now);
record.setCreateTime(now);
record.setDelFlag(DelFlagEnum.NORMAL.getValue());
clearingWithdrawInfoService.insertOrUpdate(record);
}
@Test
public void testGetPileTypeNum() {
Long stationId = 1L;
pileConnectorInfoService.getPileTypeNum(stationId);
}
@Test
public void testUpdateStatus() {
String pileConnectorCode = "8800000000012601";
String status = "0";
pileConnectorInfoService.updateConnectorStatus(pileConnectorCode, status);
}
@Test
public void testRedisSet() {
String redisKey = "push_station_connector";
redisCache.setCacheSet(redisKey, Sets.newHashSet("1"));
redisCache.setCacheSet(redisKey, Sets.newHashSet("3"));
redisCache.setCacheSet(redisKey, Sets.newHashSet("5"));
redisCache.setCacheSet(redisKey, Sets.newHashSet("1"));
redisCache.setCacheSet(redisKey, Sets.newHashSet("1"));
redisCache.setCacheSet(redisKey, Sets.newHashSet("7"));
redisCache.setCacheSet(redisKey, Sets.newHashSet("3"));
Set<Object> cacheSet = redisCache.getCacheSet(redisKey);
System.out.println(cacheSet);
}
@Test
public void testSettleOrder() {
Map<String, BigDecimal> returnAmountMap = Maps.newHashMap();
returnAmountMap.put("returnPrincipal", new BigDecimal("16.8700"));
// 更新会员钱包
BigDecimal returnPrincipal = returnAmountMap.get("returnPrincipal");
// if (returnPrincipal != null && principalPayRecord != null) {
// principalPayRecord.setRefundAmount(returnPrincipal);
// updatePayRecordList.add(principalPayRecord);
// }
BigDecimal returnGift = returnAmountMap.get("returnGift");
System.out.println(returnPrincipal);
// if (returnGift != null && giftPayRecord != null) {
// giftPayRecord.setRefundAmount(returnGift);
// updatePayRecordList.add(giftPayRecord);
// // 支付的赠送金额-退回的赠送金额 = 实际使用赠送金额消费的部分
// virtualAmount = giftPay.subtract(returnGift);
// }
// UpdateMemberBalanceDTO updateMemberBalanceDTO = UpdateMemberBalanceDTO.builder()
// .memberId(orderBasicInfo.getMemberId())
// .type(MemberWalletEnum.TYPE_IN.getValue()) // 进账
// .subType(MemberWalletEnum.SUBTYPE_ORDER_SETTLEMENT_REFUND.getValue()) // 订单结算退款
// .updatePrincipalBalance(returnPrincipal)
// .updateGiftBalance(returnGift)
// .relatedOrderCode(orderBasicInfo.getOrderCode())
// .build();
// memberBasicInfoService.updateMemberBalance(updateMemberBalanceDTO);
}
@Test
public void testVin() {
String vinCode = "tango";
MemberPlateNumberRelation memberPlateInfoByVinCode = memberPlateNumberRelationService.getMemberPlateInfoByVinCode(vinCode);
System.out.println(memberPlateInfoByVinCode);
}
@Test
public void testParking() throws UnsupportedEncodingException {
// GetTokenDTO dto = new GetTokenDTO();
// dto.setAppId("I2qa3hdr116100dc");
// dto.setSecretKey("2qa3hdr13754a8e");
// String token = ltytService.getToken(dto);
// System.out.println(token);
BindCouponDTO dto = new BindCouponDTO();
dto.setAppId("I2qa3hdr116100dc");
dto.setSecretKey("2qa3hdr13754a8e");
dto.setMerchantId("3prv98bm8db70a9");
dto.setCouponId("3prvd0q7a4817bf");
dto.setPlateNumber("贵A12345");
dto.setPlateColor(1);
String s = ltytService.bindCoupon(dto);
System.out.println(s);
}
@Test
public void testUpdateConnectorStatus() {
String pileConnectorCode = "8800000000000101";
String status = PileConnectorStatusEnum.FREE.getValue();
pileConnectorInfoService.updateConnectorStatus(pileConnectorCode, status);
}
@Test
public void testOrder() throws Exception {
// 通过vin码查询数据库绑定用户信息
MemberPlateNumberRelation plateInfo = memberPlateNumberRelationService.getMemberPlateInfoByVinCode("LNBSCC4H1LT107646");
GenerateOrderDTO dto = new GenerateOrderDTO();
dto.setMemberPlateNumberRelation(plateInfo);
dto.setPileSn("88000000000126");
dto.setConnectorCode("01");
dto.setStartMode(StartModeEnum.VIN_CODE.getValue());
dto.setMemberId(plateInfo.getMemberId());
// 通过memberId获取账户余额
MemberVO memberVO = memberBasicInfoService.queryMemberInfoByMemberId(dto.getMemberId());
if (memberVO == null) {
throw new BusinessException(ReturnCodeEnum.CODE_GET_MEMBER_ACCOUNT_AMOUNT_ERROR);
}
BigDecimal totalAccountAmount = memberVO.getTotalAccountAmount();
if (totalAccountAmount.compareTo(BigDecimal.ZERO) <= 0) {
throw new BusinessException(ReturnCodeEnum.CODE_BALANCE_IS_INSUFFICIENT);
}
dto.setChargeAmount(totalAccountAmount); // 充电金额
dto.setPayMode(OrderPayModeEnum.PAYMENT_OF_BALANCE.getValue()); // 1-余额支付
OrderBasicInfo basicInfo = orderBasicInfoService.generateOrder(dto);
// 支付订单
PayOrderDTO payOrderDTO = new PayOrderDTO();
payOrderDTO.setOrderCode(basicInfo.getOrderCode());
payOrderDTO.setPayAmount(totalAccountAmount);
payOrderDTO.setPayMode(dto.getPayMode());
payOrderDTO.setMemberId(dto.getMemberId());
// payOrderDTO.setCode();
// payOrderDTO.setLockValue();
// payOrderDTO.setOrderBasicInfo(basicInfo);
Map<String, Object> map = orderBasicInfoService.payOrder(payOrderDTO);
System.out.println(map);
}
@Test
public void testTransactionRecord() {
// 获取消息体
String msg = "8823000000123302230707215317078588230000001233020000341507071763023615070717b02a0200a00f0000000000003016000090dc010000000000000000000000000020c50100000000000000000000000000888a0100000000000000000000000000b0220749005032074900a00f000000000000e01500004c4e425343433448314c543130373634360563023615070717450000000000000000";
byte[] msgBody = BytesUtil.str2Bcd(msg);
int startIndex = 0;
int length = 16;
// 交易流水号
byte[] orderCodeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String transactionCode = BytesUtil.bcd2Str(orderCodeByteArr);
// 桩编码
startIndex += length;
length = 7;
byte[] pileSnByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String pileSn = BytesUtil.bcd2Str(pileSnByteArr);
// 枪号
startIndex += length;
length = 1;
byte[] connectorCodeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String connectorCode = BytesUtil.bcd2Str(connectorCodeByteArr);
// 开始时间 CP56Time2a 格式
startIndex += length;
length = 7;
byte[] startTimeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
// String binary = BytesUtil.binary(startTimeByteArr, 16);
Date startDate = Cp56Time2aUtil.byte2Hdate(startTimeByteArr);
String startTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, startDate);
// 结束时间 CP56Time2a 格式
startIndex += length;
byte[] endTimeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
Date endDate = Cp56Time2aUtil.byte2Hdate(endTimeByteArr);
String endTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, endDate);
// 尖单价 精确到小数点后五位（尖电费+尖服务费，见费率帧）
startIndex += length;
length = 4;
byte[] sharpPriceByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String sharpPrice = YKCUtils.convertDecimalPoint(sharpPriceByteArr, 5);
// 尖电量 精确到小数点后四位
startIndex += length;
length = 4;
byte[] sharpUsedElectricityByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String sharpUsedElectricity = YKCUtils.convertDecimalPoint(sharpUsedElectricityByteArr, 4);
// 计损尖电量
startIndex += length;
byte[] sharpPlanLossElectricityByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String sharpPlanLossElectricity = YKCUtils.convertDecimalPoint(sharpPlanLossElectricityByteArr, 4);
// 尖金额
startIndex += length;
byte[] sharpAmountByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String sharpAmount = YKCUtils.convertDecimalPoint(sharpAmountByteArr, 4);
// 峰单价 精确到小数点后五位（峰电费+峰服务费）
startIndex += length;
byte[] peakPriceByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String peakPrice = YKCUtils.convertDecimalPoint(peakPriceByteArr, 5);
// 峰电量
startIndex += length;
byte[] peakUsedElectricityByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String peakUsedElectricity = YKCUtils.convertDecimalPoint(peakUsedElectricityByteArr, 4);
// 计损峰电量
startIndex += length;
byte[] peakPlanLossElectricityByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String peakPlanLossElectricity = YKCUtils.convertDecimalPoint(peakPlanLossElectricityByteArr, 4);
// 峰金额
startIndex += length;
byte[] peakAmountByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String peakAmount = YKCUtils.convertDecimalPoint(peakAmountByteArr, 4);
// 平单价 精确到小数点后五位（平电费+平服务费）
startIndex += length;
byte[] flatPriceByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String flatPrice = YKCUtils.convertDecimalPoint(flatPriceByteArr, 5);
// 平电量
startIndex += length;
byte[] flatUsedElectricityByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String flatUsedElectricity = YKCUtils.convertDecimalPoint(flatUsedElectricityByteArr, 4);
// 计损平电量
startIndex += length;
byte[] flatPlanLossElectricityByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String flatPlanLossElectricity = YKCUtils.convertDecimalPoint(flatPlanLossElectricityByteArr, 4);
// 平金额
startIndex += length;
byte[] flatAmountByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String flatAmount = YKCUtils.convertDecimalPoint(flatAmountByteArr, 4);
// 谷单价 精确到小数点后五位（谷电费+谷 服务费）
startIndex += length;
byte[] valleyPriceByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String valleyPrice = YKCUtils.convertDecimalPoint(valleyPriceByteArr, 5);
// 谷电量
startIndex += length;
byte[] valleyUsedElectricityByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String valleyUsedElectricity = YKCUtils.convertDecimalPoint(valleyUsedElectricityByteArr, 4);
// 计损谷电量
startIndex += length;
byte[] valleyPlanLossElectricityByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String valleyPlanLossElectricity = YKCUtils.convertDecimalPoint(valleyPlanLossElectricityByteArr, 4);
// 谷金额
startIndex += length;
byte[] valleyAmountByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String valleyAmount = YKCUtils.convertDecimalPoint(valleyAmountByteArr, 4);
// 电表总起值
startIndex += length;
length = 5;
byte[] ammeterTotalStartByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String ammeterTotalStart = YKCUtils.convertDecimalPoint(ammeterTotalStartByteArr, 4);
// 电表总止值
startIndex += length;
byte[] ammeterTotalEndByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String ammeterTotalEnd = YKCUtils.convertDecimalPoint(ammeterTotalEndByteArr, 4);
// 总电量
startIndex += length;
length = 4;
byte[] totalElectricityByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String totalElectricity = YKCUtils.convertDecimalPoint(totalElectricityByteArr, 4);
// 计损总电量
startIndex += length;
byte[] planLossTotalElectricityByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String planLossTotalElectricity = YKCUtils.convertDecimalPoint(planLossTotalElectricityByteArr, 4);
// 消费金额 精确到小数点后四位，包含电费、 服务费
startIndex += length;
byte[] consumptionAmountByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String consumptionAmount = YKCUtils.convertDecimalPoint(consumptionAmountByteArr, 4);
// VIN 码 VIN 码，此处 VIN 码和充电时 VIN 码不同， 正序直接上传， 无需补 0 和反序
startIndex += length;
length = 17;
byte[] vinCodeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String vinCode = BytesUtil.ascii2Str(vinCodeByteArr);
/**
* 交易标识
* 0x01： app 启动
* 0x02：卡启动
* 0x04：离线卡启动
* 0x05: vin 码启动充电
*/
startIndex += length;
length = 1;
byte[] transactionIdentifierByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String transactionIdentifier = BytesUtil.bcd2Str(transactionIdentifierByteArr);
// 交易时间 CP56Time2a 格式
startIndex += length;
length = 7;
byte[] transactionTimeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
Date transactionDate = Cp56Time2aUtil.byte2Hdate(transactionTimeByteArr);
String transactionTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, transactionDate);
// 停止原因
startIndex += length;
length = 1;
byte[] stopReasonByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String stopReason = BytesUtil.bin2HexStr(stopReasonByteArr);
String stopReasonMsg = YKCChargingStopReasonEnum.getMsgByCode(Integer.parseInt(stopReason, 16));
// 物理卡号 不足 8 位补 0
startIndex += length;
length = 8;
byte[] cardNumByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
// byte[] logicCardNum = BytesUtil.checkLengthAndBehindAppendZero(cardNumByteArr, 16);
String logicCard = BytesUtil.binary(cardNumByteArr, 16);
// log.info("桩号:{}发送交易记录物理卡号:{}", pileSn, logicCard);
//
// log.info("[===交易记录===]交易流水号:{}, 桩编号:{}, 枪号:{}, 开始时间:{}, 结束时间:{}, 尖单价:{}, 尖电量:{}, 计损尖电量:{}, 尖金额:{}, " +
// "峰单价:{}, 峰电量:{}, 计损峰电量:{}, 峰金额:{}, 平单价:{}, 平电量:{}, 计损平电量:{}, 平金额:{}, " +
// "谷单价:{}, 谷电量:{}, 计损谷电量:{}, 谷金额:{}, 电表总起值:{}, 电表总止值:{}, 总电量:{}, 计损总电量:{}, 消费金额:{}, " +
// "电动汽车唯一标识:{}, 交易标识:{}, 交易日期、时间:{}, 停止原因码:{}, 停止原因描述:{}, 物理卡号:{}",
// transactionCode, pileSn, connectorCode, startTime, endTime, sharpPrice, sharpUsedElectricity, sharpPlanLossElectricity, sharpAmount,
// peakPrice, peakUsedElectricity, peakPlanLossElectricity, peakAmount, flatPrice, flatUsedElectricity, flatPlanLossElectricity, flatAmount,
// valleyPrice, valleyUsedElectricity, valleyPlanLossElectricity, valleyAmount, ammeterTotalStart, ammeterTotalEnd, totalElectricity, planLossTotalElectricity,
// consumptionAmount, vinCode, transactionIdentifier, transactionTime, stopReason, stopReasonMsg, logicCard);
// 交易记录封装到对象里
TransactionRecordsData data = TransactionRecordsData.builder()
// .orderCode(transactionCode)
.transactionCode(transactionCode)
.pileSn(pileSn)
.connectorCode(connectorCode)
.startTime(startTime)
.endTime(endTime)
.sharpPrice(sharpPrice)
.sharpUsedElectricity(sharpUsedElectricity)
.sharpPlanLossElectricity(sharpPlanLossElectricity)
.sharpAmount(sharpAmount)
.peakPrice(peakPrice)
.peakUsedElectricity(peakUsedElectricity)
.peakPlanLossElectricity(peakPlanLossElectricity)
.peakAmount(peakAmount)
.flatPrice(flatPrice)
.flatUsedElectricity(flatUsedElectricity)
.flatPlanLossElectricity(flatPlanLossElectricity)
.flatAmount(flatAmount)
.valleyPrice(valleyPrice)
.valleyUsedElectricity(valleyUsedElectricity)
.valleyPlanLossElectricity(valleyPlanLossElectricity)
.valleyAmount(valleyAmount)
.ammeterTotalStart(ammeterTotalStart)
.ammeterTotalEnd(ammeterTotalEnd)
.totalElectricity(totalElectricity)
.planLossTotalElectricity(planLossTotalElectricity)
.consumptionAmount(consumptionAmount)
.vinCode(vinCode)
.transactionIdentifier(transactionIdentifier)
.transactionTime(transactionTime)
.stopReasonMsg(stopReasonMsg)
.logicCard(logicCard)
.build();
// boolean flag = !StringUtils.equals("0000000000000000", "a511101970000000");
// System.out.println(flag);
// 处理订单加锁
String lockKey = "settle_order_" + transactionCode;
String uuid = IdUtils.fastUUID();
try {
// redis锁
Boolean isLock = redisCache.lock(lockKey, uuid, 1500);
if (isLock) {
// transactionRecordsRequestHandler.processOrder(data);
}
} catch (Exception e) {
System.out.println("处理订单发生异常: " + e);
} finally {
if (uuid.equals(redisCache.getCacheObject(lockKey).toString())) {
redisCache.unLock(lockKey);
}
}
}
@Test
public void testFault() {
StringBuffer sb = new StringBuffer("0100");
String lowOrder = sb.substring(0, 2);
String highOrder = sb.substring(2, 4);
// String hardwareFault = highOrder + lowOrder;
byte[] hardwareFaultByteArr = BytesUtil.str2Bcd(highOrder + lowOrder);
String binStr = BytesUtil.bytes2BinStr(hardwareFaultByteArr);
// log.info("binStr:{}", binStr); // 0000 0000 0000 0001
int faultCode = 0;
for (int i = 0; i < binStr.length(); i++) {
if (binStr.charAt(i) == '1') {
faultCode = 15 - i;
break;
}
}
String faultReason = YKCPileFaultReasonEnum.getValueByCode(faultCode);
System.out.println(faultReason);
}
@Test
public void testQueryCorpMember() {
List<AdapayMemberAccount> accountList = adapayMemberAccountService.selectAdapayMemberAccountList(new AdapayMemberAccount());
if (CollectionUtils.isNotEmpty(accountList)) {
update
2023-12-01 13:29:35 +08:00
List<String> ids = accountList.stream().map(x -> x.getId() + "").collect(Collectors.toList());
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
adapayMemberAccountService.deleteAdapayMemberAccountByIds(ids);
}
// try {
// Map<String, Object> map = adapayMemberService.selectAdapayMember("5");
//
// String adapayMemberId = "ACM29562569";
// AdapayCorpMemberVO adapayCorpMemberVO = adapayMemberService.queryCorpAdapayMemberInfo(adapayMemberId);
// System.out.println(adapayCorpMemberVO);
//
//
// } catch (BaseAdaPayException e) {
// throw new RuntimeException(e);
// }
}
@Test
public void testGetPileListByStationIdList() {
// List<String> stationIdList = Lists.newArrayList("2");
// Map<String, List<AMapEquipmentInfo>> pileListByStationIdList = aMapService.getPileListByStationIdList(stationIdList);
// System.out.println(pileListByStationIdList);
GetStationInfoDTO dto = new GetStationInfoDTO();
dto.setType("page");
aMapService.getStationInfosV2(dto);
}
@Test
public void testMultiSave() {
String prefix = "test_multi_save:";
Map<String, Object> redisMap = Maps.newHashMap();
for (int i = 0; i < 1000; i++) {
redisMap.put(prefix + i, PileInfoVO.builder().pileSn(i + "").build());
}
redisCache.multiSave(redisMap, 60);
}
@Test
public void testBillingTemplate() {
pileBillingTemplateService.queryStationBillingTemplateListForUniApp("2");
}
@Test
public void testQueryAdapayMemberInfo() {
String adapayMemberId = "AM25703321";
String settleAccountId = "0489089447022976";
try {
// adapayMemberService.queryAdapayMemberInfo(adapayMemberId);
adapayService.queryAdapaySettleAccount(adapayMemberId, settleAccountId, "");
} catch (BaseAdaPayException e) {
throw new RuntimeException(e);
}
}
@Test
public void testSaveAdapayCallbackRecord() throws JsonProcessingException {
String data = "{\n" +
" \"object\": \"refund\",\n" +
" \"status\": \"succeeded\",\n" +
" \"prod_mode\": \"true\",\n" +
" \"id\": \"0022120230531111946980509821471137853440\",\n" +
" \"refund_order_no\": \"823725974557265920\",\n" +
" \"payment_id\": \"002212023053110524210509814658135928832\",\n" +
" \"payment_order_no\": \"C27262970851\",\n" +
" \"refund_amt\": \"7.82\",\n" +
" \"fee_amt\": \"0.04\",\n" +
" \"channel_no\": \"2023053121R064uj\",\n" +
" \"created_time\": \"1685503187000\",\n" +
" \"succeed_time\": \"1685503199000\",\n" +
" \"app_id\": \"app_d0c80cb1-ffc8-48cb-a030-fe9bec823aaa\",\n" +
" \"reason\": \"\",\n" +
" \"notify_url\": \"https://api.jsowellcloud.com/uniapp/pay/adapayRefundCallback\"\n" +
"}";
JSONObject jsonObject = JSON.parseObject(data);
ObjectMapper mapper = new ObjectMapper();
mapper.setPropertyNamingStrategy(PropertyNamingStrategies.SNAKE_CASE);
mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
AdapayRefundRecord adapayRefundRecord = mapper.readValue(jsonObject.toJSONString(), AdapayRefundRecord.class);
adapayRefundRecord.setRefundId(jsonObject.getString("id"));
// 保存到数据库
adapayRefundRecordService.insertAdapayRefundRecord(adapayRefundRecord);
}
@Test
public void testQueryCallback() {
AdapayCallbackRecord aaaa = adapayCallbackRecordService.selectByOrderCode("aaaa");
System.out.println(aaaa);
}
@Test
public void testAdapayRefund() {
// 创建汇付退款对象 在完成初始化设置情况下，调用方法，获取 Refund对象
try {
String id = "002212023052710075810508353847861903360";
String refundAmount = "0.01";
Map<String, Object> refundParams = Maps.newHashMap();
refundParams.put("refund_amt", AdapayUtil.formatAmount(refundAmount));
refundParams.put("refund_order_no", SnowflakeIdWorker.getSnowflakeId());
refundParams.put("notify_url", "https://api.jsowellcloud.com/uniapp/pay/adapayRefundCallback");
Map<String, Object> response = Refund.create(id, refundParams);
System.out.println(JSON.toJSONString(response));
// if (response != null && !response.isEmpty()) {
// JSONObject jsonObject = JSONObject.parseObject(response.get("expend").toString());
// JSONObject pay_info = jsonObject.getJSONObject("pay_info");
// Map<String, Object> resultMap = JSONObject.parseObject(pay_info.toJSONString(), new TypeReference<Map<String, Object>>() {});
// }
} catch (Exception e) {
System.out.println(e);
}
}
@Test
public void testSaveCallback() throws JsonProcessingException {
update
2023-10-26 16:54:50 +08:00
String data = "{\"app_id2\":\"app_d0c80cb1-ffc8-48cb-a030-fe9bec823aaa\",\"created_time\":\"20230530132956\",\"description\":\"{\\\"orderCode\\\":\\\"C29505932783\\\",\\\"type\\\":\\\"order\\\"}\",\"end_time\":\"20230530133027\",\"expend\":{\"bank_type\":\"OTHERS\",\"open_id\":\"o8jhot6PJF93EPhNISsXi28dKdS8\",\"sub_open_id\":\"o4REX5MprZfTaLnVNxfdOY-wnwGI\"},\"fee_amt\":\"0.11\",\"id\":\"002212023053013295610509491838664794112\",\"order_no\":\"C29505932783\",\"out_trans_id\":\"4200001855202305308670391485\",\"party_order_id\":\"02212305304859640306711\",\"pay_amt\":\"20.00\",\"pay_channel\":\"wx_lite\",\"real_amt\":\"20.00\",\"share_eq\":\"Y\",\"status\":\"succeeded\",\"wx_user_id\":\"\"}";
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
JSONObject jsonObject = JSON.parseObject(data);
ObjectMapper mapper = new ObjectMapper();
mapper.setPropertyNamingStrategy(PropertyNamingStrategies.SNAKE_CASE);
update
2023-10-26 16:54:50 +08:00
mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
AdapayCallbackRecord adapayCallbackRecord = mapper.readValue(jsonObject.toJSONString(), AdapayCallbackRecord.class);
adapayCallbackRecord.setExpend(jsonObject.getString("expend"));
adapayCallbackRecord.setPaymentId(jsonObject.getString("id"));
update
2023-10-26 16:54:50 +08:00
// adapayCallbackRecordService.saveAdapayCallbackRecord(adapayCallbackRecord);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
}
@Test
public void testAMap() throws Exception {
String pileConnectorCode = "8800000000012601";
// String s = aMapService.pushChargingDeviceDynamics(pileConnectorCode);
GetStationInfoDTO dto = new GetStationInfoDTO();
dto.setType("page");
aMapService.getStationInfos(dto);
}
@Test
public void testVinCode() {
String msg = "880000000000210203000000000000000000000000000000000000000000000000004C5257594743454B584D43303437313434";
// 获取消息体
byte[] msgBody = BytesUtil.str2Bcd(msg);
int startIndex = 0;
int length = 7;
// 桩编码
byte[] pileSnByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String pileSn = BytesUtil.binary(pileSnByteArr, 16);
// 保存时间
update 校验channel
2023-11-24 11:30:53 +08:00
// saveLastTime(pileSn, channel);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
// 枪号
startIndex += length;
length = 1;
byte[] connectorNumByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String connectorCode = BytesUtil.bcd2Str(connectorNumByteArr);
// 启动方式
// 0x01 表示通过刷卡启动充电
// 0x02 表求通过帐号启动充电 （暂不支持）
// 0x03 表示vin码启动充电
startIndex += length;
byte[] startModeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String startMode = BytesUtil.bcd2Str(startModeByteArr);
// 是否需要密码 0x00 不需要 0x01 需要
startIndex += length;
byte[] needPasswordFlagByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String needPasswordFlag = BytesUtil.bcd2Str(needPasswordFlagByteArr);
// 物理卡号 不足 8 位补 0
startIndex += length;
length = 8;
byte[] cardNumByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String physicsCard = BytesUtil.binary(cardNumByteArr, 16);
// 输入密码 对用户输入的密码进行16 位MD5 加密，采用小写上传
startIndex += length;
length = 16;
byte[] inputPasswordByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
// VIN码
startIndex += length;
length = 17;
byte[] vinCodeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String vinCode = BytesUtil.ascii2Str(vinCodeByteArr);
System.out.println("桩号:" + pileSn + "申请充电VIN码:" + vinCode);
/**
* 刷卡启动充电
*/
String logicCard = "";
byte[] authenticationFlagByteArr = Constants.zeroByteArray; // 鉴权成功标识
byte[] accountBalanceByteArr = Constants.zeroByteArray; // 账户余额
String transactionCode = "";
try {
/**
* VIN码启动充电
*/
if (StringUtils.equals("03", startMode)) {
// 通过vin码查询数据库绑定用户信息
MemberPlateNumberRelation plateInfo = memberPlateNumberRelationService.getMemberPlateInfoByVinCode(vinCode);
if (plateInfo == null) {
throw new BusinessException("", "未查到绑定用户信息");
}
if (!StringUtils.equals("1", plateInfo.getVinStatus())) {
// 1- 正常使用
throw new BusinessException("", "vin状态不正确");
}
// vin码生成订单 vin启动充电
GenerateOrderDTO dto = new GenerateOrderDTO();
dto.setMemberPlateNumberRelation(plateInfo);
dto.setPileSn(pileSn);
dto.setConnectorCode(connectorCode);
dto.setStartMode(StartModeEnum.VIN_CODE.getValue());
Map<String, Object> map = orderBasicInfoService.generateOrderByCard(dto);
if (map != null) {
transactionCode = (String) map.get("transactionCode");
accountBalanceByteArr = YKCUtils.getPriceByte(String.valueOf(map.get("accountBalance")), 2);
// 鉴权成功标识 0x00 失败 0x01 成功
authenticationFlagByteArr = Constants.oneByteArray;
} else {
throw new BusinessException("", "生成vin订单失败");
}
}
} catch (BusinessException e) {
e.printStackTrace();
System.out.println("1");
// log.error("VIN码启动充电鉴权 error:{}, {}", e.getCode(), e.getMessage());
} catch (Exception e) {
e.printStackTrace();
System.out.println("2");
transactionCode = "00000000000000000000000000000000";
accountBalanceByteArr = BytesUtil.checkLengthAndBehindAppendZero(accountBalanceByteArr, 8);
authenticationFlagByteArr = Constants.zeroByteArray;
// log.error("VIN码启动充电鉴权 error", e);
}
byte[] serialNumByteArr = BytesUtil.str2Bcd(transactionCode);
byte[] defeatReasonByteArr = Constants.zeroByteArray;
// 不足位数的值补零
// cardNumByteArr = BytesUtil.checkLengthAndBehindAppendZero(cardNumByteArr, 16);
// serialNumByteArr = BytesUtil.checkLengthAndBehindAppendZero(serialNumByteArr, 32);
// pileSnByteArr = BytesUtil.checkLengthAndBehindAppendZero(pileSnByteArr, 14);
// accountBalanceByteArr = BytesUtil.checkLengthAndBehindAppendZero(accountBalanceByteArr, 8);
// 拼装消息体
byte[] msgBodyByteArr = Bytes.concat(serialNumByteArr, pileSnByteArr, connectorNumByteArr, cardNumByteArr, accountBalanceByteArr,
authenticationFlagByteArr, defeatReasonByteArr);
String s = BytesUtil.bin2HexStr(msgBodyByteArr);
System.out.println(s);
}
@Test
public void testGenerateLianlianToken() throws UnsupportedEncodingException {
String OperatorID = "425010765";
String OperatorSecret = "123123123123aaaa"; // 1234567890abcdef
//请求dataX
Map<String, String> data = new HashMap<>();
data.put("OperatorID", OperatorID);
data.put("OperatorSecret", OperatorSecret);
String dataJson = JSONUtil.toJsonStr(data);
//加密
byte[] encryptText = Cryptos.aesEncrypt(dataJson.getBytes(StandardCharsets.UTF_8),
OperatorSecret.getBytes(), OperatorSecret.getBytes());
String strData = Encodes.encodeBase64(encryptText);
Map<String, String> request = new LinkedHashMap<>();
request.put("OperatorID", OperatorID);
request.put("Data", strData);
request.put("TimeStamp", System.currentTimeMillis() + "");
request.put("Seq", "0001");
//生成签名
String sig = GBSignUtils.sign(request, OperatorSecret);
request.put("Sig", sig);
String tokenRequest = JSONUtil.toJsonStr(request);
CommonParamsDTO dto = JSONObject.parseObject(tokenRequest, CommonParamsDTO.class);
lianLianService.generateToken(dto);
}
@Test
public void testupdateElecAmount() {
// orderBasicInfoService.updateElecAmount();
}
@Test
public void testSelectSomeStatusCardInfo() {
PileAuthCard pileAuthCard = pileAuthCardService.selectCardInfoByLogicCard("1111111111111111");
System.out.println(pileAuthCard);
}
@Test
public void testLianLian() throws UnsupportedEncodingException {
// 获取令牌
// LianLianGetTokenDTO dto = new LianLianGetTokenDTO();
// dto.setOperatorId("MA1JLFUU8");
// dto.setOperatorSecret("Nh62XxlIR5OjAzFj");
// String token = lianLianService.getToken("", "MA1JLFUU8", "fGwLsxW1HdzLw7jp");
// System.out.println("token:" + token);
String operatorId = "425010765";
String operatorSecret = "3DSBTWHVIC6KVCKI";
// 请求data
// Map<String, String> data = new HashMap<>();
// data.put("OperatorID", operatorId);
// data.put("OperatorSecret", operatorSecret);
// String dataJson = JSONUtil.toJsonStr(data);
JSONObject json = new JSONObject();
// json.put("StationIDs", com.google.common.collect.Lists.newArrayList("1", "2"));
json.put("LastQueryTime", "2023-05-29 10:00:00");
json.put("PageNo", 1);
json.put("PageSize", 10);
String dataJson = JSONObject.toJSONString(json);
// 加密
byte[] encryptText = Cryptos.aesEncrypt(dataJson.getBytes(StandardCharsets.UTF_8),
operatorSecret.getBytes(), operatorSecret.getBytes());
String strData = Encodes.encodeBase64(encryptText);
String timeStamp = DateUtils.parseDateToStr(DateUtils.YYYYMMDDHHMMSS, new Date());
Map<String, String> request = new LinkedHashMap<>();
request.put("OperatorID", operatorId);
request.put("Data", strData);
request.put("TimeStamp", timeStamp);
request.put("Seq", "0001");
// 生成签名
String sig = GBSignUtils.sign(request, operatorSecret);
request.put("Sig", sig);
JSONObject jsonObject = new JSONObject(request);
System.out.println(jsonObject);
// CommonParamsDTO dto = new CommonParamsDTO();
// dto.setOperatorID(operatorId);
// dto.setData(strData);
// dto.setTimeStamp(timeStamp);
// dto.setSeq("0001");
// dto.setSig(sig);
// Map<String, String> map = lianLianService.generateToken(dto);
QueryStationInfoDTO dto = new QueryStationInfoDTO();
dto.setOperatorId(operatorId);
Map<String, String> map = lianLianService.query_stations_info(dto);
// String data1 = map.get("Data");
// 解密data
// String data1 = "JudlP17tnYuQc2zwOzmjJAb9hgghIymefG5v3ZzSOlPDh5+bJHIedsYzKMD56tHlmlg6Cb7vG+o6KjMSSpn1fyqBH3UVaEFF7uEc+lOuEc9c1vUzq20vBQ7N3EpDKqVBKjZbOezMsKYaCX7Br8XTsCYT8VCQui/np3cn+phi3VC+0s1coNxBX7xoEDZ7iuPjPoSWL7g3J0uOw2SoGaIdBQG3eTxaZJ5L+vBmuDF0pEXgazTMnuKml1mx1QHkig2F7h/ILT0VEKVXWMmmogYgiBk5ItO0DyzRl+ASb184gOhYGo82GJmWRiXrAXmceCiSNvTGg6aL26imIGKkJNfOx9/9mTqjGvy6kzxvWJ29PBU=";
// byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(data1),
// operatorSecret.getBytes(), operatorSecret.getBytes());
// String dataStr = new String(plainText, "UTF-8");
// Map<String, String> resultMap = (Map<String, String>) JSON.parse(dataStr);
//
// String token = resultMap.get("AccessToken");
//
// System.out.println("解密后token：" + token);
// LianLianPushStationInfoDTO dto1 = LianLianPushStationInfoDTO.builder()
// .OperatorID("MA1JLFUU8")
// .DataSecret("HVicnbRZbhPdIdpF")
// .DataSecretIV("JNvcjSOn1vhrE11M")
// .SigSecret("53TtFpc4gdVZbF3x")
// // .token(token)
// .stationId(2L)
//
// .build();
// lianLianService.pushStationInfo(dto1);
// 推送订单状态
// lianLianService.pushConnectorStatus("8800000000000101", "1");
// 推送订单信息
// lianLianService.pushOrderInfo("C27680791529");
// 推送启动充电结果
// lianLianService.pushStartChargeResult("C27680791529");
// 推送充电状态
// lianLianService.pushChargeStatus("C27680791529");
// 推送停止充电结果
// lianLianService.pushStopChargeResult("C27680791529");
// 推送充电订单信息
// lianLianService.pushChargeOrderInfo("C27680791529");
// 推送订单结算信息
// lianLianService.pushOrderSettlementInfo("C27680791529");
// 查询订单结算信息
// lianLianService.queryOrderSettlementInfo("C27680791529");
// 推送订单对账结果信息
// lianLianService.pushOrderReconciliationInfo("C27680791529");
// 测试生成、解密令牌
// long ttlMillis = 60 * 60 * 24 * 1000;
// String token = JWTUtils.createToken(operatorId, operatorSecret, ttlMillis);
// System.out.println(JWTUtils.checkThirdPartyToken(token));
JSONObject jsonObject1 = new JSONObject(map);
jsonObject1.put("OperatorID", "425010765");
jsonObject1.put("Data", "Ntu99RpveEOm2VUNq6RpD7OuOPXRbNxMOPmaBl67nkLk0nD/VmhipdSpq/Qfswhe1o55YMT+3Z7e6xe3fiJA3cZcvetxOEUF6sjvKLRq2rU=");
jsonObject1.put("TimeStamp", "20230530090132");
jsonObject1.put("Seq", "0001");
jsonObject1.put("Sig", "1568D2D35B245A0205B33D0EF92E7981");
String jsonString = JSONObject.toJSONString(jsonObject1);
String result = HttpUtils.sendPostContentType("http://localhost:8080/LianLian/v1/query_stations_info", jsonString, "application/json");
JSONObject object = JSONObject.parseObject(result);
String data1 = (String) object.get("data");
// 解密data
byte[] plainText = Cryptos.aesDecrypt(Encodes.decodeBase64(data1),
operatorSecret.getBytes(), operatorSecret.getBytes());
String dataStr = new String(plainText, "UTF-8");
Map<String, String> resultMap = (Map<String, String>) JSON.parse(dataStr);
}
@Test
public void testRefundForBalance() {
BigDecimal refundAmount = new BigDecimal("2");
// 退款金额 元转分 123
int refundTotalCents = refundAmount.multiply(new BigDecimal(100)).intValue();
// 查询用户充值余额订单 过滤掉已经退款的充值订单 refundableOrder
List<RefundableWxPayOrderData> recordList = Lists.newArrayList();
// recordList.add(RefundableWxPayOrderData.builder().outTradeNo("1").transactionId("1").payerAmount(new BigDecimal("1000")).refundableAmount(new BigDecimal("0")).build());
// recordList.add(RefundableWxPayOrderData.builder().outTradeNo("2").transactionId("2").payerAmount(new BigDecimal("1000")).refundableAmount(new BigDecimal("0")).build());
recordList.add(RefundableWxPayOrderData.builder().outTradeNo("3").transactionId("3").payerAmount(new BigDecimal("500")).refundableAmount(new BigDecimal("300")).build());
// 也许需要多笔支付订单才够退款
List<WechatPayRefundRequest> requestList = com.google.common.collect.Lists.newArrayList();
WechatPayRefundRequest request;
for (RefundableWxPayOrderData record : recordList) {
int refundableTotal = record.getRefundableAmount().intValue(); // 该笔支付订单的可退金额，单位分
int payerTotal = record.getPayerAmount().intValue(); // 该笔支付订单的支付金额，单位分
// 用户申请退款金额-可退金额
refundTotalCents = refundTotalCents - refundableTotal; // 123 - 100
request = new WechatPayRefundRequest();
request.setTransaction_id(record.getTransactionId()); // 微信支付单号
request.setOut_trade_no(record.getOutTradeNo()); // 商户订单号
request.setOut_refund_no(SnowflakeIdWorker.getSnowflakeId()); // 商户退款单号
request.setNotify_url(WeChatPayParameter.refundNotifyUrl); // 回调接口
request.setReason("用户余额退款");
request.setFunds_account("AVAILABLE");
if (refundTotalCents > 0) {
// 如果大于0说明，这笔单退完也不够
WechatPayRefundRequest.Amount amount = new WechatPayRefundRequest.Amount();
amount.setRefund(refundableTotal); // 退款金额
amount.setTotal(payerTotal); // 原订单金额
request.setAmount(amount);
requestList.add(request);
} else {
// 如果小于0，这笔单退一部分
// 生成退款单号
WechatPayRefundRequest.Amount amount = new WechatPayRefundRequest.Amount();
// 部分退
int i = refundableTotal + refundTotalCents;
amount.setRefund(i); // 退款金额
amount.setTotal(payerTotal); // 原订单金额
request.setAmount(amount);
requestList.add(request);
break;
}
}
System.out.println(requestList);
}
@Test
public void testCloseStartFailedOrder() {
String startTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, DateUtils.addDays(new Date(), -2));
String endTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, new Date());
orderBasicInfoService.closeStartFailedOrder(startTime, endTime);
}
@Test
public void testRedisSaveRealTimeData() {
String pileSn = "88000000000001";
String connectorCode = "01";
String orderCode = "88000000000001012211161342359448";
String pileConnectorCode = pileSn + connectorCode;
String redisKey = CacheConstants.PILE_REAL_TIME_MONITOR_DATA + pileConnectorCode + "_" + orderCode;
// for (int i = 0; i < 10; i++) {
// try {
// Thread.sleep(10000);
// } catch (InterruptedException e) {
// e.printStackTrace();
// }
// Date now = new Date();
// redisCache.hset(redisKey, DateUtils.parseDateToStr("yyyy-MM-dd HH:mm:00", now), i + ":" + DateUtils.parseDateToStr("yyyy-MM-dd HH:mm:ss", now));
// }
orderBasicInfoService.getChargingRealTimeData(orderCode);
}
@Test
public void testuniformMessageSend() {
AppletTemplateMessageSendDTO appletTemplateMessageSendDTO = new AppletTemplateMessageSendDTO();
// String openId = wxAppletRemoteService.getOpenIdByCode("0537u2100jTXsP1Y0Y300j426t47u210");
// System.out.println("openId:" + openId);
appletTemplateMessageSendDTO.setTouser("o4REX5MprZfTaLnVNxfdOY-wnwGI"); // openid
String templateId = "UyBPbADlZfsCj89rh_xvfZGlxTW5J5KURpZtt9CNFrY";
appletTemplateMessageSendDTO.setTemplate_id(templateId);
// appletTemplateMessageSendDTO.setPage("跳转的页面");
Map<String, Object> map = new HashMap<>();
map.put("amount17", ImmutableMap.of("value", "￥100")); // 结束时间
map.put("time3", ImmutableMap.of("value", "2022-12-30")); // 结束时间
map.put("thing7", ImmutableMap.of("value", "thing7")); // 结束原因
// map.put("thing5", ImmutableMap.of("value", "thing5")); // 结束原因
// map.put("time2", ImmutableMap.of("value", "time2")); // 结束原因
appletTemplateMessageSendDTO.setData(map);
wxAppletRemoteService.uniformMessageSend(appletTemplateMessageSendDTO);
}
@Test
public void testWeChatRefund() {
ApplyRefundDTO dto = new ApplyRefundDTO();
dto.setRefundType("2");
dto.setMemberId("82100864");
dto.setRefundAmount(new BigDecimal("1.23"));
orderBasicInfoService.weChatRefund(dto);
}
@Test
public void testSelectBalanceRechargeRecord() {
List<WxpayCallbackRecord> list = wxpayCallbackRecordService.queryBalanceRechargeRecordOfTheLatestYear("82100864");
System.out.println(list);
}
@Test
public void testSelectOrderBasicInfoList() {
QueryOrderDTO orderBasicInfo = new QueryOrderDTO();
orderBasicInfo.setPileSn("88000000000001");
orderBasicInfo.setOrderStatus(OrderStatusEnum.IN_THE_CHARGING.getValue());
List<OrderListVO> orderListVOS = orderBasicInfoService.selectOrderBasicInfoList(orderBasicInfo);
System.out.println(orderListVOS);
for (OrderListVO orderListVO : orderListVOS) {
if (StringUtils.equals(orderListVO.getOrderStatus(), OrderStatusEnum.IN_THE_CHARGING.getValue())) {
// 修改数据库订单状态
OrderBasicInfo info = OrderBasicInfo.builder()
.id(Long.parseLong(orderListVO.getId()))
.orderStatus(OrderStatusEnum.ABNORMAL.getValue())
.build();
orderBasicInfoService.updateOrderBasicInfo(info);
}
}
}
@Test
public void testWechatRefund() throws JsonProcessingException {
WechatPayRefundRequest request = new WechatPayRefundRequest();
request.setTransaction_id("4200001656202212302746036536"); // 微信支付单号
request.setOut_trade_no("768677222373363712"); // 商户订单号
// 生成退款单号
request.setOut_refund_no(SnowflakeIdWorker.getSnowflakeId()); // 商户退款单号
request.setNotify_url(WeChatPayParameter.refundNotifyUrl); // 回调接口
WechatPayRefundRequest.Amount amount = new WechatPayRefundRequest.Amount();
amount.setRefund(10 * 100); // 退款金额
amount.setTotal(10 * 100); // 原订单金额
request.setAmount(amount);
request.setReason("结算退款");
request.setFunds_account("AVAILABLE");
wechatPayService.ApplyForWechatPayRefundV3(request);
// 退款方法
}
@Test
public void testUpdatePileSimInfo() {
String pileSn = "88000000000001";
String iccid = "89860402102091089943";
pileBasicInfoService.updatePileSimInfo(pileSn, iccid);
}
@Test
public void testPay() {
String code = "081zIoGa11GamE0iVVIa1aaJ4G0zIoGE";
String openId = memberService.getOpenIdByCode(code);
Map<String, Object> pay = null;
try {
WeixinPayDTO dto = new WeixinPayDTO();
dto.setOpenId(openId);
dto.setAmount("0.01");
pay = orderService.weixinPayV3(dto);
} catch (Exception e) {
e.printStackTrace();
}
System.out.println(JSONObject.toJSONString(pay));
}
@Test
public void testMemberRegisterAndLogin() throws BaseAdaPayException {
}
@Test
public void testMemberBasicInfoMapper() {
// String memberId = "21772870";
// BigDecimal principalBalance = new BigDecimal("-10");
// BigDecimal giftBalance = new BigDecimal("-110");
// Integer version = 2;
// int i = memberBasicInfoMapper.updateMemberBalance(memberId, principalBalance, giftBalance, version);
// if (i == 1) {
// System.out.println("更新余额成功");
// } else {
// System.out.println("更新余额失败");
// }
Map<String, Object> refundParams = new HashMap<>(2);
refundParams.put("payment_id", "002212023071011321210524320114191904768");
// refundParams.put("refund_id", refund_id);
// refundParams.put("refund_order_no", refund_order_no);
try {
Map<String, Object> refund = Refund.query(refundParams);
System.out.println(refund);
} catch (BaseAdaPayException e) {
throw new RuntimeException(e);
}
update
2023-10-08 16:42:56 +08:00
}
/**
* 查询退款信息
*/
@Test
public void queryRefundTest() {
update 查询分账情况工具
2023-12-13 17:11:35 +08:00
List<String> list = getPaymentIdList(); // 查询退款信息
update
2023-10-08 16:42:56 +08:00
for (String paymentId : list) {
Map<String, Object> refundParams = Maps.newHashMap();
refundParams.put("payment_id", paymentId);
try {
update
2023-10-31 15:17:39 +08:00
Map<String, Object> refund = Refund.query(refundParams, wechatAppId2);
update
2023-10-08 16:42:56 +08:00
System.out.println("支付id:" + paymentId + ", 退款信息:" + JSON.toJSONString(refund));
System.out.println();
} catch (BaseAdaPayException e) {
throw new RuntimeException(e);
}
}
}
/**
* 查询支付撤销信息
*/
@Test
public void queryPaymentReverseTest() {
update 查询分账情况工具
2023-12-13 17:11:35 +08:00
List<String> list = getPaymentIdList(); // 查询支付撤销信息
update
2023-10-08 16:42:56 +08:00
for (String paymentId : list) {
try {
Map<String, Object> reverse = Maps.newHashMap();
reverse.put("payment_id", paymentId);
update
2023-10-31 15:17:39 +08:00
reverse.put("app_id", wechatAppId2);
Map<String, Object> response = PaymentReverse.queryList(reverse, wechatAppId2);
update
2023-10-08 16:42:56 +08:00
System.out.printf("支付id: %s, 支付撤销信息: %s%n", paymentId, JSON.toJSONString(response));
System.out.println();
} catch (BaseAdaPayException e) {
throw new RuntimeException(e);
}
}
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
}
@Test
public void testGenerateBillingTemplateMsgBody() {
String pileSn = "88000000000001";
// 根据桩号查询计费模板
BillingTemplateVO billingTemplateVO = pileBillingTemplateService.selectBillingTemplateDetailByPileSn(pileSn);
byte[] messageBody = pileBillingTemplateService.generateBillingTemplateMsgBody(pileSn, billingTemplateVO);
System.out.println(BytesUtil.binary(messageBody, 16));
}
@Test
public void testAnalysisPileParameter() {
BasicPileDTO dto = new BasicPileDTO();
// 3个都不传的情况
try {
System.out.println("3个都不传的情况");
dto.setPileSn("");
dto.setConnectorCode("");
dto.setPileConnectorCode("");
// orderService.analysisPileParameter(dto);
System.out.println("数据正确");
} catch (BusinessException e) {
System.out.println(e.getMessage());
}
System.out.println();
// 只传sn的情况
try {
System.out.println("只传sn的情况");
dto.setConnectorCode("");
dto.setPileConnectorCode("");
dto.setPileSn("88000000000001");
// orderService.analysisPileParameter(dto);
System.out.println("数据正确");
} catch (BusinessException e) {
System.out.println(e.getMessage());
}
System.out.println();
//
try {
System.out.println("只穿枪口号的情况");
dto.setConnectorCode("01");
dto.setPileConnectorCode("");
dto.setPileSn("");
// orderService.analysisPileParameter(dto);
System.out.println("数据正确");
} catch (BusinessException e) {
System.out.println(e.getMessage());
}
System.out.println();
// 只传充电桩枪口编号的情况
try {
System.out.println("只传充电桩枪口编号的情况");
dto.setPileConnectorCode("8800000000000101");
dto.setConnectorCode("");
dto.setPileSn("");
// orderService.analysisPileParameter(dto);
System.out.println("数据正确");
} catch (BusinessException e) {
System.out.println(e.getMessage());
}
try {
System.out.println();
System.out.println("传充电桩枪sn+枪口号的情况");
dto.setPileConnectorCode("");
dto.setConnectorCode("01");
dto.setPileSn("88000000000001");
// orderService.analysisPileParameter(dto);
System.out.println("数据正确");
} catch (BusinessException e) {
System.out.println(e.getMessage());
}
}
@Test
public void testImportBillingTemplate() {
ImportBillingTemplateDTO dto = new ImportBillingTemplateDTO();
dto.setBillingTemplateId("1");
// 查询公共计费模板是否存在
PileBillingTemplate pileBillingTemplate = pileBillingTemplateMapper.selectPileBillingTemplateById(Long.valueOf(dto.getBillingTemplateId()));
if (pileBillingTemplate == null) {
}
List<PileBillingDetail> billingDetailList = pileBillingTemplate.getPileBillingDetailList();
}
@Test
public void testProcess() {
// 62 68
String msgString = "680da300000388000000000001010020d06840a40000130000000000000000000000000000000088000000000001010202000000000000000000000000000000000000000000000000000000000000000000001516";
byte[] msg = BytesUtil.str2Bcd(msgString);
boolean b = YKCUtils.checkMsg(msg);
// ykcBusinessService.process(msg, null);
}
@Test
public void testHeartbeat() {
// heartbeatRequestHandler.updateStatus("88000000000001", "01", "0");
// heartbeatRequestHandler.updateStatus("88000000000001", "02", "0");
}
@Test
public void testPush() {
byte[] msg = new byte[]{};
String pileSn = "88000000000001";
// ykcPushBusinessService.push(msg, pileSn, YKCFrameTypeCode.READ_REAL_TIME_MONITOR_DATA_CODE);
}
@Test
public void TestMapUtils() {
String address = "淀山湖镇黄浦江南路278号";
String areaCode = "320000,320500,320583";
Map<String, String> longitudeAndLatitude = AddressUtils.getLongitudeAndLatitude(areaCode, address);
System.out.println(longitudeAndLatitude);
}
@Test
public void testCreatePile() {
BatchCreatePileDTO dto = BatchCreatePileDTO.builder()
.merchantId("1")
.stationId("1")
.softwareProtocol("1")
// .connectorNum(1)
// .num(10)
// .productionDate(new Date())
.build();
pileService.batchCreatePile(dto);
}
@Test
public void testGetIncre() {
StopWatch stopWatch = new StopWatch();
// 生成100个
stopWatch.start("生成100个sn号");
List<String> list2 = snUtils.generateSN(1);
stopWatch.stop();
System.out.println(list2);
System.out.println(stopWatch.getLastTaskTimeMillis());
}
@Test
public void testDict() {
// String dictValue = DictUtils.getDictValue("query_pile_info", "url");
// String station_type = DictUtils.getDictLabel("station_type", "1");
// System.out.println(station_type);
// System.out.println("123");
List<SysDictData> adapay_station = DictUtils.getDictCache("adapay_station");
List<String> stationIdList = com.google.common.collect.Lists.newArrayList();
if (CollectionUtils.isNotEmpty(adapay_station)) {
for (SysDictData sysDictData : adapay_station) {
stationIdList.add(sysDictData.getDictValue());
}
}
System.out.println(stationIdList);
}
@Test
public void testSelectByMerchantId() {
List<PileStationInfo> list = pileStationInfoService.selectStationListByMerchantId(Long.valueOf(Constants.ONE));
System.out.println(list);
}
@Test
public void testStr2Bcd() {
String logicCardNum = "00000000";
byte[] logicCardNumByteArr = BytesUtil.str2Bcd(logicCardNum);
System.out.println(Arrays.toString(logicCardNumByteArr));
}
@Test
public void testBigDecimalMultiply() {
BigDecimal a = new BigDecimal("216.5");
BigDecimal b = new BigDecimal("11.5");
BigDecimal result = a.multiply(b).setScale(2, BigDecimal.ROUND_HALF_UP);
System.out.println(result);
}
@Test
public void testRemoteUpdate() {
ArrayList<String> list = new ArrayList<>();
list.add("88000000000001");
// pileRemoteService.updateFirmware(list);
}
@Test
public void testGetUserPhoneNum() {
String code = "0e5394cfa4eb41c6181ed257f2368a86dfe4ebdac0a4fac85df63657637e6cc3";
wxAppletRemoteService.getMobileNumberByCode(code);
}
@Test
public void testDistance() {
QueryStationDTO dto = new QueryStationDTO();
dto.setStationLat("123.2222");
dto.setStationLng("55.6232");
// pileStationInfoService.uniAppQueryStationInfos(dto);
}
/**
* 生成英文字母随机数 RandomStringUtils.randomAlphabetic(10);
* 生成数字随机数 RandomStringUtils.randomNumeric(10);
* 字母+数字结合 RandomStringUtils.randomAlphanumeric(10);
*/
@Test
public void Test() throws ParseException {
commit
2023-03-04 16:29:55 +08:00
/*String s = RandomStringUtils.randomAlphanumeric(32);
System.out.println(s); // PuLe4Tyyg1jSFNPhF5d2Ts9ejRn6E8KQ
String str = "JS160829";
System.out.println(Md5Utils.hash(str).toUpperCase(Locale.ROOT));
*/
update 江苏省平台接口
2023-10-19 11:21:02 +08:00
String s = RandomStringUtils.randomAlphanumeric(16).toUpperCase(Locale.ROOT);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
System.out.println(s);
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
Date startTimeDate = sdf.parse("2022-11-26 10:44:11");
Date endTimeDate = sdf.parse("2022-11-27 12:45:11");
commit
2023-03-04 16:29:55 +08:00
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
System.out.println(DateUtils.getDatePoor(endTimeDate, startTimeDate)); // 1天2小时1分钟
commit
2023-03-04 16:29:55 +08:00
/*String stra = "sp_mchid=1632405339&sub_mchid=1632405339&out_trade_no=1217752501201407033233368318&sp_appid=wxbb3e0d474569481d&sub_appid=wxbb3e0d474569481d" +
"bbac689f4654b209de4d6944808ec80b";
System.out.println(Md5Utils.hash(stra).toUpperCase(Locale.ROOT));*/
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
}
@Test
public void testSimCard() throws ParseException {
ArrayList<String> list = Lists.newArrayList();
Collections.addAll(list, "898607B9102090253556", "898607B9102090253560");
// String s = list.toString().replaceAll("(?:\\[|null|\\]| +)", "");
// System.out.println(s);
// List<SimCardVO> simCardVOList = simCardService.selectSimCardInfoByIccId(list);
// System.out.println(simCardVOList.toString());
// simCardService.XunZhongSimRenewal(list, 12);
// System.out.println(s);
// SimCardVO simCardVO = simCardService.searchByLoop("898607B9102090253556");
//
// System.out.println(simCardVO.toString());
simCardService.WuLianSimRenew(list, 1);
}
@Test
public void testRefund() {
OrderBasicInfo orderInfo = orderBasicInfoService.getOrderInfoByOrderCode("88000000000001012212171045412218");
orderInfo.setReason("充电异常中止，急停开入");
TransactionRecordsData data = TransactionRecordsData.builder()
.transactionCode("88000000000001012212171045412218")
.consumptionAmount(String.valueOf(0.00))
.stopReasonMsg(orderInfo.getReason())
.totalElectricity("0")
.sharpUsedElectricity("0")
.peakUsedElectricity("0")
.flatUsedElectricity("0")
.valleyUsedElectricity("0")
.build();
update 订单逻辑改造工厂模式
2023-09-01 15:45:04 +08:00
// orderBasicInfoService.settleOrder(data, orderInfo);
单元测试 在线支付订单、退款
2023-08-30 11:02:18 +08:00
}
@Test
public void testLoginHandler() {
String msg = "8800000000001001010f63362d333000000000898604b319227036282200";
byte[] msgBody = BytesUtil.str2Bcd(msg);
int startIndex = 0;
int length = 7;
// 桩编码
byte[] pileSnByte = BytesUtil.copyBytes(msgBody, startIndex, length);
String pileSn = BytesUtil.binary(pileSnByte, 16);
// log.info("桩号：{}", pileSn);
// 桩类型 0 表示直流桩， 1 表示交流桩
startIndex += length;
length = 1;
byte[] pileTypeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String pileType = BytesUtil.bcd2Str(pileTypeByteArr);
// 充电枪数量
startIndex += length;
byte[] connectorNumByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String connectorNum = BytesUtil.bcd2Str(connectorNumByteArr);
// 通信协议版本 版本号乘 10，v1.0 表示 0x0A
startIndex += length;
byte[] communicationVersionByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
// int i = Integer.parseInt(BytesUtil.bcd2Str(communicationVersionByteArr)); // 0F --> 15
BigDecimal bigDecimal = new BigDecimal(BytesUtil.bcd2Str(communicationVersionByteArr));
BigDecimal communicationVersionTemp = bigDecimal.divide(new BigDecimal(10));
String communicationVersion = "v" + communicationVersionTemp;
// 程序版本
startIndex += length;
length = 8;
byte[] programVersionByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String programVersion = BytesUtil.bcd2Str(programVersionByteArr);
// 网络连接类型 0x00 SIM 卡 0x01 LAN 0x02 WAN 0x03 其他
startIndex += length;
length = 1;
byte[] internetConnectionTypeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String internetConnection = BytesUtil.bcd2Str(internetConnectionTypeByteArr);
// sim卡
startIndex += length;
length = 10;
byte[] simCardNumByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String iccid = BytesUtil.bin2HexStr(simCardNumByteArr);
// 运营商 0x00 移动 0x02 电信 0x03 联通 0x04 其他
startIndex += length;
length = 1;
byte[] businessTypeByteArr = BytesUtil.copyBytes(msgBody, startIndex, length);
String business = BytesUtil.bcd2Str(businessTypeByteArr);
LoginRequestData loginRequestData = LoginRequestData.builder()
.pileSn(pileSn)
.pileType(pileType)
.connectorNum(connectorNum)
.communicationVersion(communicationVersion)
.programVersion(programVersion)
.internetConnection(internetConnection)
.iccid(iccid)
.business(business)
.build();
// 结果（默认 0x01:登录失败）
byte[] flag = Constants.oneByteArray;
// 通过桩编码SN查询数据库，如果有数据，则登录成功，否则登录失败
QueryPileDTO dto = new QueryPileDTO();
dto.setPileSn(pileSn);
List<PileDetailVO> list = pileBasicInfoService.queryPileInfos(dto);
if (CollectionUtils.isNotEmpty(list)) {
flag = Constants.zeroByteArray;
// 登录成功，保存桩号和channel的关系
// PileChannelEntity.put(pileSn, channel);
// 更改桩和该桩下的枪口状态分别为 在线、空闲
// pileBasicInfoService.updatePileStatus(pileSn, PileStatusEnum.ON_LINE.getValue());
// pileConnectorInfoService.updateConnectorStatusByPileSn(pileSn, PileConnectorDataBaseStatusEnum.FREE.getValue());
// 对时
ProofreadTimeCommand command = ProofreadTimeCommand.builder().pileSn(pileSn).build();
ykcPushCommandService.pushProofreadTimeCommand(command);
// 公共方法修改状态
pileBasicInfoService.updateStatus(BytesUtil.bcd2Str(new byte[]{0x01}), pileSn, null, null, null);
// 下发二维码
IssueQRCodeCommand issueQRCodeCommand = IssueQRCodeCommand.builder().pileSn(pileSn).build();
ykcPushCommandService.pushIssueQRCodeCommand(issueQRCodeCommand);
}
// 充电桩使用的sim卡，把信息存库
if (StringUtils.equals("00", internetConnection)) {
try {
pileBasicInfoService.updatePileSimInfo(pileSn, iccid);
} catch (Exception e) {
// log.error("更新充电桩sim卡信息失败", e);
System.out.println(e.getMessage());
}
}
// 保存报文
String jsonMsg = JSONObject.toJSONString(loginRequestData);
// pileMsgRecordService.save(pileSn, pileSn, type, jsonMsg, ykcDataProtocol.getHEXString());
// // 消息体
// byte[] messageBody = Bytes.concat(pileSnByte, flag);
// return getResult(ykcDataProtocol, messageBody);
}
@Test
public void testGetMemberToken() {
String memberId = JWTUtils.getMemberId("eyJhbGciOiJIUzI1NiJ9.eyJpYXQiOjE2NzY1MTY5MzgsImV4cCI6MTY3OTEwODkzOH0.4MwhZIOpnCfQloR7zEm2hwPOh2yyI2qxbBbTcv_SnZ4");
System.out.println(memberId);
}
commit
2023-03-04 16:29:55 +08:00
}
Reference in New Issue Copy Permalink