wfuserdao.java

公司自己开发的工作流引擎

    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  /**
   * 往表wf_user插入记录
   * @param user WfUser
   * @throws Exception
   */
  public void insert(WfUser user)
      throws Exception{
    logger.info("begin insert(WfUser user)...");
    Connection conn=null;
    Statement stm=null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      StringBuffer sbInsertValue=this.getStrInsertValues(user);
      String sql=" insert into wf_user ("+this.getStrFields()+
          ") "+" values ("+sbInsertValue.toString()+")";
      logger.info("......insert sql:"+sql);
      stm.execute(sql);

      //保存业务系统在wf_user表上扩充的字段的值
      saveExtFieldData(user.getUserId(),user.getExtFieldList());
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  /**
   * 更新wf_user信息
   * @param user WfUser
   * @throws SQLException
   * @return List
   */
  public void update(WfUser user,String userId)
      throws Exception{
    Connection conn=null;
    Statement stm=null;
    try{
      conn=WorkflowDBConnectionManager.getInstance().getConnection();
      stm=conn.createStatement();
      String sql=" update wf_user set ";
      StringBuffer sbWhere=new StringBuffer(" where user_id='"+userId+"'");
      StringBuffer sbUpdata=getStrUpdateValues(user);
      if(sbWhere.length()<=0||sbUpdata.length()<=0){
        throw new Exception("更新数据为空！");
      }
      sql=sql+sbUpdata.toString()+sbWhere.toString();
      logger.info("......update sql:"+sql);
      stm.execute(sql);

      //更新业务系统扩充的字段的值，方法是先删除扩展数据，再重新保存
      delExtFieldDate(user.getUserId());
      this.saveExtFieldData(user.getUserId(),user.getExtFieldList());
    }
    finally{
      WorkflowDBConnectionManager.getInstance().close(stm,false);
      WorkflowDBConnectionManager.getInstance().close(conn);
    }
  }

  /**
   * 通过用户登录id取得用户信息
   * @param loginId String
   * @return LaUser
   */
  public WfUser getUserInfoByLoginId(String loginId)
      throws SQLException{
    WfUser user=new WfUser();
    user.setLoginId(loginId);
    List list=query(user);
    if(list!=null&&list.size()>0){
      user=(WfUser)list.get(0);
    }
    else{
      user=null;
    }
    return user;
  }

  private List resultsetToVO(ResultSet rs)
      throws SQLException{
    List list=new ArrayList();
    while(rs.next()){
      WfUser user=new WfUser();
      user.setDescription(rs.getString("description"));
      user.setEmail(rs.getString("e_mail"));
      user.setLoginId(rs.getString("login_id"));
      user.setPassword(rs.getString("password"));
      user.setRelaPhone(rs.getString("rela_phone"));
      user.setUserCode(rs.getString("user_code"));
      user.setUserId(rs.getString("user_id"));
      user.setUserName(rs.getString("user_name"));
      user.setUserOrder(rs.getLong("user_order"));
      user.setUserPosition(rs.getString("user_position"));
      user.setUserState(rs.getString("user_state"));
      list.add(user);
    }
    return list;
  }

  private StringBuffer getQueryString(WfUser user){
    StringBuffer sb=new StringBuffer();
    if(user!=null){
      if(user.getDescription()!=null&&!user.getDescription().equals("")){
        sb.append(" description = '"+user.getDescription()+"' ");
        sb.append(" and ");
      }
      if(user.getEmail()!=null&&!user.getEmail().equals("")){
        sb.append(" e_mail = '"+user.getEmail()+"' ");
        sb.append(" and ");
      }

      if(user.getLoginId()!=null&&!user.getLoginId().equals("")){
        sb.append(" login_id = '"+user.getLoginId()+"' ");
        sb.append(" and ");
      }
      if(user.getPassword()!=null&&!user.getPassword().equals("")){
        sb.append(" password = '"+user.getPassword()+"' ");
        sb.append(" and ");
      }
      if(user.getRelaPhone()!=null&&!user.getRelaPhone().equals("")){
        sb.append(" rela_phone = '"+user.getRelaPhone()+"' ");
        sb.append(" and ");
      }
      if(user.getUserCode()!=null&&!user.getUserCode().equals("")){
        sb.append(" user_code = '"+user.getUserCode()+"' ");
        sb.append(" and ");
      }
      if(user.getUserId()!=null&&!user.getUserId().equals("")){
        sb.append(" user_id = '"+user.getUserId()+"' ");
        sb.append(" and ");
      }
      if(user.getUserName()!=null&&!user.getUserName().equals("")){
        sb.append(" user_name = '"+user.getUserName()+"' ");
        sb.append(" and ");
      }
      if(user.getUserOrder()!=WorkflowConstant.LONG_INIT_VALUE){
        sb.append(" user_order = "+user.getUserOrder());
        sb.append(" and ");
      }
      if(user.getUserPosition()!=null&&!user.getUserPosition().equals("")){
        sb.append(" user_position = '"+user.getUserPosition()+"' ");
        sb.append(" and ");
      }
      if(user.getUserState()!=null&&!user.getUserState().equals("")){
        sb.append(" user_state = '"+user.getUserState()+"' ");
        sb.append(" and ");
      }
    }
    if(sb.length()>0){
      //增加查询条件关键字
      sb.insert(0," where ");
      //去除最后一个" AND "操作符
      sb.delete(sb.length()-5,sb.length());
    }
    return sb;
  }

  /**
   * 根据user取得insert语句
   * @param user WfUser
   * @throws Exception
   * @return StringBuffer
   */
  private StringBuffer getStrInsertValues(WfUser user)
      throws Exception{
    StringBuffer sbSQL=new StringBuffer();
    if(user.getDescription()!=null&&!user.getDescription().equals("")){
      sbSQL.append("'");
      sbSQL.append(user.getDescription());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(user.getEmail()!=null&&!user.getEmail().equals("")){
      sbSQL.append("'");
      sbSQL.append(user.getEmail());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }


    if(user.getLoginId()!=null&&!user.getLoginId().equals("")){
      sbSQL.append("'");
      sbSQL.append(user.getLoginId());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(user.getPassword()!=null&&!user.getPassword().equals("")){
      sbSQL.append("'");
      sbSQL.append(user.getPassword());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(user.getRelaPhone()!=null&&!user.getRelaPhone().equals("")){
      sbSQL.append("'");
      sbSQL.append(user.getRelaPhone());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(user.getUserCode()!=null&&!user.getUserCode().equals("")){
      sbSQL.append("'");
      sbSQL.append(user.getUserCode());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(user.getUserId()!=null&&!user.getUserId().equals("")){
      sbSQL.append("'");
      sbSQL.append(user.getUserId());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(user.getUserName()!=null&&!user.getUserName().equals("")){
      sbSQL.append("'");
      sbSQL.append(user.getUserName());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(user.getUserOrder()!=WorkflowConstant.LONG_INIT_VALUE){
      sbSQL.append(user.getUserOrder());
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(user.getUserPosition()!=null&&!user.getUserPosition().equals("")){
      sbSQL.append("'");
      sbSQL.append(user.getUserPosition());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(user.getUserState()!=null&&!user.getUserState().equals("")){
      sbSQL.append("'");
      sbSQL.append(user.getUserState());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    if(user.getCreator()!=null&&!user.getCreator().equals("")){
      sbSQL.append("'");
      sbSQL.append(user.getCreator());
      sbSQL.append("'");
      sbSQL.append(",");
    }
    else{
      sbSQL.append("null");
      sbSQL.append(",");
    }

    //删除最后一个逗号
    sbSQL.delete(sbSQL.length()-1,sbSQL.length());
    return sbSQL;
  }

  /**
   * 根据user取得update语句
   * @param user WfUser
   * @throws Exception
   * @return StringBuffer
   */
  private StringBuffer getStrUpdateValues(WfUser user)
      throws Exception{
    StringBuffer sbSQL=new StringBuffer();
    if(user.getDescription()!=null&&!user.getDescription().equals("")){
      sbSQL.append("description=");
      sbSQL.append("'");
      sbSQL.append(user.getDescription());
      sbSQL.append("'");
      sbSQL.append(",");
    }

    if(user.getEmail()!=null&&!user.getEmail().equals("")){
      sbSQL.append("e_mail=");
      sbSQL.append("'");
      sbSQL.append(user.getEmail());
      sbSQL.append("'");
      sbSQL.append(",");
    }