cidirfile.java

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

package jp.co.sjts.gsession.circular;

/*
 * Circular 偺XXXX  CIDirFile.java
 * Copyright (C) 1999-2000 Japan Total System Co,LTD
 *	  Masakatu O	<[e-mail]>
 */

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.*;

public class CIDirFile extends GSTextFile
{
	private List IdxList = null;	// 棙梡儌僕儏乕儖
	private CIDirData data=null;

	public static String FILENAME = "direct";

	private File file;

	/**
	 * <P>巜掕偝傟偨抣傪尦偵僆僽僕僃僋僩傪惗惉偟傑偡丅
	 *
	 * @param HomeDir - 夞棗斅僨乕僞僨傿儗僋僩儕僷僗
	 * @param UserDir - 儐乕僓乕ID
	 * @param filename - 僼傽僀儖柤(cirdirect,cirdirectwk)
	 * @param mode - 張棟儌乕僪(1 : 巜掕偟偨僼傽僀儖傪嶍彍, 偦傟埲奜 : 巜掕偟偨僼傽僀儖傪撉傒崬傓)
	 */
	public CIDirFile(String HomeDir,String UserDir,String filename,int mode) throws GSException
	{
		init();
		FILENAME = filename;
		String filePath = HomeDir + "user" + File.separator + UserDir + File.separator;

		File file1 = new File(filePath);

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

		filePath = filePath + FILENAME;
		this.file = new File(filePath);

		if(file.exists()) {
			if( mode == 1 )
				file.delete();
			else
				Load();
		}
	}


//愨懳偄傞
	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()) {
				String buf2;
				String id="";
				String name="";
				String uid="";
				String memo="";

				StringTokenizer st = new StringTokenizer(buf,",",true);
				if((buf2 = st.nextToken()).equals(","))
					throw new GSException("僼傽僀儖僨乕僞偑晄惓偱偡丅");
				id = buf2;

				if(!(buf2 = st.nextToken()).equals(","))
					throw new GSException("僼傽僀儖僨乕僞偑晄惓偱偡丅");

				if((buf2 = st.nextToken()).equals(","))
					throw new GSException("僼傽僀儖僨乕僞偑晄惓偱偡丅");
			       	name = buf2;

				if(!(buf2 = st.nextToken()).equals(","))
					throw new GSException("僼傽僀儖僨乕僞偑晄惓偱偡丅");

				if((buf2 = st.nextToken()).equals(",")) {
					uid = "";
				}else{
					uid = buf2;
				}
				if(buf2.equals(",")){
					if((buf2 = st.nextToken()).equals(","))
						throw new GSException("僼傽僀儖僨乕僞偑晄惓偱偡丅");
					else
						memo = buf2;
				}else{
					if(!(buf2 = st.nextToken()).equals(",")){
						throw new GSException("僼傽僀儖僨乕僞偑晄惓偱偡丅");
					}else{
						if((buf2 = st.nextToken()).equals(","))
							throw new GSException("僼傽僀儖僨乕僞偑晄惓偱偡丅");
						else
							memo = buf2;
					}
				}

				Addmod(new CIDirData(id,name,uid,memo));
			}
		}catch(IOException e){
			throw new GSException("夞棗僌儖乕僾僨乕僞僼傽僀儖偺撉崬傒偵幐攕");
		}
	}

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

	/**
	 * <P>僆僽僕僃僋僩撪偺夞棗斅僨乕僞偺憤悢傪庢摼偡傞丅
	 *
	 * @return 僆僽僕僃僋僩撪偺夞棗斅僨乕僞偺悢
	 */
	public synchronized int size()
	{
		return IdxList.size();
	}

	/**
	 * <P>巜掕偝傟偨夞棗斅ID偺夞棗斅傪夞棗斅僨乕僞堦棗偐傜嶍彍偡傞丅
	 *
	 * @param id - 夞棗斅ID
	 */
	public synchronized void Del(String id)
	{
		synchronized(IdxList){
			int cnt = -1;
			Iterator it=IdxList.iterator();
			for(int i=0;i<IdxList.size();i++) {
				data = (CIDirData)it.next();
				if( id.equals( data.GetId()) ) {
					cnt = i;
					break;
				}
			}
			if(cnt != -1) {
				IdxList.remove(cnt);
			}
		}
	}

	/**
	 * <P>巜掕偝傟偨夞棗斅ID傪尦偵夞棗斅僨乕僞徻嵶僆僽僕僃僋僩傪庢摼偡傞丅
	 *
	 * @param id - 夞棗斅ID
	 * @return 夞棗斅僨乕僞僆僽僕僃僋僩
	 */
	public synchronized CIDirData GetMOD(String bid)
	{
		synchronized(IdxList){
			int cnt = -1;
			Iterator it=IdxList.iterator();
			for(int i=0;i<IdxList.size();i++) {
				data = (CIDirData)it.next();
				if( Integer.parseInt(data.GetId()) == Integer.parseInt(bid) ) {
					cnt = i;
					break;
				}
			}
			return  Getmod(cnt);
		}
	}

	//捛壛
	public synchronized void Addmod(CIDirData mod)
	{
		synchronized(IdxList){
			IdxList.add(mod);
		}
	}

	//峏怴
	public synchronized CIDirData Getmod(int idx)
	{
		CIDirData mod = null;
		synchronized(IdxList){
			if( (idx>=0)&&(idx<IdxList.size()))
				mod = (CIDirData)IdxList.get(idx);
			return mod;
		}
	}

	//
	public synchronized String[] toModsString()
	{
		synchronized(IdxList){
			Iterator it=IdxList.iterator();
			String[] mods=new String[IdxList.size()];
			for(int i=0;i<IdxList.size();i++) {
				CIDirData mod = (CIDirData)it.next();
				mods[i] = mod.toString();
			}
			return mods;
		}
	}

	//峏怴
	public synchronized void update(CIDirData idata)
	{
		synchronized(IdxList){
			int cnt = -1;
			Iterator it=IdxList.iterator();
			for(int i=0;i<IdxList.size();i++) {
				data = (CIDirData)it.next();
				if( Integer.parseInt(data.GetId()) == Integer.parseInt(idata.GetId()) ) {
					IdxList.set(i,idata);
					break;
				}
			}
		}
	}


}