wdy

center-channel/app/base/api/impl/auth/accessAuth.js

@@ -36,7 +36,6 @@ class AccessAuthAPI extends WEBBase {
                     apiVersion: "2019-09-02"
                 };
                 opResult = await this.utilsTmAliyunSve.getAliOssInfo(null, "ATTORNEY", rpcParam);
-                var tmo = 0;
                 // opResult = system.getResultSuccess(null, "测试成功");
                 opResult = system.getResultSuccess(null, "测试成功");
                 break;

center-channel/app/base/api/impl/opreceive/need.js

@@ -35,6 +35,12 @@ class Need extends APIBase {
             case "needClose"://关闭需求
                 opResult = await this.utilsNeedSve.needClose(pobj, pobj.actionBody);
                 break;
+            case "needCloseIcp"://关闭需求
+                opResult = await this.utilsNeedSve.needCloseIcp(pobj, pobj.actionBody);
+                break;    
+            case "getItemByNeedNo":
+                opResult = await this.utilsNeedSve.getItemByNeedNo(pobj, pobj.actionBody);
+                break;
             case "receiveFeedback"://接收方案反馈信息
                 opResult = await this.centerorderSve.reqCenterOrderApi(pobj);
                 break;
@@ -44,7 +50,7 @@ class Need extends APIBase {
             case "icpNotify"://icp方案更新
                 var rtn = await this.utilsNeedSve.icpNotify(pobj, pobj.actionBody);
                 if (pobj.actionBody.status == 4 && rtn.status == 0) {
-                    opResult = await self.utilsNeedSve.icpNotify(pobj, pobj.actionBody);
+                    opResult = await self.centerorderSve.icppaysuccess(pobj, pobj.actionBody);
                 } else {
                     opResult = rtn;
                 }

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

@@ -97,9 +97,41 @@ class UtilsNeedService extends AppServiceBase {
     } else {
       return system.getResult(null, "推送失敗　100388");
     }
+  }
 
+  /**
+  * icp关闭需求
+ * @param {*} pobj 
+  * @param {*} actionBody 
+  */
+  async needCloseIcp(pobj, actionBody) {
+    if (!actionBody.channelNeedNo) {
+      return system.getResult(null, "actionBody.channelNeedNo can not be empty，100395");
+    }
+    pobj.actionBody.intentionBizId=pobj.actionBody.channelNeedNo;
+    pobj.actionType="needClose"
+    var reqUrl = this.centerOrderUrl + "action/need/springBoard";
+    var result = await this.restPostUrl(pobj, reqUrl);
+    if (result.status == 0) {
+      this.utilsPushSve.aliBusiness2Fq(pobj, "pushCloseNeed");
+      return system.getResultSuccess();
+    } else {
+      return system.getResult(null, "close fail　100389");
     }
 
+  }
+
+//查询需求详情
+  async getItemByNeedNo(pobj, actionBody) {
+    if (!actionBody.needNo) {
+      return system.getResult(null, "actionBody.needNo can not be empty，100395");
+    }
+    var reqUrl = this.centerOrderUrl + "action/need/springBoard";
+    var result = await this.restPostUrl(pobj, reqUrl);
+    return result;
+  }
+
+  //状态更新
   async icpNotify(pobj) {
     var actionBody = pobj.actionBody;
     var self = this;
@@ -139,25 +171,11 @@ class UtilsNeedService extends AppServiceBase {
       }
       actionBody.newuserOtherList = newuserOtherList;
     }
-    if (actionBody.status == 2) {
-      pobj.actionType = "submit";
-      var url = settings.centerOrderUrl() + "action/need/springBoard";
+    pobj.actionType = "receiveIcpStatusNotify";
+    var url = settings.centerOrderUrl() + "action/icpapi/springBoard";
     var rtn = await this.restPostUrl(pobj, url);
     return rtn;
   }
-    if (actionBody.status == 4) {
-      pobj.actionType = "close";
-      var url = settings.centerOrderUrl() + "action/need/springBoard";
-      var rtn = await this.restPostUrl(pobj, url);
-      return rtn;
-    }
-    if (actionBody.status == 11) {
-      pobj.actionType = "close";
-      var url = settings.centerOrderUrl() + "action/need/springBoard";
-      var rtn = await this.restPostUrl(pobj, url);
-      return rtn;
-    }
-  }
 }
 
 module.exports = UtilsNeedService;