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

package com.zskk.task;

import com.alibaba.fastjson.JSON;
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.service.ServiceFactory;
import com.zskk.service.WeixinService;
import org.apache.commons.codec.digest.DigestUtils;

import java.io.*;
import java.net.URLEncoder;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;



public class DataTask 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=15700002 order by createdAt desc limit 30");
			for (Exams exams2 : exams) {
				//Studies studies = Studies.dao.use("zskk").findById(exams2.getStudyId());
				Record record = Db.use("connected").findFirst("select * from zskk where accessionNumber=?",exams2.getAccessionNum());
				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"));
				patientInfos.setCardNum(record.getStr("idcard"));
				patientInfos.update();
				exams2.setExamStatus(9);
                exams2.setClinDoctors(record.getStr("clinicaldoctor"));
                exams2.setApplicationDepartment(record.getStr("department"));
                exams2.setApplicationDoctor(record.getStr("clinicaldoctor"));
                exams2.setClinDiag(record.getStr("diagnosis"));
				exams2.update();
				//传云医康 数据
                Map<String, String> params = new HashMap<>(10);
                Map<String, String> data = new HashMap<>(22);
                //获取data数据
                //医院id
                data.put("hospital_id","15700002");
                //影像所见
                data.put("description",record.getStr("DESCRIPTION"));
                //意见建议
                data.put("impression",record.getStr("impression"));
                //检查id
                data.put("exam_id",exams2.getId());
                //患者id
                data.put("patient_id",exams2.getPatientId());
                //患者姓名
                data.put("patient_name",record.getStr("patientname"));
                //患者性别
                data.put("patient_sex",record.getStr("patientsex"));
                //身份证号
                data.put("card_num",record.getStr("idcard"));
                //手机号
                data.put("phone",record.getStr("phone"));
                //患者生日
                data.put("birthday",record.getStr("birthdate"));
                //患者检查时年龄
                data.put("patient_age",record.getStr("patientage"));
                //阴阳性 1阴性 2阳性
                //data.put("report_result","");
                //报告时间 10位时间戳
                data.put("report_datetime",returnSecondTimestamp(record.getStr("reportdate")));
                //报告医生id
                //data.put("report_doctor_id",);
                //报告医生姓名
                data.put("report_doctor_name",record.getStr("reportdoctor"));
                //审核时间
                data.put("review_datetime",returnSecondTimestamp(record.getStr("reportdate")));
                //审核医生id
                //data.put("review_doctor_id",);
                //审核姓名
                data.put("review_doctor_name",record.getStr("reviewdoctor"));
                //确认时间
                data.put("confirm_datetime", returnSecondTimestamp(record.getStr("reportdate")));
                //确认医生id
                //data.put("confirm_doctor_id", );
                //确认医生姓名
                data.put("confirm_doctor_name",record.getStr("clinicaldoctor"));
                //时间戳
                params.put("timestamp", String.valueOf(getSecondTimestamp(new Date())));
                //signature
                params.put("signature", getSign(data, "YgpxjVeIx0yoK6Atz413IAj7hU9dygH4"));
                //datajson字符串
                params.put("data", JSON.toJSONString(data));
                System.out.println(params);
                //调用接口
                sendPost("https://pacs.yunyikang.cn/pacs/zskk/writePatientReport", params);
				WeixinService wService = ServiceFactory.getService(WeixinService.class);
				wService.requestWeixinQrcode(report.getId());;
			}
		} catch (Exception e) {
			// TODO: handle exception
		}
		
	}

    /**
     *
     * 功能描述: 获取当前时间戳(秒)
     *
     * @param: [date]
     * @return: int
     * @auther: zzp
     * @date: 2019/12/26 18:26
     */
    public String getSecondTimestamp(Date date) {
        if (null == date) {
            return "参数为空";
        }
        String timestamp = String.valueOf(date.getTime());
        int length = timestamp.length();
        if (length > 3) {
            return String.valueOf(timestamp.substring(0, length - 3));
        } else {
            return "参数不足3位数";
        }
    }
    /**
     *
     * 功能描述: 对数组的值按key排序,生成url的形式(http_build_query)
     *
     * @param: [map]
     * @return: java.lang.String
     * @auther: zzp
     * @date: 2019/12/26 19:21
     */
    public  String Ksort(Map<String, String> map) {
        String sb = "";
        String[] key = new String[map.size()];
        int index = 0;
        for (String k : map.keySet()) {
            key[index] = k;
            index++;
        }
        Arrays.sort(key);
        for (String s : key) {
            sb += s + "=" + map.get(s) + "&";
        }
        sb = sb.substring(0, sb.length() - 1);
        try {
            sb = URLEncoder.encode(sb, "UTF-8");
        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        }// 使用常见的UTF-8编码
        return sb.replace("%3D", "=").replace("%26", "&");
    }
    /**
     *
     * 功能描述:生成signature
     *
     * @param: [param, key]
     * @return: java.lang.String
     * @auther: zzp
     * @date: 2019/12/24 15:28
     */
    public  String getSign(Map<String, String> param, String key) {
        return DigestUtils.md5Hex(Ksort(param) + key);
    }
    /**
     *
     * 功能描述: 转时间戳(秒)
     *
     * @param:
     * @return:
     * @auther: zpp
     * @date: 2019/12/26 18:26
     */
    public  String returnSecondTimestamp(String data) throws ParseException {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        return String.valueOf(sdf.parse(data).getTime()/1000);
    }


    @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=15700002 and realname<>null",name);
		if (doctors == null) {
			Doctors newDoctors = new Doctors().use("zskk");
			newDoctors.setId(creatId());
			newDoctors.setUsername("none");
			newDoctors.setRealname(name);
			newDoctors.setPassword("123456");
			newDoctors.setInstitutionId("15700002");
			newDoctors.setCreatedAt(new Date());
			newDoctors.setUpdatedAt(new Date());
			newDoctors.save();
			return newDoctors.getId();
		}
		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;
	}

    /**
     * 发送POST请求
     *
     * @param url        目的地址
     * @param parameters 请求参数，Map类型。
     * @return 远程响应结果
     */
    public static String sendPost(String url, Map<String, String> parameters) {
        String result = "";// 返回的结果
        BufferedReader in = null;// 读取响应输入流
        PrintWriter out = null;
        StringBuffer sb = new StringBuffer();// 处理请求参数
        String params = "";// 编码之后的参数
        try {
            // 编码请求参数
            if (parameters.size() == 1) {
                for (String name : parameters.keySet()) {
                    sb.append(name).append("=").append(
                            java.net.URLEncoder.encode(parameters.get(name),
                                    "UTF-8"));
                }
                params = sb.toString();
            } else {
                for (String name : parameters.keySet()) {
                    sb.append(name).append("=").append(
                            java.net.URLEncoder.encode(parameters.get(name),
                                    "UTF-8")).append("&");
                }
                String temp_params = sb.toString();
                params = temp_params.substring(0, temp_params.length() - 1);
            }
            // 创建URL对象
            java.net.URL connURL = new java.net.URL(url);
            // 打开URL连接
            java.net.HttpURLConnection httpConn = (java.net.HttpURLConnection) connURL
                    .openConnection();
            // 设置通用属性
            httpConn.setRequestProperty("Accept", "*/*");
            httpConn.setRequestProperty("Connection", "Keep-Alive");
            httpConn.setRequestProperty("User-Agent",
                    "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.1)");
            // 设置POST方式
            httpConn.setDoInput(true);
            httpConn.setDoOutput(true);
            // 获取HttpURLConnection对象对应的输出流
            out = new PrintWriter(httpConn.getOutputStream());
            // 发送请求参数
            out.write(params);
            // flush输出流的缓冲
            out.flush();
            // 定义BufferedReader输入流来读取URL的响应，设置编码方式
            in = new BufferedReader(new InputStreamReader(httpConn
                    .getInputStream(), "UTF-8"));
            String line;
            // 读取返回的内容
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (in != null) {
                    in.close();
                }
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
        return result;
    }
	
}