数据同步接口返回处理整理

nginx/lua/luabiz/tk_sync.lua

@@ -171,35 +171,57 @@ end
 -- 数据同步接口
 -- @param nil
 -- @return ngx.say
-function TK_SYNC.sync()
+local function tk_sync()
   local dbs_st = zx_base:db_read(db_conf)
+  local code
+  local mesg
 
   if ngx.req.get_method() ~= "POST" then
-    ngx.say(json.encode({mesgRetCode="A7", mesgRetDesc="invalid method"}))
+    code = "A7"
+    mesg = "invalid method"
 
   else
     local data = json.decode(ngx.var.request_body)
 
     if data.mesgType ~= "table_sync" then
-      ngx.say(json.encode({mesgRetcode="N1", mesgRetDesc="mesgType invalid"}))
+      code = "N1"
+      mesg = "invalid mesgType"
 
     elseif data.dbHost == ngx.null then
-      ngx.say(json.encode({mesgRetCode="N0", mesgRetDesc="dbHost missing"}))
+      code = "N0"
+      mesg = "database host missing"
 
     else
       for i = 1, #dbs_st.tk_biz do
         if dbs_st.tk_biz[i].host == data.dbHost then
           if data.dbTable == ngx.null then
-            ngx.say(json.encode({mesgRetCode="N0", mesgRetDesc="dbTable missing"}))
+            code = "N0"
+            mesg = "database table missing"
+            return code, mesg
+
           else
             async(dbs_st.tk_biz[i], dbs_st.tk_control, dbs_st.tk_biz[i].database, data.dbTable)
-            return ngx.say(json.encode({mesgRetCode="00", mesgRetDesc="SUCCESS"}))
+
+            code = "00"
+            mesg = "SUCCESS"
+            return code, mesg
           end
         end
       end
-      ngx.say(json.encode({mesgRetCode="N1", mesgRetDesc="dbHost invalid"}))
+
+      code = "N1"
+      mesg = "database host invalid"
     end
   end
+  -- ngx.say(json.encode({mesgRetCode=code, mesgRetMesg=mesg}))
+  return code, mesg
+end
+
+
+function TK_SYNC.sync()
+  local code, mesg = tk_sync()
+
+  ngx.say(json.encode({mesgRetCode=code, mesgRetMesg=mesg}))
   ngx.eof()
 end