fix db sd_raw type error

src/controllers/file/sd_raw_neulive.js

@@ -0,0 +1,25 @@
+import SDRawNeulive from '../../models/file/sd_raw_neulive'
+import * as auth from '../auth'
+
+const sd_raw_Neulive = new SDRawNeulive()
+
+export const create = async (ctx, next) => {
+  const data = ctx.request.body
+  const result = await sd_raw_Neulive.create(data)
+  ctx.body = result
+  next()
+}
+
+export const getByParentUUID = async (ctx, next) => {
+  const parent_uuid = ctx.params.parent_uuid
+  const result = await sd_raw_Neulive.getByParentUUID(parent_uuid)
+  ctx.body = result
+  next()
+}
+
+export const deleteByParentUUID = async (ctx, next) => {
+  const parent_uuid = ctx.params.parent_uuid
+  const result = await sd_raw_Neulive.deleteByParentUUID(parent_uuid)
+  ctx.body = result
+  next()
+}

src/db/database.js

@@ -41,6 +41,8 @@ for (let i = 256; i < 288; i++) {
   db[i + '_recording_data_minis'] = require('./schema/recording_data_mini.model')(sequelize, Sequelize, i)
 }
 
+db.sd_raw_neulive = require('./schema/sd_raw_neulive.model')(sequelize, Sequelize)
+
 db.sequelize.sync()
 
 sequelizeStream(db.sequelize, 1000)

src/db/schema/sd_raw_neulive.model.js

@@ -0,0 +1,37 @@
+module.exports = (sequelize, Sequelize, i) => {
+  const RecordingDataRaw = sequelize.define('bps_sd_raw_neulive', {
+    channel: {
+      type: Sequelize.INTEGER
+    },
+    parent_uuid: {
+      type: Sequelize.STRING,
+    },
+    data: {
+      type: Sequelize.TEXT,
+      defaultValue: ''
+    },
+    start_time_sec: {
+      type: Sequelize.INTEGER,
+      defaultValue: 0
+    },
+    end_time_sec: {
+      type: Sequelize.INTEGER,
+      defaultValue: 0
+    },
+    start_time_micro: {
+      type: Sequelize.INTEGER,
+      defaultValue: 0
+    },
+    end_time_micro: {
+      type: Sequelize.INTEGER,
+      defaultValue: 0
+    }
+  },
+  {
+    freezeTableName: true,
+    timestamps: false
+  }
+  )
+
+  return RecordingDataRaw
+}

src/models/file/sd_raw_neulive.js

@@ -0,0 +1,42 @@
+const db = require('../../db/database')
+
+class SDRawNeulive {
+  async create (req) {
+    return db['sd_raw_neulive'].create(
+      req
+    )
+  }
+
+  async getByParentUUID (parent_uuid) {
+    const ret = await db['sd_raw_neulive'].findAllWithStream(
+      {
+        batchSize: 1000,
+        where: {
+          parent_uuid: parent_uuid
+        },
+        order: [
+          ['id', 'ASC']
+        ],
+        attributes: [
+          'data',
+          'start_time',
+          'end_time'
+        ]
+      }
+    )
+    return ret
+  }
+
+  async deleteByParentUUID (parent_uuid) {
+    const ret = await db['sd_raw_neulive'].destroy(
+      {
+        where: {
+          parent_uuid: parent_uuid
+        }
+      }
+    )
+    return ret
+  }
+}
+
+export default SDRawNeulive