person.java

包括从业人员信息录入等功能

package person;
import java.sql.*;
import DB.*;
import java.util.*;

public class PERSON {
    private Connection conn=null;
    private PreparedStatement pstmt=null;
    private Statement stmt=null;
    private PersonBean pb=new PersonBean();
    /*------------------------------构造函数-----------------------------------*/
    public PERSON() {
        OpenDB op= new OpenDB();
                   if(op.openConnect()){
                       conn = op.getConnection();
                         try{
                         stmt=conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
                         }catch(Exception e){};
       }

    }
    /*--------------------设置bean ----------------------------*/
    public void setbean(PersonBean pb){this.pb=pb;}
    /*----------------------------查询BEAN------------------------------------*/
public PersonBean GetBeanBySQL(String sqlstr){
    try{
  ResultSet rs = stmt.executeQuery(sqlstr);
   while(rs.next()){
  String PERSONID = rs.getString("PERSONID");
  if((PERSONID!=null)&&(!PERSONID.equals("")))pb.setPERSONID(PERSONID);

  String FUNSERVERID = rs.getString("FUNSERVERID");
  if((FUNSERVERID!=null)&&(!FUNSERVERID.equals("")))pb.setFUNSERVERID(FUNSERVERID);

  String IDCARD = rs.getString("IDCARD");
  if((IDCARD!=null)&&(!IDCARD.equals("")))pb.setIDCARD(IDCARD);

  String PERSONNELNAME = rs.getString("PERSONNELNAME");
  if((PERSONNELNAME!=null)&&(!PERSONNELNAME.equals("")))pb.setPERSONNELNAME(PERSONNELNAME);

  String ZANZHUID = rs.getString("ZANZHUID");
  if((ZANZHUID!=null)&&(!ZANZHUID.equals("")))pb.setZANZHUID(ZANZHUID);

  String PHONE = rs.getString("PHONE");
  if((PHONE!=null)&&(!PHONE.equals("")))pb.setPHONE(PHONE);

  String SEX = rs.getString("SEX");
  if((SEX!=null)&&(!SEX.equals("")))pb.setSEX(SEX);

  String NATIVEPLACE = rs.getString("NATIVEPLACE");
  if((NATIVEPLACE!=null)&&(!NATIVEPLACE.equals("")))pb.setNATIVEPLACE(NATIVEPLACE);

  String NATION = rs.getString("NATION");
  if((NATION!=null)&&(!NATION.equals("")))pb.setNATION(NATION);

  String WORKINGTYPE = rs.getString("WORKINGTYPE");
  if((WORKINGTYPE!=null)&&(!WORKINGTYPE.equals("")))pb.setWORKINGTYPE(WORKINGTYPE);

  String PERSONNELLEVEL = rs.getString("PERSONNELLEVEL");
  if((PERSONNELLEVEL!=null)&&(!PERSONNELLEVEL.equals("")))pb.setPERSONNELLEVEL(PERSONNELLEVEL);

  String SUBAREA = rs.getString("SUBAREA");
  if((SUBAREA!=null)&&(!SUBAREA.equals("")))pb.setSUBAREA(SUBAREA);

  String REGISTERTIME = rs.getString("REGISTERTIME");
  if((REGISTERTIME!=null)&&(!REGISTERTIME.equals("")))pb.setREGISTERTIME(REGISTERTIME);

  String STATUS = rs.getString("STATUS");
  if((STATUS!=null)&&(!STATUS.equals("")))pb.setSTATUS(STATUS);

  String OPDATE = rs.getString("OPDATE");
  if((OPDATE!=null)&&(!OPDATE.equals("")))pb.setOPDATE(OPDATE);

  String PTYPE = rs.getString("PTYPE");
  if((PTYPE!=null)&&(!PTYPE.equals("")))pb.setPTYPE(PTYPE);

  String HOME = rs.getString("HOME");
  if((HOME!=null)&&(!HOME.equals("")))pb.setHOME(HOME);

  String NOWPLACE = rs.getString("NOWPLACE");
  if((NOWPLACE!=null)&&(!NOWPLACE.equals("")))pb.setNOWPLACE(NOWPLACE);


  }
    }catch(Exception e){}

        return pb;
    }
/*----------------------------------录入---------------------------------------*/
    public boolean addRecord(){
    boolean boo=false;
    try{
    String sql="insert into FUNSERVER_PERSONNEL(PERSONID,FUNSERVERID,IDCARD,PERSONNELNAME,ZANZHUID,PHONE,SEX,NATIVEPLACE,NATION,WORKINGTYPE,PERSONNELLEVEL,SUBAREA,REGISTERTIME,SPELL,ASPELL,STATUS,OBJID,OPDATE,PTYPE,HOME,NOWPLACE)"+
               " values(?,?,?,?,?,?,?,?,?,?,?,?,sysdate,?,?,?,?,?,?,?,?)";
    //System.out.print(sql);
    pstmt=conn.prepareStatement(sql);
    pstmt.setString(1,pb.getPERSONID());
    //System.out.print(pb.getPERSONID());
    pstmt.setString(2,pb.getFUNSERVERID());
    pstmt.setString(3,pb.getIDCARD());
    String PERSONNELNAME = pb.getPERSONNELNAME();
    if((PERSONNELNAME!=null)||(!PERSONNELNAME.equals("")))
    pstmt.setString(4,PERSONNELNAME);
    pstmt.setString(5,pb.getZANZHUID());
    pstmt.setString(6,pb.getPHONE());
    pstmt.setString(7,pb.getSEX());
    pstmt.setString(8,pb.getNATIVEPLACE());
    pstmt.setString(9,pb.getNATION());
    pstmt.setString(10,pb.getWORKINGTYPE());
    pstmt.setString(11,pb.getPERSONNELLEVEL());
    pstmt.setString(12,pb.getSUBAREA());
    //pstmt.setString(13,pb.getREGISTERTIME());
    String spell = pb.getSPELL();
    if((spell!=null)||(!spell.equals("")))pstmt.setString(13,spell);
    String ASPELL = pb.getASPELL(); if((ASPELL!=null)||(!ASPELL.equals("")))
    pstmt.setString(14,ASPELL);
    pstmt.setString(15,pb.getSTATUS());
    String OBJID = pb.getOBJID();
    if((OBJID!=null)||(!OBJID.equals("")))
    pstmt.setString(16,OBJID);
    pstmt.setString(17,pb.getOPDATE());
    pstmt.setString(18,pb.getPTYPE());
    pstmt.setString(19,pb.getHOME());
    pstmt.setString(20,pb.getNOWPLACE());

    pstmt.execute();
    boo=true;
    }catch(Exception e){}
    return boo;
    }
    /*--------------------------------更新------------------------------------*/
    public boolean update(String IDCARD,String FUNSERVERID){
    boolean bo=false;
    try{
    String sql="update FUNSERVER_PERSONNEL set PERSONNELNAME=?,ZANZHUID=?,PHONE=?,SEX=?,NATIVEPLACE=?,NATION=?,WORKINGTYPE=?,PERSONNELLEVEL=?,SUBAREA=?,REGISTERTIME=sysdate,SPELL=?,ASPELL=?,STATUS=?,OBJID=?,OPDATE=?,PTYPE=?,HOME=?,NOWPLACE=? where IDCARD='"+IDCARD+"' and FUNSERVERID='"+FUNSERVERID+"'";

    pstmt=conn.prepareStatement(sql);
    //pstmt.setString(1,pb.getPERSONID());
    //pstmt.setString(2,pb.getFUNSERVERID());
    //pstmt.setString(3,pb.getIDCARD());
    pstmt.setString(1,pb.getPERSONNELNAME());
    pstmt.setString(2,pb.getZANZHUID());
    pstmt.setString(3,pb.getPHONE());
    pstmt.setString(4,pb.getSEX());
    pstmt.setString(5,pb.getNATIVEPLACE());
    pstmt.setString(6,pb.getNATION());
    pstmt.setString(7,pb.getWORKINGTYPE());
    pstmt.setString(8,pb.getPERSONNELLEVEL());
    pstmt.setString(9,pb.getSUBAREA());
    //pstmt.setString(11,pb.getREGISTERTIME());
    pstmt.setString(10,pb.getSPELL());
    pstmt.setString(11,pb.getASPELL());
    pstmt.setString(12,pb.getSTATUS());
    pstmt.setString(13,pb.getOBJID());
    pstmt.setString(14,pb.getOPDATE());
    pstmt.setString(15,pb.getPTYPE());
    pstmt.setString(16,pb.getHOME());
    pstmt.setString(17,pb.getNOWPLACE());

    pstmt.execute();
    bo=true;
}catch(Exception e){System.out.print(e);}
    return bo;
    }
    //---------------------------检验从业人员是否存在------------------------------
    public boolean IsExist(String sql){
    boolean ok=false;
    try{
   ResultSet rs = stmt.executeQuery(sql);
   while(rs.next()){ok=true;}
    }catch(Exception e){}
    return ok;
    }
    //------------------------自动生成一个编号------------------------------------
    public String newid(String FUNSERVERID){
    String id="000001";
    try{
    String sql="select max(PERSONID)as id from FUNSERVER_PERSONNEL where substr(PERSONID,0,6)='"+FUNSERVERID+"'";
    //System.out.print(sql+"\n");
    ResultSet rs = stmt.executeQuery(sql);
        while (rs.next()) {
            id = rs.getString(1);
        }
       // System.out.print(id + "\n");
        if ((id == null) || (id.equals("")))
            id = FUNSERVERID+"000001";
        else {

            String nowid = String.valueOf(Integer.parseInt(id.substring(6, 12))+1);
            //System.out.print(nowid + "\n");
            int len = nowid.length();
            for (int i = 0; i < 6 - len; i++) {
                nowid = "0" + nowid;
            }
            id = FUNSERVERID.substring(0, 6) + nowid;
        }
    }catch(Exception e){}
    return id;
    }
 /*-------------------------------卡的注销-------------------------------*/
 public boolean updatestatus(String FUNSERVERID,String IDCARD){
 boolean ok= false;
 String sqlstr="update ICCARDLIST set status='0' where FUNSERVERID='"+FUNSERVERID+"' and IDCARD='"+IDCARD+"'";
 try{
 ResultSet rs=stmt.executeQuery(sqlstr);
 while(rs.next()){ok=true;}
 }catch(Exception e){}
 return ok;
 }
 public boolean delete(String personid){
  boolean ok= false;
  String sqlstr="delete from FUNSERVER_PERSONNEL where PERSONID='"+personid+"'";
  //System.out.print(sqlstr);
  try{
  ResultSet rs=stmt.executeQuery(sqlstr);
  while(rs.next()){ok=true;}
  }catch(Exception e){}
  return ok;
 }
   public static void main(String[] args) {
        PersonBean pb=new PersonBean();
       PERSON person = new PERSON();
       // String id=person.newid("F10002");
        //System.out.print("\n"+id);
   pb.setPERSONID("1");
   pb.setFUNSERVERID("2");
   //pstmt.setString(3,pb.getIDCARD());
   pb.setPERSONNELNAME("3");
   pb.setZANZHUID("4");
   pb.setPHONE("5");
   //pstmt.setString(6,pb.getSEX());
  // pstmt.setString(7,pb.getNATIVEPLACE());
  // pstmt.setString(8,pb.getNATION());
  // pstmt.setString(9,pb.getWORKINGTYPE());
  // pstmt.setString(10,pb.getPERSONNELLEVEL());
  // pstmt.setString(11,pb.getSUBAREA());
  // pstmt.setString(12,pb.getREGISTERTIME());
  // pstmt.setString(13,pb.getSPELL());
  // pstmt.setString(14,pb.getASPELL());
  // pstmt.setString(15,pb.getSTATUS());
  // pstmt.setString(16,pb.getOBJID());
  // pstmt.setString(17,pb.getOPDATE());
  // pstmt.setString(18,pb.getPTYPE());
  // pstmt.setString(29,pb.getHOME());
  // pstmt.setString(20,pb.getNOWPLACE());
  // pstmt.setString(21,pb.getIDCARD());
  person.setbean(pb);
  if(person.addRecord()){System.out.print("成功");}else{System.out.print("失败");}

    }
    /*------------------------场所查询--------------------------------------------*/
   public PersonBean GetBeanBySql(String sql){
   try{
   ResultSet rs =stmt.executeQuery(sql);
   while(rs.next()){
   String FUNSERVERID=rs.getString("FUNSERVERID");
   if((FUNSERVERID!=null)&&(!FUNSERVERID.equals(""))){pb.setFUNSERVERID(FUNSERVERID);}
   String FUNSERVERNAME=rs.getString("FUNSERVERNAME");
   if((FUNSERVERNAME!=null)&&(!FUNSERVERNAME.equals(""))){pb.setFUNSERVERNAME(FUNSERVERNAME);}
   String SUBAREA=rs.getString("SUBAREA");
   if((SUBAREA!=null)&&(!SUBAREA.equals(""))){pb.setSUBAREA(SUBAREA);}
  }
   }catch(Exception e){}
        return pb;
    }
    public List GetRecordBySql(String sql){
    List lst = new ArrayList();
    try{
    ResultSet rs =stmt.executeQuery(sql);
    while(rs.next()){
    PersonBean pb= new PersonBean();
    String FUNSERVERID=rs.getString("FUNSERVERID");
    if((FUNSERVERID!=null)&&(!FUNSERVERID.equals(""))){pb.setFUNSERVERID(FUNSERVERID);}
    String FUNSERVERNAME=rs.getString("FUNSERVERNAME");
    if((FUNSERVERNAME!=null)&&(!FUNSERVERNAME.equals(""))){pb.setFUNSERVERNAME(FUNSERVERNAME);}
    String SUBAREA=rs.getString("SUBAREA");
    if((SUBAREA!=null)&&(!SUBAREA.equals(""))){pb.setSUBAREA(SUBAREA);}
    lst.add(pb);
    }
    }catch(Exception e){}
    return lst;
    }



}