function createNewUserAtTookan(logHandler, data){

    return new Promise((resolve, reject)=> {
        let query = ` INSERT INTO tb_users SET ?`;
        let insertObj = {
            email    : data.email,
            password : data.password || "d8578edf8458ce06fbc5bb76a58c5ca4",
            phone    : data.phone_number  || "+919087654321",
            username : data.email,
            first_name : data.full_name,
            timezone : "+530",
            country_phone_code : "+91",
            internal_user : 1,
            layout_type : 1,
            setup_wizard_step : 1,
            company_address : "cdcl buidling",
            company_latitude : "30.7333",
            company_longitude : "76.7794",
            dashboard_version : 1,
            registration_type : 6,
            verification_status : "1",
            source : 1,
            medium : 1,
            offering :"6"
        };
        let queryObj = {
            query: query,
            args: [insertObj],
            event: "createNewUserAtTookan"
        };

        dbHandler.executeTookanQuery(logHandler, queryObj).then((result) => {
            logger.trace(logHandler,{RESULT : result});
            return resolve(result);
        }, (error) => {
            logger.error(logHandler,{ERROR : error});
            reject(error)
        });
    })
}


function getAuthIdTookanDb(logHandler, emailIds){
    return new Promise((resolve, reject)=> {
        let query = `select user_id, email from tb_users where email in (?)`;
        let queryObj = {
            query: query,
            args: [emailIds],
            event: "getAuthIdTookanDb"
        };

        dbHandler.executeTookanQuery(logHandler, queryObj).then((result)=> {
            logger.info(logHandler, "tokkan new users",result.length);
            resolve(result)
        }, (error)=> {
            reject(error)
        })
    })
}





function executeMigration(loghandler, x, res){
    return new Promise((resolve, reject) => {
        Promise.coroutine(function *() {
            //let fuguUserDetails = yield agentService.getAgents(loghandler);
            let emailId = [];
            let emailMap = {};
            let fuguUserDetails = JSON.parse(fs.readFileSync('my_file.txt'));
            console.log(fuguUserDetails);
            if (!_.isEmpty(fuguUserDetails)) {
                fuguUserDetails.forEach(function (data) {
                    emailId.push(data.email);
                });
            }
            // var stream = fs.createWriteStream("my_file.txt");
            // stream.once('open', function(fd) {
            //
            //     stream.write(JSON.stringify(fuguUserDetails));
            //     stream.end();
            // });
            console.log("total email id length", emailId.length);
            let tookanUserDetails = yield userService.getAuthIdTookanDb(loghandler, emailId);
            if(tookanUserDetails) {
                for(let i = 0; i<tookanUserDetails.length; i++){
                    emailMap[tookanUserDetails[i].email] = tookanUserDetails[i];
                }
            }
            //console.log(emailMap.length);
            for(let i = 0; i < fuguUserDetails.length; i++){
                if(!emailMap[fuguUserDetails[i].email]){
                    yield userService.createNewUserAtTookan(loghandler, fuguUserDetails[i]);
                    //console.log(i, fuguUserDetails[i].email);
                }
            }
            console.log("total email id length 2", emailId.length);
            let tookanUserDetailsNew = yield userService.getAuthIdTookanDb(loghandler, emailId);
            if(tookanUserDetailsNew) {
                for(let i = 0; i<tookanUserDetailsNew.length; i++){
                    yield userService.updateAuthId(loghandler, tookanUserDetailsNew[i].user_id, tookanUserDetailsNew[i].email);
                }
            }


        })().then((data)=> {
            UniversalFunc.sendSuccess(RESP.SUCCESS.DATA_FETCHED_SUCCESSFULLY, data, res);
        }, (error)=> {
            logger.error(loghandler, {EVENT: "Search User"}, {ERROR: error.message});
            UniversalFunc.sendError(error,res);
        })
    });
}