src/main/java/com/zy/crm/manager/controller/PlanController.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/crm/manager/service/SmsCodeService.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/crm/manager/service/impl/SmsCodeServiceImpl.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 | |
src/main/java/com/zy/crm/manager/utils/SmsUtils.java | ●●●●● 补丁 | 查看 | 原始文档 | 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 随机数长度 */