diff --git a/src/META-INF/persistence.xml b/src/META-INF/persistence.xml
index 2ad4aeca..200e82f9 100644
--- a/src/META-INF/persistence.xml
+++ b/src/META-INF/persistence.xml
@@ -1,5 +1,5 @@
-
-
-
-
-
+
+
+
+
+
diff --git a/src/com/base/BaseController.java b/src/com/base/BaseController.java
index 64c66474..8a98dcfd 100644
--- a/src/com/base/BaseController.java
+++ b/src/com/base/BaseController.java
@@ -1,65 +1,65 @@
-
-/**
- * 文件名 : BaseController.java
- * 版权 : XX科技有限公司。
- * 描述 : <描述>
- * 修改时间:2016年9月7日
- * 修改内容:<修改内容>
- */
-package com.base;
-
-import java.util.HashMap;
-import java.util.Map;
-
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-
-import org.apache.log4j.Logger;
-import org.springframework.web.bind.annotation.ExceptionHandler;
-
-import com.platform.utils.Configs;
-
-/**
- * <一句话功能简述>
- * <功能详细描述>
- * @author chen
- * @version [版本号,2016年9月7日]
- * @see [相关类/方法]
- * @since [产品/模块版本]
- */
-public class BaseController {
-
- /** log4j */
- public static Logger log = Logger.getRootLogger();
-
- /**
- * <一句话功能简述> 基于@ExceptionHandler异常处理----全局异常处理
- * <功能详细描述>
- * @param request
- * @param ex 异常
- * @return
- * @see [类、类#方法、类#成员]
- */
- @ExceptionHandler
- public Object exp(HttpServletRequest request, HttpServletResponse response,Exception ex) {
- System.out.println("URI"+request.getRequestURI());
- request.setAttribute("ex", ex);
- System.err.println("BaseController --exp ");
- // 根据不同错误转向不同页面
- if(ex instanceof CustomException) {
- CustomException cuse = (CustomException) ex;
- Map errmsg = new HashMap<>();
- errmsg.put("code", cuse.getCode());
- errmsg.put("msg", cuse.getMsg());
- log.error(cuse.getCode());
- response.setStatus(500);
- return response;
- } else {
- //其他错误则 调到指定页面
- log.error(Configs.GLOBAL_EXP_NOT_CUSTOM, ex);
- response.setStatus(500);
- return response;
- }
- }
-
+
+/**
+ * 文件名 : BaseController.java
+ * 版权 : XX科技有限公司。
+ * 描述 : <描述>
+ * 修改时间:2016年9月7日
+ * 修改内容:<修改内容>
+ */
+package com.base;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import org.apache.log4j.Logger;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+
+import com.platform.utils.Configs;
+
+/**
+ * <一句话功能简述>
+ * <功能详细描述>
+ * @author chen
+ * @version [版本号,2016年9月7日]
+ * @see [相关类/方法]
+ * @since [产品/模块版本]
+ */
+public class BaseController {
+
+ /** log4j */
+ public static Logger log = Logger.getRootLogger();
+
+ /**
+ * <一句话功能简述> 基于@ExceptionHandler异常处理----全局异常处理
+ * <功能详细描述>
+ * @param request
+ * @param ex 异常
+ * @return
+ * @see [类、类#方法、类#成员]
+ */
+ @ExceptionHandler
+ public Object exp(HttpServletRequest request, HttpServletResponse response,Exception ex) {
+ System.out.println("URI"+request.getRequestURI());
+ request.setAttribute("ex", ex);
+ System.err.println("BaseController --exp ");
+ // 根据不同错误转向不同页面
+ if(ex instanceof CustomException) {
+ CustomException cuse = (CustomException) ex;
+ Map errmsg = new HashMap<>();
+ errmsg.put("code", cuse.getCode());
+ errmsg.put("msg", cuse.getMsg());
+ log.error(cuse.getCode());
+ response.setStatus(500);
+ return response;
+ } else {
+ //其他错误则 调到指定页面
+ log.error(Configs.GLOBAL_EXP_NOT_CUSTOM, ex);
+ response.setStatus(500);
+ return response;
+ }
+ }
+
}
\ No newline at end of file
diff --git a/src/com/base/Constant.java b/src/com/base/Constant.java
index 4d336465..3b1dcc59 100644
--- a/src/com/base/Constant.java
+++ b/src/com/base/Constant.java
@@ -1,23 +1,23 @@
-package com.base;
-
-/**
- * <一句话功能简述>
- * <功能详细描述>
- * @author chen
- * @version [版本号,2016年9月8日]
- * @see [相关类/方法]
- * @since [产品/模块版本]
- */
-public class Constant {
-
- /** 国际话配置文件文件-i18n.properties */
- public static String I18N_PROPERTIES_FIEL_PATH = "/com/base/i18n.properties";
-
- /** WritefileThread-线程睡眠时间--3000 */
- public final static long THREAD_SLEEP_WRITEFILETHREAD = 3000;
-
- /** CustomException记录报异常的对象的对象个数--10 */
- public final static int CustomException_log_object_size = 10;
-
-
-}
+package com.base;
+
+/**
+ * <一句话功能简述>
+ * <功能详细描述>
+ * @author chen
+ * @version [版本号,2016年9月8日]
+ * @see [相关类/方法]
+ * @since [产品/模块版本]
+ */
+public class Constant {
+
+ /** 国际话配置文件文件-i18n.properties */
+ public static String I18N_PROPERTIES_FIEL_PATH = "/com/base/i18n.properties";
+
+ /** WritefileThread-线程睡眠时间--3000 */
+ public final static long THREAD_SLEEP_WRITEFILETHREAD = 3000;
+
+ /** CustomException记录报异常的对象的对象个数--10 */
+ public final static int CustomException_log_object_size = 10;
+
+
+}
diff --git a/src/com/base/Custom4exception.java b/src/com/base/Custom4exception.java
index 0ca8b567..a5bc8540 100644
--- a/src/com/base/Custom4exception.java
+++ b/src/com/base/Custom4exception.java
@@ -1,29 +1,34 @@
-package com.base;
-
-/**
- * <一句话功能简述> 异常常量编码
- * <功能详细描述>
- * @author chen
- * @version [版本号,2016年9月8日]
- * @see [相关类/方法]
- * @since [产品/模块版本]
- */
-public class Custom4exception {
- //3003001001 : 第一位:标识异常, 第二到第四位:标识模块,第五道第七位:标识类别,第八道第十位标识具体异常
- /**eg
- * 3:异常
- * 003:虚拟机模块
- * 001:软件依赖虚拟机资源类别
- * 001:启动异常
- */
- /**
- * ThreadVolume类查询 volume异常
- */
- public final static String threadVolume_class_Except = "3001001001";
-
- /**
- * ThreadVolume类线程休眠异常
- */
- public final static String threadVolume_Thread_Except = "3001001002";
-
-}
+package com.base;
+
+/**
+ * <一句话功能简述> 异常常量编码
+ * <功能详细描述>
+ * @author chen
+ * @version [版本号,2016年9月8日]
+ * @see [相关类/方法]
+ * @since [产品/模块版本]
+ */
+public class Custom4exception {
+ //3003001001 : 第一位:标识异常, 第二到第四位:标识模块,第五道第七位:标识类别,第八道第十位标识具体异常
+ /**eg
+ * 3:异常
+ * 003:虚拟机模块
+ * 001:软件依赖虚拟机资源类别
+ * 001:启动异常
+ */
+ /**
+ * ThreadVolume类查询 volume异常
+ */
+ public final static String threadVolume_class_Except = "3001001001";
+
+ /**
+ * ThreadVolume类线程休眠异常
+ */
+ public final static String threadVolume_Thread_Except = "3001001002";
+
+ /**
+ * 抽取汇总
+ */
+ public final static String threadVolume_Oracle_Except = "3002001002";
+
+}
diff --git a/src/com/base/CustomException.java b/src/com/base/CustomException.java
index 9cf46a4a..08b75248 100644
--- a/src/com/base/CustomException.java
+++ b/src/com/base/CustomException.java
@@ -1,127 +1,127 @@
-
-
-package com.base;
-
-import org.apache.log4j.Logger;
-
-/**
- * <一句话功能简述>
- * <功能详细描述>
- * @author chen
- * @version [版本号,2016年9月8日]
- * @see [相关类/方法]
- * @since [产品/模块版本]
- */
-@SuppressWarnings("serial")
-public class CustomException extends Exception {
-
- /** log4j */
- public static Logger log = Logger.getRootLogger();
-
- /** 自定义异常信息-错误信息 */
- private String msg;
-
- /** 自定义异常信息-错误代码 */
- private String code;
-
- /** 操作对象 */
- private Object[] objArray;
-
- /** 异常 */
- private Throwable cause;
-
- public CustomException() {
- super();
- }
-
- /**
- * @功能 将异常记录进文件
- * @param code 异常编码
- * @param msg 自定义异常信息
- * @param e
- * @param obj
- */
- public CustomException(String code,Exception e,Object... obj) {
- super(code);
- StringBuffer sbuf= new StringBuffer();
- sbuf.append(msg);
- this.code = code;
- sbuf.append(code);
- sbuf.append("\r\n");
- msg = Resource.getProperties().get(code);
- // 记录自定义的 异常
- if (null != msg) {
- sbuf.append(msg);
- sbuf.append("\r\n");
- }
- // 记录原始的异常
- if (null != e) {
- StackTraceElement[] array = e.getStackTrace();
- cause = e.getCause();
- for (StackTraceElement stackTraceElement : array) {
- sbuf.append(stackTraceElement.toString());
- sbuf.append("\r\n");
- }
- }
- //记录 出现异常时 当前的对象
- if (null != obj) {
- Object[] array = obj;
- sbuf.append("Object[] size : ");
- sbuf.append(array.length);
- int forSize = 0;
- if (Constant.CustomException_log_object_size < array.length) {
- forSize = Constant.CustomException_log_object_size;
- }
- else {
- forSize = array.length;
- }
- for (int i = 0; i < forSize; i++) {
- sbuf.append(array[i]);
- sbuf.append("\r\n");
- }
- sbuf.append("......");
- sbuf.append("\r\n");
- }
- else {
- sbuf.append("null");
- sbuf.append("\r\n");
- }
-
- sbuf.append("\r\n");
- // 是否 写入 文件
- log.error(sbuf.toString());
- }
-
- /**
- * @功能 获得msg
- * @return msg
- */
- public String getMsg() {
- return msg;
- }
-
-
- /**
- * @return the code
- */
- public String getCode() {
- return code;
- }
-
- /**
- * @功能 获得objArray
- * @return objArray
- */
- public Object[] getObjArray() {
- return objArray;
- }
-
- /**
- * @功能 获得cause
- * @return cause
- */
- public Throwable getCause() {
- return cause;
- }
-}
-
+
+
+package com.base;
+
+import org.apache.log4j.Logger;
+
+/**
+ * <一句话功能简述>
+ * <功能详细描述>
+ * @author chen
+ * @version [版本号,2016年9月8日]
+ * @see [相关类/方法]
+ * @since [产品/模块版本]
+ */
+@SuppressWarnings("serial")
+public class CustomException extends Exception {
+
+ /** log4j */
+ public static Logger log = Logger.getRootLogger();
+
+ /** 自定义异常信息-错误信息 */
+ private String msg;
+
+ /** 自定义异常信息-错误代码 */
+ private String code;
+
+ /** 操作对象 */
+ private Object[] objArray;
+
+ /** 异常 */
+ private Throwable cause;
+
+ public CustomException() {
+ super();
+ }
+
+ /**
+ * @功能 将异常记录进文件
+ * @param code 异常编码
+ * @param msg 自定义异常信息
+ * @param e
+ * @param obj
+ */
+ public CustomException(String code,Exception e,Object... obj) {
+ super(code);
+ StringBuffer sbuf= new StringBuffer();
+ sbuf.append(msg);
+ this.code = code;
+ sbuf.append(code);
+ sbuf.append("\r\n");
+ msg = Resource.getProperties().get(code);
+ // 记录自定义的 异常
+ if (null != msg) {
+ sbuf.append(msg);
+ sbuf.append("\r\n");
+ }
+ // 记录原始的异常
+ if (null != e) {
+ StackTraceElement[] array = e.getStackTrace();
+ cause = e.getCause();
+ for (StackTraceElement stackTraceElement : array) {
+ sbuf.append(stackTraceElement.toString());
+ sbuf.append("\r\n");
+ }
+ }
+ //记录 出现异常时 当前的对象
+ if (null != obj) {
+ Object[] array = obj;
+ sbuf.append("Object[] size : ");
+ sbuf.append(array.length);
+ int forSize = 0;
+ if (Constant.CustomException_log_object_size < array.length) {
+ forSize = Constant.CustomException_log_object_size;
+ }
+ else {
+ forSize = array.length;
+ }
+ for (int i = 0; i < forSize; i++) {
+ sbuf.append(array[i]);
+ sbuf.append("\r\n");
+ }
+ sbuf.append("......");
+ sbuf.append("\r\n");
+ }
+ else {
+ sbuf.append("null");
+ sbuf.append("\r\n");
+ }
+
+ sbuf.append("\r\n");
+ // 是否 写入 文件
+ log.error(sbuf.toString());
+ }
+
+ /**
+ * @功能 获得msg
+ * @return msg
+ */
+ public String getMsg() {
+ return msg;
+ }
+
+
+ /**
+ * @return the code
+ */
+ public String getCode() {
+ return code;
+ }
+
+ /**
+ * @功能 获得objArray
+ * @return objArray
+ */
+ public Object[] getObjArray() {
+ return objArray;
+ }
+
+ /**
+ * @功能 获得cause
+ * @return cause
+ */
+ public Throwable getCause() {
+ return cause;
+ }
+}
+
diff --git a/src/com/base/Resource.java b/src/com/base/Resource.java
index 0b900bfe..5cd15923 100644
--- a/src/com/base/Resource.java
+++ b/src/com/base/Resource.java
@@ -1,79 +1,79 @@
-package com.base;
-
-import java.io.BufferedInputStream;
-import java.io.BufferedReader;
-import java.io.FileInputStream;
-import java.io.IOException;
-import java.io.InputStreamReader;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.Map;
-import java.util.Properties;
-
-import com.base.Constant;
-
-public class Resource {
-
- private static Map properties = new HashMap<>();
-
- static{
- // 读取 properties文件
-// readPropertiesFile(Constant.SYSTEM_PROPERTIES_FIEL_PATH);
- readPropertiesFile4Chinese(Constant.I18N_PROPERTIES_FIEL_PATH);
-
- }
-
- /**
- * @功能 读取配置(解决中文乱码)
- * @param filename "/com/utils/exception/i18n.properties" 的格式
- */
- public static void readPropertiesFile4Chinese(String filename) {
- Properties pro = new Properties();
- try {
- // 读取属性文件 XXXX.properties(Reader。writer解决中文乱码)
-// InputStreamReader in= new InputStreamReader(Resource.class.getClassLoader().getResourceAsStream(filename), "UTF-8");
- InputStreamReader in= new InputStreamReader(Resource.class.getResourceAsStream(filename), "UTF-8");
- BufferedReader bf = new BufferedReader(in);
- // InputStreamReader in = new BufferedInputStream(new FileInputStream(filename));
- pro.load(bf); // /加载属性列表
- Iterator it = pro.stringPropertyNames().iterator();
- while (it.hasNext()) {
- String key = it.next();
- properties.put(key, pro.getProperty(key));
- }
- in.close();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
-
- /**
- * @功能 获得properties
- * @return properties
- */
- public static Map getProperties() {
- return properties;
- }
-
- /**
- * @功能 读取配置
- * @param filename 文件绝对路径
- */
- public static void readPropertiesFile(String filename) {
- Properties pro = new Properties();
- try {
- // 读取属性文件 XXXX.properties( 中文会 乱码)
- BufferedInputStream bf = new BufferedInputStream(new FileInputStream(filename));
- pro.load(bf); // /加载属性列表
- Iterator it = pro.stringPropertyNames().iterator();
- while (it.hasNext()) {
- String key = it.next();
- properties.put(key, pro.getProperty(key));
- }
- bf.close();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
-
-}
+package com.base;
+
+import java.io.BufferedInputStream;
+import java.io.BufferedReader;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.Map;
+import java.util.Properties;
+
+import com.base.Constant;
+
+public class Resource {
+
+ private static Map properties = new HashMap<>();
+
+ static{
+ // 读取 properties文件
+// readPropertiesFile(Constant.SYSTEM_PROPERTIES_FIEL_PATH);
+ readPropertiesFile4Chinese(Constant.I18N_PROPERTIES_FIEL_PATH);
+
+ }
+
+ /**
+ * @功能 读取配置(解决中文乱码)
+ * @param filename "/com/utils/exception/i18n.properties" 的格式
+ */
+ public static void readPropertiesFile4Chinese(String filename) {
+ Properties pro = new Properties();
+ try {
+ // 读取属性文件 XXXX.properties(Reader。writer解决中文乱码)
+// InputStreamReader in= new InputStreamReader(Resource.class.getClassLoader().getResourceAsStream(filename), "UTF-8");
+ InputStreamReader in= new InputStreamReader(Resource.class.getResourceAsStream(filename), "UTF-8");
+ BufferedReader bf = new BufferedReader(in);
+ // InputStreamReader in = new BufferedInputStream(new FileInputStream(filename));
+ pro.load(bf); // /加载属性列表
+ Iterator it = pro.stringPropertyNames().iterator();
+ while (it.hasNext()) {
+ String key = it.next();
+ properties.put(key, pro.getProperty(key));
+ }
+ in.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ /**
+ * @功能 获得properties
+ * @return properties
+ */
+ public static Map getProperties() {
+ return properties;
+ }
+
+ /**
+ * @功能 读取配置
+ * @param filename 文件绝对路径
+ */
+ public static void readPropertiesFile(String filename) {
+ Properties pro = new Properties();
+ try {
+ // 读取属性文件 XXXX.properties( 中文会 乱码)
+ BufferedInputStream bf = new BufferedInputStream(new FileInputStream(filename));
+ pro.load(bf); // /加载属性列表
+ Iterator it = pro.stringPropertyNames().iterator();
+ while (it.hasNext()) {
+ String key = it.next();
+ properties.put(key, pro.getProperty(key));
+ }
+ bf.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+}
diff --git a/src/com/dao/mapper/RegionalismMapper.xml b/src/com/dao/mapper/RegionalismMapper.xml
index 9110649b..ce2c48f5 100644
--- a/src/com/dao/mapper/RegionalismMapper.xml
+++ b/src/com/dao/mapper/RegionalismMapper.xml
@@ -1,42 +1,42 @@
-
-
-
-
-
-
-
-
-
-
-
- code,city_name,district_name
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+ code,city_name,district_name
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/com/dao/mapper/SystemCodeMapper.xml b/src/com/dao/mapper/SystemCodeMapper.xml
index f835c99f..c23937dd 100644
--- a/src/com/dao/mapper/SystemCodeMapper.xml
+++ b/src/com/dao/mapper/SystemCodeMapper.xml
@@ -1,42 +1,42 @@
-
-
-
-
-
-
-
-
-
-
- code,system_name
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+ code,system_name
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/src/com/dao/mapper/config-details-mapper.xml b/src/com/dao/mapper/config-details-mapper.xml
index 439d4f98..3d1dba4d 100644
--- a/src/com/dao/mapper/config-details-mapper.xml
+++ b/src/com/dao/mapper/config-details-mapper.xml
@@ -1,146 +1,146 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- id id, service_port port, service_ip ip, service_name name, service_user user, service_password password, service_database databaseName, service_table tableName, service_suffix suffix, service_status status
-
-
-
-
-
- INSERT INTO
- services_info(
-
-
- service_port,
-
-
- service_ip,
-
-
- service_name,
-
-
- service_user,
-
-
- service_password,
-
-
- service_database,
-
-
- service_table,
-
-
- service_suffix,
-
-
- service_status,
-
-
- )
- VALUES(
-
-
- #{port},
-
-
- #{ip},
-
-
- #{name},
-
-
- #{user},
-
-
- #{password},
-
-
- #{databaseName},
-
-
- #{tableName},
-
-
- #{suffix},
-
-
- #{status},
-
-
- )
-
-
-
- DELETE FROM services_info
-
- id =#{id}
-
-
-
-
- UPDATE
- services_info
-
-
-
- service_name = #{name},
-
-
- service_ip = #{ip},
-
-
- service_port= #{port},
-
-
- service_user= #{user},
-
-
- service_password= #{password},
-
-
- service_database= #{databaseName},
-
-
- service_table= #{tableName},
-
-
- service_suffix= #{suffix},
-
-
- service_status= #{status},
-
-
- remove= #{remove},
-
-
-
-
- id = #{id}
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ id id, service_port port, service_ip ip, service_name name, service_user user, service_password password, service_database databaseName, service_table tableName, service_suffix suffix, service_status status
+
+
+
+
+
+ INSERT INTO
+ services_info(
+
+
+ service_port,
+
+
+ service_ip,
+
+
+ service_name,
+
+
+ service_user,
+
+
+ service_password,
+
+
+ service_database,
+
+
+ service_table,
+
+
+ service_suffix,
+
+
+ service_status,
+
+
+ )
+ VALUES(
+
+
+ #{port},
+
+
+ #{ip},
+
+
+ #{name},
+
+
+ #{user},
+
+
+ #{password},
+
+
+ #{databaseName},
+
+
+ #{tableName},
+
+
+ #{suffix},
+
+
+ #{status},
+
+
+ )
+
+
+
+ DELETE FROM services_info
+
+ id =#{id}
+
+
+
+
+ UPDATE
+ services_info
+
+
+
+ service_name = #{name},
+
+
+ service_ip = #{ip},
+
+
+ service_port= #{port},
+
+
+ service_user= #{user},
+
+
+ service_password= #{password},
+
+
+ service_database= #{databaseName},
+
+
+ service_table= #{tableName},
+
+
+ service_suffix= #{suffix},
+
+
+ service_status= #{status},
+
+
+ remove= #{remove},
+
+
+
+
+ id = #{id}
+
+
+
\ No newline at end of file
diff --git a/src/com/dao/mapper/data-details-mapper.xml b/src/com/dao/mapper/data-details-mapper.xml
index 39a61797..217885ca 100644
--- a/src/com/dao/mapper/data-details-mapper.xml
+++ b/src/com/dao/mapper/data-details-mapper.xml
@@ -1,249 +1,249 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- AND data_details.data_type=#{dataType}
-
-
- AND
- data_details.submitted_batch=#{submittedBatch}
-
-
- AND data_details.city_name=#{cityName}
-
-
- AND
- data_details.district_name=#{districtName}
-
-
- AND data_details.data_version=#{dataVersion}
-
-
- AND data_details.system_name=#{systemName}
-
-
- AND data_details.data_year=#{dataYear}
-
-
-
- AND CONCAT(regionalism_code,system_code,city_name,district_name,system_name) LIKE CONCAT('%',CONCAT(#{item},'%'))
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- INSERT INTO
- data_info(
-
-
- regionalism_code,
-
-
- system_code,
-
-
- data_type,
-
-
- data_version,
-
-
- submitted_batch,
-
-
- data_path,
-
-
- collection_time,
-
-
- collector_name,
-
-
- collector_contacts,
-
-
- data_charset,
-
-
- data_year,
-
-
- start_year,
-
-
- end_year,
-
-
- volume_ip,
-
-
- volume_path,
-
-
- extract_status,
-
-
- )
- VALUES(
-
-
- #{regionalismCode},
-
-
- #{systemCode},
-
-
- #{dataType},
-
-
- #{dataVersion},
-
-
- #{submittedBatch},
-
-
- #{dataPath},
-
-
- #{collectingTime},
-
-
- #{collectorName},
-
-
- #{collectorContacts},
-
-
- #{charset},
-
-
- #{year},
-
-
- #{start_year},
-
-
- #{end_year},
-
-
- #{volumeIp},
-
-
- #{volumePath},
-
-
- #{extractStatus},
-
-
- )
-
-
-
-
-
- UPDATE
- data_info
- set remove = '1'
- where id in
-
- #{item}
-
- and remove ='0'
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ AND data_details.data_type=#{dataType}
+
+
+ AND
+ data_details.submitted_batch=#{submittedBatch}
+
+
+ AND data_details.city_name=#{cityName}
+
+
+ AND
+ data_details.district_name=#{districtName}
+
+
+ AND data_details.data_version=#{dataVersion}
+
+
+ AND data_details.system_name=#{systemName}
+
+
+ AND data_details.data_year=#{dataYear}
+
+
+
+ AND CONCAT(regionalism_code,system_code,city_name,district_name,system_name) LIKE CONCAT('%',CONCAT(#{item},'%'))
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ INSERT INTO
+ data_info(
+
+
+ regionalism_code,
+
+
+ system_code,
+
+
+ data_type,
+
+
+ data_version,
+
+
+ submitted_batch,
+
+
+ data_path,
+
+
+ collection_time,
+
+
+ collector_name,
+
+
+ collector_contacts,
+
+
+ data_charset,
+
+
+ data_year,
+
+
+ start_year,
+
+
+ end_year,
+
+
+ volume_ip,
+
+
+ volume_path,
+
+
+ extract_status,
+
+
+ )
+ VALUES(
+
+
+ #{regionalismCode},
+
+
+ #{systemCode},
+
+
+ #{dataType},
+
+
+ #{dataVersion},
+
+
+ #{submittedBatch},
+
+
+ #{dataPath},
+
+
+ #{collectingTime},
+
+
+ #{collectorName},
+
+
+ #{collectorContacts},
+
+
+ #{charset},
+
+
+ #{year},
+
+
+ #{start_year},
+
+
+ #{end_year},
+
+
+ #{volumeIp},
+
+
+ #{volumePath},
+
+
+ #{extractStatus},
+
+
+ )
+
+
+
+
+
+ UPDATE
+ data_info
+ set remove = '1'
+ where id in
+
+ #{item}
+
+ and remove ='0'
+
+
\ No newline at end of file
diff --git a/src/com/dao/mapper/dataInfoMoveTmpmapper.xml b/src/com/dao/mapper/dataInfoMoveTmpmapper.xml
index 13a74388..e35029a5 100644
--- a/src/com/dao/mapper/dataInfoMoveTmpmapper.xml
+++ b/src/com/dao/mapper/dataInfoMoveTmpmapper.xml
@@ -1,189 +1,189 @@
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- regionalism_code,system_code,dst_path,lasttime,fkid
-
-
-
-
-
-
- UPDATE
- move_data_tmp
-
-
-
- dst_path= #{dstPath},
-
-
- complete_status= #{completeStatus},
-
-
- rate= #{rate},
-
-
- lasttime= #{lastTime},
-
-
-
-
- id = #{id}
-
-
-
-
- INSERT INTO
- move_data_tmp(
-
-
- id,
-
-
- regionalism_code,
-
-
- system_code,
-
-
- dst_path,
-
-
- complete_status,
-
-
- rate,
-
-
- lasttime,
-
-
- fkid,
-
-
- )
- VALUES(
-
-
- id,
-
-
- #{regionalismCode},
-
-
- #{systemCode},
-
-
- #{dstPath},
-
-
- #{completeStatus},
-
-
- #{rate}
-
-
- #{lastTime},
-
-
- #{fkid),
-
-
- )
-
-
-
-
-
- DELETE FROM
- move_data_tmp
- WHERE
- id = #{id}
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ regionalism_code,system_code,dst_path,lasttime,fkid
+
+
+
+
+
+
+ UPDATE
+ move_data_tmp
+
+
+
+ dst_path= #{dstPath},
+
+
+ complete_status= #{completeStatus},
+
+
+ rate= #{rate},
+
+
+ lasttime= #{lastTime},
+
+
+
+
+ id = #{id}
+
+
+
+
+ INSERT INTO
+ move_data_tmp(
+
+
+ id,
+
+
+ regionalism_code,
+
+
+ system_code,
+
+
+ dst_path,
+
+
+ complete_status,
+
+
+ rate,
+
+
+ lasttime,
+
+
+ fkid,
+
+
+ )
+ VALUES(
+
+
+ id,
+
+
+ #{regionalismCode},
+
+
+ #{systemCode},
+
+
+ #{dstPath},
+
+
+ #{completeStatus},
+
+
+ #{rate}
+
+
+ #{lastTime},
+
+
+ #{fkid),
+
+
+ )
+
+
+
+
+
+ DELETE FROM
+ move_data_tmp
+ WHERE
+ id = #{id}
+
+
+
+
\ No newline at end of file
diff --git a/src/com/platform/controller/DataModelController.java b/src/com/platform/controller/DataModelController.java
index b4c005b2..ff0b7a93 100644
--- a/src/com/platform/controller/DataModelController.java
+++ b/src/com/platform/controller/DataModelController.java
@@ -1,314 +1,332 @@
-package com.platform.controller;
-
-import java.io.UnsupportedEncodingException;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-
-import javax.annotation.Resource;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-
-import net.sf.json.JSONObject;
-
-import org.apache.commons.lang.StringUtils;
-import org.apache.log4j.Logger;
-import org.springframework.stereotype.Controller;
-import org.springframework.ui.ModelMap;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.ResponseBody;
-
-import com.base.BaseController;
-import com.platform.entities.DataInfoEntity;
-import com.platform.entities.DataInfoEntityMoveTmp;
-import com.platform.entities.FolderNode;
-import com.platform.entities.GatherOracleInfo;
-import com.platform.entities.PagerOptions;
-import com.platform.entities.VolumeEntity;
-import com.platform.service.DataInfoService;
-import com.platform.service.ICodeService;
-import com.platform.service.IGfsService;
-import com.platform.service.IMoveDataService;
-import com.platform.service.IMySqlService;
-import com.platform.service.IOracleExtractService;
-import com.platform.service.OracleStatusService;
-import com.platform.utils.Bean2MapUtils;
-import com.platform.utils.Configs;
-import com.platform.utils.UtilsHelper;
-
-@Controller
-public class DataModelController extends BaseController{
-
- public static Logger log = Logger.getLogger(DataModelController.class);
-
- @Resource(name = "dataInfoService")
- private DataInfoService dfs;
-
- @Resource(name = "gfsService")
- private IGfsService gfsService;
-
- @Resource(name = "mySqlService")
- private IMySqlService mySqlService;
-
- @Resource(name = "OracleExtract")
- private IOracleExtractService OracleExtract;
-
- @Resource(name = "moveDataService")
- private IMoveDataService moveDataService;
-
- @Resource(name = "codeService")
- private ICodeService codeService;
-
- public void setDfsImp(DataInfoService dfs) {
- this.dfs = dfs;
- }
-
- @RequestMapping("/data.json")
- @ResponseBody
- public ModelMap getAllDataToJson(HttpServletRequest res,
- HttpServletResponse req) throws UnsupportedEncodingException {
- res.setCharacterEncoding("UTF-8");
- Map paramMap = res.getParameterMap();
- Set keySet = paramMap.keySet();
- Map params = new HashMap();
- StringBuffer sb = new StringBuffer().append("当前的请求参数:{");
- for (String str : keySet) {
- String value = paramMap.get(str)[0];
- if (StringUtils.isNotEmpty(value)) {
- params.put(str, value);
- sb.append(str).append(":").append(value).append(",");
- } else {
- sb.append(str).append(":").append("null").append(",");
- }
- }
- Configs.CONSOLE_LOGGER.info(sb.deleteCharAt(sb.length() - 1)
- .append("}").toString());
- PagerOptions pagerOptions = (PagerOptions) UtilsHelper
- .newObjAndSetAttrsByClass(PagerOptions.class, params);
-
- return dfs.getPagerTableData(pagerOptions);
- }
-
- @RequestMapping(value="/delete/data", method= RequestMethod.POST)
- public void deleteData(HttpServletRequest res, HttpServletResponse req) throws Exception {
- res.setCharacterEncoding("UTF-8");
- Map paramMap = res.getParameterMap();
- String[] data = paramMap.get("data");
- dfs.deleteData(data);
- }
-
- @RequestMapping("/connectOracle")
- public void connectOracle(HttpServletRequest res, HttpServletResponse req) throws UnsupportedEncodingException {
- res.setCharacterEncoding("UTF-8");
- Map paramMap = res.getParameterMap();
- String[] oraclesName = paramMap.get("oracleName");
- if (oraclesName != null)
- for (String rcName : oraclesName) {
- Configs.CONSOLE_LOGGER.info("连接成功\t" + rcName);
- new OracleStatusService().connectToOracle(rcName);
- }
- }
-
- @RequestMapping("/cancelOracleConection")
- public void cancelOracleConnection(HttpServletRequest res,
- HttpServletResponse req) throws UnsupportedEncodingException {
- res.setCharacterEncoding("UTF-8");
- Map paramMap = res.getParameterMap();
- String[] oraclesName = paramMap.get("oracleName");
- String operate = paramMap.get("operation")[0];
- if (null != oraclesName) {
- for (String rcName : oraclesName) {
- Configs.CONSOLE_LOGGER.info("取消连接:\t" + rcName);
- new OracleStatusService().cancelToOracle(rcName, operate);
- }
- }
- }
-
- @RequestMapping(value="/oracle/{name}/extract", method= RequestMethod.POST)
- public void oracleExtract(HttpServletRequest res,
- HttpServletResponse req,@PathVariable String name) throws Exception {
- res.setCharacterEncoding("UTF-8");
- System.out.println("------extract-------");
- System.out.println(name);
- Map paramMap = res.getParameterMap();
- //汇总库 对象信息--带有tableName-
- String[] nodes = paramMap.get("target");
- Map map = null;
- for (String string : nodes) {
- JSONObject jsonobject = JSONObject.fromObject(string);
- map = jsonobject;
- System.out.println(map);
- }
-
- // 采集库对象--(多个采集库抽取到1个汇总库的1个tableName下)
- String[] inneed = paramMap.get("inneed");
- List