local _M = {}
  

  local md5 = require "md5"

  local httpc = require("http.httpc")

  -- 入口在正式服关闭  -- mock 充值
  function _M.rechargeRpc(agent , data)

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

  	local choose = msg.choose or ""

  	local dataSet = csvdb["shop_rechargeCsv"][id]

  	if not dataSet then return end

  	local roleId = role:getProperty("id")
  	

  	--创建订单号

  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)

  	if partnerOrderId == "" then
  		return 1
  	end

  	SendPacket(actionCodes.Store_rechargeRpc, MsgPack.pack({ order = partnerOrderId }))

  	-- 测试的 直接发奖励了
  	skynet.timeout(10, function ()
  		role:handlePurchase({
  			order = partnerOrderId,

  			amount = dataSet.rmb * 100 / globalCsv.QArecharge,

  			game_money = dataSet.diamond,
  			product_id = dataSet.productId,
  			pay_time = skynet.timex(),
  			transactionId = "onlyTest",
  		})
  	end)
  	
  	return true
  end
  
  local function table_keys( t )
      local keys = {}
      for k, _ in pairs( t ) do
          keys[#keys + 1] = k
      end
      return keys
  end
  
  local function signPms(params, secret_key)
      local keys = table_keys(params)
      table.sort(keys)
      local urlCode = ""
      for index, key in ipairs(keys) do
  		urlCode = urlCode .. params[key]
  	end
  	return md5.sumhexa(urlCode .. secret_key):lower()
  end
  

  local function signDyhPms(params, secret_key)
      local keys = table_keys(params)
      table.sort(keys)
      local str2Sign = ""
      for index, key in ipairs(keys) do
          if str2Sign ~= "" then
              str2Sign = str2Sign .. '&'
          end
          str2Sign = str2Sign .. string.format("%s=%s", key, params[key])
      end
  	return md5.sumhexa(str2Sign .. secret_key):lower()
  end
  

  -- bili android 充值 入口
  function _M.biliAndroidRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号

  	local partnerOrderId = role:getPurchaseOrder(id)

  	-- 签名
  	local secret_key = "8920e9dcf0cb4ebca87393ce48021ead"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb * 100,
  		game_money = dataSet.diamond,
  		notify_url = msg.notifyUrl
  	}
  	local sign = signPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_biliAndroidRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
  	return true
  end

  -- 享游sdk充值

  function _M.biliCpsRechargeRpc(agent, data)

  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
  	local partnerOrderId = role:getPurchaseOrder(id)
  	-- 签名
  	local secret_key = "d69365fe15144af990065443749f0f1b"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb * 100,
  		game_money = dataSet.diamond,
  		notify_url = msg.notifyUrl
  	}
  	local sign = signPms(need, secret_key)
  

  	SendPacket(actionCodes.Store_biliCpsRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))

  	return true
  end
  
  -- 享游sdk充值

  function _M.biliUoRechargeRpc(agent, data)

  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
  	local partnerOrderId = role:getPurchaseOrder(id)
  	-- 签名
  	local secret_key = "4243b5fb44b64175a20a53dcfb1346eb"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb * 100,
  		game_money = dataSet.diamond,
  		notify_url = msg.notifyUrl
  	}
  	local sign = signPms(need, secret_key)
  

  	SendPacket(actionCodes.Store_biliUoRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))

  	return true
  end
  

  -- 云游戏sdk充值
  function _M.biliCloudRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
  	local partnerOrderId = role:getPurchaseOrder(id)
  	-- 签名
  	local secret_key = "c97a19c2c00143d6b0f0da2bc52208e7"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb * 100,
  		game_money = dataSet.diamond,
  		notify_url = msg.notifyUrl
  	}
  	local sign = signPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_biliCloudRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
  	return true
  end
  

  -- google 充值 入口
  function _M.googleRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id

  	local choose = msg.choose or ""

  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")

  	role.ignoreHeartbeat = true

  	--创建订单号

  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)

  	-- 签名

  	-- local secret_key = "b7657fa7ccd44c16a35e3f454ac7a075"
  	local secret_key = "8920e9dcf0cb4ebca87393ce48021ead"

  	local need = {
  		out_trade_no = partnerOrderId,

  		money = dataSet.rmb * 100,

  		game_money = dataSet.diamond,

  		-- product_id = dataSet.productId,

  		notify_url = msg.notifyUrl

  	}
  	local sign = signPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_googleRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))

  	return true
  end
  

  -- mycard 充值 入口
  function _M.myCardRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id

  	local choose = msg.choose or ""

  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号

  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)

  	-- 签名
  	local secret_key = "48759e07540f46d9af17ec82669b4272"
  	local need = {
  		out_trade_no = partnerOrderId,

  		money = dataSet.rmb * 100,

  		game_money = dataSet.diamond,

  		notify_url = msg.notifyUrl

  	}
  	local sign = signPms(need, secret_key)
  

  	SendPacket(actionCodes.Store_myCardRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))

  	return true
  end

  -- bili ios 充值 入口

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

  	local choose = msg.choose or ""

  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号

  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)

  	-- 签名

  	local secret_key = "2b2036e1f44640a59168c92462714870"

  	local need = {
  		out_trade_no = partnerOrderId,

  		money = dataSet.rmb * 100,

  		game_money = dataSet.diamond,

  		product_id = dataSet.iap_product_id,

  		notify_url = msg.notifyUrl

  	}

  	local sign = signDyhPms(need, secret_key)

  
  	SendPacket(actionCodes.Store_iosRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
  	return true
  end
  

  -- dyh android 充值 入口
  function _M.dyhxAndroidRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local choose = msg.choose or ""
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
  	-- 签名
  	local secret_key = "51ba4398c69d4d229d5402295dc38b50"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb * 100,
  		game_money = dataSet.diamond,
  		notify_url = msg.notifyUrl
  	}
  	local sign = signDyhPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_dyhxAndroidRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
  	return true
  end
  

  local rechargeHandler = {

  	ali = function(cp_order_id, rechargeId, cfg, result)
  		local codeurl = skynet.getenv("codeurl")
  		local content = {
  			["paytype"] = "alipay",
  			["rechargeid"] = rechargeId,
  			["order"] = cp_order_id,
  			["title"] = cfg.title,
  			["rmb"] = cfg.rmb,
  		}
  		local status, body = httpc.get(codeurl, "/payorder?" .. httpGetFormatData(content), {})
  		if status == 200 then
  			result["orderInfo"] = body
  		end

  	end,

  	wx = function(cp_order_id, rechargeId, cfg, result)
  		local codeurl = skynet.getenv("codeurl")
  		local content = {
  			["paytype"] = "wxpay",
  			["rechargeid"] = rechargeId,
  			["order"] = cp_order_id,
  			["title"] = cfg.title,
  			["rmb"] = cfg.rmb,
  		}
  		local status, body = httpc.get(codeurl, "/payorder?" .. httpGetFormatData(content), {})
  		if status == 200 then
  			result["orderInfo"] = body
  		end

  	end,
  }
  
  function _M.getCpOrderIdRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local type = msg.skd_type or ""
  	local choose = msg.choose or ""
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
  
  	local result = {}
  	result["order"] = partnerOrderId
  	local handler = rechargeHandler[type]
  	if handler then

  		handler(partnerOrderId, id, dataSet, result)

  	end
  
  	SendPacket(actionCodes.Store_getCpOrderIdRpc, MsgPack.pack(result))

  	return true

  end
  

  function _M.purchaseOrderResult(agent, data)
  	local role = agent.role
  
  	local roleId = role:getProperty("id")
  	local msg = MsgPack.unpack(data)
  
  	role.ignoreHeartbeat = false
  

  	local status = {
  		fail = true,
  		success = true
  	}

  	local partnerOrderStr = msg.order
  	if partnerOrderStr then
  		role:updatePurchaseOrder(partnerOrderStr, msg.platformOrder, status[msg.status] and msg.status or "unknown")

  	end

  	return true
  end
  
  

  function _M.shopBuyRpc(agent , data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local count = msg.count or 1
  

  	local dataSet = csvdb["shop_normalCsv"][id]

  	if not dataSet then return end
  

  	if dataSet.unlock ~= "" then

  		if not role:checkHangPass(tonumber(dataSet.unlock)) then

  			skynet.error(string.format("shopBuyRpc,user do not finish hang pass, user_id:%d", role:getProperty("id")))
  			return 1
  		end
  	end
  

  	--判断是否是活动商品
  	if dataSet.activity_id and dataSet.activity_id ~= 0 then
  		local actCfg = csvdb["activity_ctrlCsv"][dataSet.activity_id]
  		if not actCfg then return 2 end
  		if not role.activity:isOpenById(dataSet.activity_id, "ActShopGoods") then return 3 end
  	end
  

  	local cost
  	if dataSet.disount == 0 then

  		cost = {[dataSet.icon] = math.ceil(dataSet.cost * count)}
  	else
  		cost = {[dataSet.icon] = math.ceil(dataSet.cost * count * ((dataSet.disount or 10) / 10))}
  	end

  	local desc = "unknowShop"

  	if dataSet.shop == 1 then		-- 普通商店
  		desc = "dailyShop"

  	elseif dataSet.shop == 2 then		-- 美食商店
  		desc = "dinerShop"
  	elseif dataSet.shop == 3 then		-- 竞技场商店
  		desc = "pvpShop"
  	end
  

  	if not role:checkItemEnough(cost) then return 4 end

  	if not role:costItems(cost, {log = {desc = desc, int1 = id, int2 = count, long1= dataSet.shop}}) then return 5 end

  	local buyRecord = role.storeData:getProperty("buyR")
  	if math.illegalNum(count, 1, (dataSet.limit == 0 and 10000 or dataSet.limit - (buyRecord[id] or 0))) then
  		skynet.error(string.format("shop buy over limit, user_id:%d, goods_id:%d", role:getProperty("id"), id))
  		return 6
  	end
  
  	local limitStr = ""

  	if dataSet.limit ~= 0 then
  		buyRecord[id] = (buyRecord[id] or 0) + count

  		role.storeData:updateProperty({field = "buyR", value = buyRecord})

  		limitStr = string.format("%s/%s", buyRecord[id], dataSet.limit)

  	end

  
  	local gift = {}
  	for _id, _count in pairs(dataSet.gift:toNumMap()) do
  		gift[_id] = _count * count
  	end

  	local reward = role:award(gift, {log = {desc = desc, int1 = id, int2 = count, short1=dataSet.shop}})

  	if dataSet.shop == 1 then
  		role:checkTaskEnter("ShopAll", {count = count})
  	end

  	local costId, costCount = next(cost)
  
  	role:log("shop_purchase", {
  		item_id = id, -- 道具id
  		item_type = 0, -- 道具类型，具体见枚举表中道具类型枚举表
  		item_level = 0, -- 道具等级
  		item_cnt = count, -- 购买数量技术
  		currency_type = costId or 0, -- 购买道具消耗的货币类型，记录货币ID
  		shop_purchase_current = costCount or 0, -- 购买道具消耗的货币数量
  		shop_id = dataSet.shop, -- 商店ID
  	})

  	role:mylog("role_action", {desc = "shopBuy", int1 = id, int2 = count, short1=dataSet.shop, key1 = limitStr})

  	SendPacket(actionCodes.Store_shopBuyRpc, MsgPack.pack({reward = reward}))
  	return true
  end
  

  function _M.getFreeChestRpc(agent, data)

  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  
  	local config = csvdb["shop_rechargeCsv"][id]
  	if not config then return end
  

  	--判断是否是活动商品
  	if config.activity_id ~= 0 then
  		local actCfg = csvdb["activity_ctrlCsv"][config.activity_id]
  		if not actCfg then return 2 end
  		if not role.activity:isOpenById(config.activity_id, "ActShopGoods") then return 3 end
  	end
  

      local rechargeRecord = role.storeData:getProperty("payR")
  	local getCount = (rechargeRecord[id] or 0)
  	if getCount >= config.limit then
  		return 1
  	end

  	local reward, _ = role:award(config.itemFirst, {log = {desc = "freeGift", int1 = id}})

  
  	rechargeRecord[id] = getCount + 1
  	role.storeData:updateProperty({field = "payR", value = rechargeRecord})
  

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

  	return true

  end
  
  function _M.getGrowFundRewardRpc(agent, data)	
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  
  	local config = csvdb["reward_newbeeCsv"][id]
  	if not config then return end
  
      local growFundFlag = role.storeData:getProperty("growFund")
  	local growFundRecord = role.storeData:getProperty("growFundR")
  	
  	if growFundFlag == 0 then
  		skynet.error("user do not buy grow fund")
  		return 1
  	end
  
  	if not role:checkHangPass(config.condition) then
  		skynet.error(string.format("user do not finish hang pass, user_id:%d", role:getProperty("id")))
  		return 1
  	end
  
  	local b = string.getbit(growFundRecord, id)
  	if string.char(b) == "1" then
  		return 1
  	end
  
  	growFundRecord = string.setbit(growFundRecord, id)
  	role.storeData:updateProperty({field = "growFundR", value = growFundRecord})
  
  	local gift = config.giftFree .. " " .. config.giftLimit
  	local reward, _ = role:award(gift, {log = {desc = "grownFund", int1 = id}})
  
  	SendPacket(actionCodes.Store_getGrowFundRewardRpc, MsgPack.pack({reward = reward}))

  	return true

  end
  

  -- 赛季卡

  function _M.getBattlePassRewardRpc(agent, data)	
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  
  	local config = csvdb["reward_battlepassCsv"][id]
  	if not config then return end
  
  	local timeNow = skynet.timex()

      local battleCardFlag = role.storeData:getProperty("battleCard")

  	local battleCardFreeRecord = role.storeData:getProperty("battleFR")
  	local battleCardLimitRecord = role.storeData:getProperty("battleLR")
  
  	local freeFlag = string.char(string.getbit(battleCardFreeRecord, id))
  	local limitFlag = string.char(string.getbit(battleCardLimitRecord, id))
  
  	if freeFlag == "1" and limitFlag == "1" then
  		skynet.error("user already get battle pass reward")
  		return 1
  	end
  

  	if battleCardFlag == 1 and limitFlag == "1" then

  		return 1
  	end
  

  	if role:getProperty("battlePoint") < config.point then

  		skynet.error(string.format("user do not have enough battle point, user_id:%d", role:getProperty("id")))
  		return 1
  	end
  

  	local gift = ""
  	if  freeFlag == "0" then
  		gift = config.giftFree
  
  		battleCardFreeRecord = string.setbit(battleCardFreeRecord, id)
  		role.storeData:updateProperty({field = "battleFR", value = battleCardFreeRecord})
  	end
  

  	if battleCardFlag == 1 and limitFlag == "0" then

  		if gift ~= "" then
  			gift = gift .. " "
  		end
  		gift = gift .. config.giftLimit
  
  		battleCardLimitRecord = string.setbit(battleCardLimitRecord, id)

  		role.storeData:updateProperty({field = "battleLR", value = battleCardLimitRecord})

  	end
  	
  	local reward, _ = role:award(gift, {log = {desc = "battleCard", int1 = id}})
  
  	SendPacket(actionCodes.Store_getBattlePassRewardRpc, MsgPack.pack({reward = reward}))

  	return true

  end
  

  -- 探索指令奖励
  function _M.getExploreCommandRewardRpc(agent, data)	
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id		-- 探索id
  	local subId = msg.subId		-- 领取的阶段id
  

  	local tab_name = "reward_levelpass" .. id .. "Csv"

  	local config = csvdb[tab_name][subId]

  	if not config then return end
  

  	local bpInfo = role.storeData:getProperty("bpInfo") or {}

  	local info = bpInfo[id] or {}
  	local flag = info["flag"] or 0

  	--if flag == 0 then return 1 end

  
  	local freeRecord = info["fr"] or ""
  	local buyRecord = info["br"] or ""
  
  	local freeFlag = string.char(string.getbit(freeRecord, subId))
  	local limitFlag = string.char(string.getbit(buyRecord, subId))
  
  	if freeFlag == "1" and limitFlag == "1" then
  		skynet.error("user already get explore command reward")
  		return 2
  	end
  
  	if flag == 1 and limitFlag == "1" then
  		return 3
  	end
  

  	for k, level in pairs(config.level:toNumMap()) do
  		if k == 1 then
  			if not role:checkHangPass(level) then
  				return 4
  			end
  		elseif k == 2 then
  			if not role:checkAdvChapterPass(level) then
  				return 4
  			end

  		end

  	end
  
  	local gift = ""
  	if  freeFlag == "0" then
  		gift = config.giftFree
  

  		freeRecord = string.setbit(freeRecord, subId)

  		info["fr"] = freeRecord
  	end
  
  	if flag == 1 and limitFlag == "0" then
  		if gift ~= "" then
  			gift = gift .. " "
  		end
  		gift = gift .. config.giftLimit
  

  		buyRecord = string.setbit(buyRecord, subId)

  		info["br"] = buyRecord
  	end
  

  	bpInfo[id] = info
  	role.storeData:updateProperty({field = "bpInfo", value = bpInfo})

  	
  	local reward, _ = role:award(gift, {log = {desc = "exploreCommand", int1 = id, int2 = subId}})
  
  	SendPacket(actionCodes.Store_getExploreCommandRewardRpc, MsgPack.pack({reward = reward}))
  	return true
  end
  

  -- 累充奖励
  function _M.getTotalRechargeAwardRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local index = msg.index		-- 领取的索引id

  	local totalTwd = role:getProperty("twdC")

  	local totalRechargeRecord = role.storeData:getProperty("totalRR")
  	local flag = string.char(string.getbit(totalRechargeRecord, index))

  	if flag == "1" then return 1 end

  	local cfg = csvdb["activity_payRebateCsv"][index]

  	if not cfg then return 2 end

  	if cfg.twd > totalTwd then return 3 end

  
  	totalRechargeRecord = string.setbit(totalRechargeRecord, index)
  	role.storeData:updateProperty({field = "totalRR", value = totalRechargeRecord})

  	local main = cfg.main_reward:toNumMap()
  	local sub = cfg.sub_reward:toNumMap()
  	for k, v in pairs(sub) do
  		main[k] = (main[k] or 0) + v
  	end

  	local reward, change = role:award(main, {log = {desc = "totalRecharge", int1 = index}})
  	SendPacket(actionCodes.Store_getTotalRechargeAwardRpc, MsgPack.pack(role:packReward(reward, change)))

  	return true
  end
  

  function _M.monthCardRewardRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
      local mcid = msg.mcid
  	local smcid = msg.smcid
  
  	local reward,change = {}, {}
  	--月卡奖励
  	local tmpreward, tmpchange = role.storeData:getMonthCardDailyReward(mcid)
  	if tmpreward then
  		for k, v in pairs(tmpreward) do
  			reward[k] = (reward[k] or 0) + v
  		end
  		if tmpchange then table.insert(change, tmpchange) end
  	end
  
      --特刊奖励
  	tmpreward, tmpchange = role.storeData:getSMonthCardDailyReward(smcid)
  	if tmpreward then
  		for k, v in pairs(tmpreward) do
  			reward[k] = (reward[k] or 0) + v
  		end
  		if tmpchange then table.insert(change, tmpchange) end
  	end
  	SendPacket(actionCodes.Store_monthCardRewardRpc, MsgPack.pack(role:packReward(reward, change)))
  	return true
  end
  

  return _M