prizeset/Util/PrizeDo.cs

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

namespace Util
{
    public class PrizeDo
    {
        public static string batchNo = "";
        public static string publicStep = "";
        //发奖入口
        public static void sendPrize(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 = priObjData[0];
                int projectId = int.Parse(priObjData[1]);
                int prizeInId = int.Parse(priObjData[2]);
                prizeSend(projectId, prizeInId, priListIds, 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 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)
        {
            List<QueryCondition> dic = new();
            var queryTableService = App.GetService<IPriQueryTableService>();
            var queryFieldService = App.GetService<IPriQueryFieldService>();
            var returnFieldService = App.GetService<IPriReturnFieldService>();
            //查询表
            var queryTables = queryTableService.GetList(m => ids.Contains(m.id));
            foreach(var queryTable in queryTables)
            {
                //查询返回字段
                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 + ") " + queryTable.tableEnName + "_" + returnField.fieldEnName + ",";
                    }
                    else if(returnField.fieldReturnKind == "3")
                    {
                        fields += "sum(" + returnField.fieldEnName + ") " + queryTable.tableEnName + "_" + returnField.fieldEnName + ",";
                    }
                    else if(returnField.fieldReturnKind == "4")
                    {
                        fields += "avg(" + returnField.fieldEnName + ") " + queryTable.tableEnName + "_" + returnField.fieldEnName + ",";
                    }
                    else
                    {
                        fields += returnField.fieldEnName + " " + queryTable.tableEnName + "_" + returnField.fieldEnName + ",";
                    }
                    fieldDic.Add(queryTable.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(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;
                        }
                    }
                }

                var db = initDb(queryTable.databaseId);
                string sql = "select " + fields + " from " + queryTable.tableEnName + " where 1=1" + condi;
                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 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;
            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 loopSetService = App.GetService<IPriLoopSetService>();
            var recursionStartTableService = App.GetService<IPriRecursionStartTableService>();
            var recursionStartConditionService = App.GetService<IPriRecursionStartConditionService>();
            var priList = prizeList(projectId, prizeIds);
            foreach(var sub in priList)
            {
                try
                {
                    addLog(projectId, sub.id, prizeInId, content, queueName); //初始化日志
                    string prizeObjectId = prizeObject(sub.id, sub.prizeObj, content);
                    var recursionFlag = sub.recursionFlag; //是否递归
                    setLogStep(sub.id, "是否递归", recursionFlag ? "是" : "否");
                    if(recursionFlag)
                    {
                        List<QueryCondition> queryCondiDic = condition(sub.id, projectId, Tools.SpitIntArrary(sub.queryTableIdList, ',').ToList(), content);
                        setLogStep(sub.id, "查询原始数据", queryCondiDic);
                        var loopSet = loopSetService.GetFirst(m => m.listId == sub.id) ?? new PriLoopSet();
                        var recursionStartTable = recursionStartTableService.GetFirst(m => m.listId == sub.id) ?? new PriRecursionStartTable();
                        var tableEnName = loopSet.tableEnName; //递归查询表
                        var parentField = loopSet.parentField; //父字段
                        var sonField = loopSet.sonField; //子字段
                        var afterPrizeFlag = loopSet.afterPrizeFlag; //发奖后是否继续
                        var db = initDb(loopSet.databaseId);
                        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);
                            loopLog.Add("查询" + objId + "匹配数据", condiDic);
                            if(condiDic.Count > 0)
                            {
                                bool prizeFlag = true;                            
                                var conditions = recursionStartConditionService.GetList(m => m.loopSetId == loopSet.id);
                                if(conditions.Count > 0)
                                {
                                    int allCount = conditions.Count; //所有奖励条件数
                                    int passCount = 0; //通过条件数
                                    List<Dictionary<string, object>> logStepDics = new();
                                    foreach(var condition in conditions)
                                    {
                                        if(condition.startIndex <= index)
                                        {
                                            Dictionary<string, object> logStepDic = new();
                                            
                                            var returnFieldId = condition.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
                                            {
                                                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);
                                        }
                                    }
                                    loopLog.Add(objId + "匹配情况", logStepDics);
                                    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("匹配结果", prizeFlag);
                                if(prizeFlag)
                                {
                                    decimal prizeAmt = prizeSendDo(projectId, sub, objId, content, loopSet);
                                    op = afterPrizeFlag;
                                }
                            }
                            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());
                    }
                }
                catch(Exception ex)
                {
                    setLogFieldValue(sub.id, "errLog", ex.ToString());
                }
            }
        }

        static decimal loopAmount = 0;
        public static decimal prizeSendDo(int projectId, PriList sub, string prizeObjectId, string content, PriLoopSet set)
        {
            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();
            //查询匹配条件
            List<QueryCondition> condiDic = condition(sub.id, projectId, Tools.SpitIntArrary(sub.queryTableIdList, ',').ToList(), content);
            if(sub.prizeSourceFieldType == "loop") MergeCondiDic(condiDic, loopCondition(projectId, sub, prizeObjectId, content));
            setLogStep(sub.id, "发放奖励查询来源数据", condiDic);

            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 conditions = conditionService.GetList(m => m.listId == sub.id);
            setLogStep(sub.id, "发放奖励匹配条件", condiDic);
            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; //条件返回字段
                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
                {
                    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);
            bool op = false;
            decimal prizeAmt = 0;
            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;
            setLogStep(sub.id, "是否通过", op ? "是" : "否");
            if(op) //满足条件
            {
                decimal number = 0;
                if(prizeSourceField.Contains("/"))
                {
                    number = decimal.Parse(prizeSourceField.Split('/')[1]);
                    prizeSourceField = prizeSourceField.Split('/')[0];
                }
                string prizeSourceData = "";
                if(prizeSourceField.Contains(","))
                {
                    string[] prizeSourceFieldList = prizeSourceField.Split(',');
                    foreach(string subField in prizeSourceFieldList)
                    {
                        string val = GetQueryTableData(condiDic, 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;
                }
                if(prizeSourceData.Contains(","))
                {
                    string checkField = prizeSourceData.Split(',')[0] + ",";
                    amountSet = amountSetService.GetFirst(m => m.listId == sub.id && m.prizeSourceField.StartsWith(checkField) && m.prizeSourceField.EndsWith(",%"));
                    if(amountSet != null)
                    {
                        prizePercent = amountSet.prizePercent;
                        prizeAmount = amountSet.prizeAmount;
                        prizeSourceData = prizeSourceData.Split(',')[1];
                    }
                }
                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);
                if(prizeAmt > 0)
                {
                    setLogPrizeAmount(sub.id, prizeAmt);
                    var req = getRequestParams(projectId, content);
                    var requestParamField = req[sub.requestParamField];
                    var sendFlag = recordService.Any(m => m.prizeObjId == prizeObjectId && m.listId == sub.id && m.requestParamField == requestParamField);
                    if(!sendFlag)
                    {
                        PriRecord item = new PriRecord()
                        {
                            createDate = DateTime.Now,
                            projectId = projectId,
                            listId = sub.id,
                            prizeAmount = prizeAmt,
                            prizeObjId = prizeObjectId,
                            requestParamField = content,
                            batchNo = batchNo,
                        };
                        recordService.Add(item);
                        string prizeOutContent = Newtonsoft.Json.JsonConvert.SerializeObject(item);
                        setLogFieldValue(sub.id, "prizeOutContent", prizeOutContent);
                        setLogFieldValue(sub.id, "prizeOutUrl", project.noticeUrl);
                        loopAmount = getPrizeAmount;
                        if(project.requestMode == "http" && !string.IsNullOrEmpty(project.noticeUrl))
                        {
                            Function.PostWebRequest(project.noticeUrl, prizeOutContent, "application/json");
                        }
                        else if(project.requestMode == "mq")
                        {}
                        else
                        {
                            prizeToDatabase(projectId, sub.id, content, condiDic, prizeAmt); //入库
                        }
                    }
                }
            }

            // 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);
            int allCount = queryTables.Count;
            foreach(var queryTable in queryTables)
            {
                //查询返回字段
                string fields = "1";
                Dictionary<string, string> fieldDic = new();
                var returnFields = queryReturnFieldService.GetList(m => m.objectTableId == queryTable.id);
                if(returnFields.Count > 0)
                {
                    fields = "";
                    foreach(var returnField in returnFields)
                    {
                        if(returnField.fieldReturnKind == "2")
                        {
                            fields += "count(" + returnField.fieldEnName + ") " + queryTable.tableEnName + "_" + returnField.fieldEnName + ",";
                        }
                        else if(returnField.fieldReturnKind == "3")
                        {
                            fields += "sum(" + returnField.fieldEnName + ") " + queryTable.tableEnName + "_" + returnField.fieldEnName + ",";
                        }
                        else if(returnField.fieldReturnKind == "4")
                        {
                            fields += "avg(" + returnField.fieldEnName + ") " + queryTable.tableEnName + "_" + returnField.fieldEnName + ",";
                        }
                        else
                        {
                            fields += returnField.fieldEnName + " " + queryTable.tableEnName + "_" + returnField.fieldEnName + ",";
                        }
                        fieldDic.Add(queryTable.tableEnName + "_" + returnField.fieldEnName, 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 " + queryTable.tableEnName + " where 1=1" + condi;
                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)
        {
            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();
                //入库字段
                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;
                    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")
                    {
                        fieldQueryValue = GetQueryTableData(condiDic, fieldQueryValue);
                    }
                    else if(fieldQueryModel == "fixed_value")
                    {
                        fieldQueryValue = GetExpressionVal(fieldQueryValue);
                    }
                    else if(fieldQueryModel == "db_field")
                    {
                        fieldQueryValue = GetDbExpressionVal(fieldQueryValue);
                    }
                    else if(fieldQueryModel == "prize_amt")
                    {
                        fieldQueryValue = prize_amt.ToString();
                    }
                    if(fieldQueryValueType == "text") doFields.Add(fieldEnName, fieldQueryValue);
                    if(fieldQueryValueType == "int") doFields.Add(fieldEnName, int.Parse(fieldQueryValue));
                    if(fieldQueryValueType == "number") doFields.Add(fieldEnName, decimal.Parse(fieldQueryValue));
                    if(fieldQueryValueType == "datetime") doFields.Add(fieldEnName, DateTime.Parse(fieldQueryValue));
                    if(fieldQueryValueType == "bool") doFields.Add(fieldEnName, bool.Parse(fieldQueryValue));
                }

                //查询匹配条件
                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(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);
                        }
                        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 == "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();

                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");
            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 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)
        {
            return condiDic.Any(m => m.FieldEnName == key) ? condiDic.FirstOrDefault(m => m.FieldEnName == key).Value.ToString() : "0";
        }
        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 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)
        {
            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)
        {
            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)
        {
            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)
        {
            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)
        {
            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)
        {
            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;
        }
    }
}