algernon/user/index.lua

---
--- Generated by Luanalysis
--- Created by wh.
--- DateTime: 2023/11/9 10:39

findOne = function()
    content("application/json")
    local userId = formdata().userId
    local delimiter = ","
    local resultData = {
        error_code = 1,
        error_msg = "",
    }
    local dataList = {}
    for id in string.gmatch(userId, "([^" .. delimiter .. "]+)") do
        local query = "select  b.*  from   user_source  a INNER JOIN  user_channel_info  b on  a.user_id=b.user_id where  encryption_user_id=\"" .. id .. "\"   LIMIT 1 "
        local userResults = mysql(query, address())
        local data = {}
        if #userResults > 0 then
            local user = userResults[1]
            local user_mold = user.user_mold
            if user_mold == "1" or user_mold == "3" then
                data = {
                    registe_time = user.registe_time
                }
            else
                data = {
                    phone = user.phone,
                    registe_time = user.registe_time,
                    sales_lead_phone = user.sales_lead_phone,
                    sales_ent_name = user.sales_ent_name,
                    sales_position = user.sales_position,
                    sales_dep = user.sales_dep,
                    order_type = user.order_type,
                    source = user.source,
                    data_request = user.data_request,
                    last_login_time = user.last_login_time,
                    sales_leads_source = user.sales_leads_source
                }
            end
        end
        data.encryption_user_id = id
        table.insert(dataList, data)
    end
    resultData.data = dataList
    print(json(resultData))
end
userList = function()
    content("application/json")
    local resultData = {
        error_code = 1,
        error_msg = "",
    }
    local cursor = formdata().cursor
    local pageSizeInt = formdata().pageSize
    if tonumber(cursor) < 0 or tonumber(pageSizeInt) <= 0 or tonumber(pageSizeInt) > 100 then
        resultData.error_code = "1018"
        resultData.error_msg = "无效参数"
        print(json(resultData))
        return
    end
    local query = "select count(1) as count from  user_source a   where id >\"" .. cursor .. "\""
    local countResults = mysql(query, address())
    if #countResults > 0 then
        --查询数据
        query = "select encryption_user_id,id,create_time,login_way,platform,id,SUBSTRING_INDEX(ip,',',1) as ip  from  user_source    where id>\"" .. cursor .. "\" ORDER BY id limit 0," .. pageSizeInt
        local results = mysql(query, address())
        resultData.data = {
            userCount = countResults[1].count,
            userList = results
        }
    else
        resultData.data = {
            userCount = 0
        }
    end
    print(json(resultData))
end

detailsList = function()
    content("application/json")
    local cursor = formdata().cursor
    local pageSizeInt = formdata().pageSize
    local resultData = {
        error_code = 1,
        error_msg = "",
    }
    local dataList = {}
    local query = "select  count(1) as count from  user_channel_info  where  id > \"" .. cursor .. "\""
    local countResults = mysql(query, address())
    if #countResults > 0 then

    else
        resultData.data = {
            userCount = 0
        }
        print(json(resultData))
        return
    end
    --query = "select  * from  user_channel_info  where  id >  \"" .. cursor .. "\"    ORDER BY id LIMIT 0 ," .. pageSizeInt
    query="select a.id as  infoId, a.*,(select   b.encryption_user_id from  user_source b  where  a.user_id=b.user_id LIMIT 1) as encryption_user_id from  user_channel_info a where  a.id >\"" .. cursor .. "\"  ORDER BY a.id  LIMIT 0 ," .. pageSizeInt
    local userResults = mysql(query, address())
    for _,user in ipairs(userResults) do
        local user_mold = user.user_mold
        if user_mold == "1" or user_mold == "3" then
            data = {
                registe_time = user.registe_time,
            }
        else
            data = {
                phone = user.phone,
                registe_time = user.registe_time,
                sales_lead_phone = user.sales_lead_phone,
                sales_ent_name = user.sales_ent_name,
                sales_position = user.sales_position,
                sales_dep = user.sales_dep,
                order_type = user.order_type,
                source = user.source,
                data_request = user.data_request,
                last_login_time = user.last_login_time,
                sales_leads_source = user.sales_leads_source,
            }
        end
        data.encryption_user_id = user.encryption_user_id
        data.id=user.infoId
        table.insert(dataList, data)
    end
    resultData.data={
        userList=dataList,
        count=countResults[1].count
    }
    print(json(resultData))
end
handle("/user/list", userList)
handle("/user/findOne", findOne)
handle("/user/detailsList", detailsList)