Merge remote-tracking branch 'origin/cn/develop' into cn/develop

zhangqijia
2 parents 041ee0b2 6f2c24ed
Showing 3 changed files with 59 additions and 20 deletions Show diff stats
src/actions/HeroAction.lua
src/utils/CommonFunc.lua
src/utils/MysqlUtil.lua
@@ -867,7 +867,7 @@ function _M.drawHeroRpc(agent, data)
 	if not unitPool then return 7 end
     -- ssr硬性保底
     local isSSRup = false
-    if unitPool["rare_"..HeroQuality.SSR] or 0 > 0 then
+    if (unitPool["rare_"..HeroQuality.SSR] or 0) > 0 then
         isSSRup = true
     end
  
@@ -878,34 +878,57 @@ function _M.drawHeroRpc(agent, data)
 		local values = {}
  
         -- check ssr up
-        if isSSRup then
-            local ssrUpMap = role:getProperty("ssrUp") or {}
-            local ssrFloorCnt = ssrUpMap[poolId] or 0
-            if ssrFloorCnt >= (globalCsv.draw_ssr_guarantee or 40) - 1 then
+        local ssrUpMap = role:getProperty("ssrUp") or {}
+        local ssrFloorCnt = ssrUpMap[poolId] or 0
+        if isSSRup and (ssrFloorCnt >= (globalCsv.draw_ssr_guarantee or 40) - 1) then
+            --if ssrFloorCnt >= (globalCsv.draw_ssr_guarantee or 40) - 1 then
                 values[1] = HeroQuality.SSR
                 ssrUpMap[poolId] = 0
-            else
-                for idx, field in ipairs(condition) do
-                    if not values[idx] then
-                        local lpool = {}
-                        local curIdx = 1
-                        while unitPool[field .. "_" .. curIdx] do
-                            lpool[curIdx] = {unitPool[field .. "_" .. curIdx]}
-                            curIdx = curIdx + 1
-                        end
-
-                        if next(lpool) then
-                            values[idx] =  math.randWeight(lpool, 1)
-                        end
+            --else
+            --    for idx, field in ipairs(condition) do
+            --        if not values[idx] then
+            --            local lpool = {}
+            --            local curIdx = 1
+            --            while unitPool[field .. "_" .. curIdx] do
+            --                lpool[curIdx] = {unitPool[field .. "_" .. curIdx]}
+            --                curIdx = curIdx + 1
+            --            end
+
+            --            if next(lpool) then
+            --                values[idx] =  math.randWeight(lpool, 1)
+            --            end
+            --        end
+            --    end
+            --    if values[1] == HeroQuality.SSR then
+            --        ssrUpMap[poolId] = 0
+            --    else
+            --        ssrUpMap[poolId] = ssrFloorCnt + 1
+            --    end
+            --end
+            role:updateProperty({field="ssrUp", value = ssrUpMap, notNotify = true})
+        else
+            for idx, field in ipairs(condition) do
+                if not values[idx] then
+                    local lpool = {}
+                    local curIdx = 1
+                    while unitPool[field .. "_" .. curIdx] do
+                        lpool[curIdx] = {unitPool[field .. "_" .. curIdx]}
+                        curIdx = curIdx + 1
+                    end
+
+                    if next(lpool) then
+                        values[idx] =  math.randWeight(lpool, 1)
                     end
                 end
+            end
+            if isSSRup then
                 if values[1] == HeroQuality.SSR then
                     ssrUpMap[poolId] = 0
                 else
                     ssrUpMap[poolId] = ssrFloorCnt + 1
                 end
+                role:updateProperty({field="ssrUp", value = ssrUpMap, notNotify = true})
             end
-            role:updateProperty({field="ssrUp", value = ssrUpMap, notNotify = true})
         end
  
  
@@ -349,4 +349,15 @@ function httpGetFormatData(params)
 	end
  
 	return table.concat(body, "&")
-end
 \ No newline at end of file
+end
+
+function logdump(obj, prefix)
+	for k,v in pairs(obj) do
+        local vt = type(v)
+		if vt == "table" then
+			logdump(v, prefix..':'..k)
+        elseif vt == 'string' or vt == 'number' then
+            skynet.error(prefix..':'..k..'='..v)
+		end
+	end
+end
 local skynet = require "skynet"
 local mysqlproxy = require "shared.mysqlproxy"
+require "utils.CommonFunc"
  
  
 function getDbCfgVal(tbName, keyName, fieldName)
@@ -29,20 +30,24 @@ end
  
 function addFriend(roleId, friendId)
 	local stmt_csp = mysqlproxy:prepare("call add_friends(?, ?, ?)")
+    --logdump(stmt_csp, '')
     local r = mysqlproxy:execute(stmt_csp, roleId, friendId, skynet.timex())
     if r[1][1]["t_error"] == 0 then
 		rpcRole(roleId, "addFriend", friendId)
 		rpcRole(friendId, "addFriend", roleId)
     end
+    mysqlproxy:stmt_close(stmt_csp)
 end
  
 function delFriend(roleId, friendId)
 	local stmt_csp = mysqlproxy:prepare("call del_friends(?, ?)")
+    --logdump(stmt_csp, '')
     local r = mysqlproxy:execute(stmt_csp, roleId, friendId)
     if r[1][1]["t_error"] == 0 then
 		rpcRole(roleId, "delFriend", friendId)
 		rpcRole(friendId, "delFriend", roleId)
     end
+    mysqlproxy:stmt_close(stmt_csp)
 end
  
 function roleExists(roleId)