'use strict'; /** * 账号相关控制器 * * @author CaiAoLin * @date 2018/1/26 * @version */ const moment = require('moment'); const profileMenu = require('../../config/menu').profileMenu; const smsTypeConst = require('../const/sms_type'); const qr = require('qr-image'); const path = require('path'); const sendToWormhole = require('stream-wormhole'); const loginWay = require('../const/setting').loginWay; const wxWork = require('../lib/wx_work'); const profileConst = require('../const/profile'); const DSK = require('../lib/dsk'); module.exports = app => { class ProfileController extends app.BaseController { /** * 构造函数 * * @param {Object} ctx - egg全局context * @return {void} */ constructor(ctx) { super(ctx); ctx.subMenu = profileMenu; } /** * 账号资料页面 * * @param {Object} ctx - egg全局变量 * @return {void} */ async info(ctx) { // 获取当前用户数据 const sessionUser = ctx.session.sessionUser; // 获取账号数据 const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId }); // 获取基础数据的字段规则 const baseRule = ctx.service.projectAccount.rule('profileBase'); const baseJsValidator = await this.jsValidator.convert(baseRule).setSelector('#base-form').build(); const renderData = { accountData, baseJsValidator, }; await this.layout('profile/info.ejs', renderData); } /** * 保存基本信息 * * @param {Object} ctx - egg全局变量 * @return {void} */ async saveBase(ctx) { try { // 获取当前用户数据 const sessionUser = ctx.session.sessionUser; // 获取基础数据的字段规则 const baseRule = ctx.service.projectAccount.rule('profileBase'); ctx.helper.validate(baseRule); const result = await ctx.service.projectAccount.saveInfo(ctx.request.body, sessionUser.accountId); if (!result) { throw '保存信息失败'; } this.setMessage('修改成功', this.messageType.SUCCESS); } catch (error) { this.log(error); this.setMessage(error.toString(), this.messageType.ERROR); } ctx.redirect(ctx.request.header.referer); } /** * 账号资料页面 * * @param {Object} ctx - egg全局变量 * @return {void} */ async cert(ctx) { // 获取当前用户数据 const sessionUser = ctx.session.sessionUser; // 获取账号数据 const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId }); const certList = await ctx.service.accountCert.getAllDataByCondition({ where: { uid: sessionUser.accountId }, orders: [['create_time', 'desc']] }); // json转换 certList.forEach(item => { item.edu_json = item.edu_json ? JSON.parse(item.edu_json) : []; }); const renderData = { accountData, certList, fujianOssPath: ctx.app.config.fujianOssPath, certTypeConst: profileConst.cert.certType, certSourceConst: { cert_reg: ctx.helper._.orderBy(profileConst.cert.certReg, ['sort'], ['asc']), cert_qual: ctx.helper._.orderBy(profileConst.cert.certQual, ['sort'], ['asc']), }, jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.profile.cert), }; await this.layout('profile/cert.ejs', renderData, 'profile/cert_modal.ejs'); } async certSave(ctx) { const response = { err: 0, msg: '', data: {}, }; try { const sessionUser = ctx.session.sessionUser; const data = JSON.parse(ctx.request.body.data); switch (data.type) { case 'add_cert': response.data = await ctx.service.accountCert.addCert(sessionUser.accountId); break; case 'update_cert': response.data = await ctx.service.accountCert.updateCert(data.update_data); break; case 'add_jx': response.data = await ctx.service.accountCert.addEduJson(data.id); break; case 'update_jx': response.data = await ctx.service.accountCert.updateEduJson(data.update_data); break; case 'del_cert': // 包括删除附件 response.data = await ctx.service.accountCert.delCert(data.delete_data); break; default:throw '参数有误'; } } catch (error) { response.err = 1; response.msg = error.toString(); } ctx.body = response; } /** * 上传证书（单选） * * @param {object} ctx - egg全局变量 * @return {void} */ async certUpload(ctx) { const responseData = { err: 0, msg: '', data: null, }; try { const stream = await ctx.getFileStream(); const create_time = Date.parse(new Date()) / 1000; const fileInfo = path.parse(stream.filename); const id = stream.fields && stream.fields.id ? stream.fields.id : 0; if (!id) throw '参数有误'; let jxid = ''; let type = ''; if (stream.fields && stream.fields.type === 'upload_jx') { jxid = stream.fields.jxid ? stream.fields.jxid : ''; if (!jxid) throw '参数有误'; type = 'jx'; } else if (stream.fields && stream.fields.type === 'upload_cert') { type = 'cert'; } if (!type) throw '参数有误'; // 判断用户是否选择上传文件 if (!stream.filename) { throw '请选择上传的文件!'; } const filename = stream.filename; const filepath = `app/public/upload/profile/${ctx.session.sessionUser.accountId}/cert/zhengshu_${create_time + fileInfo.ext}`; // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, filepath)); await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream); await sendToWormhole(stream); if (type === 'jx') { const info = await ctx.service.accountCert.getDataById(id); if (!info) throw '数据有误'; const edu_json = info.edu_json ? JSON.parse(info.edu_json) : []; const jxInfo = edu_json.find(item => item.id === jxid); if (!jxInfo) throw '数据有误'; jxInfo.file_path = filepath; jxInfo.file_name = filename; await ctx.service.accountCert.update({ edu_json: JSON.stringify(edu_json) }, { id }); } else { await ctx.service.accountCert.update({ file_path: filepath, file_name: filename }, { id }); } responseData.data = { file_path: filepath, file_name: filename }; } catch (err) { console.log(err); responseData.err = 1; responseData.msg = err; } ctx.body = responseData; } /** * 修改密码操作 * * @param {Object} ctx - egg全局变量 * @return {void} */ async modifyPassword(ctx) { const password = ctx.request.body.password; const newPassword = ctx.request.body.new_password; try { const sessionUser = ctx.session.sessionUser; let accountId = sessionUser.accountId; accountId = parseInt(accountId); if (isNaN(accountId) || accountId <= 0) { throw '参数错误'; } // 验证数据 const passwordRule = ctx.service.projectAccount.rule('modifyPassword'); ctx.helper.validate(passwordRule); // 判断新密码的强度 const reg = /^(?![0-9]+$)(?![a-zA-Z]+$).{6,16}$/; if (!reg.test(newPassword)) { throw '请设置至少包含数字和字母的新密码'; } const result = await ctx.service.projectAccount.modifyPassword(accountId, password, newPassword); if (!result) { throw '修改密码失败'; } this.setMessage('修改密码成功', this.messageType.SUCCESS); ctx.redirect('/logout'); } catch (error) { ctx.session.postError = error.toString(); this.setMessage(error.toString(), this.messageType.ERROR); ctx.redirect(ctx.request.header.referer); } } /** * 设置短信验证码 * * @param {object} ctx - egg全局变量 * @return {void} */ async getCode(ctx) { const response = { err: 0, msg: '', }; try { const sessionUser = ctx.session.sessionUser; const mobile = ctx.request.body.mobile; let type = null; if (ctx.request.body.type) { type = ctx.request.body.type; delete ctx.request.body.type; } const rule = { mobile: { type: 'mobile', allowEmpty: false } }; ctx.helper.validate(rule); if (type === null || type !== 'shenpi') { // 查找是否有重复的认证手机 const accountData = await ctx.service.projectAccount.getDataByCondition({ project_id: ctx.session.sessionProject.id, auth_mobile: mobile }); if (accountData !== null) { throw '此手机号码已被使用，请重新输入！'; } } const result = await ctx.service.projectAccount.setSMSCode(sessionUser.accountId, mobile); if (!result) { throw '获取验证码失败'; } } catch (error) { response.err = 1; response.msg = error.toString(); } ctx.body = response; } /** * 绑定认证手机 * * @param {object} ctx - egg全局变量 * @return {void} */ async bindMobile(ctx) { const response = { err: 0, msg: '', }; try { const rule = ctx.service.projectAccount.rule('bindMobile'); ctx.helper.validate(rule); const sessionUser = ctx.session.sessionUser; const result = await ctx.service.projectAccount.bindMobile(sessionUser.accountId, ctx.request.body, ctx.session.sessionProject.id); if (!result) { throw '绑定手机失败!'; } // this.setMessage('绑定成功', this.messageType.SUCCESS); response.msg = '绑定成功'; response.url = ctx.request.header.referer; } catch (error) { this.ctx.helper.log(error); response.err = 1; response.msg = error.toString(); } ctx.body = response; } /** * 短信通知 * * @param {object} ctx - egg全局变量 * @return {void} */ async sms(ctx) { // 获取当前用户数据 const sessionUser = ctx.session.sessionUser; // 获取账号数据 const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId }); accountData.dsk_account = accountData.dsk_account ? JSON.parse(accountData.dsk_account) : null; const renderData = { accountData, smsType: smsTypeConst.type, }; await this.layout('profile/sms.ejs', renderData, 'profile/modal.ejs'); } /** * 短信通知类型设置 * * @param {object} ctx - egg全局变量 * @return {void} */ async smsType(ctx) { try { const sessionUser = ctx.session.sessionUser; const result = await ctx.service.projectAccount.noticeTypeSet(sessionUser.accountId, ctx.request.body); if (!result) { throw '修改通知类型失败!'; } this.setMessage('通知类型绑定成功', this.messageType.SUCCESS); } catch (error) { console.log(error); this.setMessage(error.toString(), this.messageType.ERROR); } ctx.redirect(ctx.request.header.referer); } async dskApi(ctx) { const response = { err: 0, msg: '', }; try { const sessionUser = ctx.session.sessionUser; const data = JSON.parse(ctx.request.body.data); const dskAccount = await ctx.service.projectAccount.getDataById(sessionUser.accountId); const dsk = new DSK(ctx); switch (data.type) { case 'sms': if (!data.mobile) { throw '参数有误'; } if (!(/^1[3456789]\d{9}$/.test(data.mobile))) { throw '手机号码格式有误'; } await dsk.sendSms(data.mobile); break; case 'bind': if (dskAccount.dsk_account) { throw '已经绑定过大司空账号'; } if ((data.method !== 1 && data.method !== 2) || !data.value || !data.mobile) { throw '参数有误'; } if (!(/^1[3456789]\d{9}$/.test(data.mobile))) { throw '手机号码格式有误'; } const isExist = await ctx.service.projectAccount.isDskExist(ctx.session.sessionProject.id, data.mobile); if (isExist) { throw '此大司空账号已被该项目用户绑定，请重新输入'; } const result = await dsk.accountAuth(data.mobile, data.method, data.value); response.data = await ctx.service.projectAccount.bindDsk(result, data.mobile, sessionUser.accountId); break; case 'unbind': if (!dskAccount.dsk_account) { throw '未绑定大司空账号'; } response.data = await ctx.service.projectAccount.unbindDsk(sessionUser.accountId); break; case 'hadbind': if (!dskAccount.auth_mobile) { response.data = 1; // 未绑定手机 } else if (!dskAccount.dsk_account) { response.data = 2; // 未绑定大司空账号 } else { response.data = JSON.parse(dskAccount.dsk_account); } break; case 'compilation': if (!dskAccount.dsk_account) { throw '未绑定大司空账号'; } const account = JSON.parse(dskAccount.dsk_account); const compilation = await dsk.getCompilation(data.mobile); response.data = {}; response.data.compilation = compilation; if (data.getProject) { const compilationInfo = data.compilationId ? ctx.helper._.find(compilation, { ID: data.compilationId }) : null; const compilationId = compilationInfo ? compilationInfo.ID : (compilation.length > 0 ? compilation[0].ID : null); response.data.select_compilation = compilationId; const projectInfo = compilationId ? await dsk.getProjectList(account.mobile, compilationId) : []; response.data.project = projectInfo; } response.data.dskAccountData = account; break; case 'project': if (!dskAccount.dsk_account) { throw '未绑定大司空账号'; } const account2 = JSON.parse(dskAccount.dsk_account); response.data = await dsk.getProjectList(account2.mobile, data.compilationId); break; case 'save_projects': if (!dskAccount.dsk_account) { throw '未绑定大司空账号'; } const tender = await ctx.service.tender.getDataById(data.tid); if (!tender || tender.user_id !== sessionUser.accountId) { throw '无权限操作'; } await ctx.service.projectAccount.saveDskProjects(sessionUser.accountId, data.project_list); const account3 = JSON.parse(dskAccount.dsk_account); if (data.project_id && ctx.helper._.findIndex(data.project_list, { pid: data.project_id }) !== -1) { account3.select_project = data.project_id; } else { account3.select_project = data.project_list && data.project_list.length > 0 ? data.project_list[0].pid : null; } await ctx.service.projectAccount.defaultUpdate({ id: sessionUser.accountId, dsk_account: JSON.stringify(account3) }); response.data = account3.select_project; break; case 'project_tree': response.data = await dsk.getProjectTree(data.compilationId, data.projectId); const tender2 = data.tid ? await ctx.service.tender.getDataById(data.tid) : null; if (tender2 && tender2.user_id === sessionUser.accountId && dskAccount.dsk_account) { const account4 = JSON.parse(dskAccount.dsk_account); account4.select_project = data.projectId; let treeId = null; if (response.data && response.data.length > 0) { const treeInfo = ctx.helper._.find(response.data, { type: 4 }); if (treeInfo && treeInfo.ID) { treeId = treeInfo.ID; } } account4.select_tree = treeId; await ctx.service.projectAccount.defaultUpdate({ id: sessionUser.accountId, dsk_account: JSON.stringify(account4) }); } break; case 'project_bills': response.data = await dsk.getProjectBills(data.compilationId, data.treeId); const tender3 = data.tid ? await ctx.service.tender.getDataById(data.tid) : null; if (tender3 && tender3.user_id === sessionUser.accountId && dskAccount.dsk_account) { const account5 = JSON.parse(dskAccount.dsk_account); account5.select_tree = data.treeId; await ctx.service.projectAccount.defaultUpdate({ id: sessionUser.accountId, dsk_account: JSON.stringify(account5) }); } break; default:throw '参数有误'; } } catch (error) { response.err = 1; response.msg = error.toString(); } ctx.body = response; } /** * 电子签名 * * @param {object} ctx - egg全局变量 * @return {void} */ async sign(ctx) { // 获取当前用户数据 const sessionUser = ctx.session.sessionUser; // 获取账号数据 const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId }); const renderData = { accountData, fujianOssPath: ctx.app.config.fujianOssPath, }; await this.layout('profile/sign.ejs', renderData); } /** * 网证通电子签名页 * * @param {object} ctx - egg全局变量 * @return {void} */ async netcasign(ctx) { // 获取当前用户数据 const sessionUser = ctx.session.sessionUser; // 获取账号数据 const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId }); const signData = await ctx.service.netcasign.getDataByCondition({ uid: sessionUser.accountId }); const renderData = { accountData, signData, }; await this.layout('profile/netcasign.ejs', renderData, 'profile/sign_modal.ejs'); } /** * 网证通电子签名页面操作 * * @param {object} ctx - egg全局变量 * @return {void} */ async signSave(ctx) { const response = { err: 0, msg: '', }; try { const sessionUser = ctx.session.sessionUser; const data = JSON.parse(ctx.request.body.data); let signData; switch (data.type) { case 'bind': signData = await ctx.service.netcasign.getDataByCondition({ pid: ctx.session.sessionProject.id, keyId: data.updateData.keyId }); if (signData) { const accountData = await ctx.service.projectAccount.getDataByCondition({ id: signData.uid }); throw '该Ukey已绑定于 ' + accountData.name + ', 不可重复绑定'; } const result = await ctx.service.netcasign.add(data.updateData, sessionUser.accountId); if (!result) { throw '绑定Ukey失败'; } response.data = await ctx.service.netcasign.getDataByCondition({ uid: sessionUser.accountId }); break; case 'unbind': signData = await ctx.service.netcasign.getDataByCondition({ pid: ctx.session.sessionProject.id, uid: sessionUser.accountId }); if (!signData) { throw '当前用户不存在绑定证书，解除绑定失败'; } await ctx.service.netcasign.del(signData.id); break; case 'savesign': signData = await ctx.service.netcasign.getDataByCondition({ pid: ctx.session.sessionProject.id, uid: sessionUser.accountId }); if (!signData) { throw '当前用户不存在绑定证书'; } await ctx.service.netcasign.save({ sign_base64: data.sign_base64 }, signData.id); break; case 'delsign': signData = await ctx.service.netcasign.getDataByCondition({ pid: ctx.session.sessionProject.id, uid: sessionUser.accountId }); if (!signData) { throw '当前用户不存在绑定证书'; } if (signData && !signData.sign_base64) { throw '当前用户不存在签名，移除签名失败'; } await ctx.service.netcasign.save({ sign_base64: null }, signData.id); break; default:throw '参数有误'; } } catch (error) { response.err = 1; response.msg = error.toString(); } ctx.body = response; } /** * 电子签名删除 * * @param {object} ctx - egg全局变量 * @return {void} */ async signDelete(ctx) { const response = { err: 0, msg: '', }; try { const sessionUser = ctx.session.sessionUser; // 获取账号数据 const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId }); const data = JSON.parse(ctx.request.body.data); let result = false; if (data.type && data.type === 'stamp') { if (!accountData.stamp_path) { throw '不存在签章'; } const stamp_path_list = accountData.stamp_path.split('!;!'); const spIndex = ctx.helper._.indexOf(stamp_path_list, data.src); if (spIndex === -1) { throw '不存在此签章'; } // 不删除地址，只删除数据库数据，防止已签章的报表丢失 // await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + stamp_path_list[spIndex]); stamp_path_list.splice(spIndex, 1); // 删除库 result = await ctx.service.projectAccount.update({ stamp_path: stamp_path_list.length === 0 ? null : stamp_path_list.join('!;!') }, { id: sessionUser.accountId }); } else { if (accountData.sign_path === '') { throw '不存在签名'; } result = await ctx.service.projectAccount.update({ sign_path: '' }, { id: sessionUser.accountId }); } if (!result) { throw '移除签名失败'; } } catch (error) { response.err = 1; response.msg = error.toString(); } ctx.body = response; } /** * 生成二维码 * * @param {object} ctx - egg全局变量 * @return {void} */ async qrCode(ctx) { const size = 5; const margin = 1; try { // 获取当前用户数据 const sessionUser = ctx.session.sessionUser; let text = ctx.protocol + '://' + ctx.host + '/sign?user_id=' + sessionUser.accountId + '&app_token=' + sessionUser.sessionToken; if (ctx.query.from === 'netcasign') { text += '&from=netcasign'; } // 大小默认5，二维码周围间距默认1 const img = qr.image(text || '', { type: 'png', size: size || 5, margin: margin || 1 }); ctx.status = 200; ctx.type = 'image/png'; ctx.body = img; } catch (e) { ctx.status = 414; ctx.set('Content-Type', 'text/html'); ctx.body = '

414 Request-URI Too Large

'; } } /** * 上传签名图 * * @param {object} ctx - egg全局变量 * @return {void} */ async signUpload(ctx) { const responseData = { err: 0, msg: '', data: null, }; try { const stream = await ctx.getFileStream(); const create_time = Date.parse(new Date()) / 1000; const fileInfo = path.parse(stream.filename); if (stream.fields && stream.fields.type && stream.fields.type === 'stamp') { // const dirName = 'app/public/upload/sign/profile'; // const fileName = moment().format('YYYYMMDD') + '_sign_' + create_time + fileInfo.ext; const filepath = `app/public/upload/sign/profile/qianzhang_${create_time + fileInfo.ext}`; await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream); await sendToWormhole(stream); const result = await ctx.service.projectAccount.update({ stamp_path: filepath }, { id: ctx.session.sessionUser.accountId }); if (result) { responseData.data = { stamp_path: filepath }; } else { throw '添加数据库失败'; } } else { const dirName = 'public/upload/sign'; const fileName = moment().format('YYYYMMDD') + '_sign_' + create_time + fileInfo.ext; await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', dirName, fileName)); await sendToWormhole(stream); const result = await ctx.service.projectAccount.update({ sign_path: fileName }, { id: ctx.session.sessionUser.accountId }); if (result) { responseData.data = { sign_path: fileName }; } else { throw '添加数据库失败'; } } } catch (err) { this.log(err); responseData.err = 1; responseData.msg = err; } ctx.body = responseData; } /** * 上传签章图（多选） * * @param {object} ctx - egg全局变量 * @return {void} */ async stampUpload(ctx) { const responseData = { err: 0, msg: '', data: null, }; let stream; try { const parts = ctx.multipart({ autoFields: true }); const paths = []; let index = 0; stream = await parts(); while (stream !== undefined) { // 判断用户是否选择上传文件 if (!stream.filename) { throw '请选择上传的文件!'; } const fileInfo = path.parse(stream.filename); const create_time = Date.parse(new Date()) / 1000; const filepath = `app/public/upload/sign/profile/qianzhang_${create_time + index.toString() + fileInfo.ext}`; // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, filepath)); await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream); if (stream) { await sendToWormhole(stream); } paths.push(filepath); ++index; if (Array.isArray(parts.field.size) && index < parts.field.size.length) { stream = await parts(); } else { stream = undefined; } } // 获取账号数据 const accountData = await ctx.service.projectAccount.getDataByCondition({ id: ctx.session.sessionUser.accountId }); const stamp_path = accountData.stamp_path ? accountData.stamp_path.split('!;!') : []; const stamp_path_list = ctx.helper._.concat(stamp_path, paths); const result = await ctx.service.projectAccount.update({ stamp_path: stamp_path_list.join('!;!') }, { id: ctx.session.sessionUser.accountId }); if (result) { responseData.data = { stamp_path: stamp_path_list }; } else { throw '添加数据库失败'; } } catch (err) { this.log(err); // 失败需要消耗掉stream 以防卡死 if (stream) { await sendToWormhole(stream); } responseData.err = 1; responseData.msg = err.toString(); } ctx.body = responseData; } /** * 账号安全 * * @param {object} ctx - egg全局变量 * @return {void} */ async safe(ctx) { // 获取当前用户数据 const sessionUser = ctx.session.sessionUser; // 获取账号数据 const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId }); // 获取修改密码的字段规则 // const passwordRule = ctx.service.projectAccount.rule('modifyPassword'); // const passwordJsValidator = await this.jsValidator.convert(passwordRule).setSelector('#password-form').build(); // console.log(passwordJsValidator); // 获取登录日志 const loginLogging = await ctx.service.loginLogging.getLoginLogs(ctx.session.sessionProject.id, ctx.session.sessionUser.accountId); const renderData = { accountData, // passwordJsValidator, loginLogging, loginWay, }; await this.layout('profile/safe.ejs', renderData); } /** * 微信通知 * * @param {object} ctx - egg全局变量 * @return {void} */ async wechat(ctx) { // 获取当前用户数据 const sessionUser = ctx.session.sessionUser; // 获取账号数据 const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId }); if (accountData.qywx_user_info !== null) { accountData.qywx_user_info = JSON.parse(accountData.qywx_user_info); } const renderData = { accountData, smsType: smsTypeConst.type, }; await this.layout('profile/wechat.ejs', renderData, 'profile/wechat_modal.ejs'); } /** * 微信解绑 * * @param {object} ctx - egg全局变量 * @return {void} */ async removeWechat(ctx) { try { const sessionUser = ctx.session.sessionUser; // 获取账号数据 const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId }); // 判断解绑类型 if (ctx.request.body.data_type === 'wxWork') { const result = await ctx.service.projectAccount.bindWx4Work(sessionUser.accountId, null, null, null); if (!result) { throw '解绑企业微信失败!'; } // 解绑成功通知 const qywx = new wxWork(ctx); const desc = '您好，纵横云计量与企业微信解绑成功。'; const content = [ { keyname: '项目编号', value: ctx.session.sessionProject.code, }, { keyname: '账号', value: sessionUser.account, }, { keyname: '绑定时间', value: moment(new Date()).format('YYYY-MM-DD'), }, { keyname: '备注', value: '感谢您的使用，要接收通知请重新绑定。', }, ]; const url = ctx.protocol + '://' + ctx.host + '/wx/tips?msg=解绑成功，感谢您的使用。'; await qywx.sendTemplateCard([accountData.qywx_userid], accountData.qywx_corpid, '账号解绑成功通知', desc, content, url); this.setMessage('企业微信解绑成功', this.messageType.SUCCESS); } else { const result = await ctx.service.projectAccount.bindWx(sessionUser.accountId, null, null); if (!result) { throw '解绑微信失败!'; } // 解绑成功通知 const templateId = '0w0Yp65X4PHccTLeAyE5aQhS-blS-bylwxAPYEGy3CI'; const url = ''; const msgData = { first: { value: '您好，纵横云计量与微信解绑成功。', }, keyword1: { value: ctx.session.sessionProject.code, }, keyword2: { value: sessionUser.account, }, keyword3: { value: moment(new Date()).format('YYYY-MM-DD'), }, remark: { value: '感谢您的使用，要接收通知请重新绑定。', }, }; await app.wechat.api.sendTemplate(accountData.wx_openid, templateId, url, '', msgData); this.setMessage('微信解绑成功', this.messageType.SUCCESS); } } catch (error) { console.log(error); this.setMessage(error.toString(), this.messageType.ERROR); } ctx.redirect(ctx.request.header.referer); } } return ProfileController; };