icpqueue

center-channel/app/base/api/impl/icp/queueNotify.js

+var APIBase = require("../../api.base");
+var system = require("../../../system");
+var settings = require("../../../../config/settings");
+class QueueNotify extends APIBase {
+    constructor() {
+        super();
+        this.baseOrderSve = system.getObject("service.common.baseCenterOrderSve");
+    }
+    /**
+      * 接口跳转-POST请求
+      * action_process  执行的流程
+      * action_type     执行的类型
+      * action_body     执行的参数
+      */
+    async springBoard(pobj, qobj, req) {
+        if (!pobj.actionType) {
+            return system.getResult(null, "actionType参数不能为空");
+        }
+        var result = await this.opActionProcess(pobj, pobj.actionType, req);
+        return result;
+    }
+    async opActionProcess(pobj, action_type, req) {
+        var opResult = null;
+        switch (action_type) {
+            // --------- 推送icp信息至渠道和作方 zhuangbing-20201116--------
+            case "pushIcpSolution2Channel"://推送ICP方案至渠道（百度）
+                opResult = await this.baseOrderSve.pushIcpSolution2Channel(pobj);
+                break;
+            default:
+                opResult = system.getResult(null, "action_type参数错误");
+                break;
+        }
+        return opResult;
+    }
+
+}
+module.exports = QueueNotify;
\ No newline at end of file

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

@@ -78,7 +78,7 @@ class UtilsChannelPartnerService extends AppServiceBase {
     if(!pobj || !pobj.appInfo || !pobj.appInfo.app_code){
     if(!pobj || !pobj.appInfo || !pobj.appInfo.app_code){
       verify = system.getResult(null, "appInfo can not be empty，100450");
       verify = system.getResult(null, "appInfo can not be empty，100450");
     }
     }
-    var signRes = await this.signSve.createSign(pobj.actionBody,pobj.appInfo.uapp_secret);
+    var signRes = await this.signSve.createSign({actionBody:pobj.actionBody,actionType: interface_params_info.actionType},pobj.appInfo.uapp_secret);
     if(signRes && signRes.status==0){
     if(signRes && signRes.status==0){
       verify.sign=signRes.data;
       verify.sign=signRes.data;
     }else{
     }else{

center-channel/app/config/businessConfig.js

@@ -26,6 +26,6 @@ module.exports = {
             "ncGetNeedList","ncSubmitMaterial","ncNotification","ncSubmitSolution","ncWriteCommunicationRecord","ncGetCommunicationRecord","ncCloseNeed","ncClosePlan","ncCloseOrderDelivery",
             "ncGetNeedList","ncSubmitMaterial","ncNotification","ncSubmitSolution","ncWriteCommunicationRecord","ncGetCommunicationRecord","ncCloseNeed","ncClosePlan","ncCloseOrderDelivery",
             "rtGetNeedList","rtSubmitMaterial","rtNotification","rtSubmitSolution","rtWriteCommunicationRecord","rtGetCommunicationRecord","rtCloseNeed","rtClosePlan","rtCloseOrderDelivery",
             "rtGetNeedList","rtSubmitMaterial","rtNotification","rtSubmitSolution","rtWriteCommunicationRecord","rtGetCommunicationRecord","rtCloseNeed","rtClosePlan","rtCloseOrderDelivery",
         ],
         ],
-        apiSecretPathList: ["/api/icp/consultation/submit","/api/icp/feedback/submit","/api/icp/order/notify","/api/opreceive/service/create","/api/icp/order/close","/api/opreceive/service/notify"]
+        apiSecretPathList: ["/api/icp/consultation/submit","/api/icp/feedback/submit","/api/icp/order/notify","/api/opreceive/service/create","/api/icp/order/close","/api/opreceive/service/notify","/api/icp/queueNotify/springBoard",]
     }
     }
 }
 }