|
@@ -148,8 +148,8 @@ public class KfAppletMsgServiceImpl implements IKfAppletMsgService {
|
|
|
if (Objects.equals(gameApplet.getType(), 3)) {
|
|
|
//小程序自动回复
|
|
|
this.appletReplyHandle(gameApplet.getGameId(), kfAppletMsgDTO.getFromUserName(), kfRoom, gameApplet.getAppId());
|
|
|
- //保存房间消息
|
|
|
- kfRoomMsgService.save(kfRoomMsg);
|
|
|
+ //保存消息, 玩家转入接待状态
|
|
|
+ this.saveMsgAndChangeWait(kfRoom, kfRoomMsg, gameApplet, kfAppletMsgDTO, msgContent);
|
|
|
//直接结束
|
|
|
return;
|
|
|
}
|
|
@@ -169,6 +169,12 @@ public class KfAppletMsgServiceImpl implements IKfAppletMsgService {
|
|
|
this.systemReplyHandle(gameApplet.getGameId(), kfAppletMsgDTO.getFromUserName(), kfRoom);
|
|
|
//消息报警监测
|
|
|
this.monitorWordHandle(gameApplet, kfAppletMsgDTO);
|
|
|
+ //保存消息, 玩家转入接待状态
|
|
|
+ this.saveMsgAndChangeWait(kfRoom, kfRoomMsg, gameApplet, kfAppletMsgDTO, msgContent);
|
|
|
+ }
|
|
|
+
|
|
|
+ private void saveMsgAndChangeWait(KfRoom kfRoom, KfRoomMsg kfRoomMsg, GameApplet gameApplet, KfAppletMsgDTO kfAppletMsgDTO,
|
|
|
+ KfWebSocketMsgDTO.MsgContentBean msgContent) {
|
|
|
//保存房间消息
|
|
|
kfRoomMsgService.save(kfRoomMsg);
|
|
|
//玩家状态更新为待接入状态
|