diff --git a/src/com/szpg/task/ReadAssetInSpectionTask.java b/src/com/szpg/task/ReadAssetInSpectionTask.java index f5fa62c..1389e0d 100644 --- a/src/com/szpg/task/ReadAssetInSpectionTask.java +++ b/src/com/szpg/task/ReadAssetInSpectionTask.java @@ -8,13 +8,16 @@ import com.szpg.db.data.PgAssetJson; import com.szpg.util.HttpRequest; +import java.io.FileWriter; +import java.io.IOException; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Date; import java.util.List; +import java.util.logging.Logger; public class ReadAssetInSpectionTask implements Runnable{ - + private final Logger logger = Logger.getLogger(this.getClass().getName()); final String tableName="V_ASSET_INSPECTION_RECORD"; final String url="http://10.10.2.31:9056/GLYW/api/Common/LoadIndexData"; SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); @@ -25,20 +28,46 @@ String startTime=pgAssetInSpectionDao.findLastRecordTime();//上次同步数据最后记录时间 String endTime= dateFormat.format(new Date());//当前时间 + if(startTime==null) startTime=getYestodayStr(); StringBuilder sb = new StringBuilder(); sb.append("tableName = ").append(tableName); sb.append("&page=-1"); - sb.append("&strWhere=采集时间"); - sb.append("&between '").append(startTime); + sb.append("&CREATE_DATE=采集时间"); + sb.append(" between '").append(startTime); sb.append("' and '").append(endTime); - sb.append("' order by 采集时间"); + sb.append("'"); + logger.info("开始请求巡检数据"); String jsonStr = HttpRequest.sendPostByHttp(url, sb.toString()); + saveAsFileWriter(jsonStr); + if (jsonStr.equals("")) + logger.info("巡检数据请求失败"); + else { + insertDB(pgAssetInSpectionDao, jsonStr); + logger.info("巡检数据存储成功"); + } + } - insertDB(pgAssetInSpectionDao,jsonStr); + private String savefile = "D:\\test.txt"; + private void saveAsFileWriter(String content) { + + FileWriter fwriter = null; + try { + fwriter = new FileWriter(savefile); + fwriter.write(content); + } catch (IOException ex) { + ex.printStackTrace(); + } finally { + try { + fwriter.flush(); + fwriter.close(); + } catch (IOException ex) { + ex.printStackTrace(); + } + } } public void insertDB(PgAssetInSpectionDao pgAssetInSpectionDao,String jsonStr) diff --git a/src/com/szpg/task/ReadAssetInSpectionTask.java b/src/com/szpg/task/ReadAssetInSpectionTask.java index f5fa62c..1389e0d 100644 --- a/src/com/szpg/task/ReadAssetInSpectionTask.java +++ b/src/com/szpg/task/ReadAssetInSpectionTask.java @@ -8,13 +8,16 @@ import com.szpg.db.data.PgAssetJson; import com.szpg.util.HttpRequest; +import java.io.FileWriter; +import java.io.IOException; import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Date; import java.util.List; +import java.util.logging.Logger; public class ReadAssetInSpectionTask implements Runnable{ - + private final Logger logger = Logger.getLogger(this.getClass().getName()); final String tableName="V_ASSET_INSPECTION_RECORD"; final String url="http://10.10.2.31:9056/GLYW/api/Common/LoadIndexData"; SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); @@ -25,20 +28,46 @@ String startTime=pgAssetInSpectionDao.findLastRecordTime();//上次同步数据最后记录时间 String endTime= dateFormat.format(new Date());//当前时间 + if(startTime==null) startTime=getYestodayStr(); StringBuilder sb = new StringBuilder(); sb.append("tableName = ").append(tableName); sb.append("&page=-1"); - sb.append("&strWhere=采集时间"); - sb.append("&between '").append(startTime); + sb.append("&CREATE_DATE=采集时间"); + sb.append(" between '").append(startTime); sb.append("' and '").append(endTime); - sb.append("' order by 采集时间"); + sb.append("'"); + logger.info("开始请求巡检数据"); String jsonStr = HttpRequest.sendPostByHttp(url, sb.toString()); + saveAsFileWriter(jsonStr); + if (jsonStr.equals("")) + logger.info("巡检数据请求失败"); + else { + insertDB(pgAssetInSpectionDao, jsonStr); + logger.info("巡检数据存储成功"); + } + } - insertDB(pgAssetInSpectionDao,jsonStr); + private String savefile = "D:\\test.txt"; + private void saveAsFileWriter(String content) { + + FileWriter fwriter = null; + try { + fwriter = new FileWriter(savefile); + fwriter.write(content); + } catch (IOException ex) { + ex.printStackTrace(); + } finally { + try { + fwriter.flush(); + fwriter.close(); + } catch (IOException ex) { + ex.printStackTrace(); + } + } } public void insertDB(PgAssetInSpectionDao pgAssetInSpectionDao,String jsonStr) diff --git a/src/com/szpg/task/ReadMaintanceTask.java b/src/com/szpg/task/ReadMaintanceTask.java index a2daaa3..1e7c811 100644 --- a/src/com/szpg/task/ReadMaintanceTask.java +++ b/src/com/szpg/task/ReadMaintanceTask.java @@ -8,12 +8,15 @@ import com.szpg.db.data.PgMaintance; import com.szpg.util.HttpRequest; +import java.io.FileWriter; +import java.io.IOException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; +import java.util.logging.Logger; public class ReadMaintanceTask implements Runnable{ - + private final Logger logger = Logger.getLogger(this.getClass().getName()); final String tableName="V_MaintanceRecord_Head"; final String url="http://10.10.2.31:9056/GLYW/api/Common/LoadIndexData"; SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); @@ -26,20 +29,45 @@ String startTime=pgMaintanceDao.findLastRecordTime();//上次同步数据最后记录时间 String endTime= dateFormat.format(date);//当前时间 - if(startTime==null) + if(startTime==null) startTime=new ReadAssetInSpectionTask().getYestodayStr(); StringBuilder sb = new StringBuilder(); sb.append("tableName = ").append(tableName); sb.append("&page=-1"); sb.append("&strWhere=采集时间"); - sb.append("&between '").append(startTime); + sb.append(" between '").append(startTime); sb.append("' and '").append(endTime); - sb.append("' order by 采集时间"); + sb.append("'"); + logger.info("开始请求维护数据"); String jsonStr = HttpRequest.sendPostByHttp(url, sb.toString()); + saveAsFileWriter(jsonStr); + if(jsonStr.equals("")) + logger.info("维护数据请求失败"); + else { + insertDB(pgMaintanceDao, jsonStr); + logger.info("维护数据存储成功"); + } + } - insertDB(pgMaintanceDao,jsonStr); + private String savefile = "D:\\test1.txt"; + private void saveAsFileWriter(String content) { + + FileWriter fwriter = null; + try { + fwriter = new FileWriter(savefile); + fwriter.write(content); + } catch (IOException ex) { + ex.printStackTrace(); + } finally { + try { + fwriter.flush(); + fwriter.close(); + } catch (IOException ex) { + ex.printStackTrace(); + } + } } public void insertDB(PgMaintanceDao pgMaintanceDao,String jsonStr){