tj

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

@@ -31,13 +31,14 @@ class EsUtils {
         }
         }
         actionBody.messageBody = typeof actionBody.messageBody === 'object' ? JSON.stringify(actionBody.messageBody) : actionBody.messageBody || "";
         actionBody.messageBody = typeof actionBody.messageBody === 'object' ? JSON.stringify(actionBody.messageBody) : actionBody.messageBody || "";
         var params = {
         var params = {
-            opTitle: moment().format("YYYY-MM-DD HH:mm:ss:SSS") + "，" + actionBody.opTitle || "",
+            opTitle: actionBody.opTitle || "",
             identifyCode: actionBody.identifyCode || "",
             identifyCode: actionBody.identifyCode || "",
             messageBody: actionBody.messageBody,
             messageBody: actionBody.messageBody,
             resultInfo: actionBody.resultInfo || "",
             resultInfo: actionBody.resultInfo || "",
             errorInfo: actionBody.errorInfo || "",
             errorInfo: actionBody.errorInfo || "",
             requestId: actionBody.requestId,
             requestId: actionBody.requestId,
-            created_at: new Date()
+            created_at: moment().format("YYYY-MM-DD HH:mm:ss:SSS"),
+            timestamp: Date.now()
         }
         }
         var execResult = await this.execPostEs(queuedName, params, esIndexName);
         var execResult = await this.execPostEs(queuedName, params, esIndexName);
         return execResult;
         return execResult;
@@ -91,6 +92,9 @@ class EsUtils {
                 return system.getResult(null, "execPostTimeOut data is empty");
                 return system.getResult(null, "execPostTimeOut data is empty");
             }
             }
             var stdoutInfo = JSON.parse(result.stdout);
             var stdoutInfo = JSON.parse(result.stdout);
+            if(stdoutInfo.error && stdoutInfo.error.reason==="no such index"){
+                return system.getResult(null, "no such index info");
+            }
             if (stdoutInfo.error) {
             if (stdoutInfo.error) {
                 this.errorLogDao.addOpErrorLogs(queuedName + "执行execPostEs存在错误", params, result, null, 3);
                 this.errorLogDao.addOpErrorLogs(queuedName + "执行execPostEs存在错误", params, result, null, 3);
                 return system.getResult(null, "执行execPostEs存在错误");
                 return system.getResult(null, "执行execPostEs存在错误");