uidDAO

package th.in.oneauthen.object.DAO;

import java.util.List;

import org.apache.log4j.Logger;
import org.bouncycastle.util.encoders.Base64;

import th.athichitsakul.dao.impl.StandardDAOImpl;
import th.in.oneauthen.object.DocumentDB;
import th.in.oneauthen.object.SignatureProfileDB;
import th.in.oneauthen.object.UserUidDB;
import th.in.oneauthen.util.CryptoUtil;
import th.in.oneauthen.util.SystemLogger;

public class UserUidDAO extends StandardDAOImpl<UserUidDB> {
    public static final String SALT = "AccTkn-";
    private Logger logger = SystemLogger.generateSystemLogger(UserUidDAO.class);

    /**
     *  Introduce DAO in superclass that this UserDAOImpl going to use MySQL-PU persistance-unit configuration.
     */
    public UserUidDAO() {
        super("esigning");
    }

    /**
     * Instead of using method find, that can search any object by their primary key.
     * This method made this UserDAO can be search by username which is an another unique parameter.
     *
     * @param username
     * @return User instance of specify username
     */
    public UserUidDB findUsername(String username) {
        UserUidDB user = null;
        try {
            DAO.begin();
            user = (UserUidDB) DAO.getEntityManager()
                    .createNamedQuery("findByUsername")
                    .setParameter("userName", username).getSingleResult();
        } catch (Exception e) {
            logger.error("Invalid user loading with name "+username , e);
        } finally {
            DAO.close();
        }
        return user;
    }

    public static String generateUserAccessToken ( String username ) {
        try {
            String accessToken = Base64.toBase64String(CryptoUtil.encryptData((SALT+username).getBytes()));
            return accessToken;
        }catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    public static UserUidDB findUserByAccessToken ( String accessToken ) {
//      int userId = -1;
        try {
            String plainText = new String (CryptoUtil.decryptData(Base64.decode(accessToken)));
            plainText = plainText.replaceAll(SALT, "").trim();
//          userId = Integer.parseInt(plainText);

            return new UserUidDAO().findUsername(plainText);
        } catch ( Exception e ) {
            e.printStackTrace();
        }
        return null;
    }


    public void updateTimeLogin(UserUidDB updateData) {
        DAO.begin();
        try {
            UserUidDB db = DAO.getEntityManager().find(UserUidDB.class, updateData.getUserId());

            //== do update ==
            db.setLastLogin(updateData.getLastLogin());
            DAO.getEntityManager().merge(db);
            DAO.getTransaction().commit();
        }catch (Exception e) {
            if (DAO.getTransaction().isActive()) {
                DAO.getTransaction().rollback();
            }
            logger.error("Update last login failed for "+updateData.getUserName(),e);
        }

    }

    public List<UserUidDB> findUserLimt100(String type_id , int start ,int end) {
         List<UserUidDB> user = null;
        try {
            DAO.begin();
            user = (List<UserUidDB>) DAO.getEntityManager()
                    .createNamedQuery("findUser100")
                    .setParameter("type", type_id)
                    .setFirstResult(start)
                    .setMaxResults(end)
                    .getResultList();
        } catch (Exception e) {
            logger.error("Invalid user loading with type id = "+type_id , e);
        } finally {
            DAO.close();
        }
        return  user;
    }
}