JAVA极品OA-Eclipse项目完整版.rar

//Date: 2008-4-24 11:36:15 //~ //~ //CopyRight@criway FileName: JsInfoProcess.java package com.criway.jsinfo; import com.criway.database.DataConn; import com.criway.oa.schedule.Task; import java.io.PrintStream; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.Statement; import java.sql.Timestamp; import java.text.DateFormat; import java.text.SimpleDateFormat; import java.util.AbstractCollection; import java.util.ArrayList; import java.util.Collection; import java.util.Date; import java.util.Hashtable; import javax.servlet.ServletContext; import javax.servlet.http.HttpServletRequest; import org.apache.log4j.Category; import org.apache.log4j.Logger; // Referenced classes of package com.criway.jsinfo: // JsMessage, User, InvalidateException, ApplicationException, // JsInfoProcessHelper public class JsInfoProcess { public JsInfoProcess() { _$12585 = 60; _$12586 = 60; _$12587 = 60; _$12588 = false; _$9576 = false; _$12492 = null; _$12492 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); } public JsInfoProcess(boolean isInitData) { _$12585 = 60; _$12586 = 60; _$12587 = 60; _$12588 = false; _$9576 = false; _$12492 = null; _$12492 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); } public JsInfoProcess(ServletContext app) { _$12585 = 60; _$12586 = 60; _$12587 = 60; _$12588 = false; _$9576 = false; _$12492 = null; _$12492 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); if(_$12589 == null) _$12589 = app; } public static ServletContext getSingle_app() { return _$12589; } public static String getAbsPathPre() { return _$12590; } public static synchronized void setAbsPathPre(String absPath) { _$12590 = absPath; } public void initDbData(ArrayList messages) throws Exception { if(messages == null) throw new Exception("JsInfoProcess initDbData() messages is null!"); DataConn dataConn = null; try { dataConn = new DataConn(); Statement stmt = dataConn.getConnection().createStatement(); String sql = "delete from OA_jsxxjl where type_id not in(-1, 2) or (type_id = 2 and isSendClearFlag = 1 and isReceiveClearFlag = 1)"; stmt.executeUpdate(sql); sql = " select sender_name,receiver_name,type_id,send_time,content, id from OA_jsxxjl where real_receive_time is null and (type_id = -1 or type_id = 2) "; logger.debug("initDbData sql : ".concat(String.valueOf(String.valueOf(sql)))); ResultSet rs = stmt.executeQuery(sql); JsMessage message = null; String sendLoginName = ""; String sendName = ""; String sendDepName = ""; int sendId = 0; int typeId = 0; String receiveLoginName = ""; String receiveName = ""; String receiveDepName = ""; int receiveId = 0; User sendUser = null; User receiveUser = null; for(; rs.next(); messages.add(message)) { message = new JsMessage(); sendLoginName = rs.getString(1).trim(); receiveLoginName = rs.getString(2).trim(); typeId = rs.getInt(3); sendUser = JsInfoProcessHelper.getInstance().findUserByLoginName(sendLoginName); receiveUser = JsInfoProcessHelper.getInstance().findUserByLoginName(receiveLoginName); if(sendUser != null) { sendId = sendUser.getUserId(); sendName = sendUser.getUserName(); if(typeId == -1) sendDepName = "\u7CFB\u7EDF\u63D0\u9192"; else sendDepName = sendUser.getDepName(); } if(receiveUser != null) { receiveId = receiveUser.getUserId(); receiveName = receiveUser.getUserName(); receiveDepName = receiveUser.getDepName(); } message.setTypeId(typeId); message.setSenderId(sendId); message.setSenderLoginName(sendLoginName); message.setSenderName(sendName); message.setSenderDeptName(sendDepName); try { message.setSendTimeStr(_$12492.format(rs.getTimestamp(4))); } catch(Exception e) { logger.debug(" initDbData Exception :".concat(String.valueOf(String.valueOf(e.getMessage())))); } message.setContent(rs.getString(5)); message.setReceiverId(receiveId); message.setReceiverLoginName(receiveLoginName); message.setReceiverName(receiveName); message.setReceiverDeptName(receiveDepName); message.setId(rs.getInt(6)); } } catch(Exception e) { throw e; } finally { if(dataConn != null) dataConn.close(); } } public void refreshApplication(ServletContext application) throws Exception { String db_deptNames[] = findByAllDep(); ArrayList db_users = (ArrayList)findByAllUser(); Hashtable online = new Hashtable(); Hashtable offline = new Hashtable(); ArrayList tmponline = null; ArrayList tmpoffline = null; synchronized(application) { String deptNames[] = (String[])application.getAttribute("deptName"); online = (Hashtable)application.getAttribute("online"); offline = (Hashtable)application.getAttribute("offline"); for(int i = 0; db_deptNames != null && i < db_deptNames.length; i++) { tmponline = (ArrayList)online.get(db_deptNames[i]); tmpoffline = (ArrayList)offline.get(db_deptNames[i]); if(tmponline == null && tmpoffline == null) { tmponline = new ArrayList(); tmpoffline = new ArrayList(); online.put(db_deptNames[i], tmponline); offline.put(db_deptNames[i], tmpoffline); } for(int j = 0; db_users != null && j < db_users.size(); j++) { User user1 = (User)db_users.get(j); tmpoffline.add(user1); tmponline.add(user1); } } application.setAttribute("deptName", db_deptNames); application.setAttribute("online", online); application.setAttribute("offline", offline); } } public void refreshApplicationWhenAddDept(ServletContext application, String deptName) throws Exception { synchronized(application) { String deptNames[] = (String[])application.getAttribute("deptName"); String db_deptNames[] = findByAllDep(); Hashtable online = (Hashtable)application.getAttribute("online"); Hashtable offline = (Hashtable)application.getAttribute("offline"); ArrayList tmponline = (ArrayList)online.get(deptName); ArrayList tmpoffline = (ArrayList)offline.get(deptName); if(tmponline == null && tmpoffline == null) {