123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435 |
- /**
- * 用户相关控制器
- *
- * @author CaiAoLin
- * @date 2017/6/13
- * @version
- */
- const UserModel = require("../models/user_model");
- const BaseController = require("../../common/base/base_controller");
- const LogType = require("../../common/const/log_type_const");
- const LogModel = require("../models/log_model");
- const SettingModel = require("../models/setting_model");
- const SettingType = require("../../common/const/setting_type_const");
- const CompilationModel = require("../models/compilation_model");
- const getValuationBasisURL = require('../../common/const/valuationBasis');
- const mongoose = require("mongoose");
- const moment = require("moment");
- const userData = mongoose.model('user');
- class UserController extends BaseController {
- /**
- * 用户信息页面
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async info(request, response) {
- // 获取当前用户数据
- let sessionUser = request.session.sessionUser;
- let userModel = new UserModel();
- let userData = await userModel.findDataBySsoId(sessionUser.ssoId);
- userData = Object.keys(userData).length <= 0 ? [] : userData;
- let renderData = {
- userData: userData,
- provinceList: userModel.province,
- companyTypeList: userModel.companyType,
- companyScaleList: userModel.companyScale,
- compilationName: request.session.sessionCompilation.name,
- valuationBasisURL: getValuationBasisURL(request.session.sessionCompilation.name),
- versionName: request.session.compilationVersion,
- };
- response.render('users/html/user-info', renderData);
- }
- /**
- * 保存个人数据
- *
- * @param {object} request
- * @param {object} response
- * @return
- */
- async saveData(request, response) {
- try {
- let updateData = {
- real_name: request.body.real_name,
- province: request.body.province,
- company: request.body.company,
- version: request.body.version ? request.body.version : null,
- company_type: request.body.company_type ? request.body.company_type : null,
- company_scale: request.body.company_scale ? request.body.company_scale : null,
- };
- let sessionUser = request.session.sessionUser;
- // 切换验证场景
- let userModel = new UserModel();
- let condition = {ssoId: sessionUser.ssoId};
- userModel.setScene('saveInfo');
- let result = await userModel.updateUser(condition, updateData);
- //更新session
- for(let attr in sessionUser){
- sessionUser[attr] = updateData[attr] ? updateData[attr] : sessionUser[attr];
- }
- if (result.ok !== 1) {
- throw '用户数据保存失败';
- }
- } catch (error) {
- return response.redirect(request.headers.referer);
- }
- response.redirect('/pm');
- }
- /**
- * 账号安全页面
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async safe(request, response) {
- let userData = [];
- let logList = [];
- let pageData = {};
- try {
- // 获取当前用户信息
- let sessionUser = request.session.sessionUser;
- console.log(sessionUser);
- let userModel = new UserModel();
- userData = await userModel.findDataBySsoId(sessionUser.ssoId);
- console.log(userData);
- let page = request.query.page === undefined ? 1 : request.query.page;
- // 获取登录信息
- let logModel = new LogModel();
- let logCount = await logModel.count();
- logCount = logCount > 30 ? 30 : logCount;
- let pageSize = 10;
- logList = await logModel.getLog(sessionUser.id, LogType.LOGIN_LOG, page, pageSize);
- // 分页数据
- pageData = {
- current: page,
- total: parseInt(logCount / pageSize),
- queryData: response.locals.urlQuery
- };
- } catch (error) {
- console.log(error);
- }
- let renderData = {
- userData: userData,
- logList: logList,
- pages: pageData,
- compilationName: request.session.sessionCompilation.name,
- valuationBasisURL: getValuationBasisURL(request.session.sessionCompilation.name),
- versionName: request.session.compilationVersion,
- };
- response.render('users/html/user-safe', renderData);
- }
- /**
- * 产品激活页面
- *
- * @param request
- * @param response
- * @return {void}
- */
- async buy(request, response) {
- let userData = [];
- let compilationList = [];
- try {
- // 获取编办信息
- let compilationModel = new CompilationModel();
- compilationList = await compilationModel.getList();
- // 获取当前用户信息
- let sessionUser = request.session.sessionUser;
- let userModel = new UserModel();
- userData = await userModel.findDataBySsoId(sessionUser.ssoId);
- if (userData.upgrade_list !== undefined) {
- let userUpgradeList = userData.upgrade_list;
- for (let index in userUpgradeList) {
- let oneCompilationIndex = compilationList.findIndex(function (item) {
- return item.id === userUpgradeList[index].compilationID;
- });
- if (oneCompilationIndex !== -1) {
- compilationList[oneCompilationIndex].isUpgrade = userUpgradeList[index].isUpgrade;
- compilationList[oneCompilationIndex].deadline = userUpgradeList[index].deadline;
- compilationList[oneCompilationIndex].lock = userUpgradeList[index].lock;
- }
- }
- }
- } catch(error) {
- console.log(error);
- }
- let renderData = {
- userData: userData,
- compilationList: compilationList,
- compilationName: request.session.sessionCompilation.name,
- valuationBasisURL: getValuationBasisURL(request.session.sessionCompilation.name),
- versionName: request.session.compilationVersion,
- };
- response.render('users/html/user-buy', renderData);
- }
- /**
- * 偏好设置页面
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async preferences(request, response) {
- let sessionUserData = request.session.sessionUser;
- let preferenceSetting = {};
- let compilationList = [];
- try {
- // 获取配置信息
- let settingModel = new SettingModel();
- preferenceSetting = await settingModel.getPreferenceSetting(sessionUserData.id);
- // 获取编办信息
- let compilationModel = new CompilationModel();
- compilationList = await compilationModel.getList();
- } catch(error) {
- console.log(error);
- }
- let renderData = {
- preferenceSetting: preferenceSetting,
- compilationList: compilationList,
- compilationName: request.session.sessionCompilation.name,
- valuationBasisURL: getValuationBasisURL(request.session.sessionCompilation.name),
- versionName: request.session.compilationVersion,
- };
- response.render('users/html/user-set', renderData);
- }
- /**
- * 保存偏好设置
- *
- * @param {object} request
- * @param {object} response
- * @return {void}
- */
- async savePreferences(request, response) {
- let loginAsk = request.body.login_ask;
- loginAsk = parseInt(loginAsk);
- let selectVersion = request.body.select_version;
- let sessionUserData = request.session.sessionUser;
- try {
- let data = {
- login_ask: loginAsk,
- select_version: loginAsk === 0 ? selectVersion : ''
- };
- let settingModel = new SettingModel();
- let result = await settingModel.save(sessionUserData.id, SettingType.PREFERENCE, data);
- if (!result) {
- throw '保存失败';
- }
- // 保存编办信息到session
- if (data.login_ask === 1) {
- // 查找对应编办
- let compilationModel = new CompilationModel();
- let compilationData = await compilationModel.getCompilationById(selectVersion);
- // 判断当前用户的是使用免费版还是专业版
- let userModel = new UserModel();
- let compilationVersion = await userModel.getVersionFromUpgrade(sessionUserData.ssoId, compilationData._id);
- request.session.compilationVersion = compilationVersion.version;
- request.session.sessionUser.compilationLock = compilationVersion.lock;
- request.session.sessionCompilation = compilationData;
- }
- } catch (error) {
- console.log(error);
- }
- response.redirect(request.headers.referer);
- }
- /*
- * 版本激活
- * */
- async activateVersion(request, response){
- try{
- let userModel = new UserModel();
- let sessionUser = request.session.sessionUser;
- let data = JSON.parse(request.body.data);
- let activateCode = data.activateCode,
- compilationId = data.compilationId;
- let isActivated = true;//调激活接口
- if(!isActivated){
- throw '激活失败';
- }
- //激活成功,更新入库
- let userObjId = mongoose.Types.ObjectId(sessionUser.id);
- let versionInfo = {};
- versionInfo.compilationId = compilationId;
- versionInfo.activatedDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- //失效信息{invalid: boolean, invalidDate: String}
- versionInfo.invalidInfo = null;
- await userModel.addVersion({_id: userObjId}, versionInfo);
- response.json({error: 0, msg: 'success'});
- }
- catch (error){
- response.json({error: 1, msg: error})
- }
- }
- /*
- * 更新版本状态
- * */
- async updateVersionState(request, response){
- try{
- let userModel = new UserModel();
- let activated = request.body.activated,
- userId = request.body.userId,
- compilationId = request.body.compilationId;
- if(activated){
- let versionInfo = {};
- versionInfo.compilationId = compilationId;
- versionInfo.activatedDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
- versionInfo.invalidInfo = null;
- await userModel.addVersion({_id: mongoose.Types.ObjectId(userId)}, versionInfo);
- }
- else{
- await userModel.removeVersion(userId, compilationId);
- }
- response.json({error: 0, msg: 'success'});
- }
- catch (error){
- response.json({error: 1, msg: error});
- }
- }
- /*
- * 获取用户版本信息
- * */
- async getVersionInfo(request, response){
- try{
- let userModel = new UserModel();
- let userId = request.session.sessionUser.id;
- let userData = await userModel.findDataById(userId);
- let versionInfo = userData ? userData.versionInfo ? userData.versionInfo : [] : [];
- response.json({error: 0, msg: 'success', data: versionInfo});
- }
- catch(error){
- response.json({error: 1, msg: error, data: null});
- }
- }
- /*
- * 获取用户信息
- * */
- async getUserByMobile(req, res){
- try{
- let userModel = new UserModel();
- let data = JSON.parse(req.body.data);
- let userData = await userModel.findDataByMobile(data.mobile);
- res.json({error: 0, msg: 'success', data: userData});
- }
- catch (err){
- res.json({error: 1, msg: err, data: null});
- }
- }
- async getUsers(req, res){
- try{
- let data = JSON.parse(req.body.data);
- let userObjIDs = [];
- for(let userID of data.userIDs){
- userObjIDs.push(mongoose.Types.ObjectId(userID));
- }
- let users = await userData.find({_id: {$in: userObjIDs}});
- res.json({error: 0, msg: 'success', data: users});
- }
- catch (err){
- res.json({error: 1, msg: err, data: null});
- }
- }
- /*
- * 更改用户账号登录方式
- * */
- async changeIsSmsLogin(request, response) {
- try{
- let status = request.body.status;
- let userModel = new UserModel();
- let userId = request.session.sessionUser.id;
- let result = await userModel.updateUser({ _id: userId }, { isSmsLogin: status });
- if (result) {
- response.json({error: 0, msg: 'success', data: null});
- } else {
- throw '更新失败';
- }
- }
- catch(error){
- response.json({error: 1, msg: error, data: null});
- }
- }
- /*
- * 更改异常登录通知
- * */
- async changeIsLoginValid(request, response) {
- try{
- let status = request.body.status;
- let userModel = new UserModel();
- let userId = request.session.sessionUser.id;
- let result = await userModel.updateUser({ _id: userId }, { isLoginValid: status });
- if (result) {
- response.json({error: 0, msg: 'success', data: null});
- } else {
- throw '更新失败';
- }
- }
- catch(error){
- response.json({error: 1, msg: error, data: null});
- }
- }
- async isFree(req, res) {
- try {
- const sessionVersion = req.session.compilationVersion;
- const userModel = new UserModel();
- const isFree = userModel.isFreeFromSession(sessionVersion);
- res.json({ error: 0, msg: 'success', data: { isFree } });
- } catch (err) {
- res.json({ error: 1, msg: String(err), data: null });
- }
- }
- // /**
- // * 是否时免费版用户
- // */
- // async isFree(request, response) {
- // try{
- // const compilationId = request.session.sessionCompilation.compilationId;
- // const userModel = new UserModel();
- // const userId = request.session.sessionUser.ssoId;
- // const userData = await userModel.findDataBySsoId(userId);
- // const upgrade_list = userData ? userData.upgrade_list : [];
- // let free = false;
- // if (upgrade_list && upgrade_list.length > 0) {
- // const upgrade = upgrade_list.find(function (item) {
- // return item.compilationID === compilationId && item.isUpgrade === true;
- // });
- // if (upgrade) {
- // free = true;
- // }
- // }
- // response.json({error: 0, data: free});
- // }
- // catch(error){
- // response.json({error: 1, msg: error, data: null});
- // }
- // }
- }
- module.exports = UserController;
|