From 871d4095b07cedacb7fbef4c38d64982f539c404 Mon Sep 17 00:00:00 2001
From: fei.wang <wf18701153496@163.com>
Date: 星期四, 09 五月 2024 15:40:15 +0800
Subject: [PATCH] 测试提交

---
 src/main/java/com/flow/quartz/MyJob3.java |  118 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 118 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/flow/quartz/MyJob3.java b/src/main/java/com/flow/quartz/MyJob3.java
new file mode 100644
index 0000000..ac76318
--- /dev/null
+++ b/src/main/java/com/flow/quartz/MyJob3.java
@@ -0,0 +1,118 @@
+//
+// Source code recreated from a .class file by IntelliJ IDEA
+// (powered by FernFlower decompiler)
+//
+
+package com.flow.quartz;
+
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.flow.mapper.ManagerMapper;
+import com.flow.pojo.Card;
+import com.flow.pojo.Company;
+import com.flow.pojo.Duanxinlog;
+import com.flow.pojo.Manager;
+import com.flow.service.CardService;
+import com.flow.service.CompanyService;
+import com.flow.service.DuanxinlogService;
+import com.flow.util.DESUtil;
+import com.tencentcloudapi.common.Credential;
+import com.tencentcloudapi.common.exception.TencentCloudSDKException;
+import com.tencentcloudapi.common.profile.ClientProfile;
+import com.tencentcloudapi.common.profile.HttpProfile;
+import com.tencentcloudapi.sms.v20210111.SmsClient;
+import com.tencentcloudapi.sms.v20210111.models.SendSmsRequest;
+import com.tencentcloudapi.sms.v20210111.models.SendSmsResponse;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+import org.springframework.beans.factory.annotation.Autowired;
+
+public class MyJob3 {
+    private String SecretId = "AKIDrjZOI4e6KLZu9FAsSRN8eOwSt52lbMBz";
+    private String SecretKey = "xnRtHUL3YqdMyOLVSBjKkz1pQoxujS4d";
+    @Autowired
+    CardService cardService;
+    @Autowired
+    CompanyService companyService;
+
+    @Autowired
+    ManagerMapper managerMapper;
+
+    @Autowired
+    DuanxinlogService duanxinlogService;
+
+    public MyJob3() {
+    }
+
+    private void execute1() throws Exception {
+        List<Company> companies = this.companyService.findLength();
+
+        for(int i = 0; i < companies.size(); ++i) {
+            TimeUnit.SECONDS.sleep(10L);
+            String GsMc = ((Company)companies.get(i)).getCompanyname();
+            String GsPhone = DESUtil.decrypt(((Company)companies.get(i)).getPhone(), DESUtil.key);
+            System.out.println(GsPhone);
+            List<Card> cardList = this.cardService.findDaoQi1(GsMc);
+            String cardNum = "";
+            if (cardList.size() == 0) {
+                break;
+            }
+
+            for(int j = 0; j < cardList.size(); ++j) {
+                if (j == cardList.size() - 1) {
+                    cardNum = cardNum + ((Card)cardList.get(j)).getCardnumber();
+                } else {
+                    cardNum = cardNum + ((Card)cardList.get(j)).getCardnumber() + ";";
+                }
+            }
+
+            try {
+                Credential cred = new Credential(this.SecretId, this.SecretKey);
+                HttpProfile httpProfile = new HttpProfile();
+                httpProfile.setEndpoint("sms.tencentcloudapi.com");
+                ClientProfile clientProfile = new ClientProfile();
+                clientProfile.setHttpProfile(httpProfile);
+                SmsClient client = new SmsClient(cred, "ap-beijing", clientProfile);
+                SendSmsRequest req = new SendSmsRequest();
+                String[] phoneNumberSet1 = new String[]{GsPhone};
+                req.setPhoneNumberSet(phoneNumberSet1);
+                QueryWrapper sms = new QueryWrapper();
+                sms.eq("none", "0");
+                sms.eq("smsreception", "1");
+                List<Manager> managerList = (managerMapper).selectList(sms);
+                for (int s=0;s<managerList.size();s++){
+//                        System.out.println(managerList.get(s).getPhone());
+//                        phoneNumberSet1[s] = managerList.get(s).getPhone();
+                    String[] phoneNumberSet12  = {managerList.get(s).getPhone()};
+                    System.out.println(phoneNumberSet12);
+                    req.setPhoneNumberSet(phoneNumberSet12);
+
+                    req.setSmsSdkAppId("1400838975");
+                    req.setSignName("鍖椾含鍗庢槦鍖楁枟鏅烘帶");
+                    req.setTemplateId("1907853");
+
+//                    String[] templateParamSet1 = {String.valueOf(+num11 / 24 / 60 / 60 / 1000)};
+                    String[] templateParamSet1 = new String[]{cardNum};
+                    req.setTemplateParamSet(templateParamSet1);
+                    // 杩斿洖鐨剅esp鏄竴涓猄endSmsResponse鐨勫疄渚嬶紝涓庤姹傚璞″搴�
+                    SendSmsResponse resp = client.SendSms(req);
+                }
+                req.setSmsSdkAppId("1400838975");
+                req.setSignName("鍖椾含鍗庢槦鍖楁枟鏅烘帶");
+                req.setTemplateId("1878633");
+                String[] templateParamSet1 = new String[]{cardNum};
+                req.setTemplateParamSet(templateParamSet1);
+                SendSmsResponse resp = client.SendSms(req);
+                System.out.println(SendSmsResponse.toJsonString(resp));
+                Duanxinlog duanxinlog = new Duanxinlog();
+                duanxinlog.setIdentification(cardList.get(i).getCardnumber());
+                duanxinlog.setReceiver(cardList.get(i).getCompany());
+                duanxinlog.setNumber(GsPhone);
+//                duanxinlog.setContent("灏婃暚鐨勭敤鎴凤紝鎮ㄥソ锛佹偍鏈夋湇鍔″櫒灏嗕簬"+cardList.get(i).getEnddate()+"鍒版湡锛屼负閬垮厤褰卞搷鎮ㄧ殑姝e父浣跨敤璇峰強鏃剁画璐癸紝鎮ㄥ彲鐧诲綍鍗庢槦鏅烘帶鍏徃鐗╄仈缃戠鐞嗗钩鍙版煡璇㈣鎯呯画璐癸紝濡傛湁鐤戦棶鍙挩璇㈡垜鍏徃瀹㈡湇浜哄憳锛岀鎮ㄧ敓娲绘剦蹇紒");
+                this.duanxinlogService.addDuanxinlog(duanxinlog);
+            } catch (TencentCloudSDKException var15) {
+                System.out.println(var15.toString());
+            }
+        }
+
+    }
+}

--
Gitblit v1.9.3