478 lines
20 KiB
Lua
478 lines
20 KiB
Lua
local skynet = require "skynet"
|
||
local oo = require "Class"
|
||
local log = require "Log"
|
||
local pb = require "pb"
|
||
local dataType = require "DataType"
|
||
local errorInfo = require "ErrorInfo"
|
||
local Used = oo.class()
|
||
|
||
Used.SellOPType_StartSell = 1 --开始出售
|
||
Used.SellOPType_StopSell = 2 --停止出售
|
||
Used.SellOPType_ConfirmSell = 3 --确定出售
|
||
|
||
Used.SellStatus_NoSell = 1 --未卖出
|
||
Used.SellStatus_SomeoneWant = 2 --有人购买
|
||
Used.SellStatus_AlreadySell = 3 --已经出售
|
||
|
||
Used.GoodsStatus_NoReach = 1 --未到达
|
||
Used.GoodsStatus_AlreadyReach = 2 --已到达
|
||
Used.GoodsStatus_AlreadyGet = 3 --已领取
|
||
|
||
Used.CopyType_Seller = 1 --卖家
|
||
Used.CopyType_Buyer = 2 --买家
|
||
|
||
function Used:Init()
|
||
end
|
||
|
||
--闲菜展示
|
||
function Used:Show( player , c2sData , s2cData )
|
||
c2sData.data = assert(pb.decode("C2SUsedShow", c2sData.data ))
|
||
local data = {}
|
||
self:CheckRefreshGoods( player )
|
||
log.info(string.format("玩家 %d 闲菜 展示操作" , player.basicInfo.userID))
|
||
|
||
local count = 0
|
||
--多出的20个已签收物流就删除前面的
|
||
for k, v in pairs(player.gameData.used.logisticsInfo ) do
|
||
if self.GoodsStatus_AlreadyGet == v.goodsStatus then
|
||
count = count + 1
|
||
end
|
||
end
|
||
|
||
if count > 20 then
|
||
for k, v in pairs(player.gameData.used.logisticsInfo ) do
|
||
if self.GoodsStatus_AlreadyGet == v.goodsStatus then
|
||
player.gameData.used.logisticsInfo[ k ] = nil
|
||
break
|
||
end
|
||
end
|
||
end
|
||
|
||
--多出的15个卖出记录就删除前面的
|
||
count = 0
|
||
for k, v in pairs(player.gameData.used.sellInfo ) do
|
||
if self.SellStatus_AlreadySell == v.status then
|
||
count = count + 1
|
||
end
|
||
end
|
||
|
||
if count >= 15 then
|
||
local deleteCount = count - 15
|
||
local tmpCount = 0
|
||
for k, v in pairs(player.gameData.used.sellInfo ) do
|
||
if tmpCount >= deleteCount then
|
||
break
|
||
end
|
||
if self.SellStatus_AlreadySell == v.status then
|
||
player.gameData.used.sellInfo[ k ] = nil
|
||
tmpCount = tmpCount + 1
|
||
end
|
||
end
|
||
end
|
||
|
||
data.buyRefreshTime = player.gameData.used.buyRefreshTime
|
||
data.buyInfo = player.gameData.used.buyInfo
|
||
data.sellInfo = self:GetSellInfo( player )
|
||
data.logisticsInfo = self:GetLogisticsInfo( player )
|
||
skynet.server.msgTips:Reduce( player , 3)
|
||
skynet.server.msgTips:Reduce( player , 16)
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_UsedShow")
|
||
s2cData.data = assert(pb.encode("S2CUsedShow", data))
|
||
end
|
||
|
||
--闲菜购买
|
||
function Used:Buy( player , c2sData , s2cData )
|
||
c2sData.data = assert(pb.decode("C2SUsedBuy", c2sData.data ))
|
||
local data = {}
|
||
local goodsId = c2sData.data.goodsId
|
||
if not goodsId then
|
||
s2cData.code = errorInfo.ErrorCode.ErrRequestParam
|
||
else
|
||
for k, v in pairs( player.gameData.used.buyInfo ) do
|
||
if goodsId == v.goodsId then
|
||
--找到对应的商品，扣除金额
|
||
if player:MoneyChange( dataType.GoodsType_Coin , -v.coin ) then
|
||
player.gameData.used.buyInfo[ k ].isBuy = true
|
||
|
||
--计算物流到达时间
|
||
local cfgGoods = skynet.server.gameConfig:GetCurFurnitureCfg( v.goodsId )
|
||
local discount = skynet.server.gameConfig.SValue.picklesSellDiscount
|
||
local calcDeliverTime = math.floor(skynet.server.gameConfig.SValue.picklesDeliveryTime * discount * cfgGoods.coin ) * 60
|
||
local reachTime = skynet.GetTime() + calcDeliverTime
|
||
table.insert( player.gameData.used.logisticsInfo , { goodsId = v.goodsId , npcNameId = v.npcNameId , copyId = v.copyId , goodsStatus = self.GoodsStatus_NoReach , reachTime = reachTime , deliverTime = calcDeliverTime } )
|
||
skynet.server.levelTask:Modify( player , dataType.GeneralTaskType_BuyUsed , 1)
|
||
skynet.server.dailyTask:Modify( player , 4 , 1)
|
||
skynet.server.passCheck:Modify( player , 3 , v.coin )
|
||
skynet.server.passCheck:Modify( player , 21 , 1 )
|
||
|
||
--增加经验
|
||
local exp = skynet.server.bag:CalcExp( dataType.GoodsType_Furniture , goodsId, 1 )
|
||
player:AddExp( exp )
|
||
log.info(string.format("玩家 %d 闲菜 购买商品 商品ID %d NPC名字ID %d 对白ID %d 购买金币 %d 到达时间 %d" , player.basicInfo.userID , goodsId , v.npcNameId , v.copyId , v.coin , reachTime))
|
||
else
|
||
s2cData.code = errorInfo.ErrorCode.NoEnoughMoney
|
||
end
|
||
break
|
||
end
|
||
end
|
||
end
|
||
|
||
self:CheckRefreshGoods( player )
|
||
|
||
data.buyInfo = player.gameData.used.buyInfo
|
||
data.logisticsInfo = self:GetLogisticsInfo( player )
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_UsedBuy")
|
||
s2cData.data = assert(pb.encode("S2CUsedBuy", data))
|
||
end
|
||
|
||
--闲菜刷新
|
||
function Used:Refresh( player , c2sData , s2cData )
|
||
c2sData.data = assert(pb.decode("C2SUsedRefresh", c2sData.data ))
|
||
local data = {}
|
||
local cfgSValue = skynet.server.gameConfig.SValue
|
||
if player:MoneyChange( dataType.MoneyType_Volute , -cfgSValue.sellRefreshCost ) then
|
||
player.gameData.used.buyRefreshTime = skynet.GetTime() + cfgSValue.picklesRefreshTime * 60
|
||
log.info(string.format("玩家 %d 闲菜 刷新操作 下一次刷新时间 %d" , player.basicInfo.userID , player.gameData.used.buyRefreshTime))
|
||
|
||
player.gameData.used.buyInfo = self:RefreshGoods( player )
|
||
skynet.server.achieveTask:Modify( player , 34 , 1)
|
||
else
|
||
s2cData.code = errorInfo.ErrorCode.NoEnoughMoney
|
||
end
|
||
|
||
data.buyRefreshTime = player.gameData.used.buyRefreshTime
|
||
data.buyInfo = player.gameData.used.buyInfo
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_UsedRefresh")
|
||
s2cData.data = assert(pb.encode("S2CUsedRefresh", data))
|
||
end
|
||
|
||
--闲菜出售
|
||
function Used:Sell( player , c2sData , s2cData )
|
||
c2sData.data = assert(pb.decode("C2SUsedSell", c2sData.data ))
|
||
local data = {}
|
||
local opType = c2sData.data.opType
|
||
local goodsType = c2sData.data.goodsType
|
||
local goodsId = c2sData.data.goodsId
|
||
if not opType or not goodsType or not goodsId then
|
||
s2cData.code = errorInfo.ErrorCode.ErrRequestParam
|
||
else
|
||
|
||
if self.SellOPType_StartSell == opType then --开始出售
|
||
local isSell = false
|
||
if goodsType >= dataType.GoodsType_Furniture and goodsType < dataType.GoodsType_End and
|
||
goodsType ~= dataType.GoodsType_Decorate and goodsType ~= dataType.GoodsType_Flowerpot then
|
||
isSell = true
|
||
end
|
||
|
||
if player:IsBuyGoods( goodsType , goodsId ) then
|
||
if isSell then
|
||
--从背包中移出该商品
|
||
skynet.server.bag:RemoveGoods( player , dataType.GoodsType_Furniture , goodsId , 1 )
|
||
--加入闲菜卖家数据
|
||
local cfgGoods = skynet.server.gameConfig:GetCurFurnitureCfg( goodsId )
|
||
local discount = skynet.server.gameConfig.SValue.picklesSellDiscount
|
||
local sellTime = skynet.GetTime() + (math.floor(skynet.server.gameConfig.SValue.picklesDeliveryTime * discount * cfgGoods.coin ) * 60) --计算售卖时间
|
||
table.insert( player.gameData.used.sellInfo , { goodsId = goodsId , status = self.SellStatus_NoSell , npcNameId = 0 , copyId = 0 , coin = math.floor(cfgGoods.coin * discount) , sellTime = sellTime })
|
||
log.info(string.format("玩家 %d 闲菜 售卖操作 开始售卖 商品ID %d" , player.basicInfo.userID , goodsId))
|
||
end
|
||
else
|
||
s2cData.code = errorInfo.ErrorCode.NoGoodsID
|
||
end
|
||
elseif self.SellOPType_StopSell == opType then --停止出售
|
||
for k, v in pairs( player.gameData.used.sellInfo ) do
|
||
if self.SellStatus_NoSell == v.status and goodsId == v.goodsId then
|
||
--未卖出并且找到对应的商品ID
|
||
local cfgGoods = skynet.server.gameConfig:GetCurFurnitureCfg( goodsId )
|
||
skynet.server.bag:AddGoods( player , dataType.GoodsType_Furniture , goodsId , 1 )
|
||
player.gameData.used.sellInfo[ k ] = nil
|
||
log.info(string.format("玩家 %d 闲菜 售卖操作 停止售卖 商品ID %d" , player.basicInfo.userID , goodsId))
|
||
break
|
||
end
|
||
end
|
||
elseif self.SellOPType_ConfirmSell == opType then --确定出售
|
||
for k, v in pairs( player.gameData.used.sellInfo ) do
|
||
if self.SellStatus_SomeoneWant == v.status and goodsId == v.goodsId then
|
||
player.gameData.used.sellInfo[ k ].status = self.SellStatus_AlreadySell
|
||
|
||
--领取金币
|
||
player:MoneyChange( dataType.MoneyType_Coin , v.coin )
|
||
--增加经验
|
||
--local exp = skynet.server.bag:CalcExp( dataType.GoodsType_Furniture , goodsId, 1 )
|
||
--player:AddExp( exp )
|
||
|
||
skynet.server.levelTask:Modify( player , dataType.GeneralTaskType_SellUsed , 1)
|
||
skynet.server.dailyTask:Modify( player , 9 , 1)
|
||
skynet.server.passCheck:Modify( player , 4 , v.coin )
|
||
skynet.server.passCheck:Modify( player , 22 , 1 )
|
||
log.info(string.format("玩家 %d 闲菜 售卖操作 领取奖励 商品ID %d" , player.basicInfo.userID , goodsId))
|
||
break
|
||
end
|
||
end
|
||
end
|
||
end
|
||
|
||
self:CheckRefreshGoods( player )
|
||
data.sellInfo = self:GetSellInfo( player )
|
||
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_UsedSell")
|
||
s2cData.data = assert(pb.encode("S2CUsedSell", data))
|
||
end
|
||
|
||
--闲菜物流
|
||
function Used:Logistics( player , c2sData , s2cData )
|
||
c2sData.data = assert(pb.decode("C2SUsedLogistics", c2sData.data ))
|
||
local data = {}
|
||
data.goodsId = {}
|
||
|
||
local goodsId = c2sData.data.goodsId
|
||
if 0 == #goodsId then
|
||
s2cData.code = errorInfo.ErrorCode.ErrRequestParam
|
||
end
|
||
|
||
for k, oneGoodsId in pairs( goodsId ) do
|
||
if not oneGoodsId then
|
||
s2cData.code = errorInfo.ErrorCode.ErrRequestParam
|
||
else
|
||
for k, v in pairs( player.gameData.used.logisticsInfo ) do
|
||
if self.GoodsStatus_AlreadyReach == v.goodsStatus and oneGoodsId == v.goodsId then
|
||
--签收物流中商品
|
||
skynet.server.bag:AddGoods( player , dataType.GoodsType_Furniture , oneGoodsId , 1 )
|
||
v.goodsStatus = self.GoodsStatus_AlreadyGet
|
||
skynet.server.levelTask:Modify( player , dataType.GeneralTaskType_ReciveUsed , 1)
|
||
skynet.server.dailyTask:Modify( player , 10 , 1)
|
||
table.insert( data.goodsId , oneGoodsId )
|
||
skynet.server.msgTips:Reduce( player , 4)
|
||
log.info(string.format("玩家 %d 闲菜 物流签收 领取奖励 商品ID %d" , player.basicInfo.userID , oneGoodsId))
|
||
end
|
||
end
|
||
end
|
||
end
|
||
|
||
self:CheckRefreshGoods( player )
|
||
data.logisticsInfo = self:GetLogisticsInfo( player )
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_UsedLogistics")
|
||
s2cData.data = assert(pb.encode("S2CUsedLogistics", data))
|
||
end
|
||
|
||
--闲菜物流展示
|
||
function Used:LogisticsShow( player , c2sData , s2cData )
|
||
local data = {}
|
||
data.logisticsInfo =self:GetLogisticsInfo( player )
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_UsedLogisticsShow")
|
||
s2cData.data = assert(pb.encode("S2CUsedLogisticsShow", data))
|
||
end
|
||
|
||
--闲菜查看仓库
|
||
function Used:StorageShow( player , c2sData , s2cData )
|
||
c2sData.data = assert(pb.decode("C2SUsedStorageShow", c2sData.data ))
|
||
local data = {}
|
||
local goodsType = c2sData.data.goodsType
|
||
if not goodsType then
|
||
s2cData.code = errorInfo.ErrorCode.ErrRequestParam
|
||
else
|
||
data.goodsType = goodsType
|
||
data.goodsInfo = skynet.server.bag:GetUnusedGoodsInfo( player , goodsType )
|
||
end
|
||
|
||
self:CheckRefreshGoods( player )
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_UsedStorageShow")
|
||
s2cData.data = assert(pb.encode("S2CUsedStorageShow", data))
|
||
end
|
||
|
||
--闲菜出售加速
|
||
function Used:SellAccelerate( player , c2sData , s2cData )
|
||
local data = {}
|
||
local cfgSValue = skynet.server.gameConfig.SValue
|
||
if not player:MoneyChange( dataType.MoneyType_Volute , -cfgSValue.pickleCustomerCost ) then
|
||
s2cData.code = errorInfo.ErrorCode.NoEnoughMoney
|
||
else
|
||
self:AccSell( player ) --加速
|
||
data.sellInfo = self:GetSellInfo( player )
|
||
end
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_UsedSellAccelerate")
|
||
s2cData.data = assert(pb.encode("S2CUsedSellAccelerate", data))
|
||
end
|
||
|
||
--检查商品是否能刷新
|
||
function Used:CheckRefreshGoods( player )
|
||
--刷新商店购买时间
|
||
if skynet.GetTime() >= player.gameData.used.buyRefreshTime then
|
||
local cfgSValue = skynet.server.gameConfig.SValue
|
||
player.gameData.used.buyRefreshTime = skynet.GetTime() + cfgSValue.picklesRefreshTime * 60
|
||
player.gameData.used.buyInfo = self:RefreshGoods( player )
|
||
end
|
||
|
||
--刷新已经卖出的商品
|
||
for k, v in pairs( player.gameData.used.sellInfo ) do
|
||
if skynet.GetTime() >= v.sellTime and self.SellStatus_NoSell == v.status then
|
||
--成功售卖
|
||
player.gameData.used.sellInfo[ k ].status = self.SellStatus_SomeoneWant
|
||
|
||
--随机NPC名字ID
|
||
local npcNameList = skynet.server.common:RandNoRepeatItem( 1 , skynet.server.gameConfig.NPCName )
|
||
if not npcNameList then
|
||
log.info("闲菜随机的NPC名字异常 ", npcNameList )
|
||
end
|
||
|
||
--随机文案ID
|
||
local cfgCopy = {}
|
||
for k, v in pairs( skynet.server.gameConfig.Copy ) do
|
||
if self.CopyType_Buyer == v.type then
|
||
table.insert( cfgCopy , v)
|
||
end
|
||
end
|
||
local copyList = skynet.server.common:RandNoRepeatItem( 1 , cfgCopy )
|
||
if not copyList then
|
||
log.info("闲菜随机的文案ID异常 ", copyList , #copyList)
|
||
end
|
||
|
||
player.gameData.used.sellInfo[ k ].npcNameId = npcNameList[1]
|
||
player.gameData.used.sellInfo[ k ].copyId = copyList[1]
|
||
end
|
||
end
|
||
|
||
--刷新物流是否到了
|
||
for k, v in pairs( player.gameData.used.logisticsInfo ) do
|
||
if skynet.GetTime() >= v.reachTime and self.GoodsStatus_NoReach == v.goodsStatus then
|
||
--商品已到达
|
||
player.gameData.used.logisticsInfo[ k ].goodsStatus = self.GoodsStatus_AlreadyReach
|
||
end
|
||
end
|
||
end
|
||
|
||
--刷新购买商品
|
||
function Used:RefreshGoods( player )
|
||
local count = 0
|
||
local buyInfo = {}
|
||
local maxItem = 6 --最大生成
|
||
|
||
local newFurniture = {}
|
||
for k, v in pairs( skynet.server.gameConfig.Furniture ) do
|
||
--找出配置中闲菜可以买的数据
|
||
if 1 == v.marketType and player.gameData.level >= v.level then
|
||
table.insert( newFurniture , v )
|
||
end
|
||
end
|
||
|
||
--随机商品ID
|
||
local goodsList = skynet.server.common:RandNoRepeatItem( maxItem , newFurniture )
|
||
if not goodsList or maxItem ~= #goodsList then
|
||
log.info("闲菜随机的商品异常 ", goodsList , #goodsList)
|
||
end
|
||
|
||
if player.gameData.used.isFirstRefresh then
|
||
--第一次刷新，给指定商品
|
||
player.gameData.used.isFirstRefresh = false
|
||
goodsList = {}
|
||
table.insert( goodsList , 206)
|
||
table.insert( goodsList , 209)
|
||
table.insert( goodsList , 99)
|
||
table.insert( goodsList , 106)
|
||
table.insert( goodsList , 7)
|
||
table.insert( goodsList , 205)
|
||
end
|
||
|
||
--随机NPC名字ID
|
||
local npcNameList = skynet.server.common:RandNoRepeatItem( maxItem , skynet.server.gameConfig.NPCName )
|
||
if not npcNameList or maxItem ~= #npcNameList then
|
||
log.info("闲菜随机的NPC名字异常 ", npcNameList , #npcNameList)
|
||
end
|
||
|
||
--随机文案ID
|
||
local cfgCopy = {}
|
||
for k, v in pairs( skynet.server.gameConfig.Copy ) do
|
||
if self.CopyType_Seller == v.type then
|
||
table.insert( cfgCopy , v)
|
||
end
|
||
end
|
||
local copyList = skynet.server.common:RandNoRepeatItem( maxItem , cfgCopy )
|
||
|
||
if not copyList or maxItem ~= #copyList then
|
||
log.info("闲菜随机的文案ID异常 ", copyList , #copyList)
|
||
end
|
||
|
||
--从3个配置中去随机，万一哪个配置被动了，可能会遇到没有随机到指定数量的配置，那么在3个中找一个数量最少的去生成
|
||
local count1 = #goodsList
|
||
local count2 = #npcNameList
|
||
local count3 = #copyList
|
||
|
||
if maxItem < count1 then
|
||
maxItem = count1
|
||
end
|
||
if maxItem < count2 then
|
||
maxItem = count2
|
||
end
|
||
if maxItem < count3 then
|
||
maxItem = count3
|
||
end
|
||
|
||
--获取最终商品
|
||
local discountCoin = 0
|
||
for i = 1, maxItem, 1 do
|
||
discountCoin = self:GetDiscountPrice( goodsList[i] )
|
||
table.insert( buyInfo , { goodsId = goodsList[i] , npcNameId = npcNameList[i] , copyId = copyList[i] , isBuy = false , coin = discountCoin })
|
||
log.info(string.format("玩家 %d 闲菜 刷新商品 商品ID %d NPC名字ID %d 对白ID %d 金币 %d" , player.basicInfo.userID , goodsList[i] , npcNameList[i] , copyList[i] , discountCoin ))
|
||
end
|
||
return buyInfo
|
||
end
|
||
|
||
--广告加速卖出
|
||
function Used:AccSell( player )
|
||
for k, v in pairs( player.gameData.used.sellInfo ) do
|
||
--所有未卖出商品全部可以卖出
|
||
if self.SellStatus_NoSell == v.status then
|
||
v.sellTime = 0
|
||
end
|
||
end
|
||
|
||
--刷新一下
|
||
self:CheckRefreshGoods( player )
|
||
|
||
--重新发送一下展示消息
|
||
--[[
|
||
local data = {}
|
||
data.buyRefreshTime = player.gameData.used.buyRefreshTime
|
||
data.buyInfo = player.gameData.used.buyInfo
|
||
data.sellInfo = self:GetSellInfo( player )
|
||
data.logisticsInfo = self:GetLogisticsInfo( player )
|
||
skynet.server.gameServer:SendMsgToUser( player.userId , "CMD_S2C_UsedShow" , data )
|
||
]]
|
||
end
|
||
|
||
--获取折扣价格
|
||
function Used:GetDiscountPrice( id )
|
||
local cfgFurniture = skynet.server.gameConfig.Furniture
|
||
local picklesBuyDiscount = skynet.server.gameConfig.SValue.picklesBuyDiscount
|
||
local ratio = math.random( picklesBuyDiscount[1] , picklesBuyDiscount[2]) / 100
|
||
for k, v in pairs( cfgFurniture ) do
|
||
if id == v.id then
|
||
local price = math.ceil(ratio * v.coin)
|
||
log.info(string.format("闲菜计算商品折扣 最终金币数价格 %d 折扣率 %f 原需要金币数 %d" , price , ratio , v.coin))
|
||
return price
|
||
end
|
||
end
|
||
end
|
||
|
||
--获取售卖数据
|
||
function Used:GetSellInfo( player )
|
||
local data = {}
|
||
for k, v in pairs( player.gameData.used.sellInfo ) do
|
||
--上面删除指定记录后，为什么无法直接 赋值= 的方式，必须要这样拷贝，难道数组没有1以后，就找不到首地址
|
||
table.insert( data , v)
|
||
end
|
||
return data
|
||
end
|
||
|
||
--获取物流数据
|
||
function Used:GetLogisticsInfo( player )
|
||
local data = {}
|
||
for k, v in pairs( player.gameData.used.logisticsInfo ) do
|
||
--上面删除指定记录后，为什么无法直接 赋值= 的方式，必须要这样拷贝，难道数组没有1以后，就找不到首地址
|
||
table.insert( data , v)
|
||
end
|
||
return data
|
||
end
|
||
|
||
skynet.server.used = Used
|
||
return Used
|