过电压 95598工单源数据导入

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

@@ -161,12 +161,14 @@ public class OriginalTask {
 		NewDBJdbcUtils newJdbc = new NewDBJdbcUtils();
 		newJdbc.getConnection();
 		//故障条数
-		String sqlFaultCount = "SELECT fa_id FROM fault_work_order WHERE fa_acceptance_time LIKE ?";
+//		String sqlFaultCount = "SELECT fa_id FROM fault_work_order WHERE fa_acceptance_time LIKE ?";
+		String sqlFaultCount = "SELECT row_id FROM order_info WHERE date_format(order_oper_time, '%Y-%m-%d')=?";
 		//昨日日期
 		String yesterday = DateUtil.yesterday();
 		//查询昨日数据
 		List<Object> params = new ArrayList<Object>();
-		params.add(yesterday+"%");	
+//		params.add(yesterday);	
+		params.add("2019-03-21");	
 		List<Map<String, Object>> faultCount = newJdbc.findModeResult(sqlFaultCount, params);
 		//开始分页
 //		int start = 0;//开始位置，从0行开始查询
@@ -206,17 +208,20 @@ public class OriginalTask {
 		int i=1;
 		while(faultPages>0){
 			System.out.println(start + "————————————————————————————————————————" + pageSize);
-			String sql = "SELECT fa_id,fa_work_order_no,fa_state_grid_work_order_no,fa_state,"
-						+ 	"fa_business_type,fa_current_steps,fa_acceptance_personnel,"
-						+ 	"date_format(fa_acceptance_time, '%Y-%c-%e %T') as fa_acceptance_time,fa_acceptance_content,fa_user_number,"
-						+ 	"fa_user_name,fa_contact_address,fa_contact_number,"
-						+ 	"fa_content_of_return_visit,fa_primary_classification,fa_secondary_classification,"
-						+ 	"fa_superior_units,fa_power_supply_unit,fa_meter_reading_section,"
-						+ 	"fa_processing_results,fa_processing_department,fa_associated_work_order,"
-						+ 	"fa_responsible_department,fa_service_channels "
-						+ "from fault_work_order "
-						+ "where fa_acceptance_time LIKE ? "
-						+ "ORDER BY fa_id DESC "
+			String sql = "SELECT row_id,order_num,order_status,sg_order_num,"
+						+ 	"order_gnum,order_type,order_state,"
+						+ 	"order_oper_man,date_format(order_oper_time, '%Y-%m-%d %T') as order_oper_time,order_oper_ctx,"
+						+ 	"account_num,account_name,account_f_address,"
+						+ 	"account_l_address,account_phone,return_ctx,"
+						+ 	"level_1,level_2,bus_sub_level,"
+						+ 	"power_supply_unit,text_record_name,proc_ctx,"
+						+ 	"proc_unit,proc_dept,order_ship,"
+						+ 	"question_type,order_level,duty_dept,archive_time,order_oper_man,date_format(pause_time, '%Y-%m-%d %T') as pause_time"
+						+ 	"pause_cause,check_level,service_channel,p_return_cause,"
+						+ 	"extend_1,extend_2,extend_3 "
+						+ 	"from order_info "
+						+ "where date_format(order_oper_time, '%Y-%m-%d')=? "
+						+ "ORDER BY row_id DESC "
 						+ "limit "+start+","+ pageSize;
 			List<Map<String, Object>> resList = newJdbc.findModeResult(sql, params);
 			
@@ -225,8 +230,8 @@ public class OriginalTask {
 				//95598工单故障类型表导入数据
 				String fileDetailId = db.getMybatisMapper(SequenceMapper.class).getSequence("FILE_DETAIL_05_NO");
 				List<Object> params1 = new ArrayList<Object>();
-				String slsjDate = map.get("fa_acceptance_time")+"";
-				String slsjArray[] = slsjDate.split(" ");
+//				String slsjDate = map.get("order_oper_time")+"";
+//				String slsjArray[] = slsjDate.split(" ");
 				//id
 				params1.add(fileDetailId);	
 				//文件编号
@@ -234,67 +239,67 @@ public class OriginalTask {
 				//文件id
 				params1.add(fileId);
 				//工单编号
-				params1.add(map.get("fa_work_order_no"));
+				params1.add(map.get("order_num"));
 				//国网工单编号
-				params1.add(map.get("fa_state_grid_work_order_no"));
+				params1.add(map.get("sg_order_num"));
 				//状态
-				params1.add(map.get("fa_state"));
+				params1.add(map.get("order_status"));
 				//业务类型
-				params1.add(map.get("fa_business_type"));
+				params1.add(map.get("order_type"));
 				//当前步骤
-				params1.add(map.get("fa_current_steps"));
+				params1.add(map.get("order_state"));
 				//受理人员
-				params1.add(map.get("fa_acceptance_personnel"));
+				params1.add(map.get("order_oper_man"));
 				//受理时间
-				params1.add(slsjArray[0]);
+				params1.add(map.get("order_oper_time"));
 				//受理内容
-				params1.add(map.get("fa_acceptance_content"));
+				params1.add(map.get("order_oper_ctx"));
 				//用户编号
-				params1.add(map.get("fa_user_number"));
+				params1.add(map.get("account_num"));
 				//用户名称
-				params1.add(map.get("fa_user_name"));
+				params1.add(map.get("account_name"));
 				//联系地址
-				params1.add(map.get("fa_contact_address"));
+				params1.add(map.get("account_l_address"));
 				//联系电话
-				params1.add(map.get("fa_contact_number"));
+				params1.add(map.get("account_phone"));
 				//回访内容
-				params1.add(map.get("fa_content_of_return_visit"));
+				params1.add(map.get("return_ctx"));
 				//一级分类
-				params1.add(map.get("fa_primary_classification"));
+				params1.add(map.get("level_1"));
 				//二级分类
-				params1.add(map.get("fa_secondary_classification"));
+				params1.add(map.get("level_2"));
 				//业务子类 及 三级分类 
-				params1.add(map.get("fa_three_level_classification"));
-				//上级单位
-				params1.add(map.get("fa_superior_units"));
+				params1.add(map.get("bus_sub_level"));
+				//上级单位  ---
+				params1.add("");
 				//供电单位
-				params1.add(map.get("fa_power_supply_unit"));
+				params1.add(map.get("power_supply_unit"));
 				//抄表段
-				params1.add(map.get("fa_meter_reading_section"));
+				params1.add(map.get("text_record_name"));
 				//处理结果
-				params1.add(map.get("fa_processing_results"));
+				params1.add(map.get("proc_ctx"));
 				//处理单位   --
-				params1.add("");
+				params1.add(map.get("proc_unit"));
 				//处理部门
-				params1.add(map.get("fa_processing_department"));
+				params1.add(map.get("proc_dept"));
 				//关联工单
-				params1.add(map.get("fa_associated_work_order"));
+				params1.add(map.get("order_ship"));
 				//问题原因分类  --
-				params1.add("");
+				params1.add(map.get("question_type"));
 				//工单分级  --
-				params1.add("");
+				params1.add(map.get("order_level"));
 				//责任部门 
-				params1.add(map.get("fa_responsible_department"));
+				params1.add(map.get("duty_dept"));
 				//归档时间 --
-				params1.add("");
+				params1.add(map.get("archive_time"));
 				//挂起时间 --
-				params1.add("");
+				params1.add(map.get("pause_time"));
 				//挂起原因 --
-				params1.add("");
+				params1.add(map.get("pause_cause"));
 				//服务渠道
-				params1.add(map.get("fa_service_channels"));
+				params1.add(map.get("service_channel"));
 				//省级回退责任原因 -- 
-				params1.add("");
+				params1.add(map.get("p_return_cause"));
 				
 				boolean a = oldJdbc.updateByPreparedStatement(insertSql, params1);
 				if(a == true){
@@ -307,6 +312,110 @@ public class OriginalTask {
 			start+=pageSize;
 			faultPages--;
 		}
+		
+//		while(faultPages>0){
+//			System.out.println(start + "————————————————————————————————————————" + pageSize);
+//			String sql = "SELECT fa_id,fa_work_order_no,fa_state_grid_work_order_no,fa_state,"
+//						+ 	"fa_business_type,fa_current_steps,fa_acceptance_personnel,"
+//						+ 	"date_format(fa_acceptance_time, '%Y-%c-%e %T') as fa_acceptance_time,fa_acceptance_content,fa_user_number,"
+//						+ 	"fa_user_name,fa_contact_address,fa_contact_number,"
+//						+ 	"fa_content_of_return_visit,fa_primary_classification,fa_secondary_classification,"
+//						+ 	"fa_superior_units,fa_power_supply_unit,fa_meter_reading_section,"
+//						+ 	"fa_processing_results,fa_processing_department,fa_associated_work_order,"
+//						+ 	"fa_responsible_department,fa_service_channels "
+//						+ "from fault_work_order "
+//						+ "where fa_acceptance_time LIKE ? "
+//						+ "ORDER BY fa_id DESC "
+//						+ "limit "+start+","+ pageSize;
+//			List<Map<String, Object>> resList = newJdbc.findModeResult(sql, params);
+//			
+//			//循环插入数据
+//			for(Map<String,Object> map:resList){
+//				//95598工单故障类型表导入数据
+//				String fileDetailId = db.getMybatisMapper(SequenceMapper.class).getSequence("FILE_DETAIL_05_NO");
+//				List<Object> params1 = new ArrayList<Object>();
+//				String slsjDate = map.get("fa_acceptance_time")+"";
+//				String slsjArray[] = slsjDate.split(" ");
+//				//id
+//				params1.add(fileDetailId);	
+//				//文件编号
+//				params1.add(i);
+//				//文件id
+//				params1.add(fileId);
+//				//工单编号
+//				params1.add(map.get("fa_work_order_no"));
+//				//国网工单编号
+//				params1.add(map.get("fa_state_grid_work_order_no"));
+//				//状态
+//				params1.add(map.get("fa_state"));
+//				//业务类型
+//				params1.add(map.get("fa_business_type"));
+//				//当前步骤
+//				params1.add(map.get("fa_current_steps"));
+//				//受理人员
+//				params1.add(map.get("fa_acceptance_personnel"));
+//				//受理时间
+//				params1.add(slsjArray[0]);
+//				//受理内容
+//				params1.add(map.get("fa_acceptance_content"));
+//				//用户编号
+//				params1.add(map.get("fa_user_number"));
+//				//用户名称
+//				params1.add(map.get("fa_user_name"));
+//				//联系地址
+//				params1.add(map.get("fa_contact_address"));
+//				//联系电话
+//				params1.add(map.get("fa_contact_number"));
+//				//回访内容
+//				params1.add(map.get("fa_content_of_return_visit"));
+//				//一级分类
+//				params1.add(map.get("fa_primary_classification"));
+//				//二级分类
+//				params1.add(map.get("fa_secondary_classification"));
+//				//业务子类 及 三级分类 
+//				params1.add(map.get("fa_three_level_classification"));
+//				//上级单位
+//				params1.add(map.get("fa_superior_units"));
+//				//供电单位
+//				params1.add(map.get("fa_power_supply_unit"));
+//				//抄表段
+//				params1.add(map.get("fa_meter_reading_section"));
+//				//处理结果
+//				params1.add(map.get("fa_processing_results"));
+//				//处理单位   --
+//				params1.add("");
+//				//处理部门
+//				params1.add(map.get("fa_processing_department"));
+//				//关联工单
+//				params1.add(map.get("fa_associated_work_order"));
+//				//问题原因分类  --
+//				params1.add("");
+//				//工单分级  --
+//				params1.add("");
+//				//责任部门 
+//				params1.add(map.get("fa_responsible_department"));
+//				//归档时间 --
+//				params1.add("");
+//				//挂起时间 --
+//				params1.add("");
+//				//挂起原因 --
+//				params1.add("");
+//				//服务渠道
+//				params1.add(map.get("fa_service_channels"));
+//				//省级回退责任原因 -- 
+//				params1.add("");
+//				
+//				boolean a = oldJdbc.updateByPreparedStatement(insertSql, params1);
+//				if(a == true){
+//					System.out.println("95598工单 故障类型数据插入：" + params1 + "	数量：" + (i) +"	原主键："+map.get("fa_id"));
+//				}else{
+//					System.out.println("!!!!!!!!!!!!————出现异常————!!!!!!!!!!!!");
+//				}
+//				i++;
+//			}
+//			start+=pageSize;
+//			faultPages--;
+//		}
 			oldJdbc.releaseConn();
 			newJdbc.releaseConn();
 			int numrows = faultNumrows;
@@ -315,59 +424,6 @@ public class OriginalTask {
 		
 	}
 	/**
-	 * 文件表插入公共方法
-	 * @param fileId  	文件id
-	 * @param number	数据总条数
-	 * @param type		数据类型
-	 * @param fileName	文件名称
-	 * @throws SQLException
-	 * @throws ParseException
-	 */
-	public static void fileCreate(String fileId,int number,String type,String fileName)  throws SQLException, ParseException {
-		//当前报表库
-		System.out.println("<----------------文件表插入开始 类型:"+type+"--------->");
-		OldDBJdbcUtils oldJdbc = new OldDBJdbcUtils();
-		oldJdbc.getConnection();
-		//插入语句
-		String insertSql = "insert into dw_file_inf ("
-				+ "DFI_ID,DFI_UPLOAD_DATE,DFI_FILE_NAME,DFI_BRANCH,DFI_CREAT_USER,"
-				+ "DFI_DATA_NUM,DFI_TYPE,DFI_STATE)"
-				+ "values ("
-				+ "?,?,?,?,?,"
-				+ "?,?,?)";
-		List<Object> params = new ArrayList<Object>();
-		//当前日期
-		String date = DateUtil.getCurrentDateString();
-		//昨日日期
-		String yesterday = DateUtil.yesterday();
-		
-		//id
-		params.add(fileId);	
-		//导入日期
-		params.add(date);
-		//文件名称
-		params.add(fileName+"_"+yesterday);
-		//默认机构
-		params.add("88888888");
-		//默认管理员导入
-		params.add("10000000");	
-		//数据条数
-		params.add(number);	
-		//类型
-		params.add(type);		
-		//状态
-		params.add("0");
-		boolean a = oldJdbc.updateByPreparedStatement(insertSql, params);
-		if(a == true){
-			System.out.println("文件表插入：" + params + "主键："+fileId);
-		}else{
-			System.out.println("!!!!!!!!!!!!————出现异常————!!!!!!!!!!!!");
-		}
-		oldJdbc.releaseConn();
-		System.out.println("<----------------文件表插入结束 类型:"+type+"--------->");
-	}
-	
-	/**
 	 * 低电压导入
 	 * @param start
 	 * @param pageSize
@@ -387,7 +443,7 @@ public class OriginalTask {
 		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 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();
 		//查询昨日数据
@@ -418,7 +474,7 @@ public class OriginalTask {
 						+ 	"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') = ? "
+						+ "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);
@@ -488,6 +544,193 @@ public class OriginalTask {
 		newJdbc.releaseConn();
 		fileCreate(fileId,numrows,"1000004","低电压明细");
 		//递归处理分页
-		System.out.println("<----------------电网台区停电数据导入结束--------->");
+		System.out.println("<----------------电网低电压数据导入结束--------->");
 	}
+	/**
+	 * 过电压导入
+	 * @param start
+	 * @param pageSize
+	 * @throws SQLException
+	 * @throws MINBusinessException
+	 * @throws ParseException
+	 */
+	public static void gdyData(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_over_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);
+		params.add("2021-01-02");
+		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_04 ("
+				+ "DFD4_ID,DFD4_NO,DFD4_SGSMC,DFD4_XGSMC,DFD4_BDZMC,"
+				+ "DFD4_XLMC,DFD4_TQID,DFD4_BYQMC,"
+				+ "DFD4_YHGLDW1,DFD4_YHID,DFD4_YHMC,"
+				+ "DFD4_YHGLDW2,DFD4_DYMAX,DFD4_DYMIN,DFD4_DYHGL,"
+				+ "DFD4_CSXL,DFD4_CXXL,DFD4_GDYSC,DFD4_GDLX,DFD4_LJTS,"
+				+ "DFD4_SJRQ,DFD4_GDDW,DFD4_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_over_date,"
+						+ "power_supply_type,total_days,date_format(record_date, '%Y%m%d') as record_date,power_supply_unit "
+						+ "FROM power_over_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_04_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_over_date =  map.get("voltage_over_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_over_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,"1000005","过电压明细");
+		//递归处理分页
+		System.out.println("<----------------电网过电压数据导入结束--------->");
+	}
+	/**
+	 * 文件表插入公共方法
+	 * @param fileId  	文件id
+	 * @param number	数据总条数
+	 * @param type		数据类型
+	 * @param fileName	文件名称
+	 * @throws SQLException
+	 * @throws ParseException
+	 */
+	public static void fileCreate(String fileId,int number,String type,String fileName)  throws SQLException, ParseException {
+		//当前报表库
+		System.out.println("<----------------文件表插入开始 类型:"+type+"--------->");
+		OldDBJdbcUtils oldJdbc = new OldDBJdbcUtils();
+		oldJdbc.getConnection();
+		//插入语句
+		String insertSql = "insert into dw_file_inf ("
+				+ "DFI_ID,DFI_UPLOAD_DATE,DFI_FILE_NAME,DFI_BRANCH,DFI_CREAT_USER,"
+				+ "DFI_DATA_NUM,DFI_TYPE,DFI_STATE)"
+				+ "values ("
+				+ "?,?,?,?,?,"
+				+ "?,?,?)";
+		List<Object> params = new ArrayList<Object>();
+		//当前日期
+		String date = DateUtil.getCurrentDateString();
+		//昨日日期
+		String yesterday = DateUtil.yesterday();
+		
+		//id
+		params.add(fileId);	
+		//导入日期
+		params.add(date);
+		//文件名称
+		params.add(fileName+"_"+yesterday);
+		//默认机构
+		params.add("88888888");
+		//默认管理员导入
+		params.add("10000000");	
+		//数据条数
+		params.add(number);	
+		//类型
+		params.add(type);		
+		//状态
+		params.add("0");
+		boolean a = oldJdbc.updateByPreparedStatement(insertSql, params);
+		if(a == true){
+			System.out.println("文件表插入：" + params + "主键："+fileId);
+		}else{
+			System.out.println("!!!!!!!!!!!!————出现异常————!!!!!!!!!!!!");
+		}
+		oldJdbc.releaseConn();
+		System.out.println("<----------------文件表插入结束 类型:"+type+"--------->");
+	}
+	
+	
+	
+	
 }

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

@@ -28,6 +28,8 @@ public class RunOfflineService {
 		OriginalTask.workOrderData(0,500);
 		// 低电压
 		OriginalTask.ddyData(0,500);
+		// 过电压
+		OriginalTask.gdyData(0,500);
 		Log.info("跑批任务结束...._-------------");
 	}
 }