From 9ad4559d0ca58d678f5940f789df020dd66cad68 Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期四, 11 七月 2024 16:32:28 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomSMSServiceImpl.java | 107 +++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 107 insertions(+), 0 deletions(-)
diff --git a/server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomSMSServiceImpl.java b/server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomSMSServiceImpl.java
new file mode 100644
index 0000000..5ee6a41
--- /dev/null
+++ b/server/service/src/main/java/com/doumee/biz/zbom/impl/ZbomSMSServiceImpl.java
@@ -0,0 +1,107 @@
+package com.doumee.biz.zbom.impl;
+
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
+import com.doumee.biz.zbom.ZbomCRMService;
+import com.doumee.biz.zbom.ZbomSMSService;
+import com.doumee.biz.zbom.model.CrmCustomerInfoModel;
+import com.doumee.biz.zbom.model.CrmCustomerSubmmitModel;
+import com.doumee.core.utils.Constants;
+import com.doumee.core.utils.HttpsUtil;
+import com.doumee.dao.business.CrmInterfaceLogMapper;
+import com.doumee.dao.business.CustomerLogMapper;
+import com.doumee.dao.business.model.CrmInterfaceLog;
+import com.doumee.dao.business.model.CustomerLog;
+import org.apache.commons.codec.digest.DigestUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.stereotype.Service;
+
+import java.io.BufferedReader;
+import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.net.URLEncoder;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * 蹇楅偊CRM瀹㈡埛淇℃伅鎻愪氦鎺ュ彛
+ * @author 姹熻箘韫�
+ * @date 2023/11/30 15:33
+ */
+@Service
+public class ZbomSMSServiceImpl implements ZbomSMSService {
+
+ @Autowired
+ private CustomerLogMapper customerLogMapper;
+ @Autowired
+ private CrmInterfaceLogMapper crmInterfaceLogMapper;
+
+ @Autowired
+ private RedisTemplate<String, Object> redisTemplate;
+
+ /**
+ * 蹇楅偊瀹㈡埛淇℃伅鎻愪氦鎺ュ彛
+ * @return
+ */
+ @Override
+ public boolean sendMessage(String content,String phone) {
+ // TODO Auto-generated method stub
+ if(StringUtils.isBlank(content)){
+ return false;
+ }
+ String appkey = (String) redisTemplate.opsForValue().get(Constants.RedisKeys.ZBOM_SMS_API_KEY);
+ String urlStr = (String)redisTemplate.opsForValue().get(Constants.RedisKeys.ZBOM_SMS_API_URL) ;
+ try {
+ StringBuffer sb = new StringBuffer(urlStr);
+ Integer _t = (int) System.currentTimeMillis();
+ // 鍚慡tringBuffer杩藉姞鐢ㄦ埛鍚�
+ sb.append("_t=" + _t);
+ sb.append("&smsphone=" + phone);
+ sb.append("&smscode=10005");
+ // 鍚慡tringBuffer杩藉姞瀵嗙爜锛堢櫥闄嗙綉椤电増锛屽湪绠＄悊涓績--鍩烘湰璧勬枡--鎺ュ彛瀵嗙爜锛屾槸28浣嶇殑锛�
+ sb.append("&smsmsg=" + URLEncoder.encode(content.replace(" ", ""), "UTF-8"));
+ // 鍔犲瘑
+ // 497fbc01e744ef44001296b7466148e8
+ sb.append("&token=" + DigestUtils.md5Hex(phone + _t + appkey));
+
+ // 鍒涘缓url瀵硅薄
+ URL url = new URL(sb.toString());
+ // 鎵撳紑url杩炴帴
+ HttpURLConnection connection = (HttpURLConnection) url.openConnection();
+
+ // 璁剧疆url璇锋眰鏂瑰紡 鈥榞et鈥� 鎴栬�� 鈥榩ost鈥�
+ connection.setRequestMethod("POST");
+ connection.setConnectTimeout(500);
+ connection.setReadTimeout(500);
+ // 鍙戦��
+ BufferedReader in = new BufferedReader(new InputStreamReader(url.openStream()));
+ // 杩斿洖鍙戦�佺粨鏋�
+ String inputline = in.readLine();
+ // 杩斿洖缁撴灉涓衡��0锛�20140009090990,1锛屾彁浜ゆ垚鍔熲�� 鍙戦�佹垚鍔� 鍏蜂綋瑙佽鏄庢枃妗�
+ System.out.println(inputline);
+ saveInterfaceLog(urlStr,"蹇楅偊鐭俊鍙戦�佹帴鍙�", sb.toString(), 0,inputline);
+ return true;//
+ }catch (Exception e){
+ return false;
+ }
+
+ }
+ public void saveInterfaceLog(String url,String name,String param,Integer success,String respone){
+ CrmInterfaceLog log = new CrmInterfaceLog();
+ log.setCreateDate(new Date());
+ log.setUrl(url);
+ log.setEditDate(log.getCreateDate());
+ log.setPlat(Constants.ZERO);
+ log.setName(name);
+ log.setIsdeleted(Constants.ZERO);
+ log.setRequest(param);
+ log.setType(Constants.ONE);
+ log.setSuccess(success);
+ log.setRepose(respone);
+ crmInterfaceLogMapper.insert(log);
+ }
+}
--
Gitblit v1.9.3