cb1活跃回馈

测试
1 parent 2d07aef9
Showing 1 changed file with 33 additions and 0 deletions Show diff stats
src/actions/RoleAction.lua
@@ -340,6 +340,36 @@ function _M.loginRpc( agent, data )
 	return true
 end
  
+local function onCb1Back(newRole)
+	-- cb1活跃返利
+    skynet.timeout(0, function()
+		local cbbackd = cluster.query("center", "cb1backd")
+		local uid = newRole:getProperty("uid")
+		local roleId = newRole:getProperty("id")
+		local start = uid:find("_")
+		if start then
+			uid = uid:sub(start + 1)
+		end
+		if cbbackd then
+			local status, back = pcall(cluster.call, "center", cbbackd, "getCb1Reward", {uid = uid, id = roleId})
+			if status then
+				if back then
+                    if back == 0 then
+						mysqlproxy:insertEmail({roleId = roleId, emailId = MailId.CB1BackAward1, createtime = skynet.timex()})
+                    elseif back == 1 then
+						mysqlproxy:insertEmail({roleId = roleId, emailId = MailId.CB1BackAward2, createtime = skynet.timex()})
+                    end
+					newRole:mylog("cb1back", {key1 = uid, int2 = roleId, int1=back})
+				end
+			else
+				skynet.error("[ERROR] cb1backd cant call center uid: " .. uid .. " roleId:" .. roleId)
+			end
+		else
+			skynet.error("[ERROR] cb1backd cant call center uid: " .. uid .. " roleId:" .. roleId)
+		end
+    end)
+end
+
 function _M.createRpc(agent, data)
 	local msg = MsgPack.unpack(data)
 	local response = {}
@@ -446,6 +476,9 @@ function _M.createRpc(agent, data)
 		end
 	end)
  
+    -- cb1活跃回馈
+    onCb1Back(newRole)
+
 	return true
 end