sync order business

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

@@ -11,6 +11,7 @@ class AccessAuthAPI extends APIBase {
         this.utilsTmAliyunSve = system.getObject("service.utilsSve.utilsTmAliyunSve");
         this.utilsTmAliyunSve = system.getObject("service.utilsSve.utilsTmAliyunSve");
         this.utilsTmOrderCallService = system.getObject("service.utilsSve.utilsTmOrderCallSve");
         this.utilsTmOrderCallService = system.getObject("service.utilsSve.utilsTmOrderCallSve");
         this.utilsNeedSve = system.getObject("service.utilsSve.utilsNeedSve");
         this.utilsNeedSve = system.getObject("service.utilsSve.utilsNeedSve");
+        this.utilsOpOrderSve = system.getObject("service.utilsSve.utilsOpOrderSve");
     }
     }
     async QueryTradeIntentionUserList(pobj, qobj, req) {
     async QueryTradeIntentionUserList(pobj, qobj, req) {
       pobj.appInfo={uapp_id:18}
       pobj.appInfo={uapp_id:18}
@@ -116,10 +117,29 @@ class AccessAuthAPI extends APIBase {
         return system.getResultSuccess();
         return system.getResultSuccess();
     }
     }
 
 
+    /**
+     * 需求商机同步任务
+     * @param pobj
+     * @param qobj
+     * @param req
+     * @returns {Promise<{msg: *, data, bizmsg: (*|string), status: number}>}
+     */
     async taskSyncNeedBusiness(pobj,qobj,req){
     async taskSyncNeedBusiness(pobj,qobj,req){
         let result = await this.utilsNeedSve.syncNeedBusiness();
         let result = await this.utilsNeedSve.syncNeedBusiness();
         return result;
         return result;
     }
     }
 
 
+    /**
+     * 订单商机同步任务
+     * @param pobj
+     * @param qobj
+     * @param req
+     * @returns {Promise<{msg: *, data, bizmsg: (*|string), status: number}>}
+     */
+    async taskSyncOrderBusiness(pobj,qobj,req){
+        let result = await this.utilsOpOrderSve.syncOrderBusiness();
+        return result;
+    }
+
 }
 }
 module.exports = AccessAuthAPI;
 module.exports = AccessAuthAPI;
\ No newline at end of file

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

@@ -1610,7 +1610,7 @@ class UtilsNeedService extends AppServiceBase {
    */
    */
   async syncNeedBusiness(pobj,qobj,req){
   async syncNeedBusiness(pobj,qobj,req){
     let url = this.centerOrderUrl + 'task/taskAction/taskNeed';
     let url = this.centerOrderUrl + 'task/taskAction/taskNeed';
-    let data = {identifyCode : 'sync'}
+    let data = {identifyCode : 'syncNeed'}
     let result = await this.execPostByTimeOut(req,data,url,"json",null,60)
     let result = await this.execPostByTimeOut(req,data,url,"json",null,60)
     if (!result || result.status != 0) {
     if (!result || result.status != 0) {
       return system.getResult(null, result.msg);
       return system.getResult(null, result.msg);

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

@@ -115,5 +115,25 @@ class UtilsOpOrderService extends AppServiceBase {
       }
       }
     }
     }
   }
   }
+
+  /**
+   * 同步订单商机
+   * @param pobj
+   * @param qobj
+   * @param req
+   * @returns {Promise<{msg: *, data, bizmsg: *|string, status: number}>}
+   */
+  async syncOrderBusiness(pobj,qobj,req){
+    let url = this.centerOrderUrl + 'task/taskAction/taskOrder';
+    let data = {identifyCode : 'syncOrder'}
+    let result = await this.execPostByTimeOut(req,data,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 = UtilsOpOrderService;
 module.exports = UtilsOpOrderService;