ZLPMS/PMS.DBService/ComplaintManage/Complaintrecordservice.cs


using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using QWPlatform.DataIntface;
using QWPlatform.IService;
using PMS.EntityModels.ComplaintManage;
using System.Data;
using PMS.BusinessModels.ComplaintManage;
using QWPlatform.SystemLibrary;
using PMS.EntityModels.PersonManager;

namespace PMS.DBService.ComplaintManage
{
    public class Complaintrecordservice : DataServiceBase
    {
        /// <summary>
        /// 重写数据工厂
        /// </summary>
        /// <param name="conName"></param>
        protected override void DBFctory(string conName)
        {
            base.DBFctory(conName);
        }

        /// <summary>
        /// 增加数据记录
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int Add(ComplaintRecordModel model)
        {
            model.SetDataFactory(this.DataFactoryObject);
            return model.Insert();
        }

        /// <summary>
        /// 增加数据记录
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int Add(ComplaintRecordModel model, ITransaction trans)
        {
            model.SetDataFactory(this.DataFactoryObject);
            if (trans == null)
            {
                return model.Insert();
            }
            else
            {
                return model.Insert(trans);
            }
        }

        /// <summary>
        /// 更新数据库记录
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int Update(ComplaintRecordModel model)
        {
            model.SetDataFactory(this.DataFactoryObject);

            List<string> where = new List<string>();
            where.Add("ID");

            return model.Update(where, string.Empty);
        }


        /// <summary>
        /// 更新数据库记录
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int Update(ComplaintRecordModel model, ITransaction trans)
        {
            model.SetDataFactory(this.DataFactoryObject);

            List<string> where = new List<string>();
            where.Add("ID");

            if (trans == null)
            {
                return model.Update(where, string.Empty);
            }
            else
            {
                return model.Update(trans, where, string.Empty);
            }
        }

        /// <summary>
        /// 删除数据记录
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int Delete(ComplaintRecordModel model)
        {
            model.SetDataFactory(this.DataFactoryObject);

            return model.Delete("ID");
        }

        /// <summary>
        /// 删除数据记录
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int Delete(ComplaintRecordModel model, ITransaction trans)
        {
            model.SetDataFactory(this.DataFactoryObject);
            if (trans == null)
            {
                return model.Delete("ID");
            }
            else
            {
                return model.Delete(trans, "ID");
            }
        }

        /// <summary>
        /// 查询数据对象并进行赋值
        /// </summary>
        /// <returns></returns>
        public ComplaintRecordModel Select(ComplaintRecordModel model)
        {
            model.SetDataFactory(this.DataFactoryObject);
            model.Select();
            return model;
        }

        /// <summary>
        /// 列表查询
        /// </summary>
        /// <returns></returns>
        public List<ComplaintRecordModel> SelectList(ComplaintRecordModel model)
        {
            model.SetDataFactory(this.DataFactoryObject);
            return model.SelectList<ComplaintRecordModel>();
        }

        /// <summary>
        /// 调用存储过程
        /// </summary>
        /// <returns></returns>
		public void CallProcedure(ComplaintRecordModel model)
        {
            this.ProcedureBuilder
                .Procedure("p_PT_项目投诉记录_INSERT")
                .Paramter("ID_IN", model.ID)
                .Paramter("编号_IN", model.BH)
                .Paramter("渠道ID_IN", model.QDID)
                .Paramter("项目ID_IN", model.XMID)
                .Paramter("站点ID_IN", model.ZDID)
                .Paramter("科室名_IN", model.KSM)
                .Paramter("用户姓名_IN", model.YHXM)
                .Paramter("来源_IN", model.LY)
                .Paramter("投诉事件_IN", model.TSSJ)
                .Paramter("投诉描述_IN", model.TSMS)
                .Paramter("登记时间_IN", model.DJSJ)
                .Paramter("登记人ID_IN", model.DJRID)
                .Paramter("当前处理人ID_IN", model.DQCLRID)
                .Paramter("当前处理人_IN", model.DQCLR)
                .Paramter("处理说明_IN", model.CLSM)
                .Paramter("状态_IN", model.ZT)
                .Paramter("是否分配渠道_IN", model.SFFPQD)
                .Paramter("基础编码_IN", model.JCBM)
                .Paramter("完成时间_IN", model.WCSJ)
                .Execute();
        }
        public string GetComplaintDatagrid(SelectComplaintListModel Model)
        {
            var execute = this.ProcedureBuilder
                .Procedure("b_投诉管理.p_获取投诉列表")
                .Paramter("登录人ID_In", Model.strUserId)
                .Paramter("开始行_In", Model.StartNum)
                .Paramter("结束行_In", Model.EndNum)
                .Paramter("查询条件_In", Model.Search)
                .Paramter("开始时间_In", Model.StartTimeD)
                .Paramter("结束时间_In", Model.EndTimeD)
                .Paramter("状态_In", Model.Status)
                .Paramter("渠道_Id", Model.Channel)
                .Paramter("基础编码_In", Model.ComplaintType)
                .ParamterOut("总行数_Out", DbType.Double, 5)
                .ParamterOut("Resultlist", true);
            execute.Execute();
            var dt = execute.ParameterValue<DataTable>("Resultlist");
            var total = execute.ParameterValue<decimal>("总行数_Out");
            return dt.ToEasyUIGridJson(Convert.ToInt32(total));
        }
        public string GetMyComplaintDatagrid(SelectComplaintListModel Model)
        {
            var execute = this.ProcedureBuilder
                .Procedure("b_投诉管理.p_获取投诉列表_我的")
                .Paramter("登录人ID_In", Model.strUserId)
                .Paramter("开始行_In", Model.StartNum)
                .Paramter("结束行_In", Model.EndNum)
                .Paramter("查询条件_In", Model.Search)
                .Paramter("开始时间_In", Model.StartTimeD)
                .Paramter("结束时间_In", Model.EndTimeD)
                .Paramter("状态_In", Model.Status)
                .Paramter("渠道_Id", Model.Channel)
                .Paramter("基础编码_In", Model.ComplaintType)
                .ParamterOut("总行数_Out", DbType.Double, 5)
                .ParamterOut("Resultlist", true);
            execute.Execute();
            var dt = execute.ParameterValue<DataTable>("Resultlist");
            var total = execute.ParameterValue<decimal>("总行数_Out");
            return dt.ToEasyUIGridJson(Convert.ToInt32(total));
        }
        public DataTable GetComplaintFile(string id)
        {
            return this.SelectBuilder.Columns("附件路径")
                  .From("项目投诉附件")
                  .Where("投诉ID", id)
                  .Where("类型", 1)
                  .Select();
        }
        public DataTable GetComplaintPerson(string PID)
        {
            var exe = this.ProcedureBuilder
                       .Procedure("b_投诉管理.p_获取投诉人详细")
                       .Paramter("ID_IN", PID)
                       .ParamterOut("Resultlist", true);
            exe.Execute();
            var dt = exe.ParameterValue<DataTable>("Resultlist");
            return dt;

        }

        public Person_Model GetPersonModel(string pid)
        {
            var model = new Person_Model(this.DataFactoryObject);
            model.ID = pid;
            if (model.Select())
            {
                return model;
            }

            return null;
        }

        public DataTable GetDealProcess(string id)
        {
            var execute = this.ProcedureBuilder
                       .Procedure("b_投诉管理.p_获取处理流程")
                       .Paramter("投诉id_In", id)
                       .ParamterOut("Resultlist", true);
            execute.Execute();
            var dt = execute.ParameterValue<DataTable>("Resultlist");
            return dt;
        }
        public DataTable GetCommunicate(string id)
        {
            var execute = this.ProcedureBuilder
                       .Procedure("b_投诉管理.p_投诉过程沟通_Select")
                       .Paramter("投诉ID_In", id)
                       .ParamterOut("Resultlist", true);
            execute.Execute();
            var dt = execute.ParameterValue<DataTable>("Resultlist");
            return dt;
        }
        public int SubmitCmt(string id, string Content, string UserId)
        {
            var execute = this.ProcedureBuilder
                            .Procedure("b_投诉管理.p_投诉过程沟通_Insert")
                            .Paramter("投诉ID_In", id)
                            .Paramter("沟通内容_In", Content)
                            .Paramter("沟通时间_In", this.DataBaseBuilder.GetDateTime)
                            .Paramter("沟通人ID_In", UserId)
                            .Execute();
            return execute;
        }
        public int ComplaintAccept(FormAcceptComplaint model)
        {
            return this.ProcedureBuilder
                            .Procedure("b_投诉管理.p_项目投诉过程_受理")
                            .Paramter("当前处理人id_In", model.DealPersonID)
                            .Paramter("投诉id_In", model.id)
                            .Paramter("变更状态_In", model.ChangeStatus)
                            .Paramter("描述_In", model.Remarks)
                            .Paramter("记录时间_In", model.TDealTime)
                            .Paramter("是否完成_In", model.isComplete)
                            .Execute();
        }
        public int ComplaintDistributeSub(FormAcceptComplaint model)
        {
            return this.ProcedureBuilder
                           .Procedure("b_投诉管理.p_项目投诉过程_分配")
                           .Paramter("当前处理人id_In", model.CurrentDealPerID)
                           .Paramter("投诉id_In", model.id)
                           .Paramter("变更状态_In", "服务分配")
                           .Paramter("描述_In", model.Remarks)
                           .Paramter("记录时间_In", model.TDealTime)
                           .Paramter("分配人ID_IN", model.DealPersonID)
                           .Paramter("分配人_IN", model.DealPerson)
                           .Execute();
        }
        public int ComplaintDistributeSubHead(FormAcceptComplaint model)
        {
            return this.ProcedureBuilder
                           .Procedure("b_投诉管理.p_项目投诉过程_分配_提交总部")
                           .Paramter("当前处理人id_In", model.CurrentDealPerID)
                           .Paramter("投诉id_In", model.id)
                           .Paramter("变更状态_In", "服务提交")
                           .Paramter("描述_In", model.Remarks)
                           .Paramter("记录时间_In", model.TDealTime)
                           .Execute();
        }
        public string ComplaintRegistration(string typeCode, string events, string detail, string PersonID)
        {
            var execute = this.ProcedureBuilder
                            .Procedure("b_投诉管理.p_项目投诉记录_INSERT")
                            .Paramter("投诉事件_IN", events)
                            .Paramter("投诉描述_IN", detail)
                            .Paramter("登记人ID_IN", PersonID)
                            .Paramter("基础编码_IN", typeCode)
                            .Paramter("来源_IN", 1)
                            .Paramter("登记时间_IN", this.DataBaseBuilder.GetDateTime)
                            .Paramter("状态_IN", 0)
                            .Paramter("是否分配渠道_in", 0)
                            .ParamterOut("ID_Out", DbType.String, 36);
            execute.Execute();
            var st = execute.ParameterValue<string>("ID_Out");
            return st;
        }
        public int ImageUpload(string CompliantID, string src)
        {
            return this.ProcedureBuilder
                            .Procedure("b_投诉管理.p_项目投诉附件_Insert")
                            .Paramter("投诉id_In", CompliantID)
                            .Paramter("附件路径_In", src)
                            .Execute();
        }
        public DataTable QueryComplaint(QueryComplaintModel model)
        {
            var exe = this.ProcedureBuilder
                            .Procedure("b_投诉管理.p_通过登记人ID获取投诉记录")
                            .Paramter("登记人id_In", model.UserId)
                            .Paramter("登记时间_In", model.StartTimeD)
                            .Paramter("登记时间_Ine", model.EndTimeD)
                            .Paramter("状态_In", model.Intstatus)
                            .Paramter("基础编码_In", model.Type)
                            .Paramter("投诉事件_In", model.search)
                            .ParamterOut("Resultlist", true);
            exe.Execute();
            var dt = exe.ParameterValue<DataTable>("Resultlist");
            return dt;
        }
        public DataTable GetComplaintDetail(string id)
        {
            var exe = this.ProcedureBuilder
                                        .Procedure("b_投诉管理.p_获取详细投诉信息")
                                        .Paramter("ID_IN", id)
                                        .ParamterOut("Resultlist", true);
            exe.Execute();
            var dt = exe.ParameterValue<DataTable>("Resultlist");
            return dt;
        }
        public string   DeleteComplaint(string id)
        {
            var exe = this.ProcedureBuilder
                                        .Procedure("b_投诉管理.p_项目投诉记录_Delete")
                                        .Paramter("ID_In", id)
                                        .ParamterOut("Status_Out", DbType.String,2);
            exe.Execute();
            var str = exe.ParameterValue<string>("Status_Out");
            return str;
        }
    }
}