commit

DataFusion/res/config.properties

@@ -4,4 +4,8 @@ jdbcUrl_connected  = jdbc:oracle:thin:@172.16.17.71:1521:orcl
 user_connected 	   = ZSKK_VIEW
 password_connected = ZSKK_VIEW
 #DATA-Parms
-institution_id     = 44800001
+institution_id     = 44800001
+#jdbcUrl_connected  = jdbc:sqlserver://196.196.100.251:1433;DatabaseName=PACS
+jdbcUrl_connectedtemp  = jdbc:mysql://127.0.0.1:3306/pacsonline
+user_connectedtemp 	   = root
+password_connectedtemp = Zskk_2017

DataFusion/src/com/zskk/config/ZskkConfig.java

@@ -18,11 +18,14 @@ import com.jfinal.template.Engine;
 import com.zskk.control.ViewController;
 import com.zskk.service.ServiceFactory;
 import com.zskk.task.DataTask;
+import com.zskk.task.InsertTask;
+import com.zskk.task.UpdateTask;
 
 public class ZskkConfig extends JFinalConfig {
 
 	// 本地开发模式
 	private boolean isLocalDev = false;
+
 	/**
 	 * 如果生产环境配置文件存在，则优先加载该配置，否则加载开发环境配置文件
 	 * 
@@ -41,14 +44,14 @@ public class ZskkConfig extends JFinalConfig {
 	public void configConstant(Constants me) {
 		loadProp("config.properties", "a_little_config.txt");
 		me.setDevMode(PropKit.getBoolean("devMode", false));
-		me.setBaseDownloadPath("/download");//配置文件下载路径
+		me.setBaseDownloadPath("/download");// 配置文件下载路径
 	}
 
 	@Override
 	public void configRoute(Routes me) {
 		// TODO Auto-generated method stub
 		me.add("/view", ViewController.class);
-		me.add("/", ViewController.class,"");
+		me.add("/", ViewController.class, "");
 	}
 
 	@Override
@@ -59,9 +62,16 @@ public class ZskkConfig extends JFinalConfig {
 
 	public static DruidPlugin createConnectedDruidPlugin() {
 
-		return new DruidPlugin(PropKit.get("jdbcUrl_connected"), PropKit.get("user_connected"),PropKit.get("password_connected").trim());
+		return new DruidPlugin(PropKit.get("jdbcUrl_connected"), PropKit.get("user_connected"),
+				PropKit.get("password_connected").trim());
 	}
 
+	public static DruidPlugin createConnectedDruidPlugintemp() {
+
+		return new DruidPlugin(PropKit.get("jdbcUrl_connectedtemp"), PropKit.get("user_connectedtemp"),
+				PropKit.get("password_connectedtemp").trim());
+	}
+	
 	@Override
 	public void configPlugin(Plugins me) {
 		// 配置数据库连接池插件
@@ -73,13 +83,26 @@ public class ZskkConfig extends JFinalConfig {
 		arpConnected.setDialect(new OracleDialect());
 		me.add(arpConnected);
 
+		// 配置数据库连接池插件
+		DruidPlugin druidPluginConnectedtemp = createConnectedDruidPlugintemp();
+		me.add(druidPluginConnectedtemp);
+
+		// 配置ActiveRecord插件
+		ActiveRecordPlugin arpConnectedtemp = new ActiveRecordPlugin("connectedtemp", druidPluginConnectedtemp);
+		arpConnectedtemp.setDialect(new MysqlDialect());
+		me.add(arpConnectedtemp);
+
 		Cron4jPlugin cpData = new Cron4jPlugin();
 		cpData.addTask("*/5 * * * *", new DataTask());
 		me.add(cpData);
-		
-//		Cron4jPlugin urlData = new Cron4jPlugin();
-//		urlData.addTask("*/1 * * * *", new DataTask());
-//		me.add(urlData);
+
+		Cron4jPlugin inData = new Cron4jPlugin();
+		inData.addTask("*/1 * * * *", new InsertTask());
+		me.add(inData);
+
+		Cron4jPlugin urlData = new Cron4jPlugin();
+		urlData.addTask("*/1 * * * *", new UpdateTask());
+		me.add(urlData);
 	}
 
 	@Override
@@ -93,14 +116,14 @@ public class ZskkConfig extends JFinalConfig {
 		// TODO Auto-generated method stub
 
 	}
-	
+
 	@Override
 	public void onStart() {
 		// TODO Auto-generated method stub
 		super.onStart();
 		ServiceFactory.init();
 	}
-	
+
 //	public static void main(String[] args) {
 //		JFinal.start("WebRoot", 10002, "/", 5);
 //	}

DataFusion/src/com/zskk/task/InsertTask.java

@@ -0,0 +1,53 @@
+package com.zskk.task;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+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 okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
+
+public class InsertTask implements ITask {
+
+    private static final OkHttpClient OKHTTP_CLIENT = new OkHttpClient();
+
+	@Override
+	public void run() {
+		// TODO Auto-generated method stub
+		List<Record> record = Db.use("connected").find("select * from v_webpacs_study where STUDY_DATE>to_date('"+parseStringToDate()+"','yyyy-mm-dd hh24:mi:ss') order by STUDY_DATE desc");
+		for (Record record2 : record) {
+		Record studyinfo = new Record().set("studyid", record2.getStr("STUDYID")).set("status", "1").set("createAt", new Date());
+		Db.use("connectedtemp").save("study", studyinfo);
+		}
+	}
+
+	@Override
+	public void stop() {
+		// TODO Auto-generated method stub
+
+	}
+
+	/**
+	 * 日期字符串格式转换
+	 * @param dateStr
+	 * @return
+	 */
+	private String parseStringToDate() {
+		SimpleDateFormat sdf= new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+	    Date date = new Date();
+	    long dInteger =date.getTime()-360000;
+		String daString = sdf.format(new Date(dInteger));
+	    return daString;
+		
+	}
+}