fq需求商机同步

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

@@ -116,5 +116,10 @@ class AccessAuthAPI extends APIBase {
         return system.getResultSuccess();
         return system.getResultSuccess();
     }
     }
 
 
+    async taskSyncNeedBusiness(pobj,qobj,req){
+        let result = await this.utilsNeedSve.syncNeedBusiness();
+        return result;
+    }
+
 }
 }
 module.exports = AccessAuthAPI;
 module.exports = AccessAuthAPI;
\ No newline at end of file

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

@@ -1581,6 +1581,7 @@ class UtilsNeedService extends AppServiceBase {
   }
   }
   //-----------接入百度ICP------end----------------------------------
   //-----------接入百度ICP------end----------------------------------
 
 
+  //需求导入
   async importNeeds(pobj,req){
   async importNeeds(pobj,req){
     let url = this.centerOrderUrl + 'action/need/springBoard';
     let url = this.centerOrderUrl + 'action/need/springBoard';
     if(!pobj.actionBody.needsArr){
     if(!pobj.actionBody.needsArr){
@@ -1599,6 +1600,25 @@ class UtilsNeedService extends AppServiceBase {
     }
     }
     return system.getResult(result.data.data);
     return system.getResult(result.data.data);
   }
   }
+
+  /**
+   * 同步需求商机
+   * @param pobj
+   * @param qobj
+   * @param req
+   * @returns {Promise<{msg: *, data, bizmsg: *|string, status: number}>}
+   */
+  async syncNeedBusiness(pobj,qobj,req){
+    let url = this.centerOrderUrl + 'task/taskAction/taskNeed';
+    let result = await this.execPostByTimeOut(req,pobj,url,"json",null,60)
+    if (!result || result.status != 0) {
+      return system.getResult(null, result.msg);
+    }
+    if (!result.data || result.data.status != 0) {
+      return system.getResult(null, result.data.msg);
+    }
+    return system.getResult(result.data.data);
+  }
 }
 }
 
 
 module.exports = UtilsNeedService;
 module.exports = UtilsNeedService;