|
@@ -138,7 +138,6 @@ public class OriginalTask {
|
|
|
oldJdbc.releaseConn();
|
|
|
newJdbc.releaseConn();
|
|
|
fileCreate(fileId,numrows,"1000001","台区停电明细");
|
|
|
-// //递归处理分页
|
|
|
System.out.println("<----------------电网台区停电数据导入结束--------->");
|
|
|
|
|
|
}
|
|
@@ -167,8 +166,7 @@ public class OriginalTask {
|
|
|
String yesterday = DateUtil.yesterday();
|
|
|
//查询昨日数据
|
|
|
List<Object> params = new ArrayList<Object>();
|
|
|
-// params.add(yesterday+"%");
|
|
|
- params.add("2019-08-16%");
|
|
|
+ params.add(yesterday+"%");
|
|
|
List<Map<String, Object>> faultCount = newJdbc.findModeResult(sqlFaultCount, params);
|
|
|
//开始分页
|
|
|
// int start = 0;//开始位置,从0行开始查询
|
|
@@ -313,7 +311,6 @@ public class OriginalTask {
|
|
|
newJdbc.releaseConn();
|
|
|
int numrows = faultNumrows;
|
|
|
fileCreate(fileId,numrows,"1000006","95598工单明细");
|
|
|
-// //递归处理分页
|
|
|
System.out.println("<----------------95598数据导入结束--------->");
|
|
|
|
|
|
}
|
|
@@ -370,7 +367,14 @@ public class OriginalTask {
|
|
|
System.out.println("<----------------文件表插入结束 类型:"+type+"--------->");
|
|
|
}
|
|
|
|
|
|
-
|
|
|
+ /**
|
|
|
+ * 低电压导入
|
|
|
+ * @param start
|
|
|
+ * @param pageSize
|
|
|
+ * @throws SQLException
|
|
|
+ * @throws MINBusinessException
|
|
|
+ * @throws ParseException
|
|
|
+ */
|
|
|
public static void ddyData(int start,int pageSize) throws SQLException, MINBusinessException, ParseException {
|
|
|
System.out.println("<----------------电网低电压数据导入开始--------->");
|
|
|
IMINDataBaseService db = Service.lookup(IMINDataBaseService.class);
|