tj

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

@@ -53,7 +53,7 @@ class UtilsPushService extends AppServiceBase {
   }
   }
 
 
   async pushBusInfo(pobj, opType, isDelProductInfo) {//推送业务总入口，不在db中做配置进行调用
   async pushBusInfo(pobj, opType, isDelProductInfo) {//推送业务总入口，不在db中做配置进行调用
-    console.log(JSON.stringify(pobj),".......pushBusInfo.........................");
+    console.log(JSON.stringify(pobj), ".......pushBusInfo.........................");
     var interface_list = pobj.interface_info ? pobj.interface_info : pobj.actionBody.product_info.interface_info;
     var interface_list = pobj.interface_info ? pobj.interface_info : pobj.actionBody.product_info.interface_info;
     if (!interface_list) {
     if (!interface_list) {
       return system.getResult(null, "暂无推送配置");
       return system.getResult(null, "暂无推送配置");
@@ -64,11 +64,11 @@ class UtilsPushService extends AppServiceBase {
     }
     }
     var self = this;
     var self = this;
     let result;
     let result;
-    if(interface_list_temp && interface_list_temp.length==1){
+    if (interface_list_temp && interface_list_temp.length == 1) {
       const element = interface_list_temp[0];
       const element = interface_list_temp[0];
       var reflexActionRes = await self.reflexAction(element, opType, pobj, isDelProductInfo);
       var reflexActionRes = await self.reflexAction(element, opType, pobj, isDelProductInfo);
       return reflexActionRes;
       return reflexActionRes;
-    }else{
+    } else {
       for (let index = 0; index < interface_list_temp.length; index++) {
       for (let index = 0; index < interface_list_temp.length; index++) {
         const element = interface_list_temp[index];
         const element = interface_list_temp[index];
         result = await self.reflexAction(element, opType, pobj, isDelProductInfo);
         result = await self.reflexAction(element, opType, pobj, isDelProductInfo);
@@ -85,6 +85,8 @@ class UtilsPushService extends AppServiceBase {
     }
     }
     var result = await this.reflexAction(interface_info, pobj.opType, pobj, pobj.isDelProductInfo || 1);
     var result = await this.reflexAction(interface_info, pobj.opType, pobj, pobj.isDelProductInfo || 1);
     if (result.status != 0) {
     if (result.status != 0) {
+      //TODO:记录推送失败的log
+      this.execClientNew.execLogs("pushBusInfo-reflexAction-result:", pobj, "center-channel-reflexAction", result, null);
       return result;
       return result;
     }
     }
     return system.getResultSuccess();
     return system.getResultSuccess();
@@ -124,8 +126,8 @@ class UtilsPushService extends AppServiceBase {
           delete actionBody["product_info"];
           delete actionBody["product_info"];
         }//是否删除产品信息进行推送
         }//是否删除产品信息进行推送
         refResult = await this.restPostUrl(pobj.actionBody, interface_info.interface_url);
         refResult = await this.restPostUrl(pobj.actionBody, interface_info.interface_url);
-        if(refResult.code == 1) {
-            refResult.status = 0
+        if (refResult.code == 1) {
+          refResult.status = 0
         }
         }
         this.disposePushResult(pobj, refResult, "ycUrlPush->reflexAction->refResult", this.pushlogFailType.NEWRPC);
         this.disposePushResult(pobj, refResult, "ycUrlPush->reflexAction->refResult", this.pushlogFailType.NEWRPC);
       }
       }