Z-Archive » Maybank Projects » M2U UPASS Project

package my.com.upass.maybank;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.LinkedList;

import java.util.List;

import java.util.Map;

import javax.jws.WebService;

import my.com.upass.MinimalConstants;

import my.com.upass.UPassControllerV2;

import my.com.upass.UPassException;

import my.com.upass.maybank.entities.IbccUser;

import my.com.upass.maybank.entities.Im2uUser;

import my.com.upass.maybank.entities.M2uUser;

import my.com.upass.maybank.entities.StockUser;

import my.com.upass.maybank.entities.TicketingUser;

import my.com.upass.maybank.entities.UserProfile;

import my.com.upass.pojo.ClientApp;

import my.com.upass.pojo.MinimalUserBean;

import my.com.upass.pojo.UserAppAccess;

import net.penril.generic.hibernate.GenericDAOHibernate;

import net.penril.generic.hibernate.HibernateUtils;

import org.apache.commons.lang.NotImplementedException;

import org.apache.log4j.Logger;

import org.hibernate.Session;

/**

 * @author Hadi

 * 

 */

@WebService(

                serviceName = "MaybankFacade",

                endpointInterface = "my.com.upass.maybank.MaybankFacade")

//

public class MaybankFacadeImpl

                extends MinimalMaybankFacadeImpl

                implements MaybankFacade {

        private static final Logger LOGGER = Logger.getLogger(MaybankFacadeImpl.class);

        private final UPassControllerV2 upcV2;

        //

        public MaybankFacadeImpl() {

                upcV2 = new UPassControllerV2();

        }

        @Override

        public int newAdminUser(

                        String appAccessId, String hashedSecretKey,

                        String username, String hashedPassword) {

                IbccUser ibccUser = new IbccUser();

                // ibccUser.setPanCc(panCc);

                MinimalUserBean minUser = new MinimalUserBean();

                minUser.setUsername(username);

                minUser.setHashedPassword(hashedPassword);

                ibccUser.setMinUser(minUser);

                return newAdminUser(appAccessId, hashedSecretKey, ibccUser);

        }

        public int newPublicUser(

                        String appAccessId, String hashedSecretKey,

                        String username, String hashedPassword, String panCc) {

                IbccUser ibccUser = new IbccUser();

                ibccUser.setPanCc(panCc);

                MinimalUserBean minUser = new MinimalUserBean();

                minUser.setUsername(username);

                minUser.setHashedPassword(hashedPassword);

                ibccUser.setMinUser(minUser);

                return newUser(appAccessId, hashedSecretKey, ibccUser);

        }

        @Override

        public int convertPublicToM2u(

                        String appAccessId, String hashedSecretKey,

                        String username, String pan1, String pan2) {

                // TODO Auto-generated method stub

                throw new NotImplementedException();

        }

        /**

         * @deprecated

         * @see #lookupUsername(String, String, String)

         */

        @Override

        public Response lookupUsername_internal(

                        String appAccessId, String hashedSecretKey, String username) {

                throw new java.lang.UnsupportedOperationException();

        }

        @Override

        public ResponseElement lookupUsername(

                        String appAccessId, String hashedSecretKey, String username) {

                final Response response = super.lookupUsername_internal(appAccessId, hashedSecretKey, username);

                return new ResponseElement(response);

        }

        /**

         * @deprecated

         * @see #lookupPublicUsername(String, String, String)

         */

        @Override

        public Response lookupPublicUsername_internal(

                        String appAccessId, String hashedSecretKey, String username) {

                throw new java.lang.UnsupportedOperationException();

        }

        @Override

        public ResponseElement lookupPublicUsername(

                        String appAccessId, String hashedSecretKey, String username) {

                final Response response = super.lookupPublicUsername_internal(appAccessId, hashedSecretKey, username);

                return new ResponseElement(response);

        }

        /**

         * @deprecated

         * @see #lookupPan1(String, String, String)

         */

        @Override

        public Response lookupPan1_internal(

                        String appAccessId, String hashedSecretKey, String pan1) {

                throw new java.lang.UnsupportedOperationException();

        }

        @Override

        public ResponseElement lookupPan1(

                        String appAccessId, String hashedSecretKey, String pan1) {

                final Response response = super.lookupPan1_internal(appAccessId, hashedSecretKey, pan1);

                return new ResponseElement(response);

        }

        /**

         * @deprecated

         * @see #lookupPan2(String, String, String)

         */

        @Override

        public Response lookupPan2_internal(

                        String appAccessId, String hashedSecretKey, String pan1) {

                throw new java.lang.UnsupportedOperationException();

        }

        @Override

        public ResponseElement lookupPan2(

                        String appAccessId, String hashedSecretKey, String pan2) {

                final Response response = super.lookupPan2_internal(appAccessId, hashedSecretKey, pan2);

                return new ResponseElement(response);

        }

        /**

         * @deprecated

         * @see #lookupPanCc(String, String, String)

         */

        @Override

        public Response lookupPanCc_internal(

                        String appAccessId, String hashedSecretKey, String panCc) {

                throw new java.lang.UnsupportedOperationException();

        }

        @Override

        public ResponseElement lookupPanCc(

                        String appAccessId, String hashedSecretKey, String panCc) {

                final Response response = super.lookupPanCc_internal(appAccessId, hashedSecretKey, panCc);

                return new ResponseElement(response);

        }

        @Override

        public ResponseElement lookupUsernameByGroup(

                        String appAccessId, String hashedSecretKey,

                        String username) {

                // TODO Auto-generated method stub

                throw new NotImplementedException();

        }

        @Override

        public int deleteUser(

                        String appAccessId, String hashedSecretKey,

                        String username) {

                int rc = MinimalConstants.ERR_UNKNOWN;

                Session session = null;

                try {

                        session = HibernateUtils.currentSession();

                        session.beginTransaction();

                        rc = upcV2.deleteUserWithTheProfile(appAccessId, hashedSecretKey, username, session);

                        if (rc == MinimalConstants.ERR_SUCCESS)

                                session.getTransaction().commit();

                        else

                                GenericDAOHibernate.rollbackTransactionIfAny(session);

                } catch (UPassException e) {

                        rc = e.getErrorCode();

                        e.printStackTrace();

                        GenericDAOHibernate.rollbackTransactionIfAny(session);

                } catch (Exception e) {

                        LOGGER.error(e, e);

                        GenericDAOHibernate.rollbackTransactionIfAny(session);

                } finally {

                        GenericDAOHibernate.closeSessionIfAny(session);

                }

                return rc;

        }

        @Override

        public ResponseListElement searchUserByFilter(

                        String appAccessId, String hashedSecretKey,

                        Map<String, String> searchFilter) {

                ResponseListElement res = new ResponseListElement();

                final List<Map<String, String>> items = new LinkedList<Map<String, String>>();

                Session session = null;

                try {

                        session = HibernateUtils.currentSession();

                        List<UserProfile> examples = new ArrayList<UserProfile>(5);

                        for (Class<? extends UserProfile> clazz : Arrays.asList(

                                        IbccUser.class, Im2uUser.class, M2uUser.class, StockUser.class, TicketingUser.class)) {

                                final UserProfile example = clazz.newInstance();

                                example.mapToProperties(searchFilter);

                                examples.add(example);

                        }

                        List<UserProfile> profiles = upcV2.listProfilesByExamples(

                                        appAccessId, hashedSecretKey, examples, session);

                        for (UserProfile profile : profiles)

                                items.add(profile.propertiesToMap());

                        res.setItems(items);

                        res.setCode(MinimalConstants.ERR_SUCCESS);

                } catch (UPassException e) {

                        LOGGER.info(e, e);

                        res.setCode(e.getErrorCode());

                } catch (Exception e) {

                        LOGGER.error(e, e);

                        res.setCode(MinimalConstants.ERR_UNKNOWN);

                } finally {

                        GenericDAOHibernate.closeSessionIfAny(session);

                }

                return res;

        }

        @Override

        public int changeIdNo(

                        String appAccessId, String hashedSecretKey,

                        String username, String idNo) {

                Session session = null;

                try {

                        session = HibernateUtils.currentSession();

                        session.beginTransaction();

                        UserProfile profile = upcV2.findProfile(

                                        appAccessId, hashedSecretKey, username, ClientApp.APP_ID_ONLINE_STOCK, session);

                        if (profile instanceof StockUser) {

                                StockUser stockUser = (StockUser) profile;

                                stockUser.setIdNo(idNo);

                                int rc = upcV2.updateProfileShallowly(

                                                appAccessId, hashedSecretKey, stockUser, session);

                                if (rc == MinimalConstants.ERR_SUCCESS)

                                        session.getTransaction().commit();

                                else

                                        GenericDAOHibernate.rollbackTransactionIfAny(session);

                                return rc;

                        } else {

                                GenericDAOHibernate.rollbackTransactionIfAny(session);

                                return MinimalConstants.ERR_INVALID_INPUT;

                        }

                } catch (UPassException e) {

                        LOGGER.info(e, e);

                        GenericDAOHibernate.rollbackTransactionIfAny(session);

                        return e.getErrorCode();

                } catch (Exception e) {

                        LOGGER.error(e, e);

                        GenericDAOHibernate.rollbackTransactionIfAny(session);

                        return MinimalConstants.ERR_UNKNOWN;

                } finally {

                        GenericDAOHibernate.closeSessionIfAny(session);

                }

        }

        // Helper methods

        protected int newAdminUser(

                        String appAccessId, String hashedSecretKey, UserProfile profile) {

                int rc = MinimalConstants.ERR_UNKNOWN;

                Session session = null;

                try {

                        session = HibernateUtils.currentSession();

                        session.beginTransaction();

                        rc = upcV2.addUser(

                                        appAccessId, hashedSecretKey, profile.getMinUser(), UserAppAccess.TYPE_ADMIN, session);

                        if (rc == MinimalConstants.ERR_SUCCESS) {

                                rc = upcV2.updateProfileShallowly(appAccessId, hashedSecretKey, profile, session);

                                if (rc == MinimalConstants.ERR_SUCCESS)

                                        session.getTransaction().commit();

                                else

                                        GenericDAOHibernate.rollbackTransactionIfAny(session);

                        } else

                                GenericDAOHibernate.rollbackTransactionIfAny(session);

                } catch (Exception e) {

                        GenericDAOHibernate.rollbackTransactionIfAny(session);

                        LOGGER.error(e, e);

                } finally {

                        GenericDAOHibernate.closeSessionIfAny(session);

                }

                return rc;

        }

}