From c313cc06a02705d249da8f40086e152d39108d4b Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期五, 06 十月 2023 15:30:52 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/crm/manager/controller/PlanController.java       |   18 +++-----
 src/main/java/com/zy/crm/manager/service/impl/SmsCodeServiceImpl.java |   24 ++++++++++++
 src/main/java/com/zy/crm/manager/service/SmsCodeService.java          |    1 
 src/main/java/com/zy/crm/manager/utils/SmsUtils.java                  |   38 +++++++++++++++++++
 4 files changed, 70 insertions(+), 11 deletions(-)

diff --git a/src/main/java/com/zy/crm/manager/controller/PlanController.java b/src/main/java/com/zy/crm/manager/controller/PlanController.java
index 8240376..c9f790d 100644
--- a/src/main/java/com/zy/crm/manager/controller/PlanController.java
+++ b/src/main/java/com/zy/crm/manager/controller/PlanController.java
@@ -12,11 +12,9 @@
 import com.core.common.R;
 import com.core.domain.KeyValueVo;
 import com.core.exception.CoolException;
-import com.zy.crm.common.entity.RouteCollectCountType;
 import com.zy.crm.common.model.SettleDto;
 import com.zy.crm.common.service.OssService;
 import com.zy.crm.common.utils.FileSaveExampleUtil;
-import com.zy.crm.common.utils.SetOfUtils;
 import com.zy.crm.common.web.BaseController;
 import com.zy.crm.manager.controller.result.FollowerTableVo;
 import com.zy.crm.manager.entity.*;
@@ -33,20 +31,11 @@
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
-import org.springframework.core.io.Resource;
-import org.springframework.core.io.FileSystemResource;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.MediaType;
-import org.springframework.http.ResponseEntity;
 
 import javax.servlet.http.HttpServletResponse;
-import java.io.File;
 import java.io.IOException;
 import java.io.InputStream;
 import java.util.*;
-
-import static java.util.stream.Collectors.toList;
 
 @RestController
 public class PlanController extends BaseController {
@@ -63,6 +52,8 @@
     private PriOnline2Service priOnline2Service;
     @Autowired
     private OrderService orderService;
+    @Autowired
+    private SmsCodeService smsCodeService;
 
     @GetMapping(value = "/plan/{id}/auth")
     @ManagerAuth
@@ -443,6 +434,11 @@
                 plan.setUpdateBy(getUserId());
                 plan.setUpdateTime(new Date());
 
+                boolean sendSmsCode = smsCodeService.sendSmsCodeText(planner.getMobile());
+                if (!sendSmsCode) {
+                    System.out.println("鐭俊鍙戦�佸け璐ワ紒");
+                }
+
                 if (!planService.updateById(plan)) {
                     throw new CoolException("瀹℃牳澶辫触锛岃鑱旂郴绠$悊鍛�");
                 }
diff --git a/src/main/java/com/zy/crm/manager/service/SmsCodeService.java b/src/main/java/com/zy/crm/manager/service/SmsCodeService.java
index 7afbde2..b839c03 100644
--- a/src/main/java/com/zy/crm/manager/service/SmsCodeService.java
+++ b/src/main/java/com/zy/crm/manager/service/SmsCodeService.java
@@ -8,6 +8,7 @@
     SmsCode selectByPhone(String phone);
 
     boolean sendSmsCode(String phone);
+    boolean sendSmsCodeText(String phone);
 
     boolean verifySmsCode(String phone, String code);
 
diff --git a/src/main/java/com/zy/crm/manager/service/impl/SmsCodeServiceImpl.java b/src/main/java/com/zy/crm/manager/service/impl/SmsCodeServiceImpl.java
index 571e3c7..8eba75a 100644
--- a/src/main/java/com/zy/crm/manager/service/impl/SmsCodeServiceImpl.java
+++ b/src/main/java/com/zy/crm/manager/service/impl/SmsCodeServiceImpl.java
@@ -1,5 +1,6 @@
 package com.zy.crm.manager.service.impl;
 
+import com.core.common.DateUtils;
 import com.core.common.R;
 import com.zy.crm.manager.mapper.SmsCodeMapper;
 import com.zy.crm.manager.entity.SmsCode;
@@ -42,6 +43,29 @@
     }
 
     @Override
+    public boolean sendSmsCodeText(String phone) {
+        String randomNum = "鍒嗛厤浜嗘柊鐨勮鍒掔敵璇峰崟浠诲姟锛�" ;//鑾峰彇鍏綅闅忔満鏁�
+        SmsCode smsCode = new SmsCode();
+        smsCode.setPhone(phone);
+        smsCode.setCode(randomNum);
+        smsCode.setStatus(0);
+        smsCode.setCreateTime(new Date());
+        if (this.baseMapper.insert(smsCode) <= 0) {
+            return false;
+        }
+
+        boolean sendSmsCode = SmsUtils.sendSmsCodeText(phone, "");
+        if (!sendSmsCode) {
+            return false;
+        }
+
+        smsCode.setSendTime(new Date());
+        smsCode.setStatus(1);
+        this.baseMapper.updateById(smsCode);
+        return true;
+    }
+
+    @Override
     public boolean verifySmsCode(String phone, String code) {
         SmsCode smsCode1 = this.baseMapper.selectByPhone(phone);
         if (smsCode1 == null) {
diff --git a/src/main/java/com/zy/crm/manager/utils/SmsUtils.java b/src/main/java/com/zy/crm/manager/utils/SmsUtils.java
index 55a5821..2a16160 100644
--- a/src/main/java/com/zy/crm/manager/utils/SmsUtils.java
+++ b/src/main/java/com/zy/crm/manager/utils/SmsUtils.java
@@ -52,6 +52,37 @@
         }
         return false;
     }
+    /**
+     * 闃块噷浜戝競鍦篈PI  鍒嗛厤浜嗘柊鐨勮鍒掔敵璇峰崟浠诲姟锛佽娉ㄦ剰鏌ユ敹锛�
+     */
+    private static boolean aliyun_2(String phone, String code) {
+        try {
+            HashMap<String, Object> headers = new HashMap<>();
+            HashMap<String, Object> param = new HashMap<>();
+
+            String APPCODE = "15ce5d8be5e348c7b680dfd7cfb8307e";
+            headers.put("Authorization", "APPCODE " + APPCODE);
+
+            param.put("templateId", "M6F3C81FE3");
+            param.put("receive", phone);
+            param.put("tag", code);
+
+            String response = new HttpHandler.Builder()
+                    .setUri("https://smkjdxtzjk.market.alicloudapi.com")
+                    .setPath("/standard/sms/send")
+                    .setHeaders(headers)
+                    .setParams(param)
+                    .build()
+                    .doPost();
+            JSONObject jsonObject = JSON.parseObject(response);
+            if (Integer.parseInt(jsonObject.get("code").toString()) == 200) {
+                return true;
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return false;
+    }
 
     private static AsyncClient getClient() {
         StaticCredentialProvider provider = StaticCredentialProvider.create(Credential.builder()
@@ -122,6 +153,13 @@
     }
 
     /**
+     * 鍙戦�佺煭淇�-闃块噷浜戝師鐢�
+     */
+    public static boolean sendSmsCodeText(String phone, String code) {
+        return aliyun_2(phone, code);
+    }
+
+    /**
      * 鑾峰彇闅忔満鏁�
      * @param length 闅忔満鏁伴暱搴�
      */

--
Gitblit v1.9.1