From 1197277a20547f20836d0dd64812ceeb5549d182 Mon Sep 17 00:00:00 2001 From: rsgltzyd Date: Tue, 2 Jul 2024 21:30:47 +0800 Subject: [PATCH] add register --- app.js | 23 ++++---- dao/{userMapper.js => user.mapper.js} | 79 ++++++++++++++++---------- express.db | Bin 40960 -> 40960 bytes models/user.model.js | 12 +--- routes/index.js | 28 +++++++-- service/user.service.js | 41 +++++++++++++ utils/StringUtil.js | 2 +- 7 files changed, 128 insertions(+), 57 deletions(-) rename dao/{userMapper.js => user.mapper.js} (73%) diff --git a/app.js b/app.js index 28ddaf5..c2c7c0f 100644 --- a/app.js +++ b/app.js @@ -24,17 +24,17 @@ const loginSecret = process.env.SESSION_SECRET; // const databasePassword = process.env.DB_PASSWORD; // mongodbConfig.connectMongoDB(databaseAccount, databasePassword); -const userMapper = require('./dao/userMapper'); +// const userMapper = require('./dao/userMapper'); -( - async () => { - try { - await userMapper.updatePassword('333', 7); - } catch (error) { - console.error(error); - } - } -)(); +// ( +// async () => { +// try { +// await userMapper.updatePassword('333', 7); +// } catch (error) { +// console.error(error); +// } +// } +// )(); app.use(logger('dev')); app.use(express.json()); @@ -52,7 +52,8 @@ app.use(session({ }, })); -app.use('/', loginUtils.aopMiddleware, indexRouter); +// app.use('/', loginUtils.aopMiddleware, indexRouter); +app.use('/', indexRouter); // catch 404 and forward to error handler app.use(function (req, res, next) { diff --git a/dao/userMapper.js b/dao/user.mapper.js similarity index 73% rename from dao/userMapper.js rename to dao/user.mapper.js index 2c37aff..f448dd4 100644 --- a/dao/userMapper.js +++ b/dao/user.mapper.js @@ -2,24 +2,17 @@ const sqlite = require('../db/sqlite.config'); const User = require("../models/user.model"); /** - * - * @param {*} id - * @returns + * 查询用户 - account + * @param {*} account + * @returns {User} */ -exports.selectById = async (id) => { +exports.selectByAccount = async (account) => { let db; try { db = await sqlite.connectSqlite(); - db.all('SELECT * FROM USERS WHERE `id` = ?', [id], async function (err, rows) { - if (err) { - console.error(err); - } - return await getUser(rows); - }); - const rows = await new Promise((resolve, reject) => { - db.all('SELECT * FROM USERS WHERE `id` = ?', [id], (err, rows) => { + db.all('SELECT * FROM USERS WHERE `USER_ACCOUNT` = ?', [account], (err, rows) => { if (err) { reject(err); } else { @@ -28,7 +21,7 @@ exports.selectById = async (id) => { }); }); - return await getUser(rows); + return (await getUser(rows))[0]; } catch (err) { throw err; } finally { @@ -41,7 +34,39 @@ exports.selectById = async (id) => { }; /** - * + * 查询用户 - id + * @param {*} id + * @returns {User} + */ +exports.selectById = async (id) => { + let db; + + try { + db = await sqlite.connectSqlite(); + const rows = await new Promise((resolve, reject) => { + db.all('SELECT * FROM USERS WHERE `id` = ?', [id], (err, rows) => { + if (err) { + reject(err); + } else { + resolve(rows); + } + }); + }); + + return await getUser(rows)[0]; + } catch (err) { + throw err; + } finally { + try { + await db.close(); + } catch (error) { + throw err; + } + } +}; + +/** + * 查询用户 - name * @param {*} name * @returns */ @@ -52,7 +77,7 @@ exports.selectByName = async (name) => { db = await sqlite.connectSqlite(); const rows = await new Promise((resolve, reject) => { - db.all('SELECT * FROM USERS', async function (err, rows) { + db.all('SELECT * FROM USERS WHERE = ?', [name], async function (err, rows) { if (err) { reject(err); } @@ -99,20 +124,20 @@ exports.selectAllUser = async () => { } /** - * - * @param {*} User + * 新增用户 + * @param {User} _user */ -exports.insertUser = async (User) => { +exports.insertUser = async (_user) => { let db; try { db = await sqlite.connectSqlite(); - const user = await new Promise((resolve, reject) => { + const u = await new Promise((resolve, reject) => { db.run('INSERT \ INTO USERS(USER_ACCOUNT, USER_NAME, PASSWORD, EMAIL, MOBILE) \ VALUES(?, ?, ?, ?, ?)', - [User.user_account, User.user_name, User.password, User.email, User.mobile], + [_user.user_account, _user.user_name, _user.password, _user.email, _user.mobile], async function (err) { if (err) { reject(err); @@ -122,6 +147,7 @@ exports.insertUser = async (User) => { }); }); + console.log("新增成功", u.toString()); } catch (error) { throw error } finally { @@ -133,7 +159,7 @@ exports.insertUser = async (User) => { } } -/** +/** 修改密码 * @param password * @param userId */ @@ -173,16 +199,7 @@ getUser = async (rows) => { let users = new Array(); rows.map((value, index) => { - users[index] = new User( - value.id, - value.user_account, - value.user_name, - value.password, - value.email, - value.mobile, - value.status, - value.create_time, - value.update_time); + users[index] = new User(value); }); return users; diff --git a/express.db b/express.db index 172ac24c50c5469629d9b4cba30c3ae782ee203e..af6613293099663e7bb578152c0beeedd573397f 100644 GIT binary patch delta 367 zcmZoTz|?SnX@WGP;Y1l{M#GH>OZXM|xWBUSujUWq=i@uh*T84a`-XQ3Z#1tE&k3F; z9!u`8n-v8va@RYFa50EV3NkQA8XG4jB_$gg8W|fJ85;We2l+bs7#SFu=o*;o8W<@U z8Cn^cS(zGQ5poyiVvvWKk(_L7Y;0j^iPs<_E1)#U>=1ylkgd1Xkle! zgz6r!(B=~|kC}x0*|`|R`33bsJ}XHrE-^BkyieX<$k58fkc)wVfsa3efj@#jpFeRk phk_Ts5(l#=BPakwc$wuH6Jfp(=39-0niY#(S000H&P*4B> delta 110 zcmV-!0FnQIzyg540+1U4Es-2U0WGm$qz@Vk49Eiys}EKW4i3i-fDShe> { + let messageMap = new Map(); + + // console.log(user ); + const _user = user; + + if (_user == null) { + throw new Error("用户参数不能为空"); + } + + if (StringUtil.isNotEmpty(_user.getUserAccount)) { + messageMap.set("userMsg", "账号不能为空"); + return messageMap; + } + if (StringUtil.isNotEmpty(_user.getUserName)) { + messageMap.set("userMsg", "名称不能为空"); + return messageMap; + } + if (StringUtil.isNotEmpty(_user.getPassword)) { + messageMap.set("userMsg", "密码不能为空"); + return messageMap; + } + + const u = await userMapper.selectByAccount(_user.user_account); + if (u != null) { + messageMap.set("userMsg", "账户已存在"); + return messageMap; + } + await userMapper.insertUser(_user); + messageMap.set("userMsg", "succuss"); + return messageMap; +} \ No newline at end of file diff --git a/utils/StringUtil.js b/utils/StringUtil.js index e7c4026..e4335f8 100644 --- a/utils/StringUtil.js +++ b/utils/StringUtil.js @@ -1,5 +1,5 @@ /** - * + * 判断是否为空 * @param {*} obj 任意值 * @returns {Boolean} obj是否为空 */