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

package com.zskk.task;

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

import com.jfinal.plugin.activerecord.Db;
import com.jfinal.plugin.activerecord.Record;
import com.jfinal.plugin.cron4j.ITask;
import com.zskk.model.Doctors;
import com.zskk.model.Exams;
import com.zskk.model.PatientInfos;
import com.zskk.model.Report;
import com.zskk.model.Studies;
import com.zskk.service.ServiceFactory;
import com.zskk.service.WeixinService;

public class UpdateTask implements ITask {

	@Override
	public void run() {
		// TODO Auto-generated method stub
				try {
					List<Exams> exams = Exams.dao.use("zskk").find("SELECT * FROM pacsonline.exams where exam_status=3 and institution_id=51000001 order by createdAt desc limit 50");
					for (Exams exams2 : exams) {
						try {
						Studies studies = Studies.dao.use("zskk").findById(exams2.getStudyId());
						Record record = Db.use("connected2").findFirst("select * from reportinfo where STUDYUID=?",studies.getStudyuid());
						if (record == null) {
							continue;
						}
						Report report = new Report().use("zskk");
						report.setId(creatId());
						report.setReportDatetime(parseStringToDate(record.getStr("REPORTDATE")));
						if (record.getStr("IMPRESSION") == null && record.getStr("DESCRIPTION") == null) {
							continue;
						}
						report.setImpression(record.getStr("IMPRESSION"));
						report.setDescription(record.getStr("DESCRIPTION"));
						report.setExamId(exams2.getId());
						report.setCreatedAt(new Date());
						report.setReportDoctorId(getDoctorIdByName(record.getStr("REPORTDOCTOR")));
						report.setReviewDoctorId(getDoctorIdByName(record.getStr("REVIEWDOCTOR")));
						report.setReviewDatetime(parseStringToDate(record.getStr("REPORTDATE")));
						report.setConfirmDoctorId(getDoctorIdByName(record.getStr("REVIEWDOCTOR")));
						report.setConfirmDatetime(parseStringToDate(record.getStr("REPORTDATE")));
						report.save();
						PatientInfos patientInfos = PatientInfos.dao.use("zskk").findById(exams2.getPatientId());
						patientInfos.setName(record.getStr("PATIENTNAME"));
						patientInfos.setPhone(record.getStr("PHONE")==null?"":record.getStr("PHONE"));
						patientInfos.setCardNum(record.getStr("IDCARD")==null?"":record.getStr("IDCARD"));
						patientInfos.update();
						exams2.setApplicationDepartment(record.getStr("DEPARTMENT"));
						exams2.setApplicationDoctor(record.getStr("CLINICALDOCTOR"));
						exams2.setExamStatus(9);
						exams2.update();
						WeixinService wService = ServiceFactory.getService(WeixinService.class);
						wService.requestWeixinQrcode(report.getId());
						} catch (Exception e) {
							// TODO: handle exception
							continue;
						}
					}
				} catch (Exception e) {
					// TODO: handle exception
				}

	}

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

	}
	
	private String creatId() {
		UUID id=UUID.randomUUID();
        String[] idd = id.toString().split("-");
        return idd[0]+idd[1]+idd[2];
	}
	
	private String getDoctorIdByName(String name) {
		if (name == null) {
			return null;
		}
		Doctors doctors = Doctors.dao.use("zskk").findFirst("SELECT * FROM doctors where instr(?,realname) and institution_id=51000001",name);
		if (doctors == null) {
			return null;
		}
		return doctors.getId();
	}
	
	private Date parseStringToDate(String dateStr) {
		if (dateStr == null) {
			return new Date();
		}
		SimpleDateFormat sdf= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
	    Date date = null;
		try {
			date = sdf.parse(dateStr);
		} catch (ParseException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
        return date;
	}

}