ZLPMS/PMS.BusinessService/ProManager/ProBuiness.cs

using PMS.DBService.ProManager;
using PMS.Interface.ProManager;
using PMS.Interface.SysManager;
using QWPlatform.IService;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using PMS.DBService;
using PMS.BusinessModels.ProManager;
using PMS.EntityModels.PersonManager;
using QWPlatform.SystemLibrary;
using PMS.BusinessModels.Product;
using PMS.BusinessModels.Project;
using PMS.BusinessModels;
using QWPlatform.SystemLibrary.LogManager;
using QWPlatform.SystemLibrary.Utils;
using PMS.BusinessModels.Account;
using PMS.EntityModels.ProManager;
using System.Reflection;

namespace PMS.BusinessService.ProManager
{
    public class ProBuiness : IProModule
    {
        //提供ProService的数据服务
        private ProService DB_ProService = DataServiceBase.Instance<ProService>();
        #region 信息显示

        /// <summary>
        /// 获取所有渠道
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public string GetAll_Channel(string channelID)
        {
            var dt = DB_ProService.GetAll_Channel(channelID);
            return dt.ToJson();
        }

        /// <summary>
        /// 根据权限渠道ID获取项目
        /// </summary>
        /// <param name="ChannelID"></param>
        /// <returns></returns>
        public string Get_Pro_ById(string ChannelID, string query, string project)
        {
            var dt = DB_ProService.Get_Pro_ById(ChannelID, query, project);
            return dt.ToJson();
        }

        /// <summary>
        /// 根据渠道ID查项目信息(无数据权限)
        /// </summary>
        /// <param name="iD"></param>
        /// <returns></returns>
        public string Get_Pro_NoAuthor(string ChannelID, string query)
        {
            return DB_ProService.Get_Pro_NoAuthor(ChannelID, query).ToJson();
        }

        /// <summary>
        /// 根据项目ID获取服务器信息
        /// </summary>
        /// <param name="id"></param>
        /// <param name="page"></param>
        /// <param name="rows"></param>
        /// <returns></returns>
        public string Get_Server_ById(string id, int page, int rows)
        {
            int defaultrow = 5;
            int startnumber = Startnumber(page, rows, defaultrow);
            int endnumber = Endnumbers(page, rows, defaultrow);
            var dt = DB_ProService.Get_Server_ById(id, startnumber, endnumber);
            return dt;
        }

        /// <summary>
        /// 根据项目ID获取机构信息
        /// </summary>
        /// <param name="ChannelID"></param>
        /// <returns></returns>
        public string Get_Station_ById(string projectID, int page, int row, string Search)
        {
            int defaultrow = 5;
            int startnumber = Startnumber(page, row, defaultrow);
            int endnumber = Endnumbers(page, row, defaultrow);
            var dt = DB_ProService.Get_Station_ById(projectID, startnumber, endnumber, Search);
            return dt;
        }

        /// <summary>
        /// 根据项目ID获取项目人员
        /// </summary>
        /// <param name="id"></param>
        /// <param name="page"></param>
        /// <param name="rows"></param>
        /// <returns></returns>
        public string Get_Worker_ById(string id, int page, int rows)
        {
            int defaultrow = 5;
            int startnumber = Startnumber(page, rows, defaultrow);
            int endnumber = Endnumbers(page, rows, defaultrow);
            var dt = DB_ProService.Get_Worker_ById(id, startnumber, endnumber);
            return dt;
        }

        /// <summary>
        /// 根据项目ID获取项目产品
        /// </summary>
        /// <param name="id"></param>
        /// <param name="page"></param>
        /// <param name="rows"></param>
        /// <returns></returns>
        public string Get_Product_ById(string id)
        {
            var dt = DB_ProService.Get_Product_ById(id);
            return dt.ToJson();
        }

        /// <summary>
        /// 计算开始行
        /// </summary>
        /// <param name="page"></param>
        /// <param name="row"></param>
        /// <param name="defaultrow"></param>
        /// <returns></returns>
        private int Endnumbers(int page, int row, int defaultrow)
        {
            if (page == 0 && row == 0)
            {
                row = defaultrow;
                page = 1;

            }
            return (page) * row;
        }

        /// <summary>
        /// 计算结束行
        /// </summary>
        /// <param name="page"></param>
        /// <param name="row"></param>
        /// <param name="defaultrow"></param>
        /// <returns></returns>

        private int Startnumber(int page, int row, int defaultrow)
        {
            if (page == 0 && row == 0)
            {
                row = defaultrow;
                page = 1;

            }
            return (page - 1) * row + 1;
        }
        #endregion

        #region 添加项目
        /// <summary>
        /// 根据项目ID获取这个项目的信息
        /// </summary>
        /// <param name="iD"></param>
        /// <returns></returns>
        public DataTable ProInfo_ById(string ID)
        {
            return DB_ProService.ProInfo_ById(ID);
        }

        /// <summary>
        /// 项目性质
        /// </summary>
        /// <returns></returns>
        public string GetNature()
        {
            return DB_ProService.GetNature().ToJson();
        }

        /// <summary>
        /// 实施方式
        /// </summary>
        /// <returns></returns>
        public string GetImplementation()
        {
            return DB_ProService.GetImplementation().ToJson();
        }

        /// <summary>
        /// 项目状态
        /// </summary>
        /// <returns></returns>
        public string GetState()
        {
            return DB_ProService.GetState().ToJson();
        }

        /// <summary>
        /// 添加项目
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public string Add_Project(ProBusinessModel model, UserInfo user)
        {
            return DB_ProService.Add_Project(model, user);
        }
        #endregion

        #region 修改项目

        /// <summary>
        /// 保存项目信息
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int SaveProject(ProBusinessModel model)
        {
            return DB_ProService.SaveProject(model);
        }

        /// <summary>
        /// 获取项目信息
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public DataTable GetProInfo(string id)
        {
            return DB_ProService.GetProInfo(id);
        }

        /// <summary>
        /// 根据项目ID获取项目审核流程信息
        /// </summary>
        /// <param name="iD"></param>
        /// <returns></returns>
        public string GetXMWTLC(string iD)
        {
            return DB_ProService.GetXMWTLC(iD).ToJson();
        }

        public string GetProblem(string xMID, string iD)
        {
            return DB_ProService.GetProblem(xMID, iD).ToJson();
        }
        public string GetProjectByUserId(string id)
        {
            return DB_ProService.GetProjectByUserId(id);
        }
        public string GetInstitutionByProjectId(string id)
        {
            return DB_ProService.GetInstitutionByProjectId(id).ToJson();
        }
        public string GetInstitutionIndex(string id)
        {
            var dt = DB_ProService.GetInstitutionIndex(id);
            var dt2 = new DataTable();
            var check = string.Empty;
            List<IndexModel> list = new List<IndexModel>();
            IndexData model = null;
            var IndexModel = new IndexModel();
            if (dt != null && dt.Rows.Count > 0)
            {
                foreach (DataRow dr in dt.Rows)
                {
                    var FirstName = dr.GetValueByName<string>("首字母");
                    if (FirstName != check)
                    {
                        check = string.Empty;
                    }
                    if (check == string.Empty)
                    {
                        IndexModel = new IndexModel();
                        IndexModel.Index = FirstName;
                        IndexModel.Data = new List<IndexData>();
                        list.Add(IndexModel);
                        check = FirstName;
                    }
                    model = new IndexData();
                    model.ID = dr.GetValueByName<string>("ID");
                    model.Name = dr.GetValueByName<string>("名称");
                    model.FirstName = dr.GetValueByName<string>("首字母");
                    model.CodeName = dr.GetValueByName<string>("简码");
                    IndexModel.Data.Add(model);
                }
            }
            return Strings.ObjectToJson(list);
        }
        public string GetProjectIndexByCode(string Project, string code)
        {
            var dt = DB_ProService.GetProjectIndexByCode(Project, code);
            var dt2 = new DataTable();
            var check = string.Empty;
            List<IndexModel> list = new List<IndexModel>();
            IndexData model = null;
            var IndexModel = new IndexModel();
            if (dt != null && dt.Rows.Count > 0)
            {
                foreach (DataRow dr in dt.Rows)
                {
                    var FirstName = dr.GetValueByName<string>("首字母");
                    if (FirstName != check)
                    {
                        check = string.Empty;
                    }
                    if (check == string.Empty)
                    {
                        IndexModel = new IndexModel();
                        IndexModel.Index = FirstName;
                        IndexModel.Data = new List<IndexData>();
                        list.Add(IndexModel);
                        check = FirstName;
                    }
                    model = new IndexData();
                    model.ID = dr.GetValueByName<string>("ID");
                    model.Name = dr.GetValueByName<string>("名称");
                    model.FirstName = dr.GetValueByName<string>("首字母");
                    model.CodeName = dr.GetValueByName<string>("简码");
                    IndexModel.Data.Add(model);
                }
            }
            return Strings.ObjectToJson(list);
        }

        /// <summary>
        /// 根据渠道获取项目索引
        /// </summary>
        /// <param name="ChannelId"></param>
        /// <returns></returns>
        public string GetChannelProjectIndexByCode( string ChannelId)
        {
            var dt = DB_ProService.GetChannelProjectIndexByCode( ChannelId);
            var dt2 = new DataTable();
            var check = string.Empty;
            List<IndexModel> list = new List<IndexModel>();
            IndexData model = null;
            var IndexModel = new IndexModel();
            if (dt != null && dt.Rows.Count > 0)
            {
                foreach (DataRow dr in dt.Rows)
                {
                    var FirstName = dr.GetValueByName<string>("首字母");
                    if (FirstName != check)
                    {
                        check = string.Empty;
                    }
                    if (check == string.Empty)
                    {
                        IndexModel = new IndexModel();
                        IndexModel.Index = FirstName;
                        IndexModel.Data = new List<IndexData>();
                        list.Add(IndexModel);
                        check = FirstName;
                    }
                    model = new IndexData();
                    model.ID = dr.GetValueByName<string>("ID");
                    model.Name = dr.GetValueByName<string>("名称");
                    model.FirstName = dr.GetValueByName<string>("首字母");
                    model.CodeName = dr.GetValueByName<string>("简码");
                    IndexModel.Data.Add(model);
                }
            }
            return Strings.ObjectToJson(list);

        }

        #endregion

        #region 项目删除
        /// <summary>
        /// 根据项目ID删除项目
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public int Del_Project(string id)
        {
            return DB_ProService.Del_Project(id);
        }
        #endregion

        #region 添加机构
        /// <summary>
        /// 机构等级
        /// </summary>
        /// <returns></returns>
        public string GetLevel()
        {
            return DB_ProService.GetLevel().ToJson();
        }

        /// <summary>
        /// 添加机构
        /// </summary>
        /// <param name="model"></param>
        /// <param name="id"></param>
        /// <returns></returns>
        public int Add_Station(StationBusinessModel model)
        {
            return DB_ProService.Add_Station(model);
        }

        // <summary>
        /// 工作流分组目录
        /// </summary>
        /// <returns></returns>
        public string GetCatalog(string id)
        {
            return DB_ProService.GetCatalog(id).ToJson();
        }

        #endregion

        #region 修改机构
        public int SaveStation(StationBusinessModel model)
        {
            return DB_ProService.SaveStation(model);
        }

        public DataTable GetStationInfo(string id)
        {
            return DB_ProService.GetStationInfo(id);
        }
        #endregion

        #region 删除机构
        /// <summary>
        /// 根据机构D删除机构
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public int Del_Station(string id)
        {
            return DB_ProService.Del_Station(id);
        }
        #endregion

        #region 添加服务器
        /// <summary>
        /// 添加服务器
        /// </summary>
        /// <param name="model"></param>
        /// <param name="id"></param>
        /// <returns></returns>
        public int Add_Server(ServerBusinessModel model)
        {
            return DB_ProService.Add_Server(model);
        }

        /// <summary>
        /// 服务器类型
        /// </summary>
        /// <returns></returns>
        public string GetServerType()
        {
            return DB_ProService.GetServerType().ToJson();
        }

        /// <summary>
        /// 安装服务类型
        /// </summary>
        /// <returns></returns>
        public string GetInstallServerType()
        {
            return DB_ProService.GetInstallServerType().ToJson();
        }

        /// <summary>
        /// 数据库类型
        /// </summary>
        /// <returns></returns>
        public string GetDataBaseType()
        {
            return DB_ProService.GetDataBaseType().ToJson();
        }

        /// <summary>
        /// 预警类型
        /// </summary>
        /// <returns></returns>
        public string GetEarlyWarningType()
        {
            return DB_ProService.GetEarlyWarningType().ToJson();
        }

        /// <summary>
        /// 预警处理状态
        /// </summary>
        /// <returns></returns>
        public string GetWarningProcessingStatu()
        {
            return DB_ProService.GetWarningProcessingStatu().ToJson();
        }

        /// <summary>
        /// 项目监控状态
        /// </summary>
        /// <returns></returns>
        public string GetProjectMonitoringStatus()
        {
            return DB_ProService.GetProjectMonitoringStatus().ToJson();
        }

        /// <summary>
        /// 指标信息类型
        /// </summary>
        /// <returns></returns>
        public string GetIndicatorInformationType()
        {
            return DB_ProService.GetIndicatorInformationType().ToJson();
        }


        /// <summary>
        /// 指标信息状态
        /// </summary>
        /// <returns></returns>
        public string GetIndicatorInformationStatu()
        {
            return DB_ProService.GetIndicatorInformationStatu().ToJson();
        }


        /// <summary>
        /// 产品
        /// </summary>
        /// <returns></returns>
        public string GetProduct()
        {
            return DB_ProService.GetProduct().ToJson();
        }

        #endregion

        #region 修改服务器
        /// <summary>
        /// 根据id获取对应的服务器信息
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public DataTable GetServerInfo(string id)
        {
            return DB_ProService.GetServerInfo(id);
        }

        /// <summary>
        /// 修改服务器
        /// </summary>
        /// <param name="model"></param>
        /// <param name="id"></param>
        /// <returns></returns>
        public int UpdateServer(ServerBusinessModel model)
        {
            return DB_ProService.UpdateServer(model);
        }
        #endregion

        #region 服务器删除
        /// <summary>
        /// 根据服务器D删除服务器
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public int Del_Server(string id)
        {
            return DB_ProService.Del_Server(id);
        }
        #endregion

        #region 添加项目人员

        /// <summary>
        /// 根据渠道ID获取人员信息
        /// </summary>
        /// <returns></returns>
        public string GetWorkerInfo(string channelID)
        {
            return DB_ProService.GetWorkerInfo(channelID).ToJson();
        }

        public int Add_Worker(WorkerBusinessModel model)
        {
            return DB_ProService.Add_Worker(model);
        }


        #endregion

        #region 修改项目人员
        //根据人员ID获取人员信息
        public string GetWorkerInfoByID(string id)
        {
            return DB_ProService.GetWorkerInfoByID(id).ToJson();
        }
        public int UpdateWorker(string id)
        {
            return DB_ProService.UpdateWorker(id);
        }

        #endregion

        #region 添加产品

        /// <summary>
        /// 添加项目产品
        /// </summary>
        /// <param name="model"></param>
        /// <param name="id"></param>
        /// <returns></returns>
        public int Add_Product(ProductBusinessModel model)
        {
            return DB_ProService.Add_Product(model);
        }

        /// <summary>
        /// 根据项目ID获取产品
        /// </summary>
        /// <param name="ID"></param>
        /// <returns></returns>
        public string GetProductByID()
        {
            return DB_ProService.GetProductByID().ToJson();
        }

        /// <summary>
        /// 根据产品ID获取版本号
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public string GetEditionByID(string id)
        {
            return DB_ProService.GetEditionByID(id).ToJson();
        }


        #endregion

        #region 修改产品
        /// <summary>
        /// 更新项目产品
        /// </summary>
        /// <param name="model"></param>
        /// <param name="id"></param>
        /// <returns></returns>
        public int UpdateProduct(ProductBusinessModel model)
        {
            return DB_ProService.UpdateProduct(model);
        }
        /// <summary>
        /// 变更产品服务时间
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int AdjustServiceTime(ProjectMainRecordsModel model)
        {
            return DB_ProService.AdjustServiceTime(model);
        }
        /// <summary>
        /// 修改产品服务时间
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int UpdateAdjustServiceTime(ProjectMainRecordsModel model)
        {
            return DB_ProService.UpdateAdjustServiceTime(model);

        }
        /// <summary>
        /// 删除产品服务时间
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public int DeleteAdjustServiceTime(ProjectMainRecordsModel model)
        {
            return DB_ProService.DeleteAdjustServiceTime(model);
        }
        /// <summary>
        /// 查询单条记录
        /// </summary>
        /// <param name="ID"></param>
        /// <returns></returns>
        public string Get_SingleServiceRecord(string ID)
        {
            return DB_ProService.Get_SingleServiceRecord(ID).ToJson();
        }
        /// <summary>
        /// 根据产品ID获取服务时间
        /// </summary>
        /// <param name="QDID"></param>
        /// <param name="XMID"></param>
        /// <param name="CPID"></param>
        /// <returns></returns>
        public DataTable Get_ProductAdjustService(string QDID, string XMID, string CPID)
        {
            return DB_ProService.Get_ProductAdjustService( QDID,  XMID,  CPID);
        }



        public string GetProductInfo(string id)
        {
            return DB_ProService.GetProductInfo(id).ToJson();
        }

        /// <summary>
        /// 根据项目产品模块ID获取版本和说明
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public string GetProjectProducct(string id)
        {
            return DB_ProService.GetProjectProducct(id).ToJson();
        }

        #endregion

        #region 项目产品删除
        /// <summary>
        /// 根据项目产品ID删除项目产品
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public int Del_Product(string id)
        {
            return DB_ProService.Del_Product(id);
        }



        #endregion

        #region 批量添加
        public string ItemSiteBatch(string itemInfoId, string inputstr)
        {
            try
            {
                return DB_ProService.ItemSiteBatch(itemInfoId, inputstr);
            }
            catch (Exception ex)
            {
                Logger.Instance.Error("调用人员批量导入[ItemSite.ItemSiteBatch]时发生异常错误", ex);
                return "{\"code\":0,\"msg\":\"调用人员批量录入时发生异常错误,请查看日志!\"}";
            }
        }


        #endregion

        #region 附件
        public bool FileUpload(string projectId, string data, string name, string fileType, string indentifyID, string interfaceID)
        {
            return DB_ProService.FileUpload(projectId, data, name,  fileType, indentifyID, interfaceID) != 0;
        }

        public DataTable GetAttachment(string id,string type)
        {
            return DB_ProService.GetAttachment(id,type);
        }

        public int Delete_Img(string id)
        {
            return DB_ProService.Delete_Img(id);
        }


        #endregion

        #region 远程方式
        public string BingRemote(string id)
        {
            return DB_ProService.BingRemote(id).ToJson();
        }

        public int Add_Remote(RemoteBusinessModel model)
        {
            return DB_ProService.Add_Remote(model);
        }
        public int Edit_Remote(RemoteBusinessModel model)
        {
            return DB_ProService.Edit_Remote(model);
        }

        public int Del_Remote(RemoteBusinessModel model)
        {
            return DB_ProService.Del_Remote(model);
        }
        #endregion

        #region 个性化修改
        public string BingIdentify(string id)
        {
            return DB_ProService.BingIdentify(id).ToJson();
        }
        public string GetDataById(string id)
        {
            return DB_ProService.GetDataById(id).ToJson();
        }
        public string Add_Identify(Identify_Model model)
        {
            return DB_ProService.Add_Identify(model);
        }
        public string Edit_Identify(Identify_Model model)
        {
            return DB_ProService.Edit_Identify(model);
        }

        public int Del_Identify(string id)
        {
            return DB_ProService.Del_Identify(id);
        }
         public int Giveup_Identify(string id)
        {
            return DB_ProService.Giveup_Identify(id);
        }
        /// <summary>
        /// 根据项目员信息
        /// </summary>
        /// <returns></returns>
        public string GetWorker(string porId)
        {
            return DB_ProService.GetWorker(porId).ToJson();
        }
        #endregion

        #region 验收仪器
        public int Add_instrument(CheckinstrumentBusinessModel model)
        {
            return DB_ProService.Add_instrument(model);
        }

        public int Del_instrument(string iD)
        {
            return DB_ProService.Del_instrument(iD);
        }

        public string Binginstrument(string id)
        {
            return DB_ProService.Binginstrument(id).ToJson() ;
        }
        #endregion

        #region 验收模块
        public int Add_modual(CheckModualBusinessModel model)
        {
            return DB_ProService.Add_modual(model);
        }

        public int Del_modual(string iD)
        {
            return DB_ProService.Del_modual(iD);
        }

        public string Bingmodual(string id)
        {
            return DB_ProService.Bingmodual(id).ToJson();
        }

        #endregion

        #region 接口信息

        public string BingInterface(GlobalInte req)
        {
            return DB_ProService.BingInterface(req).ToJson();
        }

        public int Add_Interface(InterfaceBusinessModel model, string Pid)
        {
            return DB_ProService.Add_Interface(model,Pid);
        }

        public int Del_Interface(string id)
        {
            return DB_ProService.Del_Interface(id);
        }

        public DataTable GetInterface(string id)
        {
            return DB_ProService.GetInterface(id);
        }

        public int Edit_Interface(InterfaceBusinessModel model)
        {
            return DB_ProService.Edit_Interface(model);
        }
        public string GetInteProcess(string id)
        {
            return DB_ProService.GetInteProcess(id).ToJson();
        }

        public int DealInte(InterfaceBusinessModel model,string id)
        {
            return DB_ProService.DealInte(model,id);
        }
        public string GetinfoBynature(int type)
        {
            return DB_ProService.GetinfoBynature(type).ToJson();
        }

        #endregion
        #region 
        /// <summary>
        /// 迁移渠道项目【将机构变成项目】
        /// </summary>
        /// <param name="ProjectID"></param>
        /// <param name="SiteID"></param>
        /// <param name="user"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public bool MigrationOrganization(string ProjectID, string SiteID, UserInfo user, out string msg)
        {
            return DB_ProService.MigrationOrganization(ProjectID,  SiteID,  user, out  msg);
        }
        #endregion
    }
}