优化注释

v1.4.1
hiparker 5 years ago
parent 7abfd65bad
commit b2306e53d3

@ -30,8 +30,6 @@ public final class IPUtil {
/** 排除结果 */
private static final String UNKNOWN = "unknown";
/** 分割符 */
private static final String SPLIT = ",";
/** 尝试字段 */
private static final String[] HEADERS_TO_TRY = {
"X-Forwarded-For",

@ -25,10 +25,10 @@ import org.springframework.transaction.annotation.EnableTransactionManagement;
/**
* @Author parker
*
* MyBatis - Plus 配置
*
* @author Parker
* @date 2020-09-15
*/
@Slf4j
@EnableTransactionManagement
@ -37,7 +37,7 @@ public class MyBatisPlusConfig {
/***
* 乐观锁
* @return
* @return 拦截器
*/
@Bean
public OptimisticLockerInterceptor optimisticLockerInterceptor(){
@ -46,8 +46,8 @@ public class MyBatisPlusConfig {
/**
* Mybatis 拦截器
* @param sqlSessionFactory
* @return
* @param sqlSessionFactory sqlSessionFactory
* @return String
*/
@Bean
public String myInterceptor(SqlSessionFactory sqlSessionFactory) {

@ -27,11 +27,10 @@ import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;
/**
* @author : parker
* @date : 2020-09-15
*
* 消息订阅 配置
*
* @author Parker
* @date 2020-09-15
**/
@Slf4j
@Configuration
@ -43,9 +42,7 @@ public class RedisMessageListenerConfig {
* redis消息监听器容器
* 可以添加多个监听不同话题的redis监听器,只需要把消息监听器和相应的消息订阅处理器绑定,该消息监听器
* 通过反射技术调用消息订阅处理器的相关方法进行一些业务处理
* @return
*/
@Bean
public RedisMessageListenerContainer container(LettuceConnectionFactory lettuceConnectionFactory) {
RedisPushSubReceiver receiver = new RedisPushSubReceiver();
@ -57,12 +54,12 @@ public class RedisMessageListenerConfig {
return container;
}
/**
* 消息监听器适配器,绑定消息处理器,利用反射技术调用消息处理器的业务方法
*
* 想要处理消息 需要重写 消息接受方法
*
* @return
*/
@Bean
public MessageListenerAdapter listenerAdapter(RedisPushSubReceiver baseReceiver) {

@ -50,7 +50,7 @@ import java.util.Set;
*
* 全程用 token认证 所以也就用不着 什么共享缓存 - 无状态
*
* @author parker
* @author Parker
* @date 2017-04-20 18:33
*/
@Configuration

@ -31,7 +31,8 @@ import javax.annotation.Resource;
/**
* 配置统一的后台接口访问路径的前缀
*
* @author parker
* @author Parker
* @date 2020-09-15
*/
@Slf4j
@Configuration
@ -42,7 +43,7 @@ public class SpringWebMvcConfig implements WebMvcConfigurer {
/**
* 配置 ApiRestController 生效
* @param configurer
* @param configurer 配置
*/
@Override
public void configurePathMatch(PathMatchConfigurer configurer) {
@ -52,7 +53,7 @@ public class SpringWebMvcConfig implements WebMvcConfigurer {
/**
* 解决跨域问题
* @return
* @return CorsFilter
*/
@Bean
public CorsFilter corsFilter() {

@ -43,7 +43,8 @@ import java.util.List;
/**
* Swagger 配置类
*
* @author parker
* @author Parker
* @date 2020-09-15
*/
@Configuration
@EnableSwagger2
@ -90,7 +91,7 @@ public class SwaggerConfig {
/**
* api文档的详细信息函数,注意这里的注解引用的是哪个
*
* @return
* @return ApiInfo
*/
private ApiInfo apiInfo() {
return new ApiInfoBuilder()
@ -110,7 +111,7 @@ public class SwaggerConfig {
/**
* 安全模块
* @return
* @return SecurityContext
*/
private SecurityContext securityContext() {
return SecurityContext.builder()
@ -121,7 +122,7 @@ public class SwaggerConfig {
/**
* jwt token
* @return
* @return List
*/
private List<Parameter> defaultToken() {
ParameterBuilder parameterBuilder = new ParameterBuilder();
@ -137,7 +138,7 @@ public class SwaggerConfig {
/**
* oauth2 授权
* @return
* @return List
*/
List<SecurityReference> defaultAuth() {
AuthorizationScope authorizationScope = new AuthorizationScope("global", "accessEverything");

@ -22,7 +22,9 @@ import org.springframework.stereotype.Component;
/**
* 接口路径前缀配置
* @author parker
*
* @author Parker
* @date 2020-09-15
*/
@Component
@ConfigurationProperties(prefix = ApiPathProperties.PROP_PREFIX)

@ -22,7 +22,9 @@ import org.springframework.stereotype.Component;
/**
* 接口路径前缀配置
* @author parker
*
* @author Parker
* @date 2020-09-15
*/
@Component
@ConfigurationProperties(prefix = CacheProperties.PROP_PREFIX)

@ -17,6 +17,7 @@ import java.util.Map;
* 获得数据源工具类
*
* @author Parker
* @date 2020-09-15
*/
@Slf4j
@Configuration

@ -11,8 +11,8 @@ import java.util.Set;
/**
* OPSLI 配置文件
*
* @author 周鹏程
* @date 2021-01-31 5:52 下午
* @author Parker
* @date 2020-09-15
**/
@Configuration
@ConfigurationProperties(prefix = GlobalProperties.PROP_PREFIX)

@ -68,14 +68,10 @@ import java.util.Iterator;
import java.util.List;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.common.base.concroller
* @Author: Parker
* @CreateTime: 2020-09-13 21:16
* @Description: Controller 基类
*
* 默认 范型引用 子类的Service , 为简单的CRUD做足准备
*
* @author Parker
* @date 2020-09-15
*/
@Slf4j
@RestController

@ -21,12 +21,10 @@ import lombok.experimental.Accessors;
import org.opsli.api.base.warpper.ApiWrapper;
/**
*
* Entity 基础类
*
* @author Parker
* @date 2019-05-11
*
* @date 2020-09-15
*/
@Data
@Accessors(chain = true)

@ -19,11 +19,10 @@ import lombok.Data;
import lombok.EqualsAndHashCode;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.modulars.system.area.entity
* @Author: Parker
* @CreateTime: 2020-11-28 18:59:59
* @Description: Tree表
* Tree表
*
* @author Parker
* @date 2020-09-15
*/
@Data
@EqualsAndHashCode(callSuper = false)

@ -21,11 +21,10 @@ import org.opsli.core.base.entity.BaseEntity;
import org.opsli.core.base.service.interfaces.BaseServiceInterface;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.common.base.service
* @Author: Parker
* @CreateTime: 2020-09-17 12:33
* @Description: Opsli Base Service
* 基础Service
*
* @author Parker
* @date 2020-09-15
*/
public abstract class BaseService <M extends BaseMapper<T>, T extends BaseEntity>
extends ServiceImpl<M, T> implements BaseServiceInterface<T> {

@ -42,11 +42,7 @@ import java.util.List;
import java.util.Map;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.common.base.service.impl
* @Author: Parker
* @CreateTime: 2020-09-14 17:31
* @Description: CurdServiceImpl 基类 - 实现类
* CurdServiceImpl 基类 - 实现类
*
* 这里 可能觉得 增改 最次返回的也是实体对象 设计的有问题
*
@ -58,6 +54,8 @@ import java.util.Map;
* 单独按照ID查询数据 和 按照ID修改、删除数据 隔离级别暂时不需要
* 既然能从page列表中看到的数据 则是这个租户的数据
*
* @author Parker
* @date 2020-09-15
*/
@Slf4j
@Transactional(readOnly = true)

@ -18,11 +18,10 @@ package org.opsli.core.base.service.interfaces;
import com.baomidou.mybatisplus.extension.service.IService;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.common.base.service
* @Author: Parker
* @CreateTime: 2020-09-17 12:33
* @Description: Opsli BaseServiceInterface
* 基础服务接口
*
* @author Parker
* @date 2020-09-15
*/
public interface BaseServiceInterface<T> extends IService<T> {

@ -37,6 +37,9 @@ import java.util.List;
*
* @param <T>
* @param <E>
*
* @author Parker
* @date 2020-09-15
*/
public interface CrudServiceInterface<T extends BaseEntity, E extends ApiWrapper> extends BaseServiceInterface<T> {

@ -46,11 +46,7 @@ import java.util.Map;
import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.local
* @Author: Parker
* @CreateTime: 2020-09-16 16:20
* @Description: 本地 缓存接口
* 缓存工具类
*
* 一、控制key的生命周期,Redis不是垃圾桶(缓存不是垃圾桶)
* 建议使用expire设置过期时间(条件允许可以打散过期时间,防止集中过期),不过期的数据重点关注idletime。
@ -58,7 +54,8 @@ import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
* 二、【强制】:拒绝bigkey(防止网卡流量、慢查询)
* string类型控制在10KB以内,hash、list、set、zset元素个数不要超过5000。
*
*
* @author Parker
* @date 2020-09-16 16:20
*/
@Slf4j
@Order(UTIL_ORDER)

@ -22,11 +22,10 @@ import org.apache.commons.lang3.builder.ToStringBuilder;
import org.opsli.core.cache.pushsub.enums.PushSubType;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.entity
* @Author: Parker
* @CreateTime: 2020-09-18 00:01
* @Description: 热点数据处理 Entity
* 热点数据处理 Entity
*
* @author Parker
* @date 2020-09-18 00:01
*/
@Data
@AllArgsConstructor
@ -36,9 +35,4 @@ public class CacheDataEntity {
/** key */
private String key;
public static void main(String[] args) {
CacheDataEntity ret = new CacheDataEntity("123");
System.out.println(ToStringBuilder.reflectionToString(ret));
}
}

@ -16,11 +16,10 @@
package org.opsli.core.cache.pushsub.enums;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.enums
* @Author: Parker
* @CreateTime: 2020-09-16 22:28
* @Description: 缓存操作类型
* 缓存操作类型
*
* @author Parker
* @date 2020-09-16
*/
public enum CacheHandleType {

@ -16,11 +16,10 @@
package org.opsli.core.cache.pushsub.enums;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.enums
* @Author: Parker
* @CreateTime: 2020-09-16 22:28
* @Description: 缓存操作类型
* 缓存操作类型
*
* @author Parker
* @date 2020-09-16
*/
public enum DictModelType {

@ -16,11 +16,10 @@
package org.opsli.core.cache.pushsub.enums;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.enums
* @Author: Parker
* @CreateTime: 2020-09-15 16:15
* @Description: 消息具体类型
* 消息具体类型
*
* @author Parker
* @date 2020-09-16
*/
public enum MsgArgsType {

@ -16,11 +16,10 @@
package org.opsli.core.cache.pushsub.enums;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.enums
* @Author: Parker
* @CreateTime: 2020-09-15 16:15
* @Description: 发布订阅类型
* 发布订阅类型
*
* @author Parker
* @date 2020-09-16
*/
public enum PushSubType {

@ -16,11 +16,10 @@
package org.opsli.core.cache.pushsub.enums;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.enums
* @Author: Parker
* @CreateTime: 2020-09-16 22:28
* @Description: 用户缓存操作类型
* 用户缓存操作类型
*
* @author Parker
* @date 2020-09-16
*/
public enum UserModelType {

@ -34,11 +34,10 @@ import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.handler
* @Author: Parker
* @CreateTime: 2020-09-15 16:24
* @Description: 字典消息处理
* 字典消息处理
*
* @author Parker
* @date 2020-09-16
*/
@Slf4j
public class DictHandler implements RedisPushSubHandler{
@ -78,8 +77,8 @@ public class DictHandler implements RedisPushSubHandler{
/**
* 真正处理 - 只是处理自己本地的缓存
* @param dictWrapperModel
* @param type
* @param dictWrapperModel model
* @param type 类型
*/
private void handler(DictWrapper dictWrapperModel, CacheHandleType type){

@ -27,11 +27,10 @@ import org.opsli.plugins.cache.EhCachePlugin;
import org.springframework.beans.factory.annotation.Autowired;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.handler
* @Author: Parker
* @CreateTime: 2020-09-15 16:24
* @Description: 热数据处理
* 热数据处理
*
* @author Parker
* @date 2020-09-16
*/
@Slf4j
public class HotDataHandler implements RedisPushSubHandler{

@ -27,11 +27,10 @@ import org.opsli.plugins.cache.EhCachePlugin;
import org.springframework.beans.factory.annotation.Autowired;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.handler
* @Author: Parker
* @CreateTime: 2020-09-15 16:24
* @Description: 系统参数消息处理
* 系统参数消息处理
*
* @author Parker
* @date 2020-09-16
*/
@Slf4j
public class OptionHandler implements RedisPushSubHandler{
@ -52,7 +51,7 @@ public class OptionHandler implements RedisPushSubHandler{
/**
* 用户数据处理
* @param msgJson
* @param msgJson 信息Json
*/
private void optionHandler(JSONObject msgJson){
JSONObject data = msgJson.getJSONObject(MsgArgsType.OPTION_MODEL_DATA.toString());

@ -27,11 +27,10 @@ import org.opsli.plugins.cache.EhCachePlugin;
import org.springframework.beans.factory.annotation.Autowired;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.handler
* @Author: Parker
* @CreateTime: 2020-09-15 16:24
* @Description: 用户组织消息处理
* 用户组织消息处理
*
* @author Parker
* @date 2020-09-16
*/
@Slf4j
public class OrgHandler implements RedisPushSubHandler{
@ -52,7 +51,7 @@ public class OrgHandler implements RedisPushSubHandler{
/**
* 用户组织数据处理
* @param msgJson
* @param msgJson 信息Json
*/
private void orgHandler(JSONObject msgJson){
JSONObject data = msgJson.getJSONObject(MsgArgsType.ORG_USER_DATA.toString());

@ -19,20 +19,22 @@ import com.alibaba.fastjson.JSONObject;
import org.opsli.core.cache.pushsub.enums.PushSubType;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.receiver
* @Author: Parker
* @CreateTime: 2020-09-15 15:11
* @Description: 标示类 用于获得 消息未知
* 标示类 用于获得 消息未知
*
* @author Parker
* @date 2020-09-16
*/
public interface RedisPushSubHandler {
/**
* 获得类型
* @return 类型
*/
PushSubType getType();
/**
* 消息处理
* @param msgJson
* @param msgJson 信息Json
*/
void handler(JSONObject msgJson);

@ -27,11 +27,10 @@ import org.opsli.plugins.cache.EhCachePlugin;
import org.springframework.beans.factory.annotation.Autowired;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.handler
* @Author: Parker
* @CreateTime: 2020-09-15 16:24
* @Description: 租户消息处理
* 租户消息处理
*
* @author Parker
* @date 2020-09-16
*/
@Slf4j
public class TenantHandler implements RedisPushSubHandler{
@ -52,7 +51,7 @@ public class TenantHandler implements RedisPushSubHandler{
/**
* 租户数据处理
* @param msgJson
* @param msgJson 信息Json
*/
private void orgHandler(JSONObject msgJson){
JSONObject data = msgJson.getJSONObject(MsgArgsType.TENANT_DATA.toString());

@ -29,11 +29,10 @@ import org.opsli.plugins.cache.EhCachePlugin;
import org.springframework.beans.factory.annotation.Autowired;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.handler
* @Author: Parker
* @CreateTime: 2020-09-15 16:24
* @Description: 字典消息处理
* 用户消息处理
*
* @author Parker
* @date 2020-09-16
*/
@Slf4j
public class UserHandler implements RedisPushSubHandler{
@ -72,7 +71,7 @@ public class UserHandler implements RedisPushSubHandler{
/**
* 用户数据处理
* @param msgJson
* @param msgJson 信息Json
*/
private void userHandler(JSONObject msgJson){
JSONObject data = msgJson.getJSONObject(MsgArgsType.USER_MODEL_DATA.toString());
@ -98,7 +97,7 @@ public class UserHandler implements RedisPushSubHandler{
/**
* 用户角色数据处理
* @param msgJson
* @param msgJson 信息Json
*/
private void userRolesHandler(JSONObject msgJson){
JSONArray dataArray = msgJson.getJSONArray(MsgArgsType.USER_MODEL_DATA.toString());
@ -121,7 +120,7 @@ public class UserHandler implements RedisPushSubHandler{
/**
* 用户权限数据处理
* @param msgJson
* @param msgJson 信息Json
*/
private void userPermsHandler(JSONObject msgJson){
JSONArray dataArray = msgJson.getJSONArray(MsgArgsType.USER_MODEL_DATA.toString());
@ -144,7 +143,7 @@ public class UserHandler implements RedisPushSubHandler{
/**
* 用户菜单数据处理
* @param msgJson
* @param msgJson 信息Json
*/
private void userMenusHandler(JSONObject msgJson){
JSONArray dataArray = msgJson.getJSONArray(MsgArgsType.USER_MODEL_DATA.toString());

@ -26,13 +26,11 @@ import org.opsli.core.cache.pushsub.receiver.RedisPushSubReceiver;
import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.msgs
* @Author: Parker
* @CreateTime: 2020-09-15 16:50
* @Description: 热数据消息
* 热数据消息
*
* @author Parker
* @date 2020-09-15
*/
@Data
@Accessors(chain = true)
public final class CacheDataMsgFactory extends BaseSubMessage{
@ -43,9 +41,14 @@ public final class CacheDataMsgFactory extends BaseSubMessage{
private CacheDataMsgFactory(){}
/**
* 构建消息
* 构建消息 热数据
* @param cacheDataEntity 热数据对象
* @param value 值
* @param cacheHandleType 类型
* @return 消息
*/
public static BaseSubMessage createMsg(CacheDataEntity cacheDataEntity, Object value, CacheHandleType cacheHandleType){
public static BaseSubMessage createMsg(CacheDataEntity cacheDataEntity, Object value,
CacheHandleType cacheHandleType){
BaseSubMessage baseSubMessage = new BaseSubMessage();
// 数据
JSONObject jsonObj = new JSONObject();

@ -29,13 +29,11 @@ import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
import java.util.List;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.msgs
* @Author: Parker
* @CreateTime: 2020-09-15 16:50
* @Description: 字典消息
* 字典消息
*
* @author Parker
* @date 2020-09-15
*/
@Data
@Accessors(chain = true)
public final class DictMsgFactory extends BaseSubMessage{
@ -46,7 +44,10 @@ public final class DictMsgFactory extends BaseSubMessage{
private DictMsgFactory(){}
/**
* 构建消息
* 构建消息 字典
* @param dictWrapperModel 字典模型
* @param cacheHandleType 缓存类型
* @return 消息
*/
public static BaseSubMessage createMsg(DictWrapper dictWrapperModel, CacheHandleType cacheHandleType){
BaseSubMessage baseSubMessage = new BaseSubMessage();
@ -62,7 +63,10 @@ public final class DictMsgFactory extends BaseSubMessage{
}
/**
* 构建消息
* 构建消息 字典
* @param dictWrapperModels 字典模型集合
* @param cacheHandleType 缓存类型
* @return 消息
*/
public static BaseSubMessage createMsg(List<DictWrapper> dictWrapperModels, CacheHandleType cacheHandleType){
BaseSubMessage baseSubMessage = new BaseSubMessage();

@ -26,13 +26,11 @@ import org.opsli.core.cache.pushsub.receiver.RedisPushSubReceiver;
import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.msgs
* @Author: Parker
* @CreateTime: 2020-09-15 16:50
* @Description: 参数消息
* 参数消息
*
* @author Parker
* @date 2020-09-15
*/
@Data
@Accessors(chain = true)
public final class OptionMsgFactory extends BaseSubMessage{
@ -44,6 +42,8 @@ public final class OptionMsgFactory extends BaseSubMessage{
/**
* 构建消息 - 参数
* @param optionsModel 参数模型
* @return 消息
*/
public static BaseSubMessage createOptionMsg(OptionsModel optionsModel){
BaseSubMessage baseSubMessage = new BaseSubMessage();

@ -26,13 +26,11 @@ import org.opsli.core.cache.pushsub.receiver.RedisPushSubReceiver;
import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.msgs
* @Author: Parker
* @CreateTime: 2020-09-15 16:50
* @Description: 用户组织消息
* 用户组织消息
*
* @author Parker
* @date 2020-09-15
*/
@Data
@Accessors(chain = true)
public final class OrgMsgFactory extends BaseSubMessage{
@ -43,7 +41,9 @@ public final class OrgMsgFactory extends BaseSubMessage{
private OrgMsgFactory(){}
/**
* 构建消息 - 组织
* 构建消息 - 用户组织
* @param orgRefModel 用户组织模型
* @return 消息
*/
public static BaseSubMessage createOrgMsg(UserOrgRefModel orgRefModel){
BaseSubMessage baseSubMessage = new BaseSubMessage();

@ -26,13 +26,11 @@ import org.opsli.core.cache.pushsub.receiver.RedisPushSubReceiver;
import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.msgs
* @Author: Parker
* @CreateTime: 2020-09-15 16:50
* @Description: 租户消息
* 租户消息
*
* @author Parker
* @date 2020-09-15
*/
@Data
@Accessors(chain = true)
public final class TenantMsgFactory extends BaseSubMessage{
@ -43,7 +41,9 @@ public final class TenantMsgFactory extends BaseSubMessage{
private TenantMsgFactory(){}
/**
* 构建消息 - 组织
* 构建消息 - 租户
* @param tenantModel 租户模型
* @return 消息
*/
public static BaseSubMessage createTenantMsg(TenantModel tenantModel){
BaseSubMessage baseSubMessage = new BaseSubMessage();

@ -29,13 +29,11 @@ import org.opsli.plugins.redis.pushsub.entity.BaseSubMessage;
import java.util.List;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.cache.pushsub.msgs
* @Author: Parker
* @CreateTime: 2020-09-15 16:50
* @Description: 用户消息
* 用户消息
*
* @author Parker
* @date 2020-09-15
*/
@Data
@Accessors(chain = true)
public final class UserMsgFactory extends BaseSubMessage{
@ -47,6 +45,8 @@ public final class UserMsgFactory extends BaseSubMessage{
/**
* 构建消息 - 用户
* @param userModel 用户模型
* @return 消息
*/
public static BaseSubMessage createUserMsg(UserModel userModel){
BaseSubMessage baseSubMessage = new BaseSubMessage();
@ -64,6 +64,9 @@ public final class UserMsgFactory extends BaseSubMessage{
/**
* 构建消息 - 用户角色
* @param userId 用户ID
* @param roles 角色集合
* @return 消息
*/
public static BaseSubMessage createUserRolesMsg(String userId, List<String> roles){
BaseSubMessage baseSubMessage = new BaseSubMessage();
@ -80,6 +83,9 @@ public final class UserMsgFactory extends BaseSubMessage{
/**
* 构建消息 - 用户权限
* @param userId 用户ID
* @param perms 权限集合
* @return 消息
*/
public static BaseSubMessage createUserPermsMsg(String userId, List<String> perms){
BaseSubMessage baseSubMessage = new BaseSubMessage();
@ -96,6 +102,9 @@ public final class UserMsgFactory extends BaseSubMessage{
/**
* 构建消息 - 用户菜单
* @param userId 用户ID
* @param menus 菜单集合
* @return 消息
*/
public static BaseSubMessage createUserMenusMsg(String userId, List<MenuModel> menus){
BaseSubMessage baseSubMessage = new BaseSubMessage();

@ -37,14 +37,11 @@ import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.plugins.redis.entity
* @Author: Parker
* @CreateTime: 2020-09-15 14:50
* @Description: Redis 消息订阅 更新本地缓存
*
* Redis 消息订阅 更新本地缓存
* 字典缓存更新
*
* @author Parker
* @date 2020-09-15
*/
@Slf4j
@Configuration

@ -70,9 +70,9 @@ public class CacheDataAop {
/**
* 切如 更新数据
* @param point
* @return
* @throws Throwable
* @param point point
* @return Object
* @throws Throwable 异常
*/
@Around("hotDataPut()")
public Object hotDataPutProcess(ProceedingJoinPoint point) throws Throwable {
@ -110,9 +110,9 @@ public class CacheDataAop {
/**
* 切如 删除数据 和 逻辑删除上
* @param point
* @return
* @throws Throwable
* @param point point
* @return Object
* @throws Throwable 异常
*/
@Around("hotDataDel()")
public Object hotDataDelProcess(ProceedingJoinPoint point) throws Throwable {
@ -162,7 +162,7 @@ public class CacheDataAop {
/***
* PUT 处理数据
* @param point
* @param point point
*/
private List<CacheDataEntity> putHandlerData(ProceedingJoinPoint point, Object returnValue){
// 这里 只对 继承了 ApiWrapper 的类做处理
@ -202,7 +202,7 @@ public class CacheDataAop {
/***
* DEL 处理数据
* @param point
* @param point point
*/
private List<CacheDataEntity> delHandlerData(ProceedingJoinPoint point, Object[] args){
if(args == null || args.length == 0){
@ -268,8 +268,8 @@ public class CacheDataAop {
/**
* 获得方法
* @param point
* @return
* @param point point
* @return Method 方法
*/
private Method getMethod(ProceedingJoinPoint point){
Method m = null;
@ -284,8 +284,8 @@ public class CacheDataAop {
/**
* 存放数据
* @param cacheDataList
* @param cacheData
* @param cacheDataList 缓存数据集合
* @param cacheData 缓存数据
*/
private void putCacheData(List<CacheDataEntity> cacheDataList, CacheDataEntity cacheData){
// 非法判断

@ -59,7 +59,7 @@ public class LimiterAop {
/**
* 限流
* @param point
* @param point point
*/
@Before("requestMapping()")
public void limiterHandle(JoinPoint point){

@ -54,7 +54,7 @@ public class SearchHisAop {
/**
* 限流
* @param point
* @param point point
*/
@Before("requestMapping()")
public void limiterHandle(JoinPoint point){

@ -56,7 +56,7 @@ public class TokenAop {
/**
* 切如 post 请求
* @param point
* @param point point
*/
@Around("requestMapping()")
public Object tokenAop(ProceedingJoinPoint point) throws Throwable {

@ -54,7 +54,7 @@ public class ValitaionArgsAop {
/**
* 切如 post 请求
* @param point
* @param point point
*/
@Before("requestMapping()")
public void validation(JoinPoint point) throws Throwable {

@ -71,7 +71,7 @@ public class MybatisAutoFillInterceptor implements Interceptor {
/**
* 注入字段
* @param invocation
* @param invocation 源
*/
private void fillField(Invocation invocation) {
Object[] args = invocation.getArgs();
@ -103,7 +103,7 @@ public class MybatisAutoFillInterceptor implements Interceptor {
/**
* 新增数据
* @param arg
* @param arg 参数
*/
public void insertFill(Object arg) {
if(arg == null ){
@ -189,7 +189,7 @@ public class MybatisAutoFillInterceptor implements Interceptor {
/**
* 修改数据
* @param arg
* @param arg 参数
*/
public void updateFill(Object arg) {
if(arg == null ){
@ -204,7 +204,7 @@ public class MybatisAutoFillInterceptor implements Interceptor {
if (arg instanceof MapperMethod.ParamMap) {
MapperMethod.ParamMap<?> paramMap = (MapperMethod.ParamMap<?>) arg;
if (paramMap.containsKey(ET)) {
arg = paramMap.get("et");
arg = paramMap.get(ET);
} else {
arg = paramMap.get("param1");
}

@ -31,9 +31,10 @@ import java.util.Date;
import java.util.concurrent.TimeUnit;
/**
* @Author: 周鹏程
* @CreateTime: 2020-11-04 17:34
* @Description: 打印启动日志
* 打印启动日志
*
* @author parker
* @date 2020-09-16
*/
@Slf4j
@Component

@ -36,6 +36,8 @@ import java.sql.SQLIntegrityConstraintViolationException;
import static org.opsli.common.constants.OrderConstants.EXCEPTION_HANDLER_ORDER;
/**
* 遗产拦截器
*
* @author parker
* @date 2020-09-13
*/

@ -18,11 +18,10 @@ package org.opsli.core.msg;
import org.opsli.common.base.msg.BaseMsg;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.msg
* @Author: Parker
* @CreateTime: 2020-09-13 19:36
* @Description: 核心类 - 消息
* 核心类 - 消息
*
* @author Parker
* @date 2020-09-13 19:36
*/
public enum CoreMsg implements BaseMsg {

@ -18,11 +18,10 @@ package org.opsli.core.msg;
import org.opsli.common.base.msg.BaseMsg;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.msg
* @Author: Parker
* @CreateTime: 2020-09-13 19:36
* @Description: 核心类 - 消息
* JWT类 - 消息
*
* @author Parker
* @date 2020-09-13 19:36
*/
public enum JwtMsg implements BaseMsg {

@ -18,11 +18,10 @@ package org.opsli.core.msg;
import org.opsli.common.base.msg.BaseMsg;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.msg
* @Author: Parker
* @CreateTime: 2020-09-13 19:36
* @Description: Token - 消息
* Token - 消息
*
* @author Parker
* @date 2020-09-13 19:36
*/
public enum TokenMsg implements BaseMsg {

@ -18,11 +18,10 @@ package org.opsli.core.msg;
import org.opsli.common.base.msg.BaseMsg;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.msg
* @Author: Parker
* @CreateTime: 2020-09-13 19:36
* @Description: 参数验证 - 消息
* 参数验证 - 消息
*
* @author Parker
* @date 2020-09-13 19:36
*/
public enum ValidationMsg implements BaseMsg {

@ -29,9 +29,10 @@ import java.util.List;
/**
* 分页类
*
* @author parker
* @param <T>
* @param <E>
* @author Parker
* @date 2020-09-21 23:57
*/
@Slf4j
public class Page<T extends BaseEntity,E extends ApiWrapper> extends PageSerializable<E>{
@ -93,7 +94,7 @@ public class Page<T extends BaseEntity,E extends ApiWrapper> extends PageSeriali
/**
* 设置数据
* @param pageInfo
* @param pageInfo 分页信息
*/
public void instance(PageInfo<T> pageInfo, List<E> list) {
super.setList(list);

@ -19,11 +19,10 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.opsli.core.base.entity.BaseEntity;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.persistence.querybuilder
* @Author: Parker
* @CreateTime: 2020-09-21 23:57
* @Description: Web 条件构造器
* Web 条件构造器
*
* @author Parker
* @date 2020-09-21 23:57
*/
public class GenQueryBuilder<T extends BaseEntity> implements QueryBuilder<T> {

@ -20,17 +20,16 @@ import org.opsli.core.base.entity.BaseEntity;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.persistence.querybuilder
* @Author: Parker
* @CreateTime: 2020-09-21 23:53
* @Description: 查询构造器
* 查询构造器
*
* @author Parker
* @date 2020-09-21 23:57
*/
public interface QueryBuilder<T extends BaseEntity> {
/**
* 构造器
* @return
* @return QueryWrapper
*/
QueryWrapper<T> build();

@ -26,11 +26,10 @@ import org.opsli.core.persistence.querybuilder.conf.WebQueryConf;
import java.util.Map;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.persistence.querybuilder
* @Author: Parker
* @CreateTime: 2020-09-21 23:57
* @Description: Web 条件构造器
* Web 条件构造器
*
* @author Parker
* @date 2020-09-21 23:57
*/
public class WebQueryBuilder<T extends BaseEntity> implements QueryBuilder<T>{
@ -189,7 +188,6 @@ public class WebQueryBuilder<T extends BaseEntity> implements QueryBuilder<T>{
* @param handle 操作
* @param key 键
* @param value 值
* @return
*/
private <T extends BaseEntity> void handlerValue(QueryWrapper<T> queryWrapper, String handle, String key, String value){
if(queryWrapper == null || StringUtils.isEmpty(handle)

@ -19,18 +19,19 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.opsli.core.base.entity.BaseEntity;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.persistence.querybuilder.chain
* @Author: Parker
* @CreateTime: 2020-09-22 10:35
* @Description: 查询构建器责任链
* 查询构建器责任链
*
* @author Parker
* @date 2020-09-13 19:36
*/
public interface QueryBuilderChain {
/**
* 执行
* @param wrapper
* @param <T>
* @param entityClazz entity class
* @param wrapper 包装类
* @param <T> 泛型
* @return <T>
*/
<T extends BaseEntity> QueryWrapper<T> handler(Class<T> entityClazz, QueryWrapper<T> wrapper);

@ -25,11 +25,10 @@ import org.opsli.core.base.entity.BaseEntity;
import org.opsli.core.utils.UserUtil;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.tenant
* @Author: Parker
* @CreateTime: 2020-09-22 00:50
* @Description: 多租户赋值处理
* 多租户赋值处理
*
* @author Parker
* @date 2020-09-13 19:36
*/
public class TenantHandler implements QueryBuilderChain{
@ -49,13 +48,6 @@ public class TenantHandler implements QueryBuilderChain{
this.queryBuilderChain = queryBuilderChain;
}
/**
* 查询构建器处理
* @param entityClazz
* @param wrapper
* @param <T>
* @return
*/
@Override
public <T extends BaseEntity> QueryWrapper<T> handler(Class<T> entityClazz, QueryWrapper<T> wrapper) {
// 自身责任 -- 判断多租户

@ -10,16 +10,18 @@ import java.util.Collection;
/**
* 自定义身份验证器,根据登录使用的Token匹配调用对应的Realm
*
* @author Parker
* @date 2020-09-16
*/
public class CustomModularRealmAuthenticator extends ModularRealmAuthenticator {
/**
* 自定义Realm的分配策略
* 通过realm.supports()方法匹配对应的Realm,因此才要在Realm中重写supports()方法
* @param realms
* @param token
* @return
* @param realms realm 集合
* @param token token
* @return AuthenticationInfo
*/
@Override
protected AuthenticationInfo doMultiRealmAuthentication(Collection<Realm> realms, AuthenticationToken token) {

@ -1,9 +1,10 @@
package org.opsli.core.security.shiro.realm;
/**
* @Author: Parker
* @CreateTime: 2020-12-29 20:10
* @Description: Realm 识别类 勿删
* Realm 识别类 勿删
*
* @author Parker
* @date 2020-09-16
*/
public interface FlagRealm {
}

@ -25,9 +25,8 @@ import java.util.List;
/**
* 认证
*
* @author 孙志强
* @date 2017-05-20 14:00
* @author Parker
* @date 2020-09-16
*/
@Component
@Slf4j

@ -16,8 +16,7 @@ import org.springframework.stereotype.Component;
* 手机登录 认证
*
* @author Parker
* @date 2020-12-29 14:00
* @date 2020-09-16
*/
@Component
@Slf4j

@ -7,7 +7,6 @@ import org.apache.shiro.authc.AuthenticationToken;
* 第三方对外接口 token
*
* @author Parker
* @date 2017-05-20 13:22
*/
public class ExternalToken implements AuthenticationToken {

@ -7,7 +7,6 @@ import org.apache.shiro.authc.AuthenticationToken;
* OAuth2 token
*
* @author Parker
* @date 2017-05-20 13:22
*/
public class JwtToken implements AuthenticationToken {

@ -9,11 +9,10 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
* @BelongsProject: tank-design
* @BelongsPackage: com.parker.tank.net.thread
* @Author: Parker
* @CreateTime: 2020-08-21 14:22
* @Description: 日志保存线程
* 日志保存线程
*
* @author Parker
* @date 2020-09-16
*/
@Slf4j
@Component

@ -42,7 +42,7 @@ import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
* 验证码
*
* @author parker
* @since 2.0.0 2018-02-10
* @date 2021年5月19日12:47:20
*/
@Component
@Order(UTIL_ORDER)

@ -40,11 +40,10 @@ import java.util.Map;
import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.utils
* @Author: Parker
* @CreateTime: 2020-09-22 11:17
* @Description: 字典工具类
* 字典工具类
*
* @author parker
* @date 2020-09-22 11:17
*/
@Slf4j
@Order(UTIL_ORDER)

@ -27,11 +27,10 @@ import org.springframework.stereotype.Component;
import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.utils
* @Author: Parker
* @CreateTime: 2020-09-19 20:03
* @Description: 分布式锁工具类
* 分布式锁工具类
*
* @author parker
* @date 2020-09-22 11:17
*/
@Slf4j
@Order(UTIL_ORDER)

@ -43,11 +43,10 @@ import java.util.List;
import java.util.Map;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.utils
* @Author: Parker
* @CreateTime: 2020-09-23 21:53
* @Description: ExcelUtil
* Excel 工具类
*
* @author parker
* @date 2020-09-22 11:17
*/
@Slf4j
public final class ExcelUtil {

@ -26,11 +26,10 @@ import org.springframework.stereotype.Component;
import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.utils
* @Author: Parker
* @CreateTime: 2020-09-19 20:03
* @Description: 系统配置参数 工具类
* 系统配置参数 工具类
*
* @author parker
* @date 2020-09-22 11:17
*/
@Slf4j
@Order(UTIL_ORDER)

@ -27,7 +27,8 @@ import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
/**
* JWT工具类
* @author sunzhiqiang23
*
* @author 孙志强
* @date 2020/05/29 21:23
*/
@Slf4j

@ -40,18 +40,17 @@ import java.lang.reflect.Method;
import java.util.List;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.utils
* @Author: Parker
* @CreateTime: 2020-09-19 20:03
* @Description: 日志工具类
* 日志工具类
*
* @author Parker
* @date 2020-09-22 11:17
*/
@Slf4j
public final class LogUtil {
/**
* 保存日志
* @param point
* @param point point
* @param e 异常
* @param timerCount 花费毫秒数
*/
@ -128,9 +127,9 @@ public final class LogUtil {
/**
* 设置日志标题
* @param point
* @param method
* @param logsModel
* @param point point
* @param method 方法
* @param logsModel 日志模型
*/
private static void setTitle(ProceedingJoinPoint point, Method method, LogsModel logsModel, UserModel user){
// 设置 title
@ -192,9 +191,9 @@ public final class LogUtil {
/**
* 递归 获得菜单全名
* @param menuList
* @param permsModel
* @return
* @param menuList 菜单集合
* @param permsModel 权限模型
* @return List
*/
private static List<MenuModel> getParentMenu(List<MenuModel> menuList, MenuModel permsModel){
List<MenuModel> menuModels = Lists.newArrayList();

@ -30,11 +30,10 @@ import org.springframework.stereotype.Component;
import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.utils
* @Author: Parker
* @CreateTime: 2020-09-19 20:03
* @Description: 菜单工具类
* 菜单工具类
*
* @author Parker
* @date 2020-09-22 11:17
*/
@Slf4j
@Order(UTIL_ORDER)

@ -42,13 +42,11 @@ import java.util.Map;
import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.utils
* @Author: Parker
* @CreateTime: 2020-09-19 20:03
* @Description: 参数工具类
*
* 参数工具类
* Hash 永久缓存
*
* @author Parker
* @date 2020-09-22 11:17
*/
@Slf4j
@Order(UTIL_ORDER)

@ -30,11 +30,10 @@ import org.springframework.stereotype.Component;
import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.utils
* @Author: Parker
* @CreateTime: 2020-09-19 20:03
* @Description: 组织机构工具类
* 组织机构工具类
*
* @author Parker
* @date 2020-09-19 20:03
*/
@Slf4j
@Order(UTIL_ORDER)

@ -35,9 +35,10 @@ import java.util.Set;
import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
/**
* @Author: 周鹏程
* @CreateTime: 2020-09-22 11:17
* @Description: 搜索历史工具类
* 搜索历史工具类
*
* @author Parker
* @date 2020-09-19 20:03
*/
@Slf4j
@Order(UTIL_ORDER)

@ -13,8 +13,8 @@ import org.springframework.stereotype.Component;
/**
* 以静态变量保存Spring ApplicationContext, 可在任何代码任何地方任何时候取出ApplicationContext.
*
* 针对项目 启动后好使, 项目启动前 Bean注册时不好使
*
* @author Zaric
* @date 2016-5-29 下午1:25:40
*/

@ -30,11 +30,10 @@ import org.springframework.stereotype.Component;
import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.utils
* @Author: Parker
* @CreateTime: 2020-09-19 20:03
* @Description: 租户工具类
* 租户工具类
*
* @author Parker
* @date 2020-09-19 23:21
*/
@Slf4j
@Order(UTIL_ORDER)

@ -26,7 +26,6 @@ import java.util.UUID;
* 生成token
*
* @author Parker
* @date 2017-05-20 14:41
*/
public final class TokenGenerator {

@ -33,7 +33,6 @@ import java.util.Map;
* 注:排序只支持 int 类型
*
* @author Parker
* @date 2017-05-20 14:41
*/
public enum TreeBuildUtil {
@ -135,9 +134,9 @@ public enum TreeBuildUtil {
/**
* 欺骗编译器 强制转换
* @param obj
* @param <T>
* @return
* @param obj 对象
* @param <T> 泛型
* @return T
*/
private <T> Comparable<T> cast(T obj){
return (Comparable<T>) Convert.toInt(obj);

@ -52,9 +52,9 @@ import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
/**
* User Token Util
*
* @author parker
* @author Parker
* @date 2017-05-20 14:41
*/
@Slf4j
@Order(UTIL_ORDER)
@Component

@ -41,11 +41,10 @@ import java.util.List;
import static org.opsli.common.constants.OrderConstants.UTIL_ORDER;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.core.utils
* @Author: Parker
* @CreateTime: 2020-09-19 20:03
* @Description: 用户工具类
* 用户工具类
*
* @author Parker
* @date 2020-09-19 20:03
*/
@Slf4j
@Order(UTIL_ORDER)

@ -33,11 +33,10 @@ import java.lang.reflect.Field;
import java.nio.charset.StandardCharsets;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.common.utils
* @Author: Parker
* @CreateTime: 2020-09-22 17:29
* @Description: 验证器工具类
* 验证器工具类
*
* @author Parker
* @date 2020-09-19 20:03
*/
@Slf4j
public final class ValidationUtil {

@ -20,10 +20,11 @@ import cn.hutool.json.JSONObject;
import org.opsli.api.base.warpper.ApiWrapper;
/**
* Created Date by 2020/1/11 0011.
*
* 抽象 实体助手
*
* @author Parker
* @date 2020-09-16
*/
public abstract class AbstractModelHelper {
@ -32,7 +33,6 @@ public abstract class AbstractModelHelper {
*
* @param dictJson 字典Json
* @param wrapper 导入 wrapper
* @return Object
*/
abstract public void transformByImport(JSONObject dictJson, ApiWrapper wrapper);
@ -41,7 +41,6 @@ public abstract class AbstractModelHelper {
*
* @param dictJson 字典Json
* @param wrapper 导出 wrapper
* @return Object
*/
abstract public void transformByExport(JSONObject dictJson, ApiWrapper wrapper);

@ -35,11 +35,10 @@ import java.util.Iterator;
import java.util.Map;
/**
* Created Date by 2020/1/11 0011.
*
* 助手类工厂
*
* @author Parker
* @date 2020-09-16
*/
@Slf4j
public final class ModelFactoryHelper {
@ -56,8 +55,8 @@ public final class ModelFactoryHelper {
/**
* 获得 Model 帮助类
* @param modelClazz
* @return
* @param modelClazz 模型 class
* @return AbstractModelHelper
*/
public static AbstractModelHelper getModelHelper(Class<?> modelClazz) throws Exception{
// 这里需要全新设计,

@ -19,6 +19,7 @@ package org.opsli.plugins.email.enums;
* Email 参数类型
*
* @author Parker
* @date 2020-09-19 20:03
*/
public enum EmailType {

@ -20,11 +20,10 @@ import java.util.Collection;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.modulars.system.service
* @Author: Parker
* @CreateTime: 2020-09-17 13:07
* @Description: 租户 接口
* 邮件接口
*
* @author Parker
* @date 2020-09-19 20:03
*/
public interface IEmailService {

@ -16,11 +16,10 @@ import java.util.Collection;
import java.util.Collections;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.plugins.email.service
* @Author: Parker
* @CreateTime: 2020-09-16 17:34
* @Description: 邮件 接口实现类
* 邮件 接口实现类
*
* @author Parker
* @date 2020-09-19 20:03
*/
@Service
public class EmailServiceImpl implements IEmailService {

@ -8,11 +8,10 @@ import org.opsli.common.annotation.validation.ValidationArgsLenMax;
import org.opsli.common.enums.ValiArgsType;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.modulars.test.entity
* @Author: Parker
* @CreateTime: 2020-09-16 17:33
* @Description: 邮件服务
* 邮件服务
*
* @author Parker
* @date 2020-09-19 20:03
*/
@Data
@EqualsAndHashCode(callSuper = false)

@ -19,9 +19,10 @@ package org.opsli.plugins.oss;
import org.opsli.common.base.msg.BaseMsg;
/**
* @Author: 周鹏程
* @CreateTime: 2020-11-04 17:34
* @Description: OSS服务异常 - 消息
* OSS服务异常 - 消息
*
* @author Parker
* @date 2020-09-19 20:03
*/
public enum OssMsg implements BaseMsg {

@ -33,7 +33,6 @@ import java.util.Set;
*
* @author Parker
* @date 2021年3月16日10:16:29
*
*/
@Slf4j
public enum OssStorageFactory {

@ -19,6 +19,7 @@ package org.opsli.plugins.oss.enums;
* 存储服务类型
*
* @author Parker
* @date 2020-09-19 20:03
*/
public enum OssStorageType {

@ -29,6 +29,7 @@ import java.io.Serializable;
* 本地存储配置工程
*
* @author Parker
* @date 2020-09-19 20:03
*/
public enum LocalConfigFactory implements ConfigFactory<LocalConfigFactory.LocalConfig> {

@ -36,7 +36,6 @@ import org.apache.commons.lang3.StringUtils;
import java.util.Map;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;
/**
* 非对称加密

@ -3,11 +3,10 @@ package org.opsli.plugins.redis.pushsub.receiver;
/**
* @BelongsProject: opsli-boot
* @BelongsPackage: org.opsli.plugins.redis.receiver
* @Author: Parker
* @CreateTime: 2020-09-15 14:49
* @Description: Redis 消息订阅实现基类
* Redis 消息订阅实现基类
*
* @author Parker
* @date 2020-09-15
*/
public abstract class BaseReceiver {
@ -20,7 +19,7 @@ public abstract class BaseReceiver {
/**
* 获得监听信道
* @return
* @return String
*/
public String getListenerChannel(){
return this.channel;
@ -28,7 +27,7 @@ public abstract class BaseReceiver {
/**
* 获得消息
* @param msg
* @param msg 消息
*/
public abstract void receiveMessage(String msg);

Loading…
Cancel
Save