?? schedule.java.svn-base
字號(hào):
package hdaty.prtds.rdgadaptor.schedule;
import hdaty.prtds.rdgadaptor.protocol.Message;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.Calendar;
import java.util.Date;
import java.util.GregorianCalendar;
import java.util.TimeZone;
import java.util.Vector;
/**
* 線程執(zhí)行的周期:<br>
* 年、月、周、日、時(shí)、分
* @author Administrator
*
*/
enum Cycle{
YEAR,
MONTH,
WEEK,
DAY,
HOUR,
MINUTE;
}
public class Schedule {
public static ScheduledThreadPoolExecutor scheduler;
public Schedule(){
scheduler = new ScheduledThreadPoolExecutor(10);
}
public Schedule(int size){
scheduler = new ScheduledThreadPoolExecutor(size);
}
/**
* 周期性執(zhí)行任務(wù)
* @param event 需要執(zhí)行的任務(wù)，該任務(wù)必須實(shí)現(xiàn)runnable接口
* @param message 任務(wù)開始執(zhí)行的時(shí)間
* @throws InterruptedException
* @throws ParseException
*/
public void repeat(Runnable event, Message message)
throws InterruptedException, ParseException {
long delay = 0;
String date = message.getDATE()[0];
System.out.println(message.getDATE()[0]);
TimeZone tz = TimeZone.getTimeZone("GMT+8");
Calendar now = Calendar.getInstance(tz);
int years = now.get(Calendar.YEAR);
int months = now.get(Calendar.MONTH);
int days = now.get(Calendar.DAY_OF_MONTH);
int weeks = now.get(Calendar.DAY_OF_WEEK);
int hours = now.get(Calendar.HOUR_OF_DAY);
int minutes = now.get(Calendar.MINUTE);
// int seconds = now.get(Calendar.SECOND);
Date inittime = new Date(System.currentTimeMillis());// 任務(wù)啟動(dòng)時(shí)間
if (message.getPeriod().equals("每月")) {// DD:hh:mm 日期：小時(shí)：分鐘
int sDay = Integer.parseInt(date.split("號(hào)")[0]);
String setedtime = null;
setedtime = date.split(" ")[1];
int sHour=Integer.parseInt(setedtime.substring(0, 2));
int sMinute= Integer.parseInt(setedtime.substring(3, 5));
System.out.println(sHour);
System.out.println(sMinute);
now.set(years, months, sDay, sHour, sMinute, 0);//設(shè)定當(dāng)月定時(shí)點(diǎn)的時(shí)間
Date sysdate = new Date(now.getTimeInMillis());
System.out.println(sysdate.toString());
// if (days>sDay&& hours>sHour&& minutes>sMinute) now.add(Calendar.MONTH, 1);// 啟動(dòng)時(shí)間大于定時(shí)時(shí)間
if(days > sDay || (days == sDay && hours > sHour) || (days == sDay && hours == sHour && minutes > sMinute)){
now.add(Calendar.MONTH, 1);
}
}
if (message.getPeriod().equals("每天")) {
int sHour=Integer.parseInt(date.substring(0, 2));
int sMinute= Integer.parseInt(date.substring(3, 5));
now.set(years, months, days, sHour, sMinute, 0);//當(dāng)天定時(shí)點(diǎn)的時(shí)間
// if (hours> sHour && minutes>sMinute) now.add(Calendar.DATE, 1);// 啟動(dòng)時(shí)間小于定時(shí)時(shí)間
System.out.println(hours);
System.out.println(sHour);
System.out.println(sMinute);
if(hours > sHour ||(hours == sHour && minutes > sMinute)){
now.add(Calendar.DATE, 1);
System.out.println("在下個(gè)周期執(zhí)行！");
}
}
if (message.getPeriod().equals("每周")) {// DD:HH:mm
String week = date.split(" ")[0];
int sWeek = 2;//默認(rèn)每周一執(zhí)行任務(wù)
if(week.equals("周日")){
sWeek = 1;
}
else if(week.equals("周一")){
sWeek = 2;
}
else if(week.equals("周二")){
sWeek = 3;
}
else if(week.equals("周三")){
sWeek = 4;
}
else if(week.equals("周四")){
sWeek = 5;
}
else if(week.equals("周五")){
sWeek = 6;
}
else if(week.equals("周六")){
sWeek = 7;
}
String settime = null;
settime = date.split(" ")[1];
int sHour=Integer.parseInt(settime.substring(0, 2));
int sMinute= Integer.parseInt(settime.substring(3, 5));
now.set(years, months, days, sHour, sMinute, 0);//當(dāng)天定時(shí)點(diǎn)的時(shí)間
// if ((weeks <= sWeek && hours <= sHour && minutes <= sMinute)) now.add(Calendar.DATE, sWeek-weeks);// 啟動(dòng)時(shí)間不大于定時(shí)時(shí)間
// else now.add(Calendar.DATE, sWeek-weeks+7);//下周定時(shí)點(diǎn)執(zhí)行時(shí)間點(diǎn)
if(weeks < sWeek ||(weeks == sWeek && hours < sHour) || (weeks ==sWeek && hours == sHour && minutes < sMinute)){
now.add(Calendar.DATE, sWeek-weeks);
}
else{
now.add(Calendar.DATE, sWeek-weeks+7);
}
}
Date sysdate = new Date(now.getTimeInMillis());
System.out.println(sysdate.toString());
System.out.println(now.toString());
delay = (now.getTimeInMillis() - inittime.getTime());
System.out.println(inittime.toString());
System.out.println(now.getTimeInMillis());
System.out.println(inittime.getTime());
System.out.println(delay);
}
/**
* 測試用主函數(shù)
* @param args
* @throws InterruptedException
* @throws ParseException
* @throws IOException
* @throws ClassNotFoundException
*/
public static void main(String[] args) throws InterruptedException, ParseException, IOException, ClassNotFoundException {
Schedule schedule = new Schedule();
FileInputStream fis2 = new FileInputStream("./src/數(shù)據(jù)包/task.txt");
ObjectInputStream ois2 = new ObjectInputStream(fis2);
Vector tasks = (Vector)ois2.readObject();
System.out.println(tasks.size());
for( int i = 0; i < tasks.size(); i ++){
Message taskmessage = (Message) tasks.elementAt(i);
System.out.println(taskmessage.getTaskName());
if(taskmessage.isExcute()){
Cycle period = Cycle.DAY ;
if(taskmessage.getPeriod().equals("每月"))
period = Cycle.MONTH;
else if(taskmessage.getPeriod().equals("每周"))
period = Cycle.WEEK;
else if(taskmessage.getPeriod().equals("每天"))
period = Cycle.DAY;
schedule.repeat(new MyThread(period,taskmessage), taskmessage);
System.out.println(period);
}
}
}
}
/**
* 導(dǎo)數(shù)據(jù)用線程，該線程實(shí)現(xiàn)了，導(dǎo)數(shù)據(jù)及周期性的執(zhí)行導(dǎo)數(shù)據(jù)
* @author Administrator
*
*/
class MyThread implements Runnable{
String root = System.getProperty("user.dir");
Log log = new Log();
Date starttime = null;
private static int taskCount = 0;
private final int id = taskCount++;
private Cycle period;
private Message newtk = null;
public MyThread(Cycle period,Message newtk){
this.period = period;
this.newtk = newtk;
}
/**
* 增量導(dǎo)數(shù)據(jù)模式
*
*/
public void increment(){
SimpleDateFormat sdf = new SimpleDateFormat("yyyy年MM月dd日 HH:mm:ss: ");
// System.out.println(newtk.getDATE());
// String logerrorname = null;
// String logsqlname = null;
// logerrorname = sdf.format(new Date())+ "_系統(tǒng)錯(cuò)誤.log";
// logsqlname = sdf.format(new Date()) + "_SQL.log";
String logerrorname = null;
String logsqlname = null;
logerrorname = "log.txt";
logsqlname = "log.txt";
String error = "";
String sql = "";
boolean bFile;
bFile = false;
File dirFile;
dirFile = new File("" + root + "/src/Log");
bFile = dirFile.exists();
if (bFile == true) {
System.out.println("Log文件夾存在。");
} else {
System.out.println("Log文件夾不存在" + "\n" +"創(chuàng)建Log文件夾"+ "\n");
bFile = dirFile.mkdir();
if (bFile == true) {
System.out.println("Log文件夾 Createsuccessfully!");
} else {
System.out.println("Disable to make the folder,please check the disk is full or not.");
System.exit(1);
}
}
System.out.println("開始執(zhí)行增量模式導(dǎo)數(shù)據(jù)！………………");
// *****************************與源庫建立連接，從源庫取得數(shù)據(jù)***************************************
try {
Class.forName(newtk.getSDriver());
error += sdf.format(new Date()) + " 方案:" + newtk.getTaskName()+ " 無法完成源數(shù)據(jù)庫驅(qū)動(dòng)！\n";
log.Log("" + root + "/src/Log/" + logerrorname, error);
System.out.println("無法完成源數(shù)據(jù)庫驅(qū)動(dòng)！");
e.printStackTrace();
}
Connection conn = null;
try {
conn = DriverManager.getConnection(newtk.getSURL(),newtk.getSuser(),newtk.getSpassword());
} catch (SQLException e) {
error += sdf.format(new Date()) + " 方案:" + newtk.getTaskName()+ " 無法與源數(shù)據(jù)庫建立連接！";
log.Log("" + root + "/src/Log/" + logerrorname, error);
System.out.println("無法與源數(shù)據(jù)庫建立連接！");
e.printStackTrace();
}
String field = "";
for(int i = 0; i < newtk.getS().length; i++){
field =field + "," + newtk.getS()[i];
}
field = field.substring(1);
// newtk.getSKind().equals("");
String sschema = null;
if(newtk.getSSchema() == null){
sschema = "";
}
else{
sschema = newtk.getSSchema();
}
String stable = null;
if(newtk.getSKind().equalsIgnoreCase("excel")){
stable = "[Sheet1$]";
}
else{
stable = newtk.getSTab();
}
String query = " select " + field + " from " + sschema + "." + stable;
PreparedStatement pstm = null;
ResultSet rs = null;
try {
pstm = conn.prepareStatement(query);
rs = pstm.executeQuery();
} catch (SQLException e) {
error += sdf.format(new Date()) +" 方案:" + newtk.getTaskName()+ " 無法從源數(shù)據(jù)庫中取得數(shù)據(jù)！";
log.Log("" + root + "/src/Log/" + logerrorname, error);
System.out.println("無法從源數(shù)據(jù)庫中取得數(shù)據(jù)！");
e.printStackTrace();
}
// *****************************與目的庫建立連接，向目的庫數(shù)據(jù)*************************************************
try {
Class.forName(newtk.getDDriver());
} catch (ClassNotFoundException e) {
error += sdf.format(new Date()) + " 方案:" + newtk.getTaskName()+ " 無法完成目的數(shù)據(jù)庫驅(qū)動(dòng)！";
log.Log("" + root + "/src/Log/" + logerrorname, error);
System.out.println("無法完成目的數(shù)據(jù)庫驅(qū)動(dòng)！");
e.printStackTrace();
}
Connection newconn = null;
try {
//DriverManager.registerDriver(new oracle.jdbc.OracleDriver());
newconn = DriverManager.getConnection(newtk.getDURL(),newtk.getDuser(),newtk.getDpassword());
} catch (SQLException e) {
error += sdf.format(new Date()) + " 方案:" + newtk.getTaskName()+ " 無法與目的數(shù)據(jù)庫建立連接！";
log.Log("" + root + "/src/Log/" + logerrorname, error);
System.out.println("無法與目的數(shù)據(jù)庫建立連接！");
e.printStackTrace();
}
String newfield = "";
for(int i = 0; i < newtk.getD().length; i++){
newfield = newfield + "," + newtk.getD()[i];
}
newfield = newfield.substring(1);
String att = "";
for(int i = 0;i < newtk.getD().length; i++){
?? 快捷鍵說明
復(fù)制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號(hào)
Ctrl + =
減小字號(hào)
Ctrl + -