data_fusion/DataFusion/src/com/zskk/task/InsertTask.java

package com.zskk.task;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

import com.jfinal.plugin.activerecord.Db;
import com.jfinal.plugin.activerecord.Record;
import com.jfinal.plugin.cron4j.ITask;

import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;

public class InsertTask implements ITask {

    private static final OkHttpClient OKHTTP_CLIENT = new OkHttpClient();

	@Override
	public void run() {
		// TODO Auto-generated method stub
		List<Record> record = Db.use("connected").find("select * from v_webpacs_study where STUDY_DATE>to_date('"+parseStringToDate()+"','yyyy-mm-dd hh24:mi:ss') order by STUDY_DATE desc");
		for (Record record2 : record) {
		Record studyinfo = new Record().set("studyid", record2.getStr("STUDYID")).set("status", "1").set("createAt", new Date());
		Db.use("connectedtemp").save("study", studyinfo);
		}
	}

	@Override
	public void stop() {
		// TODO Auto-generated method stub

	}

	/**
	 * 日期字符串格式转换
	 * @param dateStr
	 * @return
	 */
	private String parseStringToDate() {
		SimpleDateFormat sdf= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
	    Date date = new Date();
	    long dInteger =date.getTime()-360000;
		String daString = sdf.format(new Date(dInteger));
	    return daString;
		
	}
}