From e15f561a1f9eddfde503d59baf45a860b131928e Mon Sep 17 00:00:00 2001
From: fei.wang <wf18701153496@163.com>
Date: 星期三, 13 八月 2025 14:22:50 +0800
Subject: [PATCH] 更新最新版代码

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

diff --git a/src/main/java/com/flow/quartz/MyJob3.java b/src/main/java/com/flow/quartz/MyJob3.java
index df6c149..473a1e3 100644
--- a/src/main/java/com/flow/quartz/MyJob3.java
+++ b/src/main/java/com/flow/quartz/MyJob3.java
@@ -5,10 +5,15 @@
 
 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;
@@ -29,6 +34,12 @@
     @Autowired
     CompanyService companyService;
 
+    @Autowired
+    ManagerMapper managerMapper;
+
+    @Autowired
+    DuanxinlogService duanxinlogService;
+
     public MyJob3() {
     }
 
@@ -38,42 +49,72 @@
         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);
+            String GsPhone = DESUtil.decrypt(((Company)companies.get(i)).getLoginphone(), DESUtil.key);
             System.out.println(GsPhone);
-            List<Card> cardList = this.cardService.findDaoQi1(GsMc);
-            String cardNum = "";
-            if (cardList.size() == 0) {
-                break;
-            }
+            for (int p = 0;p < GsPhone.split("[,锛宂").length; p++) {
+                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() + ";";
+                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.split("[,锛宂")[p]};
+                    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.split("[,锛宂")[p]);
+//                duanxinlog.setContent("灏婃暚鐨勭敤鎴凤紝鎮ㄥソ锛佹偍鏈夋湇鍔″櫒灏嗕簬"+cardList.get(i).getEnddate()+"鍒版湡锛屼负閬垮厤褰卞搷鎮ㄧ殑姝e父浣跨敤璇峰強鏃剁画璐癸紝鎮ㄥ彲鐧诲綍鍗庢槦鏅烘帶鍏徃鐗╄仈缃戠鐞嗗钩鍙版煡璇㈣鎯呯画璐癸紝濡傛湁鐤戦棶鍙挩璇㈡垜鍏徃瀹㈡湇浜哄憳锛岀鎮ㄧ敓娲绘剦蹇紒");
+                    this.duanxinlogService.addDuanxinlog(duanxinlog);
+                } catch (TencentCloudSDKException var15) {
+                    System.out.println(var15.toString());
                 }
             }
 
-            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);
-                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));
-            } catch (TencentCloudSDKException var15) {
-                System.out.println(var15.toString());
-            }
         }
 
     }

--
Gitblit v1.9.3