QueryTradeIntentionUserList

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

@@ -10,6 +10,17 @@ class AccessAuthAPI extends APIBase {
         this.aliclient = system.getObject("util.aliyunClient");
         this.utilsTmAliyunSve = system.getObject("service.utilsSve.utilsTmAliyunSve");
         this.utilsTmOrderCallService = system.getObject("service.utilsSve.utilsTmOrderCallSve");
+        this.utilsNeedSve = system.getObject("service.utilsSve.utilsNeedSve");
+    }
+    async QueryTradeIntentionUserList(pobj, qobj, req) {
+      pobj.appInfo={uapp_id:18}
+      let endtime = Date.now();
+      let starttime = Date.now() - 30 * 60 * 1000;//30分钟(毫秒)
+      pobj.actionBody = {
+          Begin: starttime,
+          End: endtime
+      };
+      return await this.utilsNeedSve.queryTradeIntentionUserList(pobj);
     }
     async taskAliIcapi() {
         var rtn = await this.gatewaypushlogSve.taskAliIcapi();

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

@@ -54,7 +54,7 @@ class UtilsNeedService extends AppServiceBase {
     }
 
 
-    if (pobj.actionBody.description.indexOf("备#") < 0) {
+    if (pobj.actionBody.description && pobj.actionBody.description.indexOf("备#") < 0) {
       pobj.actionBody.level = "A";
     } else {
       var levelurl = "http://106.13.228.212:8000/recProbability";
@@ -590,13 +590,16 @@ class UtilsNeedService extends AppServiceBase {
         type: "tmjy"
       };
       for (let item of result.data) {
+        if (item.Type == 1 && item.RegisterNumber) {
         pobj.actionBody.intentionBizId = item.BizId;
         pobj.actionBody.mobile = item.Mobile ? item.Mobile : "";
         pobj.actionBody.userName = item.UserName ? item.UserName : "";
+        pobj.actionBody.description = item.RegisterNumber
         pobj.notes = `${item.RegisterNumber ? "RegisterNumber:" + item.RegisterNumber : ""}${item.Classification ? "Classification:" + item.Classification : ""}`;
         let res = await this.submitNeed(JSON.parse(JSON.stringify(pobj)), { intentionBizId: item.BizId });
         console.log(res)
         }
+      }
       return system.getResultSuccess();
     } else {
       return system.getResultFail(result.status, result.msg);