local ipairs = ipairs
  local table = table
  local math = math
  local redisproxy = redisproxy
  local MsgPack = MsgPack
  
  local _M = {}
  
  function _M.addSellRpc( agent, data )
  	local role = agent.role
  	local msg = MsgPack.unpack(data)

  	local sellData = msg

  	local slot = sellData.slot
  	local sells = json.decode(role.dinerData:getProperty("sells"))
  	if sells[slot] and sells[slot].count and sells[slot].count ~= 0 then
  		return 0
  	end
  	if math.illegalNum(slot, 1, role.dinerData:getMaxSlots()) then
  		return 1
  	end
  	slot = tostring(slot)

  	local dish = sellData.dish
  	local dishSet = csvdb["diner_dishCsv"][dish]
  	if not dishSet then
  		return 2
  	end
  	local dishLevel = role.dinerData:getProperty("dishTree"):getv(dish, 0)
  	if dishLevel == 0 then
  		return 3
  	end
  	local dishData = dishSet[dishLevel]
  	if not dishData then
  		return 4
  	end

  	local calSell = role.dinerData:updateSell(slot, true) or {
  		deltaCount = 0,
  		deltaTime = 0,
  		lastCount = 0,
  	}

  	local count = sellData.count or 0

  	local maxDishCount = role.dinerData:getMaxDishs()
  	if math.illegalNum(count + calSell.lastCount, 1, maxDishCount) then
  		return 5
  	end

  	local cost = dishData.material:toNumMap()
  	for k, n in pairs(cost) do
  		cost[k] = n * count
  	end
  	if not role:checkItemEnough(cost) then
  		return 6
  	end

  	role:costItems(cost, {log = {desc = "addSell"}})

  	role.dinerData:updateSell(slot)

  	role:checkTaskEnter("MakeFood", {id = dish, count = count})
  	-- local dirty = false
  	-- if dirty then
  	-- 	role.dinerData:notifyUpdateProperty("order", role.dinerData:getProperty("order"))
  	-- end
  
  	sells = json.decode(role.dinerData:getProperty("sells"))
  	if not sells[slot] then
  		sells[slot] = {
  			reward = "",

  			popular = 0,

  		}

  	end

  	sells[slot].dish = dish
  	sells[slot].level = dishLevel
  	sells[slot].count = count
  	sells[slot].time = skynet.timex() - calSell.deltaTime

  
  	-- 检查解锁的顾客
  	local had = {}
  	for _, sell in pairs(sells) do
  		if sell.dish then
  			had[sell.dish] = sell.level
  		end
  	end
  

  	local customer = role.dinerData:getProperty("customer")

  	local change = false
  	for cId, cData in pairs(csvdb["diner_customerCsv"]) do
  		if not customer[cId] then
  			local unlock = true
  			for needId, lv in pairs(cData.unlock:toNumMap()) do
  				if not had[needId] or had[needId] < lv then
  					unlock = false
  					break
  				end
  			end
  			if unlock then
  				change = true
  				customer[cId] = 0
  			end
  		end
  	end
  
  	if change then 
  		role.dinerData:updateProperty({field = "customer", value = customer})
  	end

  	role:finishGuide(28)

  	role.dinerData:updateProperty({field = "sells", value = json.encode(sells)})

  	SendPacket(actionCodes.Diner_addSellRpc, "")

  	return true

  end
  

  function _M.removeSellRpc( agent, data )
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  
  	local slot = msg.slot
  	if math.illegalNum(slot, 1, role.dinerData:getMaxSlots()) then
  		return 1
  	end
  	slot = tostring(slot)
  	local sells = json.decode(role.dinerData:getProperty("sells"))
  	local sell = sells[slot]
  	if not sell then
  		return 2
  	end

  	local dish = sell.dish
  	local dishSet = csvdb["diner_dishCsv"][dish]
  	if not dishSet then
  		return 3
  	end
  	local dishLevel = role.dinerData:getProperty("dishTree"):getv(dish, 0)
  	if dishLevel == 0 then
  		return 4
  	end
  	local dishData = dishSet[dishLevel]
  	if not dishData then
  		return 5
  	end
  

  	local temp = role.dinerData:updateSell(slot)

  	local reward, change = {}

  	local cost = dishData.material:toNumMap()
  	for k, n in pairs(cost) do
  		local sum = n*sell.count

  		reward[k] = sum
  	end

  	reward, change = role:award(reward, {log = {desc = "removeSell"}})

  	sells[slot].count = 0

  	role:log("restaurant_sale", {
  		item_id = dish, -- 售卖物品ID
  		restaurant_sale_seat = slot, -- 售卖物品所在位置
  		restaurant_sale_time = temp.deltaTime or 0, -- 售卖时长
  		restaurant_sale_type = 2, -- 售卖方式，正常售卖:0,  加速:1，移除售卖:2
  		restaurant_sale_coin = reward[ItemId.DinerCoin] or 0, -- 售卖获得美食币
  		restaurant_sale_gear = reward[ItemId.Gold] or 0, -- 售卖获得齿轮
  	})

  	role.dinerData:updateProperty({field = "sells", value = json.encode(sells)})

  	SendPacket(actionCodes.Diner_removeSellRpc, MsgPack.pack({reward = reward, change = change}))

  	return true
  end
  

  function _M.getSellRewardRpc( agent, data )

  	local role = agent.role

  	local dirty = false

  	local reward, popular = "", 0

  	local sells = json.decode(role.dinerData:getProperty("sells"))

  
  	local deltaTimes = {}

  	for slot, _ in pairs(sells) do

  		local temp = role.dinerData:updateSell(slot)
  		deltaTimes[slot] = temp.deltaTime

  	end
  	sells = json.decode(role.dinerData:getProperty("sells"))
  	for slot, sell in pairs(sells) do

  		local rewards = sell.reward:toNumMap()
  		for k,v in pairs(rewards) do

  			reward = reward:incrv(k, v)

  		end

  		popular = popular + (sell.popular or 0)

  		if rewards[ItemId.Gold] and rewards[ItemId.Gold] > 0 then

  			if role.dinerData:checkDinerTask(DinerTask.DishWithGold, rewards[ItemId.Gold], sell.dish, nil, true) then

  				dirty = true
  			end

  			if role.dinerData:checkDinerTask(DinerTask.DishWithGoldType, rewards[ItemId.Gold], math.ceil(sell.dish / 100), nil, true) then
  				dirty = true
  			end
  			local dishData = csvdb["diner_dishCsv"][sell.dish][sell.level]
  			if role.dinerData:checkDinerTask(DinerTask.DishWithGoldRare, rewards[ItemId.Gold], dishData.rarity, nil, true) then
  				dirty = true
  			end

  		end

  		sells[slot].reward = ""

  		sells[slot].popular = 0

  
  		role:log("restaurant_sale", {
  			item_id = sell.dish, -- 售卖物品ID
  			restaurant_sale_seat = slot, -- 售卖物品所在位置
  			restaurant_sale_time = deltaTimes[slot] or 0, -- 售卖时长
  			restaurant_sale_type = 0, -- 售卖方式，正常售卖:0,  加速:1，移除售卖:2
  			restaurant_sale_coin = rewards[ItemId.DinerCoin] or 0, -- 售卖获得美食币
  			restaurant_sale_gear = rewards[ItemId.Gold] or 0, -- 售卖获得齿轮
  		})

  	end

  	role.dinerData:updateProperty({field = "sells", value = json.encode(sells)})

  	local gift = reward:toNumMap()
  	for k, v in pairs(gift) do

  		if k == ItemId.Gold then
  			role:checkTaskEnter("FoodSellGold", {count = v})
  		end

  	end

  	local reward, change = role:award(gift, {log = {desc = "dinerSell"}})

  	role.dinerData:popularAdd(popular)
  

  	if dirty then

  		role.dinerData:notifyUpdateProperty("order", role.dinerData:getProperty("order"))

  	end

  	SendPacket(actionCodes.Diner_getSellRewardRpc, MsgPack.pack({reward = reward, change = change}))

  	return true

  end
  

  function _M.expediteSellRpc( agent, data )
  	local role = agent.role

  	local count = role.dinerData:getProperty("expedite")
  	local max = #globalCsv.diner_sell_quick_cost

  	if count > max then

  		return 1
  	end

  	local diamond = globalCsv.diner_sell_quick_cost[count]
  	if diamond > 0 then
  		local cost = {[ItemId.Diamond] = diamond}
  		if not role:checkItemEnough(cost) then
  			return 2
  		end

  		role:costItems(cost, {log = {desc = "dinerSellQ"}})

  	end

  	local dirty = false

  	local reward,popular = "", 0

  	local sells = json.decode(role.dinerData:getProperty("sells"))
  	for slot, _ in pairs(sells) do
  		role.dinerData:updateSell(slot)
  	end
  	sells = json.decode(role.dinerData:getProperty("sells"))
  	for slot, sell in pairs(sells) do

  		local result = role.dinerData:expediteSell(slot)

  		if result then
  			local rewards = result.reward:toNumMap()
  			for k,v in pairs(result.reward:toNumMap()) do
  				reward = reward:incrv(k,v)
  			end
  			popular = popular + result.popular

  			if rewards[ItemId.Gold] and rewards[ItemId.Gold] > 0 then
  				if role.dinerData:checkDinerTask(DinerTask.DishWithGold, rewards[ItemId.Gold], sell.dish, nil, true) then
  					dirty = true
  				end

  				if role.dinerData:checkDinerTask(DinerTask.DishWithGoldType, rewards[ItemId.Gold], math.ceil(sell.dish / 100), nil, true) then
  					dirty = true
  				end
  				local dishData = csvdb["diner_dishCsv"][sell.dish][sell.level]
  				if role.dinerData:checkDinerTask(DinerTask.DishWithGoldRare, rewards[ItemId.Gold], dishData.rarity, nil, true) then
  					dirty = true
  				end

  			end

  
  			role:log("restaurant_sale", {
  				item_id = sell.dish, -- 售卖物品ID
  				restaurant_sale_seat = slot, -- 售卖物品所在位置
  				restaurant_sale_time = result.deltaTime or 0, -- 售卖时长
  				restaurant_sale_type = 1, -- 售卖方式，正常售卖:0,  加速:1，移除售卖:2
  				restaurant_sale_coin = rewards[ItemId.DinerCoin] or 0, -- 售卖获得美食币
  				restaurant_sale_gear = rewards[ItemId.Gold] or 0, -- 售卖获得齿轮
  			})

  		end
  	end
  

  	role.dinerData:notifyUpdateProperty("sells", role.dinerData:getProperty("sells"))
  	role.dinerData:setProperty("expedite",count+1)
  	role.dinerData:notifyUpdateProperty("expedite", count+1)

  	local gift = reward:toNumMap()

  
  	-- 特权卡获取加速获得额外道具
  	local coef = role.storeData:getProduceItemSpeedCoef()

  	for k, v in pairs(gift) do

  		if coef > 1 then
  			v = math.floor(v * coef)
  			gift[k] = v
  		end

  		if k == ItemId.Gold then
  			role:checkTaskEnter("FoodSellGold", {count = v})
  		end

  	end

  	local change
  	reward, change = role:award(gift, {log = {desc = "dinerSell"}})

  	role.dinerData:popularAdd(popular)
  

  	if dirty then
  		role.dinerData:notifyUpdateProperty("order", role.dinerData:getProperty("order"))
  	end

  	role:checkTaskEnter("FoodSellQuick")

  	SendPacket(actionCodes.Diner_expediteSellRpc, MsgPack.pack({reward = reward, change = change, popular = popular}))

  	return true
  end
  

  function _M.levelUpRpc( agent, data )
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  
  	local index = msg.index

  	local buildingSet = csvdb["diner_buildingCsv"][index]
  	if not buildingSet then

  		return
  	end
  
  	local buildL = role.dinerData:getProperty("buildL")
  	local curLevel = buildL:getv(index, 1)

  	if curLevel >= #buildingSet then

  		return
  	end

  	local buildingData = buildingSet[curLevel]
  	if not buildingData then
  		return
  	end
  	if buildingData.upLimit ~= "" then

  		local id, level = buildingData.upLimit:match("(%d+)=(%d+)")

  		if buildL:getv(tonumber(id), 1) < tonumber(level) then
  			return
  		end
  	end

  	local cost = buildingData.starCost:toNumMap()

  	if not role:checkItemEnough(cost) then

  		return

  	end
  

  	role:costItems(cost, {log = {desc = "dinerBuildUp", int1 = index}})

  	role.dinerData:updateProperty({field = "buildL", value = buildL:setv(index, curLevel + 1)})

  	role:checkTaskEnter("DinerLevelUp", {type = index, level = curLevel + 1})

  	role:log("restaurant_up", {
  		restaurant_up_type = index - 1, --升级部件类型，店面:0, 接客:1, 满意度:2, 宣传:3, 广告:4, 周边:5
  		restaurant_up_gear = cost[ItemId.Gold] or 0, --消耗齿轮数量
  		restaurant_up_coin = cost[ItemId.DinerCoin] or 0, --花费美食币数量
  		restaurant_up_effectbef = curLevel, --升级前加成
  		restaurant_up_effect = curLevel + 1, --升级后加成
  	})

  	SendPacket(actionCodes.Diner_levelUpRpc, '')
  	return true
  end
  

  function _M.talentUpRpc( agent, data )
  	local role = agent.role
  	local msg = MsgPack.unpack(data)

  	local dish = msg.dish

  	local dishTree = role.dinerData:getProperty("dishTree")
  	local dishLevel = dishTree:getv(dish, 0)

  
  	local talentSet = csvdb["diner_talentCsv"][dish]
  	if not talentSet then
  		return 1
  	end
  
  	local talentData = talentSet[dishLevel]
  	if not talentData then
  		return 2
  	end
  
  	if not talentSet[dishLevel+1] then
  		return 21
  	end
  
  	local typ = math.floor(dish/100 + 1)
  	local treeSet = csvdb["diner_treeCsv"][typ]
  	if not treeSet then
  		return 3
  	end
  
  	local treeData = treeSet[dish]
  	if not treeData then
  		return 4
  	end
  

  	local limit = talentData.pointFront:toNumMap()

  	for k,v in pairs(limit) do
  		local lv = dishTree:getv(k, 0)
  		if lv < v then
  			return 5

  		end

  	end

  	if talentData.levelFront ~= "" then

  		if not role:checkHangPass(tonumber(talentData.levelFront)) then

  			return 9
  		end
  	end
  

  	local cost = talentData.cost:toNumMap()

  	if not role:checkItemEnough(cost) then

  		return 6
  	end
  

  	-- 正在贩卖不能升级料理天赋

  	local sells = json.decode(role.dinerData:getProperty("sells"))
  	for slot, _ in pairs(sells) do
  		role.dinerData:updateSell(slot)
  	end
  	sells = json.decode(role.dinerData:getProperty("sells"))
  	for _, sell in pairs(sells) do

  		if sell.dish == msg.dish and sell.count > 0 then

  			return 7
  		end

  	end
  

  	-- 正在冒险不能升级营养剂天赋

  	-- if talentData.effect:toArray(true,"=")[1] == 2 then
  	-- 	if next(role:getProperty("advTeam")) then return 8 end
  	-- end

  	role:costItems(cost, {log = {desc = "talentUp", int1 = dish, int2 = dishLevel + 1}})

  	role.dinerData:updateProperty({field = "dishTree", value = dishTree:setv(dish, dishLevel + 1)})

  	-- local treePoint = talentData.tree_point:toNumMap()
  	-- if next(treePoint) then
  	-- 	role:award(treePoint)
  	-- end

  	role:checkTaskEnter("DinerTalentUp", {type = talentData.effect:toArray(true,"=")[1], level = dishLevel + 1})

  	role:finishGuide(27)

  	role:log("carriage_logistics", {
  		carriage_logistics_type = typ, -- 后勤室制作类型ID，变异:0，通常:1，魔法:2
  		carriage_logistics_itemid = dish, -- 后勤室升级物品或技能ID
  		carriage_logistics_itemlv = dishLevel + 1, -- 升级后物品或技能等级
  		carriage_logistics_gear = cost[ItemId.Gold] or 0, -- 后勤室升级花费齿轮数量
  		carriage_logistics_coin = cost[ItemId.DinerCoin] or 0, -- 后勤室升级花费美食币数量
  	})

  	SendPacket(actionCodes.Diner_talentUpRpc, '')
  	return true
  end
  

  function _M.skillUpRpc( agent, data )
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  
  	local skill = msg.skill
  	local skillSet = csvdb["diner_skillCsv"][skill]
  	if not skillSet then
  		return
  	end
  
  	local skillTree = role.dinerData:getProperty("skillTree")
  	local skillLevel = skillTree:getv(skill, 1)
  	local skillData = skillSet[skillLevel]
  	if not skillData then
  		return
  	end
  	if skillData.unlock ~= "" then
  		local id, level = skillData.unlock:math("(%d+)=(%d+)")
  		if skillTree:getv(tonumber(id), 1) < tonumber(level) then
  			return
  		end
  	end
  	local cost = skillData.cost:toNumMap()
  	if not role:checkItemEnough(cost) then
  		return
  	end
  

  	role:costItems(cost, {log = {desc = "dinerSkillUp", int1 = skill, int2 = skillLevel + 1}})

  	role.dinerData:updateProperty({field = "skillTree", value = skillTree:setv(skill, skillLevel + 1)})

  
  	SendPacket(actionCodes.Diner_skillUpRpc, '')
  	return true
  end
  

  function _M.lockTaskRpc( agent, data )
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local index = msg.index
  

  	local orders = json.decode(role.dinerData:getProperty("order"))
  
  	if math.illegalNum(index, 1, #orders) then

  		return 1
  	end

  	local order = orders[index]
  	if not order then
  		return 2
  	end

  	if order.lock == 0 then
  		order.lock = 1
  	else
  		order.lock = 0

  	end

  	role.dinerData:updateProperty({field = "order", value = json.encode(orders)})

  	SendPacket(actionCodes.Diner_lockTaskRpc, MsgPack.pack({lock = order.lock}))

  	return true
  end
  

  function _M.updateTaskRpc( agent, data )

  	local role = agent.role
  	local msg = MsgPack.unpack(data)

  	local index = msg.index

  	-- 0 接受任务,1 放弃已接受任务,2 完成已接受任务

  	local cmd = msg.cmd

  	local orders = json.decode(role.dinerData:getProperty("order"))
  	if math.illegalNum(index, 1, #orders) then

  		return 1
  	end

  	local order = orders[index]
  	if not order then
  		return 2
  	end

  	local taskSet = csvdb["diner_questCsv"][order.lv]
  	if not taskSet then
  		return 4
  	end
  	local taskData = taskSet[order.id]
  	if not taskData then
  		return 5
  	end

  	local reward, change

  	if cmd == 0 then
  		if order.status ~= 0 then
  			return 30
  		end
  		orders[index].status = 1
  		orders[index].lock = 1

  		role:checkTaskEnter("GetOderTask", {rarity = taskSet.rarity})

  	elseif cmd == 1 then
  		if order.status ~= 1 then
  			return 31
  		end
  		orders[index].status = 0
  		orders[index].lock = 0

  	elseif cmd == 2 then

  		if order.status ~= 1 then

  			return 32
  		end

  		if order.n < taskData.value then

  			return 6
  		end

  		reward, change = role:award(taskData.reward, {log = {desc = "dinerFinishTask", int1 = order.id}})

  		table.remove(orders,index)

  		role:checkTaskEnter("OverOderTask", {rarity = taskSet.rarity})

  	else
  		return 33

  	end
  

  
  	role:log("restaurant_order", {
  		restaurant_order_id = order.id, -- 订单任务ID
  		restaurant_order_status = cmd, -- 订单任务状态，接受:0, 拒绝:1, 完成:2

  		restaurant_order_rwd = reward, -- 订单完成奖励，json格式记录，{"itemid1":123,"itemid2":12,……….}

  		restaurant_order_lv = taskSet.rarity, -- 订单品质等级，普通:0, 稀有:1, 顶级:2, 豪华:3
  	})
  

  	role.dinerData:updateProperty({field = "order", value = json.encode(orders)})

  	SendPacket(actionCodes.Diner_updateTaskRpc, MsgPack.pack({reward = reward, change = change}))

  	return true
  end
  

  function _M.refreshTaskRpc( agent, data )

  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  

  	local cost = {[ItemId.Diamond] = 40}

  	if not role:checkItemEnough(cost) then
  		return 1
  	end
  
  	local orders = json.decode(role.dinerData:getProperty("order"))

  
  	local hadTask = {}

  	local needCount = 0

  	for idx, temp in pairs(orders) do

  		if temp.lock ~= 0 or temp.status ~= 0 then

  			hadTask[temp.id] = 1

  		else
  			needCount = needCount + 1

  		end

  	end
  

  	if needCount <= 0 then return 2 end
  

  	local taskLevel = role.dinerData:getProperty("buildL"):getv(5, 1)
  	local taskData = csvdb["diner_questCsv"][taskLevel]
  	if not taskData then
  		return 3
  	end

  	local pool = {}

  
  	local dishTree = role.dinerData:getProperty("dishTree")

  	for id, temp in pairs(taskData) do

  		local unlock = true
  		for _, front in ipairs(temp.front:toArray(true, "=")) do
  			if dishTree:getv(front, 0) == 0 then
  				unlock = false
  				break
  			end
  		end
  		if not hadTask[id] and unlock then

  			table.insert(pool, temp)
  		end
  	end
  	local needCount = math.min(#pool, needCount) -- 需要的任务个数
  
  	if needCount <= 0 then return end
  
  	local cost = globalCsv.diner_task_refresh_cost:toNumMap()
  	for itemId, count in pairs(cost) do
  		cost[itemId] = count * needCount
  	end
  	if not role:checkItemEnough(cost) then return end
  

  	role:costItems(cost, {log = {desc = "dinerReTask"}})

  
  	for idx, order in ipairs(orders) do
  		if (order.lock == 0 and order.status == 0) then

  			if needCount > 0 then
  				local index = math.randWeight(pool, "chance")
  				local data = pool[index]
  				orders[idx] = {lv = taskLevel, id = data.id, n = 0, lock = 0, status = 0}
  				needCount = needCount - 1
  				table.remove(pool, index)
  			end

  		end
  	end

  	role:finishGuide(41)

  	role.dinerData:updateProperty({field = "order", value = json.encode(orders)})

  
  	SendPacket(actionCodes.Diner_refreshTaskRpc, '')

  	return true
  end
  

  function _M.addWantFoodRpc(agent , data)

  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  

  	local ids = msg.ids -- list
  

  	local buildType = 6
  	local level = role.dinerData:getProperty("buildL"):getv(buildType, 1)
  	local buildingData = csvdb["diner_buildingCsv"][buildType][level]

  	if not buildingData then
  		return 1
  	end

  
  	if #ids > buildingData.business then return 2 end
  
  	local had = {}
  	for _, itemId in ipairs(ids) do
  		if had[itemId] then return end
  		had[itemId] = 1
  		local foodData = csvdb["diner_materialCsv"][itemId]
  		if not foodData then return 3 end
  		if foodData.unlock ~= 0 then

  			if not role:checkHangPass(foodData.unlock) then

  				return 4
  			end
  		end
  	end
  	local gfood = {}
  	for slot, itemId in ipairs(ids) do
  		gfood[slot] = {id = itemId, st = skynet.timex()}

  	end
  

  	role:finishGuide(36)