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

package com.zskk.control;

import java.io.IOException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.jfinal.core.Controller;
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.SqlServerDialect;
import com.jfinal.plugin.druid.DruidPlugin;
import com.zskk.service.DataService;
import com.zskk.service.ServiceFactory;

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

public class ViewController extends Controller {

	private static final MediaType JSON_CODE = MediaType.get("application/json; charset=utf-8");

	private static final OkHttpClient OKHTTP_CLIENT = new OkHttpClient();

	/**
	 * 在被连接数据库执行sql语句
	 */
	public void executeSql() {
		List<Record> d = Db.use("connected").find(this.getPara("sqlstr"));
		this.renderJson(d);
	}
	
	/**
	 * 在被连接数据库执行sql语句
	 */
	public void executeSqlCrb() {
		List<Record> d = Db.use("crb").find(this.getPara("sqlstr"));
		this.renderJson(d);
	}
	
	public void testcrb() {
		try {
		DataService dService = ServiceFactory.getService(DataService.class);
		Map<String, String> dateparams = new HashMap<>();
		dateparams.put("datetime", parseStringToDate());
        JSONArray jsonArray = dService.getReport(dateparams);	
        for (Object object : jsonArray) {
			JSONObject jsonObject = JSON.parseObject(object.toString());
//		    String REPORT_ID = jsonObject.getString("REPORT_ID")==null?"":jsonObject.getString("REPORT_ID");
		    			Record record = Db.use("crb").findFirst("select * from DC_PACS_REPORT where ID=?", jsonObject.getString("ID"));
			if (record == null) {
				Record DC_PACS_REPORT = new Record()
						.set("ID", jsonObject.getString("ID"))
						.set("REPORT_ID", jsonObject.getString("REPORT_ID"))
						.set("PAT_FROM_TYPE", "门诊")
						.set("PAT_NUM", jsonObject.getString("PAT_NUM")==null?"":jsonObject.getString("PAT_NUM"))
						.set("TESTLIST", jsonObject.getString("TESTLIST")==null?"":jsonObject.getString("TESTLIST"))
						.set("NAME", jsonObject.getString("NAME"))
						.set("SEX",jsonObject.getString("SEX").contains("M")?"男":"女")
						.set("BIRTHDAY", jsonObject.getDate("BIRTHDAY")==null?"":jsonObject.getDate("BIRTHDAY"))
						.set("ADDRESS", jsonObject.getString("ADDRESS"))
						.set("TEL", jsonObject.getString("TEL")==null?"":jsonObject.getString("TEL"))
						.set("ORG_CODE", "371728007")
						.set("ORG_NAME", "东明县第二人民医院")
						.set("DEP_NAME", jsonObject.getString("DEP_NAME")==null?"":jsonObject.getString("DEP_NAME"))
						.set("DEP_CODE", jsonObject.getString("DEP_CODE"))
						.set("DUTY_DOCTOR_NAME", jsonObject.getString("DUTY_DOCTOR_NAME")==null?"":jsonObject.getString("DUTY_DOCTOR_NAME"))
						.set("DUTY_DOCTOR_ID", jsonObject.getString("DUTY_DOCTOR_ID"))
						.set("CHIEF_COMPLAINT", jsonObject.getString("CHIEF_COMPLAINT"))
						.set("DIAGNOSIS", jsonObject.getString("DIAGNOSIS")==null?"":jsonObject.getString("DIAGNOSIS"))
						.set("STUDY_BODYPART", jsonObject.getString("STUDY_BODYPART"))
						.set("IMAGE_TYPE_NAME", jsonObject.getString("IMAGE_TYPE_NAME"))
						.set("FINDING", jsonObject.getString("FINDING"))
						.set("CONCLUSION", jsonObject.getString("CONCLUSION"))
						.set("FLAG_DIAGNOSTIC_ACCORDANCE", "1")
						.set("HAPPEN_TIME", jsonObject.getDate("HAPPEN_TIME"))
						.set("SYSTEMTIME", jsonObject.getDate("SYSTEMTIME"))
						.set("HOSPITAL_CODE", "371728007")
						.set("UPDATE_TIME", jsonObject.getDate("UPDATE_TIME"))
						.set("STATE", "0");
				Db.use("crb").save("DC_PACS_REPORT", DC_PACS_REPORT);
			}
		    Record record2 = Db.use("crb").findFirst("select * from DC_PACS_XML where REPORT_ID=?", jsonObject.getString("REPORT_ID"));
			if (record2 == null) {
				Record DC_PACS_XML = new Record()
						.set("REPORT_ID", jsonObject.getString("REPORT_ID"))
						.set("PAT_FROM_TYPE", "门诊")
						.set("PAT_NUM", jsonObject.getString("PAT_NUM")==null?"":jsonObject.getString("PAT_NUM"))
						.set("ORG_CODE", "371728007")
						.set("ORG_NAME", "东明县第二人民医院")
						.set("REPORT_XML", jsonObject.getString("FINDING")+jsonObject.getString("CONCLUSION"))
						.set("SYSTEMTIME", jsonObject.getDate("SYSTEMTIME"))
						;
				Db.use("crb").save("DC_PACS_XML", "REPORT_ID", DC_PACS_XML);
				this.renderJson(DC_PACS_XML);
			}
        	
        }
			
			
//        this.renderJson(jsonArray);
		} catch (Exception e) {
			// TODO: handle exception
    		this.renderText(e.toString());
//    		continue;
		}
//        this.renderJson(jsonArray);
		
	}
	
	public void testus() {
		try {
			List<Record> records = Db.use("connected").find("select * from View_PACS where CHECK_TYPE='US1'");
			for (Record rd : records) {
				Record	recordfind =Db.use("local").findFirst("select * from View_PACS where HISID=? and PARTOFCHECK=? and LODGEDATE=?",rd.getStr("HISID"),rd.getStr("PARTOFCHECK"),rd.getStr("LODGEDATE"));
				if(recordfind !=null)
				{
					continue;
				}
				Record	record =new Record();
				record.set("HISID", rd.getStr("HISID")==null?"":rd.getStr("HISID"));
				record.set("INPATIENTNO", rd.getStr("INPATIENTNO")==null?"":rd.getStr("INPATIENTNO"));
				record.set("LODGENO", rd.getStr("LODGENO")==null?"":rd.getStr("LODGENO"));
				record.set("NAME", rd.getStr("NAME")==null?"":rd.getStr("NAME"));
				record.set("SEX", rd.getStr("SEX")==null?"":rd.getStr("SEX"));
				record.set("BIRTHDATE", rd.getStr("BIRTHDATE")==null?"":rd.getStr("BIRTHDATE"));
				record.set("LODGESECTION", rd.getStr("LODGESECTION")==null?"":rd.getStr("LODGESECTION"));
				record.set("LODGEDOCTOR", rd.getStr("LODGEDOCTOR")==null?"":rd.getStr("LODGEDOCTOR"));
				record.set("AGE", rd.getStr("AGE")==null?"":rd.getStr("AGE"));
				record.set("CHECK_TYPE", rd.getStr("CHECK_TYPE")==null?"":rd.getStr("CHECK_TYPE"));
				record.set("PARTOFCHECK", rd.getStr("PARTOFCHECK")==null?"":rd.getStr("PARTOFCHECK"));
				record.set("DIRECTION", rd.getStr("DIRECTION")==null?"":rd.getStr("DIRECTION"));
				record.set("ADDRESS", rd.getStr("ADDRESS")==null?"":rd.getStr("ADDRESS"));
				record.set("RACE", rd.getStr("RACE")==null?"":rd.getStr("RACE"));
				record.set("PROFESSION", rd.getStr("PROFESSION")==null?"":rd.getStr("PROFESSION"));
				record.set("MARITALSTATUS", rd.getStr("MARITALSTATUS")==null?"":rd.getStr("MARITALSTATUS"));
				record.set("TELEPHONE", "");
				record.set("DEGREE", rd.getStr("DEGREE")==null?"":rd.getStr("DEGREE"));
				record.set("LODGEDATE", rd.getStr("LODGEDATE")==null?"":rd.getStr("LODGEDATE"));
				record.set("BEDNO", rd.getStr("BEDNO")==null?"":rd.getStr("BEDNO"));
				record.set("TIMES", rd.getStr("TIMES")==null?"":rd.getStr("TIMES"));
				record.set("zyh", rd.getStr("zyh")==null?"":rd.getStr("zyh"));
				record.set("cwh", rd.getStr("cwh")==null?"":rd.getStr("cwh"));
				Db.use("local").save("View_PACS", record);

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

		}
		
	}
	
	

	public void testConn() {
		try {
			DruidPlugin druidPluginConnected = createConnectedDruidPlugin();
            druidPluginConnected.start();
			// 配置ActiveRecord插件
			ActiveRecordPlugin arpConnected = new ActiveRecordPlugin("local", druidPluginConnected);
			arpConnected.setDialect(new MysqlDialect());
			arpConnected.start();

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

		return new DruidPlugin(PropKit.get("jdbcUrl_local"), PropKit.get("user_local"),PropKit.get("password_local").trim());
	}
	
	/**
	 * 日期字符串格式转换
	 * @param dateStr
	 * @return
	 */
	private String parseStringToDate() {
		SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
		Date date = new Date();
		//start
		long dInteger = date.getTime() - 96400000;
		String daString = sdf.format(new Date(dInteger));
		//end
		long eInteger = date.getTime() - 600000;
		String endString = sdf.format(new Date(eInteger));
		
        return daString+","+endString;
	}
	/**
	 * post请求
	 * @param url-请求地址
	 * @param map-参数集合
	 * @return
	 */
	private static String doPost(String url, Map<String, String> map) {
		FormBody.Builder builder = new FormBody.Builder();
		for (String key : map.keySet()) {
			builder.add(key, map.get(key));
		}

		RequestBody formBody = builder.build();

		Request request = new Request.Builder().url(url).post(formBody).build();
		
		try (Response response = OKHTTP_CLIENT.newCall(request).execute()) {
			if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);
			String content = response.body().string();
			return content;
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			return null;
		}
	}
	
	/**
	 * 日期字符串格式转换
	 * @param dateStr
	 * @return
	 */
	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;
	}

	public static void main(String[] args) {
        Map<String,String> paramsMap=new HashMap<String,String>();
        paramsMap.put("institution_id", "44100001");

		String contentString = doPost("https://risserver3.pacsonline.cn/butt/getExam/butt/getExam", paramsMap);
		System.out.println(contentString);

	}
}