渠道增加

igirl-channel/app/base/service/impl/trademark/tmquerySve.js

@@ -9,6 +9,7 @@ class TmqueryService {
         this.zcApiUrl = settings.reqZcApi();
         this.zcApiUrl = settings.reqZcApi();
         this.reqEsAddr = settings.reqEsAddr();
         this.reqEsAddr = settings.reqEsAddr();
         this.execClient = system.getObject("util.execClient");
         this.execClient = system.getObject("util.execClient");
+        this.execClientNew = system.getObject("util.execClientNew");
     }
     }
 
 
     /**
     /**
@@ -146,6 +147,7 @@ class TmqueryService {
          * 请求es 拿出数据，组装
          * 请求es 拿出数据，组装
          */
          */
         let failOrders = [];
         let failOrders = [];
+        var self=this;
         try {
         try {
             const data = await this.execClient.execPostTimeOut({
             const data = await this.execClient.execPostTimeOut({
                 "query": {
                 "query": {
@@ -191,6 +193,7 @@ class TmqueryService {
             if (tokenInfo.status != 0) {
             if (tokenInfo.status != 0) {
                 return tokenInfo;
                 return tokenInfo;
             }
             }
+            this.execClientNew.execLogs("igirl-channel-pushJdPayOrder-去重后的数据集合", queryobj, "igirl-channel-pushJdPayOrder", result, null);
             let buildResult = [];
             let buildResult = [];
             for (let pushData of result) {
             for (let pushData of result) {
                 //自助注册产品---用updateOrderPayStatus，否则为addOrderAndDelivery
                 //自助注册产品---用updateOrderPayStatus，否则为addOrderAndDelivery
@@ -217,9 +220,9 @@ class TmqueryService {
                     param.actionType = "jdAddQifuOrder";
                     param.actionType = "jdAddQifuOrder";
                 }//工商产品订单
                 }//工商产品订单
 
 
-                let reqUrl = this.channelApiUrl + "/action/tmOrder/springBoard";
-                let rtn = await this.execClient.execPushDataPost(param, reqUrl, tokenInfo.data.token, req.headers["request-id"]);
-                ;
+                let reqUrl = self.channelApiUrl + "/action/tmOrder/springBoard";
+                let rtn = await self.execClient.execPushDataPost(param, reqUrl, tokenInfo.data.token, req.headers["request-id"]);
+                self.execClientNew.execLogs("igirl-channel-pushJdPayOrder-去重后的数据处理结果", param, "igirl-channel-pushJdPayOrder", rtn, null);
                 if (!rtn || !rtn.stdout) {
                 if (!rtn || !rtn.stdout) {
                     failOrders.push(
                     failOrders.push(
                         {
                         {
@@ -245,7 +248,9 @@ class TmqueryService {
             }
             }
             return {successOrders: buildResult, failOrders};
             return {successOrders: buildResult, failOrders};
         } catch (error) {
         } catch (error) {
-            console.log(error)
+            const stackStr = error.stack ? error.stack : JSON.stringify(error);
+            console.log(stackStr,"pushJdPayOrder.................error")
+            self.execClientNew.execLogs("igirl-channel-pushJdPayOrder-去重后的数据处理结果", param, "igirl-channel-pushJdPayOrder", rtn, null);
             return system.getResultFail(-200, "操作error");
             return system.getResultFail(-200, "操作error");
         }
         }
     }
     }