profile_controller.js 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621
  1. 'use strict';
  2. /**
  3. * 账号相关控制器
  4. *
  5. * @author CaiAoLin
  6. * @date 2018/1/26
  7. * @version
  8. */
  9. const moment = require('moment');
  10. const profileMenu = require('../../config/menu').profileMenu;
  11. const smsTypeConst = require('../const/sms_type');
  12. const qr = require('qr-image');
  13. const path = require('path');
  14. const sendToWormhole = require('stream-wormhole');
  15. const loginWay = require('../const/setting').loginWay;
  16. module.exports = app => {
  17. class ProfileController extends app.BaseController {
  18. /**
  19. * 构造函数
  20. *
  21. * @param {Object} ctx - egg全局context
  22. * @return {void}
  23. */
  24. constructor(ctx) {
  25. super(ctx);
  26. ctx.subMenu = profileMenu;
  27. }
  28. /**
  29. * 账号资料页面
  30. *
  31. * @param {Object} ctx - egg全局变量
  32. * @return {void}
  33. */
  34. async info(ctx) {
  35. // 获取当前用户数据
  36. const sessionUser = ctx.session.sessionUser;
  37. // 获取账号数据
  38. const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId });
  39. // 获取基础数据的字段规则
  40. const baseRule = ctx.service.projectAccount.rule('profileBase');
  41. const baseJsValidator = await this.jsValidator.convert(baseRule).setSelector('#base-form').build();
  42. const renderData = {
  43. accountData,
  44. baseJsValidator,
  45. };
  46. await this.layout('profile/info.ejs', renderData);
  47. }
  48. /**
  49. * 保存基本信息
  50. *
  51. * @param {Object} ctx - egg全局变量
  52. * @return {void}
  53. */
  54. async saveBase(ctx) {
  55. try {
  56. // 获取当前用户数据
  57. const sessionUser = ctx.session.sessionUser;
  58. // 获取基础数据的字段规则
  59. const baseRule = ctx.service.projectAccount.rule('profileBase');
  60. ctx.helper.validate(baseRule);
  61. const result = await ctx.service.projectAccount.saveInfo(ctx.request.body, sessionUser.accountId);
  62. if (!result) {
  63. throw '保存信息失败';
  64. }
  65. this.setMessage('修改成功', this.messageType.SUCCESS);
  66. } catch (error) {
  67. this.log(error);
  68. this.setMessage(error.toString(), this.messageType.ERROR);
  69. }
  70. ctx.redirect(ctx.request.header.referer);
  71. }
  72. /**
  73. * 修改密码操作
  74. *
  75. * @param {Object} ctx - egg全局变量
  76. * @return {void}
  77. */
  78. async modifyPassword(ctx) {
  79. const password = ctx.request.body.password;
  80. const newPassword = ctx.request.body.new_password;
  81. try {
  82. const sessionUser = ctx.session.sessionUser;
  83. let accountId = sessionUser.accountId;
  84. accountId = parseInt(accountId);
  85. if (isNaN(accountId) || accountId <= 0) {
  86. throw '参数错误';
  87. }
  88. // 验证数据
  89. const passwordRule = ctx.service.projectAccount.rule('modifyPassword');
  90. ctx.helper.validate(passwordRule);
  91. // 判断新密码的强度
  92. const reg = /^(?![0-9]+$)(?![a-zA-Z]+$).{6,16}$/;
  93. if (!reg.test(newPassword)) {
  94. throw '请设置至少包含数字和字母的新密码';
  95. }
  96. const result = await ctx.service.projectAccount.modifyPassword(accountId, password, newPassword);
  97. if (!result) {
  98. throw '修改密码失败';
  99. }
  100. this.setMessage('修改密码成功', this.messageType.SUCCESS);
  101. ctx.redirect('/logout');
  102. } catch (error) {
  103. ctx.session.postError = error.toString();
  104. this.setMessage(error.toString(), this.messageType.ERROR);
  105. ctx.redirect(ctx.request.header.referer);
  106. }
  107. }
  108. /**
  109. * 设置短信验证码
  110. *
  111. * @param {object} ctx - egg全局变量
  112. * @return {void}
  113. */
  114. async getCode(ctx) {
  115. const response = {
  116. err: 0,
  117. msg: '',
  118. };
  119. try {
  120. const sessionUser = ctx.session.sessionUser;
  121. const mobile = ctx.request.body.mobile;
  122. let type = null;
  123. if (ctx.request.body.type) {
  124. type = ctx.request.body.type;
  125. delete ctx.request.body.type;
  126. }
  127. const rule = { mobile: { type: 'mobile', allowEmpty: false } };
  128. ctx.helper.validate(rule);
  129. if (type === null || type !== 'shenpi') {
  130. // 查找是否有重复的认证手机
  131. const accountData = await ctx.service.projectAccount.getDataByCondition({ project_id: ctx.session.sessionProject.id, auth_mobile: mobile });
  132. if (accountData !== null) {
  133. throw '此手机号码已被使用,请重新输入!';
  134. }
  135. }
  136. const result = await ctx.service.projectAccount.setSMSCode(sessionUser.accountId, mobile);
  137. if (!result) {
  138. throw '获取验证码失败';
  139. }
  140. } catch (error) {
  141. response.err = 1;
  142. response.msg = error.toString();
  143. }
  144. ctx.body = response;
  145. }
  146. /**
  147. * 绑定认证手机
  148. *
  149. * @param {object} ctx - egg全局变量
  150. * @return {void}
  151. */
  152. async bindMobile(ctx) {
  153. const response = {
  154. err: 0,
  155. msg: '',
  156. };
  157. try {
  158. const rule = ctx.service.projectAccount.rule('bindMobile');
  159. ctx.helper.validate(rule);
  160. const sessionUser = ctx.session.sessionUser;
  161. const result = await ctx.service.projectAccount.bindMobile(sessionUser.accountId, ctx.request.body, ctx.session.sessionProject.id);
  162. if (!result) {
  163. throw '绑定手机失败!';
  164. }
  165. // this.setMessage('绑定成功', this.messageType.SUCCESS);
  166. response.msg = '绑定成功';
  167. response.url = ctx.request.header.referer;
  168. } catch (error) {
  169. this.ctx.helper.log(error);
  170. response.err = 1;
  171. response.msg = error.toString();
  172. }
  173. ctx.body = response;
  174. }
  175. /**
  176. * 短信通知
  177. *
  178. * @param {object} ctx - egg全局变量
  179. * @return {void}
  180. */
  181. async sms(ctx) {
  182. // 获取当前用户数据
  183. const sessionUser = ctx.session.sessionUser;
  184. // 获取账号数据
  185. const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId });
  186. const renderData = {
  187. accountData,
  188. smsType: smsTypeConst.type,
  189. };
  190. await this.layout('profile/sms.ejs', renderData, 'profile/modal.ejs');
  191. }
  192. /**
  193. * 短信通知类型设置
  194. *
  195. * @param {object} ctx - egg全局变量
  196. * @return {void}
  197. */
  198. async smsType(ctx) {
  199. try {
  200. const sessionUser = ctx.session.sessionUser;
  201. const result = await ctx.service.projectAccount.noticeTypeSet(sessionUser.accountId, ctx.request.body);
  202. if (!result) {
  203. throw '修改通知类型失败!';
  204. }
  205. this.setMessage('通知类型绑定成功', this.messageType.SUCCESS);
  206. } catch (error) {
  207. console.log(error);
  208. this.setMessage(error.toString(), this.messageType.ERROR);
  209. }
  210. ctx.redirect(ctx.request.header.referer);
  211. }
  212. /**
  213. * 电子签名
  214. *
  215. * @param {object} ctx - egg全局变量
  216. * @return {void}
  217. */
  218. async sign(ctx) {
  219. // 获取当前用户数据
  220. const sessionUser = ctx.session.sessionUser;
  221. // 获取账号数据
  222. const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId });
  223. const renderData = {
  224. accountData,
  225. fujianOssPath: ctx.app.config.fujianOssPath,
  226. };
  227. await this.layout('profile/sign.ejs', renderData);
  228. }
  229. /**
  230. * 网证通电子签名页
  231. *
  232. * @param {object} ctx - egg全局变量
  233. * @return {void}
  234. */
  235. async netcasign(ctx) {
  236. // 获取当前用户数据
  237. const sessionUser = ctx.session.sessionUser;
  238. // 获取账号数据
  239. const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId });
  240. const signData = await ctx.service.netcasign.getDataByCondition({ uid: sessionUser.accountId });
  241. const renderData = {
  242. accountData,
  243. signData,
  244. };
  245. await this.layout('profile/netcasign.ejs', renderData, 'profile/sign_modal.ejs');
  246. }
  247. /**
  248. * 网证通电子签名页面操作
  249. *
  250. * @param {object} ctx - egg全局变量
  251. * @return {void}
  252. */
  253. async signSave(ctx) {
  254. const response = {
  255. err: 0,
  256. msg: '',
  257. };
  258. try {
  259. const sessionUser = ctx.session.sessionUser;
  260. const data = JSON.parse(ctx.request.body.data);
  261. let signData;
  262. switch (data.type) {
  263. case 'bind':
  264. signData = await ctx.service.netcasign.getDataByCondition({ pid: ctx.session.sessionProject.id, keyId: data.updateData.keyId });
  265. if (signData) {
  266. const accountData = await ctx.service.projectAccount.getDataByCondition({ id: signData.uid });
  267. throw '该Ukey已绑定于 ' + accountData.name + ', 不可重复绑定';
  268. }
  269. const result = await ctx.service.netcasign.add(data.updateData, sessionUser.accountId);
  270. if (!result) {
  271. throw '绑定Ukey失败';
  272. }
  273. response.data = await ctx.service.netcasign.getDataByCondition({ uid: sessionUser.accountId });
  274. break;
  275. case 'unbind':
  276. signData = await ctx.service.netcasign.getDataByCondition({ pid: ctx.session.sessionProject.id, uid: sessionUser.accountId });
  277. if (!signData) {
  278. throw '当前用户不存在绑定证书,解除绑定失败';
  279. }
  280. await ctx.service.netcasign.del(signData.id);
  281. break;
  282. case 'savesign':
  283. signData = await ctx.service.netcasign.getDataByCondition({ pid: ctx.session.sessionProject.id, uid: sessionUser.accountId });
  284. if (!signData) {
  285. throw '当前用户不存在绑定证书';
  286. }
  287. await ctx.service.netcasign.save({ sign_base64: data.sign_base64 }, signData.id);
  288. break;
  289. case 'delsign':
  290. signData = await ctx.service.netcasign.getDataByCondition({ pid: ctx.session.sessionProject.id, uid: sessionUser.accountId });
  291. if (!signData) {
  292. throw '当前用户不存在绑定证书';
  293. }
  294. if (signData && !signData.sign_base64) {
  295. throw '当前用户不存在签名,移除签名失败';
  296. }
  297. await ctx.service.netcasign.save({ sign_base64: null }, signData.id);
  298. break;
  299. default:throw '参数有误';
  300. }
  301. } catch (error) {
  302. response.err = 1;
  303. response.msg = error.toString();
  304. }
  305. ctx.body = response;
  306. }
  307. /**
  308. * 电子签名删除
  309. *
  310. * @param {object} ctx - egg全局变量
  311. * @return {void}
  312. */
  313. async signDelete(ctx) {
  314. const response = {
  315. err: 0,
  316. msg: '',
  317. };
  318. try {
  319. const sessionUser = ctx.session.sessionUser;
  320. // 获取账号数据
  321. const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId });
  322. const data = JSON.parse(ctx.request.body.data);
  323. let result = false;
  324. if (data.type && data.type === 'stamp') {
  325. if (!accountData.stamp_path) {
  326. throw '不存在签章';
  327. }
  328. const stamp_path_list = accountData.stamp_path.split('!;!');
  329. const spIndex = ctx.helper._.indexOf(stamp_path_list, data.src);
  330. if (spIndex === -1) {
  331. throw '不存在此签章';
  332. }
  333. // 删除oss文件
  334. await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + stamp_path_list[spIndex]);
  335. stamp_path_list.splice(spIndex, 1);
  336. // 删除库
  337. result = await ctx.service.projectAccount.update({ stamp_path: stamp_path_list.length === 0 ? null : stamp_path_list.join('!;!') }, { id: sessionUser.accountId });
  338. } else {
  339. if (accountData.sign_path === '') {
  340. throw '不存在签名';
  341. }
  342. result = await ctx.service.projectAccount.update({ sign_path: '' }, { id: sessionUser.accountId });
  343. }
  344. if (!result) {
  345. throw '移除签名失败';
  346. }
  347. } catch (error) {
  348. response.err = 1;
  349. response.msg = error.toString();
  350. }
  351. ctx.body = response;
  352. }
  353. /**
  354. * 生成二维码
  355. *
  356. * @param {object} ctx - egg全局变量
  357. * @return {void}
  358. */
  359. async qrCode(ctx) {
  360. const size = 5;
  361. const margin = 1;
  362. try {
  363. // 获取当前用户数据
  364. const sessionUser = ctx.session.sessionUser;
  365. let text = ctx.protocol + '://' + ctx.host + '/sign?user_id=' + sessionUser.accountId + '&app_token=' + sessionUser.sessionToken;
  366. if (ctx.query.from === 'netcasign') {
  367. text += '&from=netcasign';
  368. }
  369. // 大小默认5,二维码周围间距默认1
  370. const img = qr.image(text || '', { type: 'png', size: size || 5, margin: margin || 1 });
  371. ctx.status = 200;
  372. ctx.type = 'image/png';
  373. ctx.body = img;
  374. } catch (e) {
  375. ctx.status = 414;
  376. ctx.set('Content-Type', 'text/html');
  377. ctx.body = '<h1>414 Request-URI Too Large</h1>';
  378. }
  379. }
  380. /**
  381. * 上传签名图
  382. *
  383. * @param {object} ctx - egg全局变量
  384. * @return {void}
  385. */
  386. async signUpload(ctx) {
  387. const responseData = {
  388. err: 0, msg: '', data: null,
  389. };
  390. try {
  391. const stream = await ctx.getFileStream();
  392. const create_time = Date.parse(new Date()) / 1000;
  393. const fileInfo = path.parse(stream.filename);
  394. if (stream.fields && stream.fields.type && stream.fields.type === 'stamp') {
  395. // const dirName = 'app/public/upload/sign/profile';
  396. // const fileName = moment().format('YYYYMMDD') + '_sign_' + create_time + fileInfo.ext;
  397. const filepath = `app/public/upload/sign/profile/qianzhang_${create_time + fileInfo.ext}`;
  398. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  399. await sendToWormhole(stream);
  400. const result = await ctx.service.projectAccount.update({ stamp_path: filepath }, { id: ctx.session.sessionUser.accountId });
  401. if (result) {
  402. responseData.data = { stamp_path: filepath };
  403. } else {
  404. throw '添加数据库失败';
  405. }
  406. } else {
  407. const dirName = 'public/upload/sign';
  408. const fileName = moment().format('YYYYMMDD') + '_sign_' + create_time + fileInfo.ext;
  409. await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', dirName, fileName));
  410. await sendToWormhole(stream);
  411. const result = await ctx.service.projectAccount.update({ sign_path: fileName }, { id: ctx.session.sessionUser.accountId });
  412. if (result) {
  413. responseData.data = { sign_path: fileName };
  414. } else {
  415. throw '添加数据库失败';
  416. }
  417. }
  418. } catch (err) {
  419. this.log(err);
  420. responseData.err = 1;
  421. responseData.msg = err;
  422. }
  423. ctx.body = responseData;
  424. }
  425. /**
  426. * 上传签章图(多选)
  427. *
  428. * @param {object} ctx - egg全局变量
  429. * @return {void}
  430. */
  431. async stampUpload(ctx) {
  432. const responseData = {
  433. err: 0, msg: '', data: null,
  434. };
  435. let stream;
  436. try {
  437. const parts = ctx.multipart({ autoFields: true });
  438. const paths = [];
  439. let index = 0;
  440. while ((stream = await parts()) !== undefined) {
  441. // 判断用户是否选择上传文件
  442. if (!stream.filename) {
  443. throw '请选择上传的文件!';
  444. }
  445. const fileInfo = path.parse(stream.filename);
  446. const create_time = Date.parse(new Date()) / 1000;
  447. const filepath = `app/public/upload/sign/profile/qianzhang_${create_time + index.toString() + fileInfo.ext}`;
  448. // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, filepath));
  449. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  450. if (stream) {
  451. await sendToWormhole(stream);
  452. }
  453. paths.push(filepath);
  454. ++index;
  455. }
  456. // 获取账号数据
  457. const accountData = await ctx.service.projectAccount.getDataByCondition({ id: ctx.session.sessionUser.accountId });
  458. const stamp_path = accountData.stamp_path ? accountData.stamp_path.split('!;!') : [];
  459. const stamp_path_list = ctx.helper._.concat(stamp_path, paths);
  460. const result = await ctx.service.projectAccount.update({ stamp_path: stamp_path_list.join('!;!') }, { id: ctx.session.sessionUser.accountId });
  461. if (result) {
  462. responseData.data = { stamp_path: stamp_path_list };
  463. } else {
  464. throw '添加数据库失败';
  465. }
  466. } catch (err) {
  467. this.log(err);
  468. // 失败需要消耗掉stream 以防卡死
  469. if (stream) {
  470. await sendToWormhole(stream);
  471. }
  472. responseData.err = 1;
  473. responseData.msg = err.toString();
  474. }
  475. ctx.body = responseData;
  476. }
  477. /**
  478. * 账号安全
  479. *
  480. * @param {object} ctx - egg全局变量
  481. * @return {void}
  482. */
  483. async safe(ctx) {
  484. // 获取当前用户数据
  485. const sessionUser = ctx.session.sessionUser;
  486. // 获取账号数据
  487. const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId });
  488. // 获取修改密码的字段规则
  489. // const passwordRule = ctx.service.projectAccount.rule('modifyPassword');
  490. // const passwordJsValidator = await this.jsValidator.convert(passwordRule).setSelector('#password-form').build();
  491. // console.log(passwordJsValidator);
  492. // 获取登录日志
  493. const loginLogging = await ctx.service.loginLogging.getLoginLogs(ctx.session.sessionProject.id, ctx.session.sessionUser.accountId);
  494. const renderData = {
  495. accountData,
  496. // passwordJsValidator,
  497. loginLogging,
  498. loginWay,
  499. };
  500. await this.layout('profile/safe.ejs', renderData);
  501. }
  502. /**
  503. * 微信通知
  504. *
  505. * @param {object} ctx - egg全局变量
  506. * @return {void}
  507. */
  508. async wechat(ctx) {
  509. // 获取当前用户数据
  510. const sessionUser = ctx.session.sessionUser;
  511. // 获取账号数据
  512. const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId });
  513. const renderData = {
  514. accountData,
  515. smsType: smsTypeConst.type,
  516. };
  517. await this.layout('profile/wechat.ejs', renderData, 'profile/wechat_modal.ejs');
  518. }
  519. /**
  520. * 微信解绑
  521. *
  522. * @param {object} ctx - egg全局变量
  523. * @return {void}
  524. */
  525. async removeWechat(ctx) {
  526. try {
  527. const sessionUser = ctx.session.sessionUser;
  528. // 获取账号数据
  529. const accountData = await ctx.service.projectAccount.getDataByCondition({ id: sessionUser.accountId });
  530. const result = await ctx.service.projectAccount.bindWx(sessionUser.accountId, null, null);
  531. if (!result) {
  532. throw '解绑微信失败!';
  533. }
  534. // 解绑成功通知
  535. const templateId = '0w0Yp65X4PHccTLeAyE5aQhS-blS-bylwxAPYEGy3CI';
  536. const url = '';
  537. const msgData = {
  538. first: {
  539. value: '您好,纵横云计量与微信解绑成功。',
  540. },
  541. keyword1: {
  542. value: ctx.session.sessionProject.code,
  543. },
  544. keyword2: {
  545. value: sessionUser.account,
  546. },
  547. keyword3: {
  548. value: moment(new Date()).format('YYYY-MM-DD'),
  549. },
  550. remark: {
  551. value: '感谢您的使用,要接收通知请重新绑定。',
  552. },
  553. };
  554. await app.wechat.api.sendTemplate(accountData.wx_openid, templateId, url, '', msgData);
  555. this.setMessage('微信解绑成功', this.messageType.SUCCESS);
  556. } catch (error) {
  557. console.log(error);
  558. this.setMessage(error.toString(), this.messageType.ERROR);
  559. }
  560. ctx.redirect(ctx.request.header.referer);
  561. }
  562. }
  563. return ProfileController;
  564. };