package com.szpg.task;

import com.szpg.db.dao.PgMaintanceDao;
import com.szpg.db.dao.impl.PgMaintanceDaoImpl;
import com.szpg.db.data.PgMainJson;
import com.szpg.db.data.PgMaintance;
import com.szpg.util.HttpRequest;
import net.sf.json.JSONObject;

import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

public class ReadMaintanceTask implements Runnable{

    final String tableName="V_MaintanceRecord_Head";
    final String url="http://10.10.2.31:9056/GLYW/api/Common/LoadIndexData";

    @Override
    public void run(){
        PgMaintanceDao pgMaintanceDao=new PgMaintanceDaoImpl();
        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        String startTime=pgMaintanceDao.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());

        PgMainJson pgMainJson=getMintanceJsonByJsonString(jsonStr);
        List<PgMaintance> pgMaintanceList=pgMainJson.getRows();
        pgMaintanceDao.addMaintanceRecord(pgMaintanceList);
    }

    private PgMainJson getMintanceJsonByJsonString(String jsonStr){
        JSONObject jsonObject=JSONObject.fromObject(jsonStr);
        PgMainJson pgMainJson=(PgMainJson)JSONObject.toBean(jsonObject, PgMainJson.class);

        return pgMainJson;
    }

}