| | |
| | | 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 com.dsh.guns.modular.system.util.PayMoneyUtil; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.context.annotation.Configuration; |
| | | import org.springframework.scheduling.annotation.EnableScheduling; |
| | |
| | | private IOperatorUserService operatorUserService; |
| | | @Autowired |
| | | private IUserService userService; |
| | | @Autowired |
| | | private PayMoneyUtil payMoneyUtil; |
| | | private String appPrivateKey = "MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQCi5i9nW/hGLJ3A06cZxTQdviFC7THpdSihoTYGLr9q006hu0V26ecBMY/o4w5bvIX0Ok/yofmZsVcCJpAPvbXL/uqVrIjnRRxXiaeBFThlxoBUTdunvbUSDYfzlEhJr5NvUKI6H6lz2niXlQGx4qy8Hau4ccWit9kM8jwUvsBVQoFgJA+xrjMvooA7YLopQtpOD+UJr5thApTSf1xrnr1W12yolTLEH15JmNV372cqXrYUuqnY0QsaPtxeqJUGAOcGdVLllQ7easEznP8DFBvDdHATcmp2SHNQDUEWN6MCVPbMgY06NQVqAXxqjTAYSVh+6TRu6bofPmpYC3TZB003AgMBAAECggEBAJAcR2+PA3NBYUYHeFrqBRMS8uX8ZR19kjZ7IgoSLTFaQsP9opRylPSPXhrPVBKAE5leRQAHn4MCSlESwHvMfxo7KFjFTFAc6dffZZpipYQUOc9bGampwJh58/3e/pyBgVMG6J23CPf/HJQtNFSkjd/V9+ayb/9l2dUEL3bC0fAZ/dbx8HsxdLw8wn3fLlWLj68hOMqa2deCZe3JdSVsPbeWqkh56FFsMLug0Nd+Ar4TgRl9/jnhXF0JWiD0LmPUYLhboY7EfUBzN4w1iYbDi1P+3zvoOYsiVKAXox9GMhQ2VzOO2UcSTuizSza2e98mGpabl/GpKmCz+RDFjtkX6eECgYEA2MyCij65eO3aGIm3FUe93DULRBYTfX8qJQSJq2WOWA3mmQlEW6L3O2B5/lG2h+8WmN6iLEs9eHpgycGYp7vAqgrANEn16ACVcuyx0scFtrZfZ+kmHMzFfiUWxJjVYk/6YngsGVBLdw6ueM42C8TTP67X9tU5TdVGoGWuqEj4W98CgYEAwFqwprXOch5Pqk/RPbb49r0Ou03K/UbciWnWWKzUhFFNS8MdlQPoDvQZbMwHLeWsa2VhaKITK3x5biLQb3U+0GLOn6lTvEyrEUH+ucREyLgVYTRAvwBPtnvlrzpyxPk2HnslQjju8WrvvLLBMKWUjlTrTOzhaHT21gz3pHMiOakCgYEAhLmfaXdBITGshb054sNLDtdCkGpbgEcrzAHdLps769iGxkYQHXHFngpQZUwtTUcoNGqIKknd1jZFrv7gsD+XkgKG7PwimehRlkwmCX5ilxtLiVgJRzRt6+5U5AMVD90a0tHzXYP0z2yjj73fBJF5KtGl0a10KZxaYrQdm1UhB00CgYBZZgzx/k9rtHC8LAqIj1CYhHejT92G53c6Gkl3vyOqN4sgKhfGmSEySfrDGPRBPZxr8ZtbIPCd5mUdberH0osWGMYFaJI1UsCy7aQwvGpniz7MhZeN7dweaOjwDs8mgtjHQ96mL4XGCDhR0BZ/wIURvZ/6iaGdhbbu9unlsWj3uQKBgQCmZYdsbbZkd3ev6f8rwyvMz+DrCQyYpY44cegBYuJgrZiQnL2fJioeN7ixX0UM48SfwsZEIrzshP/LGAwnc2MdjxKUl4jLN8SEe0NAjXOnz9Zaw740+aOmLpXcLWdP4uM2gIhWsvW1tEkQZCXmm7c9s/RsU8Pmzv+YL3+fSijOzA==";//支付宝开发者应用私钥 |
| | | private String alipay_public_key = "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAmu8n/4yTHWbn7VOrNc9OsLtDL1bEQ8gC1dHkj8Wy5z0mkaOsjJRIG/28ze12M0V8jdCKuuDr5Z1OPKiqf+XO3ypguEh+mYUVMBM/cZodDFQfTY1TKLWjvQCuaqlA+QUTCK6f7T7stsgyQ1o9Jj0rXZDz6PM4QHSTzjrLIBaeqM5WIBvH+fy/X+QG5Utd+/UT0kc0JyvuKhZ65yVUd/C9VcwJJAPliRsAQNrqYterwAJ9zvw9tF11wj9W0XgJ8Ccu4x3gR1vrlLRJJo/OA97RmxPQ+5hSacWQZCUd1dwiBq+YCrKVHGTj14izRHXrLc0yBlRXo7tBOIqcy3IsvKVthQIDAQAB";//支付宝支付公钥 |
| | | private String aliAppid = "2021004105665036";//支付宝appid |
| | | // 一个小时执行一次 |
| | | @Scheduled(fixedRate=600000) |
| | | @Scheduled(fixedRate=60000) |
| | | private void configureTasks() { |
| | | List<OperatorAuthAlipay> list = operatorAuthService.list(new QueryWrapper<OperatorAuthAlipay>()); |
| | | for (OperatorAuthAlipay operatorAuthAlipay : list) { |
| | | System.err.println("执行定时任务时间: " + LocalDateTime.now()); |
| | | AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", |
| | | aliAppid, |
| | | appPrivateKey, "json", "GBK", |
| | | alipay_public_key, |
| | | "RSA2"); |
| | | AntMerchantExpandIndirectZftorderQueryRequest request = new AntMerchantExpandIndirectZftorderQueryRequest(); |
| | | request.setBizContent("{" + |
| | | " \"order_id\":\"" + operatorAuthAlipay.getOrderNo() + "\"," + |
| | | " \"external_id\":\"" + operatorAuthAlipay.getOutBizNo() + "\"" + |
| | | "}"); |
| | | AntMerchantExpandIndirectZftorderQueryResponse response = null; |
| | | try { |
| | | response = alipayClient.execute(request); |
| | | } catch (AlipayApiException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | if (response.isSuccess()) { |
| | | System.out.println("调用成功"); |
| | | JSONObject json = JSONObject.parseObject(response.getBody()); |
| | | System.err.println(json); |
| | | JSONObject sign = json.getJSONObject("ant_merchant_expand_indirect_zftorder_query_response"); |
| | | JSONArray orders = sign.getJSONArray("orders"); |
| | | JSONObject order = orders.getJSONObject(0); |
| | | // 提取订单信息 |
| | | String reason = order.getString("reason"); |
| | | String smid = order.getString("smid"); |
| | | String merchantName = order.getString("merchant_name"); |
| | | String applyTime = order.getString("apply_time"); |
| | | String externalId = order.getString("external_id"); |
| | | String orderId = order.getString("order_id"); |
| | | String applyType = order.getString("apply_type"); |
| | | String status = order.getString("status"); |
| | | // 打印订单信息 |
| | | System.out.println("Reason: " + reason); |
| | | System.out.println("Merchant Name: " + merchantName); |
| | | System.out.println("Apply Time: " + applyTime); |
| | | System.out.println("External ID: " + externalId); |
| | | System.out.println("Order ID: " + orderId); |
| | | System.out.println("Apply Type: " + applyType); |
| | | System.out.println("Status: " + status); |
| | | } else { |
| | | System.out.println("调用失败"); |
| | | } |
| | | } |
| | | // payMoneyUtil.getMessage(); |
| | | // List<OperatorAuthAlipay> list = operatorAuthService.list(new QueryWrapper<OperatorAuthAlipay>()); |
| | | // for (OperatorAuthAlipay operatorAuthAlipay : list) { |
| | | // System.err.println("执行定时任务时间: " + LocalDateTime.now()); |
| | | // AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do", |
| | | // aliAppid, |
| | | // appPrivateKey, "json", "GBK", |
| | | // alipay_public_key, |
| | | // "RSA2"); |
| | | // AntMerchantExpandIndirectZftorderQueryRequest request = new AntMerchantExpandIndirectZftorderQueryRequest(); |
| | | // request.setBizContent("{" + |
| | | // " \"order_id\":\"" + operatorAuthAlipay.getOrderNo() + "\"," + |
| | | // " \"external_id\":\"" + operatorAuthAlipay.getOutBizNo() + "\"" + |
| | | // "}"); |
| | | // AntMerchantExpandIndirectZftorderQueryResponse response = null; |
| | | // try { |
| | | // response = alipayClient.execute(request); |
| | | // } catch (AlipayApiException e) { |
| | | // e.printStackTrace(); |
| | | // } |
| | | // if (response.isSuccess()) { |
| | | // System.out.println("调用成功"); |
| | | // JSONObject json = JSONObject.parseObject(response.getBody()); |
| | | // System.err.println(json); |
| | | // JSONObject sign = json.getJSONObject("ant_merchant_expand_indirect_zftorder_query_response"); |
| | | // JSONArray orders = sign.getJSONArray("orders"); |
| | | // JSONObject order = orders.getJSONObject(0); |
| | | // // 提取订单信息 |
| | | // String reason = order.getString("reason"); |
| | | // String smid = order.getString("smid"); |
| | | // String merchantName = order.getString("merchant_name"); |
| | | // String applyTime = order.getString("apply_time"); |
| | | // String externalId = order.getString("external_id"); |
| | | // String orderId = order.getString("order_id"); |
| | | // String applyType = order.getString("apply_type"); |
| | | // String status = order.getString("status"); |
| | | // // 打印订单信息 |
| | | // System.out.println("Reason: " + reason); |
| | | // System.out.println("Merchant Name: " + merchantName); |
| | | // System.out.println("Apply Time: " + applyTime); |
| | | // System.out.println("External ID: " + externalId); |
| | | // System.out.println("Order ID: " + orderId); |
| | | // System.out.println("Apply Type: " + applyType); |
| | | // System.out.println("Status: " + status); |
| | | // } else { |
| | | // System.out.println("调用失败"); |
| | | // } |
| | | // } |
| | | |
| | | |
| | | |