prizeset/Util/PrizeDo.cs

using System.Data;
using System.Linq;
using System.Net.Mime;
using System.Text.RegularExpressions;
using Common;
using Infrastructure;
using LitJson;
using Microsoft.Extensions.Localization;
using Model;
using Model.Customer;
using NuGet.Packaging;
using Services;

namespace Util
{
    public class PrizeDo
    {
        public static string batchNo = "";
        public static string publicStep = "";
        public static bool logFlag = true;
        //发奖入口
        public static void sendPrize(string queueName, string content)
        {
            batchNo = DateTime.Now.ToString("yyyyMMddHHmmssfff") + Function.get_Random(3);
            publicStep = "";
            string priObjString = prizeInSet(queueName);
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-1", "接收mq数据日志");
            if(!string.IsNullOrEmpty(priObjString))
            {
                string[] priObjData = priObjString.Split('|');
                string priListIds = priObjData[0];
                int projectId = int.Parse(priObjData[1]);
                int prizeInId = int.Parse(priObjData[2]);

                var projectService = App.GetService<IPriProjectService>();
                var project = projectService.GetFirst(m => m.id == projectId) ?? new PriProject();
                logFlag = project.logFlag;

                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-2", "接收mq数据日志");

                prizeSend(projectId, prizeInId, priListIds, content, queueName);
            }
        }

        //补奖入口
        public static void addPrize(string queueName, string content)
        {
            batchNo = DateTime.Now.ToString("yyyyMMddHHmmssfff") + Function.get_Random(3);
            publicStep = "";
            string priObjString = prizeInSet(queueName);
            if(!string.IsNullOrEmpty(priObjString))
            {
                string[] priObjData = priObjString.Split('|');
                string priListIds = "";
                int projectId = int.Parse(priObjData[1]);
                int prizeInId = int.Parse(priObjData[2]);

                var projectService = App.GetService<IPriProjectService>();
                var project = projectService.GetFirst(m => m.id == projectId) ?? new PriProject();
                logFlag = project.logFlag;

                JsonData jsonObj = JsonMapper.ToObject(content);
                JsonData posSn = jsonObj["pos_sn"].ToString();
                JsonData prizeKinds = jsonObj["prize_kind_list"];
                for (int i = 0; i < prizeKinds.Count; i++)
                {
                    string kind = prizeKinds[i].ToString();
                    if(kind == "0") priListIds += "42,45,";
                    if(kind == "7") priListIds += "43,";
                    if(kind == "50") priListIds += "44,";
                    if(kind == "116") priListIds += "49,";
                    if(kind == "121") priListIds += "50,";
                    if(kind == "139") priListIds += "56,";
                }

                prizeSend(projectId, prizeInId, priListIds.TrimEnd(','), content, queueName);
            }
        }


        //接收入参
        public static Dictionary<string, string> getRequestParams(int projectId, string content)
        {
            Dictionary<string, string> dic = new();
            JsonData jsonData = JsonMapper.ToObject(content);
            var paramService = App.GetService<IPriProjectParamService>();
            var paramList = paramService.GetList(m => m.projectId == projectId);
            foreach(var param in paramList)
            {
                if(content.Contains("\"" + param.fieldEnName + "\"")) dic.Add(param.fieldEnName, jsonData[param.fieldEnName].ToString());
            }
            return dic;
        }
        public static string getRequestParams(int projectId, string content, string key)
        {
            JsonData jsonData = JsonMapper.ToObject(content);
            var paramService = App.GetService<IPriProjectParamService>();
            var param = paramService.GetFirst(m => m.projectId == projectId && m.fieldEnName == key);
            if(param != null)
            {
                return jsonData[param.fieldEnName].ToString();
            }
            return key;
        }

        //数据库链接
        public static SqlSugarClient initDb(int id)
        {
            var databaseSetService = App.GetService<IPriDatabaseSetService>();
            var connectionString = databaseSetService.GetFirst(m => m.id == id);
            string server = connectionString.ipAddress;
            int port = connectionString.port;
            string user = connectionString.userId;
            string password = connectionString.password;
            string database = connectionString.databaseName;
            var db = new SqlSugarClient(new ConnectionConfig()
            {
                ConnectionString = "server=" + server + ";port=" + port + ";user=" + user + ";password=" + password + ";database=" + database + ";charset=utf8;",
                DbType = SqlSugar.DbType.MySql,
                IsAutoCloseConnection = true,
            });
            return db;
        }

        //查询条件匹配数据
        public static List<QueryCondition> condition(int listId, int projectId, List<int> ids, string content, Dictionary<string, string> startData)
        {
            List<QueryCondition> dic = new();
            var queryTableService = App.GetService<IPriQueryTableService>();
            var queryFieldService = App.GetService<IPriQueryFieldService>();
            var returnFieldService = App.GetService<IPriReturnFieldService>();
            //查询表
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-0", "接收mq数据日志");
            var queryTables = queryTableService.GetList(m => ids.Contains(m.id) && m.startDataFlag == false).OrderByDescending(m => m.sort).ThenBy(m => m.id).ToList();
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-1", "接收mq数据日志");
            foreach(var queryTable in queryTables)
            {
                string sql = "";
                Dictionary<string, string> fieldDic = new();
                if(string.IsNullOrEmpty(queryTable.customSql))
                {
                    string tableEnName = queryTable.tableEnName;
                    if(tableEnName.Contains("#{")) tableEnName = MatchExpressionVal(tableEnName);
                    //查询返回字段
                    string fields = "";
                    var returnFields = returnFieldService.GetList(m => m.queryTableId == queryTable.id);
                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-2", "接收mq数据日志");
                    foreach(var returnField in returnFields)
                    {
                        string aliasName = returnField.fieldAliasName;
                        if(string.IsNullOrEmpty(aliasName)) aliasName = tableEnName + "_" + returnField.fieldEnName;
                        if(aliasName.Contains("-")) aliasName = aliasName.Split('-')[0];
                        if(returnField.fieldReturnKind == "2")
                        {
                            fields += "count(" + returnField.fieldEnName + ") " + aliasName + ",";
                        }
                        else if(returnField.fieldReturnKind == "3")
                        {
                            fields += "sum(" + returnField.fieldEnName + ") " + aliasName + ",";
                        }
                        else if(returnField.fieldReturnKind == "4")
                        {
                            fields += "avg(" + returnField.fieldEnName + ") " + aliasName + ",";
                        }
                        else if(returnField.fieldReturnKind == "5")
                        {
                            fields += "max(" + returnField.fieldEnName + ") " + aliasName + ",";
                        }
                        else if(returnField.fieldReturnKind == "6")
                        {
                            fields += "min(" + returnField.fieldEnName + ") " + aliasName + ",";
                        }
                        else if(returnField.fieldReturnKind == "7")
                        {
                            fields += GetDbExpressionVal(returnField.fieldEnName, projectId, content, dic, startData) + ",";
                        }
                        else
                        {
                            fields += returnField.fieldEnName + " " + aliasName + ",";
                        }
                        fieldDic.Add(aliasName, returnField.fieldName);
                    }
                    fields = fields.TrimEnd(',');

                    //查询匹配条件
                    string condi = "";
                    var queryFields = queryFieldService.GetList(m => m.queryTableId == queryTable.id);
                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-3", "接收mq数据日志");
                    foreach(var queryField in queryFields)
                    {
                        string fieldEnName = queryField.fieldEnName;
                        string fieldQueryKind = queryField.fieldQueryKind;
                        string fieldQueryModel = queryField.fieldQueryModel;
                        string fieldQueryValue = queryField.fieldQueryValue;
                        fieldQueryValue = MatchExpressionVal(fieldQueryValue);
                        string fieldQueryValueType = queryField.fieldQueryValueType;
                        if(fieldQueryKind == "1") //模糊匹配
                        {
                            condi += " and " + fieldEnName + " like ";
                            if(fieldQueryModel == "request_param")
                            {
                                condi += "'%" + getRequestParams(projectId, content, fieldQueryValue) + "%'";
                            }
                            else if(fieldQueryModel == "fixed_value")
                            {
                                condi += "'%" + GetExpressionVal(fieldQueryValue) + "%'";
                            }
                            else if(fieldQueryModel == "db_field")
                            {
                                condi += "'%" + GetDbExpressionVal(fieldQueryValue) + "%'";
                            }
                            else if(fieldQueryModel == "query_field")
                            {
                                string val = GetQueryTableData(dic, fieldQueryValue);
                                condi += "'%" + val + "%'";                            
                            }
                            else if(fieldQueryModel == "querystart_list_field")
                            {
                                string val = GetStartData(startData, fieldQueryValue);
                                condi += "'%" + val + "%'";                            
                            }
                        }
                        else if(fieldQueryKind == "2") //精确匹配
                        {
                            if(fieldQueryValue == "null" && fieldQueryValueType == "text") condi += " and " + fieldEnName + " is null";
                            else
                            {
                                condi += " and " + fieldEnName + "=";
                                string val = "";
                                if(fieldQueryModel == "request_param")
                                {
                                    Dictionary<string, string> req = getRequestParams(projectId, content);
                                    val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                                }
                                else if(fieldQueryModel == "fixed_value")
                                {
                                    val = GetExpressionVal(fieldQueryValue);
                                }
                                else if(fieldQueryModel == "db_field")
                                {
                                    val = GetDbExpressionVal(fieldQueryValue);
                                }
                                else if(fieldQueryModel == "query_field")
                                {
                                    val = GetQueryTableData(dic, fieldQueryValue);
                                }
                                else if(fieldQueryModel == "querystart_list_field")
                                {
                                    val = GetStartData(startData, fieldQueryValue);
                                }
                                if(fieldQueryValueType == "text")
                                {
                                    val = "'" + val + "'";
                                }
                                condi += val;
                            }
                        }
                        else if(fieldQueryKind == "5" || fieldQueryKind == "6") //数组匹配/排除
                        {
                            if(fieldQueryKind == "5") condi += " and " + fieldEnName + " in (";
                            else if(fieldQueryKind == "6") condi += " and " + fieldEnName + " not in (";
                            string val = "";
                            string[] valList = fieldQueryValue.Split(',');
                            if(fieldQueryModel == "request_param")
                            {
                                Dictionary<string, string> req = getRequestParams(projectId, content);
                                foreach(string sub in valList)
                                {
                                    if(fieldQueryValueType == "text")
                                    {
                                        val += "'" + req[sub] + "',";
                                    }
                                    else
                                    {
                                        val += req[sub] + ",";
                                    }
                                }
                            }
                            else if(fieldQueryModel == "fixed_value")
                            {
                                foreach(string sub in valList)
                                {
                                    if(fieldQueryValueType == "text")
                                    {
                                        val += "'" + GetExpressionVal(sub) + "',";
                                    }
                                    else
                                    {
                                        val += GetExpressionVal(sub) + ",";
                                    }
                                }
                            }
                            else if(fieldQueryModel == "db_field")
                            {
                                foreach(string sub in valList)
                                {
                                    if(fieldQueryValueType == "text")
                                    {
                                        val += "'" + GetDbExpressionVal(sub) + "',";
                                    }
                                    else
                                    {
                                        val += GetDbExpressionVal(sub) + ",";
                                    }
                                }
                            }
                            else if(fieldQueryModel == "query_field")
                            {
                                foreach(string sub in valList)
                                {
                                    string dicVal = GetQueryTableData(dic, sub);
                                    if(fieldQueryValueType == "text")
                                    {
                                        val += "'" + dicVal + "',";
                                    }
                                    else
                                    {
                                        val += dicVal + ",";
                                    }
                                }                       
                            }
                            else if(fieldQueryModel == "querystart_list_field")
                            {
                                foreach(string sub in valList)
                                {
                                    string dicVal = GetStartData(startData, sub);
                                    if(fieldQueryValueType == "text")
                                    {
                                        val += "'" + dicVal + "',";
                                    }
                                    else
                                    {
                                        val += dicVal + ",";
                                    }
                                }                       
                            }
                            val = val.TrimEnd(',');
                            condi += val + ")";
                        }
                        else if(fieldQueryKind == "3") //范围匹配
                        {
                            string[] val = fieldQueryValue.Split(':');
                            if(fieldQueryModel == "request_param")
                            {
                                Dictionary<string, string> req = getRequestParams(projectId, content);
                                if(fieldQueryValueType == "number")
                                {
                                    if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">=" + req[val[0]];
                                    if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<=" + req[val[1]];
                                }
                                else
                                {
                                    if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">='" + req[val[0]] + "'";
                                    if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<='" + req[val[1]] + "'";
                                }
                            }
                            else if(fieldQueryModel == "fixed_value")
                            {
                                if(fieldQueryValueType == "number")
                                {
                                    if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + val[0];
                                    if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + val[1];
                                }
                                else
                                {
                                    if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">='" + GetExpressionVal(val[0]) + "'";
                                    if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<='" + GetExpressionVal(val[1]) + "'";
                                }
                            }
                            else if(fieldQueryModel == "db_field")
                            {
                                if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + GetDbExpressionVal(val[0]);
                                if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + GetDbExpressionVal(val[1]);
                            }
                            else if(fieldQueryModel == "query_field")
                            {
                                string valLeft = val[0];
                                string valRight = val[1];
                                string dicValLeft = GetQueryTableData(dic, valLeft);
                                string dicValRight = GetQueryTableData(dic, valRight);
                                if(fieldQueryValueType == "number")
                                {
                                    if(!string.IsNullOrEmpty(dicValLeft)) condi += " and " + fieldEnName + ">=" + dicValLeft;
                                    if(!string.IsNullOrEmpty(dicValRight)) condi += " and " + fieldEnName + "<=" + dicValRight;
                                }
                                else
                                {
                                    if(!string.IsNullOrEmpty(dicValLeft)) condi += " and " + fieldEnName + ">='" + GetExpressionVal(dicValLeft) + "'";
                                    if(!string.IsNullOrEmpty(dicValRight)) condi += " and " + fieldEnName + "<='" + GetExpressionVal(dicValRight) + "'";
                                }
                            }
                            else if(fieldQueryModel == "querystart_list_field")
                            {
                                string valLeft = val[0];
                                string valRight = val[1];
                                string dicValLeft = GetStartData(startData, valLeft);
                                string dicValRight = GetStartData(startData, valRight);
                                if(fieldQueryValueType == "number")
                                {
                                    if(!string.IsNullOrEmpty(dicValLeft)) condi += " and " + fieldEnName + ">=" + dicValLeft;
                                    if(!string.IsNullOrEmpty(dicValRight)) condi += " and " + fieldEnName + "<=" + dicValRight;
                                }
                                else
                                {
                                    if(!string.IsNullOrEmpty(dicValLeft)) condi += " and " + fieldEnName + ">='" + GetExpressionVal(dicValLeft) + "'";
                                    if(!string.IsNullOrEmpty(dicValRight)) condi += " and " + fieldEnName + "<='" + GetExpressionVal(dicValRight) + "'";
                                }
                            }
                        }
                        else if(fieldQueryKind == "4") //取反匹配
                        {
                            if(fieldQueryValue == "null" && fieldQueryValueType == "text") condi += " and " + fieldEnName + " is not null";
                            else
                            {
                                condi += " and " + fieldEnName + "!=";
                                string val = "";
                                if(fieldQueryModel == "request_param")
                                {
                                    Dictionary<string, string> req = getRequestParams(projectId, content);
                                    val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                                }
                                else if(fieldQueryModel == "fixed_value")
                                {
                                    val = GetExpressionVal(fieldQueryValue);
                                }
                                else if(fieldQueryModel == "db_field")
                                {
                                    val = GetDbExpressionVal(fieldQueryValue);
                                }
                                else if(fieldQueryModel == "query_field")
                                {
                                    val = GetQueryTableData(dic, fieldQueryValue);
                                }
                                else if(fieldQueryModel == "querystart_list_field")
                                {
                                    val = GetStartData(startData, fieldQueryValue);
                                }
                                if(fieldQueryValueType == "text")
                                {
                                    val = "'" + val + "'";
                                }
                                condi += val;
                            }
                        }
                    }
                    sql = "select " + fields + " from " + tableEnName + " where 1=1" + condi;
                    if(!string.IsNullOrEmpty(queryTable.orderBy))
                    {
                        sql += " order by " + queryTable.orderBy;
                    }
                    sql += " limit 1";
                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-4", "接收mq数据日志");
                }
                else
                {
                    sql = queryTable.customSql;
                    sql = GetDbExpressionVal(sql, projectId, content, dic, startData);
                }
                var db = initDb(queryTable.databaseId);
                var items = db.Ado.GetDataTable(sql);
                if(items.Rows.Count > 0)
                {
                    if(string.IsNullOrEmpty(queryTable.customSql))
                    {
                        foreach(string field in fieldDic.Keys)
                        {
                            if(!dic.Any(m => m.FieldEnName == field)) dic.Add(new QueryCondition()
                            {
                                FieldName = fieldDic[field],
                                FieldEnName = field,
                                Value = items.Rows[0][field].ToString()
                            });
                        }
                    }
                    else
                    {
                        foreach(DataColumn column in items.Columns)
                        {
                            string field = column.ColumnName;
                            if(!dic.Any(m => m.FieldEnName == field)) dic.Add(new QueryCondition()
                            {
                                FieldName = field,
                                FieldEnName = field,
                                Value = items.Rows[0][field].ToString()
                            });
                        }
                    }
                }
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-5", "接收mq数据日志");
            }
            return dic;
        }

        public static DataTable conditionList(int listId, int projectId, List<int> ids, string content, int skip = 0, int size = 1000)
        {
            List<QueryCondition> dic = new();
            var queryTableService = App.GetService<IPriQueryTableService>();
            var queryFieldService = App.GetService<IPriQueryFieldService>();
            var returnFieldService = App.GetService<IPriReturnFieldService>();
            //查询表
            var queryTable = queryTableService.GetFirst(m => ids.Contains(m.id) && m.startDataFlag == true);
            if (queryTable != null)
            {
                string sql = "";
                if(string.IsNullOrEmpty(queryTable.customSql))
                {
                    string groupBy = "";
                    string tableEnName = queryTable.tableEnName;
                    if(tableEnName.Contains("#{")) tableEnName = MatchExpressionVal(tableEnName);

                    //查询返回字段
                    string fields = "";
                    Dictionary<string, string> fieldDic = new();
                    var returnFields = returnFieldService.GetList(m => m.queryTableId == queryTable.id);
                    foreach(var returnField in returnFields)
                    {
                        if(returnField.fieldReturnKind == "2")
                        {
                            fields += "count(" + returnField.fieldEnName + ") " + tableEnName + "_" + returnField.fieldEnName.Split('+')[0] + ",";
                        }
                        else if(returnField.fieldReturnKind == "3")
                        {
                            fields += "sum(" + returnField.fieldEnName + ") " + tableEnName + "_" + returnField.fieldEnName.Split('+')[0] + ",";
                        }
                        else if(returnField.fieldReturnKind == "4")
                        {
                            fields += "avg(" + returnField.fieldEnName + ") " + tableEnName + "_" + returnField.fieldEnName.Split('+')[0] + ",";
                        }
                        else if(returnField.fieldReturnKind == "5")
                        {
                            fields += "max(" + returnField.fieldEnName + ") " + tableEnName + "_" + returnField.fieldEnName.Split('+')[0] + ",";
                        }
                        else if(returnField.fieldReturnKind == "6")
                        {
                            fields += "min(" + returnField.fieldEnName + ") " + tableEnName + "_" + returnField.fieldEnName.Split('+')[0] + ",";
                        }
                        else
                        {
                            fields += returnField.fieldEnName + " " + tableEnName + "_" + returnField.fieldEnName + ",";
                        }
                        fieldDic.Add(tableEnName + "_" + returnField.fieldEnName, returnField.fieldName);
                    }
                    fields = fields.TrimEnd(',');

                    //查询匹配条件
                    string condi = "";
                    var queryFields = queryFieldService.GetList(m => m.queryTableId == queryTable.id);
                    foreach(var queryField in queryFields)
                    {
                        string fieldEnName = queryField.fieldEnName;
                        string fieldQueryKind = queryField.fieldQueryKind;
                        string fieldQueryModel = queryField.fieldQueryModel;
                        string fieldQueryValue = queryField.fieldQueryValue;
                        string fieldQueryValueType = queryField.fieldQueryValueType;

                        //拼装聚合字段
                        if(queryField.groupByFlag)
                        {
                            groupBy += queryField.fieldEnName + ",";
                        }
                        else
                        {
                            if(fieldQueryKind == "1") //模糊匹配
                            {
                                condi += " and " + fieldEnName + " like ";
                                if(fieldQueryModel == "request_param")
                                {
                                    Dictionary<string, string> req = getRequestParams(projectId, content);
                                    string val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                                    condi += "'%" + val + "%'";
                                }
                                else if(fieldQueryModel == "fixed_value")
                                {
                                    condi += "'%" + GetExpressionVal(fieldQueryValue) + "%'";
                                }
                                else if(fieldQueryModel == "db_field")
                                {
                                    condi += "'%" + GetDbExpressionVal(fieldQueryValue) + "%'";
                                }
                                else if(fieldQueryModel == "query_field")
                                {
                                    string val = GetQueryTableData(dic, fieldQueryValue);
                                    condi += "'%" + val + "%'";                            
                                }
                            }
                            else if(fieldQueryKind == "2") //精确匹配
                            {
                                if(fieldQueryValue == "null" && fieldQueryValueType == "text") condi += " and " + fieldEnName + " is null";
                                else
                                {
                                    condi += " and " + fieldEnName + "=";
                                    string val = "";
                                    if(fieldQueryModel == "request_param")
                                    {
                                        Dictionary<string, string> req = getRequestParams(projectId, content);
                                        val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                                    }
                                    else if(fieldQueryModel == "fixed_value")
                                    {
                                        val = GetExpressionVal(fieldQueryValue);
                                    }
                                    else if(fieldQueryModel == "db_field")
                                    {
                                        val = GetDbExpressionVal(fieldQueryValue);
                                    }
                                    else if(fieldQueryModel == "query_field")
                                    {
                                        val = GetQueryTableData(dic, fieldQueryValue);
                                    }
                                    if(fieldQueryValueType == "text")
                                    {
                                        val = "'" + val + "'";
                                    }
                                    condi += val;
                                }
                            }
                            else if(fieldQueryKind == "5" || fieldQueryKind == "6") //数组匹配/排除
                            {
                                if(fieldQueryKind == "5") condi += " and " + fieldEnName + " in (";
                                else if(fieldQueryKind == "6") condi += " and " + fieldEnName + " not in (";
                                string val = "";
                                string[] valList = fieldQueryValue.Split(',');
                                if(fieldQueryModel == "request_param")
                                {
                                    Dictionary<string, string> req = getRequestParams(projectId, content);
                                    foreach(string sub in valList)
                                    {
                                        if(fieldQueryValueType == "text")
                                        {
                                            val += "'" + req[sub] + "',";
                                        }
                                        else
                                        {
                                            val += req[sub] + ",";
                                        }
                                    }
                                }
                                else if(fieldQueryModel == "fixed_value")
                                {
                                    foreach(string sub in valList)
                                    {
                                        if(fieldQueryValueType == "text")
                                        {
                                            val += "'" + GetExpressionVal(sub) + "',";
                                        }
                                        else
                                        {
                                            val += GetExpressionVal(sub) + ",";
                                        }
                                    }
                                }
                                else if(fieldQueryModel == "db_field")
                                {
                                    foreach(string sub in valList)
                                    {
                                        if(fieldQueryValueType == "text")
                                        {
                                            val += "'" + GetDbExpressionVal(sub) + "',";
                                        }
                                        else
                                        {
                                            val += GetDbExpressionVal(sub) + ",";
                                        }
                                    }
                                }
                                else if(fieldQueryModel == "query_field")
                                {
                                    foreach(string sub in valList)
                                    {
                                        string dicVal = GetQueryTableData(dic, sub);
                                        if(fieldQueryValueType == "text")
                                        {
                                            val += "'" + dicVal + "',";
                                        }
                                        else
                                        {
                                            val += dicVal + ",";
                                        }
                                    }                       
                                }
                                val = val.TrimEnd(',');
                                condi += val + ")";
                            }
                            else if(fieldQueryKind == "3") //范围匹配
                            {
                                string[] val = fieldQueryValue.Split(':');
                                if(fieldQueryModel == "request_param")
                                {
                                    Dictionary<string, string> req = getRequestParams(projectId, content);
                                    if(fieldQueryValueType == "number")
                                    {
                                        if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">=" + req[val[0]];
                                        if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<=" + req[val[1]];
                                    }
                                    else
                                    {
                                        if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">='" + req[val[0]] + "'";
                                        if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<='" + req[val[1]] + "'";
                                    }
                                }
                                else if(fieldQueryModel == "fixed_value")
                                {
                                    if(fieldQueryValueType == "number")
                                    {
                                        if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + val[0];
                                        if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + val[1];
                                    }
                                    else
                                    {
                                        if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">='" + GetExpressionVal(val[0]) + "'";
                                        if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<='" + GetExpressionVal(val[1]) + "'";
                                    }
                                }
                                else if(fieldQueryModel == "db_field")
                                {
                                    if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + GetDbExpressionVal(val[0]);
                                    if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + GetDbExpressionVal(val[1]);
                                }
                                else if(fieldQueryModel == "query_field")
                                {
                                    string valLeft = val[0];
                                    string valRight = val[1];
                                    string dicValLeft = GetQueryTableData(dic, valLeft);
                                    string dicValRight = GetQueryTableData(dic, valRight);
                                    if(fieldQueryValueType == "number")
                                    {
                                        if(!string.IsNullOrEmpty(dicValLeft)) condi += " and " + fieldEnName + ">=" + dicValLeft;
                                        if(!string.IsNullOrEmpty(dicValRight)) condi += " and " + fieldEnName + "<=" + dicValRight;
                                    }
                                    else
                                    {
                                        if(!string.IsNullOrEmpty(dicValLeft)) condi += " and " + fieldEnName + ">='" + GetExpressionVal(dicValLeft) + "'";
                                        if(!string.IsNullOrEmpty(dicValRight)) condi += " and " + fieldEnName + "<='" + GetExpressionVal(dicValRight) + "'";
                                    }
                                }
                            }
                            else if(fieldQueryKind == "4") //取反匹配
                            {
                                if(fieldQueryValue == "null" && fieldQueryValueType == "text") condi += " and " + fieldEnName + " is not null";
                                else
                                {
                                    condi += " and " + fieldEnName + "!=";
                                    string val = "";
                                    if(fieldQueryModel == "request_param")
                                    {
                                        Dictionary<string, string> req = getRequestParams(projectId, content);
                                        val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                                    }
                                    else if(fieldQueryModel == "fixed_value")
                                    {
                                        val = GetExpressionVal(fieldQueryValue);
                                    }
                                    else if(fieldQueryModel == "db_field")
                                    {
                                        val = GetDbExpressionVal(fieldQueryValue);
                                    }
                                    else if(fieldQueryModel == "query_field")
                                    {
                                        val = GetQueryTableData(dic, fieldQueryValue);
                                    }
                                    if(fieldQueryValueType == "text")
                                    {
                                        val = "'" + val + "'";
                                    }
                                    condi += val;
                                }
                            }
                        }
                    }

                    if(!string.IsNullOrEmpty(groupBy)) groupBy = " group by " + groupBy.TrimEnd(',') + " order by " + groupBy.TrimEnd(',');

                    if(!string.IsNullOrEmpty(queryTable.orderBy))
                    {
                        groupBy += " " + queryTable.orderBy;
                    }
                    sql = "select " + fields + " from " + tableEnName + " where 1=1" + condi + groupBy + " limit " + skip + "," + size;
                }
                else
                {
                    sql = queryTable.customSql;
                }

                var db = initDb(queryTable.databaseId);
                var items = db.Ado.GetDataTable(sql);
                return items;
            }
            return new DataTable();
        }

        //奖励发放对象
        public static string prizeObject(int listId, int prizeObjectTag, string content)
        {
            Dictionary<string, object> logStepDic = new();
            Dictionary<string, object> dic = new();
            var prizeObjectTableService = App.GetService<IPriPrizeObjectTableService>();
            var prizeObjectFieldService = App.GetService<IPriPrizeObjectFieldService>();
            //查询表
            var prizeObjectTable = prizeObjectTableService.GetFirst(m => m.id == prizeObjectTag) ?? new PriPrizeObjectTable();
            //查询返回字段
            string field = prizeObjectTable.selectField;
            if(string.IsNullOrEmpty(field)) return "0";
            int projectId = prizeObjectTable.projectId;

            logStepDic.Add("奖励发放对象说明", prizeObjectTable.note);

            //查询匹配条件
            string condi = "";
            List<Dictionary<string, object>> condiDics = new();
            var queryFields = prizeObjectFieldService.GetList(m => m.objectTableId == prizeObjectTable.id);
            foreach(var queryField in queryFields)
            {
                string fieldName = queryField.fieldName;
                string fieldEnName = queryField.fieldEnName;
                string fieldQueryKind = queryField.fieldQueryKind;
                string fieldQueryModel = queryField.fieldQueryModel;
                string fieldQueryValue = queryField.fieldQueryValue;
                string fieldQueryValueType = queryField.fieldQueryValueType;

                Dictionary<string, object> condiDic = new();

                condiDic.Add("字段名称", fieldName);
                condiDic.Add("匹配条件", getQueryKind(fieldQueryKind));
                condiDic.Add("匹配方式", getQueryModel(fieldQueryModel));

                if(fieldQueryKind == "1") //模糊匹配
                {
                    condi += " and " + fieldEnName + " like ";
                    if(fieldQueryModel == "request_param")
                    {
                        Dictionary<string, string> req = getRequestParams(projectId, content);
                        string val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                        condi += "'%" + val + "%'";
                        condiDic.Add("匹配值", val);
                    }
                    else if(fieldQueryModel == "fixed_value")
                    {
                        string val = GetExpressionVal(fieldQueryValue);
                        condi += "'%" + val + "%'";
                        condiDic.Add("匹配值", val);
                    }
                    else if(fieldQueryModel == "db_field")
                    {
                        string val = GetDbExpressionVal(fieldQueryValue);
                        condi += "'%" + GetDbExpressionVal(fieldQueryValue) + "%'";
                        condiDic.Add("匹配值", val);
                    }
                }
                else if(fieldQueryKind == "2") //精确匹配
                {
                    condi += " and " + fieldEnName + "=";
                    string val = "";
                    if(fieldQueryModel == "request_param")
                    {
                        Dictionary<string, string> req = getRequestParams(projectId, content);
                        val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                    }
                    else if(fieldQueryModel == "fixed_value")
                    {
                        val = GetExpressionVal(fieldQueryValue);
                    }
                    else if(fieldQueryModel == "db_field")
                    {
                        val = GetDbExpressionVal(fieldQueryValue);
                    }
                    if(fieldQueryValueType == "text")
                    {
                        val = "'" + val + "'";
                    }
                    condi += val;
                    condiDic.Add("匹配值", val);
                }
                else if(fieldQueryKind == "5" || fieldQueryKind == "6") //数组匹配/排除
                {
                    if(fieldQueryKind == "5") condi += " and " + fieldEnName + " in (";
                    else if(fieldQueryKind == "6") condi += " and " + fieldEnName + " not in (";
                    string val = "";
                    string[] valList = fieldQueryValue.Split(',');
                    if(fieldQueryModel == "request_param")
                    {
                        Dictionary<string, string> req = getRequestParams(projectId, content);
                        foreach(string sub in valList)
                        {
                            if(fieldQueryValueType == "text")
                            {
                                val += "'" + req[sub] + "',";
                            }
                            else
                            {
                                val += req[sub] + ",";
                            }
                        }
                    }
                    else if(fieldQueryModel == "fixed_value")
                    {
                        foreach(string sub in valList)
                        {
                            if(fieldQueryValueType == "text")
                            {
                                val += "'" + GetExpressionVal(sub) + "',";
                            }
                            else
                            {
                                val += GetExpressionVal(sub) + ",";
                            }
                        }
                    }
                    else if(fieldQueryModel == "db_field")
                    {
                        foreach(string sub in valList)
                        {
                            if(fieldQueryValueType == "text")
                            {
                                val += "'" + GetDbExpressionVal(sub) + "',";
                            }
                            else
                            {
                                val += GetDbExpressionVal(sub) + ",";
                            }
                        }
                    }
                    val = val.TrimEnd(',');
                    condi += val + ")";
                    condiDic.Add("匹配值", val);
                }
                else if(fieldQueryKind == "3") //范围匹配
                {
                    string[] val = fieldQueryValue.Split(':');
                    if(fieldQueryModel == "request_param")
                    {
                        Dictionary<string, string> req = getRequestParams(projectId, content);
                        if(fieldQueryValueType == "number")
                        {
                            if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">=" + req[val[0]];
                            if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<=" + req[val[1]];
                        }
                        else
                        {
                            if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">='" + req[val[0]] + "'";
                            if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<='" + req[val[1]] + "'";
                        }
                    }
                    else if(fieldQueryModel == "fixed_value")
                    {
                        if(fieldQueryValueType == "number")
                        {
                            if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + val[0];
                            if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + val[1];
                        }
                        else
                        {
                            if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">='" + GetExpressionVal(val[0]) + "'";
                            if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<='" + GetExpressionVal(val[1]) + "'";
                        }
                    }
                    else if(fieldQueryModel == "db_field")
                    {
                        if(fieldQueryValueType == "number")
                        {
                            if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + val[0];
                            if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + val[1];
                        }
                        else
                        {
                            if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">='" + GetDbExpressionVal(val[0]) + "'";
                            if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<='" + GetDbExpressionVal(val[1]) + "'";
                        }
                    }
                    condiDic.Add("匹配值", val);
                }
                else if(fieldQueryKind == "4") //取反匹配
                {
                    condi += " and " + fieldEnName + "!=";
                    string val = "";
                    if(fieldQueryModel == "request_param")
                    {
                        Dictionary<string, string> req = getRequestParams(projectId, content);
                        val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                    }
                    else if(fieldQueryModel == "fixed_value")
                    {
                        val = GetExpressionVal(fieldQueryValue);
                    }
                    else if(fieldQueryModel == "db_field")
                    {
                        val = GetDbExpressionVal(fieldQueryValue);
                    }
                    if(fieldQueryValueType == "text")
                    {
                        val = "'" + val + "'";
                    }
                    condi += val;
                    condiDic.Add("匹配值", val);
                }
                condiDics.Add(condiDic);
            }

            logStepDic.Add("奖励发放对象查询条件", condiDics);

            string result = "0";
            var db = initDb(prizeObjectTable.databaseId);
            var item = db.Ado.GetScalar("select " + field + " from " + prizeObjectTable.tableEnName + " where 1=1" + condi);
            if(item != null)
            {
                result = item.ToString();
            }
            logStepDic.Add("奖励发放对象", result);
            setLogStep(listId, "奖励发放对象", logStepDic);
            return result;
        }

        //奖励发放入口
        public static string prizeInSet(string queueName)
        {
            Dictionary<string, object> dic = new();
            var prizeInSetService = App.GetService<IPriPrizeInSetService>();
            //查询表
            var prizeInSet = prizeInSetService.GetFirst(m => m.mqQueueName == queueName) ?? new PriPrizeInSet();
            if(prizeInSet.id > 0)
            {
                return prizeInSet.prizeListIds + "|" + prizeInSet.projectId + "|" + prizeInSet.id;
            }
            return "";
        }

        //奖励列表
        public static List<PriList> prizeList(int projectId, string prizeIds)
        {
            List<int> ids = Tools.SpitIntArrary(prizeIds, ',').ToList();
            var priListService = App.GetService<IPriListService>();
            var priList = priListService.GetList(m => m.projectId == projectId && ids.Contains(m.id)).ToList();
            return priList;
        }

        //奖励发放
        public static void prizeSend(int projectId, int prizeInId, string prizeIds, string content, string queueName)
        {
            var queryTableService = App.GetService<IPriQueryTableService>();
            var priList = prizeList(projectId, prizeIds);
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-3", "接收mq数据日志");
            foreach(var sub in priList)
            {
                try
                {
                    List<int> ids = Tools.SpitIntArrary(sub.queryTableIdList, ',').ToList();
                    var queryTable = queryTableService.GetFirst(m => ids.Contains(m.id) && m.startDataFlag == true);
                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-4", "接收mq数据日志");
                    if (queryTable != null)
                    {
                        int page = 0;
                        int size = queryTable.stepCount;
                        if(size == 0) size = 20;
                        bool op = true;
                        while(op)
                        {
                            int skip = page * size;
                            DataTable query = conditionList(sub.id, projectId, ids, content, skip, size);
                            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-41", "接收mq数据日志");
                            if(query.Rows.Count > 0)
                            {
                                foreach(DataRow dr in query.Rows)
                                {
                                    Dictionary<string, string> startData = new();
                                    foreach(DataColumn dc in query.Columns)
                                    {
                                        startData.Add(dc.ColumnName, dr[dc.ColumnName].ToString());
                                    }
                                    prizeSendSub(sub, projectId, prizeInId, prizeIds, content, queueName, startData);
                                }
                                page += 1;
                            }
                            else
                            {
                                op = false;
                            }
                        }
                    }
                    else
                    {
                        prizeSendSub(sub, projectId, prizeInId, prizeIds, content, queueName, new Dictionary<string, string>());
                    }
                }
                catch(Exception ex)
                {
                    setLogFieldValue(sub.id, "errLog", ex.ToString());
                }
            }
        }

        //执行每个奖励发放逻辑
        public static void prizeSendSub(PriList sub, int projectId, int prizeInId, string prizeIds, string content, string queueName, Dictionary<string, string> startData)
        {
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-" + sub.prizeName, "接收mq数据日志");
            var loopSetService = App.GetService<IPriLoopSetService>();
            var recursionStartTableService = App.GetService<IPriRecursionStartTableService>();
            var recursionStartConditionService = App.GetService<IPriRecursionStartConditionService>();
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-s1", "接收mq数据日志");
            addLog(projectId, sub.id, prizeInId, content, queueName); //初始化日志
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-s2", "接收mq数据日志");
            string prizeObjectId = prizeObject(sub.id, sub.prizeObj, content);
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-s3", "接收mq数据日志");
            var recursionFlag = sub.recursionFlag; //是否递归
            setLogStep(sub.id, "是否递归", recursionFlag ? "是" : "否");
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-s4", "接收mq数据日志");
            if(recursionFlag)
            {
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop0", "接收mq数据日志");
                List<QueryCondition> queryCondiDic = condition(sub.id, projectId, Tools.SpitIntArrary(sub.queryTableIdList, ',').ToList(), content, startData);
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop1", "接收mq数据日志");
                setLogStep(sub.id, "查询原始数据", queryCondiDic);
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop2", "接收mq数据日志");
                var loopSet = loopSetService.GetFirst(m => m.listId == sub.id) ?? new PriLoopSet();
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop3", "接收mq数据日志");
                var recursionStartTable = recursionStartTableService.GetFirst(m => m.listId == sub.id) ?? new PriRecursionStartTable();
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop4", "接收mq数据日志");
                var tableEnName = loopSet.tableEnName; //递归查询表
                var parentField = loopSet.parentField; //父字段
                var sonField = loopSet.sonField; //子字段
                var afterPrizeFlag = loopSet.afterPrizeFlag; //发奖后是否继续
                var db = initDb(loopSet.databaseId);
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop5", "接收mq数据日志");
                string objId = prizeObjectId;
                bool op = true;
                int index = 0;
                loopAmount = 0;
                List<Dictionary<string, object>> loopLogDic = new();
                while(!string.IsNullOrEmpty(objId) && objId != "0" && op)
                {
                    Dictionary<string, object> loopLog = new();
                    List<QueryCondition> condiDic = loopCondition(projectId, sub, objId, content);
                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop-in-1", "接收mq数据日志");
                    loopLog.Add("查询" + objId + "匹配数据", condiDic);
                    if(condiDic.Count > 0)
                    {
                        bool prizeFlag = false;
                        List<Dictionary<string, object>> logStepDics = new();
                        var groupNos = recursionStartConditionService.GetList(m => m.loopSetId == loopSet.id).ToList().Select(m => m.groupNo).Distinct().ToList();
                        Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop-in-2", "接收mq数据日志");
                        foreach(var groupNo in groupNos)
                        {
                            var conditions = recursionStartConditionService.GetList(m => m.loopSetId == loopSet.id && m.groupNo == groupNo);
                            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop-in-11", "接收mq数据日志");
                            if(conditions.Count > 0)
                            {
                                int allCount = conditions.Count; //所有奖励条件数
                                int passCount = 0; //通过条件数
                                foreach(var condition in conditions)
                                {
                                    if(condition.startIndex <= index)
                                    {
                                        Dictionary<string, object> logStepDic = new();
                                        
                                        var returnFieldId = condition.returnFieldId; //条件返回字段
                                        returnFieldId = MatchExpressionVal(returnFieldId);
                                        var fieldQueryKind = condition.fieldQueryKind; //匹配条件
                                        var fieldQueryModel = condition.fieldQueryModel; //匹配方式
                                        var fieldQueryValue = condition.fieldQueryValue; //匹配值
                                        var fieldQueryValueType = condition.fieldQueryValueType; //匹配值类型

                                        string checkObj = "";
                                        string checkTitle = "";
                                        if(returnFieldId.Contains(","))
                                        {
                                            string[] returnFieldIdList = returnFieldId.Split(',');
                                            foreach(string subField in returnFieldIdList)
                                            {
                                                string val = GetQueryTableData(condiDic, subField);
                                                checkObj += val + ",";
                                                string title = GetQueryTableTitle(condiDic, subField);
                                                checkTitle += title + ",";
                                            }
                                            checkObj = checkObj.TrimEnd(',');
                                            checkTitle = checkTitle.TrimEnd(',');
                                        }
                                        else if (returnFieldId.Contains("+") || returnFieldId.Contains("-") || returnFieldId.Contains("*") || returnFieldId.Contains("/") || returnFieldId.Contains("(") || returnFieldId.Contains(")"))
                                        {
                                            string expresssion = returnFieldId;
                                            checkTitle = returnFieldId;
                                            string[] returnFields = returnFieldId.Split(new char[] { '+', '-', '*', '/', '(', ')' });
                                            foreach(string returnField in returnFields)
                                            {
                                                string val = GetQueryTableData(condiDic, returnField);
                                                expresssion = expresssion.Replace(returnField, val);

                                                string title = GetQueryTableTitle(condiDic, returnField);
                                                checkTitle = checkTitle.Replace(returnField, title);
                                            }
                                            DataTable dt = new();
                                            checkObj = dt.Compute(expresssion, "false").ToString();
                                        }
                                        else if(returnFieldId.StartsWith("val"))
                                        {
                                            checkObj = returnFieldId.Replace("val{", "").Replace("}", "");
                                        }
                                        else
                                        {
                                            checkObj = GetQueryTableData(condiDic, returnFieldId);
                                            checkTitle = GetQueryTableTitle(condiDic, returnFieldId);
                                        }
                                        
                                        logStepDic.Add("标题", checkTitle);
                                        logStepDic.Add("匹配条件", getQueryKind(fieldQueryKind));
                                        logStepDic.Add("匹配方式", getQueryModel(fieldQueryModel));
                                        logStepDic.Add("匹配值", fieldQueryValue);
                                        logStepDic.Add("实际值", checkObj);

                                        var checkVal = fieldQueryValue;
                                        bool passFlag = false;

                                        if(fieldQueryKind == "1") //模糊匹配
                                        {
                                            if(fieldQueryValueType == "text")
                                            {
                                                if(checkObj.ToString().Contains(GetExpressionVal(checkVal))) 
                                                {
                                                    passCount += 1; passFlag = true;
                                                }
                                            }
                                        }
                                        else if(fieldQueryKind == "2") //精确匹配
                                        {
                                            if(fieldQueryValueType == "int")
                                            {
                                                if(int.Parse(Function.CheckInt(checkObj.ToString())) == int.Parse(Function.CheckNum(checkVal))) 
                                                {
                                                    passCount += 1; passFlag = true;
                                                }
                                            }
                                            else if(fieldQueryValueType == "number")
                                            {
                                                if(decimal.Parse(Function.CheckNum(checkObj.ToString())) == decimal.Parse(Function.CheckNum(checkVal))) 
                                                {
                                                    passCount += 1; passFlag = true;
                                                }
                                            }
                                            else
                                            {
                                                if(checkObj.ToString() == GetExpressionVal(checkVal)) 
                                                {
                                                    passCount += 1; passFlag = true;
                                                }
                                            }
                                        }
                                        else if(fieldQueryKind == "3") //范围匹配
                                        {
                                            string[] val = checkVal.Split(':');
                                            string valLeft = val[0];
                                            string valRight = val[1];
                                            if(fieldQueryModel == "request_param")
                                            {
                                                Dictionary<string, string> req = getRequestParams(projectId, content);
                                                if(fieldQueryValueType == "number")
                                                {
                                                    if(!string.IsNullOrEmpty(req[valLeft]) && !string.IsNullOrEmpty(req[valRight]) && decimal.Parse(checkObj) >= decimal.Parse(Function.CheckNum(req[valLeft])) && decimal.Parse(checkObj) <= decimal.Parse(Function.CheckNum(req[valRight]))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(!string.IsNullOrEmpty(req[valLeft]) && string.IsNullOrEmpty(req[valRight]) && decimal.Parse(checkObj) >= decimal.Parse(Function.CheckNum(req[valLeft]))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(string.IsNullOrEmpty(req[valLeft]) && !string.IsNullOrEmpty(req[valRight]) && decimal.Parse(checkObj) <= decimal.Parse(Function.CheckNum(req[valRight]))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                }
                                                else if(fieldQueryValueType == "int")
                                                {
                                                    if(!string.IsNullOrEmpty(req[valLeft]) && !string.IsNullOrEmpty(req[valRight]) && int.Parse(checkObj) >= int.Parse(Function.CheckInt(req[valLeft])) && int.Parse(checkObj) <= int.Parse(Function.CheckInt(req[valRight]))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(!string.IsNullOrEmpty(req[valLeft]) && string.IsNullOrEmpty(req[valRight]) && int.Parse(checkObj) >= int.Parse(Function.CheckInt(req[valLeft]))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(string.IsNullOrEmpty(req[valLeft]) && !string.IsNullOrEmpty(req[valRight]) && int.Parse(checkObj) <= int.Parse(Function.CheckInt(req[valRight]))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                }
                                                else if(fieldQueryValueType.StartsWith("date"))
                                                {
                                                    if(!string.IsNullOrEmpty(req[valLeft]) && !string.IsNullOrEmpty(req[valRight]) && DateTime.Parse(checkObj) >= DateTime.Parse(req[valLeft]) && DateTime.Parse(checkObj) <= DateTime.Parse(req[valRight])) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(!string.IsNullOrEmpty(req[valLeft]) && string.IsNullOrEmpty(req[valRight]) && DateTime.Parse(checkObj) >= DateTime.Parse(req[valLeft])) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(string.IsNullOrEmpty(req[valLeft]) && !string.IsNullOrEmpty(req[valRight]) && DateTime.Parse(checkObj) <= DateTime.Parse(req[valRight])) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                }
                                            }
                                            else if(fieldQueryModel == "fixed_value")
                                            {
                                                string checkValLeft = valLeft.Replace("#{", "").Replace("}#", "");
                                                string checkValRight = valRight.Replace("#{", "").Replace("}#", "");
                                                if(checkValLeft.Contains(",")) checkValLeft = checkValLeft.Split(',')[0];
                                                if(checkValRight.Contains(",")) checkValRight = checkValRight.Split(',')[0];
                                                valLeft = GetExpressionVal(valLeft);
                                                valRight = GetExpressionVal(valRight);
                                                if(fieldQueryValueType == "number")
                                                {
                                                    if(!string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && decimal.Parse(checkObj) >= decimal.Parse(Function.CheckNum(valLeft)) && decimal.Parse(Function.CheckNum(checkObj.ToString())) <= decimal.Parse(Function.CheckNum(valRight))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(!string.IsNullOrEmpty(valLeft) && string.IsNullOrEmpty(valRight) && decimal.Parse(Function.CheckNum(checkObj.ToString())) >= decimal.Parse(Function.CheckNum(valLeft))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && decimal.Parse(Function.CheckNum(checkObj.ToString())) <= decimal.Parse(Function.CheckNum(valRight))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                }
                                                else if(fieldQueryValueType == "int")
                                                {
                                                    if(!string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && int.Parse(checkObj) >= int.Parse(Function.CheckInt(valLeft)) && int.Parse(Function.CheckInt(checkObj.ToString())) <= int.Parse(Function.CheckInt(valRight))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(!string.IsNullOrEmpty(valLeft) && string.IsNullOrEmpty(valRight) && int.Parse(Function.CheckInt(checkObj.ToString())) >= int.Parse(Function.CheckInt(valLeft))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && int.Parse(Function.CheckInt(checkObj.ToString())) <= int.Parse(Function.CheckInt(valRight))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                }
                                                else if(fieldQueryValueType.StartsWith("date"))
                                                {
                                                    if(valLeft == "0") valLeft = "";
                                                    if(valRight == "0") valRight = "";
                                                    if(checkObj != "0" && checkObj != "")
                                                    {
                                                        if(!string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && DateTime.Parse(checkObj) >= DateTime.Parse(GetExpressionVal(valLeft)) && DateTime.Parse(checkObj) <= DateTime.Parse(GetExpressionVal(valRight))) 
                                                        {
                                                            passCount += 1; passFlag = true;
                                                        }
                                                        else if(!string.IsNullOrEmpty(valLeft) && string.IsNullOrEmpty(valRight) && DateTime.Parse(checkObj) >= DateTime.Parse(GetExpressionVal(valLeft))) 
                                                        {
                                                            passCount += 1; passFlag = true;
                                                        }
                                                        else if(string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && DateTime.Parse(checkObj) <= DateTime.Parse(GetExpressionVal(valRight))) 
                                                        {
                                                            passCount += 1; passFlag = true;
                                                        }
                                                    }
                                                }
                                            }
                                            else if(fieldQueryModel == "query_field")
                                            {                                                
                                                valLeft = GetComputeVal(queryCondiDic, valLeft);
                                                valRight = GetComputeVal(queryCondiDic, valRight);
                                                if(fieldQueryValueType == "number")
                                                {
                                                    if(!string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && decimal.Parse(checkObj) >= decimal.Parse(Function.CheckNum(valLeft)) && decimal.Parse(Function.CheckNum(checkObj.ToString())) <= decimal.Parse(Function.CheckNum(valRight))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(!string.IsNullOrEmpty(valLeft) && string.IsNullOrEmpty(valRight) && decimal.Parse(Function.CheckNum(checkObj.ToString())) >= decimal.Parse(Function.CheckNum(valLeft))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && decimal.Parse(Function.CheckNum(checkObj.ToString())) <= decimal.Parse(Function.CheckNum(valRight))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                }
                                                else if(fieldQueryValueType == "int")
                                                {
                                                    if(!string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && int.Parse(checkObj) >= int.Parse(Function.CheckInt(valLeft)) && int.Parse(Function.CheckInt(checkObj.ToString())) <= int.Parse(Function.CheckInt(valRight))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(!string.IsNullOrEmpty(valLeft) && string.IsNullOrEmpty(valRight) && int.Parse(Function.CheckInt(checkObj.ToString())) >= int.Parse(Function.CheckInt(valLeft))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                    else if(string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && int.Parse(Function.CheckInt(checkObj.ToString())) <= int.Parse(Function.CheckInt(valRight))) 
                                                    {
                                                        passCount += 1; passFlag = true;
                                                    }
                                                }
                                                else if(fieldQueryValueType.StartsWith("date"))
                                                {
                                                    if(valLeft == "0") valLeft = "";
                                                    if(valRight == "0") valRight = "";
                                                    if(checkObj != "0" && checkObj != "")
                                                    {
                                                        if(!string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && DateTime.Parse(checkObj) >= DateTime.Parse(GetExpressionVal(valLeft)) && DateTime.Parse(checkObj) <= DateTime.Parse(GetExpressionVal(valRight))) 
                                                        {
                                                            passCount += 1; passFlag = true;
                                                        }
                                                        else if(!string.IsNullOrEmpty(valLeft) && string.IsNullOrEmpty(valRight) && DateTime.Parse(checkObj) >= DateTime.Parse(GetExpressionVal(valLeft))) 
                                                        {
                                                            passCount += 1; passFlag = true;
                                                        }
                                                        else if(string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && DateTime.Parse(checkObj) <= DateTime.Parse(GetExpressionVal(valRight))) 
                                                        {
                                                            passCount += 1; passFlag = true;
                                                        }
                                                    }
                                                }
                                            }
                                        }
                                        else if(fieldQueryKind == "4") //取反匹配
                                        {
                                            if(fieldQueryValueType == "int")
                                            {
                                                if(int.Parse(checkObj) != int.Parse(Function.CheckInt(checkVal))) 
                                                {
                                                    passCount += 1; passFlag = true;
                                                }
                                            }
                                            else if(fieldQueryValueType == "number")
                                            {
                                                if(decimal.Parse(checkObj) != decimal.Parse(Function.CheckNum(checkVal))) 
                                                {
                                                    passCount += 1; passFlag = true;
                                                }
                                            }
                                            else if(fieldQueryValueType == "text")
                                            {
                                                if(checkObj.ToString() != GetExpressionVal(checkVal)) 
                                                {
                                                    passCount += 1; passFlag = true;
                                                }
                                            }
                                        }
                                        else if(fieldQueryKind == "5" || fieldQueryKind == "6") //数组匹配/排除
                                        {
                                            string val = ",";
                                            string[] valList = checkVal.Split(',');
                                            if(fieldQueryModel == "request_param")
                                            {
                                                Dictionary<string, string> req = getRequestParams(projectId, content);
                                                foreach(string subVal in valList)
                                                {
                                                    val += req[subVal] + ",";
                                                }
                                            }
                                            else if(fieldQueryModel == "fixed_value")
                                            {
                                                foreach(string subVal in valList)
                                                {
                                                    val += GetExpressionVal(subVal) + ",";
                                                }
                                            }
                                            else if(fieldQueryModel == "db_field")
                                            {
                                                foreach(string subVal in valList)
                                                {
                                                    val += GetDbExpressionVal(subVal) + ",";
                                                }
                                            }
                                            if(fieldQueryKind == "5" && val.Contains("," + checkObj.ToString() + ",")) 
                                            {
                                                passCount += 1; passFlag = true;
                                            }
                                            if(fieldQueryKind == "6" && !val.Contains("," + checkObj.ToString() + ",")) 
                                            {
                                                passCount += 1; passFlag = true;
                                            }
                                        }
                                        logStepDic.Add("状态", passFlag ? "通过" : "未通过");
                                        logStepDics.Add(logStepDic);
                                    }
                                }
                                if(loopSet.conditionMode == "all" && passCount == allCount) prizeFlag = true;
                                else if(loopSet.conditionMode == "one" && passCount >= 1) prizeFlag = true;
                                else if(loopSet.conditionMode == "two" && passCount >= 2) prizeFlag = true;
                                else if(loopSet.conditionMode == "three" && passCount >= 3) prizeFlag = true;
                                // else prizeFlag = false;
                            }
                            // else
                            // {
                            //     prizeFlag = false;
                            // }
                        }
                        loopLog.Add(objId + "匹配情况", logStepDics);
                        loopLog.Add("匹配结果", prizeFlag);
                        if(prizeFlag)
                        {
                            decimal prizeAmt = prizeSendDo(projectId, sub, objId, content, loopSet, startData);
                            op = afterPrizeFlag;
                        }
                        Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop-in-3", "接收mq数据日志");
                    }
                    loopLogDic.Add(loopLog);
                    var parent = db.Ado.GetScalar("select " + parentField + " from " + tableEnName + " where " + sonField + "=" + objId);
                    if(parent != null)
                    {
                        objId = parent.ToString();
                    }
                    else
                    {
                        objId = "0";
                    }
                    index += 1;
                }
                setLogStep(sub.id, "向上递归流程", loopLogDic);
            }
            else
            {
                prizeSendDo(projectId, sub, prizeObjectId, content, new PriLoopSet(), startData);
            }
        }

        static decimal loopAmount = 0;
        public static decimal prizeSendDo(int projectId, PriList sub, string prizeObjectId, string content, PriLoopSet set, Dictionary<string, string> startData)
        {
            var projectService = App.GetService<IPriProjectService>();
            var recordService = App.GetService<IPriRecordService>();
            var conditionService = App.GetService<IPriConditionService>();
            var returnFieldService = App.GetService<IPriReturnFieldService>();
            // var queryTableService = App.GetService<IPriQueryTableService>();
            var amountSetService = App.GetService<IPriListAmountSetService>();

            var project = projectService.GetFirst(m => m.id == projectId) ?? new PriProject();
            //查询匹配条件
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p1", "接收mq数据日志");
            List<QueryCondition> condiDic = condition(sub.id, projectId, Tools.SpitIntArrary(sub.queryTableIdList, ',').ToList(), content, startData);
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p2", "接收mq数据日志");
            if(sub.prizeSourceFieldType == "loop") MergeCondiDic(condiDic, loopCondition(projectId, sub, prizeObjectId, content));
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p3", "接收mq数据日志");
            setLogStep(sub.id, "发放奖励查询来源数据", condiDic);
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p4", "接收mq数据日志");
            var prizeSourceField = sub.prizeSourceField; //奖励金额来源字段（对应条件匹配返回字段）
            var prizePercent = sub.prizePercent; //奖励比例
            var prizeAmount = sub.prizeAmount; //奖励固定值
            var prizeContent = sub.prizeContent; //奖励内容
            var conditionMode = sub.conditionMode; //条件模式
            var recursionFlag = sub.recursionFlag; //是否递归
            var prizeCode = sub.prizeCode; //奖励代码

            prizeSourceField = MatchExpressionVal(prizeSourceField);
            
            bool op = false;
            var groupNos = conditionService.GetList(m => m.listId == sub.id).ToList().Select(m => m.groupNo).Distinct().ToList();
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p5", "接收mq数据日志");
            foreach(var groupNo in groupNos)
            {
                var conditions = conditionService.GetList(m => m.listId == sub.id && m.groupNo == groupNo);
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p6", "接收mq数据日志");
                setLogStep(sub.id, "发放奖励匹配条件", condiDic);
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p7", "接收mq数据日志");
                int allCount = conditions.Count; //所有奖励条件数
                int passCount = 0; //通过条件数
                List<Dictionary<string, object>> logStepDics = new();
                foreach(var condition in conditions)
                {
                    Dictionary<string, object> logStepDic = new();
                    var returnFieldId = condition.returnFieldId; //条件返回字段
                    returnFieldId = MatchExpressionVal(returnFieldId);
                    var fieldQueryKind = condition.fieldQueryKind; //匹配条件
                    var fieldQueryModel = condition.fieldQueryModel; //匹配方式
                    var fieldQueryValue = condition.fieldQueryValue; //匹配值
                    var fieldQueryValueType = condition.fieldQueryValueType; //匹配值类型

                    string checkObj = "";
                    string checkTitle = "";
                    if(returnFieldId.Contains(","))
                    {
                        string[] returnFieldIdList = returnFieldId.Split(',');
                        foreach(string subField in returnFieldIdList)
                        {
                            string val = GetQueryTableData(condiDic, subField);
                            checkObj += val + ",";
                            string title = GetQueryTableTitle(condiDic, subField);
                            checkTitle += title + ",";
                        }
                        checkObj = checkObj.TrimEnd(',');
                        checkTitle = checkTitle.TrimEnd(',');
                    }
                    else if (returnFieldId.Contains("+") || returnFieldId.Contains("-") || returnFieldId.Contains("*") || returnFieldId.Contains("/") || returnFieldId.Contains("(") || returnFieldId.Contains(")"))
                    {
                        string expresssion = returnFieldId;
                        checkTitle = returnFieldId;
                        string[] returnFields = returnFieldId.Split(new char[] { '+', '-', '*', '/', '(', ')' });
                        foreach(string returnField in returnFields)
                        {
                            string val = GetQueryTableData(condiDic, returnField);
                            expresssion = expresssion.Replace(returnField, val);

                            string title = GetQueryTableTitle(condiDic, returnField);
                            checkTitle = checkTitle.Replace(returnField, title);
                        }
                        DataTable dt = new();
                        checkObj = dt.Compute(expresssion, "false").ToString();
                    }
                    else if(returnFieldId.StartsWith("val"))
                    {
                        checkObj = returnFieldId.Replace("val{", "").Replace("}", "");
                    }
                    else
                    {
                        checkObj = GetQueryTableData(condiDic, returnFieldId);
                        checkTitle = GetQueryTableTitle(condiDic, returnFieldId);
                    }
                    // if(!sub.recursionFlag)
                    // {
                        logStepDic.Add("标题", checkTitle);
                        logStepDic.Add("匹配条件", getQueryKind(fieldQueryKind));
                        logStepDic.Add("匹配方式", getQueryModel(fieldQueryModel));
                        logStepDic.Add("匹配值", fieldQueryValue);
                        logStepDic.Add("实际值", checkObj);
                    // }

                    string checkVal = fieldQueryValue;
                    bool passFlag = false;

                    if(fieldQueryKind == "1") //模糊匹配
                    {
                        if(fieldQueryValueType == "text")
                        {
                            if(checkObj.ToString().Contains(GetExpressionVal(checkVal))) 
                            {
                                passCount += 1; passFlag = true;
                            }
                        }
                    }
                    else if(fieldQueryKind == "2") //精确匹配
                    {
                        if(fieldQueryValueType == "int")
                        {
                            if(int.Parse(Function.CheckInt(checkObj.ToString())) == int.Parse(Function.CheckNum(checkVal))) 
                            {
                                passCount += 1; passFlag = true;
                            }
                        }
                        else if(fieldQueryValueType == "number")
                        {
                            if(decimal.Parse(Function.CheckNum(checkObj.ToString())) == decimal.Parse(Function.CheckNum(checkVal))) 
                            {
                                passCount += 1; passFlag = true;
                            }
                        }
                        else
                        {
                            if(checkObj.ToString() == GetExpressionVal(checkVal)) 
                            {
                                passCount += 1; passFlag = true;
                            }
                        }
                    }
                    else if(fieldQueryKind == "3") //范围匹配
                    {
                        string[] val = checkVal.Split(':');
                        string valLeft = val[0];
                        string valRight = val[1];
                        if(fieldQueryModel == "request_param")
                        {
                            Dictionary<string, string> req = getRequestParams(projectId, content);
                            if(fieldQueryValueType == "number")
                            {
                                if(!string.IsNullOrEmpty(req[valLeft]) && !string.IsNullOrEmpty(req[valRight]) && decimal.Parse(checkObj) >= decimal.Parse(Function.CheckNum(req[valLeft])) && decimal.Parse(checkObj) <= decimal.Parse(Function.CheckNum(req[valRight]))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(!string.IsNullOrEmpty(req[valLeft]) && string.IsNullOrEmpty(req[valRight]) && decimal.Parse(checkObj) >= decimal.Parse(Function.CheckNum(req[valLeft]))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(string.IsNullOrEmpty(req[valLeft]) && !string.IsNullOrEmpty(req[valRight]) && decimal.Parse(checkObj) <= decimal.Parse(Function.CheckNum(req[valRight]))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                            }
                            else if(fieldQueryValueType == "int")
                            {
                                if(!string.IsNullOrEmpty(req[valLeft]) && !string.IsNullOrEmpty(req[valRight]) && int.Parse(checkObj) >= int.Parse(Function.CheckInt(req[valLeft])) && int.Parse(checkObj) <= int.Parse(Function.CheckInt(req[valRight]))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(!string.IsNullOrEmpty(req[valLeft]) && string.IsNullOrEmpty(req[valRight]) && int.Parse(checkObj) >= int.Parse(Function.CheckInt(req[valLeft]))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(string.IsNullOrEmpty(req[valLeft]) && !string.IsNullOrEmpty(req[valRight]) && int.Parse(checkObj) <= int.Parse(Function.CheckInt(req[valRight]))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                            }
                            else if(fieldQueryValueType.StartsWith("date"))
                            {
                                if(!string.IsNullOrEmpty(req[valLeft]) && !string.IsNullOrEmpty(req[valRight]) && DateTime.Parse(checkObj) >= DateTime.Parse(req[valLeft]) && DateTime.Parse(checkObj) <= DateTime.Parse(req[valRight])) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(!string.IsNullOrEmpty(req[valLeft]) && string.IsNullOrEmpty(req[valRight]) && DateTime.Parse(checkObj) >= DateTime.Parse(req[valLeft])) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(string.IsNullOrEmpty(req[valLeft]) && !string.IsNullOrEmpty(req[valRight]) && DateTime.Parse(checkObj) <= DateTime.Parse(req[valRight])) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                            }
                        }
                        else if(fieldQueryModel == "fixed_value")
                        {
                            valLeft = GetExpressionVal(valLeft);
                            valRight = GetExpressionVal(valRight);
                            if(fieldQueryValueType == "number")
                            {
                                if(!string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && decimal.Parse(Function.CheckNum(checkObj.ToString())) >= decimal.Parse(Function.CheckNum(valLeft)) && decimal.Parse(Function.CheckNum(checkObj.ToString())) <= decimal.Parse(Function.CheckNum(valRight))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(!string.IsNullOrEmpty(valLeft) && string.IsNullOrEmpty(valRight) && decimal.Parse(Function.CheckNum(checkObj.ToString())) >= decimal.Parse(Function.CheckNum(valLeft))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && decimal.Parse(Function.CheckNum(checkObj.ToString())) <= decimal.Parse(Function.CheckNum(valRight))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                            }
                            else if(fieldQueryValueType == "int")
                            {
                                if(!string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && int.Parse(Function.CheckNum(checkObj.ToString())) >= int.Parse(Function.CheckInt(valLeft)) && int.Parse(Function.CheckInt(checkObj.ToString())) <= int.Parse(Function.CheckInt(valRight))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(!string.IsNullOrEmpty(valLeft) && string.IsNullOrEmpty(valRight) && int.Parse(Function.CheckInt(checkObj.ToString())) >= int.Parse(Function.CheckInt(valLeft))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && int.Parse(Function.CheckInt(checkObj.ToString())) <= int.Parse(Function.CheckInt(valRight))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                            }
                            else if(fieldQueryValueType.StartsWith("date"))
                            {
                                if(valLeft == "0") valLeft = "";
                                if(valRight == "0") valRight = "";
                                if(checkObj != "0" && checkObj != "")
                                {
                                    if(!string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && DateTime.Parse(checkObj.ToString()) >= DateTime.Parse(GetExpressionVal(valLeft)) && DateTime.Parse(checkObj.ToString()) <= DateTime.Parse(GetExpressionVal(valRight))) 
                                    {
                                        passCount += 1; passFlag = true;
                                    }
                                    else if(!string.IsNullOrEmpty(valLeft) && string.IsNullOrEmpty(valRight) && DateTime.Parse(checkObj.ToString()) >= DateTime.Parse(GetExpressionVal(valLeft))) 
                                    {
                                        passCount += 1; passFlag = true;
                                    }
                                    else if(string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && DateTime.Parse(checkObj.ToString()) <= DateTime.Parse(GetExpressionVal(valRight))) 
                                    {
                                        passCount += 1; passFlag = true;
                                    }
                                }
                            }
                        }
                        else if(fieldQueryModel == "query_field")
                        {
                            string checkValLeft = valLeft.Replace("#{", "").Replace("}#", "");
                            string checkValRight = valRight.Replace("#{", "").Replace("}#", "");
                            if(checkValLeft.Contains(",")) checkValLeft = checkValLeft.Split(',')[0];
                            if(checkValRight.Contains(",")) checkValRight = checkValRight.Split(',')[0];
                            if(!string.IsNullOrEmpty(valLeft)) valLeft = valLeft.Replace(checkValLeft, GetQueryTableData(condiDic, checkValLeft));
                            if(!string.IsNullOrEmpty(valRight)) valRight = valRight.Replace(checkValRight, GetQueryTableData(condiDic, checkValRight));
                            valLeft = GetExpressionVal(valLeft);
                            valRight = GetExpressionVal(valRight);
                            if(fieldQueryValueType == "number")
                            {
                                if(!string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && decimal.Parse(Function.CheckNum(checkObj.ToString())) >= decimal.Parse(Function.CheckNum(valLeft)) && decimal.Parse(Function.CheckNum(checkObj.ToString())) <= decimal.Parse(Function.CheckNum(valRight))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(!string.IsNullOrEmpty(valLeft) && string.IsNullOrEmpty(valRight) && decimal.Parse(Function.CheckNum(checkObj.ToString())) >= decimal.Parse(Function.CheckNum(valLeft))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && decimal.Parse(Function.CheckNum(checkObj.ToString())) <= decimal.Parse(Function.CheckNum(valRight))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                            }
                            else if(fieldQueryValueType == "int")
                            {
                                if(!string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && int.Parse(Function.CheckNum(checkObj.ToString())) >= int.Parse(Function.CheckInt(valLeft)) && int.Parse(Function.CheckInt(checkObj.ToString())) <= int.Parse(Function.CheckInt(valRight))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(!string.IsNullOrEmpty(valLeft) && string.IsNullOrEmpty(valRight) && int.Parse(Function.CheckInt(checkObj.ToString())) >= int.Parse(Function.CheckInt(valLeft))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                                else if(string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && int.Parse(Function.CheckInt(checkObj.ToString())) <= int.Parse(Function.CheckInt(valRight))) 
                                {
                                    passCount += 1; passFlag = true;
                                }
                            }
                            else if(fieldQueryValueType.StartsWith("date"))
                            {
                                if(valLeft == "0") valLeft = "";
                                if(valRight == "0") valRight = "";
                                if(checkObj != "0" && checkObj != "")
                                {
                                    if(!string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && DateTime.Parse(checkObj.ToString()) >= DateTime.Parse(GetExpressionVal(valLeft)) && DateTime.Parse(checkObj.ToString()) <= DateTime.Parse(GetExpressionVal(valRight))) 
                                    {
                                        passCount += 1; passFlag = true;
                                    }
                                    else if(!string.IsNullOrEmpty(valLeft) && string.IsNullOrEmpty(valRight) && DateTime.Parse(checkObj.ToString()) >= DateTime.Parse(GetExpressionVal(valLeft))) 
                                    {
                                        passCount += 1; passFlag = true;
                                    }
                                    else if(string.IsNullOrEmpty(valLeft) && !string.IsNullOrEmpty(valRight) && DateTime.Parse(checkObj.ToString()) <= DateTime.Parse(GetExpressionVal(valRight))) 
                                    {
                                        passCount += 1; passFlag = true;
                                    }
                                }
                            }
                        }
                    }
                    else if(fieldQueryKind == "4") //取反匹配
                    {
                        if(fieldQueryValueType == "int")
                        {
                            if(int.Parse(Function.CheckNum(checkObj.ToString())) != int.Parse(Function.CheckInt(checkVal))) 
                            {
                                passCount += 1; passFlag = true;
                            }
                        }
                        else if(fieldQueryValueType == "number")
                        {
                            if(decimal.Parse(Function.CheckNum(checkObj.ToString())) != decimal.Parse(Function.CheckNum(checkVal))) 
                            {
                                passCount += 1; passFlag = true;
                            }
                        }
                        else if(fieldQueryValueType == "text")
                        {
                            if(checkObj.ToString() != GetExpressionVal(checkVal)) 
                            {
                                passCount += 1; passFlag = true;
                            }
                        }
                    }
                    else if(fieldQueryKind == "5" || fieldQueryKind == "6") //数组匹配/排除
                    {
                        string val = ",";
                        string[] valList = checkVal.Split(',');
                        if(fieldQueryModel == "request_param")
                        {
                            Dictionary<string, string> req = getRequestParams(projectId, content);
                            foreach(string subVal in valList)
                            {
                                val += req[subVal] + ",";
                            }
                        }
                        else if(fieldQueryModel == "fixed_value")
                        {
                            foreach(string subVal in valList)
                            {
                                val += GetExpressionVal(subVal) + ",";
                            }
                        }
                        else if(fieldQueryModel == "db_field")
                        {
                            foreach(string subVal in valList)
                            {
                                val += GetDbExpressionVal(subVal) + ",";
                            }
                        }
                        if (fieldQueryKind == "5" && val.Contains("," + checkObj.ToString() + ",")) 
                        {
                            passCount += 1; passFlag = true;
                        }
                        if(fieldQueryKind == "6" && !val.Contains("," + checkObj.ToString() + ",")) 
                        {
                            passCount += 1; passFlag = true;
                        }
                    }

                    // if(!sub.recursionFlag)
                    // {
                        logStepDic.Add("状态", passFlag ? "通过" : "未通过");
                        logStepDics.Add(logStepDic);
                    // }
                }
                setLogStep(sub.id, "匹配结果", logStepDics);
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p8", "接收mq数据日志");

                if(conditionMode == "all" && passCount == allCount && passCount > 0) op = true;
                else if(conditionMode == "one" && passCount >= 1) op = true;
                else if(conditionMode == "two" && passCount >= 2) op = true;
                else if(conditionMode == "three" && passCount >= 3) op = true;
            }
            decimal prizeAmt = 0;
            setLogStep(sub.id, "是否通过", op ? "是" : "否");
            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p9", "接收mq数据日志");
            if(op) //满足条件
            {
                bool repeatFlag = sub.repeatFlag;
                decimal number = 0;
                if(prizeSourceField.Contains("/"))
                {
                    number = decimal.Parse(prizeSourceField.Split('/')[1]);
                    prizeSourceField = prizeSourceField.Split('/')[0];
                }
                string prizeSourceData = "";
                if(prizeSourceField.Contains(","))
                {
                    string[] list = prizeSourceField.Split(',');
                    foreach(string subField in list)
                    {
                        string val = GetQueryTableData(condiDic, subField);
                        if(subField == val) val = GetStartData(startData, subField);
                        prizeSourceData += val + ",";
                    }
                    prizeSourceData = prizeSourceData.TrimEnd(',');
                }
                else
                {
                    prizeSourceData = GetQueryTableData(condiDic, prizeSourceField);
                }
                if(string.IsNullOrEmpty(prizeSourceData)) prizeSourceData = "0";
                if(prizeSourceField.Contains("/") && number > 0)
                {
                    decimal prizeSourceDataNum = decimal.Parse(prizeSourceData) / number;
                    prizeSourceData = prizeSourceDataNum.ToString("f2");
                }
                var amountSet = amountSetService.GetFirst(m => m.listId == sub.id && m.prizeSourceField == prizeSourceData);
                if(amountSet != null)
                {
                    prizePercent = amountSet.prizePercent;
                    prizeAmount = amountSet.prizeAmount;
                    prizeCode = amountSet.prizeCode;
                    repeatFlag = amountSet.repeatFlag;
                }
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p9", "接收mq数据日志");

                if(!prizeSourceData.Contains("$") && !prizeSourceData.Contains("=") && prizeSourceData.Contains(","))
                {
                    string[] prizeSourceDataList = prizeSourceData.Split(',');
                    string checkField = "";
                    for (int i = 0; i < prizeSourceDataList.Length - 1; i++)
                    {
                        checkField += prizeSourceDataList[i] + ",";
                    }
                    amountSet = amountSetService.GetFirst(m => m.listId == sub.id && m.prizeSourceField.StartsWith(checkField) && m.prizeSourceField.EndsWith(",%"));
                    if(amountSet != null)
                    {
                        prizePercent = amountSet.prizePercent;
                        prizeAmount = amountSet.prizeAmount;
                        prizeCode = amountSet.prizeCode;
                        repeatFlag = amountSet.repeatFlag;
                        prizeSourceData = prizeSourceDataList[prizeSourceDataList.Length - 1];
                    }
                }
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p10", "接收mq数据日志");
                string[] prizeSourceFieldList = prizeSourceData.Split(',');
                var amountSets = amountSetService.GetList(m => m.listId == sub.id && m.prizeSourceField.Contains("${"));
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p11", "接收mq数据日志");
                foreach(var subAmountSet in amountSets)
                {
                    string subPrizeSourceField = subAmountSet.prizeSourceField;
                    for (int i = 0; i < prizeSourceFieldList.Length; i++)
                    {
                        subPrizeSourceField = subPrizeSourceField.Replace("${" + i + "}", prizeSourceFieldList[i]);
                    }
                    DataTable dt = new();
                    string chk = dt.Compute(subPrizeSourceField, "false").ToString();
                    if(chk == "True")
                    {
                        prizePercent = subAmountSet.prizePercent;
                        prizePercent = subAmountSet.prizePercent;
                        prizeAmount = subAmountSet.prizeAmount;
                        prizeCode = subAmountSet.prizeCode;
                        repeatFlag = subAmountSet.repeatFlag;
                        prizeSourceData = prizeSourceFieldList[subAmountSet.prizeSourceFieldIndex];
                        break;
                    }
                }
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p12", "接收mq数据日志");
                
                if(prizePercent > 0) prizeAmt += decimal.Parse(Function.CheckNum(prizeSourceData)) * prizePercent;
                if(prizeAmount > 0) prizeAmt += prizeAmount;
                decimal getPrizeAmount = prizeAmt;
                if(set.levelDiffFlag) prizeAmt -= loopAmount;
                setLogStep(sub.id, "发放金额", prizeAmt);
                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p13", "接收mq数据日志");
                if(prizeAmt > 0)
                {
                    prizeAmt = Util.PublicFunction.NumberFormat(prizeAmt);
                    setLogPrizeAmount(sub.id, prizeAmt);
                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p14", "接收mq数据日志");
                    var req = getRequestParams(projectId, content);
                    // var requestParamField = req[sub.requestParamField];
                    var sendFlag = false;
                    if(!repeatFlag) sendFlag = recordService.Any(m => m.prizeObjId == prizeObjectId && m.listId == sub.id && m.prizeCode == prizeCode && m.requestParamField == content);
                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p15", "接收mq数据日志");
                    if(!sendFlag && prizeObjectId != "0" && !string.IsNullOrEmpty(prizeObjectId))
                    {
                        PriRecord item = new PriRecord()
                        {
                            createDate = DateTime.Now,
                            projectId = projectId,
                            listId = sub.id,
                            prizeAmount = prizeAmt,
                            prizeCode = prizeCode,
                            prizeObjId = prizeObjectId,
                            requestParamField = content,
                            batchNo = batchNo,
                        };
                        recordService.Add(item);
                        Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p16", "接收mq数据日志");
                        Dictionary<string, object> prizeItem = new Dictionary<string, object>();
                        prizeItem.Add("prize_date", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                        prizeItem.Add("prize_name", sub.prizeName);
                        prizeItem.Add("prize_code", prizeCode);
                        prizeItem.Add("batch_no", batchNo);
                        prizeItem.Add("request_param_field", content);
                        List<Dictionary<string, object>> prizeItemList = new List<Dictionary<string, object>>();
                        Dictionary<string, object> prizeItemSub = new Dictionary<string, object>();
                        prizeItemSub.Add("prize_amount", prizeAmt);
                        prizeItemSub.Add("prize_obj", prizeObjectId);
                        prizeItemList.Add(prizeItemSub);
                        prizeItem.Add("prize_list", prizeItemList);
                        string prizeOutContent = Newtonsoft.Json.JsonConvert.SerializeObject(prizeItem);
                        setLogFieldValue(sub.id, "prizeOutContent", prizeOutContent);
                        setLogFieldValue(sub.id, "prizeOutUrl", project.noticeUrl);
                        Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p17", "接收mq数据日志");
                        if(project.requestMode == "http" && !string.IsNullOrEmpty(project.noticeUrl))
                        {
                            int status = -1;
                            string noticeJson = Function.PostWebRequest(project.noticeUrl, prizeOutContent, "application/json");
                            Function.WriteLog(noticeJson, "通知返回报文");
                            JsonData jsonObj = JsonMapper.ToObject(noticeJson);
                            if(jsonObj["status"].ToString() == "1")
                            {
                                status = 1;
                            }
                            Function.WriteLog(status.ToString(), "通知返回报文");
                            var sendItem = recordService.GetFirst(m => m.prizeObjId == prizeObjectId && m.listId == sub.id && m.requestParamField == content);
                            if(sendItem != null)
                            {
                                Function.WriteLog("in", "通知返回报文");
                                sendItem.status = status;
                                recordService.Update(sendItem);
                                Function.WriteLog("end", "通知返回报文");
                            }
                        }
                        else if(project.requestMode == "mq")
                        {}
                        else if(project.requestMode == "db")
                        {
                            prizeToDatabase(projectId, sub.id, content, condiDic, prizeAmt, startData); //入库
                        }
                        Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p18", "接收mq数据日志");
                    }
                    else if(project.requestMode == "db")
                    {
                        prizeToDatabase(projectId, sub.id, content, condiDic, prizeAmt, startData); //入库
                    }
                    loopAmount = getPrizeAmount;
                }
            }

            // if(!sub.recursionFlag)
            // {
                setLogStatus(sub.id, op ? 1 : 0);
            // }
            return prizeAmt;
        }

        //递归条件判断
        public static List<QueryCondition> loopCondition(int projectId, PriList sub, string objId, string content)
        {
            List<QueryCondition> dic = new();
            var queryTableService = App.GetService<IPriRecursionStartTableService>();
            var queryFieldService = App.GetService<IPriRecursionStartFieldService>();
            var queryReturnFieldService = App.GetService<IPriRecursionStartReturnFieldService>();
            int passCount = 0;
            //查询表
            var queryTables = queryTableService.GetList(m => m.listId == sub.id).OrderByDescending(m => m.sort).ThenBy(m => m.id).ToList();
            int allCount = queryTables.Count;
            foreach(var queryTable in queryTables)
            {
                //查询返回字段
                string fields = "1";
                string tableEnName = queryTable.tableEnName;
                if(tableEnName.Contains("#{")) tableEnName = MatchExpressionVal(tableEnName);
                Dictionary<string, string> fieldDic = new();
                var returnFields = queryReturnFieldService.GetList(m => m.objectTableId == queryTable.id);
                if(returnFields.Count > 0)
                {
                    fields = "";
                    foreach(var returnField in returnFields)
                    {
                        string aliasName = returnField.fieldAliasName;
                        if(string.IsNullOrEmpty(aliasName)) aliasName = tableEnName + "_" + returnField.fieldEnName;
                        if(returnField.fieldReturnKind == "2")
                        {
                            fields += "count(" + returnField.fieldEnName + ") " + aliasName + ",";
                        }
                        else if(returnField.fieldReturnKind == "3")
                        {
                            fields += "sum(" + returnField.fieldEnName + ") " + aliasName + ",";
                        }
                        else if(returnField.fieldReturnKind == "4")
                        {
                            fields += "avg(" + returnField.fieldEnName + ") " + aliasName + ",";
                        }
                        else if(returnField.fieldReturnKind == "5")
                        {
                            fields += "max(" + returnField.fieldEnName + ") " + aliasName + ",";
                        }
                        else if(returnField.fieldReturnKind == "6")
                        {
                            fields += "min(" + returnField.fieldEnName + ") " + aliasName + ",";
                        }
                        else
                        {
                            fields += returnField.fieldEnName + " " + aliasName + ",";
                        }
                        fieldDic.Add(aliasName, returnField.fieldName);
                    }
                    fields = fields.TrimEnd(',');
                }

                //查询匹配条件
                string condi = "";
                var queryFields = queryFieldService.GetList(m => m.objectTableId == queryTable.id);
                foreach(var queryField in queryFields)
                {
                    string fieldEnName = queryField.fieldEnName;
                    string fieldQueryKind = queryField.fieldQueryKind;
                    string fieldQueryModel = queryField.fieldQueryModel;
                    string fieldQueryValue = queryField.fieldQueryValue;
                    if(fieldQueryModel == "loop_field") fieldQueryValue = objId;
                    string fieldQueryValueType = queryField.fieldQueryValueType;
                    if(fieldQueryKind == "1") //模糊匹配
                    {
                        condi += " and " + fieldEnName + " like ";
                        if(fieldQueryModel == "request_param")
                        {
                            Dictionary<string, string> req = getRequestParams(projectId, content);
                            string val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                            condi += "'%" + val + "%'";
                        }
                        else if(fieldQueryModel == "fixed_value")
                        {
                            condi += "'%" + GetExpressionVal(fieldQueryValue) + "%'";
                        }
                        else if(fieldQueryModel == "db_field")
                        {
                            condi += "'%" + GetDbExpressionVal(fieldQueryValue) + "%'";
                        }
                    }
                    else if(fieldQueryKind == "2") //精确匹配
                    {
                        condi += " and " + fieldEnName + "=";
                        string val = fieldQueryValue;
                        if(fieldQueryModel == "request_param")
                        {
                            Dictionary<string, string> req = getRequestParams(projectId, content);
                            val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                        }
                        else if(fieldQueryModel == "fixed_value")
                        {
                            val = GetExpressionVal(fieldQueryValue);
                        }
                        else if(fieldQueryModel == "db_field")
                        {
                            val = GetDbExpressionVal(fieldQueryValue);
                        }
                        if(fieldQueryValueType == "text")
                        {
                            val = "'" + val + "'";
                        }
                        condi += val;
                    }
                    else if(fieldQueryKind == "5" || fieldQueryKind == "6") //数组匹配/排除
                    {
                        if(fieldQueryKind == "5") condi += " and " + fieldEnName + " in (";
                        else if(fieldQueryKind == "6") condi += " and " + fieldEnName + " not in (";
                        string val = "";
                        string[] valList = fieldQueryValue.Split(',');
                        if(fieldQueryModel == "request_param")
                        {
                            Dictionary<string, string> req = getRequestParams(projectId, content);
                            foreach(string subval in valList)
                            {
                                if(fieldQueryValueType == "text")
                                {
                                    val += "'" + req[subval] + "',";
                                }
                                else
                                {
                                    val += req[subval] + ",";
                                }
                            }
                        }
                        else if(fieldQueryModel == "fixed_value")
                        {
                            foreach(string subval in valList)
                            {
                                if(fieldQueryValueType == "text")
                                {
                                    val += "'" + GetExpressionVal(subval) + "',";
                                }
                                else
                                {
                                    val += GetExpressionVal(subval) + ",";
                                }
                            }
                        }
                        else if(fieldQueryModel == "db_field")
                        {
                            foreach(string subval in valList)
                            {
                                if(fieldQueryValueType == "text")
                                {
                                    val += "'" + GetDbExpressionVal(subval) + "',";
                                }
                                else
                                {
                                    val += GetDbExpressionVal(subval) + ",";
                                }
                            }
                        }
                        val = val.TrimEnd(',');
                        condi += val + ")";
                    }
                    else if(fieldQueryKind == "3") //范围匹配
                    {
                        string[] val = fieldQueryValue.Split(':');
                        if(fieldQueryModel == "request_param")
                        {
                            Dictionary<string, string> req = getRequestParams(projectId, content);
                            if(fieldQueryValueType == "number")
                            {
                                if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">=" + req[val[0]];
                                if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<=" + req[val[1]];
                            }
                            else
                            {
                                if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">='" + req[val[0]] + "'";
                                if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<='" + req[val[1]] + "'";
                            }
                        }
                        else if(fieldQueryModel == "fixed_value")
                        {
                            if(fieldQueryValueType == "number")
                            {
                                if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + val[0];
                                if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + val[1];
                            }
                            else
                            {
                                if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">='" + GetExpressionVal(val[0]) + "'";
                                if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<='" + GetExpressionVal(val[1]) + "'";
                            }
                        }
                        else if(fieldQueryModel == "db_field")
                        {
                            if(fieldQueryValueType == "number")
                            {
                                if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + val[0];
                                if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + val[1];
                            }
                            else
                            {
                                if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">='" + GetDbExpressionVal(val[0]) + "'";
                                if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<='" + GetDbExpressionVal(val[1]) + "'";
                            }
                        }
                    }
                    else if(fieldQueryKind == "4") //取反匹配
                    {
                        condi += " and " + fieldEnName + "!=";
                        string val = "";
                        if(fieldQueryModel == "request_param")
                        {
                            Dictionary<string, string> req = getRequestParams(projectId, content);
                            val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                        }
                        else if(fieldQueryModel == "fixed_value")
                        {
                            val = GetExpressionVal(fieldQueryValue);
                        }
                        else if(fieldQueryModel == "db_field")
                        {
                            val = GetDbExpressionVal(fieldQueryValue);
                        }
                        if(fieldQueryValueType == "text")
                        {
                            val = "'" + val + "'";
                        }
                        condi += val;
                    }
                }

                var db = initDb(queryTable.databaseId);
                string sql = "select " + fields + " from " + tableEnName + " where 1=1" + condi;
                if(!string.IsNullOrEmpty(queryTable.orderBy))
                {
                    sql += " order by " + queryTable.orderBy;
                }
                sql += " limit 1";
                var items = db.Ado.GetDataTable(sql);
                if(items.Rows.Count > 0)
                {
                    foreach(string field in fieldDic.Keys)
                    {
                        if(!dic.Any(m => m.FieldEnName == field)) dic.Add(new QueryCondition()
                        {
                            FieldName = fieldDic[field],
                            FieldEnName = field,
                            Value = items.Rows[0][field].ToString()
                        });
                    }
                }
            }
            return dic;
        }

        //奖励入库
        public static void prizeToDatabase(int projectId, int listId, string content, List<QueryCondition> condiDic, decimal prize_amt, Dictionary<string, string> startData)
        {
            var prizeInTableService = App.GetService<IPriPrizeInTableService>();
            var prizeInFieldService = App.GetService<IPriPrizeInFieldService>();
            var prizeInQueryFieldService = App.GetService<IPriPrizeInQueryFieldService>();

            //入库表
            var prizeInTables = prizeInTableService.GetList(m => m.listId == listId);
            foreach(var prizeInTable in prizeInTables)
            {
                var db = initDb(prizeInTable.databaseId);
                Dictionary<string, object> doFields = new();
                List<string> inFields = new();
                //入库字段
                var prizeInFields = prizeInFieldService.GetList(m => m.inTableId == prizeInTable.id);
                foreach(var prizeInField in prizeInFields)
                {
                    string fieldEnName = prizeInField.fieldEnName;
                    string fieldQueryModel = prizeInField.fieldQueryModel;
                    string fieldQueryValue = prizeInField.fieldQueryValue;
                    fieldQueryValue = fieldQueryValue.Replace("${prize_amt}", prize_amt.ToString());
                    fieldQueryValue = GetDbExpressionVal(fieldQueryValue, projectId, content, condiDic, startData);
                    fieldQueryValue = MatchExpressionVal(fieldQueryValue);
                    string fieldQueryValueType = prizeInField.fieldQueryValueType;
                    if(fieldQueryModel == "request_param")
                    {
                        Dictionary<string, string> req = getRequestParams(projectId, content);
                        fieldQueryValue = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                    }
                    else if(fieldQueryModel == "query_field")
                    {
                        if (fieldQueryValue.Contains("+") || fieldQueryValue.Contains("-") || fieldQueryValue.Contains("*") || fieldQueryValue.Contains("/") || fieldQueryValue.Contains("(") || fieldQueryValue.Contains(")"))
                        {
                            string[] texts = fieldQueryValue.Split(new char[] { '+', '-', '*', '/', '(', ')' });
                            foreach (string text in texts)
                            {
                                string val = GetStartData(startData, text);
                                if(string.IsNullOrEmpty(val)) val = GetQueryTableData(condiDic, text);
                                fieldQueryValue = fieldQueryValue.Replace(text, val);
                            }
                            DataTable dt = new();
                            fieldQueryValue = dt.Compute(fieldQueryValue, "false").ToString();
                        }
                        else
                        {
                            fieldQueryValue = GetQueryTableData(condiDic, fieldQueryValue);
                        }
                    }
                    else if(fieldQueryModel == "querystart_list_field")
                    {
                        fieldQueryValue = GetStartData(startData, fieldQueryValue);
                    }
                    else if(fieldQueryModel == "query_all_field")
                    {
                        if (fieldQueryValue.Contains("+") || fieldQueryValue.Contains("-") || fieldQueryValue.Contains("*") || fieldQueryValue.Contains("/") || fieldQueryValue.Contains("(") || fieldQueryValue.Contains(")"))
                        {
                            string[] texts = fieldQueryValue.Split(new char[] { '+', '-', '*', '/', '(', ')' });
                            foreach (string text in texts)
                            {
                                string val = GetStartData(startData, text);
                                if(string.IsNullOrEmpty(val)) val = GetQueryTableData(condiDic, text);
                                fieldQueryValue = fieldQueryValue.Replace(text, val);
                            }
                            DataTable dt = new();
                            fieldQueryValue = dt.Compute(fieldQueryValue, "false").ToString();
                        }
                        else
                        {
                            string val = GetStartData(startData, fieldQueryValue);
                            if(string.IsNullOrEmpty(val)) val = GetQueryTableData(condiDic, fieldQueryValue);
                            fieldQueryValue = val;
                        }
                    }
                    else if(fieldQueryModel == "fixed_value")
                    {
                        fieldQueryValue = GetExpressionVal(fieldQueryValue);
                    }
                    else if(fieldQueryModel == "db_field")
                    {
                        fieldQueryValue = GetDbExpressionVal(fieldQueryValue);
                    }
                    else if(fieldQueryModel == "prize_amt")
                    {
                        if (fieldQueryValue.Contains("+") || fieldQueryValue.Contains("-") || fieldQueryValue.Contains("*") || fieldQueryValue.Contains("/") || fieldQueryValue.Contains("(") || fieldQueryValue.Contains(")"))
                        {
                            fieldQueryValue = fieldQueryValue.Replace("${prize_amt}", prize_amt.ToString());
                            if(fieldQueryValue.Contains("${"))
                            {
                                string[] texts = fieldQueryValue.Split(new char[] { '+', '-', '*', '/', '(', ')' });
                                foreach (string text in texts)
                                {
                                    string val = GetStartData(startData, text);
                                    if(string.IsNullOrEmpty(val)) val = GetQueryTableData(condiDic, text);
                                    fieldQueryValue = fieldQueryValue.Replace(text, val);
                                }
                            }
                            DataTable dt = new();
                            fieldQueryValue = dt.Compute(fieldQueryValue, "false").ToString();
                        }
                        else
                        {
                            fieldQueryValue = prize_amt.ToString();
                        }
                    }
                    if(fieldQueryValueType == "text") doFields.Add(fieldEnName, fieldQueryValue);
                    if(fieldQueryValueType == "int") doFields.Add(fieldEnName, int.Parse(Function.CheckInt(fieldQueryValue)));
                    if(fieldQueryValueType == "number") doFields.Add(fieldEnName, decimal.Parse(Function.CheckNum(fieldQueryValue)));
                    if(fieldQueryValueType == "datetime") doFields.Add(fieldEnName, DateTime.Parse(fieldQueryValue));
                    if(fieldQueryValueType == "bool") doFields.Add(fieldEnName, bool.Parse(fieldQueryValue));

                    inFields.Add(fieldEnName + "#cut#" + fieldQueryValue + "#cut#" + fieldQueryValueType + "#cut#" + prizeInField.fieldInModel);
                }

                //查询匹配条件
                string condi = "";
                var queryFields = prizeInQueryFieldService.GetList(m => m.inTableId == prizeInTable.id);
                foreach(var queryField in queryFields)
                {
                    string fieldEnName = queryField.fieldEnName;
                    string fieldQueryKind = queryField.fieldQueryKind;
                    string fieldQueryModel = queryField.fieldQueryModel;
                    string fieldQueryValue = queryField.fieldQueryValue;
                    string fieldQueryValueType = queryField.fieldQueryValueType;
                    if(fieldQueryKind == "1") //模糊匹配
                    {
                        condi += " and " + fieldEnName + " like ";
                        if(fieldQueryModel == "request_param")
                        {
                            Dictionary<string, string> req = getRequestParams(projectId, content);
                            string val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                            condi += "'%" + val + "%'";
                        }
                        else if(fieldQueryModel == "fixed_value")
                        {
                            condi += "'%" + fieldQueryValue + "%'";
                        }
                        else if(fieldQueryModel == "query_field")
                        {
                            condi += "'%" + GetQueryTableData(condiDic, fieldQueryValue) + "%'";
                        }
                        else if(fieldQueryModel == "querystart_list_field")
                        {
                            condi += "'%" + GetStartData(startData, fieldQueryValue) + "%'";
                        }
                    }
                    else if(fieldQueryKind == "2") //精确匹配
                    {
                        condi += " and " + fieldEnName + "=";
                        string val = "";
                        if(fieldQueryModel == "request_param")
                        {
                            Dictionary<string, string> req = getRequestParams(projectId, content);
                            val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                        }
                        else if(fieldQueryModel == "fixed_value")
                        {
                            val = fieldQueryValue;
                        }
                        else if(fieldQueryModel == "query_field")
                        {
                            val = GetQueryTableData(condiDic, fieldQueryValue);
                        }
                        else if(fieldQueryModel == "querystart_list_field")
                        {
                            val = GetStartData(startData, fieldQueryValue);
                        }
                        if(fieldQueryValueType == "text")
                        {
                            val = "'" + val + "'";
                        }
                        condi += val;
                    }
                    else if(fieldQueryKind == "5" || fieldQueryKind == "6") //数组匹配/排除
                    {
                        if(fieldQueryKind == "5") condi += " and " + fieldEnName + " in (";
                        else if(fieldQueryKind == "6") condi += " and " + fieldEnName + " not in (";
                        string val = "";
                        string[] valList = fieldQueryValue.Split(',');
                        if(fieldQueryModel == "request_param")
                        {
                            Dictionary<string, string> req = getRequestParams(projectId, content);
                            foreach(string sub in valList)
                            {
                                if(fieldQueryValueType == "text")
                                {
                                    val += "'" + req[sub] + "',";
                                }
                                else
                                {
                                    val += req[sub] + ",";
                                }
                            }
                        }
                        else if(fieldQueryModel == "fixed_value")
                        {
                            foreach(string sub in valList)
                            {
                                if(fieldQueryValueType == "text")
                                {
                                    val += "'" + GetExpressionVal(sub) + "',";
                                }
                                else
                                {
                                    val += GetExpressionVal(sub) + ",";
                                }
                            }
                        }
                        else if(fieldQueryModel == "query_field")
                        {
                            foreach(string sub in valList)
                            {
                                if(fieldQueryValueType == "text")
                                {
                                    val += "'" + GetQueryTableData(condiDic, sub) + "',";
                                }
                                else
                                {
                                    val += GetQueryTableData(condiDic, sub) + ",";
                                }
                            }
                        }
                        else if(fieldQueryModel == "querystart_list_field")
                        {
                            foreach(string sub in valList)
                            {
                                if(fieldQueryValueType == "text")
                                {
                                    val += "'" + GetStartData(startData, sub) + "',";
                                }
                                else
                                {
                                    val += GetStartData(startData, sub) + ",";
                                }
                            }
                        }
                        else if(fieldQueryModel == "db_field")
                        {
                            foreach(string sub in valList)
                            {
                                if(fieldQueryValueType == "text")
                                {
                                    val += "'" + GetDbExpressionVal(sub) + "',";
                                }
                                else
                                {
                                    val += GetDbExpressionVal(sub) + ",";
                                }
                            }
                        }
                        val = val.TrimEnd(',');
                        condi += val + ")";
                    }
                    else if(fieldQueryKind == "3") //范围匹配
                    {
                        string[] val = fieldQueryValue.Split(':');
                        if(fieldQueryModel == "request_param")
                        {
                            Dictionary<string, string> req = getRequestParams(projectId, content);
                            if(fieldQueryValueType == "number")
                            {
                                if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">=" + req[val[0]];
                                if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<=" + req[val[1]];
                            }
                            else
                            {
                                if(!string.IsNullOrEmpty(req[val[0]])) condi += " and " + fieldEnName + ">='" + req[val[0]] + "'";
                                if(!string.IsNullOrEmpty(req[val[1]])) condi += " and " + fieldEnName + "<='" + req[val[1]] + "'";
                            }
                        }
                        else if(fieldQueryModel == "fixed_value")
                        {
                            if(fieldQueryValueType == "number")
                            {
                                if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">=" + val[0];
                                if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<=" + val[1];
                            }
                            else
                            {
                                if(!string.IsNullOrEmpty(val[0])) condi += " and " + fieldEnName + ">='" + val[0] + "'";
                                if(!string.IsNullOrEmpty(val[1])) condi += " and " + fieldEnName + "<='" + val[1] + "'";
                            }
                        }
                    }
                    else if(fieldQueryKind == "4") //取反匹配
                    {
                        condi += " and " + fieldEnName + "!=";
                        string val = "";
                        if(fieldQueryModel == "request_param")
                        {
                            Dictionary<string, string> req = getRequestParams(projectId, content);
                            val = req.ContainsKey(fieldQueryValue) ? req[fieldQueryValue] : "0";
                        }
                        else if(fieldQueryModel == "fixed_value")
                        {
                            val = fieldQueryValue;
                        }
                        if(fieldQueryValueType == "text")
                        {
                            val = "'" + val + "'";
                        }
                        condi += val;
                    }
                }

                if(prizeInTable.excuteKind == "add") db.Insertable(doFields).AS(prizeInTable.tableEnName).ExecuteCommand();
                if(prizeInTable.excuteKind == "update") db.Updateable(doFields).AS(prizeInTable.tableEnName).Where("1=1" + condi).ExecuteCommand();
                if(prizeInTable.excuteKind == "update_or_add")
                {
                    string doSql = "";
                    var check = db.Ado.GetDataTable("select 1 from " + prizeInTable.tableEnName + " where 1=1" + condi);
                    if(check.Rows.Count > 0)
                    {
                        string fieldString = "";
                        foreach(var inField in inFields)
                        {
                            string[] inFieldData = inField.Split(new string[]{ "#cut#" }, StringSplitOptions.None);
                            string fieldEnName = inFieldData[0];
                            string fieldQueryValue = inFieldData[1];
                            string fieldQueryValueType = inFieldData[2];
                            string fieldInModel = inFieldData[3];
                            if(fieldQueryValueType == "int" || fieldQueryValueType == "number" || fieldQueryValueType == "bool")
                            {
                                if(fieldInModel == "add")
                                {
                                    fieldString += fieldEnName + "=" + fieldEnName + "+" + fieldQueryValue;
                                }
                                else
                                {
                                    fieldString += fieldEnName + "=" + fieldQueryValue;
                                }
                            }
                            else
                            {
                                if(fieldInModel == "add")
                                {
                                    fieldString += fieldEnName + "=" + "concat(" + fieldEnName + ", '" + fieldQueryValue + "')";
                                }
                                else
                                {
                                    fieldString += fieldEnName + "=" + "'" + fieldQueryValue + "'";
                                }
                            }
                            fieldString += ",";
                        }
                        if(!string.IsNullOrEmpty(fieldString))
                        {
                            fieldString = fieldString.TrimEnd(',');
                        }
                        doSql = "update " + prizeInTable.tableEnName + " set " + fieldString + " where 1=1" + condi;
                    }
                    else
                    {
                        string fieldString = "";
                        string valString = "";
                        foreach(var fieldEnName in doFields.Keys)
                        {
                            fieldString += fieldEnName;
                            if(typeof(int) == doFields[fieldEnName].GetType() || typeof(decimal) == doFields[fieldEnName].GetType())
                            {
                                valString += doFields[fieldEnName].ToString();
                            }
                            else
                            {
                                valString += "'" + doFields[fieldEnName].ToString() + "'";
                            }
                            fieldString += ",";
                            valString += ",";
                        }
                        if(!string.IsNullOrEmpty(fieldString))
                        {
                            fieldString = fieldString.TrimEnd(',');
                            valString = valString.TrimEnd(',');
                        }
                        doSql = "insert into " + prizeInTable.tableEnName + " (" + fieldString + ") values (" + valString + ")";
                    }
                    db.Ado.ExecuteCommand(doSql);
                }

                Function.WriteLog(DateTime.Now.ToString() + "\n" + prizeInTable.excuteKind + "\n" + prizeInTable.tableEnName + "\n" + Newtonsoft.Json.JsonConvert.SerializeObject(doFields) + "\n" + condi + "\n\n", "奖励入库数据");
            }

        }

        //固定值表达式
        public static string GetExpressionVal(string str)
        {
            if(str == "#{now}#") return DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
            if(str == "#{today}#") return DateTime.Now.ToString("yyyy-MM-dd");
            if(str == "#{this_month}#") return DateTime.Now.ToString("yyyy-MM");
            if(str.StartsWith("#{now") && str.EndsWith("DAY}#")) return DateTime.Now.AddDays(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM-dd HH:mm:ss");
            if(str.StartsWith("#{now") && str.EndsWith("MONTH}#")) return DateTime.Now.AddMonths(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM-dd HH:mm:ss");
            if(str.StartsWith("#{today") && str.EndsWith("DAY}#")) return DateTime.Now.AddDays(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM-dd");
            if(str.StartsWith("#{today") && str.EndsWith("MONTH}#")) return DateTime.Now.AddMonths(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM-dd");
            if(str.StartsWith("#{this_month") && str.EndsWith("DAY}#")) return DateTime.Now.AddDays(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM");
            if(str.StartsWith("#{this_month") && str.EndsWith("MONTH}#")) return DateTime.Now.AddMonths(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM");
            if(str.StartsWith("#{") && str.EndsWith("DAY}#")) return DateTime.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[0]).AddDays(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM-dd HH:mm:ss");
            if(str.StartsWith("#{") && str.EndsWith("MONTH}#")) return DateTime.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[0]).AddMonths(int.Parse(str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',')[1])).ToString("yyyy-MM-dd HH:mm:ss");
            if(str.StartsWith("#{split") && str.EndsWith("}#"))
            {
                string[] data = str.Replace("#{", "").Replace("}#", "").Split(',');
                string text = data[1];
                string splitTag = data[2];
                string index = data[3];
                return text.Split(new string[]{ splitTag }, StringSplitOptions.None)[int.Parse(index)];
            }
            else if(str.StartsWith("#{") && str.EndsWith("}#"))
            {
                string[] data = str.Replace("#{", "").Replace("}#", "").Split(',');
                string tag = data[0];
                string format = data[data.Length - 1];
                if(tag == "now" && format.StartsWith("yyyy"))
                {
                    if(data.Length == 2)
                    {
                        return DateTime.Now.ToString(format);
                    }
                    else if(data.Length == 4)
                    {
                        if(data[2] == "DAY") return DateTime.Now.AddDays(int.Parse(data[1])).ToString(format);
                        if(data[2] == "MONTH") return DateTime.Now.AddMonths(int.Parse(data[1])).ToString(format);
                    }
                }
            }
            return str;
        }
        public static string MatchExpressionVal(string str)
        {
            MatchCollection mc = Regex.Matches(str, "#\\{.*?\\}#");
            foreach(Match m in mc)
            {
                str = str.Replace(m.Value, GetExpressionVal(m.Value));
            }
            return str;
        }

        //库内字段值表达式
        public static string GetDbExpressionVal(string str)
        {
            string[] data = str.Replace("#", "").Replace("{", "").Replace("}", "").Split(',');
            if(str.StartsWith("#{") && str.EndsWith("DAY}#")) str = "DATE_ADD(" + data[0] + ",INTERVAL " + data[1] + " DAY)";
            if(str.StartsWith("#{") && str.EndsWith("MONTH}#")) str = "DATE_ADD(" + data[0] + ",INTERVAL " + data[1] + " MONTH)";
            return str;
        }
        public static string GetDbExpressionVal(string str, int projectId, string content, List<QueryCondition> dic, Dictionary<string, string> startData)
        {
            MatchCollection mc = Regex.Matches(str, "\\$\\{.*?\\}");
            foreach(Match m in mc)
            {
                string matchValue = m.Value.Replace("${", "").Replace("}", "");
                string val = "";
                if(string.IsNullOrEmpty(val) || val == matchValue) val = getRequestParams(projectId, content, matchValue);
                if(string.IsNullOrEmpty(val) || val == matchValue) val = GetQueryTableData(dic, matchValue);
                if(string.IsNullOrEmpty(val) || val == matchValue) val = GetStartData(startData, matchValue);
                str = str.Replace(m.Value, val);
            }
            return str;
        }
    
        //四则混合运算
        public static string GetComputeVal(List<QueryCondition> condiDic, string expresssion)
        {
            if (expresssion.Contains("+") || expresssion.Contains("-") || expresssion.Contains("*") || expresssion.Contains("/") || expresssion.Contains("(") || expresssion.Contains(")"))
            {
                string[] returnFields = expresssion.Split(new char[] { '+', '-', '*', '/', '(', ')' });
                foreach (string returnField in returnFields)
                {
                    if(condiDic.Any(m => m.FieldEnName == returnField))
                    {
                        string val = GetQueryTableData(condiDic, returnField);
                        expresssion = expresssion.Replace(returnField, val);
                    }
                }
                DataTable dt = new();
                return dt.Compute(expresssion, "false").ToString();
            }
            return expresssion;
        }

        //获取查询条件数据
        public static string GetQueryTableData(List<QueryCondition> condiDic, string key)
        {
            if(key.Contains("#{"))
            {
                Match m = Regex.Match(key, "\\$\\{.*?\\}\\$");
                if(m.Success)
                {
                    string keyString = m.Value.Replace("${", "").Replace("}$", "");
                    string val = condiDic.Any(m => m.FieldEnName == keyString) ? condiDic.FirstOrDefault(m => m.FieldEnName == keyString).Value.ToString() : key;
                    key = key.Replace(m.Value, val);
                    key = GetExpressionVal(key);
                    return key;
                }
            }
            return condiDic.Any(m => m.FieldEnName == key) ? condiDic.FirstOrDefault(m => m.FieldEnName == key).Value.ToString() : key;
        }
        public static string GetQueryTableTitle(List<QueryCondition> condiDic, string key)
        {
            return condiDic.Any(m => m.FieldEnName == key) ? condiDic.FirstOrDefault(m => m.FieldEnName == key).FieldName : "";
        }
        public static string GetStartData(Dictionary<string, string> startData, string key)
        {
            return startData.ContainsKey(key) ? startData[key] : key;
        }

        //合并字典
        public static void MergeCondiDic(List<QueryCondition> condiDic, List<QueryCondition> condiDic1)
        {
            foreach(QueryCondition sub in condiDic1)
            {
                condiDic.Add(sub);
            }
        }

        //记录日志
        public static void addLog(int projectId, int listId, int prizeIn, string requestParam, string prizeInUrl)
        {
            if(!logFlag) return;
            var logService = App.GetService<IPriLogService>();
            logService.Add(new PriLog()
            {
                createDate = DateTime.Now,
                projectId = projectId,
                listId = listId,
                batchNo = batchNo,
                prizeIn = prizeIn,
                requestParam = requestParam,
                prizeInUrl = prizeInUrl,
            });
        }
        public static void setLogPrizeAmount(int listId, decimal prizeAmount)
        {
            if(!logFlag) return;
            var logService = App.GetService<IPriLogService>();
            var log = logService.GetFirst(m => m.batchNo == batchNo && m.listId == listId);
            if(log != null)
            {
                log.prizeAmount = prizeAmount;
                logService.Update(log);
            }
        }
        public static void setLogStep(int listId, Dictionary<string, object> step)
        {
            if(!logFlag) return;
            var logService = App.GetService<IPriLogService>();
            var log = logService.GetFirst(m => m.batchNo == batchNo && m.listId == listId);
            if(log != null)
            {
                log.stepList += Newtonsoft.Json.JsonConvert.SerializeObject(step) + ",";
                logService.Update(log);
            }
        }
        public static void setLogStep(int listId, string key, object val)
        {
            if(!logFlag) return;
            var logService = App.GetService<IPriLogService>();
            var log = logService.GetFirst(m => m.batchNo == batchNo && m.listId == listId);
            if(log != null)
            {
                log.stepList += "\"" + key + "\":" + Newtonsoft.Json.JsonConvert.SerializeObject(val) + ",";
                logService.Update(log);
            }
        }
        public static void setLogStatus(int listId, int status)
        {
            if(!logFlag) return;
            var logService = App.GetService<IPriLogService>();
            var log = logService.GetFirst(m => m.batchNo == batchNo && m.listId == listId);
            if(log != null)
            {
                log.status = status;
                logService.Update(log);
            }
        }
        public static void setLogFieldValue(int listId, string field, string content)
        {
            if(!logFlag) return;
            var logService = App.GetService<IPriLogService>();
            var log = logService.GetFirst(m => m.batchNo == batchNo && m.listId == listId);
            if(log != null)
            {
                if(field == "errLog") log.errLog = content;
                if(field == "prizeOutContent") log.prizeOutContent = content;
                if(field == "prizeOutUrl") log.prizeOutUrl = content;
                if(field == "stepListIndex") log.stepListIndex = content;
                logService.Update(log);
            }
        }

        public static string getQueryKind(string kind)
        {
            if(kind == "1") return "模糊匹配";
            if(kind == "2") return "精确匹配";
            if(kind == "4") return "取反匹配";
            if(kind == "5") return "数组匹配";
            if(kind == "6") return "数组排除";
            if(kind == "3") return "范围匹配";
            return kind;
        }

        public static string getQueryModel(string model)
        {
            if(model == "request_param") return "入参";
            if(model == "query_field") return "条件匹配返回字段";
            if(model == "loop_field") return "循环递归字段";
            if(model == "loop_condition_field") return "循环递归条件字段";
            if(model == "fixed_value") return "固定值";
            if(model == "db_field") return "库内字段";
            return model;
        }
    }
}