package com.l2wolf.hook;
import java.sql.Connection;
import java.sql.Date;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.security.*;
import java.util.Locale;

import javax.annotation.Resource;
import javax.sql.DataSource;


import com.liferay.portal.kernel.exception.PortalException;
import com.liferay.portal.kernel.exception.SystemException;
import com.liferay.portal.model.User;
import com.liferay.portal.service.ServiceContext;
import com.liferay.portal.service.UserLocalService;
import com.liferay.portal.service.UserLocalServiceWrapper;
import com.liferay.portal.service.persistence.UserUtil;
import com.mysql.jdbc.PreparedStatement;

public class L2WolfUserLocalServiceImpl extends  UserLocalServiceWrapper {



	@Resource(name="jdbc/L2WolfGame")
	DataSource datasource;



	public L2WolfUserLocalServiceImpl(UserLocalService userLocalService) {
		super(userLocalService);
	}


	private final Connection newConnection() {
		return null;
	}


	/*@Override
	public int authenticateByScreenName(long companyId, java.lang.String screenName, java.lang.String password, java.util.Map headerMap, java.util.Map parameterMap) throws com.liferay.portal.kernel.exception.PortalException, com.liferay.portal.kernel.exception.SystemException {
		System.out.println("authenticateByScreenName called "+screenName);
		return super.authenticateByScreenName(companyId, screenName, password, headerMap, parameterMap);
	}*/



    @Override
    public User addUser(long creatorUserId, long companyId,
    		boolean autoPassword, String password1, String password2,
    		boolean autoScreenName, String screenName, String emailAddress,
            long facebookId, String openId, Locale locale, String firstName,
            String middleName, String lastName, int prefixId, int suffixId,
            boolean male, int birthdayMonth, int birthdayDay, int birthdayYear,
            String jobTitle, long[] groupIds, long[] organizationIds,
            long[] roleIds, long[] userGroupIds, boolean sendEmail,
            ServiceContext serviceContext) throws PortalException,
            SystemException {
    	/*try {
    		System.out.println("Adding new user:"+screenName+"*"+password1+"*");
    		if(password1 != null && password2 != null) {
    			//addGameServerUser( screenName , password1 , password2 );
    			if(password1.equals(password2)) {

    			}
    				//pingameServer();
    		} else {
    			throw new PortalException("Password is wrong");
    		}
    	} catch(Exception epx) {
    		epx.printStackTrace( );
    		throw new PortalException("Unable to establish connection remote server.Try again later");
    	}
    	*/
        User usr = super.addUser(creatorUserId, companyId, autoPassword, password1,
                password2, autoScreenName, screenName, emailAddress, facebookId,
                openId, locale, firstName, middleName, lastName, prefixId, suffixId,
                male, birthdayMonth, birthdayDay, birthdayYear, jobTitle, groupIds,
                organizationIds, roleIds, userGroupIds, sendEmail, serviceContext);
        if(usr != null) {
        	try {
        		System.out.println("Adding new user:"+screenName+"*"+password1+"*");
				addGameServerUser( "68.68.68.68" , password1 , screenName );
				System.out.println("Done!");
			} catch (Exception e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
				UserUtil.remove(usr.getUserId());
				throw new PortalException("Unable to establish connection remote server.Try again later");
				//super.deleteUser(userId);
			}
        }

        return usr;
    }


    /*
    @Override
    public User addUser( User user ) throws SystemException {
    	System.out.println("User Created !!!! Passssssssssssssssssssssssssssssssssssssssssssssssssssssssss");
        return super.addUser(user);
    }
    */


    @Override
    public void deleteUser(long userId) throws com.liferay.portal.kernel.exception.PortalException {
    	try {
    		//pingameServer();


			try {

				User user = UserUtil.findByContactId( userId );
				if(user != null) {
					Connection conn = newConnection();//datasource.getConnection();
				    java.sql.PreparedStatement ps = conn.prepareStatement("delete from accounts where login=?");
				    ps.setString(1, user.getScreenName() );
					ps.executeUpdate();
					ps.close();
					conn.close();

					Class.forName("com.mysqljdbc.Driver");
					Connection conn2 = DriverManager.getConnection("jdbc:mysql://game.l2wolf.com/L2JEP?characterEncoding=utf8&useUnicode=true","xxxxxx","xxxxxx");
					ps = conn2.prepareStatement("update characters set account_name=? where account_name=?");
					ps.setString(1, "-/"+user.getScreenName() );
					ps.setString(2, user.getScreenName()  );
					ps.executeUpdate();

					ps.close();

					conn2.close();

					super.deleteUser(userId);

				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace( );
			}

			/*
				UPDATE characters SET deletetime=1 WHERE level<=20 AND (UNIX_TIMESTAMP()*1000-lastAccess) >= 10368000000;
				UPDATE characters SET account=momo61 WHERE deletion_time=1;
			 *
			/*
		    //DELETE FROM character_premium_items WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_friends WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_hennas WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_macroses WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_quests WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_quests_item WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_quests_global_data WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_recipebook WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_recipeshoplist WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_recommends WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_relations WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_shortcuts WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_skills WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_skills_save WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_subclasses WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM character_raid_points WHERE charId NOT IN (SELECT charId FROM characters);

		    DELETE FROM clan_data WHERE leader_id NOT IN (SELECT charId FROM characters);
		    DELETE FROM clan_privs WHERE clan_id NOT IN (SELECT clan_id FROM clan_data);
		    DELETE FROM clan_skills WHERE clan_id NOT IN (SELECT clan_id FROM clan_data);
		    DELETE FROM clan_introductions WHERE clan_id NOT IN (SELECT clan_id FROM clan_data);
		    DELETE FROM clan_notices WHERE clan_id NOT IN (SELECT clan_id FROM clan_data);
		    DELETE FROM clan_wars WHERE clan1 NOT IN (SELECT clan_id FROM clan_data) OR clan2 NOT IN (SELECT clan_id FROM clan_data);
		    UPDATE clan_subpledges SET leader_id = 0 where leader_id NOT IN (SELECT charid from characters);
		    DELETE FROM fortsiege_clans WHERE clan_id NOT IN (SELECT clan_id FROM clan_data);

		    DELETE FROM pets WHERE item_obj_id NOT IN (SELECT object_id FROM items WHERE owner_id IN (SELECT charId FROM characters));
		    DELETE FROM items WHERE owner_id NOT IN (SELECT charId FROM characters) AND owner_id NOT IN (SELECT clan_id FROM clan_data);
		    DELETE FROM seven_signs WHERE charId NOT IN (SELECT charId FROM characters);
		    UPDATE characters SET clanid = 0, title = "", clan_privs = 0 where clanid NOT IN (SELECT clan_id FROM clan_data);
		    UPDATE clanhall SET ownerId = 0, paidUntil = 0 where ownerId NOT IN (SELECT clan_id FROM clan_data);
		    DELETE FROM olympiad_nobles WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM olympiad_nobles_eom WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM heroes WHERE charId NOT IN (SELECT charId FROM characters);
		    DELETE FROM item_attributes WHERE itemId NOT IN (SELECT object_id FROM items);
		    DELETE FROM siege_clans WHERE clan_id NOT IN (SELECT clan_id FROM clan_data);
		    DELETE FROM obj_restrictions WHERE obj_Id NOT IN (SELECT charId FROM characters);

		    DELETE FROM accounts WHERE login NOT IN (SELECT account_name FROM characters);
		    DELETE FROM accounts2 WHERE login NOT IN (SELECT account_name FROM characters);
		    DELETE FROM account_data WHERE account_name NOT IN (SELECT login FROM accounts);
	 * */
		} catch (Exception e) {
			// TODO Auto-generated catch block
			//e.printStackTrace();
			throw new PortalException("Unable to establish connection remote server.Try again later");

		}
    }


	@Override
	public com.liferay.portal.model.User updateUser(long userId, java.lang.String oldPassword, java.lang.String newPassword1, java.lang.String newPassword2, boolean passwordReset, java.lang.String reminderQueryQuestion, java.lang.String reminderQueryAnswer, java.lang.String screenName, java.lang.String emailAddress, long facebookId, java.lang.String openId, java.lang.String languageId, java.lang.String timeZoneId, java.lang.String greeting, java.lang.String comments, java.lang.String firstName, java.lang.String middleName, java.lang.String lastName, int prefixId, int suffixId, boolean male, int birthdayMonth, int birthdayDay, int birthdayYear, java.lang.String smsSn, java.lang.String aimSn, java.lang.String facebookSn, java.lang.String icqSn, java.lang.String jabberSn, java.lang.String msnSn, java.lang.String mySpaceSn, java.lang.String skypeSn, java.lang.String twitterSn, java.lang.String ymSn, java.lang.String jobTitle, long[] groupIds, long[] organizationIds, long[] roleIds, java.util.List userGroupRoles, long[] userGroupIds, com.liferay.portal.service.ServiceContext serviceContext) throws com.liferay.portal.kernel.exception.PortalException, com.liferay.portal.kernel.exception.SystemException {

		if(newPassword1.equals(newPassword2)) {
			if(!oldPassword.equals(newPassword1)) {
				try {
					changeGamePassword( screenName , newPassword1 );
				} catch (Exception e) {
					// TODO Auto-generated catch block
					//e.printStackTrace();
					throw new PortalException("Unable to establish connection remote server.Try again later");
				}
			}
		}

		//System.out.println("update user called");
		User usr = super.updateUser(userId, oldPassword, newPassword1, newPassword2, passwordReset, reminderQueryQuestion, reminderQueryAnswer, screenName, emailAddress, facebookId, openId, languageId, timeZoneId, greeting, comments, firstName, middleName, lastName, prefixId, suffixId, male, birthdayMonth, birthdayDay, birthdayYear, smsSn, aimSn, facebookSn, icqSn, jabberSn, msnSn, mySpaceSn, skypeSn, twitterSn, ymSn, jobTitle, groupIds, organizationIds, roleIds, userGroupRoles, userGroupIds, serviceContext);

		return usr;
	}



	private final void changeGamePassword(String usr,String new_passwd) throws Exception {

		Connection conn = newConnection();//datasource.getConnection();
		MessageDigest md = MessageDigest.getInstance("SHA");
		byte[] raw = new_passwd.getBytes("UTF-8");
		byte[] hash = md.digest( raw );

		java.sql.PreparedStatement statement;
		//(login,password,lastactive,accessLevel,lastIP,lastServer,userIP,pcIp,hop1,hop2,hop3,hop4)  values(?,?,?,?,?,?,?,?,?,?,?,?);");
		statement = conn.prepareStatement("UPDATE accounts SET password=? where login=?;");
		//com.liferay.portal.kernel.util.Base64.encode(hash)
		statement.setString( 1 , usr );
		statement.setString( 2, com.liferay.portal.kernel.util.Base64.encode(hash) );


		if(statement.executeUpdate() <= 0) {
			throw new PortalException("Communication failed with gameserver");
		}

	}


	/*
	private final void pingameServer( ) throws Exception {
		Connection conn = datasource.getConnection();
		java.sql.Statement statement;
		statement = conn.createStatement();
		statement.execute("SELECT 1;");
	}
	*/


	private final void addGameServerUser( String ip_addr , String password , String user ) throws Exception {
		System.out.println("Start of DB");
		Connection conn = newConnection();//datasource.getConnection();
		MessageDigest md = MessageDigest.getInstance("SHA");
		byte[] raw = password.getBytes("UTF-8");
		byte[] hash = md.digest( raw );

		java.sql.PreparedStatement statement;

        statement = conn.prepareStatement("INSERT INTO accounts (login,password,lastactive,accessLevel,lastIP) values(?,?,?,?,?);");
        statement.setString(1, user );
        statement.setString(2, com.liferay.portal.kernel.util.Base64.encode(hash) );
        statement.setLong(3, System.currentTimeMillis());
        statement.setInt(4, 0);
        statement.setString(5, ip_addr );

		statement.execute(  );
		statement.close(  );
		System.out.println("END of DB");
	}
}