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

package com.zskk.task;

import java.util.List;

import com.jfinal.plugin.activerecord.Db;
import com.jfinal.plugin.activerecord.Record;
import com.jfinal.plugin.cron4j.ITask;
import com.zskk.model.Exams;

public class UpdateTask implements ITask {

	@Override
	public void run() {
		// TODO Auto-generated method stub
		List<Exams> exams = Exams.dao.use("zskk").find(
				"SELECT * FROM pacsonline.exams where exam_status=9 and institution_id=15700002 and hopitalized_no is null order by createdAt desc limit 50");
		for (Exams exams2 : exams) {
			try {
				Record record = Db.use("connected").findFirst("select * from zskk where accessionNumber=?",
						exams2.getPatientNum());
				if (record == null) {
					continue;
				}
				String patString = record.getStr("patientid");
				patString.replace(" ", "");
				exams2.setHopitalizedNo(patString);
				exams2.update();
			}catch (Exception e) {
				// TODO: handle exception
			}
		}

	}

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

	}

}