移动 类

Author: 胡贵

lts-admin/src/main/java/com/lts/job/web/cluster/RegistryService.java

@@ -6,9 +6,9 @@
 import com.lts.job.core.registry.NotifyListener;
 import com.lts.job.core.registry.Registry;
 import com.lts.job.core.registry.RegistryFactory;
-import com.lts.job.core.util.CollectionUtils;
-import com.lts.job.core.util.ConcurrentHashSet;
-import com.lts.job.core.util.StringUtils;
+import com.lts.job.core.commons.utils.CollectionUtils;
+import com.lts.job.core.commons.collect.ConcurrentHashSet;
+import com.lts.job.core.commons.utils.StringUtils;
 import com.lts.job.web.request.NodeRequest;
 import com.lts.job.web.support.AppConfigurer;
 import com.lts.job.web.support.memorydb.NodeMemoryDB;

lts-admin/src/main/java/com/lts/job/web/controller/api/JobQueueApiController.java

@@ -2,22 +2,17 @@
 
 import com.lts.job.core.domain.JobQueueRequest;
 import com.lts.job.core.domain.PageResponse;
-import com.lts.job.core.exception.CronException;
 import com.lts.job.core.support.CronExpression;
-import com.lts.job.core.util.CollectionUtils;
-import com.lts.job.core.util.StringUtils;
+import com.lts.job.core.commons.utils.CollectionUtils;
+import com.lts.job.core.commons.utils.StringUtils;
 import com.lts.job.queue.domain.JobPo;
 import com.lts.job.web.cluster.AdminApplication;
 import com.lts.job.web.controller.AbstractController;
 import com.lts.job.web.vo.RestfulResponse;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
-import java.util.List;
-import java.util.Map;
-
 /**
  * @author Robert HG (254963746@qq.com) on 6/6/15.
  */

lts-admin/src/main/java/com/lts/job/web/controller/api/NodeApiController.java

@@ -1,8 +1,8 @@
 package com.lts.job.web.controller.api;
 
 import com.lts.job.core.cluster.Node;
-import com.lts.job.core.util.CollectionUtils;
-import com.lts.job.core.util.StringUtils;
+import com.lts.job.core.commons.utils.CollectionUtils;
+import com.lts.job.core.commons.utils.StringUtils;
 import com.lts.job.web.cluster.RegistryService;
 import com.lts.job.web.controller.AbstractController;
 import com.lts.job.web.request.NodeRequest;

lts-admin/src/main/java/com/lts/job/web/support/AdminAppFactoryBean.java

@@ -4,7 +4,7 @@
 import com.lts.job.core.cluster.Node;
 import com.lts.job.core.cluster.NodeType;
 import com.lts.job.core.extension.ExtensionLoader;
-import com.lts.job.core.util.StringUtils;
+import com.lts.job.core.commons.utils.StringUtils;
 import com.lts.job.queue.*;
 import com.lts.job.web.cluster.AdminApplication;
 import org.springframework.beans.factory.FactoryBean;

lts-admin/src/main/java/com/lts/job/web/support/DateEditor.java

@@ -1,6 +1,6 @@
 package com.lts.job.web.support;
 
-import com.lts.job.core.util.DateUtils;
+import com.lts.job.core.commons.utils.DateUtils;
 import org.springframework.util.StringUtils;
 
 import java.beans.PropertyEditorSupport;

lts-admin/src/main/java/com/lts/job/web/support/ExceptionHandlerResolver.java

@@ -1,6 +1,6 @@
 package com.lts.job.web.support;
 
-import com.lts.job.core.util.JSONUtils;
+import com.lts.job.core.commons.utils.JSONUtils;
 import com.lts.job.web.vo.RestfulResponse;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

lts-admin/src/main/java/com/lts/job/web/support/MapEditor.java

@@ -1,7 +1,7 @@
 package com.lts.job.web.support;
 
 import com.alibaba.fastjson.TypeReference;
-import com.lts.job.core.util.JSONUtils;
+import com.lts.job.core.commons.utils.JSONUtils;
 import org.springframework.util.StringUtils;
 
 import java.beans.PropertyEditorSupport;

lts-admin/src/main/java/com/lts/job/web/support/memorydb/NodeMemoryDB.java

@@ -4,7 +4,7 @@
 import com.lts.job.core.cluster.NodeType;
 import com.lts.job.core.logger.Logger;
 import com.lts.job.core.logger.LoggerFactory;
-import com.lts.job.core.util.CollectionUtils;
+import com.lts.job.core.commons.utils.CollectionUtils;
 import com.lts.job.store.jdbc.SqlBuilder;
 import com.lts.job.web.request.NodeRequest;
 import org.apache.commons.dbutils.ResultSetHandler;

lts-core/src/main/java/com/lts/job/core/cluster/AbstractClientNode.java

@@ -5,7 +5,7 @@
 import com.lts.job.core.factory.NamedThreadFactory;
 import com.lts.job.core.remoting.HeartBeatMonitor;
 import com.lts.job.core.remoting.RemotingClientDelegate;
-import com.lts.job.core.util.StringUtils;
+import com.lts.job.core.commons.utils.StringUtils;
 import com.lts.job.remoting.netty.NettyClientConfig;
 import com.lts.job.remoting.netty.NettyRemotingClient;
 import com.lts.job.remoting.netty.NettyRequestProcessor;

lts-core/src/main/java/com/lts/job/core/cluster/AbstractJobNode.java

@@ -12,8 +12,8 @@
 import com.lts.job.core.logger.LoggerFactory;
 import com.lts.job.core.protocol.command.CommandBodyWrapper;
 import com.lts.job.core.registry.*;
-import com.lts.job.core.util.CollectionUtils;
-import com.lts.job.core.util.GenericsUtils;
+import com.lts.job.core.commons.utils.CollectionUtils;
+import com.lts.job.core.commons.utils.GenericsUtils;
 import com.lts.job.ec.EventCenterFactory;
 
 import java.util.ArrayList;