testservicepojoimp.java

功能完善的java开发框架

/*
 * Copyright 2003-2005 the original author or authors.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 */
package com.jdon.framework.test.service;


import org.apache.log4j.Logger;

import com.jdon.container.visitor.data.SessionContext;
import com.jdon.container.visitor.data.SessionContextAcceptable;
import com.jdon.controller.events.EventModel;
import com.jdon.controller.model.PageIterator;
import com.jdon.controller.pool.Poolable;
import com.jdon.framework.test.Constants;
import com.jdon.framework.test.dao.JdbcDAO;
import com.jdon.framework.test.model.UserTest;
import com.jdon.security.web.UserPrincipalSetup;

/**
 * this class implements Poolable, that will active the pool function
 * @author <a href="mailto:[e-mail]">banq </a>
 *
 */
public class TestServicePOJOImp implements TestService, Poolable, SessionContextAcceptable{
    private final static Logger logger = Logger
            .getLogger(TestServicePOJOImp.class);

    private JdbcDAO jdbcDao;
    protected SessionContext sessionContext;
    private UserPrincipalSetup userPrincipalSetup;
    
    /**
     *
     */
    public TestServicePOJOImp(JdbcDAO jdbcDao, UserPrincipalSetup userPrincipalSetup) {
        this.userPrincipalSetup = userPrincipalSetup;
        this.jdbcDao = jdbcDao;
    }

    public void createUser(EventModel em) {
        UserTest user = (UserTest) em.getModel();
        try {
            jdbcDao.insert(user);
            logger.debug(" userId:" + user.getUserId());
            logger.debug(" userName:" + user.getName());
            String principleName = userPrincipalSetup.getPrincipalName(sessionContext);
            logger.debug(" principleName:" + principleName);
            clearCache();
        } catch (Exception ex) {
            logger.error(ex);
            em.setErrors(Constants.USER_SAVE_ERROR);
        }

    }

    public void updateUser(EventModel em) {
        UserTest user = (UserTest) em.getModel();
        try {
            jdbcDao.update(user);
            logger.debug(" update ok!");
            logger.debug(" userId:" + user.getUserId());
            logger.debug(" userName:" + user.getName());
            
            clearCache();
        } catch (Exception ex) {
            logger.error(ex);
            em.setErrors(Constants.USER_SAVE_ERROR);
        }

    }

    public void deleteUser(EventModel em) {
        UserTest user = (UserTest) em.getModel();
        try {
            jdbcDao.delete(user);
            clearCache();
            logger.debug(" delete ok!");
            String principleName = userPrincipalSetup.getPrincipalName(sessionContext);
            logger.debug(" principleName:" + principleName);
            
        } catch (Exception ex) {
            logger.error(ex);
            em.setErrors(Constants.USER_SAVE_ERROR);
        }
    }
    
    public UserTest initUser(){
        UserTest usertest = new UserTest();
        String principleName = userPrincipalSetup.getPrincipalName(sessionContext);
        logger.debug(" principleName:" + principleName);
        
        usertest.setPrincipleName(principleName);
        return usertest;
    }

    public UserTest getUser(String userId) {
        logger.debug(" get User from DAO + JDBC");
        UserTest usertest =  jdbcDao.getUser(userId);
        String principleName = userPrincipalSetup.getPrincipalName(sessionContext);
        logger.debug(" principleName:" + principleName);
        usertest.setPrincipleName(principleName);
        return usertest;

    }

    public PageIterator getAllUsers(int start, int count) {
        PageIterator pageIterator = new PageIterator(PageIterator.EMPTY, 0,
                false);
        try {
            pageIterator = jdbcDao.getUsers(start, count);
        } catch (Exception ex) {
            logger.error(ex);
        }
        return pageIterator;

    }

    private void clearCache() throws Exception {
        jdbcDao.clearCacheOfItem();
    }
    
    /**
     * @return Returns the sessionContext.
     */
    public SessionContext getSessionContext() {
        return sessionContext;
    }
    /**
     * @param sessionContext The sessionContext to set.
     */
    public void setSessionContext(SessionContext sessionContext) {
        this.sessionContext = sessionContext;
    }    

}