tj

center-channel/app/base/service/impl/utilsSve/utilsPushSve.js

@@ -66,12 +66,14 @@ class UtilsPushService extends AppServiceBase {
     let result;
     if (interface_list_temp && interface_list_temp.length == 1) {
       const element = interface_list_temp[0];
-      var reflexActionRes = await self.reflexAction(element, opType, pobj, isDelProductInfo);
+      let reflexActionRes = await self.reflexAction(element, opType, pobj, isDelProductInfo);
+      self.execClientNew.execLogs("pushBusInfo-reflexAction-result:", pobj, "center-channel-reflexAction", reflexActionRes, null);
       return reflexActionRes;
     } else {
       for (let index = 0; index < interface_list_temp.length; index++) {
         const element = interface_list_temp[index];
         result = await self.reflexAction(element, opType, pobj, isDelProductInfo);
+        self.execClientNew.execLogs("pushBusInfo-for---reflexAction-result:", pobj, "center-channel-reflexAction", result, null);
       }
       return result;
     }
@@ -84,9 +86,8 @@ class UtilsPushService extends AppServiceBase {
       return system.getResult(null, "暂无推送配置");
     }
     var result = await this.reflexAction(interface_info, pobj.opType, pobj, pobj.isDelProductInfo || 1);
+    this.execClientNew.execLogs("againPushBusInfo-reflexAction-result:", pobj, "center-channel-reflexAction", result, null);
     if (result.status != 0) {
-      //TODO:记录推送失败的log
-      this.execClientNew.execLogs("pushBusInfo-reflexAction-result:", pobj, "center-channel-reflexAction", result, null);
       return result;
     }
     return system.getResultSuccess();