tj

brg-queue-center/app/base/db/consumer.base.js

@@ -22,7 +22,7 @@ class ConsumerBase {
       }
       }
       var self = this;
       var self = this;
       this.duplicateInstance.brpop(queuedName, 3600, async function (err, repl) {
       this.duplicateInstance.brpop(queuedName, 3600, async function (err, repl) {
-        console.log(JSON.stringify(repl), "..........repl..............");
+        console.log(JSON.stringify(repl), ".....．．．．.....repl.............." + queuedName);
         if (err) {
         if (err) {
           return new Error('doConsumer brpop error :' + err);
           return new Error('doConsumer brpop error :' + err);
         }
         }

brg-queue-center/app/base/db/consumer/publicServiceAllocation/publicConsumer.js

@@ -7,7 +7,7 @@ class PublicConsumer extends ConsumerBase {
     this.esUtils = system.getObject("util.esUtils");
     this.esUtils = system.getObject("util.esUtils");
   }
   }
   async subBeforeConsumer(queuedName, actionBody) {
   async subBeforeConsumer(queuedName, actionBody) {
-    console.log("前置操作......", this.serviceName);
+    console.log("publicConsumer前置操作......", this.serviceName);
   }
   }
   async subDoConsumer(queuedName, actionBody) {
   async subDoConsumer(queuedName, actionBody) {
     var params = {
     var params = {
@@ -16,7 +16,9 @@ class PublicConsumer extends ConsumerBase {
       actionBody: actionBody.messageBody,
       actionBody: actionBody.messageBody,
       requestId: actionBody.requestId
       requestId: actionBody.requestId
     }
     }
+    console.log(JSON.stringify(params), "publicConsumer推送信息．．．．．actionBody.pushUrl=" + actionBody.pushUrl)
     var execResult = await this.execPostByTimeOut(params, actionBody.pushUrl);
     var execResult = await this.execPostByTimeOut(params, actionBody.pushUrl);
+    console.log(JSON.stringify(execResult), "publicConsumer推送结果．．．．．actionBody.pushUrl=" + actionBody.pushUrl)
     var tmpBody = {
     var tmpBody = {
       "opTitle": "队列推送数据记录，推送地址：" + actionBody.pushUrl,// N 操作的业务标题
       "opTitle": "队列推送数据记录，推送地址：" + actionBody.pushUrl,// N 操作的业务标题
       "identifyCode": actionBody.identifyCode || "",// Y 操作的业务标识
       "identifyCode": actionBody.identifyCode || "",// Y 操作的业务标识

brg-queue-center/app/base/utils/esUtils.js

@@ -20,10 +20,10 @@ class EsUtils {
             esIndexName = queuedName + (actionBody.indexName ? "-" + actionBody.indexName : "");
             esIndexName = queuedName + (actionBody.indexName ? "-" + actionBody.indexName : "");
         }
         }
         esIndexName = esIndexName.toLocaleLowerCase() + "/_doc?pretty";
         esIndexName = esIndexName.toLocaleLowerCase() + "/_doc?pretty";
-        actionBody.resultInfo = typeof actionBody.resultInfo === 'object' ? JSON.stringify(actionBody.resultInfo) : actionBody.resultInfo;
-        actionBody.errorInfo = typeof actionBody.errorInfo === 'object' ? JSON.stringify(actionBody.errorInfo) : actionBody.errorInfo;
-        actionBody.messageBody = typeof actionBody.messageBody === 'object' ? JSON.stringify(actionBody.messageBody) : actionBody.messageBody;
-        actionBody.messageBody=actionBody.messageBody+"；actionType="+actionBody.actionType+"；pushUrl="+actionBody.pushUrl
+        actionBody.resultInfo = typeof actionBody.resultInfo === 'object' ? JSON.stringify(actionBody.resultInfo) : actionBody.resultInfo || "";
+        actionBody.errorInfo = typeof actionBody.errorInfo === 'object' ? JSON.stringify(actionBody.errorInfo) : actionBody.errorInfo || "";
+        actionBody.messageBody = typeof actionBody.messageBody === 'object' ? JSON.stringify(actionBody.messageBody) : actionBody.messageBody || "";
+        actionBody.messageBody = (actionBody.messageBody || "") + "；actionType=" + (actionBody.actionType || "") + "；pushUrl=" + (actionBody.pushUrl || "");
         var params = {
         var params = {
             opTitle: moment().format("YYYY-MM-DD HH:mm:ss:SSS") + "，" + actionBody.opTitle || "",
             opTitle: moment().format("YYYY-MM-DD HH:mm:ss:SSS") + "，" + actionBody.opTitle || "",
             identifyCode: actionBody.identifyCode || "",
             identifyCode: actionBody.identifyCode || "",