assetdao.java

固定资产管理系统 资产的增删改查 借出 管理 自动报废 统计功能等等

/*
 * @(#)AssetDAO.java apr 4, 2009
 * Copyright 2007 ThinkJ organization, Inc. All rights reserved
 */
package com.qrsx.asset.dao;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

import com.qrsx.asset.model.Asset;
import com.qrsx.asset.model.AssetType;
import com.qrsx.asset.model.Page;
import com.qrsx.asset.model.Storage;

/**
 * 
 * Author  : 马利永<br>
 * Company : qrsx<br>
 * Version : 1.0<br>
 * Date    : apr 4, 2009<br>
 */
public class AssetDAO extends BaseDAO{

    /**
     * 创建资产
     * @param Asset
     */
    public void create( Asset asset ) throws Exception{
    	asset.setDisprice(asset.getPrice());//创建时 折旧价格为购买价格
    	String sql = " Insert Into Asset(code, name, assetTypeId, model, client, " +
    			     " leaveFactoryDate, buyDate, life, price, deptment, use1," +
    			     "  storageId, addType, employeeId, state, disprice) " +
    			     " Values(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?,?)";
    	    	
    	//设置参数值
    	ps=conn.prepareStatement(sql);
    	processStatement1(asset,ps,sql);
        //执行
        ps.executeUpdate();
    }  
    /**
     * 更新资产
     * @param Asset
     */
    public void update( Asset asset ) throws Exception{
        
    	String sql = " update Asset set code=?, name=?, assetTypeId=?, " +
    			" model=?, client=?, leaveFactoryDate=?, buyDate=?, life=?, " +
    			" price=?, deptment=?, use1=? , storageId=?, addType=?, " +
    			" employeeId=?, state=? " +
    			" where id=? ";
        //设置参数值
        ps=conn.prepareStatement(sql);
        processStatement1(asset,ps,sql);
        //执行
        ps.executeUpdate();
    }  
    /**
     * 更新折旧价格
     * @param Asset
     */
    public void updateDisprice(Asset asset)throws Exception{
    	String sql=" Update asset Set disprice =? Where id = ? ";
    	 //设置参数值
        ps=conn.prepareStatement(sql);
        processStatement1(asset,ps,sql);
        //执行
        ps.executeUpdate();
    }
    /**
     * 更新状态
     * @param Asset
     */
 public void updateState( Asset asset ) throws Exception{
        
    	String sql = " update asset set  state=? " +
    			" where id=? ";
        //设置参数值
        ps=conn.prepareStatement(sql);
        processStatement1(asset,ps,sql);
        //执行
        ps.executeUpdate();
    }  
    /**
     * 删除资产
     * @param AssetId 要删除的用户主键
     * @return 删除的用户数目
     */
    public int delete( Integer assetId ) throws SQLException{
        String sql = "Delete from asset where id=? ";
        //设置参数值
        ps=conn.prepareStatement(sql);
        ps.setInt(1, assetId);
        //执行
        int total = ps.executeUpdate();
        return total;
    }
    /**
     * 根据主键检索资产
     * @param AssetId 要检索的用户主键
     * @return 检索到的用户
     */
    public Asset findById( Integer assetId ) throws Exception{
        String sql = "Select * From asset where id=? ";
        //设置参数值并执行查询
        ps=conn.prepareStatement(sql);
        ps.setInt(1, assetId);
        ResultSet rs = ps.executeQuery();
        
        Asset asset = null;
        if( rs.next() ){
        	asset = new Asset();
        	//自动组装对象
        	processResultset(asset, rs);   
        	//组装级联的AssetType对象
            AssetTypeDAO dao = new AssetTypeDAO();
            AssetType assetType = dao.findById(asset.getAssetTypeId());
            asset.setAssetType(assetType);
            //组装级联的Storage对象
            StorageDAO dao1=new StorageDAO();
             Storage storage= dao1.findById(asset.getStorageId());
             asset.setStorage(storage);
        }      
        return asset;
    }
    /**
     * 检索资产
     * @param Asset
     * @return
     */
    public List<Asset> findAll() throws Exception{
        String sql = " Select * From asset ";       
        //执行查询
        ps=conn.prepareStatement(sql);
        ResultSet rs = ps.executeQuery();     
        //将查询结果组装至Asset实体对象
        Asset asset = null; 
        List<Asset> list = new ArrayList<Asset>();
        AssetTypeDAO dao = new AssetTypeDAO();
        while( rs.next() ){
        	asset = new Asset();
        	//一行结果集组装，一个对象
        	processResultset(asset, rs);
        	//组装级联的assetType
            AssetType assetType = dao.findById(asset.getAssetTypeId());
            asset.setAssetType(assetType);
           //组装级联的Storage对象
            StorageDAO dao1=new StorageDAO();
             Storage storage= dao1.findById(asset.getStorageId());
            asset.setStorage(storage);
            
            list.add(asset);
        }       
        return list;
    }
    
    /**
     * 检索资产
     * @param Asset
     * @return
     */
    public Object[] list( Asset asset,Integer  currentpage) throws Exception{
        String sql = "Select * From asset Where 1=1 ";
        //根据资产名称检索
        if( asset.getName()!=null && !asset.getName().equals("") ){
            sql = sql + " And name Like '%" + asset.getName() + "%' ";
        }
        //根据资产类型检索
        if( asset.getAssetTypeId()!=null ){
            sql = sql + " And assetTypeId=" + asset.getAssetTypeId() + " ";
        }
        //根据资产状态查询
        if(asset.getState()!=null&&asset.getState().trim().length()>0){
        	sql=sql + " And state="+ asset.getState();
        }
        //执行查询
        ps=conn.prepareStatement(sql);
        ResultSet rs = ps.executeQuery();
        //实例化一个page对象
        Page page=new Page();
		pageIndex(page,rs,currentpage);
        //将查询结果组装至Asset实体对象
        List<Asset> list = new ArrayList<Asset>();
        AssetTypeDAO dao = new AssetTypeDAO();
        StorageDAO dao1=new StorageDAO();
        while( rs.next()&&list.size()<page.getSize()){
        	Asset	asset1 = new Asset();
        	processResultset(asset1, rs);//一行结果集组装，一个对象
        	//组装级联的assetType
            AssetType assetType = dao.findById(asset1.getAssetTypeId());
            asset1.setAssetType(assetType);
            //组装级联的Storage对象         
             Storage storage= dao1.findById(asset1.getStorageId());
             asset1.setStorage(storage);
            list.add(asset1);
        }
        Object [] lp={list,page};
        return lp;
    }
}