中扬CRM客户关系管理系统
#
LSH
2023-10-06 c313cc06a02705d249da8f40086e152d39108d4b
#
4个文件已修改
81 ■■■■ 已修改文件
src/main/java/com/zy/crm/manager/controller/PlanController.java 18 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/crm/manager/service/SmsCodeService.java 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/crm/manager/service/impl/SmsCodeServiceImpl.java 24 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/crm/manager/utils/SmsUtils.java 38 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
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("审核失败,请联系管理员");
                }
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);
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) {
src/main/java/com/zy/crm/manager/utils/SmsUtils.java
@@ -52,6 +52,37 @@
        }
        return false;
    }
    /**
     * 阿里云市场API  分配了新的规划申请单任务!请注意查收!
     */
    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 随机数长度
     */