低电压

src/main/java/com/minpay/common/action/OriginalTask.java

@@ -370,4 +370,120 @@ public class OriginalTask {
 		System.out.println("<----------------文件表插入结束 类型:"+type+"--------->");
 	}
 	
+	
+	public static void ddyData(int start,int pageSize)  throws SQLException, MINBusinessException, ParseException {
+		System.out.println("<----------------电网低电压数据导入开始--------->");
+		IMINDataBaseService db = Service.lookup(IMINDataBaseService.class);
+		//获取文件id
+		String fileId = db.getMybatisMapper(SequenceMapper.class).getSequence("FILE_INF_NO");
+		//当前报表库
+		OldDBJdbcUtils oldJdbc = new OldDBJdbcUtils();
+		oldJdbc.getConnection();
+		//rpa数据库
+		NewDBJdbcUtils newJdbc = new NewDBJdbcUtils();
+		newJdbc.getConnection();
+		
+		String sqlCount = "SELECT row_id FROM power_low_info WHERE date_format(record_date, '%Y-%m-%d') = ? ORDER BY row_id DESC";
+		//昨日日期
+		String yesterday = DateUtil.yesterday();
+		//查询昨日数据
+		List<Object> params = new ArrayList<Object>();
+		params.add(yesterday);
+		List<Map<String, Object>> resCount = newJdbc.findModeResult(sqlCount, params);
+		//开始分页
+//		int start = 0;//开始位置，从0行开始查询
+//		int pageSize = 20;//偏移量
+		int numrows =  resCount.size();//这里是总的行数
+		int pages = (int)(numrows / pageSize);//根据偏移量计算需要翻多少页
+		if (numrows % pageSize > 0){
+			pages++;
+		}
+		
+		String insertSql = "insert into dw_file_detail_03 ("
+				+ "DFD3_ID,DFD3_NO,DFD3_SGSMC,DFD3_XGSMC,DFD3_BDZMC,"
+				+ "DFD3_XLMC,DFD3_TQID,DFD3_BYQMC,"
+				+ "DFD3_YHGLDW1,DFD3_YHID,DFD3_YHMC,"
+				+ "DFD3_YHGLDW2,DFD3_DYMAX,DFD3_DYMIN,DFD3_DYHGL,DFD3_CSXL,DFD3_CXXL,DFD3_DYSC,DFD3_GDLX,DFD3_LJTS,DFD3_SJRQ,DFD3_GDDW,DFD3_FILE_ID)"
+				+ "values ("
+				+ "?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
+		int i=1;
+		while(pages>0){
+			System.out.println(start + "————————————————————————————————————————" + pageSize);
+			String sql = "SELECT row_id,company_ctiy_name,company_county_name,"
+						+ 	"power_station_name,power_line_name,station_id,"
+						+ 	"transformer_name,unit_of_emp,emp_num,emp_name,voltage_max,voltage_min,voltage_qua,up_rate,down_rate,voltage_min_date,"
+						+ "power_supply_type,total_days,date_format(record_date, '%Y%m%d') as record_date,power_supply_unit "
+						+ "FROM power_low_info "
+						+ "WHERE date_format(record_date, '%Y-%m-%d') = ? "
+						+ "ORDER BY row_id DESC "
+						+ "limit "+start+","+ pageSize;
+			List<Map<String, Object>> resList = newJdbc.findModeResult(sql, params);
+			
+			//循环插入数据
+			for(Map<String,Object> map:resList){
+				//台区停电表导入数据
+				String fileDetailId = db.getMybatisMapper(SequenceMapper.class).getSequence("FILE_DETAIL_03_NO");
+				List<Object> params1 = new ArrayList<Object>();
+				//时间截取 反正时间强转 导致时间不准问题
+				String row_id = map.get("row_id")+"";									// row_id
+				String company_ctiy_name =  map.get("company_ctiy_name")+"";			// 市公司名称
+				String company_county_name =  map.get("company_county_name")+"";		// 县公司名称
+				String power_station_name =  map.get("power_station_name")+"";			// 变电站名称
+				String power_line_name =  map.get("power_line_name")+"";				// 线路名称
+				String station_id =  map.get("station_id")+"";							// 台区ID
+				String transformer_name =  map.get("transformer_name")+"";				// 变压器名称
+				String unit_of_emp =  map.get("unit_of_emp")+"";						// 用户管理单位名称
+				String emp_num =  map.get("emp_num")+"";								// 用户编号
+				String emp_name =  map.get("emp_name")+"";								// 用户名称
+				String voltage_max =  map.get("voltage_max")+"";						// 最大电压
+				String voltage_min =  map.get("voltage_min")+"";						// 最小电压
+				String voltage_qua =  map.get("voltage_qua")+"";						// 电压合格率
+				String up_rate =  map.get("up_rate")+"";								// 超上限率
+				String down_rate =  map.get("down_rate")+"";							// 超下限率
+				String voltage_min_date =  map.get("voltage_min_date")+"";				// 低电压时长
+				String power_supply_type =  map.get("power_supply_type")+"";			// 供电类型
+				String total_days =  map.get("total_days")+"";							// 累计天数
+				String record_date =  map.get("record_date")+"";						// 数据日期
+				String power_supply_unit =  map.get("power_supply_unit")+"";			// 供电单位
+				//id
+				params1.add(fileDetailId);												// 编号
+				params1.add(i);															// 序号
+				params1.add(company_ctiy_name);											// 市公司名称
+				params1.add(company_county_name);										// 县公司名称
+				params1.add(power_station_name);										// 变电站名称
+				params1.add(power_line_name);											// 线路名称
+				params1.add(station_id);												// 台区id		
+				params1.add(transformer_name);											// 变压器名称
+				params1.add(unit_of_emp);												// 用户管理单位名称1
+				params1.add(emp_num);													// 用户编号	
+				params1.add(emp_name);													// 用户名称
+				params1.add(unit_of_emp);												// 用户管理单位名称2
+				params1.add(voltage_max);												// 电压最大值				
+				params1.add(voltage_min);												// 电压最小值				
+				params1.add(voltage_qua);												// 电压合格率				
+				params1.add(up_rate);													// 超上限率				
+				params1.add(down_rate);													// 超下限率				
+				params1.add(voltage_min_date);											// 低电压时长				
+				params1.add(power_supply_type);											// 供电类型				
+				params1.add(total_days);												// 累计天数				
+				params1.add(record_date);												// 数据日期				
+				params1.add(power_supply_unit);											// 供电单位				
+				params1.add(fileId);													// 所属文件id				
+				boolean a = oldJdbc.updateByPreparedStatement(insertSql, params1);
+				if(a == true){
+					System.out.println("低电压插入：" + params1 + "	数量：" + (i) +"	原主键："+row_id);
+				}else{
+					System.out.println("!!!!!!!!!!!!————出现异常————!!!!!!!!!!!!");
+				}
+				i++;
+			}
+			start+=pageSize;
+			pages--;
+		}
+		oldJdbc.releaseConn();
+		newJdbc.releaseConn();
+		fileCreate(fileId,numrows,"1000004","低电压明细");
+		//递归处理分页
+		System.out.println("<----------------电网台区停电数据导入结束--------->");
+	}
 }

src/main/java/com/minpay/common/action/RunOfflineService.java

@@ -24,10 +24,10 @@ public class RunOfflineService {
 		Log.info("跑批任务开始...._-------------");
 		//台区停电数据导入
 		OriginalTask.tqtdData(0,500);
-		//低电压 
-//		OriginalTask.ddyData(0,2);
 		//95598 工单数据导入
 		OriginalTask.workOrderData(0,500);
+		// 低电压
+		OriginalTask.ddyData(0,500);
 		Log.info("跑批任务结束...._-------------");
 	}
 }