+models: webhook_logs, outbound_messages

.gitignore

@@ -13,7 +13,8 @@ dist-ssr
 *.local
 distTest
 dev-dist
-tmp
+tmp
+schema
 
 # Editor directories and files
 .vscode/*

wai-server/models/init-models.js

@@ -1,14 +1,20 @@
 var DataTypes = require('sequelize').DataTypes;
 var _connections = require('./connections');
+var _outbound_messages = require("./outbound_messages");
 var _request_logs = require('./request_logs');
+var _webhook_logs = require('./webhook_logs');
 
 function initModels(sequelize) {
   var connections = _connections(sequelize, DataTypes);
+  var outbound_messages = _outbound_messages(sequelize, DataTypes);
   var request_logs = _request_logs(sequelize, DataTypes);
+  var webhook_logs = _webhook_logs(sequelize, DataTypes);
 
   return {
     connections,
+    outbound_messages,
     request_logs,
+    webhook_logs,
   };
 }
 module.exports = initModels;

wai-server/models/outbound_messages.js

@@ -0,0 +1,137 @@
+const Sequelize = require('sequelize');
+module.exports = function(sequelize, DataTypes) {
+  return sequelize.define(
+    'outbound_messages',
+    {
+      sn: {
+        autoIncrement: true,
+        type: DataTypes.BIGINT,
+        allowNull: false,
+        primaryKey: true,
+      },
+      direction: {
+        type: DataTypes.STRING(50),
+        allowNull: true,
+      },
+      evt_id: {
+        type: DataTypes.STRING(100),
+        allowNull: true,
+      },
+      actionId: {
+        type: DataTypes.STRING(100),
+        allowNull: true,
+      },
+      opi_sn: {
+        type: DataTypes.INTEGER,
+        allowNull: true,
+      },
+      coli_sn: {
+        type: DataTypes.INTEGER,
+        allowNull: true,
+      },
+      msgtime: {
+        type: DataTypes.DATE,
+        allowNull: true,
+      },
+      id: {
+        type: DataTypes.STRING(100),
+        allowNull: true,
+      },
+      wamid: {
+        type: DataTypes.STRING(200),
+        allowNull: true,
+      },
+      froms: {
+        type: DataTypes.STRING(100),
+        allowNull: true,
+      },
+      tos: {
+        type: DataTypes.STRING(100),
+        allowNull: true,
+      },
+      customerProfile_name: {
+        type: DataTypes.TEXT,
+        allowNull: true,
+      },
+      msgtype: {
+        type: DataTypes.STRING(50),
+        allowNull: true,
+      },
+      externalId: {
+        type: DataTypes.STRING(100),
+        allowNull: true,
+      },
+      msg_status: {
+        type: DataTypes.STRING(50),
+        allowNull: true,
+        comment: '消息状态 read、send等',
+      },
+      errors_code: {
+        type: DataTypes.STRING(50),
+        allowNull: true,
+      },
+      errors_title: {
+        type: DataTypes.TEXT,
+        allowNull: true,
+      },
+      createTime: {
+        type: DataTypes.DATE,
+        allowNull: true,
+        defaultValue: Sequelize.Sequelize.literal('CURRENT_TIMESTAMP'),
+      },
+      updateTime: {
+        type: DataTypes.DATE,
+        allowNull: true,
+      },
+      sendTime: {
+        type: DataTypes.DATE,
+        allowNull: true,
+      },
+      deliverTime: {
+        type: DataTypes.DATE,
+        allowNull: true,
+      },
+      readTime: {
+        type: DataTypes.DATE,
+        allowNull: true,
+      },
+      regionCode: {
+        type: DataTypes.STRING(50),
+        allowNull: true,
+      },
+      text_body: {
+        type: DataTypes.TEXT,
+        allowNull: true,
+      },
+      text_preview_url: {
+        type: DataTypes.TEXT,
+        allowNull: true,
+      },
+      context_from: {
+        type: DataTypes.STRING(50),
+        allowNull: true,
+      },
+      context_id: {
+        type: DataTypes.STRING(200),
+        allowNull: true,
+      },
+      message_origin: {
+        type: DataTypes.TEXT,
+        allowNull: true,
+      },
+    },
+    {
+      sequelize,
+      tableName: 'outbound_messages',
+      timestamps: false,
+      indexes: [
+        {
+          name: 'PRIMARY',
+          unique: true,
+          using: 'BTREE',
+          fields: [{ name: 'sn' }],
+        },
+      ],
+    },
+  );
+};

wai-server/models/request_logs.js

@@ -1,54 +1,56 @@
 const Sequelize = require('sequelize');
 module.exports = function(sequelize, DataTypes) {
-  return sequelize.define('request_logs', {
+  return sequelize.define(
-    sn: {
+    'request_logs',
-      autoIncrement: true,
+    {
-      type: DataTypes.BIGINT,
+      sn: {
-      allowNull: false,
+        autoIncrement: true,
-      primaryKey: true
+        type: DataTypes.BIGINT,
-    },
+        allowNull: false,
-    action: {
+        primaryKey: true,
-      type: DataTypes.STRING(100),
+      },
-      allowNull: true
+      action: {
-    },
+        type: DataTypes.STRING(100),
-    method: {
+        allowNull: true,
-      type: DataTypes.STRING(15),
+      },
-      allowNull: true
+      method: {
-    },
+        type: DataTypes.STRING(15),
-    path: {
+        allowNull: true,
-      type: DataTypes.STRING(1000),
+      },
-      allowNull: true
+      path: {
-    },
+        type: DataTypes.STRING(1000),
-    request_data: {
+        allowNull: true,
-      type: DataTypes.TEXT,
+      },
-      allowNull: true
+      request_data: {
-    },
+        type: DataTypes.TEXT,
-    snapshots: {
+        allowNull: true,
-      type: DataTypes.TEXT,
+      },
-      allowNull: true
+      snapshots: {
+        type: DataTypes.TEXT,
+        allowNull: true,
+      },
+      ip: {
+        type: DataTypes.STRING(200),
+        allowNull: true,
+      },
+      createtime: {
+        type: DataTypes.DATE,
+        allowNull: false,
+        defaultValue: Sequelize.Sequelize.literal('CURRENT_TIMESTAMP'),
+      },
     },
-    ip: {
+    {
-      type: DataTypes.STRING(200),
+      sequelize,
-      allowNull: true
+      tableName: 'request_logs',
+      timestamps: false,
+      indexes: [
+        {
+          name: 'PRIMARY',
+          unique: true,
+          using: 'BTREE',
+          fields: [{ name: 'sn' }],
+        },
+      ],
     },
-    createtime: {
+  );
-      type: DataTypes.DATE,
-      allowNull: false,
-      defaultValue: Sequelize.Sequelize.literal('CURRENT_TIMESTAMP')
-    }
-  }, {
-    sequelize,
-    tableName: 'request_logs',
-    timestamps: false,
-    indexes: [
-      {
-        name: "PRIMARY",
-        unique: true,
-        using: "BTREE",
-        fields: [
-          { name: "sn" },
-        ]
-      },
-    ]
-  });
 };

wai-server/models/webhook_logs.js

@@ -0,0 +1,48 @@
+const Sequelize = require('sequelize');
+module.exports = function(sequelize, DataTypes) {
+  return sequelize.define(
+    'webhook_logs',
+    {
+      id: {
+        autoIncrement: true,
+        type: DataTypes.BIGINT,
+        allowNull: false,
+        primaryKey: true,
+      },
+      event: {
+        type: DataTypes.STRING(100),
+        allowNull: false,
+      },
+      event_id: {
+        type: DataTypes.STRING(100),
+        allowNull: true,
+      },
+      data_id: {
+        type: DataTypes.STRING(100),
+        allowNull: true,
+      },
+      createtime: {
+        type: DataTypes.DATE,
+        allowNull: true,
+        defaultValue: Sequelize.Sequelize.literal('CURRENT_TIMESTAMP'),
+      },
+      updatetime: {
+        type: DataTypes.DATE,
+        allowNull: true,
+      },
+    },
+    {
+      sequelize,
+      tableName: 'webhook_logs',
+      timestamps: false,
+      indexes: [
+        {
+          name: 'PRIMARY',
+          unique: true,
+          using: 'BTREE',
+          fields: [{ name: 'id' }],
+        },
+      ],
+    },
+  );
+};