Kaynağa Gözat

打开判断当前是否为生产环境的判断代码注释

William 2 yıl önce
ebeveyn
işleme
ea91da3054

+ 3 - 4
src/main/java/org/springblade/sms/component/MarketTaskPushService.java

@@ -5,7 +5,6 @@ import java.util.concurrent.TimeUnit;
 
 import org.springblade.sms.bean.dto.AdsMarketTaskInfo;
 import org.springblade.sms.bean.dto.DefineGroup;
-import org.springblade.sms.enums.GroupSort;
 import org.springblade.sms.enums.GroupType;
 import org.springblade.sms.enums.SmsPushStatus;
 import org.springblade.sms.kafka.PushTaskProducer;
@@ -63,9 +62,9 @@ public class MarketTaskPushService {
 	@Async
 	public void asyncPushSms(AdsMarketTaskInfo task, int curTime) {
 		// windata测试后,打开该代码段
-//		if (!smsSender.isProd()) {
-//			return;
-//		}
+		if (!smsSender.isProd()) {
+			return;
+		}
 
 		log.info("MarketTaskPushService:asyncPushSms start send sms");
 		try {

+ 0 - 6
src/main/java/org/springblade/sms/component/SmsSender.java

@@ -1,6 +1,5 @@
 package org.springblade.sms.component;
 
-import java.net.URLEncoder;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
@@ -213,10 +212,5 @@ public class SmsSender {
 //		JSONObject jo = JSON.parseObject(json);
 //		String errorInfo = jo.getString("data");
 //		log.info(""+errorInfo);
-
-		String userid = DesUtil.encode("17611110266", DesUtil.PASSWORD);
-		log.info("userid is " + userid);
-		log.info("userid is " + URLEncoder.encode(userid));
-		log.info("userid is " + "JB%2FqPs%2FsIN1nZ%2Blb3ZuerQ%3D%3D");
 	}
 }

+ 6 - 6
src/main/java/org/springblade/sms/component/SmsService.java

@@ -77,9 +77,9 @@ public class SmsService {
 
 	public void handleSmsSpidQueue(LinkedBlockingQueue<Tuple<String, String>> queue) {
 		// windata测试后,打开该代码段
-//		if (!smsSender.isProd()) {
-//			return;
-//		}
+		if (!smsSender.isProd()) {
+			return;
+		}
 
 		try {
 			final String msg = "您有10GB芒果TV定向流量仍未激活使用,请在芒果TV客户端中登录激活。具体流程:芒果TV客户端“我的”-运营商专区 “我要免流”,点击页面下方“会员免流激活”,输入手机号验证码即可。详细操作可参考 https://live.mige.tv/platform/ytpxz/tutorial/mangotv.html";
@@ -148,9 +148,9 @@ public class SmsService {
 
 	public void handleSmsQueue(LinkedBlockingQueue<SmsDataKafka> queue) {
 		// windata测试后,打开该代码段
-//		if (!smsSender.isProd()) {
-//			return;
-//		}
+		if (!smsSender.isProd()) {
+			return;
+		}
 
 		try {
 			SmsDataKafka smsData = queue.take();