Merge branch 'master_test_hw' of http://60.1.1.230/backend/jieling_server into master_test_hw
commit
70d170c341
|
@ -186,27 +186,27 @@ public class ChatLogic {
|
|||
break;
|
||||
case 3: //好友
|
||||
List<Integer> friends = friendManager.getFriends();
|
||||
if (!friends.contains(friendId)){
|
||||
if (!friends.contains(friendId)) {
|
||||
throw new ErrorCodeException(ErrorCode.CHAT_NOT_FRIENDS);
|
||||
}
|
||||
//现在好友推送
|
||||
if (OnlineUserManager.checkUidOnline(friendId)){
|
||||
if (OnlineUserManager.checkUidOnline(friendId)) {
|
||||
ISession sessionByUid = OnlineUserManager.getSessionByUid(friendId);
|
||||
chatInfo = CBean2Proto.getChatInfoBuilder(user,message,nowTime,0);
|
||||
chatInfo = CBean2Proto.getChatInfoBuilder(user, message, nowTime, 0);
|
||||
sendChatInfoIndication = ChatProto.SendChatInfoIndication.newBuilder()
|
||||
.setChatInfo(chatInfo)
|
||||
.setType(1)
|
||||
.build();
|
||||
assert sessionByUid != null;
|
||||
MessageUtil.sendIndicationMessage(sessionByUid, 1, MessageTypeProto.MessageType.SEND_CHAT_INFO_INDICATION_VALUE, sendChatInfoIndication, true);
|
||||
}else{
|
||||
RedisUtil.getInstence().hset(GameApplication.serverId +RedisKey.CUser_Chat+friendId,uid +"#"+ nowTime,message, -1);
|
||||
} else {
|
||||
RedisUtil.getInstence().hset(GameApplication.serverId + RedisKey.CUser_Chat + friendId, uid + "#" + nowTime, message, -1);
|
||||
}
|
||||
|
||||
break;
|
||||
default:{
|
||||
break;
|
||||
}
|
||||
default: {
|
||||
break;
|
||||
}
|
||||
}
|
||||
onSendChatSuccess(user,chatType,message);
|
||||
ReportUtil.onReportEvent(user, ReportEventEnum.SEND_MESSAGE.getType(),String.valueOf(chatType),message);
|
||||
|
|
|
@ -2,13 +2,15 @@ package com.ljsd.jieling.db.mongo;
|
|||
|
||||
import com.google.gson.*;
|
||||
import com.ljsd.jieling.util.SysUtil;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import java.io.*;
|
||||
import java.nio.charset.Charset;
|
||||
import java.nio.file.Files;
|
||||
|
||||
public class MongoUtiltest {
|
||||
|
||||
private static final Logger LOGGER = LoggerFactory.getLogger(MongoUtiltest.class);
|
||||
public static void main(String[] args) {
|
||||
|
||||
try {
|
||||
|
@ -30,7 +32,7 @@ public class MongoUtiltest {
|
|||
StringBuilder stringBuilder2 = new StringBuilder();
|
||||
if (MongoUtil.equill(obj1, obj, stringBuilder,stringBuilder2)) {
|
||||
|
||||
System.out.println("匹配");
|
||||
LOGGER.info("匹配");
|
||||
} else {
|
||||
|
||||
File file3 = new File(SysUtil.getPath("conf/checkout_diffmem__" +dbf3.getName()+ ".txt"));
|
||||
|
|
|
@ -57,7 +57,7 @@ public class FamilyFeteRequestHandler extends BaseHandler<Family.FamilyFeteReque
|
|||
}
|
||||
|
||||
//check cost
|
||||
boolean enough = ItemUtil.itemCost(user, sGuildSacrificeConfig.getExpend(), BIReason.FETE_CONSUME, 0);
|
||||
boolean enough = ItemUtil.itemCost(user, sGuildSacrificeConfig.getExpend(), BIReason.FETE_CONSUME, type);
|
||||
if (!enough) {
|
||||
throw new ErrorCodeException(ErrorCode.ITEM_NOT_ENOUGH);
|
||||
}
|
||||
|
|
|
@ -13,7 +13,7 @@ public class EventType {
|
|||
public static final int businessman = 6;
|
||||
public static final int box = 7;
|
||||
public static final int hinder = 8;
|
||||
public static final int allEvents = 9;
|
||||
public static final int towerBuff = 9;
|
||||
public static final int suddenlyBoss = 11; //精英怪
|
||||
|
||||
/**
|
||||
|
|
|
@ -657,6 +657,11 @@ public class MapLogic {
|
|||
SEventPointConfig sEventPointConfig = STableManager.getConfig(SEventPointConfig.class).get(initialEventId);
|
||||
StoreLogic.initOneStore(user, sEventPointConfig.getOption()[0]);
|
||||
}
|
||||
}else if(mapPointConfig.getStyle()==EventType.towerBuff){
|
||||
if(cell.getEventId()==0){
|
||||
BehaviorUtil.destoryApointXY(user,triggerXY);
|
||||
throw new ErrorCodeException(ErrorCode.newDefineCode("该点已被清除"));
|
||||
}
|
||||
}
|
||||
|
||||
mapManager.setTriggerXY(triggerXY);
|
||||
|
|
|
@ -349,12 +349,12 @@ public class EndlessMap extends AbstractMap{
|
|||
mapManager.updateEndlessConsumeExecution(mapManager.getEndlessMapInfo().getConsumeExecution()+costNum);
|
||||
int [] cost1 = new int[]{costId,costNum};
|
||||
cost[0] = cost1;
|
||||
boolean costResult = ItemUtil.itemCost(user, cost, BIReason.ENDLESS_CONSUME_EXECUTION, 1);
|
||||
boolean costResult = ItemUtil.itemCost(user, cost, BIReason.ENDLESS_CONSUME_EXECUTION, mapManager.getCurMapId());
|
||||
if(!costResult) {
|
||||
costNum = user.getItemManager().getItem(costId).getItemNum();
|
||||
cost1[1]= costNum;
|
||||
cost[0] = cost1;
|
||||
ItemUtil.itemCost(user,cost,BIReason.ENDLESS_CONSUME_EXECUTION,1);
|
||||
ItemUtil.itemCost(user,cost,BIReason.ENDLESS_CONSUME_EXECUTION,mapManager.getCurMapId());
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -471,6 +471,7 @@ public class EndlessMap extends AbstractMap{
|
|||
}
|
||||
}
|
||||
private int getMapIdByWorldLevel() throws Exception {
|
||||
// return 4002;
|
||||
return GlobalDataManaager.getEndleeMapIdByLevel();
|
||||
|
||||
}
|
||||
|
|
|
@ -1,6 +1,8 @@
|
|||
package com.ljsd.jieling.kefu;
|
||||
|
||||
import com.ljsd.jieling.core.Lockeys;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import java.util.HashSet;
|
||||
import java.util.Set;
|
||||
|
@ -11,6 +13,7 @@ import java.util.Set;
|
|||
* CreateDate: 2020/6/11 11:48
|
||||
*/
|
||||
public class Cmd_test_lock extends GmAbstract {
|
||||
private static final Logger LOGGER = LoggerFactory.getLogger(Cmd_test_lock.class);
|
||||
@Override
|
||||
public boolean exec(String[] args) throws Exception {
|
||||
Set<Integer> sendUids = new HashSet<>();
|
||||
|
@ -20,7 +23,7 @@ public class Cmd_test_lock extends GmAbstract {
|
|||
while (i++<10){
|
||||
String name = Thread.currentThread().getName();
|
||||
Thread.currentThread().sleep(1000);
|
||||
System.out.println("name"+name+" = [" + i + "]");
|
||||
LOGGER.info("name=>{}, i=>{}",name, i);
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
|
|
@ -909,8 +909,8 @@ public class ActivityLogic implements IEventHandler{
|
|||
temp[0] = costConfig[0][0];
|
||||
temp[1] = (int) MathUtils.calABX(activityProgressInfoMap.get(BlessInfoConfig.BLESS_PROGRESS_STATUS).getProgrss(), costConfig[1]);
|
||||
cost[0] = temp;
|
||||
LOGGER.info("本次为第{}次抽取,消耗{}个数为{}", activityProgressInfoMap.get(BlessInfoConfig.BLESS_PROGRESS_STATUS).getProgrss(), temp[0], temp[1]);
|
||||
boolean costResult = ItemUtil.itemCost(user, cost, BIReason.BLESS_CHOOSE_CONSUME, 1);
|
||||
LOGGER.info("blessChoose uid=>{} 本次为第{}次抽取,消耗{}个数为{}", user.getId(), activityProgressInfoMap.get(BlessInfoConfig.BLESS_PROGRESS_STATUS).getProgrss(), temp[0], temp[1]);
|
||||
boolean costResult = ItemUtil.itemCost(user, cost, BIReason.BLESS_CHOOSE_CONSUME, locationId);
|
||||
if (!costResult) {
|
||||
throw new ErrorCodeException(ErrorCode.ITEM_NOT_ENOUGH);
|
||||
}
|
||||
|
@ -930,7 +930,7 @@ public class ActivityLogic implements IEventHandler{
|
|||
break;
|
||||
}
|
||||
}
|
||||
LOGGER.info("本次抽取的Id为{}", resultRewardId);
|
||||
LOGGER.info("blessChoose uid=>{}本次抽取的Id为{}", user.getId(), resultRewardId);
|
||||
Map<Integer, SBlessingRewardPool> poolMap = STableManager.getConfig(SBlessingRewardPool.class);
|
||||
int[][] dropItem = new int[1][];
|
||||
for (Integer count : SBlessingConfig.blessingConfigMap.get(blessActivityId).getCounts()) {
|
||||
|
@ -1266,7 +1266,7 @@ public class ActivityLogic implements IEventHandler{
|
|||
int[][] costItems = new int[1][];
|
||||
int[] costTemp = {cost[0][0],num};
|
||||
costItems[0]=costTemp;
|
||||
boolean result = ItemUtil.itemCost(user,costItems,BIReason.TREASURE_BUY_LEVEL_CONSUME,1);
|
||||
boolean result = ItemUtil.itemCost(user,costItems,BIReason.TREASURE_BUY_LEVEL_CONSUME, level);
|
||||
if(result) {
|
||||
user.getPlayerInfoManager().setTreasureLevel(level);
|
||||
}else{
|
||||
|
|
|
@ -391,7 +391,7 @@ public class ChampionshipLogic {
|
|||
MailLogic.getInstance().sendMail(user.getId(), title, content, ItemUtil.getMailReward(sChampionshipReward.getSeasonReward()), nowTime, Global.MAIL_EFFECTIVE_TIME);
|
||||
}
|
||||
}catch (Exception e){
|
||||
System.out.println("Exception e = "+"size"+ arenaRankInfo.size()+ e.toString());
|
||||
LOGGER.info("Exception e = "+"size"+ arenaRankInfo.size()+ e.toString());
|
||||
}
|
||||
|
||||
MongoUtil.getLjsdMongoTemplate().lastUpdate();
|
||||
|
@ -411,7 +411,7 @@ public class ChampionshipLogic {
|
|||
costs[0] = new int[2];
|
||||
costs[0][0] = arenaItemId;
|
||||
costs[0][1] = itemNum;
|
||||
ItemUtil.itemCost(user, costs, BIReason.CHAMPIONM_EXCHANGE_CONSUME, 0);
|
||||
ItemUtil.itemCost(user, costs, BIReason.CHAMPIONM_EXCHANGE_CONSUME, sendId);
|
||||
Map<Integer, Integer> itemReward = new HashMap<>(1);
|
||||
itemReward.put(rewardItemId, itemNum / sChampionshipSetting.getExchangeItem());
|
||||
ItemUtil.addItem(user, itemReward, null, BIReason.CHAMPIONM_EXCHANGE_REWARD);
|
||||
|
|
|
@ -113,7 +113,7 @@ public class GuildChallengeLogic {
|
|||
}
|
||||
int remainHp;
|
||||
if(bossHpRemain==0){
|
||||
remainHp = 0;
|
||||
remainHp = 10000;
|
||||
}else if(bossHpRemain==-1){
|
||||
remainHp = -1;
|
||||
}else{
|
||||
|
@ -304,7 +304,7 @@ public class GuildChallengeLogic {
|
|||
}
|
||||
int remainHp;
|
||||
if(guildInfo.getBossHpRemain()==0){
|
||||
remainHp = 0;
|
||||
remainHp = 10000;
|
||||
}else if(guildInfo.getBossHpRemain()==-1){
|
||||
remainHp = -1;
|
||||
}else{
|
||||
|
@ -356,14 +356,7 @@ public class GuildChallengeLogic {
|
|||
SGuildCheckpointConfig config = STableManager.getConfig(SGuildCheckpointConfig.class).get(guildInfo.getCurrBossId());
|
||||
int[] attributePromote = config.getAttributePromote();
|
||||
int maxCount = attributePromote.length;
|
||||
if(guildInfo.getBuffIndex()>=maxCount){
|
||||
throw new ErrorCodeException(ErrorCode.SERVER_SELF_DEFINE);
|
||||
}
|
||||
int[][] attributePromotePrice = config.getAttributePromotePrice();
|
||||
boolean itemCost = ItemUtil.itemCost(user, new int[][]{{attributePromotePrice[0][0], attributePromotePrice[1][guildInfo.getBuffIndex()]}}, BIReason.GUILD_CHALLENGE_BUFF_BUY_CONSUME, 1);
|
||||
if(!itemCost){
|
||||
throw new ErrorCodeException(ErrorCode.SERVER_SELF_DEFINE);
|
||||
}
|
||||
|
||||
|
||||
synchronized (lockMap.get(guildId)){
|
||||
int time;
|
||||
|
@ -376,6 +369,14 @@ public class GuildChallengeLogic {
|
|||
}
|
||||
time = TimeUtils.nowInt() + 3600;
|
||||
}
|
||||
if(guildInfo.getBuffIndex()>=maxCount){
|
||||
throw new ErrorCodeException(ErrorCode.SERVER_SELF_DEFINE);
|
||||
}
|
||||
int[][] attributePromotePrice = config.getAttributePromotePrice();
|
||||
boolean itemCost = ItemUtil.itemCost(user, new int[][]{{attributePromotePrice[0][0], attributePromotePrice[1][guildInfo.getBuffIndex()]}}, BIReason.GUILD_CHALLENGE_BUFF_BUY_CONSUME, 1);
|
||||
if(!itemCost){
|
||||
throw new ErrorCodeException(ErrorCode.SERVER_SELF_DEFINE);
|
||||
}
|
||||
guildInfo.setBuffIndex(guildInfo.getBuffIndex()+1);
|
||||
int fiveTime = (int)(TimeUtils.getLastOrUnderHour(TimeUtils.now(), 5, 0, false)/1000);
|
||||
guildInfo.setBuffOverTime(Math.min(time,fiveTime));
|
||||
|
|
|
@ -1230,7 +1230,7 @@ public class GuildFightLogic {
|
|||
public static Family.CarDelayProgressIndication carDelayProgressIndication;
|
||||
|
||||
public static void minuteCheckForCarFight() throws Exception {
|
||||
LOGGER.info("车迟斗法progress={}",carProgress);
|
||||
LOGGER.info("minuteCheckForCarFight 车迟斗法progress={}",carProgress);
|
||||
int carProgressTmp =carProgress;
|
||||
int id =1;
|
||||
|
||||
|
@ -1288,7 +1288,7 @@ public class GuildFightLogic {
|
|||
}else{
|
||||
carProgressTmp = -1;
|
||||
}
|
||||
System.out.println("当前状态"+carProgressTmp);
|
||||
LOGGER.info("minuteCheckForCarFight 当前状态=>{}", carProgressTmp);
|
||||
if(carProgressTmp!=carProgress){
|
||||
int battleStartTime = 0;
|
||||
int grapStartTime = 0;
|
||||
|
@ -1318,7 +1318,7 @@ public class GuildFightLogic {
|
|||
|
||||
public static void sendAllProgressUpdate(){
|
||||
//向全服玩家广播进度变更信息
|
||||
System.out.println("状态更改发送推送");
|
||||
LOGGER.info("sendAllProgressUpdate 状态更改发送推送");
|
||||
for(ISession session : OnlineUserManager.sessionMap.values()){
|
||||
MessageUtil.sendIndicationMessage(session,1, MessageTypeProto.MessageType.CAR_DELAY_PROGRESS_INDICATION_VALUE,carDelayProgressIndication,true);
|
||||
}
|
||||
|
|
|
@ -406,7 +406,7 @@ public class HeroLogic{
|
|||
for(int mustId:mustSet){
|
||||
maxId = mustId>maxId?mustId:maxId;
|
||||
}
|
||||
System.out.println("触发必出"+maxId);
|
||||
LOGGER.info("randomOne uid=>{} 触发必出=>{}", user.getId(), maxId);
|
||||
SLotterySpecialConfig onConfig = null;
|
||||
for(SLotterySpecialConfig everyConfig:specialConfigs){
|
||||
if(everyConfig.getDifferentType()!=maxId){
|
||||
|
@ -682,7 +682,7 @@ public class HeroLogic{
|
|||
// 卡牌不存在
|
||||
return "card not exists";
|
||||
}
|
||||
}if(teamId==GlobalsDef.TRIAL_TEAM){
|
||||
}else if(teamId==GlobalsDef.TRIAL_TEAM){
|
||||
if(!user.getMapManager().getTrialInfo().getHeroInfo().containsKey(heroId)){
|
||||
return "card not exists";
|
||||
}
|
||||
|
@ -783,6 +783,9 @@ public class HeroLogic{
|
|||
}
|
||||
for(;oldLevel<targetLevel;oldLevel++){
|
||||
SHeroLevlConfig sHeroLevlConfig = SHeroLevlConfig.getsCHero().get(oldLevel);
|
||||
if (sHeroLevlConfig == null) {
|
||||
break;
|
||||
}
|
||||
consume = sHeroLevlConfig.getConsume();
|
||||
combinedAttribute(consume,consumeMap);
|
||||
}
|
||||
|
@ -1544,6 +1547,15 @@ public class HeroLogic{
|
|||
combinedAttribute(config.get(buildLevelProperty).getProperty(),heroAllAttribute);
|
||||
}
|
||||
}
|
||||
//魂印
|
||||
Map<Integer, Integer> soulEquipByPositionMap = hero.getSoulEquipByPositionMap();
|
||||
soulEquipByPositionMap.forEach((k,v)->{
|
||||
SEquipConfig sEquipConfig = STableManager.getConfig(SEquipConfig.class).get(v);
|
||||
int[][] property = sEquipConfig.getProperty();
|
||||
if(property!=null&&property.length>0&&property[0].length>0){
|
||||
combinedAttribute(property,heroAllAttribute);
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
//皮肤、称号加成
|
||||
|
@ -1854,8 +1866,11 @@ public class HeroLogic{
|
|||
for(String equipId : equipIds){
|
||||
int equip = Integer.parseInt(equipId);
|
||||
SEquipConfig sEquipConfig = STableManager.getConfig(SEquipConfig.class).get(equip);
|
||||
if (sEquipConfig == null) {
|
||||
return false;
|
||||
}
|
||||
int position = sEquipConfig.getPosition();
|
||||
boolean itemCost = ItemUtil.itemCost(user, new int[][]{{equip, 1}}, BIReason.EQUIP_WEAR_CONSUME, 1);
|
||||
boolean itemCost = ItemUtil.itemCost(user, new int[][]{{equip, 1}}, BIReason.EQUIP_WEAR_CONSUME, equip);
|
||||
if(!itemCost){
|
||||
return false;
|
||||
}
|
||||
|
@ -2011,6 +2026,9 @@ public class HeroLogic{
|
|||
int itemId = item.getItemId();
|
||||
int itemNum = item.getItemNum();
|
||||
SItem sItem = SItem.getsItemMap().get(itemId);
|
||||
if (sItem == null || itemNum <= 0 || itemNum >= Integer.MAX_VALUE) {
|
||||
throw new ErrorCodeException(ErrorCode.SERVER_SELF_DEFINE);
|
||||
}
|
||||
int composeNum = itemNum/sItem.getUsePerCount();
|
||||
SGameSetting gameSetting = STableManager.getFigureConfig(CommonStaticConfig.class).getGameSetting();
|
||||
if (composeNum <= 0 || composeNum > gameSetting.getHeroCompoundLimit()){
|
||||
|
@ -2019,7 +2037,7 @@ public class HeroLogic{
|
|||
if (hasHeroNum + composeNum > gameSetting.getHeroNumlimit()){
|
||||
throw new ErrorCodeException(ErrorCode.HERO_HERO_MAX);
|
||||
}
|
||||
boolean result = ItemUtil.checkCost(user, sItem, itemNum,BIReason.COMPOS_HERO_CONSUME,0);
|
||||
boolean result = ItemUtil.checkCost(user, sItem, itemNum,BIReason.COMPOS_HERO_CONSUME,itemId);
|
||||
if (!result){
|
||||
throw new ErrorCodeException(ErrorCode.ITEM_NOT_ENOUGH);
|
||||
}
|
||||
|
|
|
@ -6,6 +6,8 @@ import com.ljsd.jieling.ktbeans.sendbeans.ReportServerEvent;
|
|||
import com.ljsd.jieling.logic.OnlineUserManager;
|
||||
import com.ljsd.jieling.logic.dao.UserManager;
|
||||
import com.ljsd.jieling.logic.dao.root.User;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
|
||||
import java.util.Date;
|
||||
import java.util.HashMap;
|
||||
|
@ -18,6 +20,9 @@ import java.util.Set;
|
|||
* @discribe
|
||||
*/
|
||||
public class OnlineUserReportTask extends Thread {
|
||||
|
||||
private static final Logger LOGGER = LoggerFactory.getLogger(OnlineUserReportTask.class);
|
||||
|
||||
public OnlineUserReportTask(){
|
||||
setName("OnlineUserReportTask");
|
||||
}
|
||||
|
@ -53,7 +58,7 @@ public class OnlineUserReportTask extends Thread {
|
|||
properties.put("platform","DEFAULT_platform");
|
||||
properties.put("#time",new Date());
|
||||
ReportServerEvent reportServerEvent = new ReportServerEvent("online_user_amount",properties);
|
||||
System.out.println(reportServerEvent.toString());
|
||||
LOGGER.info("OnlineUserReportTask reportServerEvent=>{}", reportServerEvent.toString());
|
||||
ReportUtil.doReport(reportServerEvent);
|
||||
}catch (Exception e){
|
||||
e.printStackTrace();
|
||||
|
|
|
@ -1261,7 +1261,10 @@ public class ItemUtil {
|
|||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
if (entry.getValue() < 0) {
|
||||
LOGGER.info("checkCost uid=>{} use negative item itemId=>{} count=>{}", user.getId(), entry.getKey(), entry.getValue());
|
||||
return false;
|
||||
}
|
||||
if (temporaryItem == null && item.getItemNum() < entry.getValue()) {
|
||||
return false;
|
||||
}
|
||||
|
|
|
@ -39,7 +39,7 @@ public class MessageUtil {
|
|||
} else {
|
||||
backMessage = generatedMessage.toByteArray();
|
||||
if (backMessage.length != 0)
|
||||
LOGGER.info("\r\n" + "uid:" + uid + ":\r\n" + JsonFormat.printToString(generatedMessage));
|
||||
LOGGER.info("wrappedBuffer uid=>{}, generatedMessage=>{}", uid, JsonFormat.printToString(generatedMessage));
|
||||
}
|
||||
|
||||
int length = PackageConstant.UID_FIELD_LEN + PackageConstant.TOKEN_LEN
|
||||
|
@ -64,7 +64,7 @@ public class MessageUtil {
|
|||
int[] secretKey = Tea.KEY;
|
||||
byte[] bytes1 = Tea.encrypt2(bytes, secretKey);
|
||||
if (backMessage.length != 0) {
|
||||
LOGGER.info("sendbyte"+bytes1.length);
|
||||
LOGGER.info("wrappedBuffer uid=>{} sendbyte=>{}", uid, bytes1.length);
|
||||
}
|
||||
return bytes1;
|
||||
}
|
||||
|
|
|
@ -67,9 +67,6 @@ public class SExchangeRate implements BaseConfig {
|
|||
|
||||
|
||||
}
|
||||
|
||||
|
||||
System.out.println("");
|
||||
}
|
||||
|
||||
|
||||
|
|
|
@ -1,4 +0,0 @@
|
|||
package PACKAGE_NAME;
|
||||
|
||||
public class Test {
|
||||
}
|
|
@ -124,9 +124,9 @@ public class NettyTCPClientHandler extends SimpleChannelInboundHandler<Object> {
|
|||
if(msgId == RECONNECT_RESPONSE_VALUE){
|
||||
rec =true;
|
||||
}
|
||||
|
||||
|
||||
System.out.println("back hartbeat id : "+msgId);
|
||||
|
||||
LOGGER.info("channelRead0 back hartbeat id : {}", msgId);
|
||||
|
||||
//System.out.println(JsonFormat.printToString());
|
||||
|
||||
|
|
|
@ -1,4 +0,0 @@
|
|||
package db;
|
||||
|
||||
public class Test {
|
||||
}
|
Loading…
Reference in New Issue