package com.dsh.guns.modular.system.api;
|
|
import cn.hutool.core.io.FileUtil;
|
import com.alibaba.fastjson.JSONObject;
|
import com.alipay.api.msg.AlipayMsgClient;
|
import com.alipay.api.msg.MsgHandler;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.dsh.guns.modular.system.model.OperatorAuthAlipay;
|
import com.dsh.guns.modular.system.model.OperatorUser;
|
import com.dsh.guns.modular.system.service.IOperatorAuthService;
|
import com.dsh.guns.modular.system.service.IOperatorUserService;
|
import com.dsh.guns.modular.system.service.IUserService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.context.properties.EnableConfigurationProperties;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.stereotype.Component;
|
|
@Component
|
@Configuration
|
@EnableConfigurationProperties({AliPayProperties.class})
|
public class AliPayMsgConfig {
|
@Autowired
|
private IOperatorAuthService operatorAuthService;
|
@Autowired
|
private IOperatorUserService operatorUserService;
|
@Autowired
|
private IUserService userService;
|
private AliPayProperties aliPay;
|
public AliPayMsgConfig(AliPayProperties aliPay) {
|
this.aliPay = aliPay;
|
}
|
@Bean
|
public AlipayMsgClient alipayMsgClient() throws Exception {
|
AlipayMsgClient alipayMsgClient = AlipayMsgClient.getInstance(aliPay.getAppId());
|
alipayMsgClient.setConnector("openchannel.alipay.com");
|
alipayMsgClient.setSecurityConfig(aliPay.getSignType(), aliPay.getAppPrivateKey(), aliPay.getAlipay_public_key());
|
alipayMsgClient.setCharset(aliPay.getChartSet());
|
alipayMsgClient.setMessageHandler(new MsgHandler() {
|
/**
|
* 客户端接收到消息后回调此方法
|
* @param msgApi 接收到的消息的消息api名
|
* @param msgId 接收到的消息的消息id
|
* @param bizContent 接收到的消息的内容，json格式
|
*/
|
@Override
|
public void onMessage (String msgApi, String msgId, String bizContent) {
|
System.err.println(" 消息对象"+msgApi);
|
System.err.println("id"+msgId);
|
System.err.println("内容"+bizContent);
|
if (msgApi.equals("ant.merchant.expand.indirect.zft.passed")){
|
// 审核通过
|
JSONObject json = JSONObject.parseObject(bizContent);
|
String smid = json.getString("smid");
|
String order_id = json.getString("order_id");
|
OperatorAuthAlipay orderNo = operatorAuthService.getOne(new QueryWrapper<OperatorAuthAlipay>()
|
.eq("orderNo", order_id));
|
if (orderNo!=null){
|
Integer operatorId = orderNo.getOperatorId();
|
OperatorUser operatorId1 = operatorUserService.getOne(new QueryWrapper<OperatorUser>()
|
.eq("operatorId", operatorId));
|
if (operatorId1!=null){
|
operatorId1.setAlipayNum(smid);
|
operatorId1.setAlipayAudit(2);
|
}
|
}
|
}else if (msgApi.equals("ant.merchant.expand.indirect.zft.rejected")){
|
// 审核拒绝
|
JSONObject json = JSONObject.parseObject(bizContent);
|
String reason = json.getString("reason");
|
String order_id = json.getString("order_id");
|
OperatorAuthAlipay orderNo = operatorAuthService.getOne(new QueryWrapper<OperatorAuthAlipay>()
|
.eq("orderNo", order_id));
|
if (orderNo!=null){
|
orderNo.setRefuseReason(reason);
|
operatorAuthService.updateById(orderNo);
|
Integer operatorId = orderNo.getOperatorId();
|
OperatorUser operatorId1 = operatorUserService.getOne(new QueryWrapper<OperatorUser>()
|
.eq("operatorId", operatorId));
|
if (operatorId1!=null){
|
operatorId1.setAlipayAudit(3);
|
operatorUserService.updateById(operatorId1);
|
}
|
}
|
}
|
|
}
|
});
|
alipayMsgClient.connect();
|
return alipayMsgClient;
|
}
|
}
|
