开启多线程运行机具奖励

Common/RabbitMQClient.cs

@@ -60,9 +60,9 @@ namespace MySystem
                 CreateConn();
             }
             var channel = _connection.CreateModel();
-            channel.QueueDeclare(QueueName, true, false, false, null);
+            var queue = channel.QueueDeclare(QueueName, true, false, false, null);
             channel.QueueBind(QueueName, Exchange, RoutingKey);
-            channel.BasicQos(0, 50, false);
+            channel.BasicQos(0, 1, false);
             EventingBasicConsumer consumer = new EventingBasicConsumer(channel);
             consumer.Received += (a, e) =>
             {
@@ -85,6 +85,8 @@ namespace MySystem
                     Function.WriteLog(DateTime.Now + "\n" + ex.ToString() + "\n" + MsgContent, "发奖异常");
                 }
                 channel.BasicAck(e.DeliveryTag, false); //收到回复后，RabbitMQ会直接在队列中删除这条消息
+
+                Function.WritePage("/count/", QueueName + ".txt", queue.MessageCount.ToString());
             };
             channel.BasicConsume(QueueName, false, consumer);
         }
@@ -94,7 +96,17 @@ namespace MySystem
             var list = setService.GetList(m => m.status == 1);
             foreach(var sub in list)
             {
-                StartReceive(sub.mqQueueName, "kxs_direct_ranch", "/");
+                if(sub.mqQueueName == "QUEUE_KXS_MACHINE_PRIZE_CONFIG_DIVISION")
+                {
+                    for (int i = 0; i < 200; i++)
+                    {
+                        StartReceive(sub.mqQueueName, "kxs_direct_ranch", "/");
+                    }
+                }
+                else
+                {
+                    StartReceive(sub.mqQueueName, "kxs_direct_ranch", "/");
+                }
             }
             StartReceive("QUEUE_KXS_RETRY_MACHINE_PRIZE_CONFIG_DIVISION", "kxs_direct_ranch", "/");
         }

Util/PrizeDo.cs

@@ -24,7 +24,7 @@ namespace Util
             batchNo = DateTime.Now.ToString("yyyyMMddHHmmssfff") + Function.get_Random(3);
             publicStep = "";
             string priObjString = prizeInSet(queueName);
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-1", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-1", "接收mq数据日志");
             if(!string.IsNullOrEmpty(priObjString))
             {
                 string[] priObjData = priObjString.Split('|');
@@ -36,7 +36,7 @@ namespace Util
                 var project = projectService.GetFirst(m => m.id == projectId) ?? new PriProject();
                 logFlag = project.logFlag;
 
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-2", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-2", "接收mq数据日志");
 
                 prizeSend(projectId, prizeInId, priListIds, content, queueName);
             }
@@ -130,9 +130,9 @@ namespace Util
             var queryFieldService = App.GetService<IPriQueryFieldService>();
             var returnFieldService = App.GetService<IPriReturnFieldService>();
             //查询表
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-0", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-0", "接收mq数据日志");
             var queryTables = queryTableService.GetList(m => ids.Contains(m.id) && m.startDataFlag == false).OrderByDescending(m => m.sort).ThenBy(m => m.id).ToList();
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-1", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-1", "接收mq数据日志");
             foreach(var queryTable in queryTables)
             {
                 string sql = "";
@@ -144,7 +144,7 @@ namespace Util
                     //查询返回字段
                     string fields = "";
                     var returnFields = returnFieldService.GetList(m => m.queryTableId == queryTable.id);
-                    Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-2", "接收mq数据队列");
+                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-2", "接收mq数据日志");
                     foreach(var returnField in returnFields)
                     {
                         string aliasName = returnField.fieldAliasName;
@@ -184,7 +184,7 @@ namespace Util
                     //查询匹配条件
                     string condi = "";
                     var queryFields = queryFieldService.GetList(m => m.queryTableId == queryTable.id);
-                    Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-3", "接收mq数据队列");
+                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-3", "接收mq数据日志");
                     foreach(var queryField in queryFields)
                     {
                         string fieldEnName = queryField.fieldEnName;
@@ -447,7 +447,7 @@ namespace Util
                         sql += " order by " + queryTable.orderBy;
                     }
                     sql += " limit 1";
-                    Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-4", "接收mq数据队列");
+                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-4", "接收mq数据日志");
                 }
                 else
                 {
@@ -484,7 +484,7 @@ namespace Util
                         }
                     }
                 }
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-5", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-query-5", "接收mq数据日志");
             }
             return dic;
         }
@@ -1025,14 +1025,14 @@ namespace Util
         {
             var queryTableService = App.GetService<IPriQueryTableService>();
             var priList = prizeList(projectId, prizeIds);
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-3", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-3", "接收mq数据日志");
             foreach(var sub in priList)
             {
                 try
                 {
                     List<int> ids = Tools.SpitIntArrary(sub.queryTableIdList, ',').ToList();
                     var queryTable = queryTableService.GetFirst(m => ids.Contains(m.id) && m.startDataFlag == true);
-                    Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-4", "接收mq数据队列");
+                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-4", "接收mq数据日志");
                     if (queryTable != null)
                     {
                         int page = 0;
@@ -1043,7 +1043,7 @@ namespace Util
                         {
                             int skip = page * size;
                             DataTable query = conditionList(sub.id, projectId, ids, content, skip, size);
-                            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-41", "接收mq数据队列");
+                            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-41", "接收mq数据日志");
                             if(query.Rows.Count > 0)
                             {
                                 foreach(DataRow dr in query.Rows)
@@ -1078,35 +1078,35 @@ namespace Util
         //执行每个奖励发放逻辑
         public static void prizeSendSub(PriList sub, int projectId, int prizeInId, string prizeIds, string content, string queueName, Dictionary<string, string> startData)
         {
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-" + sub.prizeName, "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-" + sub.prizeName, "接收mq数据日志");
             var loopSetService = App.GetService<IPriLoopSetService>();
             var recursionStartTableService = App.GetService<IPriRecursionStartTableService>();
             var recursionStartConditionService = App.GetService<IPriRecursionStartConditionService>();
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-s1", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-s1", "接收mq数据日志");
             addLog(projectId, sub.id, prizeInId, content, queueName); //初始化日志
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-s2", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-s2", "接收mq数据日志");
             string prizeObjectId = prizeObject(sub.id, sub.prizeObj, content);
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-s3", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-s3", "接收mq数据日志");
             var recursionFlag = sub.recursionFlag; //是否递归
             setLogStep(sub.id, "是否递归", recursionFlag ? "是" : "否");
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-s4", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-s4", "接收mq数据日志");
             if(recursionFlag)
             {
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop0", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop0", "接收mq数据日志");
                 List<QueryCondition> queryCondiDic = condition(sub.id, projectId, Tools.SpitIntArrary(sub.queryTableIdList, ',').ToList(), content, startData);
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop1", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop1", "接收mq数据日志");
                 setLogStep(sub.id, "查询原始数据", queryCondiDic);
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop2", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop2", "接收mq数据日志");
                 var loopSet = loopSetService.GetFirst(m => m.listId == sub.id) ?? new PriLoopSet();
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop3", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop3", "接收mq数据日志");
                 var recursionStartTable = recursionStartTableService.GetFirst(m => m.listId == sub.id) ?? new PriRecursionStartTable();
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop4", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop4", "接收mq数据日志");
                 var tableEnName = loopSet.tableEnName; //递归查询表
                 var parentField = loopSet.parentField; //父字段
                 var sonField = loopSet.sonField; //子字段
                 var afterPrizeFlag = loopSet.afterPrizeFlag; //发奖后是否继续
                 var db = initDb(loopSet.databaseId);
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop5", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop5", "接收mq数据日志");
                 string objId = prizeObjectId;
                 bool op = true;
                 int index = 0;
@@ -1116,18 +1116,18 @@ namespace Util
                 {
                     Dictionary<string, object> loopLog = new();
                     List<QueryCondition> condiDic = loopCondition(projectId, sub, objId, content);
-                    Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop-in-1", "接收mq数据队列");
+                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop-in-1", "接收mq数据日志");
                     loopLog.Add("查询" + objId + "匹配数据", condiDic);
                     if(condiDic.Count > 0)
                     {
                         bool prizeFlag = false;
                         List<Dictionary<string, object>> logStepDics = new();
                         var groupNos = recursionStartConditionService.GetList(m => m.loopSetId == loopSet.id).ToList().Select(m => m.groupNo).Distinct().ToList();
-                        Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop-in-2", "接收mq数据队列");
+                        Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop-in-2", "接收mq数据日志");
                         foreach(var groupNo in groupNos)
                         {
                             var conditions = recursionStartConditionService.GetList(m => m.loopSetId == loopSet.id && m.groupNo == groupNo);
-                            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop-in-11", "接收mq数据队列");
+                            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop-in-11", "接收mq数据日志");
                             if(conditions.Count > 0)
                             {
                                 int allCount = conditions.Count; //所有奖励条件数
@@ -1479,7 +1479,7 @@ namespace Util
                             decimal prizeAmt = prizeSendDo(projectId, sub, objId, content, loopSet, startData);
                             op = afterPrizeFlag;
                         }
-                        Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop-in-3", "接收mq数据队列");
+                        Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-loop-in-3", "接收mq数据日志");
                     }
                     loopLogDic.Add(loopLog);
                     var parent = db.Ado.GetScalar("select " + parentField + " from " + tableEnName + " where " + sonField + "=" + objId);
@@ -1513,13 +1513,13 @@ namespace Util
 
             var project = projectService.GetFirst(m => m.id == projectId) ?? new PriProject();
             //查询匹配条件
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p1", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p1", "接收mq数据日志");
             List<QueryCondition> condiDic = condition(sub.id, projectId, Tools.SpitIntArrary(sub.queryTableIdList, ',').ToList(), content, startData);
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p2", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p2", "接收mq数据日志");
             if(sub.prizeSourceFieldType == "loop") MergeCondiDic(condiDic, loopCondition(projectId, sub, prizeObjectId, content));
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p3", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p3", "接收mq数据日志");
             setLogStep(sub.id, "发放奖励查询来源数据", condiDic);
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p4", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p4", "接收mq数据日志");
             var prizeSourceField = sub.prizeSourceField; //奖励金额来源字段（对应条件匹配返回字段）
             var prizePercent = sub.prizePercent; //奖励比例
             var prizeAmount = sub.prizeAmount; //奖励固定值
@@ -1532,13 +1532,13 @@ namespace Util
             
             bool op = false;
             var groupNos = conditionService.GetList(m => m.listId == sub.id).ToList().Select(m => m.groupNo).Distinct().ToList();
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p5", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p5", "接收mq数据日志");
             foreach(var groupNo in groupNos)
             {
                 var conditions = conditionService.GetList(m => m.listId == sub.id && m.groupNo == groupNo);
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p6", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p6", "接收mq数据日志");
                 setLogStep(sub.id, "发放奖励匹配条件", condiDic);
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p7", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p7", "接收mq数据日志");
                 int allCount = conditions.Count; //所有奖励条件数
                 int passCount = 0; //通过条件数
                 List<Dictionary<string, object>> logStepDics = new();
@@ -1876,7 +1876,7 @@ namespace Util
                     // }
                 }
                 setLogStep(sub.id, "匹配结果", logStepDics);
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p8", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p8", "接收mq数据日志");
 
                 if(conditionMode == "all" && passCount == allCount && passCount > 0) op = true;
                 else if(conditionMode == "one" && passCount >= 1) op = true;
@@ -1885,7 +1885,7 @@ namespace Util
             }
             decimal prizeAmt = 0;
             setLogStep(sub.id, "是否通过", op ? "是" : "否");
-            Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p9", "接收mq数据队列");
+            Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p9", "接收mq数据日志");
             if(op) //满足条件
             {
                 bool repeatFlag = sub.repeatFlag;
@@ -1924,7 +1924,7 @@ namespace Util
                     prizeCode = amountSet.prizeCode;
                     repeatFlag = amountSet.repeatFlag;
                 }
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p9", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p9", "接收mq数据日志");
 
                 if(!prizeSourceData.Contains("$") && !prizeSourceData.Contains("=") && prizeSourceData.Contains(","))
                 {
@@ -1944,10 +1944,10 @@ namespace Util
                         prizeSourceData = prizeSourceDataList[prizeSourceDataList.Length - 1];
                     }
                 }
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p10", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p10", "接收mq数据日志");
                 string[] prizeSourceFieldList = prizeSourceData.Split(',');
                 var amountSets = amountSetService.GetList(m => m.listId == sub.id && m.prizeSourceField.Contains("${"));
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p11", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p11", "接收mq数据日志");
                 foreach(var subAmountSet in amountSets)
                 {
                     string subPrizeSourceField = subAmountSet.prizeSourceField;
@@ -1968,24 +1968,24 @@ namespace Util
                         break;
                     }
                 }
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p12", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p12", "接收mq数据日志");
                 
                 if(prizePercent > 0) prizeAmt += decimal.Parse(Function.CheckNum(prizeSourceData)) * prizePercent;
                 if(prizeAmount > 0) prizeAmt += prizeAmount;
                 decimal getPrizeAmount = prizeAmt;
                 if(set.levelDiffFlag) prizeAmt -= loopAmount;
                 setLogStep(sub.id, "发放金额", prizeAmt);
-                Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p13", "接收mq数据队列");
+                Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p13", "接收mq数据日志");
                 if(prizeAmt > 0)
                 {
                     prizeAmt = Util.PublicFunction.NumberFormat(prizeAmt);
                     setLogPrizeAmount(sub.id, prizeAmt);
-                    Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p14", "接收mq数据队列");
+                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p14", "接收mq数据日志");
                     var req = getRequestParams(projectId, content);
                     var requestParamField = req[sub.requestParamField];
                     var sendFlag = false;
                     if(!repeatFlag) sendFlag = recordService.Any(m => m.prizeObjId == prizeObjectId && m.listId == sub.id && m.prizeCode == prizeCode && m.requestParamField == content);
-                    Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p15", "接收mq数据队列");
+                    Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p15", "接收mq数据日志");
                     if(!sendFlag)
                     {
                         PriRecord item = new PriRecord()
@@ -2000,7 +2000,7 @@ namespace Util
                             batchNo = batchNo,
                         };
                         recordService.Add(item);
-                        Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p16", "接收mq数据队列");
+                        Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p16", "接收mq数据日志");
                         Dictionary<string, object> prizeItem = new Dictionary<string, object>();
                         prizeItem.Add("prize_date", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
                         prizeItem.Add("prize_name", sub.prizeName);
@@ -2016,7 +2016,7 @@ namespace Util
                         string prizeOutContent = Newtonsoft.Json.JsonConvert.SerializeObject(prizeItem);
                         setLogFieldValue(sub.id, "prizeOutContent", prizeOutContent);
                         setLogFieldValue(sub.id, "prizeOutUrl", project.noticeUrl);
-                        Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p17", "接收mq数据队列");
+                        Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p17", "接收mq数据日志");
                         if(project.requestMode == "http" && !string.IsNullOrEmpty(project.noticeUrl))
                         {
                             int status = -1;
@@ -2043,7 +2043,7 @@ namespace Util
                         {
                             prizeToDatabase(projectId, sub.id, content, condiDic, prizeAmt, startData); //入库
                         }
-                        Function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p18", "接收mq数据队列");
+                        Function.WriteLog(batchNo + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-p18", "接收mq数据日志");
                     }
                     loopAmount = getPrizeAmount;
                 }