tj

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

@@ -19,14 +19,25 @@ class EsUtils {
         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 = (actionBody.messageBody || "") + "；actionType=" + (actionBody.actionType || "") + "；pushUrl=" + (actionBody.pushUrl || "");
+        if (!actionBody.messageBody) {
+            actionBody.messageBody = {};
+        }
+        if (typeof actionBody.messageBody === 'string') {
+            actionBody.messageBody = actionBody.messageBody + "；actionType=" + (actionBody.actionType || "") + "；pushUrl=" + (actionBody.pushUrl || "");
+        }
+        if (typeof actionBody.messageBody === 'object') {
+            actionBody.messageBody.actionType = actionBody.actionType || "";
+            actionBody.messageBody.pushUrl = actionBody.pushUrl || "";
+        }
+        actionBody.messageBody = typeof actionBody.messageBody === 'object' ? JSON.stringify(actionBody.messageBody) : actionBody.messageBody || "";
         var params = {
             opTitle: moment().format("YYYY-MM-DD HH:mm:ss:SSS") + "，" + actionBody.opTitle || "",
             identifyCode: actionBody.identifyCode || "",
-            messageBody: actionBody.messageBody || "",
+            messageBody: actionBody.messageBody,
             resultInfo: actionBody.resultInfo || "",
             errorInfo: actionBody.errorInfo || "",
-            requestId: actionBody.requestId
+            requestId: actionBody.requestId,
+            created_at: new Date()
         }
         var execResult = await this.execPostEs(queuedName, params, esIndexName);
         return execResult;