update package

This commit is contained in:
SAM2O2O 2019-07-31 23:12:30 +08:00
parent ef6c270181
commit 8f5db8452f
170 changed files with 522 additions and 537 deletions

View File

@ -36,10 +36,10 @@ import org.springframework.web.servlet.ModelAndView;
import com.akaxin.common.utils.GsonUtils;
import com.akaxin.proto.core.PluginProto;
import com.akaxin.site.business.dao.UserProfileDao;
import com.akaxin.site.storage.bean.GroupMemberBean;
import com.akaxin.site.storage.bean.GroupProfileBean;
import com.akaxin.site.storage.bean.SimpleGroupBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.windchat.im.storage.bean.GroupMemberBean;
import com.windchat.im.storage.bean.GroupProfileBean;
import com.windchat.im.storage.bean.SimpleGroupBean;
import com.windchat.im.storage.bean.UserProfileBean;
import com.akaxin.site.web.admin.exception.UserPermissionException;
import com.akaxin.site.web.admin.service.IConfigService;
import com.akaxin.site.web.admin.service.IGroupService;

View File

@ -2,7 +2,7 @@ package com.akaxin.site.web.admin.controller;
import com.akaxin.common.utils.GsonUtils;
import com.akaxin.proto.core.PluginProto;
import com.akaxin.site.storage.bean.MonitorBean;
import com.windchat.im.storage.bean.MonitorBean;
import com.akaxin.site.web.admin.common.Timeutils;
import com.akaxin.site.web.admin.exception.UserPermissionException;
import com.akaxin.site.web.admin.service.IMonitorService;

View File

@ -34,7 +34,7 @@ import org.springframework.web.servlet.ModelAndView;
import com.akaxin.common.utils.StringHelper;
import com.akaxin.proto.core.PluginProto;
import com.akaxin.site.storage.bean.PluginBean;
import com.windchat.im.storage.bean.PluginBean;
import com.akaxin.site.web.admin.exception.UserPermissionException;
import com.akaxin.site.web.admin.service.IPluginService;
import com.google.protobuf.InvalidProtocolBufferException;

View File

@ -37,7 +37,7 @@ import org.springframework.web.servlet.ModelAndView;
import com.akaxin.common.utils.GsonUtils;
import com.akaxin.proto.core.PluginProto;
import com.akaxin.site.business.impl.site.SiteConfig;
import com.akaxin.site.storage.bean.UicBean;
import com.windchat.im.storage.bean.UicBean;
import com.akaxin.site.web.admin.service.IUICService;
//邀请码管理

View File

@ -39,8 +39,8 @@ import org.springframework.web.servlet.ModelAndView;
import com.akaxin.common.utils.StringHelper;
import com.akaxin.proto.core.PluginProto;
import com.akaxin.proto.core.UserProto.UserStatus;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.UserProfileBean;
import com.akaxin.site.web.admin.exception.ManagerException;
import com.akaxin.site.web.admin.exception.UserPermissionException;
import com.akaxin.site.web.admin.service.IConfigService;

View File

@ -24,8 +24,8 @@ import com.akaxin.proto.core.UserProto;
import com.akaxin.site.business.dao.UserFriendDao;
import com.akaxin.site.business.impl.notice.User2Notice;
import com.akaxin.site.business.push.PushNotification;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.UserProfileBean;
import com.akaxin.site.web.admin.service.IUserService;
import com.google.protobuf.InvalidProtocolBufferException;

View File

@ -2,9 +2,9 @@ package com.akaxin.site.web.admin.service;
import java.util.List;
import com.akaxin.site.storage.bean.GroupMemberBean;
import com.akaxin.site.storage.bean.GroupProfileBean;
import com.akaxin.site.storage.bean.SimpleGroupBean;
import com.windchat.im.storage.bean.GroupMemberBean;
import com.windchat.im.storage.bean.GroupProfileBean;
import com.windchat.im.storage.bean.SimpleGroupBean;
/**
*

View File

@ -2,7 +2,7 @@ package com.akaxin.site.web.admin.service;
import java.util.List;
import com.akaxin.site.storage.bean.PluginBean;
import com.windchat.im.storage.bean.PluginBean;
public interface IPluginService {
boolean addNewPlugin(PluginBean bean);

View File

@ -2,7 +2,7 @@ package com.akaxin.site.web.admin.service;
import java.util.List;
import com.akaxin.site.storage.bean.UicBean;
import com.windchat.im.storage.bean.UicBean;
public interface IUICService {

View File

@ -2,8 +2,8 @@ package com.akaxin.site.web.admin.service;
import java.util.List;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.UserProfileBean;
public interface IUserService {
// 获取用户profile

View File

@ -22,9 +22,9 @@ import org.springframework.stereotype.Service;
import com.akaxin.site.business.dao.UserGroupDao;
import com.akaxin.site.business.impl.site.SiteConfig;
import com.akaxin.site.storage.bean.GroupMemberBean;
import com.akaxin.site.storage.bean.GroupProfileBean;
import com.akaxin.site.storage.bean.SimpleGroupBean;
import com.windchat.im.storage.bean.GroupMemberBean;
import com.windchat.im.storage.bean.GroupProfileBean;
import com.windchat.im.storage.bean.SimpleGroupBean;
import com.akaxin.site.web.admin.service.IGroupService;
/**

View File

@ -20,7 +20,7 @@ import java.util.List;
import org.springframework.stereotype.Service;
import com.akaxin.site.business.dao.SitePluginDao;
import com.akaxin.site.storage.bean.PluginBean;
import com.windchat.im.storage.bean.PluginBean;
import com.akaxin.site.web.admin.service.IPluginService;
/**

View File

@ -23,7 +23,7 @@ import org.springframework.stereotype.Service;
import com.akaxin.proto.core.UicProto.UicStatus;
import com.akaxin.site.business.dao.SiteUicDao;
import com.akaxin.site.storage.bean.UicBean;
import com.windchat.im.storage.bean.UicBean;
import com.akaxin.site.web.admin.service.IUICService;
@Service

View File

@ -30,22 +30,22 @@ import com.akaxin.site.business.dao.UserGroupDao;
import com.akaxin.site.business.dao.UserProfileDao;
import com.akaxin.site.business.impl.site.SiteConfig;
import com.akaxin.site.business.utils.FilePathUtils;
import com.akaxin.site.storage.api.IGroupDao;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.api.IUserDeviceDao;
import com.akaxin.site.storage.api.IUserFriendDao;
import com.akaxin.site.storage.api.IUserProfileDao;
import com.akaxin.site.storage.api.IUserSessionDao;
import com.akaxin.site.storage.bean.SimpleGroupBean;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.UserDeviceBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.akaxin.site.storage.service.DeviceDaoService;
import com.akaxin.site.storage.service.GroupDaoService;
import com.akaxin.site.storage.service.MessageDaoService;
import com.akaxin.site.storage.service.UserFriendDaoService;
import com.akaxin.site.storage.service.UserProfileDaoService;
import com.akaxin.site.storage.service.UserSessionDaoService;
import com.windchat.im.storage.api.IGroupDao;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.api.IUserDeviceDao;
import com.windchat.im.storage.api.IUserFriendDao;
import com.windchat.im.storage.api.IUserProfileDao;
import com.windchat.im.storage.api.IUserSessionDao;
import com.windchat.im.storage.bean.SimpleGroupBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.UserDeviceBean;
import com.windchat.im.storage.bean.UserProfileBean;
import com.windchat.im.storage.service.DeviceDaoService;
import com.windchat.im.storage.service.GroupDaoService;
import com.windchat.im.storage.service.MessageDaoService;
import com.windchat.im.storage.service.UserFriendDaoService;
import com.windchat.im.storage.service.UserProfileDaoService;
import com.windchat.im.storage.service.UserSessionDaoService;
import com.akaxin.site.web.admin.service.IUserService;
@Service("userManageService")

View File

@ -52,12 +52,12 @@ import com.akaxin.site.connector.handler.WSRequestHandler;
import com.akaxin.site.connector.http.HttpServer;
import com.akaxin.site.connector.netty.NettyServer;
import com.akaxin.site.connector.ws.WsServer;
import com.akaxin.site.storage.DataSourceManager;
import com.akaxin.site.storage.dao.config.DBConfig;
import com.akaxin.site.storage.dao.sqlite.manager.PluginArgs;
import com.akaxin.site.storage.exception.InitDatabaseException;
import com.akaxin.site.storage.exception.NeedInitMysqlException;
import com.akaxin.site.storage.exception.UpgradeDatabaseException;
import com.windchat.im.storage.DataSourceManager;
import com.windchat.im.storage.dao.config.DBConfig;
import com.windchat.im.storage.dao.sqlite.manager.PluginArgs;
import com.windchat.im.storage.exception.InitDatabaseException;
import com.windchat.im.storage.exception.NeedInitMysqlException;
import com.windchat.im.storage.exception.UpgradeDatabaseException;
/**
* <pre>

View File

@ -19,13 +19,13 @@ import com.akaxin.common.utils.PrintUtils;
import com.akaxin.common.utils.StringHelper;
import com.akaxin.site.boot.config.ConfigHelper;
import com.akaxin.site.boot.config.ConfigKey;
import com.akaxin.site.storage.DataSourceManager;
import com.akaxin.site.storage.dao.config.DBConfig;
import com.akaxin.site.storage.dao.config.DBType;
import com.akaxin.site.storage.dao.sql.SQLConst;
import com.akaxin.site.storage.exception.MigrateDatabaseException;
import com.akaxin.site.storage.exception.NeedInitMysqlException;
import com.akaxin.site.storage.exception.UpgradeDatabaseException;
import com.windchat.im.storage.DataSourceManager;
import com.windchat.im.storage.dao.config.DBConfig;
import com.windchat.im.storage.dao.config.DBType;
import com.windchat.im.storage.dao.sql.SQLConst;
import com.windchat.im.storage.exception.MigrateDatabaseException;
import com.windchat.im.storage.exception.NeedInitMysqlException;
import com.windchat.im.storage.exception.UpgradeDatabaseException;
public class Helper {
private static final Logger logger = LoggerFactory.getLogger(Helper.class);

View File

@ -20,9 +20,9 @@ import java.sql.SQLException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.ITokenDao;
import com.akaxin.site.storage.bean.ExpireToken;
import com.akaxin.site.storage.service.TokenDaoService;
import com.windchat.im.storage.api.ITokenDao;
import com.windchat.im.storage.bean.ExpireToken;
import com.windchat.im.storage.service.TokenDaoService;
/**
* 站点相关过期token操作

View File

@ -1,11 +1,10 @@
package com.akaxin.site.business.dao;
import com.akaxin.site.storage.api.*;
import com.akaxin.site.storage.service.*;
import com.windchat.im.storage.api.*;
import com.windchat.im.storage.service.*;
import org.slf4j.LoggerFactory;
import java.sql.SQLException;
import java.time.DayOfWeek;
public class MonitorDao {
private static final org.slf4j.Logger logger = LoggerFactory.getLogger(UserProfileDao.class);

View File

@ -22,8 +22,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.proto.core.ConfigProto.ConfigKey;
import com.akaxin.site.storage.api.ISiteConfigDao;
import com.akaxin.site.storage.service.SiteConfigDaoService;
import com.windchat.im.storage.api.ISiteConfigDao;
import com.windchat.im.storage.service.SiteConfigDaoService;
/**
* 站点配置供业务逻辑使用

View File

@ -20,17 +20,15 @@ import java.sql.SQLException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.IUserDeviceDao;
import com.akaxin.site.storage.api.IUserProfileDao;
import com.akaxin.site.storage.api.IUserSessionDao;
import com.akaxin.site.storage.bean.UserDeviceBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.akaxin.site.storage.bean.UserSessionBean;
import com.akaxin.site.storage.service.DeviceDaoService;
import com.akaxin.site.storage.service.UserProfileDaoService;
import com.akaxin.site.storage.service.UserSessionDaoService;
import javax.transaction.TransactionRequiredException;
import com.windchat.im.storage.api.IUserDeviceDao;
import com.windchat.im.storage.api.IUserProfileDao;
import com.windchat.im.storage.api.IUserSessionDao;
import com.windchat.im.storage.bean.UserDeviceBean;
import com.windchat.im.storage.bean.UserProfileBean;
import com.windchat.im.storage.bean.UserSessionBean;
import com.windchat.im.storage.service.DeviceDaoService;
import com.windchat.im.storage.service.UserProfileDaoService;
import com.windchat.im.storage.service.UserSessionDaoService;
/**
* 用户登陆使用dao负责用户信息入库

View File

@ -22,9 +22,9 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.proto.core.PluginProto;
import com.akaxin.site.storage.api.IPluginDao;
import com.akaxin.site.storage.bean.PluginBean;
import com.akaxin.site.storage.service.PluginServiceDao;
import com.windchat.im.storage.api.IPluginDao;
import com.windchat.im.storage.bean.PluginBean;
import com.windchat.im.storage.service.PluginServiceDao;
public class SitePluginDao {
private static final Logger logger = LoggerFactory.getLogger(SitePluginDao.class);

View File

@ -21,9 +21,9 @@ import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.IUicDao;
import com.akaxin.site.storage.bean.UicBean;
import com.akaxin.site.storage.service.UicDaoService;
import com.windchat.im.storage.api.IUicDao;
import com.windchat.im.storage.bean.UicBean;
import com.windchat.im.storage.service.UicDaoService;
public class SiteUicDao {
private static final Logger logger = LoggerFactory.getLogger(SiteUicDao.class);

View File

@ -5,8 +5,8 @@ import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.ISiteUsersDao;
import com.akaxin.site.storage.service.SiteUsersDaoService;
import com.windchat.im.storage.api.ISiteUsersDao;
import com.windchat.im.storage.service.SiteUsersDaoService;
/**
* 获取站点数据库信息例如所有用户

View File

@ -21,9 +21,9 @@ import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.IUserDeviceDao;
import com.akaxin.site.storage.bean.UserDeviceBean;
import com.akaxin.site.storage.service.DeviceDaoService;
import com.windchat.im.storage.api.IUserDeviceDao;
import com.windchat.im.storage.bean.UserDeviceBean;
import com.windchat.im.storage.service.DeviceDaoService;
public class UserDeviceDao {
private static final Logger logger = LoggerFactory.getLogger(UserDeviceDao.class);

View File

@ -23,14 +23,14 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.proto.core.UserProto;
import com.akaxin.site.storage.api.IFriendApplyDao;
import com.akaxin.site.storage.api.IUserFriendDao;
import com.akaxin.site.storage.bean.ApplyFriendBean;
import com.akaxin.site.storage.bean.ApplyUserBean;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.UserFriendBean;
import com.akaxin.site.storage.service.FriendApplyDaoService;
import com.akaxin.site.storage.service.UserFriendDaoService;
import com.windchat.im.storage.api.IFriendApplyDao;
import com.windchat.im.storage.api.IUserFriendDao;
import com.windchat.im.storage.bean.ApplyFriendBean;
import com.windchat.im.storage.bean.ApplyUserBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.UserFriendBean;
import com.windchat.im.storage.service.FriendApplyDaoService;
import com.windchat.im.storage.service.UserFriendDaoService;
/**
* 用户好友相关操作

View File

@ -27,17 +27,17 @@ import org.slf4j.LoggerFactory;
import com.akaxin.common.utils.StringHelper;
import com.akaxin.proto.core.GroupProto;
import com.akaxin.site.business.impl.notice.GroupNotice;
import com.akaxin.site.storage.api.IGroupDao;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.api.IUserGroupDao;
import com.akaxin.site.storage.bean.GroupMemberBean;
import com.akaxin.site.storage.bean.GroupProfileBean;
import com.akaxin.site.storage.bean.SimpleGroupBean;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.UserGroupBean;
import com.akaxin.site.storage.service.GroupDaoService;
import com.akaxin.site.storage.service.MessageDaoService;
import com.akaxin.site.storage.service.UserGroupDaoService;
import com.windchat.im.storage.api.IGroupDao;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.api.IUserGroupDao;
import com.windchat.im.storage.bean.GroupMemberBean;
import com.windchat.im.storage.bean.GroupProfileBean;
import com.windchat.im.storage.bean.SimpleGroupBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.UserGroupBean;
import com.windchat.im.storage.service.GroupDaoService;
import com.windchat.im.storage.service.MessageDaoService;
import com.windchat.im.storage.service.UserGroupDaoService;
/**
* 用户群组群组相关数据源操作

View File

@ -21,12 +21,12 @@ import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.IUserProfileDao;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.SimpleUserRelationBean;
import com.akaxin.site.storage.bean.UserFriendBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.akaxin.site.storage.service.UserProfileDaoService;
import com.windchat.im.storage.api.IUserProfileDao;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.SimpleUserRelationBean;
import com.windchat.im.storage.bean.UserFriendBean;
import com.windchat.im.storage.bean.UserProfileBean;
import com.windchat.im.storage.service.UserProfileDaoService;
/**
*

View File

@ -22,8 +22,8 @@ import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.IUserSessionDao;
import com.akaxin.site.storage.service.UserSessionDaoService;
import com.windchat.im.storage.api.IUserSessionDao;
import com.windchat.im.storage.service.UserSessionDaoService;
public class UserSessionDao {
private static final Logger logger = LoggerFactory.getLogger(UserSessionDao.class);

View File

@ -16,18 +16,11 @@
package com.akaxin.site.business.impl;
import java.lang.reflect.Method;
import java.sql.SQLException;
import com.akaxin.site.business.dao.SiteUserDao;
import com.akaxin.site.business.dao.UserGroupDao;
import com.akaxin.site.business.dao.UserProfileDao;
import com.akaxin.site.message.dao.ImUserGroupDao;
import com.akaxin.site.message.dao.ImUserProfileDao;
import com.akaxin.site.storage.api.IUserProfileDao;
import com.akaxin.site.storage.bean.GroupProfileBean;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.akaxin.site.storage.service.UserProfileDaoService;
import com.windchat.im.storage.bean.GroupProfileBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

View File

@ -37,7 +37,7 @@ import com.akaxin.site.business.dao.UserProfileDao;
import com.akaxin.site.business.impl.AbstractRequest;
import com.akaxin.site.business.impl.notice.User2Notice;
import com.akaxin.site.business.push.PushNotification;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.SimpleUserBean;
/**
* <pre>

View File

@ -17,7 +17,6 @@ package com.akaxin.site.business.impl.hai;
import java.util.List;
import com.akaxin.site.business.impl.site.SiteConfig;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@ -42,9 +41,9 @@ import com.akaxin.proto.plugin.HaiGroupUpdateProto;
import com.akaxin.site.business.constant.GroupConfig;
import com.akaxin.site.business.dao.UserGroupDao;
import com.akaxin.site.business.impl.AbstractRequest;
import com.akaxin.site.storage.bean.GroupMemberBean;
import com.akaxin.site.storage.bean.GroupProfileBean;
import com.akaxin.site.storage.bean.SimpleGroupBean;
import com.windchat.im.storage.bean.GroupMemberBean;
import com.windchat.im.storage.bean.GroupProfileBean;
import com.windchat.im.storage.bean.SimpleGroupBean;
import com.google.protobuf.ProtocolStringList;
/**

View File

@ -33,10 +33,10 @@ import com.akaxin.proto.core.UserProto;
import com.akaxin.proto.plugin.HaiSessionProfileProto;
import com.akaxin.site.business.dao.UserProfileDao;
import com.akaxin.site.business.impl.AbstractRequest;
import com.akaxin.site.storage.api.IUserSessionDao;
import com.akaxin.site.storage.bean.SimpleAuthBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.akaxin.site.storage.service.UserSessionDaoService;
import com.windchat.im.storage.api.IUserSessionDao;
import com.windchat.im.storage.bean.SimpleAuthBean;
import com.windchat.im.storage.bean.UserProfileBean;
import com.windchat.im.storage.service.UserSessionDaoService;
/**
* <pre>

View File

@ -42,9 +42,9 @@ import com.akaxin.site.business.dao.UserProfileDao;
import com.akaxin.site.business.impl.AbstractRequest;
import com.akaxin.site.business.utils.FilePathUtils;
import com.akaxin.site.business.utils.FileServerUtils;
import com.akaxin.site.storage.bean.SimpleGroupBean;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.windchat.im.storage.bean.SimpleGroupBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.UserProfileBean;
import com.google.protobuf.ByteString;
/**

View File

@ -29,7 +29,7 @@ import com.akaxin.site.business.constant.NoticeText;
import com.akaxin.site.business.dao.UserProfileDao;
import com.akaxin.site.message.api.IMessageService;
import com.akaxin.site.message.service.ImMessageService;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.google.protobuf.ByteString;
/**

View File

@ -29,7 +29,7 @@ import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.business.constant.NoticeText;
import com.akaxin.site.message.api.IMessageService;
import com.akaxin.site.message.service.ImMessageService;
import com.akaxin.site.storage.bean.ApplyFriendBean;
import com.windchat.im.storage.bean.ApplyFriendBean;
import com.google.protobuf.ByteString;
public class User2Notice {

View File

@ -21,7 +21,7 @@ import org.slf4j.LoggerFactory;
import com.akaxin.proto.core.UicProto;
import com.akaxin.site.business.dao.SiteUicDao;
import com.akaxin.site.storage.bean.UicBean;
import com.windchat.im.storage.bean.UicBean;
/**
* 用户邀请码管理实现

View File

@ -31,7 +31,7 @@ import com.akaxin.proto.site.ApiDeviceListProto;
import com.akaxin.proto.site.ApiDeviceProfileProto;
import com.akaxin.site.business.dao.UserDeviceDao;
import com.akaxin.site.business.impl.AbstractRequest;
import com.akaxin.site.storage.bean.UserDeviceBean;
import com.windchat.im.storage.bean.UserDeviceBean;
/**
*

View File

@ -48,10 +48,10 @@ import com.akaxin.site.business.impl.AbstractRequest;
import com.akaxin.site.business.impl.notice.User2Notice;
import com.akaxin.site.business.impl.site.SiteConfig;
import com.akaxin.site.business.push.PushNotification;
import com.akaxin.site.storage.bean.ApplyFriendBean;
import com.akaxin.site.storage.bean.ApplyUserBean;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.UserFriendBean;
import com.windchat.im.storage.bean.ApplyFriendBean;
import com.windchat.im.storage.bean.ApplyUserBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.UserFriendBean;
/**
* <pre>

View File

@ -54,12 +54,12 @@ import com.akaxin.site.business.dao.UserGroupDao;
import com.akaxin.site.business.dao.UserProfileDao;
import com.akaxin.site.business.impl.AbstractRequest;
import com.akaxin.site.business.impl.site.SiteConfig;
import com.akaxin.site.storage.bean.ExpireToken;
import com.akaxin.site.storage.bean.GroupMemberBean;
import com.akaxin.site.storage.bean.GroupProfileBean;
import com.akaxin.site.storage.bean.SimpleGroupBean;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.UserGroupBean;
import com.windchat.im.storage.bean.ExpireToken;
import com.windchat.im.storage.bean.GroupMemberBean;
import com.windchat.im.storage.bean.GroupProfileBean;
import com.windchat.im.storage.bean.SimpleGroupBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.UserGroupBean;
import com.google.common.collect.Lists;
import com.google.protobuf.ProtocolStringList;

View File

@ -42,7 +42,7 @@ import com.akaxin.proto.site.ApiPluginProxyProto;
import com.akaxin.site.business.dao.SitePluginDao;
import com.akaxin.site.business.impl.AbstractRequest;
import com.akaxin.site.business.impl.site.SiteConfig;
import com.akaxin.site.storage.bean.PluginBean;
import com.windchat.im.storage.bean.PluginBean;
import com.google.protobuf.ByteString;
/**

View File

@ -29,9 +29,9 @@ import com.akaxin.proto.core.DeviceProto;
import com.akaxin.proto.site.ApiSecretChatApplyU2Proto;
import com.akaxin.site.business.impl.AbstractRequest;
import com.akaxin.site.business.impl.site.SiteConfig;
import com.akaxin.site.storage.api.IUserDeviceDao;
import com.akaxin.site.storage.bean.UserDeviceBean;
import com.akaxin.site.storage.service.DeviceDaoService;
import com.windchat.im.storage.api.IUserDeviceDao;
import com.windchat.im.storage.bean.UserDeviceBean;
import com.windchat.im.storage.service.DeviceDaoService;
/**
* 用户开启二人群聊 绝密聊天

View File

@ -54,13 +54,13 @@ import com.akaxin.site.business.impl.notice.User2Notice;
import com.akaxin.site.business.impl.site.PlatformUserPhone;
import com.akaxin.site.business.impl.site.SiteConfig;
import com.akaxin.site.business.impl.site.UserUic;
import com.akaxin.site.storage.api.IUserDeviceDao;
import com.akaxin.site.storage.bean.ApplyFriendBean;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.UserDeviceBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.akaxin.site.storage.bean.UserSessionBean;
import com.akaxin.site.storage.service.DeviceDaoService;
import com.windchat.im.storage.api.IUserDeviceDao;
import com.windchat.im.storage.bean.ApplyFriendBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.UserDeviceBean;
import com.windchat.im.storage.bean.UserProfileBean;
import com.windchat.im.storage.bean.UserSessionBean;
import com.windchat.im.storage.service.DeviceDaoService;
/**
* 获取站点信息 <br>

View File

@ -30,7 +30,6 @@ import com.akaxin.common.constant.IErrorCode;
import com.akaxin.common.exceptions.ZalyException2;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.common.utils.StringHelper;
import com.akaxin.common.utils.UserIdUtils;
import com.akaxin.common.utils.ValidatorPattern;
import com.akaxin.proto.core.UserProto;
import com.akaxin.proto.site.ApiUserMuteProto;
@ -41,8 +40,8 @@ import com.akaxin.proto.site.ApiUserUpdateProfileProto;
import com.akaxin.site.business.dao.UserFriendDao;
import com.akaxin.site.business.dao.UserProfileDao;
import com.akaxin.site.business.impl.AbstractRequest;
import com.akaxin.site.storage.bean.UserFriendBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.windchat.im.storage.bean.UserFriendBean;
import com.windchat.im.storage.bean.UserProfileBean;
/**
* 用户个人自身资料相关功能

View File

@ -5,7 +5,7 @@ import org.apache.commons.lang3.StringUtils;
import com.akaxin.common.utils.StringHelper;
import com.akaxin.site.business.dao.UserProfileDao;
import com.akaxin.site.business.impl.site.SiteConfig;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.SimpleUserBean;
/**
*

View File

@ -33,9 +33,9 @@ import com.akaxin.common.utils.StringHelper;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.site.business.service.ApiRequestService;
import com.akaxin.site.connector.constant.AkxProject;
import com.akaxin.site.storage.api.IUserSessionDao;
import com.akaxin.site.storage.bean.SimpleAuthBean;
import com.akaxin.site.storage.service.UserSessionDaoService;
import com.windchat.im.storage.api.IUserSessionDao;
import com.windchat.im.storage.bean.SimpleAuthBean;
import com.windchat.im.storage.service.UserSessionDaoService;
import com.google.protobuf.ByteString;
import io.netty.channel.Channel;

View File

@ -34,7 +34,7 @@ import com.akaxin.proto.site.ImSiteHelloProto;
import com.akaxin.site.business.impl.site.SiteConfig;
import com.akaxin.site.connector.constant.AkxProject;
import com.akaxin.site.connector.session.SessionManager;
import com.akaxin.site.storage.bean.SimpleAuthBean;
import com.windchat.im.storage.bean.SimpleAuthBean;
import io.netty.channel.Channel;

View File

@ -20,9 +20,9 @@ import org.slf4j.LoggerFactory;
import com.akaxin.common.utils.StringHelper;
import com.akaxin.site.connector.constant.AkxProject;
import com.akaxin.site.storage.api.IPluginDao;
import com.akaxin.site.storage.bean.PluginBean;
import com.akaxin.site.storage.service.PluginServiceDao;
import com.windchat.im.storage.api.IPluginDao;
import com.windchat.im.storage.bean.PluginBean;
import com.windchat.im.storage.service.PluginServiceDao;
/**
* @author Sam{@link an.guoyue254@gmail.com}

View File

@ -15,7 +15,7 @@
*/
package com.akaxin.site.connector.session;
import com.akaxin.site.storage.bean.SimpleAuthBean;
import com.windchat.im.storage.bean.SimpleAuthBean;
/**
* 管理用户session设置用户在线离线状态

View File

@ -20,11 +20,11 @@ import java.sql.SQLException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.IUserDeviceDao;
import com.akaxin.site.storage.api.IUserSessionDao;
import com.akaxin.site.storage.bean.SimpleAuthBean;
import com.akaxin.site.storage.service.DeviceDaoService;
import com.akaxin.site.storage.service.UserSessionDaoService;
import com.windchat.im.storage.api.IUserDeviceDao;
import com.windchat.im.storage.api.IUserSessionDao;
import com.windchat.im.storage.bean.SimpleAuthBean;
import com.windchat.im.storage.service.DeviceDaoService;
import com.windchat.im.storage.service.UserSessionDaoService;
/**
* 负责用户session表数据更新

View File

@ -20,8 +20,8 @@ import java.sql.SQLException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.IUserFriendDao;
import com.akaxin.site.storage.service.UserFriendDaoService;
import com.windchat.im.storage.api.IUserFriendDao;
import com.windchat.im.storage.service.UserFriendDaoService;
/**
* IM消息通信过程判断用户之间的关系操作

View File

@ -21,12 +21,12 @@ import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.IGroupDao;
import com.akaxin.site.storage.api.IUserGroupDao;
import com.akaxin.site.storage.bean.GroupMemberBean;
import com.akaxin.site.storage.bean.GroupProfileBean;
import com.akaxin.site.storage.service.GroupDaoService;
import com.akaxin.site.storage.service.UserGroupDaoService;
import com.windchat.im.storage.api.IGroupDao;
import com.windchat.im.storage.api.IUserGroupDao;
import com.windchat.im.storage.bean.GroupMemberBean;
import com.windchat.im.storage.bean.GroupProfileBean;
import com.windchat.im.storage.service.GroupDaoService;
import com.windchat.im.storage.service.UserGroupDaoService;
public class ImUserGroupDao {
private static final Logger logger = LoggerFactory.getLogger(ImUserGroupDao.class);

View File

@ -21,11 +21,11 @@ import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.IUserDeviceDao;
import com.akaxin.site.storage.api.IUserProfileDao;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.service.DeviceDaoService;
import com.akaxin.site.storage.service.UserProfileDaoService;
import com.windchat.im.storage.api.IUserDeviceDao;
import com.windchat.im.storage.api.IUserProfileDao;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.service.DeviceDaoService;
import com.windchat.im.storage.service.UserProfileDaoService;
/**
*

View File

@ -22,8 +22,8 @@ import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.IUserSessionDao;
import com.akaxin.site.storage.service.UserSessionDaoService;
import com.windchat.im.storage.api.IUserSessionDao;
import com.windchat.im.storage.service.UserSessionDaoService;
public class ImUserSessionDao {
private static final Logger logger = LoggerFactory.getLogger(ImUserSessionDao.class);

View File

@ -22,8 +22,8 @@ import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.IUserSessionDao;
import com.akaxin.site.storage.service.UserSessionDaoService;
import com.windchat.im.storage.api.IUserSessionDao;
import com.windchat.im.storage.service.UserSessionDaoService;
/**
*

View File

@ -21,8 +21,8 @@ import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.api.ISiteConfigDao;
import com.akaxin.site.storage.service.SiteConfigDaoService;
import com.windchat.im.storage.api.ISiteConfigDao;
import com.windchat.im.storage.service.SiteConfigDaoService;
/**
* 站点配置相关操作

View File

@ -26,8 +26,8 @@ import com.akaxin.proto.core.UserProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.message.dao.ImUserGroupDao;
import com.akaxin.site.message.dao.ImUserProfileDao;
import com.akaxin.site.storage.bean.GroupProfileBean;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.GroupProfileBean;
import com.windchat.im.storage.bean.SimpleUserBean;
/**
* <pre>

View File

@ -22,9 +22,9 @@ import com.akaxin.common.command.Command;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.GroupMessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.GroupMessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
* 群图片消息

View File

@ -23,9 +23,9 @@ import com.akaxin.proto.client.ImStcMessageProto;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.core.CoreProto.MsgType;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.GroupMessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.GroupMessageBean;
import com.windchat.im.storage.service.MessageDaoService;
import io.netty.channel.Channel;

View File

@ -22,9 +22,9 @@ import com.akaxin.common.command.Command;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.GroupMessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.GroupMessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
* 群通知消息

View File

@ -22,9 +22,9 @@ import com.akaxin.common.command.Command;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.GroupMessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.GroupMessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
* 群文本消息

View File

@ -23,9 +23,9 @@ import com.akaxin.proto.client.ImStcMessageProto;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.core.CoreProto.MsgType;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.GroupMessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.GroupMessageBean;
import com.windchat.im.storage.service.MessageDaoService;
import io.netty.channel.Channel;

View File

@ -22,9 +22,9 @@ import com.akaxin.common.command.Command;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.GroupMessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.GroupMessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
* 群语音消息

View File

@ -25,8 +25,8 @@ import com.akaxin.proto.client.ImStcMessageProto;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.core.CoreProto.MsgType;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.service.MessageDaoService;
import io.netty.channel.Channel;

View File

@ -23,9 +23,9 @@ import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.message.bean.WebBean;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.GroupMessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.GroupMessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
* 群web消息

View File

@ -23,9 +23,9 @@ import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.message.bean.WebBean;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.GroupMessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.GroupMessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
* 群web通知消息

View File

@ -29,8 +29,8 @@ import com.akaxin.common.constant.ErrorCode2;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.client.ImStcPsnProto;
import com.akaxin.site.message.dao.ImUserSessionDao;
import com.akaxin.site.storage.api.IGroupDao;
import com.akaxin.site.storage.service.GroupDaoService;
import com.windchat.im.storage.api.IGroupDao;
import com.windchat.im.storage.service.GroupDaoService;
public class GroupPsnHandler extends AbstractGroupHandler<Command> {
private static final Logger logger = LoggerFactory.getLogger(GroupPsnHandler.class);

View File

@ -35,9 +35,9 @@ import com.akaxin.site.message.dao.ImUserProfileDao;
import com.akaxin.site.message.push.PushClient;
import com.akaxin.site.message.threads.MultiPushThreadExecutor;
import com.akaxin.site.message.utils.SiteConfigHelper;
import com.akaxin.site.storage.api.IGroupDao;
import com.akaxin.site.storage.bean.GroupProfileBean;
import com.akaxin.site.storage.service.GroupDaoService;
import com.windchat.im.storage.api.IGroupDao;
import com.windchat.im.storage.bean.GroupProfileBean;
import com.windchat.im.storage.service.GroupDaoService;
import com.google.protobuf.ByteString;
/**

View File

@ -28,8 +28,8 @@ import com.akaxin.common.constant.ErrorCode2;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.client.ImStcPsnProto;
import com.akaxin.proto.site.ImSyncFinishProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.service.MessageDaoService;
/**
* 客户端同步消息完成结束标志

View File

@ -36,11 +36,11 @@ import com.akaxin.proto.core.CoreProto.MsgType;
import com.akaxin.proto.site.ImSyncMessageProto;
import com.akaxin.site.message.bean.WebBean;
import com.akaxin.site.message.utils.NumUtils;
import com.akaxin.site.storage.api.IGroupDao;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.GroupMessageBean;
import com.akaxin.site.storage.service.GroupDaoService;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IGroupDao;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.GroupMessageBean;
import com.windchat.im.storage.service.GroupDaoService;
import com.windchat.im.storage.service.MessageDaoService;
import com.google.protobuf.ByteString;
import io.netty.channel.Channel;

View File

@ -23,10 +23,10 @@ import org.slf4j.LoggerFactory;
import com.akaxin.common.command.Command;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.site.ImSyncMsgStatusProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.GroupMessageBean;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.GroupMessageBean;
import com.windchat.im.storage.bean.U2MessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
*

View File

@ -34,9 +34,9 @@ import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.core.CoreProto.MsgType;
import com.akaxin.proto.site.ImSyncMessageProto;
import com.akaxin.site.message.utils.NumUtils;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.U2MessageBean;
import com.windchat.im.storage.service.MessageDaoService;
import com.google.protobuf.ByteString;
import io.netty.channel.Channel;

View File

@ -37,9 +37,9 @@ import com.akaxin.proto.core.CoreProto.MsgType;
import com.akaxin.proto.site.ImSyncMessageProto;
import com.akaxin.site.message.bean.WebBean;
import com.akaxin.site.message.utils.NumUtils;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.U2MessageBean;
import com.windchat.im.storage.service.MessageDaoService;
import com.google.protobuf.ByteString;
import io.netty.channel.Channel;

View File

@ -22,9 +22,9 @@ import com.akaxin.common.command.Command;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.U2MessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
* 二人图片消息处理

View File

@ -22,9 +22,9 @@ import com.akaxin.common.command.Command;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.U2MessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
* 加密二人图片

View File

@ -23,9 +23,9 @@ import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.message.group.handler.AbstractGroupHandler;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.U2MessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
* 二人通知消息

View File

@ -24,9 +24,9 @@ import com.akaxin.common.command.Command;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.U2MessageBean;
import com.windchat.im.storage.service.MessageDaoService;
import com.google.protobuf.ByteString;
/**

View File

@ -24,9 +24,9 @@ import com.akaxin.common.command.Command;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.U2MessageBean;
import com.windchat.im.storage.service.MessageDaoService;
import com.google.protobuf.ByteString;
/**

View File

@ -22,9 +22,9 @@ import com.akaxin.common.command.Command;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.U2MessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
* 二人语音消息

View File

@ -22,9 +22,9 @@ import com.akaxin.common.command.Command;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.U2MessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
* 二人加密语音

View File

@ -23,9 +23,9 @@ import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.message.bean.WebBean;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.U2MessageBean;
import com.windchat.im.storage.service.MessageDaoService;
public class U2MessageWebHandler extends AbstractU2Handler<Command> {
private static final Logger logger = LoggerFactory.getLogger(U2MessageWebHandler.class);

View File

@ -23,9 +23,9 @@ import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.message.bean.WebBean;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.U2MessageBean;
import com.windchat.im.storage.service.MessageDaoService;
public class U2MessageWebNoticeHandler extends AbstractU2Handler<Command> {
private static final Logger logger = LoggerFactory.getLogger(U2MessageWebNoticeHandler.class);

View File

@ -26,7 +26,7 @@ import com.akaxin.proto.core.UserProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.message.dao.ImUserFriendDao;
import com.akaxin.site.message.dao.ImUserProfileDao;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.SimpleUserBean;
/**
* <pre>

View File

@ -35,7 +35,7 @@ import com.akaxin.site.message.dao.ImUserProfileDao;
import com.akaxin.site.message.push.PushClient;
import com.akaxin.site.message.threads.MultiPushThreadExecutor;
import com.akaxin.site.message.utils.SiteConfigHelper;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.google.protobuf.ByteString;
public class UserPushHandler extends AbstractU2Handler<Command> {

View File

@ -22,9 +22,9 @@ import com.akaxin.common.command.Command;
import com.akaxin.common.logs.LogUtils;
import com.akaxin.proto.core.CoreProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.storage.api.IMessageDao;
import com.akaxin.site.storage.bean.GroupMessageBean;
import com.akaxin.site.storage.service.MessageDaoService;
import com.windchat.im.storage.api.IMessageDao;
import com.windchat.im.storage.bean.GroupMessageBean;
import com.windchat.im.storage.service.MessageDaoService;
/**
* web群聊文本消息

View File

@ -26,7 +26,7 @@ import com.akaxin.proto.core.UserProto;
import com.akaxin.proto.site.ImCtsMessageProto;
import com.akaxin.site.message.dao.ImUserFriendDao;
import com.akaxin.site.message.dao.ImUserProfileDao;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.SimpleUserBean;
/**
* web消息检测

View File

@ -13,7 +13,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package com.akaxin.site.storage;
package com.windchat.im.storage;
import java.io.File;
import java.io.FileInputStream;
@ -27,19 +27,19 @@ import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.akaxin.site.storage.dao.config.DBConfig;
import com.akaxin.site.storage.dao.config.DBType;
import com.akaxin.site.storage.dao.config.JdbcConst;
import com.akaxin.site.storage.dao.config.PrepareSiteConfigData;
import com.akaxin.site.storage.dao.mysql.manager.MysqlManager;
import com.akaxin.site.storage.dao.sqlite.manager.SQLiteJDBCManager;
import com.akaxin.site.storage.dao.sqlite.manager.SQLiteUpgrade;
import com.akaxin.site.storage.exception.InitDatabaseException;
import com.akaxin.site.storage.exception.MigrateDatabaseException;
import com.akaxin.site.storage.exception.NeedInitMysqlException;
import com.akaxin.site.storage.exception.UpgradeDatabaseException;
import com.akaxin.site.storage.util.FileUtils;
import com.akaxin.site.storage.util.MigrateUtils;
import com.windchat.im.storage.dao.config.DBConfig;
import com.windchat.im.storage.dao.config.DBType;
import com.windchat.im.storage.dao.config.JdbcConst;
import com.windchat.im.storage.dao.config.PrepareSiteConfigData;
import com.windchat.im.storage.dao.mysql.manager.MysqlManager;
import com.windchat.im.storage.dao.sqlite.manager.SQLiteJDBCManager;
import com.windchat.im.storage.dao.sqlite.manager.SQLiteUpgrade;
import com.windchat.im.storage.exception.InitDatabaseException;
import com.windchat.im.storage.exception.MigrateDatabaseException;
import com.windchat.im.storage.exception.NeedInitMysqlException;
import com.windchat.im.storage.exception.UpgradeDatabaseException;
import com.windchat.im.storage.util.FileUtils;
import com.windchat.im.storage.util.MigrateUtils;
/**
* 数据源初始化管理不做具体操作对外提供方法

View File

@ -1,10 +1,10 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import java.util.List;
import com.akaxin.site.storage.bean.ApplyFriendBean;
import com.akaxin.site.storage.bean.ApplyUserBean;
import com.windchat.im.storage.bean.ApplyFriendBean;
import com.windchat.im.storage.bean.ApplyUserBean;
public interface IFriendApplyDao {

View File

@ -1,12 +1,12 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import java.util.List;
import com.akaxin.site.storage.bean.GroupMemberBean;
import com.akaxin.site.storage.bean.GroupProfileBean;
import com.akaxin.site.storage.bean.SimpleGroupBean;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.GroupMemberBean;
import com.windchat.im.storage.bean.GroupProfileBean;
import com.windchat.im.storage.bean.SimpleGroupBean;
import com.windchat.im.storage.bean.SimpleUserBean;
public interface IGroupDao {

View File

@ -1,4 +1,4 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
public interface IGroupProfileDao {

View File

@ -1,10 +1,10 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import java.util.List;
import com.akaxin.site.storage.bean.GroupMessageBean;
import com.akaxin.site.storage.bean.U2MessageBean;
import com.windchat.im.storage.bean.GroupMessageBean;
import com.windchat.im.storage.bean.U2MessageBean;
/**
* 处理二人消息群消息等

View File

@ -1,9 +1,9 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import java.util.List;
import com.akaxin.site.storage.bean.PluginBean;
import com.windchat.im.storage.bean.PluginBean;
public interface IPluginDao {

View File

@ -1,4 +1,4 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import java.util.Map;

View File

@ -1,4 +1,4 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import java.util.List;

View File

@ -1,8 +1,8 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import com.akaxin.site.storage.bean.ExpireToken;
import com.windchat.im.storage.bean.ExpireToken;
public interface ITokenDao {

View File

@ -1,9 +1,9 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import java.util.List;
import com.akaxin.site.storage.bean.UicBean;
import com.windchat.im.storage.bean.UicBean;
public interface IUicDao {

View File

@ -1,9 +1,9 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import java.util.List;
import com.akaxin.site.storage.bean.UserDeviceBean;
import com.windchat.im.storage.bean.UserDeviceBean;
public interface IUserDeviceDao {

View File

@ -1,10 +1,10 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import java.util.List;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.UserFriendBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.UserFriendBean;
public interface IUserFriendDao {

View File

@ -1,9 +1,9 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import java.util.List;
import com.akaxin.site.storage.bean.UserGroupBean;
import com.windchat.im.storage.bean.UserGroupBean;
public interface IUserGroupDao {

View File

@ -1,12 +1,12 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import java.util.List;
import com.akaxin.site.storage.bean.SimpleUserBean;
import com.akaxin.site.storage.bean.SimpleUserRelationBean;
import com.akaxin.site.storage.bean.UserFriendBean;
import com.akaxin.site.storage.bean.UserProfileBean;
import com.windchat.im.storage.bean.SimpleUserBean;
import com.windchat.im.storage.bean.SimpleUserRelationBean;
import com.windchat.im.storage.bean.UserFriendBean;
import com.windchat.im.storage.bean.UserProfileBean;
public interface IUserProfileDao {

View File

@ -1,10 +1,10 @@
package com.akaxin.site.storage.api;
package com.windchat.im.storage.api;
import java.sql.SQLException;
import java.util.List;
import com.akaxin.site.storage.bean.SimpleAuthBean;
import com.akaxin.site.storage.bean.UserSessionBean;
import com.windchat.im.storage.bean.SimpleAuthBean;
import com.windchat.im.storage.bean.UserSessionBean;
public interface IUserSessionDao {
public boolean saveUserSession(UserSessionBean bean) throws SQLException;

Some files were not shown because too many files have changed in this diff Show More