siteserver / cms Goto Github PK

  private static string GetValidateCheckMethod(string attributeName, string displayName, InputValidateInfo validateInfo)
        {
            if (validateInfo != null)
            {
                return
                    $"checkAttributeValue('{attributeName}', '{displayName}', {validateInfo.IsRequire.ToString().ToLower()}, {validateInfo.MinNum}, {validateInfo.MaxNum}, '{validateInfo.RegExp}', '{validateInfo.ErrorMessage}');";
            }
            return string.Empty;
        }

需求：需要使用SiteServer获取其它数据库中的内容，并生成HTML。
首先已经在Web.Config中定义好连接字符串,修改后的代码如下
 //<add key="IsProtectData" value="False" />
//<add key="DatabaseType" value="SqlServer" />
//<add key="ConnectionString" value="server=(local);uid=SA;pwd=ABC;database=SiteServer" />
//<add key="EIS" value="server=(local);uid=sa;pwd=ABC;database=EIS" />


使用ConnectionStringName="EIS"语句时不生效，且生成HTML后标记为 <!-- stl:sqlcontents error:对象名 '表名称' 无效。 -->，多次测试后均报此错误。

使用ConnectionString="server=(local);uid=sa;pwd=ABC;database=EIS"时可正常使用SQL语句获取内容。
但是由于第二种方式中数据库连接信息都写在模板里，安全性太低，期待能修复此问题。
感谢！！！

public static List<CreateTaskInfo> GetPendings(int count)
{
    List<CreateTaskInfo> infoList = new List<CreateTaskInfo>();
    var sqlString = SqlUtils.GetTopSqlString("siteserver_CreateTask", "ID, CreateType, PublishmentSystemID, ChannelID, ContentID, TemplateID", "ORDER BY ID", count);

    using (IDataReader reader = WebConfigUtils.Helper.ExecuteReader(WebConfigUtils.ConnectionString, CommandType.Text, sqlString))
    {
        while (reader.Read())
        {
            var i = 0;

            CreateTaskInfo info = new CreateTaskInfo(GetInt(reader, i++),
                SiteServer.CMS.Model.Enumerations.ECreateTypeUtils.GetEnumType(GetString(reader, i++)),
                GetInt(reader, i++),
                GetInt(reader, i++),
                GetInt(reader, i++),
                GetInt(reader, i));

            infoList.Add(info);
        }
        reader.Close();
    }
    return infoList;
}

public static void F(CreateTaskInfo taskInfo)
{
    try
    {
        var start = DateTime.Now;
        var fso = new FileSystemObject(taskInfo.PublishmentSystemID);
        fso.Execute(taskInfo);
        var timeSpan = DateUtils.GetRelatedDateTimeString(start);
        CreateTaskManager.Instance.RemovePendingAndAddSuccessLog(taskInfo, timeSpan);
    }
    catch (Exception ex)
    {
        CreateTaskManager.Instance.RemovePendingAndAddFailureLog(taskInfo, ex);
    }
}

public static bool ExecutePendingCreate()
{
    try
    {
        if (!ServiceManager.IsPendingCreateTask())
        {
            return false;
        }


        while (true)
        {
            var taskInfo = CreateTaskManager.Instance.GetLastPendingTask();
            if (taskInfo == null)
            {
                ServiceManager.ClearIsPendingCreateCache();
                return true;
            }
           //并行执行
            List<CreateTaskInfo> list = GetPendings(200);
            Parallel.ForEach<CreateTaskInfo>(list, i => F(i));
        }
    }
    catch (Exception ex)
    {
        LogUtils.AddAdminLog(string.Empty, "服务组件生成失败", ex.ToString());
    }

    return false;
}