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

package com.zskk.task;

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 com.zskk.model.Reports;
import com.zskk.model.Studies;

public class DataTask implements ITask {

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

		List<Studies> studies = Studies.dao.use("zskk").find("select * from Studies where hospitalId = 74300001 order by createdAt desc limit 50");
		for (Studies studies2 : studies) {

			Reports reports = Reports.dao.use("zskk").findFirst("select * from Reports where hospitalNo=74300001 and studyuid=?",studies2.getStudyUid());
			if (reports == null) {
				Record record = Db.use("connected").findFirst("select * from yhxx where STUDYUID=?",studies2.getStudyUid());
				if (record == null ) {
					continue;
				}
				Reports newreport = new Reports().use("zskk");
				newreport.setTitle("定西市中医院");
				newreport.setSubtitle(record.getStr("modality")==null?"":record.getStr("modality") + "诊断报告单");
				newreport.setReportDoctor(record.getStr("reportdoctor")==null?"定西市中医院":record.getStr("reportdoctor"));
				newreport.setImpression(record.getStr("impression")==null?"暂未出具":record.getStr("impression"));
				newreport.setDescription(record.getStr("description")==null?"暂未出具":record.getStr("description"));
				newreport.setHospitalNo("74300001");
				newreport.setPatientName(record.getStr("patientName")==null?"无":record.getStr("patientName"));
				newreport.setExamClass(record.getStr("modality")==null?record.getStr("modality"):record.getStr("modality"));
				//newreport.setExamItem(record.getStr("FITEM_CH_NAME")==null?"无":record.getStr("FITEM_CH_NAME"));
				newreport.setStatus(1);
				newreport.setStudyuid(studies2.getStudyUid());
				newreport.setExamNo(record.getStr("patientID")==null?"无":record.getStr("patientID"));
				newreport.setStudyid(studies2.getAccessionNumber());
				newreport.setCreatedAt(new Date());
				newreport.setUpdatedAt(new Date());
				newreport.setStudyKey(studies2.getStudyKey());
				newreport.setDid(1);
				newreport.setPatientid(record.getStr("patientID")==null?"无":record.getStr("patientID"));
				newreport.setPatientSex(record.getStr("genderID")==null?"未设置":record.getStr("genderID"));
				newreport.setPatientAge(record.getStr("patientage"));
				newreport.setExamDateTime(record.getStr("reportDate")==null?"未设置":record.getStr("reportDate"));
				newreport.setReportDateTime(record.getStr("reportDate")==null?"未设置":record.getStr("reportDate"));
				newreport.setPhone(record.getStr("phone")==null?"未设置":record.getStr("phone"));
				newreport.save();
				studies2.setModality(record.getStr("modality")==null?record.getStr("modality"):record.getStr("modality"));
				studies2.update();
			}else {
				continue;
			}
		}
	}

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

	}

}