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> records = Db.use("connected").find("select * from v_webpacs_study where STUDY_DATE>to_date('" + parseStringToDate()+ "','yyyy-mm-dd hh24:mi:ss') and MODALITY!='US' and MODALITY!='XA' order by STUDY_DATE desc");
		for (Record record : records) {
			Record studyidfind = Db.use("connectedtemp").findFirst("select * from study where studyid = ?",record.getStr("STUDYID"));
			if (studyidfind == null) {
				Record studyinfo = new Record().set("studyid", record.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() - 3600000;
		String daString = sdf.format(new Date(dInteger));
		return daString;

	}
}