问题反馈接口oK

Author: xianengqi

db/feedback.js

@@ -0,0 +1,29 @@
+// 引入 models
+const models = require('../models');
+const code = require('../lib/code');
+const Sequelize = require('sequelize');
+const Op = Sequelize.Op;
+
+submitAction = async (parms) => {
+  try{
+    const data = await models.feedbacks.create({
+      'user_id': parms.openId,
+      "user_name": parms.name,
+      "msg_content": parms.content,
+      "connect": parms.phone,
+      "msg_time": new Date().getTime() / 100
+    });
+    console.log(data);
+    return {
+      results:  'success',
+      dataBaseError: false
+    };
+  }
+  catch(e) {
+    return { results: e, dataBaseError: true}
+  }
+}
+
+module.exports = {
+  submitAction
+}

migrations/20181222094828-create-nideshop_feedback-table.js

@@ -1,8 +1,7 @@
-'use strict';
 
 module.exports = {
   up: (queryInterface, Sequelize) => queryInterface.createTable(
-    'nideshop_feedback',
+    'nideshop_feedbacks',
     {
       id: {
         type: Sequelize.INTEGER,
@@ -30,17 +29,11 @@ module.exports = {
         type: Sequelize.STRING,
         allowNull: false,
         defaultValue: false,
-      }
+      },
+       created_at: Sequelize.DATE,
+         updated_at: Sequelize.DATE,
     }
   ),
 
-  down: (queryInterface, Sequelize) => {
-    /*
-      Add reverting commands here.
-      Return a promise to correctly handle asynchronicity.
-
-      Example:
-      return queryInterface.dropTable('users');
-    */
-  }
+  down: queryInterface => queryInterface.dropTable(nideshop_feedbacks),
 };

migrations/20181228070217-feedback.js

@@ -0,0 +1,37 @@
+module.exports = {
+  up: (queryInterface, Sequelize) => queryInterface.createTable(
+    'feedbacks', {
+      id: {
+        type: Sequelize.INTEGER,
+        autoIncrement: true,
+        primaryKey: true,
+      },
+      user_id: {
+        type: Sequelize.STRING,
+        allowNull: false,
+        defaultValue: false,
+      },
+      user_name: {
+        type: Sequelize.STRING,
+        allowNull: false,
+      },
+      connect: {
+        type: Sequelize.STRING,
+        allowNull: false,
+      },
+      msg_content: {
+        type: Sequelize.TEXT,
+        allowNull: false,
+      },
+      msg_time: {
+        type: Sequelize.STRING,
+        allowNull: false,
+        defaultValue: false,
+      },
+      created_at: Sequelize.DATE,
+      updated_at: Sequelize.DATE,
+    }
+  ),
+
+  down: queryInterface => queryInterface.dropTable(feedbacks),
+};

models/feedbacks.js

@@ -0,0 +1,33 @@
+module.exports = (sequelize, DataTypes) => sequelize.define(
+  'feedbacks', {
+    id: {
+      type: DataTypes.INTEGER,
+      autoIncrement: true,
+      primaryKey: true,
+    },
+    user_id: {
+      type: DataTypes.STRING,
+      allowNull: false,
+      defaultValue: false,
+    },
+    user_name: {
+      type: DataTypes.STRING,
+      allowNull: false,
+    },
+    connect: {
+      type: DataTypes.STRING,
+      allowNull: false,
+    },
+    msg_content: {
+      type: DataTypes.TEXT,
+      allowNull: false,
+    },
+    msg_time: {
+      type: DataTypes.STRING,
+      allowNull: false,
+      defaultValue: false,
+    },
+  }, {
+    tableName: 'feedbacks'
+  }
+)

models/nideshop_feedback.js

@@ -1,5 +1,5 @@
 module.exports = (sequelize, DataTypes) => sequelize.define(
-  'nideshop_feedback',
+  'feedbacks',
   {
     id: {
       type: DataTypes.INTEGER,
@@ -30,6 +30,6 @@ module.exports = (sequelize, DataTypes) => sequelize.define(
     },
   },
   {
-    tableName: 'nideshop_feedback'
+    tableName: 'feedbacks'
   }
 )

routes/feedback.js

@@ -1,15 +1,31 @@
+const controllers = require('../db/index');
+const middleware = require('../middleware');
+const Joi = require('joi');
+const { paginationDefine } = require('../lib/router-helper');
 const GROUP_NAME = 'feedback';
 
 module.exports = [
   {
     method: 'POST',
-    path: `/${GROUP_NAME}/{data}/submitAction`,
+    path: `/${GROUP_NAME}/submitAction`,
     handler: async (request, reply) => {
-      reply();
+      let parms = request.payload;
+      let res = await controllers.feedback.submitAction(parms);
+      middleware.dbErrorMiddleware(request, res, reply);
     },
     config: {
       tags: ['api', GROUP_NAME],
-      description: '意见反馈'
+      description: '意见反馈',
+      validate: {
+        // ...jwtHeaderDefine,
+        payload: Joi.object().keys({
+          // addressId: Joi.number().required(),
+          openId: Joi.string(),
+          name: Joi.string(),
+          content: Joi.string(),
+          phone: Joi.string(),
+        })
+      },
     },
   },
 ];

seeders/20181222095147-init-nideshop_feedback.js

@@ -5,7 +5,7 @@ const timestamps = {
 
 module.exports = {
   up: queryInterface => queryInterface.bulkInsert(
-    'nideshop_feedback',
+    'feedbacks',
     [
       {
         "id": "1",
@@ -36,7 +36,7 @@ module.exports = {
     const {
       Op
     } = Sequelize;
-    return queryInterface.bulkDelete('nideshop_feedback', {
+    return queryInterface.bulkDelete('feedbacks', {
       id: {
         [Op.in]: [1, 2, 3]
       }