获取邮件信息接口，邮件审核，添加邮件订单。

CallCenterApi/CallCenterApi.BLL/T_Email_EmailMessage_Map.cs

@@ -29,6 +29,14 @@ namespace CallCenterApi.BLL
         {
             return dal.Exists(E_Id);
         }
+        
+        /// <summary>
+        /// 是否存在该记录
+        /// </summary>
+        public bool ExistsByEmailId(string EmailId)
+        {
+            return dal.ExistsByEmailId(EmailId);
+        }
 
         /// <summary>
         /// 增加一条数据

CallCenterApi/CallCenterApi.DAL/T_Email_EmailMessage_Map.cs

@@ -38,23 +38,40 @@ namespace CallCenterApi.DAL
 
             return DbHelperSQL.Exists(strSql.ToString(), parameters);
         }
+        
+        /// <summary>
+        /// 是否存在该记录
+        /// </summary>
+        public bool ExistsByEmailId(string EmailId)
+        {
+            StringBuilder strSql = new StringBuilder();
+            strSql.Append("select count(1) from T_Email_EmailMessage_Map");
+            strSql.Append(" where E_EmailId=@EmailId");
+            SqlParameter[] parameters = {
+                    new SqlParameter("@EmailId", SqlDbType.VarChar,50)
+            };
+            parameters[0].Value = EmailId;
+
+            return DbHelperSQL.Exists(strSql.ToString(), parameters);
+        }
 
 
         /// <summary>
-        /// 增加一条数据
-        /// </summary>
-        public int Add(Model.T_Email_EmailMessage_Map model)
+		/// 增加一条数据
+		/// </summary>
+		public int Add(Model.T_Email_EmailMessage_Map model)
         {
             StringBuilder strSql = new StringBuilder();
             strSql.Append("insert into T_Email_EmailMessage_Map(");
-            strSql.Append("E_WorkOrderId,E_EmailId,E_IsWorkOrder,E_SendEmail,E_SendName,E_Title,E_Content,E_AttachmentsUrl,E_AddTime,E_EmailTime,F_UserId,F_UserName)");
+            strSql.Append("E_WorkOrderId,E_EmailId,E_IsWorkOrder,E_IsAudit,E_SendEmail,E_SendName,E_Title,E_Content,E_AttachmentsUrl,E_AddTime,E_EmailTime,F_UserId,F_UserName)");
             strSql.Append(" values (");
-            strSql.Append("@E_WorkOrderId,@E_EmailId,@E_IsWorkOrder,@E_SendEmail,@E_SendName,@E_Title,@E_Content,@E_AttachmentsUrl,@E_AddTime,@E_EmailTime,@F_UserId,@F_UserName)");
+            strSql.Append("@E_WorkOrderId,@E_EmailId,@E_IsWorkOrder,@E_IsAudit,@E_SendEmail,@E_SendName,@E_Title,@E_Content,@E_AttachmentsUrl,@E_AddTime,@E_EmailTime,@F_UserId,@F_UserName)");
             strSql.Append(";select @@IDENTITY");
             SqlParameter[] parameters = {
                     new SqlParameter("@E_WorkOrderId", SqlDbType.VarChar,20),
                     new SqlParameter("@E_EmailId", SqlDbType.VarChar,50),
                     new SqlParameter("@E_IsWorkOrder", SqlDbType.Int,4),
+                    new SqlParameter("@E_IsAudit", SqlDbType.Int,4),
                     new SqlParameter("@E_SendEmail", SqlDbType.VarChar,50),
                     new SqlParameter("@E_SendName", SqlDbType.NVarChar,20),
                     new SqlParameter("@E_Title", SqlDbType.VarChar,50),
@@ -67,15 +84,16 @@ namespace CallCenterApi.DAL
             parameters[0].Value = model.E_WorkOrderId;
             parameters[1].Value = model.E_EmailId;
             parameters[2].Value = model.E_IsWorkOrder;
-            parameters[3].Value = model.E_SendEmail;
-            parameters[4].Value = model.E_SendName;
-            parameters[5].Value = model.E_Title;
-            parameters[6].Value = model.E_Content;
-            parameters[7].Value = model.E_AttachmentsUrl;
-            parameters[8].Value = model.E_AddTime;
-            parameters[9].Value = model.E_EmailTime;
-            parameters[10].Value = model.F_UserId;
-            parameters[11].Value = model.F_UserName;
+            parameters[3].Value = model.E_IsAudit;
+            parameters[4].Value = model.E_SendEmail;
+            parameters[5].Value = model.E_SendName;
+            parameters[6].Value = model.E_Title;
+            parameters[7].Value = model.E_Content;
+            parameters[8].Value = model.E_AttachmentsUrl;
+            parameters[9].Value = model.E_AddTime;
+            parameters[10].Value = model.E_EmailTime;
+            parameters[11].Value = model.F_UserId;
+            parameters[12].Value = model.F_UserName;
 
             object obj = DbHelperSQL.GetSingle(strSql.ToString(), parameters);
             if (obj == null)
@@ -88,15 +106,16 @@ namespace CallCenterApi.DAL
             }
         }
         /// <summary>
-        /// 更新一条数据
-        /// </summary>
-        public bool Update(Model.T_Email_EmailMessage_Map model)
+		/// 更新一条数据
+		/// </summary>
+		public bool Update(Model.T_Email_EmailMessage_Map model)
         {
             StringBuilder strSql = new StringBuilder();
             strSql.Append("update T_Email_EmailMessage_Map set ");
             strSql.Append("E_WorkOrderId=@E_WorkOrderId,");
             strSql.Append("E_EmailId=@E_EmailId,");
             strSql.Append("E_IsWorkOrder=@E_IsWorkOrder,");
+            strSql.Append("E_IsAudit=@E_IsAudit,");
             strSql.Append("E_SendEmail=@E_SendEmail,");
             strSql.Append("E_SendName=@E_SendName,");
             strSql.Append("E_Title=@E_Title,");
@@ -111,6 +130,7 @@ namespace CallCenterApi.DAL
                     new SqlParameter("@E_WorkOrderId", SqlDbType.VarChar,20),
                     new SqlParameter("@E_EmailId", SqlDbType.VarChar,50),
                     new SqlParameter("@E_IsWorkOrder", SqlDbType.Int,4),
+                    new SqlParameter("@E_IsAudit", SqlDbType.Int,4),
                     new SqlParameter("@E_SendEmail", SqlDbType.VarChar,50),
                     new SqlParameter("@E_SendName", SqlDbType.NVarChar,20),
                     new SqlParameter("@E_Title", SqlDbType.VarChar,50),
@@ -124,16 +144,17 @@ namespace CallCenterApi.DAL
             parameters[0].Value = model.E_WorkOrderId;
             parameters[1].Value = model.E_EmailId;
             parameters[2].Value = model.E_IsWorkOrder;
-            parameters[3].Value = model.E_SendEmail;
-            parameters[4].Value = model.E_SendName;
-            parameters[5].Value = model.E_Title;
-            parameters[6].Value = model.E_Content;
-            parameters[7].Value = model.E_AttachmentsUrl;
-            parameters[8].Value = model.E_AddTime;
-            parameters[9].Value = model.E_EmailTime;
-            parameters[10].Value = model.F_UserId;
-            parameters[11].Value = model.F_UserName;
-            parameters[12].Value = model.E_Id;
+            parameters[3].Value = model.E_IsAudit;
+            parameters[4].Value = model.E_SendEmail;
+            parameters[5].Value = model.E_SendName;
+            parameters[6].Value = model.E_Title;
+            parameters[7].Value = model.E_Content;
+            parameters[8].Value = model.E_AttachmentsUrl;
+            parameters[9].Value = model.E_AddTime;
+            parameters[10].Value = model.E_EmailTime;
+            parameters[11].Value = model.F_UserId;
+            parameters[12].Value = model.F_UserName;
+            parameters[13].Value = model.E_Id;
 
             int rows = DbHelperSQL.ExecuteSql(strSql.ToString(), parameters);
             if (rows > 0)
@@ -189,7 +210,6 @@ namespace CallCenterApi.DAL
             }
         }
 
-
         /// <summary>
         /// 得到一个对象实体
         /// </summary>
@@ -197,7 +217,7 @@ namespace CallCenterApi.DAL
         {
 
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("select  top 1 E_Id,E_WorkOrderId,E_EmailId,E_IsWorkOrder,E_SendEmail,E_SendName,E_Title,E_Content,E_AttachmentsUrl,E_AddTime,E_EmailTime,F_UserId,F_UserName from T_Email_EmailMessage_Map ");
+            strSql.Append("select  top 1 E_Id,E_WorkOrderId,E_EmailId,E_IsWorkOrder,E_IsAudit,E_SendEmail,E_SendName,E_Title,E_Content,E_AttachmentsUrl,E_AddTime,E_EmailTime,F_UserId,F_UserName from T_Email_EmailMessage_Map ");
             strSql.Append(" where E_Id=@E_Id");
             SqlParameter[] parameters = {
                     new SqlParameter("@E_Id", SqlDbType.Int,4)
@@ -218,9 +238,9 @@ namespace CallCenterApi.DAL
 
 
         /// <summary>
-        /// 得到一个对象实体
-        /// </summary>
-        public Model.T_Email_EmailMessage_Map DataRowToModel(DataRow row)
+		/// 得到一个对象实体
+		/// </summary>
+		public Model.T_Email_EmailMessage_Map DataRowToModel(DataRow row)
         {
             Model.T_Email_EmailMessage_Map model = new Model.T_Email_EmailMessage_Map();
             if (row != null)
@@ -241,6 +261,10 @@ namespace CallCenterApi.DAL
                 {
                     model.E_IsWorkOrder = int.Parse(row["E_IsWorkOrder"].ToString());
                 }
+                if (row["E_IsAudit"] != null && row["E_IsAudit"].ToString() != "")
+                {
+                    model.E_IsAudit = int.Parse(row["E_IsAudit"].ToString());
+                }
                 if (row["E_SendEmail"] != null)
                 {
                     model.E_SendEmail = row["E_SendEmail"].ToString();
@@ -282,12 +306,12 @@ namespace CallCenterApi.DAL
         }
 
         /// <summary>
-        /// 获得数据列表
-        /// </summary>
-        public DataSet GetList(string strWhere)
+		/// 获得数据列表
+		/// </summary>
+		public DataSet GetList(string strWhere)
         {
             StringBuilder strSql = new StringBuilder();
-            strSql.Append("select E_Id,E_WorkOrderId,E_EmailId,E_IsWorkOrder,E_SendEmail,E_SendName,E_Title,E_Content,E_AttachmentsUrl,E_AddTime,E_EmailTime,F_UserId,F_UserName ");
+            strSql.Append("select E_Id,E_WorkOrderId,E_EmailId,E_IsWorkOrder,E_IsAudit,E_SendEmail,E_SendName,E_Title,E_Content,E_AttachmentsUrl,E_AddTime,E_EmailTime,F_UserId,F_UserName ");
             strSql.Append(" FROM T_Email_EmailMessage_Map ");
             if (strWhere.Trim() != "")
             {
@@ -297,9 +321,9 @@ namespace CallCenterApi.DAL
         }
 
         /// <summary>
-        /// 获得前几行数据
-        /// </summary>
-        public DataSet GetList(int Top, string strWhere, string filedOrder)
+		/// 获得前几行数据
+		/// </summary>
+		public DataSet GetList(int Top, string strWhere, string filedOrder)
         {
             StringBuilder strSql = new StringBuilder();
             strSql.Append("select ");
@@ -307,7 +331,7 @@ namespace CallCenterApi.DAL
             {
                 strSql.Append(" top " + Top.ToString());
             }
-            strSql.Append(" E_Id,E_WorkOrderId,E_EmailId,E_IsWorkOrder,E_SendEmail,E_SendName,E_Title,E_Content,E_AttachmentsUrl,E_AddTime,E_EmailTime,F_UserId,F_UserName ");
+            strSql.Append(" E_Id,E_WorkOrderId,E_EmailId,E_IsWorkOrder,E_IsAudit,E_SendEmail,E_SendName,E_Title,E_Content,E_AttachmentsUrl,E_AddTime,E_EmailTime,F_UserId,F_UserName ");
             strSql.Append(" FROM T_Email_EmailMessage_Map ");
             if (strWhere.Trim() != "")
             {

CallCenterApi/CallCenterApi.Interface/CallCenterApi.Interface/Controllers/EmailSendController.cs

@@ -1,6 +1,7 @@
 using CallCenter.Utility;
 using CallCenterApi.Common;
 using CallCenterApi.Interface.Controllers.Base;
+using CallCenterApi.Interface.Controllers.workorder;
 using CallCenterApi.Model;
 using LumiSoft.Net.Mail;
 using LumiSoft.Net.MIME;
@@ -150,12 +151,12 @@ namespace CallCenterApi.Interface.Controllers
             return Success("导入成功", resultEmail.Trim(',').ToString());
         }
 
-        #region 批量获取,删除邮件
+        #region 批量获取邮件,删除,审核，创建邮件工单
         /// <summary>
         /// 获取邮件信息列表（可以分页）
         /// </summary>
         /// <returns></returns>
-        //[Authority]
+        [Authority]
         public ActionResult GetEmailMessage()
         {
             BLL.T_Email_EmailMessage_Map bll = new BLL.T_Email_EmailMessage_Map();
@@ -256,6 +257,7 @@ namespace CallCenterApi.Interface.Controllers
                             {
                                 model.E_WorkOrderId = listmodel.E_WorkOrderId;
                                 model.E_IsWorkOrder = listmodel.E_IsWorkOrder;
+                                model.E_IsAudit = listmodel.E_IsAudit;
                             }
                         }
 
@@ -276,8 +278,13 @@ namespace CallCenterApi.Interface.Controllers
         /// </summary>
         /// <param name="uid">邮件唯一标识ID</param>
         /// <returns></returns>
+        [Authority]
         public ActionResult DelEmailByID(string uid)
         {
+            if (string.IsNullOrEmpty(uid))
+            {
+                return Error("参数为空");
+            }
             using (POP3_Client pop3 = new POP3_Client())
             {
                 pop3.Connect(Configs.GetValue("Email_Server"), int.Parse(Configs.GetValue("Email_Port")), false);
@@ -305,6 +312,131 @@ namespace CallCenterApi.Interface.Controllers
             return Success("删除成功");
         }
 
+        /// <summary>
+        /// 邮件审核（0未审核，1已审核）
+        /// </summary>
+        /// <param name="uid">邮件ID</param>
+        /// <returns></returns>
+        [Authority]
+        public ActionResult IsAudit(EmailrReceive input)
+        {
+            BLL.T_Email_EmailMessage_Map bll = new BLL.T_Email_EmailMessage_Map();
+            Model.T_Email_EmailMessage_Map model = new Model.T_Email_EmailMessage_Map();
+            if (string.IsNullOrEmpty(input.E_EmailId))
+            {
+                return Error("邮件Id不能为空");
+            }
+            if (string.IsNullOrEmpty(input.E_Email))
+            {
+                return Error("邮件不能为空");
+            }
+            if (string.IsNullOrEmpty(input.E_Title))
+            {
+                return Error("邮件标题不能为空");
+            }
+            var listmodel = bll.GetModelList(" E_EmailId='" + input.E_EmailId + "' and E_IsAudit = 1 ").FirstOrDefault();
+            if (listmodel == null)
+            {
+                //邮件未审核 添加              
+                //model.E_Id = 0;
+                model.E_WorkOrderId = "";
+                model.E_EmailId = input.E_EmailId;
+                model.E_IsWorkOrder = 0;    //是否已发工单(0未发，1已发)
+                model.E_IsAudit = 1;    //0未审核，1已审核
+                model.E_SendEmail = input.E_Email;
+                model.E_SendName = input.E_Email.Split('@')[0].ToString(); ;
+                model.E_Title = input.E_Title;
+                model.E_Content = input.E_Content;
+                model.E_AttachmentsUrl = input.E_AttachmentsUrl;
+                model.E_AddTime = DateTime.Now;
+                model.E_EmailTime = input.E_EmailTime;
+                model.F_UserId = int.Parse(User.UserData["F_UserID"]);
+                model.F_UserName = User.UserData["F_UserCode"];
+                int b = bll.Add(model);
+                if (b > 0)
+                {
+                    return Success("审核成功");
+                }
+                else {
+                    return Error("审核失败");
+                }
+            }
+            else {
+                //邮件已审核
+                return Error("邮件已审核");
+
+            }
+        }
+
+        /// <summary>
+        /// 添加邮件工单（E_IsWorkOrder 0未创建工单，1已创建工单）
+        /// </summary>
+        /// <returns></returns>
+        [Authority]
+        public ActionResult AddWorkOrderByEmail()
+        {
+            string emailid = RequestString.GetFormString("emailid");             //邮件id
+            int source = RequestString.GetInt("source", 2);             //信息来源(2市长信箱)
+            string cusname = RequestString.GetFormString("cusname");    //投诉人姓名
+            string cussex = RequestString.GetFormString("cussex");      //投诉人性别
+            string cusphone = RequestString.GetFormString("cusphone");  //投诉人电话
+            string cusaddress = RequestString.GetFormString("cusaddress");    //投诉人详细地址
+            string email = RequestString.GetFormString("email");        //邮箱
+            string zipcode = RequestString.GetFormString("zipcode");    //邮编
+            string conname = RequestString.GetFormString("conname");    //联系人姓名
+            string conphone = RequestString.GetFormString("conphone");  //客户电话
+            string title = RequestString.GetFormString("title");        //标题
+            string content = RequestString.GetFormString("content");    //内容
+            int sourcearea = RequestString.GetInt("sourcearea", 0);      //事发地域id
+            string sourceaddress = RequestString.GetFormString("sourceaddress");    //事发详细地址
+            string keys = RequestString.GetFormString("keys");          //关键词id(多个用英文逗号, 隔开)
+            string splituser = RequestString.GetFormString("splituser");    //分管领导id(多个用英文逗号, 隔开)
+            int type = RequestString.GetInt("type", 9);              //类型（9咨询10求助11投诉12建议13表扬14其他）
+            int bigtype = RequestString.GetInt("bigtype", 0);        //大类别
+            int smalltype = RequestString.GetInt("smalltype", 0);    //小类别
+            int isprotect = RequestString.GetInt("isprotect", 0);    //0普通1保密
+            int level = RequestString.GetInt("level", 1);            //1普通2紧急3特急
+            WorkOrderController wo = new WorkOrderController();
+
+            BLL.T_Email_EmailMessage_Map bll = new BLL.T_Email_EmailMessage_Map();
+            Model.T_Email_EmailMessage_Map model = new Model.T_Email_EmailMessage_Map();
+
+            if (string.IsNullOrEmpty(emailid))
+            {
+                return Error("邮件Id不能为空");
+            }
+            if (string.IsNullOrEmpty(email))
+            {
+                return Error("邮件不能为空");
+            }
+            if (string.IsNullOrEmpty(title))
+            {
+                return Error("标题不能为空");
+            }
+            var modelemailid = bll.GetModelList(" E_EmailId='" + emailid + "' and E_IsAudit = 1 AND ISNULL(E_IsWorkOrder,0) = 0 ").FirstOrDefault();
+            //邮件关联表 信息存在时修改
+            if (modelemailid != null)
+            {
+                string WorkOrderId = wo.AddWorkOrderBySource(source, cusname, cussex, cusphone, cusaddress, email, zipcode, conname, conphone, title, content, sourcearea, sourceaddress, keys, splituser, type, bigtype, smalltype, isprotect, level);
+                if (string.IsNullOrEmpty(WorkOrderId))
+                    return Error("操作失败");
+                model = bll.GetModelList(" E_EmailId='" + emailid + "'").FirstOrDefault();
+                if (model != null)
+                {
+                    model.E_WorkOrderId = WorkOrderId;
+                    model.E_IsWorkOrder = 1;
+                    model.E_AddTime = DateTime.Now;
+                    if (!bll.Update(model))
+                    {
+                        return Error("操作失败");
+                    }
+                    return Success("操作成功");
+                }
+                return Error("信息不存在");
+            }
+            return Error("操作失败，请先审核信息");
+        }
+
         #endregion
 
         #region 内部邮件 - 已发送邮件管理

CallCenterApi/CallCenterApi.Model/EmailrReceive.cs

@@ -44,5 +44,9 @@ namespace CallCenterApi.Model
         /// 是否已发工单(0未发，1已发)
         /// </summary>
         public int? E_IsWorkOrder { get; set; }
+        /// <summary>
+        /// 是否审核（0未审核，1已审核）
+        /// </summary>
+        public int? E_IsAudit { get; set; }
     }
 }

CallCenterApi/CallCenterApi.Model/T_Email_EmailMessage_Map.cs

@@ -14,7 +14,8 @@ namespace CallCenterApi.Model
         private int _e_id;
         private string _e_workorderid;
         private string _e_emailid;
-        private int? _e_isworkorder;
+        private int? _e_isworkorder = 0;
+        private int? _e_isaudit = 0;
         private string _e_sendemail;
         private string _e_sendname;
         private string _e_title;
@@ -57,6 +58,14 @@ namespace CallCenterApi.Model
             get { return _e_isworkorder; }
         }
         /// <summary>
+        /// 是否审核
+        /// </summary>
+        public int? E_IsAudit
+        {
+            set { _e_isaudit = value; }
+            get { return _e_isaudit; }
+        }
+        /// <summary>
         /// 发送邮箱
         /// </summary>
         public string E_SendEmail