Z-Archive » Maybank Projects » M2U UPASS Project

package my.com.upass.maybank;

import java.text.ParseException;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.Date;

import java.util.LinkedList;

import java.util.List;

import javax.jws.WebService;

import my.com.upass.MinimalConstants;

import my.com.upass.UPassControllerV2;

import my.com.upass.UPassException;

import my.com.upass.generic.hibernate.GenericDAOHibernate;

import my.com.upass.generic.hibernate.HibernateUtils;

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 my.com.upass.util.MapWrapper;

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 newIbccAdminUser(

                        String appAccessId, String hashedSecretKey,

                        String username, String hashedPassword) {

                final MinimalUserBean minUser = new MinimalUserBean();

                minUser.setUsername(username);

                minUser.setHashedPassword(hashedPassword);

                return newAdminUser(appAccessId, hashedSecretKey, minUser, ClientApp.APP_ID_CCPP);

        }

        @Override

        public int newIbccPublicUser(

                        String appAccessId, String hashedSecretKey,

                        String username, String hashedPassword, String panCc) {

                final IbccUser ibccUser = new IbccUser();

                ibccUser.setPanCc(panCc);

                final MinimalUserBean minUser = new MinimalUserBean();

                minUser.setUsername(username);

                minUser.setHashedPassword(hashedPassword);

                ibccUser.setMinUser(minUser);

                return newUser(appAccessId, hashedSecretKey, ibccUser);

        }

        @Override

        public int newOnlineStockUser(

                        String appAccessId, String hashedSecretKey,

                        String username, String idNo) {

                StockUser stockUser = new StockUser();

                stockUser.setIdNo(idNo);

                MinimalUserBean minUser = new MinimalUserBean();

                minUser.setUsername(username);

                stockUser.setMinUser(minUser);

                return newUser(appAccessId, hashedSecretKey, stockUser);

        }

        @Override

        public int newIm2uUser(

                        String appAccessId, String hashedSecretKey, String username,

                        String wsFlag, String wsIdentCode, String wsMySgId, Date wsRegTimeStamp) {

                Im2uUser im2uUser = new Im2uUser();

                im2uUser.setWsFlag(wsFlag);

                im2uUser.setWsIdentCode(wsIdentCode);

                im2uUser.setWsMySgId(wsMySgId);

                im2uUser.setWsRegTimeStamp(wsRegTimeStamp);

                MinimalUserBean minUser = new MinimalUserBean();

                minUser.setUsername(username);

                im2uUser.setMinUser(minUser);

                return newUser(appAccessId, hashedSecretKey, im2uUser);

        }

        @Override

        public int newTicketingUser(

                        String appAccessId, String hashedSecretKey,

                        String username, String hashedPassword,

                        String fullName, String firstName, String lastName, String payeeCode) {

                final TicketingUser ticketingUser = new TicketingUser();

                ticketingUser.setFullName(fullName);

                ticketingUser.setFirstName(firstName);

                ticketingUser.setLastName(lastName);

                ticketingUser.setPayeeCode(payeeCode);

                final MinimalUserBean minUser = new MinimalUserBean();

                minUser.setUsername(username);

                minUser.setHashedPassword(hashedPassword);

                ticketingUser.setMinUser(minUser);

                return newUser(appAccessId, hashedSecretKey, ticketingUser);

        }

        /**

         * @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 #lookupUsername(String, String, String)

         */

        @Override

        public Response lookupUsernameForApp_internal(

                        String appAccessId, String hashedSecretKey,

                        String username, Integer appId) {

                throw new java.lang.UnsupportedOperationException();

        }

        @Override

        public ResponseElement lookupUsernameForApp(

                        String appAccessId, String hashedSecretKey,

                        String username, Integer appId) {

                final Response response = super.lookupUsernameForApp_internal(

                                appAccessId, hashedSecretKey, username, appId);

                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 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, MapWrapper searchFilter) {

                ResponseListElement res = new ResponseListElement();

                final List<MapWrapper> items = new LinkedList<MapWrapper>();

                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.getMap());

                                examples.add(example);

                        }

                        List<UserProfile> profiles = upcV2.listProfilesByExamples(

                                        appAccessId, hashedSecretKey, examples, session);

                        for (UserProfile profile : profiles)

                                items.add(new MapWrapper(profile.propertiesToMap()));

                        res.setItems(items);

                        res.setCode(MinimalConstants.ERR_SUCCESS);

                } catch (UPassException e) {

                        LOGGER.info(e, e);

                        res.setCode(e.getErrorCode());

                } catch (ParseException e) {

                        LOGGER.error(e, e);

                        res.setCode(MinimalConstants.ERR_INVALID_INPUT);

                } 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);

                }

        }

        @Override

        public CountResponseElement getFailedLoginsCount(

                        String appAccessId, String hashedSecretKey, String username) {

                CountResponse response = super.getFailedLoginsCount(appAccessId, hashedSecretKey, username);

                return new CountResponseElement(response);

        }

        // Helper methods

        protected int newAdminUser(

                        String appAccessId, String hashedSecretKey, MinimalUserBean adminUser, Integer targetAppId) {

                int rc = MinimalConstants.ERR_UNKNOWN;

                Session session = null;

                try {

                        session = HibernateUtils.currentSession();

                        session.beginTransaction();

                        rc = upcV2.addUser(

                                        appAccessId, hashedSecretKey,

                                        adminUser, UserAppAccess.TYPE_ADMIN, targetAppId, session, true);

                        if (rc == MinimalConstants.ERR_SUCCESS)

                                session.getTransaction().commit();

                        else

                                GenericDAOHibernate.rollbackTransactionIfAny(session);

                } catch (Exception e) {

                        GenericDAOHibernate.rollbackTransactionIfAny(session);

                        LOGGER.error(e, e);

                } finally {

                        GenericDAOHibernate.closeSessionIfAny(session);

                }

                return rc;

        }

}