wdy

center-channel/app/base/db/impl/common/testneedDao.js

+const system=require("../../../system");
+const Dao=require("../../dao.base");
+class testneedDao extends Dao{
+  constructor(){
+    super(Dao.getModelName(testneedDao));
+  }
+}
+module.exports=testneedDao;

center-channel/app/base/db/models/common/testneed.js

+const system = require("../../../system");
+const settings = require("../../../../config/settings");
+const uiconfig = system.getUiConfig2(settings.appKey);
+module.exports = (db, DataTypes) => {
+  return db.define("testneed", {
+    channelNeedNo: DataTypes.STRING,
+    status: DataTypes.STRING,
+  }, {
+      //freezeTableName: true,
+      // define the table's name
+      tableName: 'testneed',
+    });
+}

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

@@ -3,6 +3,7 @@ var settings = require("../../../../config/settings");
 const AppServiceBase = require("../../app.base");
 const fs = require("fs");
 const { json } = require("sequelize");
+const async = require('async')
 //需求操作类----ali对接的需求
 class UtilsNeedService extends AppServiceBase {
   constructor() {
@@ -13,6 +14,7 @@ class UtilsNeedService extends AppServiceBase {
     this.ossClient = system.getObject("util.ossClient");
     this.restClient = system.getObject("util.restClient");
     this.utilsOrderSve = system.getObject("service.utilsSve.utilsOrderSve");
+    this.utilsneedSve = system.getObject("service.common.gatewaypushlogSve");
     this.opPushQueueUrl = settings.opPushQueueUrl();
   }
 
@@ -457,7 +459,16 @@ class UtilsNeedService extends AppServiceBase {
         PageSize: pobj.actionBody.pageSize || 10,
       }, apiVersion: "2019-05-08"
     });
-    console.log(res)
+    // 2020 0820 lin 新增 拉去有跟进信息的需求但 并 记录
+    // console.log(pobj.actionBody.intentionBizId,res.data.TotalItemNum)
+    // if(res.data.TotalItemNum > 0) {
+    //     var sql = "update testneed set status=1 where channelNeedNo=:channelNeedNo"
+    //     var paramWhere = {
+    //       channelNeedNo: pobj.actionBody.intentionBizId
+    //     };
+    //     var updateRes = await this.utilsneedSve.dao.customUpdate(sql, paramWhere);
+    // }
+    // func();
     return system.getResultSuccess(res);
   }
 

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

@@ -32,7 +32,6 @@ class UtilsPushService extends AppServiceBase {
 
   async aliBusiness2Fq(pobj, opType) {//供业务调用，在代码中调用，不在db中做配置进行调用
     pobj.actionType = "getAppInterface";
-    debugger;
     var reqUrl = settings.centerAppUrl() + "action/opProduct/springBoard";
     var productItemInterfaceResult = await this.restPostUrl(pobj, reqUrl);
     pobj.interface_info = productItemInterfaceResult.data;

center-channel/package.json

@@ -16,6 +16,7 @@
     "ali-oss": "^4.12.2",
     "alipay-sdk": "^3.1.1",
     "aliyun-api-gateway": "^1.1.6",
+    "async": "^3.2.0",
     "axios": "^0.19.2",
     "babel-polyfill": "^6.26.0",
     "base64id": "^1.0.0",