testneed ok

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();
   }
 
@@ -430,6 +432,16 @@ class UtilsNeedService extends AppServiceBase {
         PageSize: pobj.actionBody.pageSize || 10,
       }, apiVersion: "2019-05-08"
     });
+    // 2020 0820 lin 新增 拉去有跟进信息的需求但 并 记录
+    // if(res.data.TotalItemNum > 0) {
+    //     console.log(pobj.actionBody.intentionBizId)
+    //     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);
   }
 
@@ -470,7 +482,78 @@ class UtilsNeedService extends AppServiceBase {
 module.exports = UtilsNeedService;
 
 // var a=new UtilsNeedService();
-// a.queryExpertApplyCommunicationLogs({actionBody:{intentionBizId:"20200803095203000001",userFeedBack:true}});
+var arr = [
+    "20200820110400000001",
+    "20200820110431000001",
+    "20200820110540000001",
+    "20200820110607000001",
+    "20200820110608000001",
+    "20200820110639000001",
+    "20200820110645000001",
+    "20200820110942000001",
+    "20200820111027000001",
+    "20200820111522000001",
+    "20200820111740000001",
+    "20200820111942000001",
+    "20200820111951000001",
+    "20200820112048000001",
+    "20200820112447000001",
+    "20200820112506000001",
+    "20200820112545000001",
+    "20200820112546000001",
+    "20200820112646000001",
+    "20200820112721000001",
+    "20200820112804000001",
+    "20200820113016000001",
+    "20200820113249000001",
+    "20200820113526000001",
+    "20200820113924000001",
+    "20200820113926000001",
+    "20200820114043000001",
+    "20200820114418000001",
+    "20200820114423000001",
+    "20200820114447000001",
+    "20200820114605000001",
+    "20200820114731000001",
+    "20200820115252000001",
+    "20200820115738000001",
+    "20200820115819000001",
+    "20200820115902000001",
+    "20200820115933000001",
+    "20200820121315000001",
+    "20200820121742000001",
+    "20200820124729000001",
+    "20200820125618000001",
+    "20200820125703000001",
+    "20200820130900000001",
+    "20200820131113000001",
+    "20200820131128000001",
+    "20200820131221000001",
+    "20200820131257000001",
+    "20200820131537000001",
+    "20200820131757000001",
+    "20200820131948000001",
+    "20200820132002000001",
+    "20200820132229000001",
+    "20200820133244000001",
+    "20200820133446000001",
+    "20200820133449000001",
+    "20200820133751000001",
+    "20200820134118000001",
+    "20200820134131000001",
+    "20200820134222000001",
+    "20200820134446000001",
+    "20200820134548000001",
+    "I20200323111952000001"
+]
+
+// async.map(arr, function(item, callback) {
+//     a.queryExpertApplyCommunicationLogs({actionBody:{intentionBizId:item,userFeedBack:true}},function(err, res) {
+//         callback()
+//     });
+// })
+
+
 // // var a=new UtilsNeedService();
 // a.writeCommunicationLog({actionBody:{intentionBizId:"20200804200124000001",note:"测试反馈"}});
 

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",