替换 System.out.println
parent
9e32a22e06
commit
c3aa0b815f
|
@ -186,25 +186,25 @@ public class ChatLogic {
|
||||||
break;
|
break;
|
||||||
case 3: //好友
|
case 3: //好友
|
||||||
List<Integer> friends = friendManager.getFriends();
|
List<Integer> friends = friendManager.getFriends();
|
||||||
if (!friends.contains(friendId)){
|
if (!friends.contains(friendId)) {
|
||||||
throw new ErrorCodeException(ErrorCode.CHAT_NOT_FRIENDS);
|
throw new ErrorCodeException(ErrorCode.CHAT_NOT_FRIENDS);
|
||||||
}
|
}
|
||||||
//现在好友推送
|
//现在好友推送
|
||||||
if (OnlineUserManager.checkUidOnline(friendId)){
|
if (OnlineUserManager.checkUidOnline(friendId)) {
|
||||||
ISession sessionByUid = OnlineUserManager.getSessionByUid(friendId);
|
ISession sessionByUid = OnlineUserManager.getSessionByUid(friendId);
|
||||||
chatInfo = CBean2Proto.getChatInfoBuilder(user,message,nowTime,0);
|
chatInfo = CBean2Proto.getChatInfoBuilder(user, message, nowTime, 0);
|
||||||
sendChatInfoIndication = ChatProto.SendChatInfoIndication.newBuilder()
|
sendChatInfoIndication = ChatProto.SendChatInfoIndication.newBuilder()
|
||||||
.setChatInfo(chatInfo)
|
.setChatInfo(chatInfo)
|
||||||
.setType(1)
|
.setType(1)
|
||||||
.build();
|
.build();
|
||||||
assert sessionByUid != null;
|
assert sessionByUid != null;
|
||||||
MessageUtil.sendIndicationMessage(sessionByUid, 1, MessageTypeProto.MessageType.SEND_CHAT_INFO_INDICATION_VALUE, sendChatInfoIndication, true);
|
MessageUtil.sendIndicationMessage(sessionByUid, 1, MessageTypeProto.MessageType.SEND_CHAT_INFO_INDICATION_VALUE, sendChatInfoIndication, true);
|
||||||
}else{
|
} else {
|
||||||
RedisUtil.getInstence().hset(GameApplication.serverId +RedisKey.CUser_Chat+friendId,uid +"#"+ nowTime,message, -1);
|
RedisUtil.getInstence().hset(GameApplication.serverId + RedisKey.CUser_Chat + friendId, uid + "#" + nowTime, message, -1);
|
||||||
}
|
}
|
||||||
|
|
||||||
break;
|
break;
|
||||||
default:{
|
default: {
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -2,13 +2,15 @@ package com.ljsd.jieling.db.mongo;
|
||||||
|
|
||||||
import com.google.gson.*;
|
import com.google.gson.*;
|
||||||
import com.ljsd.jieling.util.SysUtil;
|
import com.ljsd.jieling.util.SysUtil;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
import java.io.*;
|
import java.io.*;
|
||||||
import java.nio.charset.Charset;
|
import java.nio.charset.Charset;
|
||||||
import java.nio.file.Files;
|
import java.nio.file.Files;
|
||||||
|
|
||||||
public class MongoUtiltest {
|
public class MongoUtiltest {
|
||||||
|
private static final Logger LOGGER = LoggerFactory.getLogger(MongoUtiltest.class);
|
||||||
public static void main(String[] args) {
|
public static void main(String[] args) {
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
@ -30,7 +32,7 @@ public class MongoUtiltest {
|
||||||
StringBuilder stringBuilder2 = new StringBuilder();
|
StringBuilder stringBuilder2 = new StringBuilder();
|
||||||
if (MongoUtil.equill(obj1, obj, stringBuilder,stringBuilder2)) {
|
if (MongoUtil.equill(obj1, obj, stringBuilder,stringBuilder2)) {
|
||||||
|
|
||||||
System.out.println("匹配");
|
LOGGER.info("匹配");
|
||||||
} else {
|
} else {
|
||||||
|
|
||||||
File file3 = new File(SysUtil.getPath("conf/checkout_diffmem__" +dbf3.getName()+ ".txt"));
|
File file3 = new File(SysUtil.getPath("conf/checkout_diffmem__" +dbf3.getName()+ ".txt"));
|
||||||
|
|
|
@ -1,6 +1,8 @@
|
||||||
package com.ljsd.jieling.kefu;
|
package com.ljsd.jieling.kefu;
|
||||||
|
|
||||||
import com.ljsd.jieling.core.Lockeys;
|
import com.ljsd.jieling.core.Lockeys;
|
||||||
|
import org.slf4j.Logger;
|
||||||
|
import org.slf4j.LoggerFactory;
|
||||||
|
|
||||||
import java.util.HashSet;
|
import java.util.HashSet;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
@ -11,6 +13,7 @@ import java.util.Set;
|
||||||
* CreateDate: 2020/6/11 11:48
|
* CreateDate: 2020/6/11 11:48
|
||||||
*/
|
*/
|
||||||
public class Cmd_test_lock extends GmAbstract {
|
public class Cmd_test_lock extends GmAbstract {
|
||||||
|
private static final Logger LOGGER = LoggerFactory.getLogger(Cmd_test_lock.class);
|
||||||
@Override
|
@Override
|
||||||
public boolean exec(String[] args) throws Exception {
|
public boolean exec(String[] args) throws Exception {
|
||||||
Set<Integer> sendUids = new HashSet<>();
|
Set<Integer> sendUids = new HashSet<>();
|
||||||
|
@ -20,7 +23,7 @@ public class Cmd_test_lock extends GmAbstract {
|
||||||
while (i++<10){
|
while (i++<10){
|
||||||
String name = Thread.currentThread().getName();
|
String name = Thread.currentThread().getName();
|
||||||
Thread.currentThread().sleep(1000);
|
Thread.currentThread().sleep(1000);
|
||||||
System.out.println("name"+name+" = [" + i + "]");
|
LOGGER.info("name=>{}, i=>{}",name, i);
|
||||||
}
|
}
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
|
@ -391,7 +391,7 @@ public class ChampionshipLogic {
|
||||||
MailLogic.getInstance().sendMail(user.getId(), title, content, ItemUtil.getMailReward(sChampionshipReward.getSeasonReward()), nowTime, Global.MAIL_EFFECTIVE_TIME);
|
MailLogic.getInstance().sendMail(user.getId(), title, content, ItemUtil.getMailReward(sChampionshipReward.getSeasonReward()), nowTime, Global.MAIL_EFFECTIVE_TIME);
|
||||||
}
|
}
|
||||||
}catch (Exception e){
|
}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();
|
MongoUtil.getLjsdMongoTemplate().lastUpdate();
|
||||||
|
|
|
@ -1230,7 +1230,7 @@ public class GuildFightLogic {
|
||||||
public static Family.CarDelayProgressIndication carDelayProgressIndication;
|
public static Family.CarDelayProgressIndication carDelayProgressIndication;
|
||||||
|
|
||||||
public static void minuteCheckForCarFight() throws Exception {
|
public static void minuteCheckForCarFight() throws Exception {
|
||||||
LOGGER.info("车迟斗法progress={}",carProgress);
|
LOGGER.info("minuteCheckForCarFight 车迟斗法progress={}",carProgress);
|
||||||
int carProgressTmp =carProgress;
|
int carProgressTmp =carProgress;
|
||||||
int id =1;
|
int id =1;
|
||||||
|
|
||||||
|
@ -1288,7 +1288,7 @@ public class GuildFightLogic {
|
||||||
}else{
|
}else{
|
||||||
carProgressTmp = -1;
|
carProgressTmp = -1;
|
||||||
}
|
}
|
||||||
System.out.println("当前状态"+carProgressTmp);
|
LOGGER.info("minuteCheckForCarFight 当前状态=>{}", carProgressTmp);
|
||||||
if(carProgressTmp!=carProgress){
|
if(carProgressTmp!=carProgress){
|
||||||
int battleStartTime = 0;
|
int battleStartTime = 0;
|
||||||
int grapStartTime = 0;
|
int grapStartTime = 0;
|
||||||
|
@ -1318,7 +1318,7 @@ public class GuildFightLogic {
|
||||||
|
|
||||||
public static void sendAllProgressUpdate(){
|
public static void sendAllProgressUpdate(){
|
||||||
//向全服玩家广播进度变更信息
|
//向全服玩家广播进度变更信息
|
||||||
System.out.println("状态更改发送推送");
|
LOGGER.info("sendAllProgressUpdate 状态更改发送推送");
|
||||||
for(ISession session : OnlineUserManager.sessionMap.values()){
|
for(ISession session : OnlineUserManager.sessionMap.values()){
|
||||||
MessageUtil.sendIndicationMessage(session,1, MessageTypeProto.MessageType.CAR_DELAY_PROGRESS_INDICATION_VALUE,carDelayProgressIndication,true);
|
MessageUtil.sendIndicationMessage(session,1, MessageTypeProto.MessageType.CAR_DELAY_PROGRESS_INDICATION_VALUE,carDelayProgressIndication,true);
|
||||||
}
|
}
|
||||||
|
|
|
@ -406,7 +406,7 @@ public class HeroLogic{
|
||||||
for(int mustId:mustSet){
|
for(int mustId:mustSet){
|
||||||
maxId = mustId>maxId?mustId:maxId;
|
maxId = mustId>maxId?mustId:maxId;
|
||||||
}
|
}
|
||||||
System.out.println("触发必出"+maxId);
|
LOGGER.info("randomOne uid=>{} 触发必出=>{}", user.getId(), maxId);
|
||||||
SLotterySpecialConfig onConfig = null;
|
SLotterySpecialConfig onConfig = null;
|
||||||
for(SLotterySpecialConfig everyConfig:specialConfigs){
|
for(SLotterySpecialConfig everyConfig:specialConfigs){
|
||||||
if(everyConfig.getDifferentType()!=maxId){
|
if(everyConfig.getDifferentType()!=maxId){
|
||||||
|
|
|
@ -67,9 +67,6 @@ public class SExchangeRate implements BaseConfig {
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
System.out.println("");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -126,7 +126,7 @@ public class NettyTCPClientHandler extends SimpleChannelInboundHandler<Object> {
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
System.out.println("back hartbeat id : "+msgId);
|
LOGGER.info("channelRead0 back hartbeat id : {}", msgId);
|
||||||
|
|
||||||
//System.out.println(JsonFormat.printToString());
|
//System.out.println(JsonFormat.printToString());
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue