From f31fc9f42f78de0808e7f4bdc797c5e622df09e3 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 10 Jun 2026 11:22:37 +0800
Subject: [PATCH] 1
---
trading-order-service/src/main/java/com/yami/trading/service/impl/IdentifyingCodeServiceImpl.java | 136 +++------------------------------------------
1 files changed, 9 insertions(+), 127 deletions(-)
diff --git a/trading-order-service/src/main/java/com/yami/trading/service/impl/IdentifyingCodeServiceImpl.java b/trading-order-service/src/main/java/com/yami/trading/service/impl/IdentifyingCodeServiceImpl.java
index 708dc54..4e393f6 100644
--- a/trading-order-service/src/main/java/com/yami/trading/service/impl/IdentifyingCodeServiceImpl.java
+++ b/trading-order-service/src/main/java/com/yami/trading/service/impl/IdentifyingCodeServiceImpl.java
@@ -5,6 +5,7 @@
import com.yami.trading.common.http.HttpHelper;
import com.yami.trading.common.manager.BlacklistIpTimeWindow;
import com.yami.trading.common.manager.SendCountTimeWindow;
+import com.yami.trading.common.manager.sms.BUKASmsUtils;
import com.yami.trading.common.manager.sms.GoToneSmsUtils;
import com.yami.trading.service.EmailSendService;
import com.yami.trading.service.IdentifyingCodeService;
@@ -13,6 +14,7 @@
import com.yami.trading.service.syspara.SysparaService;
import com.yami.trading.service.system.CodeLogService;
import org.apache.commons.codec.digest.DigestUtils;
+import org.apache.commons.lang3.StringEscapeUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -60,27 +62,13 @@
@Autowired
GoToneSmsUtils goToneSmsUtils;
+ @Autowired
+ BUKASmsUtils bukasmsUtils;
+
@Override
public void send(String target, String ip) throws IOException {
- String code = null;
- if (chcekIp(ip)) {// 被封的ip直接返回 不操作
- return;
- }
- /**
- * 短信发送签名
- */
-// String smsbao_sign = sysparaService.find("smsbao_sign").getValue();
-
- // 短信发送文本[TEST]code is ：{0}
- String send_code_text = this.sysparaService.find("send_code_text").getSvalue();
- if (StringUtils.isNullOrEmpty(send_code_text)) {
- logger.error("send_code_text 未配置");
- return;
- }
-
- /**
- * 是否每次发送的code都不一样
- */
+ String code;
+ //是否每次发送的code都不一样
boolean send_code_always_new = this.sysparaService.find("send_code_always_new").getBoolean();
Object object = this.identifyingCodeTimeWindowService.getAuthCode(target);
@@ -90,120 +78,14 @@
} else {
code = String.valueOf(object);
}
-// log.info(MessageFormat.format("target:{0},code:{1},ip:{2}", target, code, ip));
- String content = MessageFormat.format("code is ：{0}", new Object[] { code });
- if (target.indexOf("@") == -1) {
-
- /**
- * 发送的短信接口类型 tiantian---天天---smsSendService--->>>>--
- * moduyun---摩杜云---smsSingleSender
- */
- String send_code_type = this.sysparaService.find("send_code_type").getSvalue();
- if (StringUtils.isNullOrEmpty(send_code_type)) {
- logger.error("send_code_type 未配置");
- return;
- }
-
- if ("GoTone".equals(send_code_type)) {
- goToneSmsUtils.sendSms(target, MessageFormat.format(send_code_text, new Object[] { code }));
- logger.info(MessageFormat.format("GoTone--target:{0},code:{1},ip:{2}", target, code, ip));
- }
-
-
- if ("tiantian".equals(send_code_type)) {
- smsSendService.send(target, MessageFormat.format(send_code_text, new Object[] { code }));
- logger.info(MessageFormat.format("tiangtian--target:{0},code:{1},ip:{2}", target, code, ip));
- }
-
- if("eex".equalsIgnoreCase(send_code_type)){
- String format = MessageFormat.format(send_code_text, new Object[]{code});
- String apiKey = "5PUIQ2KvNDeC6XfuS0Bl8g==";
- String apiSecret = "5981db6ff1f94264a88d8ead7b90c93e";
- String send_url = "https://api.i51sms.com/outauth/verifCodeSend";
- Date date = new Date();
- SimpleDateFormat dateFormat= new SimpleDateFormat("yyyyMMddHHmmss");
-
- Map<String,Object> param = new HashMap<>();
- param.put("apikey",apiKey);
- param.put("timestamp",dateFormat.format(date));
- param.put("sign", DigestUtils.md5Hex(apiKey+dateFormat.format(date)+apiSecret));
- param.put("mobile",target);
- param.put("content",format);
- String s = HttpHelper.sendPostHttpSMS(send_url, param, true);
- }
-
-// else if ("moduyun".equals(send_code_type)) {
-// // -- 摩杜云短信签名的Id--accesskey,secretkey,signId,templateId
-// String send_code_moduyun = this.sysparaService.find("send_code_moduyun").getValue();
-// String[] send_code_moduyun_parts = send_code_moduyun.split(",");
-// List<String> params = new ArrayList<String>();
-// params.add(code);
-// String strh_code = "";
-// strh_code = target.substring(0, 2);
-// if ("86".equals(strh_code)) {
-// try {
-// smsSingleSender.send(0, "86", target.substring(2, target.length()), send_code_moduyun_parts[2],
-// send_code_moduyun_parts[3], params, "", send_code_moduyun_parts[0],
-// send_code_moduyun_parts[1]);
-// log.info(MessageFormat.format("moduyun--target:{0},code:{1},ip:{2}", target, code, ip));
-// } catch (Exception e) {
-// }
-// }
-// }
- else if ("smsbao".equals(send_code_type)) {
- smsSendService.send(target, MessageFormat.format(send_code_text, new Object[] { code }));
- logger.info(MessageFormat.format("smsbao--target:{0},code:{1},ip:{2}", target, code, ip));
- }
-
- } else {
- /**
- * 邮件
- */
- emailSendService.sendEmail(target, MessageFormat.format(send_code_text, new Object[] { code }), content);
- logger.info(MessageFormat.format("email--target:{0},code:{1},ip:{2}", target, code, ip));
- }
-
+ emailSendService.sendEmail(target,null, code);
+ logger.info(MessageFormat.format("email--target:{0},code:{1},ip:{2}", target, code, ip));
this.identifyingCodeTimeWindowService.putAuthCode(target, code);
- System.out.println("获取验证码：" + target + "---" + code);
CodeLog codeLog = new CodeLog();
codeLog.setTarget(target);
codeLog.setLog("发送地址：" + target + ",验证码：" + code + ",ip地址：" + ip);
codeLog.setCreateTime(new Date());
codeLogService.save(codeLog);
}
-
- /**
- * 返回true:ip已被封， false：ip正常
- *
- * @param ip
- * @return
- */
- private boolean chcekIp(String ip) {
- String check_send_count = sysparaService.find("send_code_check_ip").getSvalue();
- if (!"true".equals(check_send_count))
- return false;// 不为1时 未开启，直接返回false不做处理
- if (blacklistIpTimeWindow.getBlackIp(ip) != null)
- return true;// ip被封，不发送
-
- if (sendCountTimeWindow.getIpSend(ip) != null) {
- Integer count = ipCache.get(ip);
- count++;
- if (count >= 30) {// 从ip发送第一条开始
- blacklistIpTimeWindow.putBlackIp(ip, ip);
- ipCache.remove(ip);
- sendCountTimeWindow.delIpSend(ip);
- return true;
- } else {
- ipCache.put(ip, count++);
- }
-
- } else {
- ipCache.put(ip, 1);
- sendCountTimeWindow.putIpSend(ip, ip);
- }
- return false;
-
- }
-
}
--
Gitblit v1.9.3