diff --git a/pluss-api-page/src/main/java/cn/pluss/platform/controller/merchant/callback/AuditCallbackController.java b/pluss-api-page/src/main/java/cn/pluss/platform/controller/merchant/callback/AuditCallbackController.java index a95577b..4eda885 100644 --- a/pluss-api-page/src/main/java/cn/pluss/platform/controller/merchant/callback/AuditCallbackController.java +++ b/pluss-api-page/src/main/java/cn/pluss/platform/controller/merchant/callback/AuditCallbackController.java @@ -2,6 +2,7 @@ package cn.pluss.platform.controller.merchant.callback; import cn.hutool.crypto.symmetric.DES; import cn.pluss.platform.channel.MerchantAuditService; +import cn.pluss.platform.channel.ys.YSAuditServiceV3; import cn.pluss.platform.entity.RyxAccessModel; import cn.pluss.platform.ryx.RyxService; import cn.pluss.platform.ys.impl.v20210929.YsConfigV2; @@ -15,6 +16,7 @@ import org.springframework.web.bind.annotation.*; import java.nio.charset.StandardCharsets; import java.util.Map; +import java.util.concurrent.ExecutorService; /** * @author DJH @@ -45,6 +47,10 @@ public class AuditCallbackController { @Autowired private YsConfigV2 ysConfig; + @Autowired + private YSAuditServiceV3 ysAuditServiceV3; + @Autowired + private ExecutorService executorService; @PostMapping("sxf") // TODO 后续需要接sxf的回调 @@ -75,6 +81,30 @@ public class AuditCallbackController { ysAuditServiceV2.merchantAuditCallback(respJson); return "success"; } + @PostMapping("/ysV3") + public String ysAuditCallbackV3(@RequestBody JSONObject result) throws Exception { + log.info("云商服V3进件接口回调参数:{},",result.toJSONString()); + executorService.execute(() -> { + try { + ysAuditServiceV3.callback(result); + } catch (Exception e) { + e.printStackTrace(); + } + }); + return "success"; + } + @PostMapping("/ysSignV3") + public String ysSignV3(@RequestBody JSONObject result) throws Exception { + log.info("云商服V3签约接口回调参数:{},",result.toJSONString()); + executorService.execute(() -> { + try { + ysAuditServiceV3.callback(result); + } catch (Exception e) { + e.printStackTrace(); + } + }); + return "success"; + } /** * 审核不通过的解密data数据 diff --git a/pluss-common-bundle/src/main/resources/config/application-ys.yml b/pluss-common-bundle/src/main/resources/config/application-ys.yml index 4dae38e..f940049 100644 --- a/pluss-common-bundle/src/main/resources/config/application-ys.yml +++ b/pluss-common-bundle/src/main/resources/config/application-ys.yml @@ -12,14 +12,14 @@ ys: ## 代理商编号 agentNo: ## 交易发起方编号 武汉融商创赢科技有限公司 - srcMerchantNo: + srcMerchantNo: 826521673920090 ## 私钥用于签名,对应的公钥给到银盛 - priKey: + priKey: MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQD2J82Gg79Tk8HZ9Zl7EOeLwvUn41c4ktUg6jveIhYLhT/PW5hpPAtgKXd9BvhtpfXhzbK6U9UURKhBgFIkQ+oIJQNfbB/F2jdVK9ke3IYi0/TXHMnY63x43qxciLeAOt+LxdhHn6ZImV4MsRkPjF/zLsaJrPOPWbc2m4T1yvinfzkrxhZaWn1dj4+IdyO3tA/juXCjydQqKR2kSqJlo6gdT9N3RIJ+ETda2UUahZyYXBfjyxFQEaOXthm6krZH1zBHs510Og6bQJQHjMmTskkslWvj38qPDfsuC4tq0Hgbu3LcyiX9vGYzQoGOaGhDEiNPObdDlOuh5gn0slRmg+PxAgMBAAECggEAJRvrCBRki50C5HD6Kmtp/M/vVYwYYhcAum2ViO9qk2ILNJ+CYpsCvASEVvzuBtm2L8xq3Vw2C1AubXGC8KSsa33o/EG4qIM1REnP+a8VKbr6dlOIuoMFyNMI+QpDX7mAafnxmRqgXuGAJDmupYFsFaU/mRHRxhKoZDsd2FA5HEbuDI9SJp86keE72NHsxyqfDIZyIk3Z8k7HZY2wg3FW+YaOKQBHVA9JYvhfZMeaQ1ymrA0IAqWpUqjLkqAa2Qa6xUsbj+QhvrkBCE48i8duamXKDSOaLfkqTb8IyxOM9eTsFwLVGEuZQrkhrLxdrg5aBPvu81pIJME6SgrquJJ84QKBgQD/MAFLiWU0wDJ4Hqf2jKa5vgrBmCqOsANBc079s8gDXM4zbsG/TjMHPDmiOGZxtDG8937twjYzRv9XpnqyITMArlhWWMhTOJ3r3CTVr/OISgeZKPGjfp+MbeDsOK4OggTVKZmNLx3nKiuc94IlTDOcz5qArVBTxKadWg56f1UGswKBgQD28G+haXxneMhRZozoHPjcfdgtDoZJaVa8XTXw8nvQala5ioU9yesbIAdtD/VR/eWwuMtO4rK1IFxtNZQ/MtSXwqlnKLf1xDJQPuj3kY5mC7H7sn4HGeFDP50VFnPgIaUnB5VwgyYFm8l19AW06OBjlnoBv0dnl1s5u+DgpzQcywKBgQCfeWSVzBtPR/1CTAYzcdqPoVAfg/S0jxK5yFHJAp0wXMMQKVszLq99CgoKcqyyyiV7LkBIXWJ50RipsgRjZZP2DP5vl7Q5LdyjFUR/tiG/PmRZNtkrj2ot3Ez/0rwTnPVgMUsgjB1n5Va0FYljvadTi/nGCIl2kCJ/m1QJAaIlOQKBgGV8TwRxS9ViiEEb+lDyhzxm488wpvPIvQLQ8/hAT65J5bZ/PV81etA9C5BA/Ltjs2A7siKLfJJ/6DxhxrlqdICiWeixjVkN9vePw0LrqTA7IjylELJuamuu2yntflXgvfUaYspIu/mWGufFEAtXodCL6TyKlhf21mEV28e4L+ydAoGAItgCUGbot95QNT1z+9QFN+18AvMnWCNvqanrC4qsk0phjYX9FFwfSCqWVeVm0Q0+2tUrRNcUEcbmlbQToBZq/hSu0nPcZIPvnNxLfW/NY7eVCXIcI5eNPjUIgbRCVMc6w5ukYMxPidOBuRXIt1iq2+iV20/FMbA58sY7AgOiaMw= ## 签名公钥,由银盛提供 pubKey: ## 付款验签公钥,由银盛提供 - oldPubKey: + oldPubKey: MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQC7SPkmIUf2auwkgbVchMyfeCDgICuA1GKrSwRbDI24UMVhzDgcIxCUmFG5/DfcPJz0d3oV9Ggkd4/7NmteRvmNnOOGNOnmR6AGEKafDpL1mAdpndmpkAZ0f6OVo3Py5JDg2wt8d+u3dF0AFWwd2rrrqscWvxJVB55DnuZfXl2CyQIDAQAB ## 进件URL前缀v2 auditDomainV2: https://ouser.ysepay.com:6443/ diff --git a/pluss-dao-bundle/src/main/java/cn/pluss/platform/mapper/MerchantBaseInfoMapper.java b/pluss-dao-bundle/src/main/java/cn/pluss/platform/mapper/MerchantBaseInfoMapper.java index b96b185..f342685 100644 --- a/pluss-dao-bundle/src/main/java/cn/pluss/platform/mapper/MerchantBaseInfoMapper.java +++ b/pluss-dao-bundle/src/main/java/cn/pluss/platform/mapper/MerchantBaseInfoMapper.java @@ -28,8 +28,10 @@ public interface MerchantBaseInfoMapper extends BaseMapper { @Select("SELECT * FROM tb_pluss_merchant_base_info WHERE userId = #{userId}") List selectListByUserId(@Param("userId") Serializable userId); + MerchantBaseInfo getByUserId(@Param("userId") String userId); - default MerchantBaseInfo queryMerchantBaseInfo(MerchantBaseInfo merchantBaseInfo) { + + default MerchantBaseInfo queryMerchantBaseInfo(MerchantBaseInfo merchantBaseInfo) { return selectOne(new QueryWrapper<>(merchantBaseInfo)); } diff --git a/pluss-dao-bundle/src/main/resources/mapper/MerchantBaseInfo-sqlmap.xml b/pluss-dao-bundle/src/main/resources/mapper/MerchantBaseInfo-sqlmap.xml index 5a0f8cf..3a2d14a 100644 --- a/pluss-dao-bundle/src/main/resources/mapper/MerchantBaseInfo-sqlmap.xml +++ b/pluss-dao-bundle/src/main/resources/mapper/MerchantBaseInfo-sqlmap.xml @@ -263,7 +263,12 @@ - +