From da2d95a9b432a6aa7d652de10aba3e7210c0e4ed Mon Sep 17 00:00:00 2001 From: wanglei <34475144@qqcom> Date: Thu, 23 Oct 2025 11:14:19 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E8=B4=A6=E5=8F=B7=E7=9B=B8?= =?UTF-8?q?=E5=85=B3=E6=8E=A5=E5=8F=A3=EF=BC=8C=E5=92=8C=E7=9B=B8=E5=85=B3?= =?UTF-8?q?=E7=9A=84=E4=B8=9A=E5=8A=A1=E9=80=BB=E8=BE=91=E4=BB=A3=E7=A0=81?= =?UTF-8?q?=EF=BC=8C=E5=B9=B6=E4=BF=AE=E6=94=B9=E6=8E=A5=E5=8F=A3=E7=9B=B8?= =?UTF-8?q?=E5=85=B3=E5=87=BD=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- conf/system/account.conf | 4 + src/api/api.lua | 33 ++++++++ src/api/system/account.lua | 76 +++++++++++++++++ src/service/system/account.lua | 145 +++++++++++++++++++++++++++++++++ src/service/system/user.lua | 10 +-- 5 files changed, 263 insertions(+), 5 deletions(-) create mode 100644 conf/system/account.conf create mode 100644 src/api/system/account.lua create mode 100644 src/service/system/account.lua diff --git a/conf/system/account.conf b/conf/system/account.conf new file mode 100644 index 0000000..837330c --- /dev/null +++ b/conf/system/account.conf @@ -0,0 +1,4 @@ +#API接口文件 +location /api { + content_by_lua_file '/home/frankly/work/AuthPlatform/src/api/api.lua'; +} \ No newline at end of file diff --git a/src/api/api.lua b/src/api/api.lua index 4cefdc9..27c98dc 100644 --- a/src/api/api.lua +++ b/src/api/api.lua @@ -5,9 +5,11 @@ --- local radix = require("resty.radixtree") local userApi = require("api.system.user") +local accountApi = require("api.system.account") --定义相关路由，前端接口url地址 local routes = { + --用户相关路由接口 { paths = { "/api/get-users" }, metadata = { "metadata get-users" }, @@ -38,6 +40,37 @@ local routes = { methods = { "PUT" }, handler = userApi.update_user, }, + --账户相关路由接口 + { + paths = { "/api/get-account" }, + metadata = { "metadata get-account" }, + methods = { "GET" }, + handler = accountApi.get_allaccounts, + }, + { + paths = { "/api/get-account/:id" }, + metadata = { "metadata /api/get-account/id" }, + methods = { "GET" }, + handler = accountApi.get_account, + }, + { + paths = { "/api/delete-account/:id" }, + metadata = { "metadata /api/delete-account/id" }, + methods = { "DELETE" }, + handler = accountApi.delete_account, + }, + { + paths = { "/api/add-account" }, + metadata = { "metadata /api/add-account" }, + methods = { "POST" }, + handler = accountApi.add_account, + }, + { + paths = { "/api/update-account/:id" }, + metadata = { "metadata /api/update-account/id" }, + methods = { "PUT" }, + handler = accountApi.update_account, + }, } -- 初始化路由 diff --git a/src/api/system/account.lua b/src/api/system/account.lua new file mode 100644 index 0000000..ac374e3 --- /dev/null +++ b/src/api/system/account.lua @@ -0,0 +1,76 @@ +--- +--- Generated by EmmyLua(https://github.com/EmmyLua) +--- Created by admin. +--- DateTime: 2025/9/25 08:19 +--- + +local _M = {} + +local dao = require("service.system.user") +local resp = require("util.response") + +--验证请求头是否正确 +local function checkReqHeader() + local headers = ngx.req.get_headers() + if headers["content-type"] ~= "application/json" then + local result = resp:json(0x000001) + resp:send(result) + return false + end + return true +end + +--获取所有用户信息 +function _M.get_allaccount(uuid) + local code,ret = dao.getAllAccount(uuid) + local result = resp:json(code, ret) + resp:send(result) +end + +--根据用户id获取用户信息 +function _M.get_account(m) + local id = m.id + local code,ret = dao.getAccount(id) + local result = resp:json(code, ret) + resp:send(result) +end + +--根据用户id获取用户信息 +function _M.add_account() + --获取请求头并进行校验 + if checkReqHeader() == false then + return + end + --读取请求体的数据 + ngx.req.read_body() + --获取请求数据 + local body_data = ngx.req.get_body_data() + --判断请求体数据是否为空 + if body_data == nil then + local result = resp:json(0x000001) + resp:send(result) + return + end + --ngx.say(body_data) + local code, ret = dao.addAccount(body_data) + local result = resp:json(code, ret) + resp:send(result) +end + +--根据用户id删除用户信息 +function _M.delete_account(m) + local id = m.id + local code, ret = dao.deleteAccount(id) + local result = resp:json(code, ret) + resp:send(result) +end + +--根据用户id删除用户信息 +function _M.update_account(m) + local id = m.id + local code, ret = dao.updateAccount(id) + local result = resp:json(code, ret) + resp:send(result) +end + +return _M \ No newline at end of file diff --git a/src/service/system/account.lua b/src/service/system/account.lua new file mode 100644 index 0000000..7933cb6 --- /dev/null +++ b/src/service/system/account.lua @@ -0,0 +1,145 @@ +--- +--- Generated by EmmyLua(https://github.com/EmmyLua) +--- Created by . +--- DateTime: 2025/9/25 08:19 +--- 业务逻辑 对用户数据表进行数据表业务处理 +local cjson = require('cjson') +local pgmoon = require('pgmoon') +local dbconf = require("config.database") +local status = require("config.status") +local snowflake = require("util.snowflake") + +local _M = {} + +--获取一个数据库操作连接 +local function get_con(cfg) + local code = 0 + -- 创建一个新的连接 + local conn = pgmoon.new(cfg); + ---- 连接到数据库 + local ok, err = conn:connect() + if not ok then + print("Connection failed: " .. err) + code = 0x000002 + end + --ngx.say("Connection success") + return code,conn +end + +local function getUuid() + local workerId = 0 -- 假设当前机器的ID是1，范围在[0, 31]之间 + local datacenterId = 0 -- 数据中心ID，范围在[0, 31]之间 + local snow = snowflake.new(workerId, datacenterId) + local id = snow:generateUniqueId()-- 生成ID + --print("Generated ID:", snow.int64_to_string(id)) + return snow.int64_to_string(id) +end + +--数据库执行sql语句 +local function execSQL(sql) + local res = nil + if sql == '' or sql == nil then + return 0x000003,res + end + --获取数据库连接 + local code,conn = get_con(dbconf.postgres) + if code ~= 0 then + return 0x000003,res + end + --执行数据库操作 + res = conn:query(sql) + if not res then + print("query sql failed: "..sql) + return 0x000003,res + end + --关闭数据库 + conn:disconnect() + return code,res +end + +--校验json数据的正确性，并返回json解析后的数据 +local function checkJson(jsonData) + local success, result = pcall(function() + return cjson.decode(jsonData) + end) + if success == true then + return true, result + end + local res = nil + return false,res +end + +--通过查询条件判断数据库中的数据记录 +--根据用户、手机号、邮箱进行验证用户是否存在 +local function checkAccountExist(username, phone, email) + --组装sql语句 + local where = string.format("where username='%s' or phone='%s' or email='%s'", username, phone, email) + local sql = string.format("select count(*) as count from \"T_Users\" %s", where) + print("check sql: "..sql) + --获取数据库连接 + return execSQL(sql) +end + +-- 查询数据表中的所有账户根据用户的uuid +function _M.getAllAccount(uuid) + --组装sql语句 + local sql = "select * from \"T_Users\"" + return execSQL(sql) +end + +--根据用户id获取用户信息 +function _M.getAccount(uuid) + --组装sql语句 + local sql = "select * from \"T_Users\" where uuid='"..uuid.."'" + return execSQL(sql) +end + +--增加用户信息到数据表 +function _M.addAccount(jsonData) + --验证数据的正确性，错误时返回 + local success, result = checkJson(jsonData) + if success == false then + return 0x000001,result + end + --解析json中的键和数据值 + local keys = "" + local values = "" + local username, phone, email + for key, value in pairs(result) do + keys = keys..key.."," + values = values..((type(value) == "string") and "'"..value.."'" or value).."," + if key == "username" then username = value end + if key == "phone" then phone = value end + if key == "email" then email = value end + end + --校验用户是否存在 + local ok, res = checkAccountExist(username, phone, email) + if ok ~= 0 then + return 0x000001,res + end + local num = 0 + for _, row in ipairs(res) do + for key, value in pairs(row) do + num = value + end + end + print("exec result:", num) + if num > 0 then + return 0x010000,nil + end + --自己增加对应的uuid数据值 + local newKeys = keys.."uuid" + local newValues = values.."'"..getUuid().."'" + --组装sql语句 + local sql = string.format("insert into \"T_Users\"(%s)values(%s)", newKeys, newValues) + return execSQL(sql) +end + +--增加用户信息到数据表 +function _M.deleteAccount(uuid) + --组装sql语句 + local sql = "delete from \"T_Users\" where uuid='"..uuid.."'" + return execSQL(sql) +end + +return _M diff --git a/src/service/system/user.lua b/src/service/system/user.lua index a51267f..824aec9 100644 --- a/src/service/system/user.lua +++ b/src/service/system/user.lua @@ -88,9 +88,9 @@ function _M.getAllUser() end --根据用户id获取用户信息 -function _M.getUser(uuid) +function _M.getUser(id) --组装sql语句 - local sql = "select * from \"T_Users\" where uuid='"..uuid.."'" + local sql = "select * from \"T_Users\" where id='"..id.."'" return execSQL(sql) end @@ -128,7 +128,7 @@ function _M.addUser(jsonData) return 0x010000,nil end --自己增加对应的uuid数据值 - local newKeys = keys.."uuid" + local newKeys = keys.."id" local newValues = values.."'"..getUuid().."'" --组装sql语句 local sql = string.format("insert into \"T_Users\"(%s)values(%s)", newKeys, newValues) @@ -136,9 +136,9 @@ function _M.addUser(jsonData) end --增加用户信息到数据表 -function _M.delete_user(uuid) +function _M.delete_user(id) --组装sql语句 - local sql = "delete from \"T_Users\" where uuid='"..uuid.."'" + local sql = "delete from \"T_Users\" where id='"..id.."'" return execSQL(sql) end