feat: 将相关操作接口提取出来

Author: klren0312

src/renderer/service/data.service.js

@@ -0,0 +1,24 @@
+import { dataDb } from '@/dataStore'
+const collection = dataDb.defaults({ data: [] }).get('data')
+
+/**
+ * 清空缓存数据
+ */
+export function clearData () {
+  return dataDb.set('data', []).write()
+}
+
+/**
+ * 获取数据
+ */
+export function getDatas () {
+  return dataDb.get('data').value()
+}
+
+/**
+ * 添加数据
+ * @param {Object} data 数据
+ */
+export function addData (data) {
+  return collection.insert({ ...data }).write()
+}

src/renderer/service/global.service.js

@@ -0,0 +1,69 @@
+import { globalDb } from '@/dataStore'
+import store from '@/store'
+const appCollection = globalDb.get('apps')
+
+/**
+ * 获取应用列表
+ */
+export function getApps () {
+  return JSON.parse(JSON.stringify(globalDb.get('apps').value()))
+}
+
+/**
+ * 通过id获取应用
+ * @param {String} id 应用id
+ */
+export function getAppById (id) {
+  return appCollection.find({ id: id }).value()
+}
+
+/**
+ * 通过id修改应用
+ * @param {String} id 应用id
+ * @param {Object} app 应用配置
+ */
+export function editAppById (id, app) {
+  return appCollection.find({ id: id }).assign({ ...app }).write()
+}
+
+/**
+ * 新增应用
+ * @param {Object} app 应用配置
+ */
+export function addApp (app) {
+  return appCollection.insert({...app}).write()
+}
+
+/**
+ * 上传应用
+ * @param {Object} app 应用配置
+ */
+export function uploadApp (app) {
+  return fetch(`${store.state.ServerUrl}/apps`, {
+    method: 'post',
+    headers: {
+      'Content-Type': 'application/json'
+    },
+    body: JSON.stringify({
+      appName: app.appName,
+      ruleConfig: app.ruleConfig,
+      localId: app.id,
+      type: app.type
+    })
+  }).then(res => res.json())
+}
+
+/**
+ * 拉取远程应用
+ */
+export function getRemoteApp () {
+  return fetch(`${store.state.ServerUrl}/apps`).then(res => res.json())
+}
+
+/**
+ * 删除应用
+ * @param {String} id 应用id
+ */
+export function deleteApp (id) {
+  return appCollection.remove({ id: id }).write()
+}

src/renderer/service/rule.service.js

@@ -0,0 +1,74 @@
+import { ruleDb } from '@/dataStore'
+
+/**
+ * 清除规则
+ */
+export function clearRule () {
+  ruleDb.set('config', {}).write()
+  ruleDb.set('contentUrls', {}).write()
+  ruleDb.set('publishConfig', []).write()
+}
+
+/**
+ * 获取规则
+ * @param {Object} obj 规则
+ */
+export function addRule (obj) {
+  ruleDb.set('config', obj.config).write()
+  ruleDb.set('contentUrls', obj.contentUrls).write()
+  ruleDb.set('publishConfig', obj.publishConfig).write()
+}
+
+/**
+ * 获取config
+ */
+export function getConfig () {
+  return ruleDb.get('config').value()
+}
+
+/**
+ * 获取内容页链接
+ */
+export function getContentUrls () {
+  return ruleDb.get('contentUrls').value()
+}
+
+/**
+ * 存储内容页链接
+ */
+export function setContentUrls (urls) {
+  return ruleDb.set('contentUrls', urls).write()
+}
+
+const publishCollection = ruleDb.get('publishConfig')
+/**
+ * 获取发布配置
+ */
+export function getPublishConfig () {
+  return ruleDb.get('publishConfig').value()
+}
+
+/**
+ * 添加发布配置
+ * @param {Object} obj 发布配置
+ */
+export function addPublish (obj) {
+  return publishCollection.insert({ ...obj }).write()
+}
+
+/**
+ * 修改指定发布配置
+ * @param {String} id 发布id
+ * @param {Object} obj 发布配置
+ */
+export function editPublishById (id, obj) {
+  return publishCollection.find({id: id}).assign({...obj}).write()
+}
+
+/**
+ * 删除指定发布配置
+ * @param {String} id 发布id
+ */
+export function deletePublish (id) {
+  return publishCollection.remove({ id: id }).write()
+}

src/renderer/views/homePage/index.vue

@@ -35,8 +35,9 @@
   </div>
 </template>
 <script>
-import { globalDb, ruleDb, dataDb } from '@/dataStore'
-const appCollection = globalDb.get('apps')
+import { getApps, getAppById, editAppById, addApp, uploadApp, getRemoteApp, deleteApp } from '@/service/global.service'
+import { clearRule, addRule } from '@/service/rule.service'
+import { clearData } from '@/service/data.service'
 const { remote } = require('electron')
 const fs = require('fs')
 
@@ -53,35 +54,22 @@ export default {
   },
   methods: {
     getAppList () {
-      this.appList = JSON.parse(JSON.stringify(globalDb.get('apps').value()))
+      this.appList = getApps()
     },
     handleCtrl ($event, app) {
       if ($event === 'delete') {
         this.deleteApp(app.id)
       } else if ($event === 'upload') {
-        fetch(`${this.$store.state.ServerUrl}/apps`, {
-          method: 'post',
-          headers: {
-            'Content-Type': 'application/json'
-          },
-          body: JSON.stringify({
-            appName: app.appName,
-            ruleConfig: app.ruleConfig,
-            localId: app.id,
-            type: app.type
+        uploadApp(app).then(res => {
+          remote.dialog.showMessageBox({
+            type: 'info',
+            title: '上传结果',
+            message: res.message,
+            buttons: ['ok']
           })
         })
-          .then(res => res.json())
-          .then(res => {
-            remote.dialog.showMessageBox({
-              type: 'info',
-              title: '上传结果',
-              message: res.message,
-              buttons: ['ok']
-            })
-          })
       } else if ($event === 'export') {
-        const details = globalDb.get('apps').find({ id: app.id }).value()
+        const details = getAppById(app.id)
         const path = remote.dialog.showSaveDialog({
           title: '选择保存路径',
           filters: [{
@@ -113,10 +101,8 @@ export default {
      * 新建触发
      */
     handleCreate (command) {
-      ruleDb.set('config', {}).write()
-      ruleDb.set('contentUrls', {}).write()
-      ruleDb.set('publishConfig', []).write()
-      dataDb.set('data', []).write()
+      clearRule()
+      clearData()
       if (command === 'rule') {
         this.$router.push('/ruleSetting')
       } else {
@@ -135,25 +121,18 @@ export default {
         buttons: ['ok', 'no']
       }, index => {
         if (index === 0) {
-          fetch(`${this.$store.state.ServerUrl}/apps`)
-            .then(res => res.json())
+          getRemoteApp()
             .then(res => {
               res.data.forEach(v => {
-                const localApp = appCollection
-                  .find({ id: v.localId })
-                  .value()
-                console.log(localApp)
+                const localApp = getAppById(v.localId)
                 if (localApp) {
                   const remoteApp = JSON.parse(JSON.stringify(v))
                   remoteApp.id = remoteApp.localId
-                  appCollection
-                    .find({ id: v.localId })
-                    .assign({...remoteApp})
-                    .write()
+                  editAppById(v.localId, remoteApp)
                 } else {
                   const remoteApp = JSON.parse(JSON.stringify(v))
                   remoteApp.id = remoteApp.localId
-                  appCollection.insert({...remoteApp}).write()
+                  addApp(remoteApp)
                   this.getAppList()
                 }
               })
@@ -179,13 +158,11 @@ export default {
         fs.readFile(filePath[0], 'utf8', (e, res) => {
           if (e) throw e
           const data = JSON.parse(res)
-          appCollection
-            .insert({
-              appName: filePath[0].match(/([^\.\/\\]+)\.([a-z]+)$/i)[1],
-              ruleConfig: data.ruleConfig,
-              type: data.type
-            })
-            .write()
+          addApp({
+            appName: filePath[0].match(/([^\.\/\\]+)\.([a-z]+)$/i)[1],
+            ruleConfig: data.ruleConfig,
+            type: data.type
+          })
           this.getAppList()
         })
         /* eslint-enable */
@@ -199,23 +176,19 @@ export default {
         buttons: ['ok', 'no']
       }, index => {
         if (index === 0) {
-          appCollection
-            .remove({ id: id })
-            .write()
+          deleteApp(id)
           this.getAppList()
         } else {
         }
       })
     },
     toDetails (data) {
       if (data.type === 'rule') {
-        const details = globalDb.get('apps').find({ id: data.id }).value()
+        const details = getAppById(data.id)
         if (details) {
           const obj = JSON.parse(details.ruleConfig)
-          ruleDb.set('config', obj.config).write()
-          ruleDb.set('contentUrls', obj.contentUrls).write()
-          ruleDb.set('publishConfig', obj.publishConfig).write()
-          dataDb.set('data', []).write()
+          addRule(obj)
+          clearData()
           this.$nextTick(_ => {
             this.$router.push(`/ruleSetting?id=${details.id}&appName=${details.appName}`)
           })