This commit is contained in:
韩鹏辉 2024-06-21 13:57:10 +08:00
commit 14b75d982d
3 changed files with 5 additions and 9 deletions

View File

@ -113,6 +113,10 @@ public class PushToClientChannelHandlerAdapter extends NettyChannelHandlerAdapte
this.shopId=shopId;
if (webSocketMap.containsKey(shopId)) {
ConcurrentHashMap<String, ChannelHandlerContext> clientSocketMap = webSocketMap.get(shopId);
ChannelHandlerContext channelHandlerContext = clientSocketMap.get(clientId);
if (channelHandlerContext != null) {
channelHandlerContext.close();
}
clientSocketMap.put(clientId, ctx);
} else {
ConcurrentHashMap<String, ChannelHandlerContext> clientSocketMap = new ConcurrentHashMap<>();

View File

@ -22,10 +22,8 @@ import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutionException;
/**
* @author lyf

View File

@ -116,16 +116,10 @@ public class LoginService {
tbUserInfoMapper.updateByPrimaryKeySelective(userInfo);
List<TbShopUser> tbShopUsers = tbShopUserMapper.selectAllByUserId(userInfo.getId().toString());
for (TbShopUser tbShopUser : tbShopUsers) {
tbShopUser.setUserId("");
tbShopUser.setUserId(null);
tbShopUser.setUpdatedAt(System.currentTimeMillis());
tbShopUserMapper.upUserBYId(tbShopUser);
}
List<TbShopUser> tbShopUsers1 = tbShopUserMapper.selectByPhone(telephone);
for (TbShopUser tbShopUser : tbShopUsers1) {
tbShopUser.setUpdatedAt(System.currentTimeMillis());
tbShopUser.setUserId(userInfo.getId().toString());
tbShopUserMapper.upUserBYId(tbShopUser);
}
}
}
}