From 9fdf745a3aed238f267ca1291d1feb062cb50d3d Mon Sep 17 00:00:00 2001
From: wanglei <34475144@qqcom>
Date: Tue, 21 Oct 2025 10:40:44 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=87=BD=E6=95=B0=E6=8A=A5?=
 =?UTF-8?q?=E9=94=99=E8=BF=94=E5=9B=9E=E5=A4=84=E7=90=86=EF=BC=8C=E5=B9=B6?=
 =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=96=B0=E5=A2=9E=E7=94=A8=E6=88=B7=E7=9A=84?=
 =?UTF-8?q?=E5=86=99=E5=85=A5=E6=95=B0=E6=8D=AE=E5=BA=93=E6=8E=A5=E5=8F=A3?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=87=BD=E6=95=B0=E8=BF=9B=E8=A1=8C=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E5=BA=93=E7=9A=84=E4=BF=A1=E6=81=AF=E5=86=99=E5=85=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/service/system/user.lua | 35 ++++++++++++++++++++++++++---------
 1 file changed, 26 insertions(+), 9 deletions(-)

diff --git a/src/service/system/user.lua b/src/service/system/user.lua
index 632c80f..837f50c 100644
--- a/src/service/system/user.lua
+++ b/src/service/system/user.lua
@@ -17,7 +17,7 @@ local function get_con(cfg)
     ---- 连接到数据库
     local ok, err = conn:connect()
     if not ok then
-        error("Connection failed: " .. err)
+        print("Connection failed: " .. err)
         code = 0x000002
     end
     --ngx.say("Connection success")
@@ -35,8 +35,8 @@ function _M.getAllUser()
     --执行数据库操作
     local res = conn:query(sql)
     if not res then
-        error("Query failed: " .. err)
-        code = 0x000003
+        print("get all users Query failed: "..sql)
+        return 0x000003,res
     end
     --整理数据库结果返回值
     --for _, row in ipairs(res) do
@@ -60,8 +60,8 @@ function _M.getUser(id)
     --执行数据库操作
     local res = conn:query(sql)
     if not res then
-        error("Query failed: " .. err)
-        code = 0x000003
+        print("Query failed: "..sql)
+        return 0x000003,res
     end
     --关闭数据库
     conn:disconnect()
@@ -78,14 +78,31 @@ function _M.addUser(jsonData)
     if success == false then
         return 0x000001,res
     end
+    --解析json中的键和数据值
+    local keys = ""
+    local values = ""
+    for key, value in pairs(result) do
+        keys = keys..key
+        local val = type(value)
+        if val == "string" then
+            values = values.."\'"..value.."\'"
+        else
+            values = values..value
+        end
+        keys = keys..","
+        values = values..","
+    end
+    local newKeys = keys:sub(1, #keys -1)
+    local newValues = values:sub(1, #values -1)
     --组装sql语句
-    local sql = "select * from \"T_Users\""
+    local sql = string.format("insert into \"T_Users\"(%s)values(%s)", newKeys, newValues)
+    --ngx.say(sql)
     --获取数据库连接
     local code,conn = get_con(dbconf.postgres)
     --执行数据库操作
     res = conn:query(sql)
     if not res then
-        error("Query failed: " .. err)
+        print("adduser sql failed: "..sql)
         return 0x000003,res
     end
     --关闭数据库
@@ -102,8 +119,8 @@ function _M.delete_user(id)
     --执行数据库操作
     local res = conn:query(sql)
     if not res then
-        error("exec sql failed: " .. err)
-        code = 0x000003
+        print("delete exec sql failed: "..sql)
+        return 0x000003,res
     end
     --关闭数据库
     conn:disconnect()