提交代码

Mall.CacheManager/ByteDance/ByteDanceRedis.cs

+using Mall.CacheManager.DataStatistic;
+using Mall.Common.Plugin.Redis;
+using Mall.Model.Extend.User;
+using Newtonsoft.Json;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace Mall.CacheManager.ByteDance
+{
+    public class ByteDanceRedis
+    {
+
+        static RedisHelper redis = new RedisHelper(DataConstant.REDIS_DB2);
+          /// <summary>
+          /// 获取微信用的formID
+          /// </summary>
+          /// <param name="uid"></param>
+          /// <returns></returns>
+        public static List<ByteDanceCustomer> GetByteDanceList(int customerId, string FormId)
+        {
+            string cacheKey = CacheKey.UserModuleCacheKeyConfig.ByteDanceFormId + customerId + "_" + FormId;
+            List<ByteDanceCustomer> airInfo = new List<ByteDanceCustomer>();
+            try
+            {
+                var dic = redis.StringGet(cacheKey);
+                foreach (var item in dic)
+                {
+                    var model = JsonConvert.DeserializeObject<List<ByteDanceCustomer>>(item.ToString());
+                    airInfo.AddRange(model);
+                }
+            }
+            catch (Exception ex)
+            {
+                Common.Plugin.LogHelper.Write(ex, "GetByteDanceList");
+            }
+            return airInfo;
+        }
+
+        /// <summary>
+        /// 设置缓存
+        /// </summary>
+        /// <param name="airList"></param>
+        public static void SetDyteDanceInfo(List<ByteDanceCustomer> airList)
+        {
+            string cacheKey = CacheKey.UserModuleCacheKeyConfig.ByteDanceFormId + airList.FirstOrDefault().UserID + "_" + airList.FirstOrDefault().FormId;
+            TimeSpan ts = GetExpirTime(7 * 60 * 60 * 24 - 60 * 1);
+            redis.StringSet(cacheKey, JsonConvert.SerializeObject(airList), ts);
+        }
+
+        /// <summary>
+        /// 获取缓存时长
+        /// </summary>
+        /// <param name="JwtExpirTime"></param>
+        /// <returns></returns>
+        private static TimeSpan GetExpirTime(int JwtExpirTime)
+        {
+            DateTime dt = DateTime.Now;
+            DateTime dt2 = DateTime.Now;
+            TimeSpan ts = dt.AddSeconds(JwtExpirTime) - dt2;
+            return ts;
+        }
+
+
+        /// <summary>
+        /// 设置缓存
+        /// </summary>
+        /// <param name="airList"></param>
+        public static void RemoveCacheKey(string CustomerID, string FormId, ByteDanceCustomer model)
+        {
+            string cacheKey = CacheKey.UserModuleCacheKeyConfig.ByteDanceFormId + CustomerID + "_" + FormId;
+            redis.ListRemove(cacheKey, model);
+        }
+    }
+}

Mall.CacheManager/keyManager/UserModuleCacheKeyConfig.cs

@@ -31,5 +31,11 @@ namespace Mall.CacheKey
         {
             get { return "DATA_WeiXinToken"; }
         }
+
+        public static string ByteDanceFormId
+        {
+            get { return "ByteDanceFormId_"; }
+        }
+        
     }
 }

Mall.Common/Config.cs

@@ -318,5 +318,17 @@ namespace Mall.Common
                 return new ConfigurationBuilder().Add(new JsonConfigurationSource { Path = "appsettings.json" }).Build().GetSection("FirstPage").Value;
             }
         }
+
+
+        /// <summary>
+        /// 抖音发送消息模板
+        /// </summary>
+        public static string ByteDanceSendTemplate
+        {
+            get
+            {
+                return new ConfigurationBuilder().Add(new JsonConfigurationSource { Path = "appsettings.json" }).Build().GetSection("ByteDanceSendTemplate").Value;
+            }
+        }
     }
 }
\ No newline at end of file

Mall.Model/Extend/User/RB_Member_User_Extend.cs

@@ -73,4 +73,31 @@ namespace Mall.Model.Extend.User
         #endregion
 
     }
+
+
+    /// <summary>
+    /// 抖音客户实体类
+    /// </summary>
+    public class ByteDanceCustomer
+    {
+        /// <summary>
+        ///  form Id
+        /// </summary>
+        public string FormId { get; set; }
+
+        /// <summary>
+        /// form Id缓存时间
+        /// </summary>
+        public DateTime FormCreateDate { get; set; }
+
+        /// <summary>
+        /// 用户的标识
+        /// </summary>
+        public string Openid { get; set; }
+
+        /// <summary>
+        /// 客户编号
+        /// </summary>
+        public int UserID { get; set; }
+    }
 }

Mall.WebApi/Controllers/ByteDance/ByteDanceController.cs

+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Net;
+using System.Threading.Tasks;
+using Google.Protobuf.WellKnownTypes;
+using Mall.Common.API;
+using Mall.Common.Plugin;
+using Mall.Model.Entity.User;
+using Mall.Model.Extend.User;
+using Mall.Module.User;
+using Mall.WebApi.Filter;
+using Microsoft.AspNetCore.Cors;
+using Microsoft.AspNetCore.Mvc;
+using Newtonsoft.Json.Linq;
+
+namespace Mall.WebApi.Controllers.ByteDance
+{
+    [Route("api/[controller]/[action]")]
+    [ApiExceptionFilter]
+    [ApiController]
+    [EnableCors("AllowCors")]
+    public class ByteDanceController : BaseController
+    {
+
+        private readonly UserModule userModule = new UserModule();
+        /// <summary>
+        /// 保存客户formId
+        /// </summary>
+        /// <param name="request"></param>
+        /// <returns></returns>
+        public ApiResult SaveFormId()
+        {
+            var parms = RequestParm;
+            JObject parmsJob = JObject.Parse(RequestParm.msg.ToString());
+            int customerId = parmsJob.GetInt("customerId");
+            string formId = parmsJob.GetStringValue("formId");
+            // string openid = GetWx(code);
+            RB_Member_User customerInfo = new RB_Member_User();
+            //判断是否绑定了openid
+            customerInfo = userModule.GetMemberUserInfo(customerId);
+            if (customerInfo != null)
+            {
+                ByteDanceCustomer wechatExtend = new ByteDanceCustomer
+                {
+                    FormCreateDate = System.DateTime.Now,
+                    FormId = formId,
+                    Openid = customerInfo.OpenId,
+                    UserID = customerInfo.Id
+                };
+                List<ByteDanceCustomer> listCustomerWechat = new List<ByteDanceCustomer>
+                    {
+                        wechatExtend
+                    };
+                CacheManager.ByteDance.ByteDanceRedis.SetDyteDanceInfo(listCustomerWechat);
+            }
+            return ApiResult.Success("");
+        }
+
+
+        /// <summary>
+        /// 向客户抖音小程序发送消息
+        /// </summary>
+        /// <param name="content"></param>
+        /// <param name="model"></param>
+        /// <param name="ID"></param>
+        /// <param name="guestModel"></param>
+        public void SendMsg(string content, ByteDanceCustomer model, int ID, RB_Member_User userModel)
+        {
+
+            //谁来接受微信消息通知
+            string tempOpenId = model.Openid;
+            //要使用的form_id
+            string formId = "";
+
+            var list = CacheManager.ByteDance.ByteDanceRedis.GetByteDanceList(model.UserID, formId);
+            if (list != null && list.Any())
+            {
+                formId = list.OrderBy(x => x.FormCreateDate).FirstOrDefault().FormId;
+                string WeChatSendTemplate = Common.Config.ByteDanceSendTemplate;
+                var tempData = new
+                {
+
+                    keyword1 = new
+                    {
+                        value = "旅客意见调查表",
+                    },
+                    keyword2 = new
+                    {
+                        value = userModel.AliasName,
+                    },
+                    keyword3 = new
+                    {
+                        value = content,
+                    },
+                };
+                //拼接字符串
+                var msgData = new
+                {
+                    access_token = "",
+                    touser = tempOpenId,//openId，推送给谁，给那个用户
+                    template_id = WeChatSendTemplate,//模板消息ID，在微信小程序后台的模板消息里有.。这个是*****成功通知。的id
+                                                     // topcolor = "#173177",
+                    page = "",//点击消息卡片之后打开的小程序页面地址，空则无跳转。        
+                    form_id = formId,//要从服务器数据库里取最近7天时间最长的一条没有使用的来，用完了要设置这个formId被用过了。
+                    data = tempData
+                };
+
+                string postData = JsonHelper.Serialize(msgData);
+                string tempUrl = "https://developer.toutiao.com/api/apps/game/template/send";
+                string resulr = WebRequestPostOrGet(tempUrl, postData);
+                CacheManager.ByteDance.ByteDanceRedis.RemoveCacheKey(model.UserID.ToString(), formId, model);
+            }
+        }
+
+        /// <summary>
+        /// 发送消息
+        /// </summary>
+        /// <param name="sUrl"></param>
+        /// <param name="sParam"></param>
+        /// <returns></returns>
+        public static string WebRequestPostOrGet(string sUrl, string sParam)
+        {
+            byte[] bt = System.Text.Encoding.UTF8.GetBytes(sParam);
+            Uri uriurl = new Uri(sUrl);
+            HttpWebRequest req = (HttpWebRequest)HttpWebRequest.Create(uriurl);//HttpWebRequest req = (HttpWebRequest)HttpWebRequest.Create(url + (url.IndexOf("?") > -1 ? "" : "?") + param);
+            req.Method = "Post";
+            req.Timeout = 120 * 1000;
+            req.ContentType = "application/x-www-form-urlencoded;";
+            req.ContentLength = bt.Length;
+            using (Stream reqStream = req.GetRequestStream())//using 使用可以释放using段内的内存
+            {
+                reqStream.Write(bt, 0, bt.Length);
+                reqStream.Flush();
+            }
+            try
+            {
+                using (WebResponse res = req.GetResponse())
+                {
+                    Stream resStream = res.GetResponseStream();
+                    StreamReader resStreamReader = new StreamReader(resStream, System.Text.Encoding.UTF8);
+                    string resLine;
+                    System.Text.StringBuilder resStringBuilder = new System.Text.StringBuilder();
+                    while ((resLine = resStreamReader.ReadLine()) != null)
+                    {
+                        resStringBuilder.Append(resLine + System.Environment.NewLine);
+                    }
+                    resStream.Close();
+                    resStreamReader.Close();
+                    return resStringBuilder.ToString();
+                }
+            }
+            catch (Exception ex)
+            {
+                return ex.Message;//url错误时候回报错
+            }
+        }
+
+
+        public ApiResult GetTest()
+        {
+
+            string info = ExecuteInCmd("ipconfig");
+            // ProcessCore.ExecuteOutCmd("-I http://www.baidu.com", @"C:\curl.exe");
+            return ApiResult.Success("", info);
+        }
+
+
+        /// <summary>
+        /// 执行外部命令
+        /// </summary>
+        /// <param name="argument">命令参数</param>
+        /// <param name="application">命令程序路径</param>
+        /// <returns>执行结果</returns>
+        public static string ExecuteOutCmd(string argument, string applocaltion)
+        {
+            using (var process = new System.Diagnostics.Process())
+            {
+                process.StartInfo.Arguments = argument;
+                process.StartInfo.FileName = applocaltion;
+                process.StartInfo.UseShellExecute = false;
+                process.StartInfo.RedirectStandardInput = true;
+                process.StartInfo.RedirectStandardOutput = true;
+                process.StartInfo.RedirectStandardError = true;
+                process.StartInfo.CreateNoWindow = true;
+
+                process.Start();
+                process.StandardInput.AutoFlush = true;
+                process.StandardInput.WriteLine("exit");
+
+                //获取cmd窗口的输出信息  
+                string output = process.StandardOutput.ReadToEnd();
+
+                process.WaitForExit();
+                process.Close();
+
+                return output;
+            }
+        }
+
+
+        /// <summary>
+        /// 执行内部命令（cmd.exe 中的命令）
+        /// </summary>
+        /// <param name="cmdline">命令行</param>
+        /// <returns>执行结果</returns>
+        public static string ExecuteInCmd(string cmdline)
+        {
+            using (var process = new System.Diagnostics.Process())
+            {
+                process.StartInfo.FileName = "cmd.exe";
+                process.StartInfo.UseShellExecute = false;
+                process.StartInfo.RedirectStandardInput = true;
+                process.StartInfo.RedirectStandardOutput = true;
+                process.StartInfo.RedirectStandardError = true;
+                process.StartInfo.CreateNoWindow = true;
+
+                process.Start();
+                process.StandardInput.AutoFlush = true;
+                process.StandardInput.WriteLine(cmdline + "&exit");
+
+                //获取cmd窗口的输出信息  
+                string output = process.StandardOutput.ReadToEnd();
+
+                process.WaitForExit();
+                process.Close();
+
+                return output;
+            }
+        }
+
+    }
+}
\ No newline at end of file

Mall.WebApi/appsettings.json

@@ -24,6 +24,7 @@
   "ProjectUrl": "D:/project/GitProject/tripfriend",
   "DeveloperKitsPort": "63994",
   "FirstPage": "pages/index/index.html",
+  "ByteDanceSendTemplate": "https://developer.toutiao.com/api/apps/game/template/send",
   "RedisSetting": {
     "RedisServer": "192.168.2.214",
     "RedisPort": "6379",