data_fusion/DataFusion/src/com/zskk/control/ViewController.java

package com.zskk.control;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.jfinal.core.Controller;
import com.jfinal.kit.HashKit;
import com.jfinal.kit.PropKit;
import com.jfinal.plugin.activerecord.ActiveRecordPlugin;
import com.jfinal.plugin.activerecord.Db;
import com.jfinal.plugin.activerecord.Record;
import com.jfinal.plugin.activerecord.dialect.MysqlDialect;
import com.jfinal.plugin.activerecord.dialect.OracleDialect;
import com.jfinal.plugin.activerecord.dialect.SqlServerDialect;
import com.jfinal.plugin.druid.DruidPlugin;
import com.jfinal.plugin.redis.RedisPlugin;
import com.zskk.model.*;

import okhttp3.FormBody;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;

import org.apache.commons.codec.digest.DigestUtils;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;

public class ViewController extends Controller {
	private static final OkHttpClient OKHTTP_CLIENT = new OkHttpClient();

//	static{
//		PropKit.use("config.properties");
//		DruidPlugin plugin = new DruidPlugin(PropKit.get("jdbcUrl_zskk"), PropKit.get("user_zskk"), PropKit.get("password_zskk").trim());
//		ActiveRecordPlugin arp = new ActiveRecordPlugin(plugin); 		
//		_MappingKit.mapping(arp);
//		plugin.start();
//		arp.start();
//
//	}
	
	/**
	 * 在被连接数据库执行sql语句
	 */
	public void executeSql() {
		try {
			List<Record>  d =  Db.use("connected").find("select top 5 * from reportinfo");
			this.renderJson(d);
		} catch (Exception e) {
			// TODO: handle exception
			
			this.renderText(e.toString());
		}
	}
	
	public void executeSql2() {
		try {
			String sqlString = this.getPara("str");
			List<Record>  d =  Db.use("connected").find(sqlString);
			this.renderJson(d);
		} catch (Exception e) {
			// TODO: handle exception
			this.renderText(e.toString());
		}
	}
	
	public void executeSql3() {
		try {
			DruidPlugin druidPluginConnected = createConnectedDruidPlugin();
            druidPluginConnected.start();
			// 配置ActiveRecord插件
			ActiveRecordPlugin arpConnected = new ActiveRecordPlugin("connected", druidPluginConnected);
			arpConnected.setDialect(new SqlServerDialect());
			arpConnected.start();

		} catch (Exception e) {
			// TODO: handle exception
			this.renderText(e.toString());
		}
	}
	public static DruidPlugin createConnectedDruidPlugin() {

		return new DruidPlugin(PropKit.get("jdbcUrl_connected"), PropKit.get("user_connected"),PropKit.get("password_connected").trim());
	}
	public static DruidPlugin createZskkDruidPlugin() {

		return new DruidPlugin("jdbc:mysql://47.104.6.21:3306/pacsonline?characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=false", "pacs","ZSKK@2017~!@#");
	}
	public static void testTask() {

		try {
			String string = "here";
			String jString = "{\"birthdate\":\"1976-04-21 00:00:00\",\"modality\":\"MR\",\"patientid\":\"030419456\",\"patientsex\":\"女\",\"reportPaperNum\":740386,\"reportdate\":\"2020-01-08 16:13:06\",\"diagnosis\":\"上颌骨恶性肿瘤\",\"accessionNumber\":\"17822\",\"patientname\":\"王晓艳\",\"symptom\":\"上颌骨恶性肿瘤\",\"clinicaldoctor\":\"周宏\",\"phone\":\"13836302692\",\"DESCRIPTION\":\"    右侧上颌窦呈术后改变，上颌窦窦壁、部分鼻甲及右侧上腭部局部缺如。右侧上颌窦壁及鼻翼旁皮下软组织不均匀增厚，其内信号欠均，T1WI呈等、稍低信号，T2脂肪抑制呈不均匀稍高信号，增强扫描呈不均匀强化。右侧翼外肌内可见片状异常信号影，T1WI及T2脂肪抑制均呈低信号，增强扫描未见明显强化。双侧颈深部Ⅱ-Ⅳ区及咽旁可见多发结节影，T1WI呈低信号，T2脂肪抑制呈高信号，增强扫描呈不均匀中等强化，大者约为1.7*0.9*2.8cm。右侧筛窦及乳突内可见长T1长T2信号影，增强扫描未见强化。\\r\\n\\r\\n\",\"printreport\":false,\"idcard\":\"231003197604211648\",\"patientage\":\"43岁\",\"impression\":\" 1、右侧上颌窦呈术后改变，上颌窦窦壁、部分鼻甲及右侧上腭部局部缺如：右侧上颌窦壁及鼻翼旁皮下软组织不均匀增厚，右侧翼外肌双低信号，考虑术后改变伴周围软组织水肿，请以此为基准片定期复查。\\r\\n2、双侧颈深及左侧咽旁多发淋巴结增大，请追随。\\r\\n3、右侧副鼻窦炎、中耳炎。\\r\\n\",\"regPaperNum\":\"894136\",\"reviewdoctor\":\"杨波\",\"department\":\"放疗三科\",\"studyuid\":\"17822\",\"printfilm\":false,\"reportdoctor\":\"刘媛\"}";
			List<Exams> exams = Exams.dao.find("SELECT * FROM pacsonline.exams where id='116f84268cc9186a'");
			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());
//				Record record = (Record)JSON.parse(jString);
				JSONObject record = JSON.parseObject(jString);
				if (record == null) {
					continue;
				}
				Report report = new Report().use("zskk");
				report.setId(creatId());
				report.setReportDatetime(parseStringToDate(record.getString("reportdate")));
				if (record.getString("impression") == null || record.getString("DESCRIPTION") == null || record.getString("impression").isBlank() || record.getString("DESCRIPTION").isBlank()) {
					continue;
				}
				report.setImpression(record.getString("impression"));
				report.setDescription(record.getString("DESCRIPTION"));
				report.setExamId(exams2.getId());
				report.setCreatedAt(new Date());
				report.setReportDoctorId(getDoctorIdByName(record.getString("reportdoctor")));
				report.setReviewDoctorId(getDoctorIdByName(record.getString("reviewdoctor")));
				report.setReviewDatetime(parseStringToDate(record.getString("reportdate")));
				report.setConfirmDoctorId(getDoctorIdByName(record.getString("reviewdoctor")));
				report.setConfirmDatetime(parseStringToDate(record.getString("reportdate")));
//				report.save();
				PatientInfos patientInfos = PatientInfos.dao.findById(exams2.getPatientId());
				patientInfos.setName(record.getString("patientname"));
				patientInfos.setPhone(record.getString("phone"));
				patientInfos.setCardNum(record.getString("idcard"));
//				patientInfos.update();
				exams2.setExamStatus(9);
                exams2.setClinDoctors(record.getString("clinicaldoctor"));
                exams2.setApplicationDepartment(record.getString("department"));
                exams2.setApplicationDoctor(record.getString("clinicaldoctor"));
                exams2.setClinDiag(record.getString("diagnosis"));
//				exams2.update();
				//传云医康 数据
                Map<String, String> data = new HashMap<String, String>();
                //获取data数据
                //医院id
                data.put("hospital_id","15700002");
                //影像所见
                data.put("description",record.getString("DESCRIPTION"));
                //意见建议
                data.put("impression",record.getString("impression"));
                //检查id
                data.put("exam_id",exams2.getId());
                //患者id
                data.put("patient_id",exams2.getPatientId());
                data.put("study_id",exams2.getStudyId());

                //患者姓名
                data.put("patient_name",record.getString("patientname"));
                //患者性别
                data.put("patient_sex",record.getString("patientsex").equals("女")?"F":"M");
                //身份证号
                data.put("card_num","");
                //手机号
                data.put("phone","");
                //患者生日
                data.put("birthday",returnSecondTimestamp(record.getString("birthdate")));
                //患者检查时年龄
                data.put("patient_age",patientInfos.getAge());
                //阴阳性 1阴性 2阳性
                data.put("report_result","");
                //报告时间 10位时间戳
                data.put("report_datetime",returnSecondTimestamp(record.getString("reportdate")));
                //报告医生id
                data.put("report_doctor_id",record.getString("reportdoctor"));
                //报告医生姓名
                data.put("report_doctor_name",record.getString("reportdoctor"));
                //审核时间
                data.put("review_datetime",returnSecondTimestamp(record.getString("reportdate")));
                //审核医生id
                data.put("review_doctor_id",record.getString("reviewdoctor"));
                //审核姓名
                data.put("review_doctor_name",record.getString("reviewdoctor"));
                //确认时间
                data.put("confirm_datetime", returnSecondTimestamp(record.getString("reportdate")));
                //确认医生id
                data.put("confirm_doctor_id", record.getString("reviewdoctor"));
                //确认医生姓名
                data.put("confirm_doctor_name",record.getString("reviewdoctor"));
//                System.out.println(data);
                //调用接口
//               String s = post(null, data);
////               string = string+s;
//                String ssString = data.toString();
//
////        		String ssString = "{\"birthday\":\"-937382400\",\"review_datetime\":\"1577608513\",\"review_doctor_name\":\"王宪\",\"confirm_doctor_id\":\"王宪\",\"description\":\"所示胸腰椎及骨盆未见骨质异常；rn双侧膈下见气体密度影；rn腹部肠管内积气伴局部扩张；rn腰大肌影清晰；腹壁软组织影未见异常；rn胆囊区、肾区、输尿管区、膀胱区未见阳性结石影；rn双肾轮廓显影欠清；隐约可见；未见明显形态改变；rn腹部未见异常软组织团块影，未见异常钙化影。rn\",\"study_id\":\"116f50c27d705e37\",\"hospital_id\":\"15700002\",\"confirm_datetime\":\"1577608513\",\"card_num\":\"\",\"patient_sex\":\"M\",\"phone\":\"\",\"report_doctor_id\":\"王宪\",\"patient_id\":\"116f50c27d46d081\",\"report_doctor_name\":\"王宪\",\"patient_name\":\"赵清标\",\"impression\":\"1、膈下游离气体，考虑气腹，请结合临床rn2、腹部肠管扩张、积气，请结合临床。rn\",\"review_doctor_id\":\"王宪\",\"report_datetime\":\"1577608513\",\"patient_age\":\"79岁\",\"report_result\":\"\",\"confirm_doctor_name\":\"王宪\",\"exam_id\":\"116f50c27d8a1bc5\"}";
//           	 Map maps = (Map)JSON.parse(ssString);  
//             System.out.println(ssString);
                String ssString=JSON.toJSONString(data);
                System.out.println(ssString);
                ssString = ssString.replace("\\r\\n","");
                ssString = ssString.replace(" ","");
                ssString = ssString.replace("、","，");
                ssString = ssString.replace("*","乘");



           	 Map maps = (Map)JSON.parse(ssString);  

                post(null, maps);
			}
            System.out.println(string);
//			this.renderText(string);
		} catch (Exception e) {
			// TODO: handle exception
//			this.renderText(e.toString());
            System.out.println(e.toString());

		}
	}
	
	 public static  String getSign(Map<String, String> param, String key) {
	        return DigestUtils.md5Hex(Ksort(param) + key);
	    }
	 
	public static 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位数";
        }
    }
	
	private static String creatId() {
		UUID id = UUID.randomUUID();
        String[] idd= id.toString().split("-");
		return idd[0]+idd[1]+idd[2];
	}
	
	private static String getDoctorIdByName(String name) {
		if (name == null || name.isBlank()) {
			return null;
		}
		name = name.replace(" ", "");
		Doctors doctors = Doctors.dao.findFirst("SELECT * FROM doctors where instr(?,realname) and institution_id=15700002 and realname <>''",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 static 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;
	}
	
	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;
            }
            System.out.println(result);
            return result;
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (in != null) {
                    in.close();
                }
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
        return result;
    }

	private static void post(String url, Map<String, String> map) throws IOException {
		RequestBody formBody = new FormBody.Builder()
		        .add("timestamp", String.valueOf(getSecondTimestamp(new Date())))
		        .add("signature", Ksort(map))
		        .add("data", JSON.toJSONString(map))
		        .build();

		 System.out.println(String.valueOf(getSecondTimestamp(new Date())));
	      System.out.println(Ksort(map));
	      System.out.println(JSON.toJSONString(map));
		    Request request = new Request.Builder()
		        .url("http://39.106.136.96/pacs/zskk/writePatientReport")
		        .post(formBody)
		        .build();

		    try (Response response = OKHTTP_CLIENT.newCall(request).execute()) {
		      if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

		      System.out.println(response.body().string());
//			  return response.body().string();
//
		    }
	  }  
	public static 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);
		System.out.println("***"+sb);

		try {
		sb = URLEncoder.encode(sb, "UTF-8");
		} catch (UnsupportedEncodingException e) {
		e.printStackTrace();
		}// 使用常见的UTF-8编码
		sb = sb.replace("%3D", "=").replace("%26", "&");

		System.out.println("**"+sb);
		String resultString = HashKit.md5(sb+"YgpxjVeIx0yoK6Atz413IAj7hU9dygH4");
		return resultString;
	}
	
	public static  String returnSecondTimestamp(String data) throws ParseException {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        return String.valueOf(sdf.parse(data).getTime()/1000);
    }
	public static void main(String[] args) {
		try {
			String ssString = returnSecondTimestamp("1955-03-17 00:00:00");
			System.out.println(ssString);
		} catch (ParseException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
//			testTask();
	}
}