cirdirectfile.java

一个日本流行的,功能较全的开源Web办公管理(Groupware)系统。

/*-
 * 夞棗偺妋擣僨乕僞娗棟梡   CIRdirectFile.java
 */
package jp.co.sjts.gsession.circular;

import java.util.List;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.Collections;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.BufferedReader;
import java.io.PrintWriter;
import java.io.IOException;
import java.util.StringTokenizer;
import jp.co.sjts.gsession.tools.*;

/**
 * <p>嫟捠娭悢掕媊僋儔僗  GSTool.java
 * <p>Copyright (C) 1999-2000 Japan Total System Co,LTD
 *
 * @author   Masakatu O   &lt;[e-mail]&gt;
 * @author   Satoru K  &lt;[e-mail]&gt;
 */
public class CIRdirectFile extends GSTextFile
{
	public static String FILENAME = "cirdirect";
	public static String FILENAME2= "cirdirectwk";
	public final static String DIR0 = "data" + File.separator ;
	public final static String DIR1 = "user" + File.separator ;
	public final static String SPATH = File.separator ;

	private List IdxList = null;		// 棙梡儌僕儏乕儖
	private CIRdirectData data=null;
	private int hitcnt;

	private File file;
	private String filePath;

	/**
	 * 巜掕偝傟偨抣傪尦偵僆僽僕僃僋僩傪惗惉偟傑偡丅
	 *
	 * @param HomeDir - 夞棗斅僨乕僞僨傿儗僋僩儕
	 * @param Id - 夞棗斅ID(mode=0)丄傑偨偼儐乕僓乕ID(mode=1 or 2)
	 * @param mode - 
	 */
	public CIRdirectFile(String HomeDir,String Id,int mode) throws GSException
	{
		init();
		switch(mode){
		case 0:// 
			filePath = HomeDir + DIR0 + Id ;//ID偼夞棗斅ID
			break;
		case 1:// 
			filePath = HomeDir + DIR1 + Id ;//ID偼儐乕僓乕ID
			break;
		case 2:// 
			filePath = HomeDir + DIR1 + Id ;//ID偼儐乕僓乕ID
			break;
		}

		File file1 = new File(filePath);

		if(!file1.exists())		// 僼傽僀儖偑懚嵼偡傞偐
			file1.mkdirs();		// 僼傽僀儖偑懚嵼偟側偄応崌偼丄嶌惉傪帋傒傞

		if(mode == 2)
			filePath = filePath + SPATH + FILENAME2;
		else
			filePath = filePath + SPATH + FILENAME;
		this.file = new File(filePath);

		if(file.exists()) {
			Load();
		}
	}

    public CIRdirectFile() throws GSException
    {
        init();
    }

    public synchronized boolean Get(String HomeDir,String Id) throws GSException
    {
        filePath = HomeDir + DIR0 + Id + SPATH + FILENAME;

        this.file = new File(filePath);

        if(file.exists()) {
            Load();
            return  true;
        }else{
            return  false;
        }
    }



//愨懳偄傞
	protected File GetFile()
	{
		return file;
	}


//愨懳偄傞
	synchronized protected void Write(PrintWriter pw) throws GSException
	{
		String[] buf = toModsString();
		for(int i=0;i<buf.length;i++) {
			pw.println(buf[i]);
		}
	}


//愨懳偄傞
	synchronized protected void Read(BufferedReader bf) throws GSException
	{
		init();

		try{
			String buf;

			for(buf=bf.readLine();buf!=null;buf=bf.readLine()) {
				StringTokenizer st = new StringTokenizer(buf,",");
				String id = st.nextToken();
				String memo = GSTool.delimitDecorde(",",st.nextToken());
				String date = st.nextToken();
				String uname = st.nextToken();

				Addmod(new CIRdirectData(id,memo,date,uname));
			}
		}catch(IOException e){
			throw new GSException("庴怣僨乕僞僼傽僀儖偺撉崬傒偵幐攕");
		}
	}

//婡擻

	//弶婜壔
	public synchronized void init()
	{
		IdxList = Collections.synchronizedList(new ArrayList());
	}

	//僒僀僘庢摼
	public synchronized int size()
	{
		return IdxList.size();
	}

	//嶍彍
	public synchronized void Deluid(String bid)
	{
		synchronized(IdxList){
			int cnt = -1 ;
			Iterator it=IdxList.iterator();

			for(int i=0;i<IdxList.size();i++) {
				data = (CIRdirectData)it.next();
				if( bid.equals( data.GetId()) ) {
					cnt = i ;
					break;
				}
			}
			if(cnt != -1) {
				IdxList.remove(cnt);
			}
		}
	}

	//
	/**
	 * <P>巜掕偝傟偨儐乕僓乕ID傪尦偵宖帵斅妋擣僨乕僞傪曉偟傑偡丅
	 *
	 * @param uid - 儐乕僓乕ID
	 * @return 宖帵斅妋擣僨乕僞
	 */
	public synchronized CIRdirectData DataChk(String uid)
	{
		hitcnt = -1;
		synchronized(IdxList){
			Iterator it=IdxList.iterator();
			for(int i=0;i<IdxList.size();i++) {
				data = (CIRdirectData)it.next();
				if( Integer.parseInt(data.GetId()) == Integer.parseInt(uid) ) {
					hitcnt = i;
					return data;
				}
			}
			return data;
		}
	}

	//捛壛
	/**
	 * <P>巜掕偝傟偨宖帵斅妋擣僨乕僞傪宖帵斅妋擣僨乕僞堦棗偵捛壛偟傑偡丅
	 *
	 * @param mod - 宖帵斅妋擣僨乕僞
	 */
	public synchronized void Addmod(CIRdirectData mod)
	{
		synchronized(IdxList){
			IdxList.add(mod);
		}
	}

	//捛壛
	/**
	 * <P>巜掕偝傟偨宖帵斅ID傪帩偮宖帵斅妋擣僨乕僞偑宖帵斅妋擣僨乕僞堦棗偵懚嵼偡傞応崌丄<BR>
	 * <P>偦偺宖帵斅妋擣僨乕僞傪巜掕偝傟偨宖帵斅妋擣僨乕僞偵峏怴偡傞丅<BR>
	 * <P>巜掕偝傟偨宖帵斅ID傪帩偮宖帵斅妋擣僨乕僞偑宖帵斅妋擣僨乕僞堦棗偵懚嵼偟側偄応崌丄<BR>
	 * <P>偦偺宖帵斅妋擣僨乕僞傪宖帵斅妋擣僨乕僞堦棗偵捛壛偡傞丅<BR>
	 *
	 * @param bid - 宖帵斅ID
	 * @param mod - 宖帵斅妋擣僨乕僞
	 */
	public synchronized void Addmod(String bid,CIRdirectData mod)
	{
		int hit = -1;
		synchronized(IdxList){
			Iterator it=IdxList.iterator();
			for(int i=0;i<IdxList.size();i++) {
				CIRdirectData mod1 = (CIRdirectData)it.next();
				if( bid.equals(mod1.GetId()) ) {
					hit = i;
					break;
				}
			}
			if(hit == -1)
				IdxList.add(mod);
			else
				IdxList.set(hit,mod);
		}
	}

	//峏怴
	/**
	 * <P>宖帵斅妋擣僨乕僞堦棗撪偺巜掕偝傟偨埵抲偵偁傞宖帵斅妋擣僨乕僞傪曉偟傑偡丅
	 *
	 * @param bullid - 庢摼偡傞宖帵斅妋擣僨乕僞偺埵抲
	 */
	public synchronized CIRdirectData Getmod(int bullid)
	{
		CIRdirectData mod = null;
		synchronized(IdxList){
			if( (bullid>=0)&&(bullid<IdxList.size()))
				mod = (CIRdirectData)IdxList.get(bullid);
			return mod;
		}
	}

	//峏怴
	public synchronized void update(CIRdirectData mod)
	{
		synchronized(IdxList){
			IdxList.set(hitcnt,mod);
		}
	}

	/**
	 * <P>宖帵斅妋擣僨乕僞堦棗撪偺宖帵斅妋擣僨乕僞傪慡偰暥帤楍昞尰偵曄姺偟偰曉偟傑偡丅
	 *
	 * @return 宖帵斅妋擣僨乕僞堦棗撪偺慡偰偺宖帵斅妋擣僨乕僞偺暥帤楍昞尰
	 */
	public synchronized String[] toModsString()
	{
		synchronized(IdxList){
			Iterator it=IdxList.iterator();
			String[] mods=new String[IdxList.size()];
			for(int i=0;i<IdxList.size();i++) {
				CIRdirectData mod = (CIRdirectData)it.next();
				mods[i] = mod.GetId() + ","  + GSTool.delimitEncorde(",",mod.GetMemo()) 
					+ "," + mod.GetDate() + "," + mod.GetUname() ;
			}
			return mods;
		}
	}


}