package com.dsh.guns.modular.system.api;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.alipay.api.AlipayApiException;
|
import com.alipay.api.AlipayClient;
|
import com.alipay.api.DefaultAlipayClient;
|
import com.alipay.api.domain.PrivilegeBenefit;
|
import com.alipay.api.request.AlipayMerchantIndirectAuthorderCloseRequest;
|
import com.alipay.api.request.AlipayMerchantIndirectAuthorderQuerystatusRequest;
|
import com.alipay.api.response.AlipayMerchantIndirectAuthorderCloseResponse;
|
import com.alipay.api.response.AlipayMerchantIndirectAuthorderQuerystatusResponse;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.dsh.guns.modular.system.model.OperatorAuth;
|
import com.dsh.guns.modular.system.model.OperatorUser;
|
import com.dsh.guns.modular.system.model.User;
|
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.context.annotation.Configuration;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
import java.time.LocalDateTime;
|
import java.util.List;
|
|
@Configuration //1.主要用于标记配置类，兼备Component的效果。
|
@EnableScheduling // 2.开启定时任务
|
public class SaticScheduleTask {
|
@Autowired
|
private IOperatorAuthService operatorAuthService;
|
@Autowired
|
private IOperatorUserService operatorUserService;
|
@Autowired
|
private IUserService userService;
|
// 一个小时执行一次
|
@Scheduled(fixedRate=3600000)
|
private void configureTasks() {
|
System.err.println("执行定时任务时间: " + LocalDateTime.now());
|
// 回查商户认证单审核状态 查询除了审核通过以外的认证单
|
List<OperatorAuth> list = operatorAuthService.list(new QueryWrapper<OperatorAuth>().ne("orderStatus", "AUDIT_PASS"));
|
AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do","2021004123692417",
|
"MIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQCq1V7akWZ/V9mr8NGW2CihIbY93M7M33LpVM5y63qEuN7yqyJV197WT6c7uHBcttY6cJLawXLihgC8KF6ZzdXWbm4n4RiigxIaz9LbSVBjYplkNgG2rg7W7dB8wrrqcwBQU0n+pFX3KWJkHRXDugqE21VCGgzySKQBkhiztmTI/z039PdWp2RTGLiL/OuwVrPjQv3He2orYIZgADWid0mtZXCEFosDkaQDTEqCfuDEuMouEiaIk/lw0ZWxiR1Fvfr82nO0r94lM/CC1wNRif2+2ESR+YystsWQPm16eRgS3wAQz2cOTP4L5VNKNzcUAgxTQK3Bj8GvqrYUUlcC7VCTAgMBAAECggEAPKmYDTUkmIOxoATb6BzKEK3P8Re/t7CBNaoPxW8pCog7YyCyCJmnX6LZV7Oe8s1aNVZUT6nyCc5b5HTRYvxcutBr/W1JOiwg+bRiw8u86A3TOmqTITOdwWShbCwaA7binaN12x6wCByB+9r4J5Cgu5zHIbnubvqsgoJGk0ppb5XbyYkikOAXPHli4PUe4GOorSuhRdq3XlGWiMwh4yt48kF4vP+2ByuDOYQU6LjGs0wn/5LpN+ReLdXTab65Cz7WYTDrTndyIrhFg7cyT5m2gtiJuEgIJ45uaaeGNIecV6JSnRsEv4YD4m+I58yhyyvw9zd0Z5qP04QNjy7OK2UeQQKBgQD/EJpaVv0RR83Z6Hp2YVrPoiMz279U5bgkBbcxgr9GR2YYE3rrHqBdqch1Uitu+g6LIC+SDtib7yG9C7EqPHB3fsfEw8NtL54gy3OFbCcH3lqFxgtrCpQ2SIXQjd8932TpzcMdD6jzyUoSraT+lgkf2MgjqFiMbNVg50lGDyWujQKBgQCrdbXTttuazdwU0pdRFCuTz42iIJSZtHFUPvmbrBy7LFQ8NTN76dqLM1RUH7gJukPc4+Ax+DfpDgHZ4nQ2KSk9FweLqKSf10kojibKpc3nkgDRtUtSTar8fZn9VKTuXK1Ho0LUkjDlHjlEwUuf/Ef+IdjzXDJ2UPWHp2YzxvNDnwKBgBWGtjAnpUX/FF1upF83Si251lS7GAO3O3o2zUYtba0lu3UOt9H+DLS67oMQQ0AjdHTDa6BdBmTqoqNMyE/zN96t4Xg2uViOqz7DTOWWwhiE6IjftPj8tJN8PWbjglK7ds3QosXiG3UvqMO4yfL+gJiieAmiXI7FZKDABEwYXSrFAoGASXVe91vKbmJwPgOTjMsleGhd9+4ZfFjQjRWF/2oXzSFK3Zi1fAtO9ICDSp9kS9afqI2AyifcXF8B8AWTYHj2EBRDyVPxZAHqeBOfDwdGVkY5T59qq9JWxWJSjTSsjOrr2ltaEJSpmh/+zTQ7YEnH1ltOBcWkYQiCiSHxKZG9O2UCgYBfBTkjktzv81SnW47d0qRwmiXrcyObmXTe5fIW9e6KaB0SnzcVvoCmm7TTk+Bm4WqNmfb5k8U6J22vdxB1TPlRksnY+VZDM0Grv/xUII9G8oVQ4+NiE5XvQ7+nc5EBJ12of6GxE7/yXZiDld62q2sFZgrFzhvvHV+IADsu/VdIEw==","json","GBK",
|
"MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEApCzq4BIE4gMdEXxIAAUbiMpSytkzp+LVLVsBtji87rFGfWUcnrr3NKftaw0WtRu+36d1nDVOWW4CmgsOPyj1GOFoTcJOR/BqyIriwyLxpuMS8qgOqGJZXi+W4Nw2AJL6iMVwY2eI8F1G10gACK2I9TNJRzHh3tMTA6ItysbGoekRDtn6Xrkh5V6cyHQjLw0Q6MJK/68XT6/LWzarDEEYrSnIevOydMY32ptAgm5fp/h08M2khCmI6CuMWKmc87dPpd2krGVTALqprAQvB74AIqO+5DE0fN4LoitOYXAtWDCEF4kHN0hQUygIEGCwtMgEVzkf92VLlCX35YtDhWd1yQIDAQAB","RSA2");
|
for (OperatorAuth operatorAuth : list) {
|
// 第三步：查询申请单审核结果
|
AlipayMerchantIndirectAuthorderQuerystatusRequest request1 = new AlipayMerchantIndirectAuthorderQuerystatusRequest();
|
request1.setBizContent("{" +
|
" \"order_no\":\""+operatorAuth.getOrderNo()+"\"," +
|
" \"out_biz_no\":\""+operatorAuth.getOutBizNo()+"\"," +
|
"}");
|
AlipayMerchantIndirectAuthorderQuerystatusResponse response1 = null;
|
try {
|
response1 = alipayClient.execute(request1);
|
} catch (AlipayApiException e) {
|
e.printStackTrace();
|
}
|
if(response1.isSuccess()){
|
System.out.println("调用成功");
|
} else {
|
System.out.println("调用失败");
|
}
|
JSONObject json = JSONObject.parseObject(response1.getBody());
|
JSONObject sign = json.getJSONObject("alipay_merchant_indirect_authorder_querystatus_response");
|
String orderNo = sign.getString("order_no");
|
String order_status = sign.getString("order_status");
|
operatorAuth.setOrderStatus(order_status);
|
operatorAuth.setOrderNo(orderNo);
|
// 失败原因
|
JSONArray verify_list = sign.getJSONArray("verify_list");
|
StringBuilder reason = new StringBuilder("");
|
// 失败原因
|
if (verify_list!=null){
|
for (int i = 0; i < verify_list.size(); i++) {
|
JSONObject jsonObject = verify_list.getJSONObject(i);
|
String fail_reason = jsonObject.getString("fail_reason");
|
reason.append(fail_reason+",");
|
}
|
String res = reason.toString();
|
String substring = res.substring(0, res.length() - 1);
|
operatorAuth.setRefuseReason(substring);
|
operatorAuthService.updateById(operatorAuth);
|
// 获取运营商的管理员id
|
Integer operatorId = operatorAuth.getOperatorId();
|
User one = userService.getOne(new QueryWrapper<User>().eq("objectId", operatorId)
|
.eq("objectType", 2));
|
/**
|
* 状态 1=审核中(AUDITING)、2=待联系人确认（CONTACT_CONFIRM），
|
* 3=待法人确认（LEGAL_CONFIRM）、4=审核通过(AUDIT_PASS)、
|
* 5=审核失败(AUDIT_REJECT)、6=已冻结(AUDIT_FREEZE)、
|
* 7=已撤回(CANCELED)、8=联系人处理中(CONTACT_PROCESSING)
|
*/
|
// 失败修改审核状态
|
OperatorUser userId = operatorUserService.getOne(new QueryWrapper<OperatorUser>()
|
.eq("userId", one.getId()));
|
if (userId!=null){
|
switch (order_status){
|
case "AUDITING":
|
userId.setAlipayAudit(1);
|
break;
|
case "CONTACT_CONFIRM":
|
userId.setAlipayAudit(2);
|
break;
|
case "LEGAL_CONFIRM":
|
userId.setAlipayAudit(3);
|
break;
|
case "AUDIT_PASS":
|
userId.setAlipayAudit(4);
|
break;
|
case "AUDIT_REJECT":
|
userId.setAlipayAudit(5);
|
break;
|
case "AUDIT_FREEZE":
|
userId.setAlipayAudit(6);
|
break;
|
case "CANCELED":
|
userId.setAlipayAudit(7);
|
break;
|
case "CONTACT_PROCESSING":
|
userId.setAlipayAudit(8);
|
break;
|
}
|
operatorUserService.updateById(userId);
|
}
|
|
|
|
}
|
// 审核通过
|
String qr_code = sign.getString("qr_code");
|
if (qr_code!=null&& (!qr_code.equals(""))){
|
// 将二维码链接保存起来
|
operatorAuth.setQrCode(qr_code);
|
operatorAuthService.updateById(operatorAuth);
|
}
|
if (operatorAuth.getOrderStatus().equals("AUDIT_REJECT")
|
|| operatorAuth.getOrderStatus().equals("AUDIT_FREEZE")
|
|| operatorAuth.getOrderStatus().equals("CANCELED")){
|
// 未通过审核 撤销申请单
|
AlipayClient alipayClient1 = new DefaultAlipayClient
|
("https://openapi.alipay.com/gateway.do",
|
"2021004123692417","MIIEvAIBADANBgkqhkiG9w0BAQEFAASCBKYwggSiAgEAAoIBAQCq1V7akWZ/V9mr8NGW2CihIbY93M7M33LpVM5y63qEuN7yqyJV197WT6c7uHBcttY6cJLawXLihgC8KF6ZzdXWbm4n4RiigxIaz9LbSVBjYplkNgG2rg7W7dB8wrrqcwBQU0n+pFX3KWJkHRXDugqE21VCGgzySKQBkhiztmTI/z039PdWp2RTGLiL/OuwVrPjQv3He2orYIZgADWid0mtZXCEFosDkaQDTEqCfuDEuMouEiaIk/lw0ZWxiR1Fvfr82nO0r94lM/CC1wNRif2+2ESR+YystsWQPm16eRgS3wAQz2cOTP4L5VNKNzcUAgxTQK3Bj8GvqrYUUlcC7VCTAgMBAAECggEAPKmYDTUkmIOxoATb6BzKEK3P8Re/t7CBNaoPxW8pCog7YyCyCJmnX6LZV7Oe8s1aNVZUT6nyCc5b5HTRYvxcutBr/W1JOiwg+bRiw8u86A3TOmqTITOdwWShbCwaA7binaN12x6wCByB+9r4J5Cgu5zHIbnubvqsgoJGk0ppb5XbyYkikOAXPHli4PUe4GOorSuhRdq3XlGWiMwh4yt48kF4vP+2ByuDOYQU6LjGs0wn/5LpN+ReLdXTab65Cz7WYTDrTndyIrhFg7cyT5m2gtiJuEgIJ45uaaeGNIecV6JSnRsEv4YD4m+I58yhyyvw9zd0Z5qP04QNjy7OK2UeQQKBgQD/EJpaVv0RR83Z6Hp2YVrPoiMz279U5bgkBbcxgr9GR2YYE3rrHqBdqch1Uitu+g6LIC+SDtib7yG9C7EqPHB3fsfEw8NtL54gy3OFbCcH3lqFxgtrCpQ2SIXQjd8932TpzcMdD6jzyUoSraT+lgkf2MgjqFiMbNVg50lGDyWujQKBgQCrdbXTttuazdwU0pdRFCuTz42iIJSZtHFUPvmbrBy7LFQ8NTN76dqLM1RUH7gJukPc4+Ax+DfpDgHZ4nQ2KSk9FweLqKSf10kojibKpc3nkgDRtUtSTar8fZn9VKTuXK1Ho0LUkjDlHjlEwUuf/Ef+IdjzXDJ2UPWHp2YzxvNDnwKBgBWGtjAnpUX/FF1upF83Si251lS7GAO3O3o2zUYtba0lu3UOt9H+DLS67oMQQ0AjdHTDa6BdBmTqoqNMyE/zN96t4Xg2uViOqz7DTOWWwhiE6IjftPj8tJN8PWbjglK7ds3QosXiG3UvqMO4yfL+gJiieAmiXI7FZKDABEwYXSrFAoGASXVe91vKbmJwPgOTjMsleGhd9+4ZfFjQjRWF/2oXzSFK3Zi1fAtO9ICDSp9kS9afqI2AyifcXF8B8AWTYHj2EBRDyVPxZAHqeBOfDwdGVkY5T59qq9JWxWJSjTSsjOrr2ltaEJSpmh/+zTQ7YEnH1ltOBcWkYQiCiSHxKZG9O2UCgYBfBTkjktzv81SnW47d0qRwmiXrcyObmXTe5fIW9e6KaB0SnzcVvoCmm7TTk+Bm4WqNmfb5k8U6J22vdxB1TPlRksnY+VZDM0Grv/xUII9G8oVQ4+NiE5XvQ7+nc5EBJ12of6GxE7/yXZiDld62q2sFZgrFzhvvHV+IADsu/VdIEw==",
|
"json","GBK",
|
"MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEApCzq4BIE4gMdEXxIAAUbiMpSytkzp+LVLVsBtji87rFGfWUcnrr3NKftaw0WtRu+36d1nDVOWW4CmgsOPyj1GOFoTcJOR/BqyIriwyLxpuMS8qgOqGJZXi+W4Nw2AJL6iMVwY2eI8F1G10gACK2I9TNJRzHh3tMTA6ItysbGoekRDtn6Xrkh5V6cyHQjLw0Q6MJK/68XT6/LWzarDEEYrSnIevOydMY32ptAgm5fp/h08M2khCmI6CuMWKmc87dPpd2krGVTALqprAQvB74AIqO+5DE0fN4LoitOYXAtWDCEF4kHN0hQUygIEGCwtMgEVzkf92VLlCX35YtDhWd1yQIDAQAB","RSA2");
|
AlipayMerchantIndirectAuthorderCloseRequest request = new AlipayMerchantIndirectAuthorderCloseRequest();
|
request.setBizContent("{" +
|
" \"order_no\":\""+operatorAuth.getOrderNo()+"\"," +
|
" \"out_biz_no\":\""+operatorAuth.getOutBizNo()+"\"" +
|
"}");
|
AlipayMerchantIndirectAuthorderCloseResponse response = null;
|
try {
|
response = alipayClient1.execute(request);
|
} catch (AlipayApiException e) {
|
e.printStackTrace();
|
}
|
if(response.isSuccess()){
|
System.out.println("撤销申请单调用成功");
|
} else {
|
System.out.println("撤销申请单调用失败");
|
}
|
}
|
|
}
|
}
|
|
}
|
