'use strict'; const Controller = require('../core/base_controller'); const fs = require('fs'); const fileName = "BdCard"; class BdCardController extends Controller { // 注册北斗卡 async addBdCard() { const { ctx } = this; try { let rdmcode = await this.checkUid(ctx); if (!rdmcode) { this.setResponse(ctx, 401, 'token过期或错误', "none"); return; } const requestMsg = ctx.request.body.requestMsg; requestMsg.forEach(element => { element.card_id = this.decryptRequest(element.card_id); element.card_imsi = this.decryptRequest(element.card_imsi); element.type = 0; element.status = 0; element.created_at = new Date(); element.updated_at = new Date(); }); const result = await ctx.service.bdCard.addBdCard(requestMsg); if (result == "error") { this.setResponse(ctx, 500, '服务器错误', "none"); return; } if (result) { this.setResponse(ctx, 200, '导入北斗卡成功', "none"); } else { this.setResponse(ctx, 404, '导入北斗卡失败', "none"); } } catch (error) { const blockName = fileName + "--" + "addBdCard"; ctx.app.middleware.log('../../controllerLog', blockName + ">>>>" + error); this.setResponse(ctx, 500, '服务器错误', "none"); } } // 查看北斗卡 async showBdCard() { const { ctx } = this; try { let rdmcode = await this.checkUid(ctx); if (!rdmcode) { this.setResponse(ctx, 401, 'token过期或错误', "none"); return; } const body = ctx.request.body; const result = await ctx.service.bdCard.showBdCard(body); if (result == "error") { this.setResponse(ctx, 500, '服务器错误', "none"); return; } if (result) { let bdCardMsg = []; result.rows.forEach(element => { bdCardMsg.push(element.dataValues); }); const data = { bdCardMsg: bdCardMsg, count: result.count }; this.setResponse(ctx, 200, '搜索北斗卡成功', "deconstruction", data); } else { this.setResponse(ctx, 404, '搜索北斗卡失败', "none"); } } catch (error) { const blockName = fileName + "--" + "showBdCard"; ctx.app.middleware.log('../../controllerLog', blockName + ">>>>" + error); this.setResponse(ctx, 500, '服务器错误', "none"); } } // 编辑北斗卡 async editBdCard() { const { ctx } = this; try { let rdmcode = await this.checkUid(ctx); if (!rdmcode) { this.setResponse(ctx, 401, 'token过期或错误', "none"); return; } const uid = JSON.parse(rdmcode).uid; const body = ctx.request.body; const { model, password, updateMsg, requestMsg } = body const modelType = this.decryptRequest(model); const deCodePassword = this.decryptRequest(password); const result = await ctx.service.bdCard.editBdCard(uid, modelType, deCodePassword, updateMsg, requestMsg); if (result == "error") { this.setResponse(ctx, 500, '服务器错误', "none"); return; } if (result) { this.setResponse(ctx, 200, '编辑北斗卡成功', "none"); } else { this.setResponse(ctx, 404, '编辑北斗卡失败', "none"); } } catch (error) { const blockName = fileName + "--" + "editBdCard"; ctx.app.middleware.log('../../controllerLog', blockName + ">>>>" + error); this.setResponse(ctx, 500, '服务器错误', "none"); } } // 删除北斗卡 async deleteBdCard() { const { ctx } = this; try { let rdmcode = await this.checkUid(ctx); if (!rdmcode) { this.setResponse(ctx, 401, 'token过期或错误', "none"); return; } const uid = JSON.parse(rdmcode).uid; const body = ctx.request.body; const { model, password, requestMsg } = body const modelType = this.decryptRequest(model); const deCodePassword = this.decryptRequest(password); const result = await ctx.service.bdCard.deleteBdCard(uid, modelType, deCodePassword, requestMsg); if (result == "error") { this.setResponse(ctx, 500, '服务器错误', "none"); return; } if (result) { this.setResponse(ctx, 200, '删除北斗卡成功', "none"); } else { this.setResponse(ctx, 404, '删除北斗卡失败', "none"); } } catch (error) { const blockName = fileName + "--" + "deleteBdCard"; ctx.app.middleware.log('../../controllerLog', blockName + ">>>>" + error); this.setResponse(ctx, 500, '服务器错误', "none"); } } // 管理系统导出北斗卡 async downloadBDCard() { const { ctx } = this; try { let rdmcode = await this.checkUid(ctx); if (!rdmcode) { this.setResponse(ctx, 401, 'token过期或错误', "none"); return; } const uid = JSON.parse(rdmcode).uid; const { form, searchMsg, dataHeaders } = ctx.request.body; const result = await ctx.service.bdCard.downloadBDCard(uid, searchMsg); if (result == "error") { this.setResponse(ctx, 500, '服务器错误', "none"); return; } if (result.code) { const file = this.downloadData(form, result.data, dataHeaders); if (file) { const { filePath, completeName, buf } = file; try { fs.writeFileSync(filePath, Buffer.from(buf)); const data = { // 本机服务器地址 // 'http://127.0.0.1:8012' // 'http://192.168.31.28:8012' // 公司服务器地址 // 'http://123.57.205.46:8012' // 'http://manager.bdrd.hwasmart.com//accountManager' fileUrl: 'http://127.0.0.1:8012' + `/public/${completeName}?time=${new Date().getTime()}`, fileName: completeName, } this.setResponse(ctx, 200, '文件已成功写入', "deconstruction", data); setTimeout(() => { fs.unlinkSync(filePath); }, 600000); } catch (error) { this.setResponse(ctx, 500, '写入文件时发生错误', "none"); } } else { this.setResponse(ctx, 404, '操作失败', "none"); } } else { this.setResponse(ctx, 404, '操作失败', "none"); } } catch (error) { const blockName = fileName + "--" + "downloadBDCard"; ctx.app.middleware.log('../../controllerLog', blockName + ">>>>" + error); this.setResponse(ctx, 500, '服务器错误', "none"); } } } module.exports = BdCardController;