package com.szpg.task; import com.szpg.db.dao.PgAssetInSpectionDao; import com.szpg.db.dao.impl.PgAssetInSpectionImpl; import com.szpg.db.data.PgAssetInSpection; import com.szpg.db.data.PgAssetJson; import com.szpg.util.HttpRequest; import net.sf.json.JSONObject; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List; public class ReadAssetInSpectionTask implements Runnable{ final String tableName="V_ASSET_INSPECTION_RECORD"; final String url="http://10.10.2.31:9056/GLYW/api/Common/LoadIndexData"; @Override public void run(){ PgAssetInSpectionDao pgAssetInSpectionDao=new PgAssetInSpectionImpl(); SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String startTime=pgAssetInSpectionDao.findLastRecordTime();//上次同步数据最后记录时间 String endTime= dateFormat.format(new Date());//当前时间 StringBuilder sb = new StringBuilder(); sb.append("tableName = ").append(tableName); sb.append("&page=-1"); sb.append("&strWhere=采集时间"); sb.append("&between '").append(startTime); sb.append("' and '").append(endTime); sb.append("' order by 采集时间"); String jsonStr = HttpRequest.sendPostByHttp(url, sb.toString()); PgAssetJson pgAssetJson=getAssetJsonByJsonString(jsonStr); List<PgAssetInSpection> pgAssetInSpectionList=pgAssetJson.getRows(); pgAssetInSpectionDao.addAssetInSpectionRecord(pgAssetInSpectionList); } private PgAssetJson getAssetJsonByJsonString(String jsonStr){ JSONObject jsonObject=JSONObject.fromObject(jsonStr); PgAssetJson pgAssetJson=(PgAssetJson)JSONObject.toBean(jsonObject, PgAssetJson.class); return pgAssetJson; } }