user_controller.js 12 KB

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