Newer
Older
pgdsc / src / com / szpg / task / ReadAssetInSpectionTask.java
xiaowei on 23 Nov 2018 1 KB 增加巡检运维数据同步
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;
    }

}