无尽修改

lvxinran 2021-06-08 14:19:59 +08:00
parent ad24318ef5
commit 5feec114b7
5 changed files with 30 additions and 36 deletions

View File

@ -13,7 +13,6 @@ public class EndlessTreasureReward extends MongoBase {
private int createTime; //取当天零点 根据其可以推算出期数。
private int score;
private int isBuy;
private Map<Integer,Integer> rewardStatusMap = new HashMap<>(); //领取状态 1表示领取基础奖励 2表示领取额外奖励。
@ -21,39 +20,17 @@ public class EndlessTreasureReward extends MongoBase {
this.setRootCollection(User._COLLECTION_NAME);
}
public void reset(){
updataCreateTime((int)(TimeUtils.getMonthStartTime(1,1)/1000) -1);
setRewardStatusMap(new HashMap<>());
setIsBuy(0);
}
public int getCreateTime() {
return createTime;
}
public int getScore() {
return score;
}
public void setScore(int score) {
this.score = score;
}
public Map<Integer, Integer> getRewardStatusMap() {
return rewardStatusMap;
}
public void setRewardStatusMap(Map<Integer, Integer> rewardStatusMap) {
this.rewardStatusMap = rewardStatusMap;
updateString("rewardStatusMap",rewardStatusMap);
}
public void updateMissionStatus(int id, int value){
rewardStatusMap.put(id,value);
updateString("rewardStatusMap."+id, value);
}
public int getIsBuy() {
@ -62,10 +39,8 @@ public class EndlessTreasureReward extends MongoBase {
public void setIsBuy(int isBuy) {
this.isBuy = isBuy;
updateString("isBuy",isBuy);
}
public void updataCreateTime(int createTime){
public void setCreateTime(int createTime){
this.createTime = createTime;
updateString("createTime",createTime);
}
}

View File

@ -6,7 +6,6 @@ import com.ljsd.jieling.core.FunctionIdEnum;
import com.ljsd.jieling.core.GlobalsDef;
import com.ljsd.jieling.core.VipPrivilegeType;
import com.ljsd.jieling.dataReport.reportBeans_37.ChatContentType;
import com.ljsd.jieling.db.mongo.MongoUtil;
import com.ljsd.jieling.db.redis.RedisKey;
import com.ljsd.jieling.db.redis.RedisUtil;
import com.ljsd.jieling.exception.ErrorCode;
@ -3400,7 +3399,6 @@ public class MapLogic {
states.add(builder.build());
});
response.addAllTreasureRewardState(states);
response.setScore(worldTreasureReward.getScore());
response.setResetTime(worldTreasureReward.getCreateTime());
response.setIsBuy(worldTreasureReward.getIsBuy());
// }else {
@ -3411,7 +3409,7 @@ public class MapLogic {
}
public void flushEndlessTreasure(User user) throws Exception {
if(user.getMapManager().getEndlessTreasureReward().getCreateTime()<TimeUtils.nowInt()){
user.getMapManager().getEndlessTreasureReward().reset();
user.getMapManager().resetEndlessTreasure();
Item item = user.getItemManager().getItem(102);//升级积分清除
if(item!=null&&item.getItemNum()>0){
item.setItemNum(0);

View File

@ -123,7 +123,7 @@ public class MapManager extends MongoBase {
private int currentJourneyId;
private EndlessTreasureReward endlessTreasureReward;
private EndlessTreasureReward endlessTreasureReward = new EndlessTreasureReward();
public MapManager() {
this.setRootCollection(User._COLLECTION_NAME);
@ -910,10 +910,6 @@ public class MapManager extends MongoBase {
}
public EndlessTreasureReward getEndlessTreasureReward() {
if(endlessTreasureReward==null){
endlessTreasureReward = new EndlessTreasureReward();
endlessTreasureReward.init(getRootId(), MongoKey.mapManager+"."+"endlessTreasureReward");
}
return endlessTreasureReward;
}
@ -940,6 +936,31 @@ public class MapManager extends MongoBase {
removeString("endlessMapInfo.monsterHp."+position);
}
public void updateTreasureCreateTime(int time){
endlessTreasureReward.setCreateTime(time);
updateString("endlessTreasureReward.createTime",time);
}
public void setTreasureRewardStatusMap(Map<Integer, Integer> rewardStatusMap){
endlessTreasureReward.setRewardStatusMap(rewardStatusMap);
updateString("endlessTreasureReward.rewardStatusMap",rewardStatusMap);
}
public void setTreasureIsBuy(int isBuy){
endlessTreasureReward.setIsBuy(isBuy);
updateString("endlessTreasureReward.isBuy",isBuy);
}
public void updateMissionStatus(int id, int value){
endlessTreasureReward.getRewardStatusMap().put(id,value);
updateString("endlessTreasureReward.rewardStatusMap."+id,value);
}
public void resetEndlessTreasure(){
updateTreasureCreateTime((int)(TimeUtils.getMonthStartTime(1,1)/1000) -1);
setTreasureRewardStatusMap(new HashMap<>());
setTreasureIsBuy(0);
}
}

View File

@ -67,7 +67,7 @@ public class TakeEndlessTreasureHandler extends BaseHandler<MapInfoProto.Endless
dropByState(endlessTreasure, drops, curState, changeState);
endlessTreasureReward.updateMissionStatus(id, changeState);
user.getMapManager().updateMissionStatus(id, changeState);
CommonProto.Drop.Builder drop = ItemUtil.drop(user, drops, BIReason.ENDLESS_TREASURE_REWARD);
MapInfoProto.EndlessTakeTreasureResponse build = MapInfoProto.EndlessTakeTreasureResponse.newBuilder().setDrop(drop).build();

View File

@ -370,7 +370,7 @@ public class BuyGoodsNewLogic {
MessageUtil.sendIndicationMessage(OnlineUserManager.getSessionByUid(user.getId()),1,MessageTypeProto.MessageType.TREASURE_LEVELUP_INDICATION_VALUE,indication,true);
}
if(type==GiftGoodsType.ENDLESS_TREASURE){
user.getMapManager().getEndlessTreasureReward().setIsBuy(1);
user.getMapManager().setTreasureIsBuy(1);
}
if(drop!=null&&session!=null){