2025-03-29

进度消息订阅

 LogInfoUtil.DoExecEventPush(pfGloal, _subPushTraceLogBasis, ExecResultTypeConst.ERROR, logContent, Math.Round((record / total) * 100, 2));

特殊表不验证

\RG3.PF.Abstractions\Middlewares\ParameterVerifyMiddleware.cs

  string ignore = _configuration.GetValue<string>("parameterVerify:ignore");
  if (String.IsNullOrEmpty(ignore))
  {
      ignore = "pm-test-step-exec";
  }

时间补齐

    /// <summary>
    /// 时间补齐  IsDateEnd
    /// </summary>
    /// <param name="sqlConfig"></param>
    /// <param name="dicPK"></param>
    private void DoDateSuffix(SqlConfig sqlConfig, Dictionary<string, object> dicPK)
    {
        IEnumerable<SqlColumn> sqlColumDC = sqlConfig.ColumnsLst.Where<SqlColumn>(temp =>
        {
            return temp.IsDate == true && temp.TableId == sqlConfig.Tables[0].Id;
        });

        foreach (SqlColumn sqlColumn in sqlColumDC)
        {
            var fieldSn = $"{sqlColumn.Field}Sn";
            var field = $"{sqlColumn.Field}";
            if (dicPK.ContainsKey(fieldSn) && dicPK[fieldSn] != null && !String.IsNullOrEmpty(dicPK[fieldSn].ToString()) && dicPK[fieldSn].ToString().Length < 9)
            {
                dicPK[sqlColumn.Field] = sqlColumn.IsDateEnd == true ? DateUtil.ConvertDataWhereEndDate(dicPK[fieldSn].ToString()) : DateUtil.ConvertDataToDateTime(dicPK[fieldSn].ToString());
            }
            else if (dicPK.ContainsKey(field) && dicPK[field] != null && !String.IsNullOrEmpty(dicPK[field].ToString()) && dicPK[field].ToString().Length < 9)
            {
                dicPK[sqlColumn.Field] = sqlColumn.IsDateEnd == true ? DateUtil.ConvertDataWhereEndDate(dicPK[field].ToString()) : DateUtil.ConvertDataToDateTime(dicPK[field].ToString());
            }
        }
    }