wdy

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

@@ -8,6 +8,7 @@ class CenterorderService {
     this.aliclient = system.getObject("util.aliyunClient");
     this.cacheManager = system.getObject("db.common.cacheManager");
     this.utilsOrderSve = system.getObject("service.utilsSve.utilsOrderSve");
+    this.utilsPushSve = system.getObject("service.utilsSve.utilsPushSve");
   };
   //调用center-order 
   async reqCenterOrderApi(pobj, reqUrl) {
@@ -130,21 +131,19 @@ class CenterorderService {
     // }
     pobj.actionBody.totalSum = pobj.actionBody.orderPrice;
     pobj.actionBody.payTotalSum = pobj.actionBody.orderPrice;
-    pobj.actionBody.quantity=1;
+    pobj.actionBody.quantity = 1;
     pobj.actionBody.channelOrder = {
       channelServiceNo: pobj.actionBody.orderNo,
       channelOrderNo: pobj.actionBody.orderNo,
       orderStatus: 2
     }
     var orderrtn = await this.utilsOrderSve.addOrder(pobj, pobj.actionBody);
-    
-    if (orderrtn.status != 0) {
+   if (orderrtn.status != 0) {
       return system.getResultFail(-5012, "订单创建失败");
     }
-    if(orderrtn.data){
-      pobj.actionBody.orderNo=orderrtn.data.orderNo
+    if (orderrtn.data) {
+      pobj.actionBody.orderNo = orderrtn.data.orderNo
     }
-      
     if (pobj.actionBody.solutionBizId) {
       pobj.actionType = "receiveSolutionPayInfo";
     } else {
@@ -159,9 +158,12 @@ class CenterorderService {
     if (solutiondata.status != 0) {
       return system.getResultFail(-5011, "方案查询失败");
     }
-    if (solutiondata.data&&solutiondata.data.channelNeedNo) {
+    if (solutiondata.data && solutiondata.data.channelNeedNo) {
       pobj.actionBody.needId = solutiondata.data.channelNeedNo;
     }
+    if (solutiondata.status == 0) {
+      this.utilsPushSve.aliBusiness2Fq(pobj, "pushOrderBusiness");
+    }
     return system.getResultSuccess();
   }
 }

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

@@ -45,7 +45,7 @@ class UtilsFqAliyunSve extends AppServiceBase {
     var result = this.opAliyunClientPost(pobj, "pushOrderBusiness", interface_params_info.opUrl, interface_params_info.key, interface_params_info.secret, params);
   }
 
-  async pushAliIcNeedBusiness(pobj) {//推送阿里工商需求商机
+  async pushAliBusiness2Fq(pobj) {//推送阿里工商需求商机
     if (!pobj.interface_params) {
       return "";
     }

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

@@ -21,11 +21,7 @@ class UtilsNeedSve extends AppServiceBase {
     var reqUrl = this.centerOrderUrl + "action/need/springBoard";
     var result = await this.restPostUrl(pobj, reqUrl);
     if (result.status == 0) {
-      pobj.actionType = "getAppInterface";
-      var url = settings.centerAppUrl() + "action/opProduct/springBoard";
-      var productItemInterfaceResult = await this.restPostUrl(pobj, url);
-      pobj.interface_info = productItemInterfaceResult.data;
-      this.utilsPushSve.pushBusInfo(pobj, "pushNeedBusiness", 1);
+      this.utilsPushSve.aliBusiness2Fq(pobj, "pushNeedBusiness");
     }
     return result;
   }
@@ -52,7 +48,10 @@ class UtilsNeedSve extends AppServiceBase {
       return system.getResult(null, "actionBody.intentionBizId can not be empty，100380");
     }
     var reqUrl = this.centerOrderUrl + "action/need/springBoard";
-    return await this.restPostUrl(pobj, reqUrl);
+    var result = await this.restPostUrl(pobj, reqUrl);
+    if (result.status == 0) {
+      this.utilsPushSve.aliBusiness2Fq(pobj, "pushCloseNeed");
+    }
   }
 }
 module.exports = UtilsNeedSve;

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

@@ -7,6 +7,15 @@ class UtilsPushService extends AppServiceBase {
     super();
     this.pushlogSve = system.getObject("service.common.pushlogSve");
   };
+
+  async aliBusiness2Fq(pobj, opType) {
+    pobj.actionType = "getAppInterface";
+    var reqUrl = settings.centerAppUrl() + "action/opProduct/springBoard";
+    var productItemInterfaceResult = await this.restPostUrl(pobj, reqUrl);
+    pobj.interface_info = productItemInterfaceResult.data;
+    this.pushBusInfo(pobj, opType, 1);
+  }
+
   async pushBusInfo(pobj, opType, isDelProductInfo) {//推送业务信息
     var interface_list = pobj.actionBody.product_info ? pobj.actionBody.product_info.interface_info : pobj.interface_info;
     if (!interface_list) {