|
@@ -26,6 +26,7 @@ import javax.annotation.Resource;
|
|
|
import java.io.IOException;
|
|
import java.io.IOException;
|
|
|
import java.math.BigDecimal;
|
|
import java.math.BigDecimal;
|
|
|
import java.util.Date;
|
|
import java.util.Date;
|
|
|
|
|
+import java.util.HashMap;
|
|
|
import java.util.List;
|
|
import java.util.List;
|
|
|
import java.util.Objects;
|
|
import java.util.Objects;
|
|
|
|
|
|
|
@@ -66,7 +67,7 @@ public class RetrieveTTQFApi {
|
|
|
public static String extractBalance(String userId,String decimal) throws Exception {
|
|
public static String extractBalance(String userId,String decimal) throws Exception {
|
|
|
SysUserBankCard bankCard = SpringUtil.getBean(SysUserBankCardMapper.class).selectByIdPay("9914D1305");
|
|
SysUserBankCard bankCard = SpringUtil.getBean(SysUserBankCardMapper.class).selectByIdPay("9914D1305");
|
|
|
signService.saveUserSign(bankCard.getUserId());
|
|
signService.saveUserSign(bankCard.getUserId());
|
|
|
- if (false){
|
|
|
|
|
|
|
+ if (queryPressing(bankCard.getIdentity())){
|
|
|
//用户已经签约 进行打款操作
|
|
//用户已经签约 进行打款操作
|
|
|
orderAdd(bankCard,new BigDecimal(decimal),"测试打款");
|
|
orderAdd(bankCard,new BigDecimal(decimal),"测试打款");
|
|
|
return "0";
|
|
return "0";
|
|
@@ -103,6 +104,7 @@ public class RetrieveTTQFApi {
|
|
|
.paymentType(0)
|
|
.paymentType(0)
|
|
|
//选填项:微信APPID,若填写,以填写项稳准,否则应用预留配置的微信appid;该字段适用于同主体下含有多个公众号或小程序的场景
|
|
//选填项:微信APPID,若填写,以填写项稳准,否则应用预留配置的微信appid;该字段适用于同主体下含有多个公众号或小程序的场景
|
|
|
.wechatAppId("")
|
|
.wechatAppId("")
|
|
|
|
|
+ .notifyUrl(PayConstantStatus.getPaymentNoticeUrl())
|
|
|
.build();
|
|
.build();
|
|
|
OrderAddResponse response = testOrderAdd(addModel, bankCard.getUserId());
|
|
OrderAddResponse response = testOrderAdd(addModel, bankCard.getUserId());
|
|
|
if(response.isSuccess()) {
|
|
if(response.isSuccess()) {
|
|
@@ -331,7 +333,7 @@ public class RetrieveTTQFApi {
|
|
|
ConfirmResponse response = tangClient.execute(confirmRequest);
|
|
ConfirmResponse response = tangClient.execute(confirmRequest);
|
|
|
if(response.isSuccess()) {
|
|
if(response.isSuccess()) {
|
|
|
log.info("成功 ====>Confirm{}", response.getResultModel());
|
|
log.info("成功 ====>Confirm{}", response.getResultModel());
|
|
|
- paymentStatus.updatePaymentStatus(orderNo);
|
|
|
|
|
|
|
+ //startPaymentResultCallback(orderNo);
|
|
|
} else {
|
|
} else {
|
|
|
log.error("失败 ====>Confirm {}", response.getRespData());
|
|
log.error("失败 ====>Confirm {}", response.getRespData());
|
|
|
}
|
|
}
|
|
@@ -339,6 +341,23 @@ public class RetrieveTTQFApi {
|
|
|
return response.isSuccess();
|
|
return response.isSuccess();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 异步检查打款状态
|
|
|
|
|
+ * @param orderNo
|
|
|
|
|
+ */
|
|
|
|
|
+ public static void startPaymentResultCallback(String orderNo){
|
|
|
|
|
+ try {
|
|
|
|
|
+ HashMap<String, String> hashMap = new HashMap<>();
|
|
|
|
|
+ hashMap.put("orderNo",orderNo);
|
|
|
|
|
+ QuartzManager manager = QuartzManager.getInstance();
|
|
|
|
|
+ manager.getContext().put("flag",true);
|
|
|
|
|
+ manager.addJob(orderNo,"jobGroup" + orderNo, RegularlyUpdateStatus.class,"*/5 * * * * ?",hashMap);
|
|
|
|
|
+ manager.start();
|
|
|
|
|
+ }catch (Exception e){
|
|
|
|
|
+ e.printStackTrace();
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
/**
|
|
/**
|
|
|
* 商户余额查询接口
|
|
* 商户余额查询接口
|
|
|
*/
|
|
*/
|