ZLPMS/PMS.DBService/SysManager/ConfigDBService.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using PMS.BusinessModels;
using PMS.BusinessModels.SysManager;
using QWPlatform.IService;
using System.Data;
using PMS.BusinessModels.CloudMonitorManage;

namespace PMS.DBService.SysManager
{
    /// <summary>
    /// 配置信息
    /// </summary>
    public class ConfigDBService : DataServiceBase
    {
        public bool SaveEmailConfig(emailConfig emailInfo)
        {
            //序列化对象
            var bytes = QWPlatform.SystemLibrary.Serialize.SerializeHelper.SerializeBinary(emailInfo);

            var key = PMSCONSTS.SERVER_EMAIL;
            var r = this.SelectBuilder.Columns("1")
                .From("参数配置")
                .Where("参数名", key)
                .Where("所属账户", 0)
                .Exists();

            if (r)
            {//更新
                return this.UpdateBuilder
                        .Column("参数内容", bytes)
                        .Update("参数配置")
                        .Where("参数名", key)
                        .Where("所属账户", 0)
                        .Execute() > 0;
            }
            else
            {//插入新记录
                return InsertBuilder
                        .Insert("参数配置")
                        .Column("参数名", key)
                        .Column("参数内容", bytes)
                        .Column("所属账户", 0)
                        .Execute() > 0;
            }
        }

        public bool SaveCloudMonitorConfig(CloudMonitorConfig cloudMonitorConfig)
        {
            //序列化对象
            var bytes = QWPlatform.SystemLibrary.Serialize.SerializeHelper.SerializeBinary(cloudMonitorConfig);

            var key = PMSCONSTS.CLOUD_MONITOR_CONFIG;
            var r = this.SelectBuilder.Columns("1")
                .From("参数配置")
                .Where("参数名", key)
                .Where("所属账户", 0)
                .Exists();

            if (r)
            {//更新
                return this.UpdateBuilder
                        .Column("参数内容", bytes)
                        .Update("参数配置")
                        .Where("参数名", key)
                        .Where("所属账户", 0)
                        .Execute() > 0;
            }
            else
            {//插入新记录
                return InsertBuilder
                        .Insert("参数配置")
                        .Column("参数名", key)
                        .Column("参数内容", bytes)
                        .Column("所属账户", 0)
                        .Execute() > 0;
            }
        }

        public int TimeOutConfig(string id, string minute, string dealtime, string state)
        {
            return UpdateBuilder.Update("问题流程环节").Column("受理时间", minute).Column("处理时间", dealtime).Column("超时启用",state).Where("ID", id).Execute();
        }

        public DataTable LoadTime(string id)
        {
            return SelectBuilder.From("问题流程环节").Columns("ID,受理时间,处理时间,超时启用").Where("ID",id).Select();
        }

        /// <summary>
        /// 返回问题流环节程配置
        /// </summary>
        public DataTable RingInfo()
        {
            string sql = @"select ID,名称,描述,受理时间,处理时间,decode(超时启用,1,'启用','待用') as 超时启用 from 问题流程环节";
            return SqlBuilder.SqlText(sql).Select();
        }


        //获取email配置信息
        public emailConfig GetEmailConfig()
        {
            var bytes = this.SelectBuilder.Columns("参数内容")
                 .From("参数配置")
                 .Where("参数名", PMSCONSTS.SERVER_EMAIL)
                 .Where("所属账户", 0)
                 .Select<byte[]>();

            if (bytes != null)
            {
                return QWPlatform.SystemLibrary.Serialize.SerializeHelper.DeserializeBinary(bytes) as emailConfig;
            }

            return null;
        }

        public CloudMonitorConfig GetCloudMonitorConfig()
        {
            var bytes = this.SelectBuilder.Columns("参数内容")
                 .From("参数配置")
                 .Where("参数名", PMSCONSTS.CLOUD_MONITOR_CONFIG)
                 .Where("所属账户", 0)
                 .Select<byte[]>();

            if (bytes == null)
            {
                CloudMonitorConfig config = new CloudMonitorConfig();
                config.AlertConfig = new AlertConfig();
                config.CollectionConfig= new CollectionConfig();
                SaveCloudMonitorConfig(config);
                return config;
            }

            return QWPlatform.SystemLibrary.Serialize.SerializeHelper.DeserializeBinary(bytes) as CloudMonitorConfig;
        }
    }
}