From 9dd1b0f01919bc1997b90ea85e78f489d141fef9 Mon Sep 17 00:00:00 2001
From: chenlw <874313221@qq.com>
Date: Wed, 7 Dec 2016 09:28:26 +0800
Subject: [PATCH] =?UTF-8?q?=E5=86=B7=E7=83=AD=E5=8C=BA=E6=95=B0=E6=8D=AE?=
=?UTF-8?q?=E5=88=86=E4=B8=BA=E5=86=B7=E5=8C=BA=E4=B8=80=E5=BC=A0=E8=A1=A8?=
=?UTF-8?q?=E7=83=AD=E5=8C=BA=E4=B8=80=E5=BC=A0=E8=A1=A8=E5=AD=98=E5=82=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
src/com/dao/mapper/hotDataDetailsMapper.xml | 357 ++++++++++++++++++
.../mapper/standard_data_details-mapper.xml | 11 +
src/com/platform/dao/IHotDataInfoDao.java | 39 ++
src/com/platform/dao/PreDataInfoDao.java | 2 +
src/com/platform/oracle/OracleConnector.java | 3 +-
.../service/impl/CheckoutServiceImpl.java | 151 ++++----
.../service/impl/DataInfoServiceImp.java | 11 +-
.../thread/ThreadCheckoutStandardOracle.java | 2 +-
.../service/thread/ThreadExtractOracle.java | 1 +
.../thread/ThreadExtractStandardOracle.java | 1 +
.../ThreadExtractStandardSqlServer.java | 1 +
.../service/thread/ThreadMoveData.java | 11 +-
.../service/thread/TreadMoveData2Start.java | 1 +
src/com/platform/utils/Constant.java | 2 +-
14 files changed, 521 insertions(+), 72 deletions(-)
create mode 100644 src/com/dao/mapper/hotDataDetailsMapper.xml
create mode 100644 src/com/platform/dao/IHotDataInfoDao.java
diff --git a/src/com/dao/mapper/hotDataDetailsMapper.xml b/src/com/dao/mapper/hotDataDetailsMapper.xml
new file mode 100644
index 00000000..be523283
--- /dev/null
+++ b/src/com/dao/mapper/hotDataDetailsMapper.xml
@@ -0,0 +1,357 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ AND data_details.data_type=#{dataType}
+
+
+ AND data_details.mark=#{mark}
+
+
+ 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 data_details.data_base_type=#{dataBaseType}
+
+
+
+ AND CONCAT(regionalism_code,system_code,city_name,district_name,system_name,data_year) 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,
+
+
+ checkout_pay,
+
+
+ checkout_indicate,
+
+
+ start_month,
+
+
+ end_month,
+
+
+ data_base_type,
+
+
+ )
+ VALUES(
+
+
+ #{regionalismCode},
+
+
+ #{systemCode},
+
+
+ #{dataType},
+
+
+ #{dataVersion},
+
+
+ #{submittedBatch},
+
+
+ #{dataPath},
+
+
+ #{collectingTime},
+
+
+ #{collectorName},
+
+
+ #{collectorContacts},
+
+
+ #{charset},
+
+
+ #{year},
+
+
+ #{startYear},
+
+
+ #{endYear},
+
+
+ #{volumeIp},
+
+
+ #{volumePath},
+
+
+ #{extractStatus},
+
+
+ #{payResult},
+
+
+ #{execResult},
+
+
+ #{startMonth},
+
+
+ #{endMonth},
+
+
+ #{dataBaseType},
+
+
+ )
+
+
+
+
+
+ UPDATE
+ data_info
+ set remove = '1'
+ where id in
+
+ #{item}
+
+ and remove ='0'
+
+
+
+
+
+ UPDATE
+ data_info
+
+
+
+ data_path= #{dataPath},
+
+
+ extract_status= #{extractStatus},
+
+
+ checkout_pay_last= #{payResultLast},
+
+
+ checkout_indicate_last= #{execResultLast},
+
+
+ checkout_flag= #{checkoutFlag},
+
+
+
+
+ id = #{id}
+ AND remove ='0'
+
+
+
+
\ No newline at end of file
diff --git a/src/com/dao/mapper/standard_data_details-mapper.xml b/src/com/dao/mapper/standard_data_details-mapper.xml
index 902633cb..225a5c0e 100644
--- a/src/com/dao/mapper/standard_data_details-mapper.xml
+++ b/src/com/dao/mapper/standard_data_details-mapper.xml
@@ -203,6 +203,17 @@ PUBLIC "-//ibatis.apache.org//DTD Mapper 3.0//EN"
ORDER BY a.area_code,a.sys_code,d.data_version
+
+