后端代码

代码/MadRunFabirc.Model/OnlineServiceApi/T_Msg_Chat.cs

+using MadRunFabric.Common;
+using MongoDB.Bson.Serialization.Attributes;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.Text;
+
+namespace MadRunFabric.Model.OnlineServiceApi
+{
+  public   class T_Msg_Chat : IBaseModel<string>
+    {
+        /// <summary>
+        /// id
+        /// </summary>
+        [Key]
+        [BsonRepresentation(MongoDB.Bson.BsonType.ObjectId)]
+        public string id { get; set; }
+        /// <summary>
+        /// 内容
+        /// </summary>
+        public string Msgcontent { get; set; }
+        /// <summary>
+        /// 创建时间
+        /// </summary>
+        public DateTime createtime { get; set; }
+
+        /// <summary>
+        /// 消息来源
+        /// </summary>
+        public string  fromuserid { get; set; }
+
+        /// <summary>
+        /// 消息发送给谁
+        /// </summary>
+        public string  touserid { get; set; }
+
+        /// <summary>
+        /// 是否删除
+        /// </summary>
+        public int isdelete { get; set; }
+    }
+}

代码/MadRunFabirc.Model/OnlineServiceApi/T_Msg_Chat_Map.cs

+using MadRunFabric.Common;
+using MongoDB.Bson.Serialization.Attributes;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.Text;
+
+namespace MadRunFabric.Model.OnlineServiceApi
+{
+   public  class T_Msg_Chat_Map : IBaseModel<string>
+    {
+        /// <summary>
+        /// id
+        /// </summary>
+        [Key]
+        [BsonRepresentation(MongoDB.Bson.BsonType.ObjectId)]
+        public string id { get; set; }
+        /// <summary>
+        /// 消息主键id编号
+        /// </summary>
+        public string chatid { get; set; }
+        /// <summary>
+        /// 内容
+        /// </summary>
+        public string Msgcontent { get; set; }
+        /// <summary>
+        /// 消息来源
+        /// </summary>
+        public string fromuserid { get; set; }
+        public string fromusername { get; set; }
+        /// <summary>
+        /// 消息发送给谁
+        /// </summary>
+        public string touserid { get; set; }
+        public string tousername { get; set; }
+        /// <summary>
+        /// 创建时间
+        /// </summary>
+        public DateTime createtime { get; set; }
+        /// <summary>
+        /// 是否查看过 0未查看 1查看过
+        /// </summary>
+        public int isread { get; set; }
+
+        /// <summary>
+        /// 是否删除
+        /// </summary>
+        public int isdelete { get; set; }
+    }
+}

代码/MadRunFabirc.Model/TestUserTypeApi/T_Msg_Chat.cs

+using MadRunFabric.Common;
+using MongoDB.Bson.Serialization.Attributes;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.Text;
+
+namespace MadRunFabric.Model.TestUserTypeApi
+{
+  public   class T_Msg_Chat : IBaseModel<string>
+    {
+        /// <summary>
+        /// id
+        /// </summary>
+        [Key]
+        [BsonRepresentation(MongoDB.Bson.BsonType.ObjectId)]
+        public string id { get; set; }
+        /// <summary>
+        /// 内容
+        /// </summary>
+        public string Msgcontent { get; set; }
+        /// <summary>
+        /// 创建时间
+        /// </summary>
+        public DateTime createtime { get; set; }
+
+        /// <summary>
+        /// 消息来源
+        /// </summary>
+        public string fromuserid { get; set; }
+
+        /// <summary>
+        /// 消息发送给谁
+        /// </summary>
+        public string touserid { get; set; }
+
+        /// <summary>
+        /// 是否删除
+        /// </summary>
+        public int isdelete { get; set; }
+        /// <summary>
+        /// 区分微信接口和网站接口
+        /// </summary>
+
+        public int isonetype { get; set; }
+
+       
+    }
+}

代码/MadRunFabirc.Model/TestUserTypeApi/T_Msg_Chat_Map.cs

+using MadRunFabric.Common;
+using MongoDB.Bson.Serialization.Attributes;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations;
+using System.Text;
+
+namespace MadRunFabric.Model.TestUserTypeApi
+{
+   public  class T_Msg_Chat_Map : IBaseModel<string>
+    {
+        /// <summary>
+        /// id
+        /// </summary>
+        [Key]
+        [BsonRepresentation(MongoDB.Bson.BsonType.ObjectId)]
+        public string id { get; set; }
+        /// <summary>
+        /// 消息主键id编号
+        /// </summary>
+        public string chatid { get; set; }
+        /// <summary>
+        /// 消息来源
+        /// </summary>
+        public string  fromuserid { get; set; }
+
+        /// <summary>
+        /// 消息发送给谁
+        /// </summary>
+        public string  touserid { get; set; }
+        /// <summary>
+        /// 创建时间
+        /// </summary>
+        public DateTime createtime { get; set; }
+        /// <summary>
+        /// 是否查看过 0未查看 1查看过
+        /// </summary>
+        public int isread { get; set; }
+
+        /// <summary>
+        /// 是否删除
+        /// </summary>
+        public int isdelete { get; set; }
+    }
+}

代码/MadRunFabric.TestUserTypeApi/TestUserTypeApi.IRepositories/ImsgonlineRepository.cs

+using System;
+using System.Collections.Generic;
+using System.Text;
+using MadRunFabric.Common;
+using MadRunFabric.Model.OnlineServiceApi;
+
+namespace TestUserTypeApi.IRepositories
+{
+   public  interface ImsgonlineRepository : IRepository<T_Msg_Chat, string>
+    {
+    }
+}

代码/MadRunFabric.TestUserTypeApi/TestUserTypeApi.IRepositories/ImsgonlinemapRepository.cs

+using System;
+using System.Collections.Generic;
+using System.Text;
+using MadRunFabric.Common;
+using MadRunFabric.Model.TestUserTypeApi;
+
+namespace TestUserTypeApi.IRepositories
+{
+    public interface ImsgonlinemapRepository : IRepository<T_Msg_Chat_Map, string>
+    {
+    }
+}

代码/MadRunFabric.TestUserTypeApi/TestUserTypeApi.Model/Dto/T_Msg_Chat.cs

+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace TestUserTypeApi.Model.Dto
+{
+   public  class T_Msg_Chat
+    {
+        /// <summary>
+        /// id
+        /// </summary>
+        public string id { get; set; }
+        /// <summary>
+        /// 内容
+        /// </summary>
+        public string Msgcontent { get; set; }
+        /// <summary>
+        /// 创建时间
+        /// </summary>
+        public DateTime createtime { get; set; }
+
+        /// <summary>
+        /// 消息来源
+        /// </summary>
+        public int fromuserid { get; set; }
+
+        /// <summary>
+        /// 消息发送给谁
+        /// </summary>
+        public int touserid { get; set; }
+
+        /// <summary>
+        /// 是否删除
+        /// </summary>
+        public int isdelete { get; set; }
+    }
+}

代码/MadRunFabric.TestUserTypeApi/TestUserTypeApi.Model/Dto/T_Msg_Chat_Map.cs

+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace TestUserTypeApi.Model.Dto
+{
+   public  class T_Msg_Chat_Map
+    {
+        public string id { get; set; }
+        /// <summary>
+        /// 消息主键id编号
+        /// </summary>
+        public string chatid { get; set; }
+        /// <summary>
+        /// 消息来源
+        /// </summary>
+        public int fromuserid { get; set; }
+
+        /// <summary>
+        /// 消息发送给谁
+        /// </summary>
+        public int touserid { get; set; }
+        /// <summary>
+        /// 创建时间
+        /// </summary>
+        public DateTime createtime { get; set; }
+        /// <summary>
+        /// 是否查看过 0未查看 1查看过
+        /// </summary>
+        public int isread { get; set; }
+
+        /// <summary>
+        /// 是否删除
+        /// </summary>
+        public int isdelete { get; set; }
+    }
+}

代码/MadRunFabric.TestUserTypeApi/TestUserTypeApi.Repositories/msgonlineRepository.cs

+using System;
+using System.Collections.Generic;
+using System.Text;
+using MadRunFabric.Common;
+using MadRunFabric.Common.Options;
+using MadRunFabric.Model.OnlineServiceApi;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
+using MongoDB.Driver;
+
+
+namespace TestUserTypeApi.Repositories
+{
+   public  class msgonlineRepository : BaseRepository<T_Msg_Chat, string>, IRepositories.ImsgonlineRepository
+    {
+        protected readonly ILogger<BaseRepository<T_Msg_Chat, string>> _logger;
+        protected readonly IMongoCollection<T_Msg_Chat> _collection_MassageInfo;
+        public msgonlineRepository(IOptions<MongodbOptions> settings, ILogger<BaseRepository<T_Msg_Chat, string>> logger) : base(settings, logger)
+        {
+            _collection_MassageInfo = _context.GetCollection<T_Msg_Chat>();
+            _logger = logger;
+        }
+    }
+}

代码/MadRunFabric.TestUserTypeApi/TestUserTypeApi.Repositories/msgonlinemapRepository.cs

+using System;
+using System.Collections.Generic;
+using System.Text;
+using MadRunFabric.Common;
+using MadRunFabric.Common.Options;
+using MadRunFabric.Model.OnlineServiceApi;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
+using MongoDB.Driver;
+
+namespace TestUserTypeApi.Repositories
+{
+  public   class msgonlinemapRepository : BaseRepository<T_Msg_Chat_Map, string>, IRepositories.ImsgonlinemapRepository
+    {
+        protected readonly ILogger<BaseRepository<T_Msg_Chat_Map, string>> _logger;
+        protected readonly IMongoCollection<T_Msg_Chat_Map> _collection_MassageInfo;
+        public msgonlinemapRepository(IOptions<MongodbOptions> settings, ILogger<BaseRepository<T_Msg_Chat_Map, string>> logger) : base(settings, logger)
+        {
+            _collection_MassageInfo = _context.GetCollection<T_Msg_Chat_Map>();
+            _logger = logger;
+        }
+    }
+}

代码/MadRunFabric.TestUserTypeApi/TestUserTypeApi/Controllers/TestUserTypeController.cs

 using System.Collections;
 using System.Net.Http;
 using System.Reflection;
+using MadRunFabric.Model.OnlineServiceApi;
 
 // For more information on enabling MVC for empty projects, visit https://go.microsoft.com/fwlink/?LinkID=397860
 
         {
             return View();
         }
+        #region 定义接口模块
+
         private readonly ILogger<TestUserTypeController> _logger;
         private readonly IConfiguration _configuration;
         private readonly ItestusertypeRepository _tsertuserRepository;//每一道试题信息表
         private readonly ItesttypeRepository _ItesttypeRepository;    //试题类型表
-        private readonly IUserTestRepository   _IUserTestRepository;  //用户总分表
+        private readonly IUserTestRepository _IUserTestRepository;  //用户总分表
         private readonly IUserDoTestRepository _IUserDoTestRepository;//用户做每一题的信息表
+        /// <summary>
+        /// 信息模块
+        /// </summary>
         private readonly IMassageInfoRepository _IMassageInfoRepository;//发送信息记录表
         private readonly ItestquestionRepository _ItestquestionRepository;//发送信息记录表
         private readonly IMassageTypeRepository _IMassageTypeRepository;//短信模板
+
+        /// <summary>
+        /// 在线客服模块
+        /// </summary>
+        private readonly ImsgonlineRepository _ImsgonlineRepository;//在线客服
+        private readonly ImsgonlinemapRepository _ImsgonlinemapRepository;//在线客服
+
+
         public TestUserTypeController(ILogger<TestUserTypeController> logger,
-            IConfiguration configuration,
-            ItestusertypeRepository tsertuserRepository,
-            ItesttypeRepository testtypeRepository, 
-            IUserTestRepository UserTestRepository, 
-            IUserDoTestRepository UserDoTestRepository, 
-            IMassageInfoRepository MassageInfoRepository,
-            ItestquestionRepository ItestquestionRepository,
-            IMassageTypeRepository IMassageTypeRepository)
+           IConfiguration configuration,
+           ItestusertypeRepository tsertuserRepository,
+           ItesttypeRepository testtypeRepository,
+           IUserTestRepository UserTestRepository,
+           IUserDoTestRepository UserDoTestRepository,
+           IMassageInfoRepository MassageInfoRepository,
+           ItestquestionRepository ItestquestionRepository,
+           IMassageTypeRepository IMassageTypeRepository,
+           ImsgonlineRepository ImsgonlineRepository,//在线客服
+           ImsgonlinemapRepository ImsgonlinemapRepository//在线客服
+           )
         {
             _logger = logger;
             _configuration = configuration;
             _tsertuserRepository = tsertuserRepository;
             _ItesttypeRepository = testtypeRepository;
-            _IUserTestRepository  =UserTestRepository;
+            _IUserTestRepository = UserTestRepository;
             _IUserDoTestRepository = UserDoTestRepository;
             _IMassageInfoRepository = MassageInfoRepository;
             _ItestquestionRepository = ItestquestionRepository;
             _IMassageTypeRepository = IMassageTypeRepository;
-        }
+            _ImsgonlineRepository = ImsgonlineRepository;
+            _ImsgonlinemapRepository = ImsgonlinemapRepository;
+        } 
+        #endregion
+        #region 满意度模块
         /// <summary>
         /// 查询试题
         /// </summary>
         public async Task<IActionResult> GetListDrop(int PageIndex, int PageSize, string testtypeid)
         {
             //var list1 = await _tsertuserRepository.Get(p=>p.testtype==testtypeid);
-           
+
             //if (testtypeid != null)
             //{
             //    list = await _tsertuserRepository.Get(s => s.testtype == testtypeid);
             var redCount = await _tsertuserRepository.CountAsync(filter);   //获取总数
             var listmodel = new List<TestPager>();
 
-          
+
             int iscount = 1;
             foreach (var item in list)
             {
                 ///定义选项
                 var optioncenter = "";
                 TestTypes ttps = await _ItesttypeRepository.GetSingle(p => p.id == item.testtype);
-               var  tqn = await _ItestquestionRepository.Get(p=>p.testid==item.id);
+                var tqn = await _ItestquestionRepository.Get(p => p.testid == item.id);
                 foreach (var tqnitem in tqn)
                 {
                     optioncenter += tqnitem.questname;
         [HttpGet("getlistdroplis")]
         public async Task<IActionResult> GetListDropLis(int PageIndex, int PageSize, string testtypeid)
         {
-           
+
             //排序字段
             var sort = Builders<TestPager>.Sort.Descending("createdatatime");
             //根据条件查询集合
             var redCount = await _tsertuserRepository.CountAsync(filter);   //获取总数
             var listmodel = new List<TestPager>();
 
-           
+
             foreach (var item in list)
             {
                 TestTypes ttps = await _ItesttypeRepository.GetSingle(p => p.id == item.testtype);
-                
+
                 var tqn = await _ItestquestionRepository.Get(p => p.testid == item.id);
                 var model = new TestPager();
                 model.id = item.id;
             tp.standardkey = tps.standardkey;
             tp.isdelete = 0;
             tp.createdatatime = DateTime.Now;
-            var a =  _tsertuserRepository.AddRetID(tp);
-            if (a.Result != null||a.Result!="")
+            var a = _tsertuserRepository.AddRetID(tp);
+            if (a.Result != null || a.Result != "")
             {
-                return Success("成功",a.Result);
+                return Success("成功", a.Result);
             }
             else
             {
                 return Error("失败");
             }
-            
+
         }
         /// <summary>
         /// 根据id获取详情信息
         /// <param name="tps"></param>
         /// <returns></returns>
         [HttpGet("updatestpageoption")]
-        public async Task<IActionResult> updatestpageoption(string id ,string testoptions)
+        public async Task<IActionResult> updatestpageoption(string id, string testoptions)
         {
             var model = await _tsertuserRepository.GetSingle(p => p.id == id);
             model.testoptions = testoptions;
-            
+
             var resua = _tsertuserRepository.Update(model);
             if (resua.Result)
             {
         /// </summary>
         /// <returns></returns>
         [HttpGet("gettesttype")]
-        public async Task<IActionResult> Gettesttype(int PageIndex,int PageSize)
+        public async Task<IActionResult> Gettesttype(int PageIndex, int PageSize)
         {
             //排序字段
             var sort = Builders<TestTypes>.Sort.Descending("Createtime");
             //根据条件查询集合
             var listApp = new List<FilterDefinition<TestTypes>>();
             listApp.Add(Builders<TestTypes>.Filter.Eq("isdelete", 0));
-           
+
             var filter = Builders<TestTypes>.Filter.And(listApp);
 
             var list = await _ItesttypeRepository.GetByPage(filter, PageIndex, PageSize, sort);
             var model = await _ItesttypeRepository.GetSingle(p => p.id == id);
             var listmodel = new List<TestTypes>();
             listmodel.Add(model);
-            
+
             return Success("成功", listmodel);
         }
         /// <summary>
         /// </summary>
         /// <returns></returns>
         [HttpGet("getUserDoTest")]
-        public async  Task<IActionResult> GetUserDoTest(int PageIndex, int PageSize,string telcode)
+        public async Task<IActionResult> GetUserDoTest(int PageIndex, int PageSize, string telcode)
         {
             //var list = await _IUserDoTestRepository.GetAll();
 
             {
                 listApp.Add(Builders<UserDoTest>.Filter.Eq("telcode", telcode));
             }
-           
+
             var filter = Builders<UserDoTest>.Filter.And(listApp);
 
             var list = await _IUserDoTestRepository.GetByPage(filter, PageIndex, PageSize, sort);
             }
 
             UserDoTest tp = new UserDoTest();
-           tp.telcode = tps.telcode;//电话号
-           tp.testid =  tps.testid;//试卷表id
+            tp.telcode = tps.telcode;//电话号
+            tp.testid = tps.testid;//试卷表id
             tp.testtype = testtype;//试卷类型
-           tp.testoptions = tps.testoptions;//选项
-           tp.grade = tps.grade;//得分
-           tp.createtime = DateTime.Now;//做题时间
+            tp.testoptions = tps.testoptions;//选项
+            tp.grade = tps.grade;//得分
+            tp.createtime = DateTime.Now;//做题时间
             tp.isdelete = 0;
-           
-           var a = _IUserDoTestRepository.AddRetID(tp);
+
+            var a = _IUserDoTestRepository.AddRetID(tp);
 
             if (a.Result != null || a.Result != "")
             {
-               
-                var testuserlist = await _IUserTestRepository.GetSingle(p=>p.telcode==tps.telcode&&p.testtype==testtype);
+
+                var testuserlist = await _IUserTestRepository.GetSingle(p => p.telcode == tps.telcode && p.testtype == testtype);
                 if (testuserlist == null)
                 {
                     UserTest usertest = new UserTest();
                     UserTest usertest = new UserTest();
                     usertest.id = testuserlist.id;
                     usertest.telcode = tps.telcode;//电话号
-                    usertest.testcount = testuserlist.testcount+ 1;//答题数量
-                    usertest.allgrade =testuserlist.allgrade+ tps.grade;//总分数
+                    usertest.testcount = testuserlist.testcount + 1;//答题数量
+                    usertest.allgrade = testuserlist.allgrade + tps.grade;//总分数
                     usertest.testtype = testtype;//试卷类型
                     usertest.createtime = DateTime.Now;
                     var resua = _IUserTestRepository.Update(usertest);
                 model.allgrade = item.allgrade;//总分数
                 model.testtype = item.testtype;//试卷类型
                 model.testtypename = ttps.Typename;//试卷类型名称
-               // model.testid = item.testid;//问题id
-                
+                                                   // model.testid = item.testid;//问题id
+
                 listmodel.Add(model);
             }
             var obj = new
         public async Task<IActionResult> AddUserTest(Model.Dto.UserTestDto tps)
         {
             UserTest tp = new UserTest();
-            tp.telcode =   tps.telcode;//电话号
+            tp.telcode = tps.telcode;//电话号
             tp.testcount = tps.testcount;//答题数量
-            tp.allgrade =  tps.allgrade;//总分数
-            tp.testtype =  tps.testtype;//试卷类型
+            tp.allgrade = tps.allgrade;//总分数
+            tp.testtype = tps.testtype;//试卷类型
             tp.isdelete = 0;
-            var a =  _IUserTestRepository.AddRetID(tp);
+            var a = _IUserTestRepository.AddRetID(tp);
             if (a.Result != null || a.Result != "")
             {
                 return Success("成功", a.Result);
         [HttpGet("addtestquestion")]
         public async Task<IActionResult> AddTestQuestion(Model.Dto.testquestion tps)
         {
-            
+
             testquestion tp = new testquestion();
             tp.questname = tps.questname;//选项内容
             tp.testid = tps.testid;//题目编号
         {
             var model = await _ItestquestionRepository.Get(p => p.testid == testid);
             return Success("成功", model);
-        }
-
-       /// <summary>
-       /// 获取短信模板信息
-       /// </summary>
-       /// <param name="PageIndex"></param>
-       /// <param name="PageSize"></param>
-       /// <param name="typename"></param>
-       /// <returns></returns>
+        } 
+        #endregion
+        #region 短信模块
+        /// <summary>
+        /// 获取短信模板信息
+        /// </summary>
+        /// <param name="PageIndex"></param>
+        /// <param name="PageSize"></param>
+        /// <param name="typename"></param>
+        /// <returns></returns>
         [HttpGet("getlistmassagetype")]
         public async Task<IActionResult> GetListMassageType(int PageIndex, int PageSize, string typename)
         {
-          
+
             //排序字段
             var sort = Builders<MassageType>.Sort.Descending("Createtime");
             //根据条件查询集合
             {
                 return Error("该类型模板已存在请选择编辑");
             }
-           
+
         }
         /// <summary>
         /// 删除短信模板
             string[] arrStr = id.Split(',');
             foreach (var item in arrStr)
             {
-                var result =  _IMassageTypeRepository.Remove(item);
+                var result = _IMassageTypeRepository.Remove(item);
                 res += 1;
             }
             if (res == arrStr.Length)
                     return Error("该类型模板已存在请选择相应模板进行编辑");
                 }
             }
-           
-           
+
+
 
         }
 
             //发送给哪个手机号
             var Mobile = tps.telcode;
             //定时发送还是立即发送
-            var  SendTime = tps.SendTime;
+            var SendTime = tps.SendTime;
             string result1 = HttpUtility.UrlEncode(str, Encoding.GetEncoding("GB2312"));
             var ifsend = false;
             var aaa = " ";
-            string url = "https://sdk2.028lk.com/sdk2/BatchSend2.aspx?CorpID=DYRMYY011170&Pwd=xxk@80188&Mobile="+Mobile+"&Content=" + result1 + "&Cell=&SendTime=";
-            
+            string url = "https://sdk2.028lk.com/sdk2/BatchSend2.aspx?CorpID=DYRMYY011170&Pwd=xxk@80188&Mobile=" + Mobile + "&Content=" + result1 + "&Cell=&SendTime=";
+
             //?CorpID=DYRMYY011170&Pwd=xxk@80188&Mobile=13935966971&Content="+ result1 + "&Cell=&SendTime=
 
             //Encoding encoding = Encoding.GetEncoding("GB2312");
             parameters.Add("Mobile", Mobile);
             parameters.Add("Content", result1);
             parameters.Add("Cell", "");
-            parameters.Add("SendTime",SendTime.ToString());
+            parameters.Add("SendTime", SendTime.ToString());
             HttpWebResponse response = PostHttps(url, parameters, encoding);
             //打印返回值
             Stream stream = response.GetResponseStream();   //获取响应的字符串流
             StreamReader sr = new StreamReader(stream); //创建一个stream读取流
 
             //返回的信息
-             string html = sr.ReadToEnd();
+            string html = sr.ReadToEnd();
 
             if (Convert.ToInt32(html) > 0)
             {
             {
                 return Error("IP未导白");
             }
-            else {
+            else
+            {
                 return Error("调用接口失败");
             }
 
         }
 
-        
+
 
         /// <summary>
         /// 获取发送短信记录更改回复内容
 
             //string replycent = GetFunction("https://sdk2.028lk.com/sdk2/BatchSend2.aspx?CorpID=DYRMYY011170&Pwd=xxk@80188");//
             //var replycent1 = DoGet("https://sdk2.028lk.com/sdk2/BatchSend2.aspx?CorpID=DYRMYY011170&Pwd=xxk@80188");
-            
+
             string url = "https://sdk2.028lk.com/sdk2/BatchSend2.aspx?CorpID=DYRMYY011170&Pwd=xxk@80188";
-            
+
             Encoding encoding = Encoding.GetEncoding("GBK");
 
-           // var replycent = GetHttpPost(url, "gb2312");
+            // var replycent = GetHttpPost(url, "gb2312");
 
 
             IDictionary<string, string> parameters = new Dictionary<string, string>();
                         return Error("失败");
                     }
                 }
-              
+
             }
             else
             {
         /// </summary>
         /// <returns></returns>
         [HttpGet("getmassage")]
-        public async Task<IActionResult> Getmassage(int PageIndex,int PageSize)
+        public async Task<IActionResult> Getmassage(int PageIndex, int PageSize)
         {
             //排序字段
             var sort = Builders<MassageInfo>.Sort.Descending("senddate");
 
             var list = await _IMassageInfoRepository.GetByPage(filter, PageIndex, PageSize, sort);
             var redCount = await _IMassageInfoRepository.CountAsync(filter);   //获取总数
-            
+
             var listmodel = new List<MassageInfo>();
             foreach (var item in list)
             {
             };
             return Success("成功", obj);
         }
-        
+
         private static readonly string DefaultUserAgent = "Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/72.0.3626.121 Safari/537.36";
 
         private static bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors)
                 {
                     if (i > 0)
                     {
-                        if (key== "Content")
+                        if (key == "Content")
                         {
                             buffer.AppendFormat("&{0}={1}", key, HttpUtility.UrlEncode(parameters[key], Encoding.GetEncoding("GB2312"))); //
                         }
                         {
                             buffer.AppendFormat("&{0}={1}", key, WebUtility.UrlEncode(parameters[key])); //Encoding.GetEncoding("GBK").GetBytes(parameters[key])
                         }
-                        
+
                     }
                     else
                     {
             }
             return responseBody;
         }
-        public string  GetFunction(string url)
+        public string GetFunction(string url)
         {
             HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
             request.Method = "GET";
             return retString;
         }
 
+        #endregion
+        #region 在线客服模块
+        /// <summary>
+        /// 根据编号删除聊天记录
+        /// </summary>
+        /// <param name="id"></param>
+        /// <returns></returns>
+        [HttpGet("delonlinservice")]
+        public async Task<IActionResult> Delonlinservice(string id)
+        {
+            var result = _ImsgonlineRepository.Remove(id);
+            if (result.Result)
+            {
+                return Success("成功");
+            }
+            else
+            {
+                return Error("失败");
+            }
+        }
+        /// <summary>
+        /// 获取聊天记录
+        /// </summary>
+        /// <param name="PageIndex"></param>
+        /// <param name="PageSize"></param>
+        /// <returns></returns>
+        [HttpGet("getListonlineservice")]
+        public async Task<IActionResult> GetListOnlineservice(int PageIndex, int PageSize)
+        {
+
+            //排序字段
+            var sort = Builders<T_Msg_Chat>.Sort.Descending("createdatatime");
+            //根据条件查询集合
+            var listApp = new List<FilterDefinition<T_Msg_Chat>>();
+            listApp.Add(Builders<T_Msg_Chat>.Filter.Eq("isdelete", 0));
+
+            var filter = Builders<T_Msg_Chat>.Filter.And(listApp);
+
+            var list = await _ImsgonlineRepository.GetByPage(filter, PageIndex, PageSize, sort);
+            var redCount = await _ImsgonlineRepository.CountAsync(filter);   //获取总数
+            var listmodel = new List<T_Msg_Chat>();
+
+
+            foreach (var item in list)
+            {
+                var model = new T_Msg_Chat();
+                model.id = item.id;
+                model.Msgcontent = item.Msgcontent;//信息内容
+                model.fromuserid = item.fromuserid;//消息来源
+                model.touserid = item.touserid;//发送给谁
+                model.createtime = item.createtime;//创建时间
+                model.isdelete = item.isdelete;//是否禁用
+                listmodel.Add(model);
+            }
+            var obj = new
+            {
+                rows = listmodel,
+                total = redCount
+            };
+            return Success("成功", obj);
+        }
+        /// <summary>
+        /// 添加聊天记录表信息
+        /// </summary>
+        /// <param name="tps"></param>
+        /// <returns></returns>
+        [HttpGet("addonlineservice")]
+        public async Task<IActionResult> AddOnlineservice(Model.Dto.T_Msg_Chat tps)
+        {
+            T_Msg_Chat tp = new T_Msg_Chat();
+            tp.Msgcontent = tps.Msgcontent;//信息内容
+            tp.fromuserid = tps.fromuserid;//消息来源
+            tp.touserid = tps.touserid;//发送给谁
+            tp.isdelete = 0;
+            tp.createtime = DateTime.Now;
+            var a = _ImsgonlineRepository.AddRetID(tp);
+            if (a.Result != null || a.Result != "")
+            {
+                T_Msg_Chat_Map tmp = new T_Msg_Chat_Map();
+                tmp.chatid = a.Result;//聊天记录的编号
+                tmp.fromuserid = tps.fromuserid;
+                tmp.touserid = tps.touserid;
+                tmp.isdelete = 0;
+                tmp.isread = 0;//是否查看过
+                tmp.createtime = DateTime.Now;
+                var b = _ImsgonlinemapRepository.AddRetID(tmp);
+                if (b.Result != null || b.Result != "")
+                {
+                    return Success("成功", a.Result);
+                }
+                else
+                {
+                    return Error("添加关联记录失败");
+                }
+                    
+            }
+            else
+            {
+                return Error("添加聊天记录失败");
+            }
+
+        }
+        /// <summary>
+        /// 根据编号获取聊天记录信息详情
+        /// </summary>
+        /// <param name="id"></param>
+        /// <returns></returns>
+        [HttpGet("getonlineservicetinfo")]
+        public async Task<IActionResult> GetOnlineservicetinfo(string id)
+        {
+            var mapmode = await _ImsgonlinemapRepository.GetSingle(p => p.id == id);
+            mapmode.isread = 1;//修改成已读
+            var resua = _ImsgonlinemapRepository.Update(mapmode);//修改数据库数据
+
+            var model = await _ImsgonlineRepository.GetSingle(p => p.id == mapmode.chatid);
+            return Success("成功", model);
+        }
+        /// <summary>
+        /// 获取未读消息列表
+        /// </summary>
+        /// <param name="PageIndex"></param>
+        /// <param name="PageSize"></param>
+        /// <returns></returns>
+        [HttpGet("getListonlineservice")]
+        public async Task<IActionResult> GetListOnlineservicemap(int PageIndex, int PageSize)
+        {
+
+            //排序字段
+            var sort = Builders<T_Msg_Chat_Map>.Sort.Descending("createdatatime");
+            //根据条件查询集合
+            var listApp = new List<FilterDefinition<T_Msg_Chat_Map>>();
+            listApp.Add(Builders<T_Msg_Chat_Map>.Filter.Eq("isdelete", 0));
+
+            var filter = Builders<T_Msg_Chat_Map>.Filter.And(listApp);
+
+            var list = await _ImsgonlinemapRepository.GetByPage(filter, PageIndex, PageSize, sort);
+            var redCount = await _ImsgonlinemapRepository.CountAsync(filter);   //获取总数
+            var listmodel = new List<T_Msg_Chat_Map>();
+
+
+            foreach (var item in list)
+            {
+                var model = new T_Msg_Chat_Map();
+                model.id = item.id;
+                model.chatid = item.chatid;//聊天记录编号
+                model.isread = item.isread;//是否阅读
+                model.fromuserid = item.fromuserid;//消息来源
+                model.touserid = item.touserid;//发送给谁
+                model.createtime = item.createtime;//创建时间
+                model.isdelete = item.isdelete;//是否禁用
+                listmodel.Add(model);
+            }
+            var obj = new
+            {
+                rows = listmodel,
+                total = redCount
+            };
+            return Success("成功", obj);
+        }
+        #endregion
     }
 }