submitNeed push / submitIcpProgramme push

center-channel/app/base/service/impl/common/qcCenterOrderSve.js

@@ -15,6 +15,7 @@ class QcCenterOrderService extends AppServiceBase {
     this.utilsOrderSve = system.getObject("service.utilsSve.utilsOrderSve");
     this.utilsOrderSve = system.getObject("service.utilsSve.utilsOrderSve");
     this.utilsPushSve = system.getObject("service.utilsSve.utilsPushSve");
     this.utilsPushSve = system.getObject("service.utilsSve.utilsPushSve");
     this.utilsTmAliyunSve = system.getObject("service.utilsSve.utilsTmAliyunSve");//测试用
     this.utilsTmAliyunSve = system.getObject("service.utilsSve.utilsTmAliyunSve");//测试用
+    this.opPushQueueUrl = settings.opPushQueueUrl();
   };
   };
   //调用center-order 
   //调用center-order 
   async reqCenterOrderApi(pobj, reqUrl) {
   async reqCenterOrderApi(pobj, reqUrl) {
@@ -54,6 +55,22 @@ class QcCenterOrderService extends AppServiceBase {
       var self = this;
       var self = this;
       //推送方案
       //推送方案
       await this.pushIcpSolution(pushObj, needsolution.solutionNo, pobj.appInfo, self);
       await this.pushIcpSolution(pushObj, needsolution.solutionNo, pobj.appInfo, self);
+
+      // 2020 0806 lin 新增推送
+      var reqParams = {
+        actionType: "produceData",// Y 功能名称
+        actionBody: {
+          pushUrl: pushUrl,// Y 推送地址
+          actionType: "updateChanceStatus",// Y 推送地址接收时的功能名称
+          notifyUrl: "",// N 推送成功后通知的Url                 
+          identifyCode: "ali.vat",// Y 操作的业务标识
+          messageBody: pobj.actionBody, // Y 推送的业务消息，必须有一项对象属性值
+          headData: ""//N 请求头信息，Json格式，如：{token:"XXXXXXX"}
+        },
+        requestId: pobj.requestId || "" // N 请求id
+      }
+      this.opQueuePushClientPost(pobj, this.opPushQueueUrl, reqParams);
+
       return system.getResultSuccess();
       return system.getResultSuccess();
     }
     }
     return res;
     return res;

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

@@ -13,6 +13,7 @@ class UtilsNeedService extends AppServiceBase {
     this.ossClient = system.getObject("util.ossClient");
     this.ossClient = system.getObject("util.ossClient");
     this.restClient = system.getObject("util.restClient");
     this.restClient = system.getObject("util.restClient");
     this.utilsOrderSve = system.getObject("service.utilsSve.utilsOrderSve");
     this.utilsOrderSve = system.getObject("service.utilsSve.utilsOrderSve");
+    this.opPushQueueUrl = settings.opPushQueueUrl();
   }
   }
 
 
   /**
   /**
@@ -51,6 +52,22 @@ class UtilsNeedService extends AppServiceBase {
         } else {
         } else {
           pobj.actionBody.type = "ali.edi";
           pobj.actionBody.type = "ali.edi";
         }
         }
+        
+        // 2020 0806 lin 新增推送
+        var reqParams = {
+        actionType: "produceData",// Y 功能名称
+            actionBody: {
+                pushUrl: interface_params_info.pushUrl,// Y 推送地址
+                actionType: "addChance",// Y 推送地址接收时的功能名称
+                notifyUrl: "",// N 推送成功后通知的Url                 
+                identifyCode: "ali.vat",// Y 操作的业务标识
+                messageBody: pobj.actionBody, // Y 推送的业务消息，必须有一项对象属性值
+                headData: ""//N 请求头信息，Json格式，如：{token:"XXXXXXX"}
+            },
+            requestId: pobj.requestId || "" // N 请求id
+        }
+        this.opQueuePushClientPost(pobj, this.opPushQueueUrl, reqParams);
+
         this.utilsPushSve.aliBusiness2Fq(pobj, "pushNeedICPBusiness");
         this.utilsPushSve.aliBusiness2Fq(pobj, "pushNeedICPBusiness");
       }
       }
     }
     }