user_controller.js 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435
  1. /**
  2. * 用户相关控制器
  3. *
  4. * @author CaiAoLin
  5. * @date 2017/6/13
  6. * @version
  7. */
  8. const UserModel = require("../models/user_model");
  9. const BaseController = require("../../common/base/base_controller");
  10. const LogType = require("../../common/const/log_type_const");
  11. const LogModel = require("../models/log_model");
  12. const SettingModel = require("../models/setting_model");
  13. const SettingType = require("../../common/const/setting_type_const");
  14. const CompilationModel = require("../models/compilation_model");
  15. const getValuationBasisURL = require('../../common/const/valuationBasis');
  16. const mongoose = require("mongoose");
  17. const moment = require("moment");
  18. const userData = mongoose.model('user');
  19. class UserController extends BaseController {
  20. /**
  21. * 用户信息页面
  22. *
  23. * @param {object} request
  24. * @param {object} response
  25. * @return {void}
  26. */
  27. async info(request, response) {
  28. // 获取当前用户数据
  29. let sessionUser = request.session.sessionUser;
  30. let userModel = new UserModel();
  31. let userData = await userModel.findDataBySsoId(sessionUser.ssoId);
  32. userData = Object.keys(userData).length <= 0 ? [] : userData;
  33. let renderData = {
  34. userData: userData,
  35. provinceList: userModel.province,
  36. companyTypeList: userModel.companyType,
  37. companyScaleList: userModel.companyScale,
  38. compilationName: request.session.sessionCompilation.name,
  39. valuationBasisURL: getValuationBasisURL(request.session.sessionCompilation.name),
  40. versionName: request.session.compilationVersion,
  41. };
  42. response.render('users/html/user-info', renderData);
  43. }
  44. /**
  45. * 保存个人数据
  46. *
  47. * @param {object} request
  48. * @param {object} response
  49. * @return
  50. */
  51. async saveData(request, response) {
  52. try {
  53. let updateData = {
  54. real_name: request.body.real_name,
  55. province: request.body.province,
  56. company: request.body.company,
  57. version: request.body.version ? request.body.version : null,
  58. company_type: request.body.company_type ? request.body.company_type : null,
  59. company_scale: request.body.company_scale ? request.body.company_scale : null,
  60. };
  61. let sessionUser = request.session.sessionUser;
  62. // 切换验证场景
  63. let userModel = new UserModel();
  64. let condition = {ssoId: sessionUser.ssoId};
  65. userModel.setScene('saveInfo');
  66. let result = await userModel.updateUser(condition, updateData);
  67. //更新session
  68. for(let attr in sessionUser){
  69. sessionUser[attr] = updateData[attr] ? updateData[attr] : sessionUser[attr];
  70. }
  71. if (result.ok !== 1) {
  72. throw '用户数据保存失败';
  73. }
  74. } catch (error) {
  75. return response.redirect(request.headers.referer);
  76. }
  77. response.redirect('/pm');
  78. }
  79. /**
  80. * 账号安全页面
  81. *
  82. * @param {object} request
  83. * @param {object} response
  84. * @return {void}
  85. */
  86. async safe(request, response) {
  87. let userData = [];
  88. let logList = [];
  89. let pageData = {};
  90. try {
  91. // 获取当前用户信息
  92. let sessionUser = request.session.sessionUser;
  93. console.log(sessionUser);
  94. let userModel = new UserModel();
  95. userData = await userModel.findDataBySsoId(sessionUser.ssoId);
  96. console.log(userData);
  97. let page = request.query.page === undefined ? 1 : request.query.page;
  98. // 获取登录信息
  99. let logModel = new LogModel();
  100. let logCount = await logModel.count();
  101. logCount = logCount > 30 ? 30 : logCount;
  102. let pageSize = 10;
  103. logList = await logModel.getLog(sessionUser.id, LogType.LOGIN_LOG, page, pageSize);
  104. // 分页数据
  105. pageData = {
  106. current: page,
  107. total: parseInt(logCount / pageSize),
  108. queryData: response.locals.urlQuery
  109. };
  110. } catch (error) {
  111. console.log(error);
  112. }
  113. let renderData = {
  114. userData: userData,
  115. logList: logList,
  116. pages: pageData,
  117. compilationName: request.session.sessionCompilation.name,
  118. valuationBasisURL: getValuationBasisURL(request.session.sessionCompilation.name),
  119. versionName: request.session.compilationVersion,
  120. };
  121. response.render('users/html/user-safe', renderData);
  122. }
  123. /**
  124. * 产品激活页面
  125. *
  126. * @param request
  127. * @param response
  128. * @return {void}
  129. */
  130. async buy(request, response) {
  131. let userData = [];
  132. let compilationList = [];
  133. try {
  134. // 获取编办信息
  135. let compilationModel = new CompilationModel();
  136. compilationList = await compilationModel.getList();
  137. // 获取当前用户信息
  138. let sessionUser = request.session.sessionUser;
  139. let userModel = new UserModel();
  140. userData = await userModel.findDataBySsoId(sessionUser.ssoId);
  141. if (userData.upgrade_list !== undefined) {
  142. let userUpgradeList = userData.upgrade_list;
  143. for (let index in userUpgradeList) {
  144. let oneCompilationIndex = compilationList.findIndex(function (item) {
  145. return item.id === userUpgradeList[index].compilationID;
  146. });
  147. if (oneCompilationIndex !== -1) {
  148. compilationList[oneCompilationIndex].isUpgrade = userUpgradeList[index].isUpgrade;
  149. compilationList[oneCompilationIndex].deadline = userUpgradeList[index].deadline;
  150. compilationList[oneCompilationIndex].lock = userUpgradeList[index].lock;
  151. }
  152. }
  153. }
  154. } catch(error) {
  155. console.log(error);
  156. }
  157. let renderData = {
  158. userData: userData,
  159. compilationList: compilationList,
  160. compilationName: request.session.sessionCompilation.name,
  161. valuationBasisURL: getValuationBasisURL(request.session.sessionCompilation.name),
  162. versionName: request.session.compilationVersion,
  163. };
  164. response.render('users/html/user-buy', renderData);
  165. }
  166. /**
  167. * 偏好设置页面
  168. *
  169. * @param {object} request
  170. * @param {object} response
  171. * @return {void}
  172. */
  173. async preferences(request, response) {
  174. let sessionUserData = request.session.sessionUser;
  175. let preferenceSetting = {};
  176. let compilationList = [];
  177. try {
  178. // 获取配置信息
  179. let settingModel = new SettingModel();
  180. preferenceSetting = await settingModel.getPreferenceSetting(sessionUserData.id);
  181. // 获取编办信息
  182. let compilationModel = new CompilationModel();
  183. compilationList = await compilationModel.getList();
  184. } catch(error) {
  185. console.log(error);
  186. }
  187. let renderData = {
  188. preferenceSetting: preferenceSetting,
  189. compilationList: compilationList,
  190. compilationName: request.session.sessionCompilation.name,
  191. valuationBasisURL: getValuationBasisURL(request.session.sessionCompilation.name),
  192. versionName: request.session.compilationVersion,
  193. };
  194. response.render('users/html/user-set', renderData);
  195. }
  196. /**
  197. * 保存偏好设置
  198. *
  199. * @param {object} request
  200. * @param {object} response
  201. * @return {void}
  202. */
  203. async savePreferences(request, response) {
  204. let loginAsk = request.body.login_ask;
  205. loginAsk = parseInt(loginAsk);
  206. let selectVersion = request.body.select_version;
  207. let sessionUserData = request.session.sessionUser;
  208. try {
  209. let data = {
  210. login_ask: loginAsk,
  211. select_version: loginAsk === 0 ? selectVersion : ''
  212. };
  213. let settingModel = new SettingModel();
  214. let result = await settingModel.save(sessionUserData.id, SettingType.PREFERENCE, data);
  215. if (!result) {
  216. throw '保存失败';
  217. }
  218. // 保存编办信息到session
  219. if (data.login_ask === 1) {
  220. // 查找对应编办
  221. let compilationModel = new CompilationModel();
  222. let compilationData = await compilationModel.getCompilationById(selectVersion);
  223. // 判断当前用户的是使用免费版还是专业版
  224. let userModel = new UserModel();
  225. let compilationVersion = await userModel.getVersionFromUpgrade(sessionUserData.ssoId, compilationData._id);
  226. request.session.compilationVersion = compilationVersion.version;
  227. request.session.sessionUser.compilationLock = compilationVersion.lock;
  228. request.session.sessionCompilation = compilationData;
  229. }
  230. } catch (error) {
  231. console.log(error);
  232. }
  233. response.redirect(request.headers.referer);
  234. }
  235. /*
  236. * 版本激活
  237. * */
  238. async activateVersion(request, response){
  239. try{
  240. let userModel = new UserModel();
  241. let sessionUser = request.session.sessionUser;
  242. let data = JSON.parse(request.body.data);
  243. let activateCode = data.activateCode,
  244. compilationId = data.compilationId;
  245. let isActivated = true;//调激活接口
  246. if(!isActivated){
  247. throw '激活失败';
  248. }
  249. //激活成功,更新入库
  250. let userObjId = mongoose.Types.ObjectId(sessionUser.id);
  251. let versionInfo = {};
  252. versionInfo.compilationId = compilationId;
  253. versionInfo.activatedDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  254. //失效信息{invalid: boolean, invalidDate: String}
  255. versionInfo.invalidInfo = null;
  256. await userModel.addVersion({_id: userObjId}, versionInfo);
  257. response.json({error: 0, msg: 'success'});
  258. }
  259. catch (error){
  260. response.json({error: 1, msg: error})
  261. }
  262. }
  263. /*
  264. * 更新版本状态
  265. * */
  266. async updateVersionState(request, response){
  267. try{
  268. let userModel = new UserModel();
  269. let activated = request.body.activated,
  270. userId = request.body.userId,
  271. compilationId = request.body.compilationId;
  272. if(activated){
  273. let versionInfo = {};
  274. versionInfo.compilationId = compilationId;
  275. versionInfo.activatedDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  276. versionInfo.invalidInfo = null;
  277. await userModel.addVersion({_id: mongoose.Types.ObjectId(userId)}, versionInfo);
  278. }
  279. else{
  280. await userModel.removeVersion(userId, compilationId);
  281. }
  282. response.json({error: 0, msg: 'success'});
  283. }
  284. catch (error){
  285. response.json({error: 1, msg: error});
  286. }
  287. }
  288. /*
  289. * 获取用户版本信息
  290. * */
  291. async getVersionInfo(request, response){
  292. try{
  293. let userModel = new UserModel();
  294. let userId = request.session.sessionUser.id;
  295. let userData = await userModel.findDataById(userId);
  296. let versionInfo = userData ? userData.versionInfo ? userData.versionInfo : [] : [];
  297. response.json({error: 0, msg: 'success', data: versionInfo});
  298. }
  299. catch(error){
  300. response.json({error: 1, msg: error, data: null});
  301. }
  302. }
  303. /*
  304. * 获取用户信息
  305. * */
  306. async getUserByMobile(req, res){
  307. try{
  308. let userModel = new UserModel();
  309. let data = JSON.parse(req.body.data);
  310. let userData = await userModel.findDataByMobile(data.mobile);
  311. res.json({error: 0, msg: 'success', data: userData});
  312. }
  313. catch (err){
  314. res.json({error: 1, msg: err, data: null});
  315. }
  316. }
  317. async getUsers(req, res){
  318. try{
  319. let data = JSON.parse(req.body.data);
  320. let userObjIDs = [];
  321. for(let userID of data.userIDs){
  322. userObjIDs.push(mongoose.Types.ObjectId(userID));
  323. }
  324. let users = await userData.find({_id: {$in: userObjIDs}});
  325. res.json({error: 0, msg: 'success', data: users});
  326. }
  327. catch (err){
  328. res.json({error: 1, msg: err, data: null});
  329. }
  330. }
  331. /*
  332. * 更改用户账号登录方式
  333. * */
  334. async changeIsSmsLogin(request, response) {
  335. try{
  336. let status = request.body.status;
  337. let userModel = new UserModel();
  338. let userId = request.session.sessionUser.id;
  339. let result = await userModel.updateUser({ _id: userId }, { isSmsLogin: status });
  340. if (result) {
  341. response.json({error: 0, msg: 'success', data: null});
  342. } else {
  343. throw '更新失败';
  344. }
  345. }
  346. catch(error){
  347. response.json({error: 1, msg: error, data: null});
  348. }
  349. }
  350. /*
  351. * 更改异常登录通知
  352. * */
  353. async changeIsLoginValid(request, response) {
  354. try{
  355. let status = request.body.status;
  356. let userModel = new UserModel();
  357. let userId = request.session.sessionUser.id;
  358. let result = await userModel.updateUser({ _id: userId }, { isLoginValid: status });
  359. if (result) {
  360. response.json({error: 0, msg: 'success', data: null});
  361. } else {
  362. throw '更新失败';
  363. }
  364. }
  365. catch(error){
  366. response.json({error: 1, msg: error, data: null});
  367. }
  368. }
  369. async isFree(req, res) {
  370. try {
  371. const sessionVersion = req.session.compilationVersion;
  372. const userModel = new UserModel();
  373. const isFree = userModel.isFreeFromSession(sessionVersion);
  374. res.json({ error: 0, msg: 'success', data: { isFree } });
  375. } catch (err) {
  376. res.json({ error: 1, msg: String(err), data: null });
  377. }
  378. }
  379. // /**
  380. // * 是否时免费版用户
  381. // */
  382. // async isFree(request, response) {
  383. // try{
  384. // const compilationId = request.session.sessionCompilation.compilationId;
  385. // const userModel = new UserModel();
  386. // const userId = request.session.sessionUser.ssoId;
  387. // const userData = await userModel.findDataBySsoId(userId);
  388. // const upgrade_list = userData ? userData.upgrade_list : [];
  389. // let free = false;
  390. // if (upgrade_list && upgrade_list.length > 0) {
  391. // const upgrade = upgrade_list.find(function (item) {
  392. // return item.compilationID === compilationId && item.isUpgrade === true;
  393. // });
  394. // if (upgrade) {
  395. // free = true;
  396. // }
  397. // }
  398. // response.json({error: 0, data: free});
  399. // }
  400. // catch(error){
  401. // response.json({error: 1, msg: error, data: null});
  402. // }
  403. // }
  404. }
  405. module.exports = UserController;