billscheduledservice.java

自动导入文件到数据库,用于无法实时入库,需要在特定时间大批量入库的程序

package com.onet.autobill.bill;

import org.apache.log4j.Logger;

import com.onet.autobill.scheduler.ScheduledService;

/**
 * 调度服务管理器,执行倒库,更新,添加数据库操作
 * 
 * @author mengwei
 * @version 3.0
 */
public class BillScheduledService implements ScheduledService {

	private static Logger logger = Logger.getLogger(BillScheduledService.class);

	private String scheduledServiceName = "日志自动倒库程序";


	private long scheduleRefreshTime = 0;

	private long scheduleStartTime = 0;
	
	private BillHandlerManager billHandlerManager;

	public boolean init() {
		if(billHandlerManager==null){
			logger.error("billHandlerManager参数没有配置,无法执行倒库程序");
			return false;
		}
		return billHandlerManager.initService();
	}

	public void run() {
		try{
			billHandlerManager.importBills2DB();
//			if(billHandlerManager.importBills2DB()){
//				if(dbService!=null){
//					dbService.updateDeliverInfo();
//					logger.debug(updateRun+""+totelRun);
//					if(updateRun){
//						dbService.updateSubmitStatusAndProductId();			
//					}
//					if(totelRun){
//						dbService.doAutoTestStat();
//					}
//				}

//			}
		}catch(Exception e){
			logger.error("", e);
		}
	}


	public void shutDown() {
		billHandlerManager.closeManager();
	}

	public String getScheduledServiceName() {
		return scheduledServiceName;
	}

	public long getScheduleRefreshTime() {
		return scheduleRefreshTime;
	}

	public void setScheduleRefreshTime(long scheduleRefreshTime) {
		this.scheduleRefreshTime = scheduleRefreshTime;
	}

	public long getScheduleStartTime() {
		return scheduleStartTime;
	}

	public void setScheduleStartTime(long scheduleStartTime) {
		this.scheduleStartTime = scheduleStartTime;
	}

	public void setBillHandlerManager(BillHandlerManager billHandlerManager) {
		this.billHandlerManager = billHandlerManager;
	}
	
}