//login.js
import {GET, POST} from '../common/request';
import {API_HOST, SERVICE_HOST} from '../common/config';
import {Encrypt} from '../common/aes'
import {isStringEmpty} from './util'
import {  logEvent, 
          YB_MY_LOGIN,
          YB_PAGE_OPEN_L,
          YB_REGISTER_SUCCESS,
        } from '../common/analytics.js'

//获取应用实例
var app = getApp()
let PV_ID = new Date().getTime() + '';

let listenerList = [];//存放订阅者回调函数


/*****************************************/
/**获取用户UnionID相关逻辑**/
/*****************************************/

/* 
  调用wx.login后，用获取到的jscode调用该接口，返回openid/unionid/srdSession。
(注:如果是全新的用户，不会返回unionid,需要申请用户授权后再调用getUnionID函数。
*/
function wechatLoginAction(callbackFunc) {
  var app = getApp()
    wx.login({
    success: function(res) {
      if (res.code) {
        let param = {
          method: 'wechat.smallProgram.onLogin',
          jsCode: res.code,
          miniapp_type: app.globalData.miniapp_type,
        }
        GET(SERVICE_HOST+'/wechat/', param)
        .then(data => {
          if (data.code != 200) {
            callbackFunc({
              succeed: false,
              message: data.message
            });
          } else {
            let responseData = data.data
            //上报接口返回的结果，线上debug用
            checkUnionIDExist(responseData.openid + "", responseData.unionid + "", responseData.srd_session+"", param.method)

            //保存srdSession
            app.setWechatThirdSession(responseData.srd_session);
            //保存openid
            app.setOpenID(responseData.openid);

            //如果unionID不存在（未使用过任何有货微信产品的全新用户),调用getUnionID函数，再次获取unionID
            if (isStringEmpty(responseData.unionid)) {
              getUnionID(responseData.srd_session, callbackFunc);
            }
            //如果unionID存在，保存并查询该unionID是否有uid
            else{
              // console.log("union：", data.data.unionid)
              app.setWXUnionID(data.data.unionid);
              wechatUserIsBind(data.data.unionid, "", callbackFunc);
            }
            let params = { LOGIN_TYPE: 4, PV_ID: PV_ID, };
            logEvent(YB_MY_LOGIN, params); 
          }             
        })
        .catch(error => {
          callbackFunc({
            succeed: false,
            message: error.message
          });
        });

      } else {
        callbackFunc({
          succeed: false,
          message: '获取用户登录态失败！'
        });
      }
    }
  });
}

/*
申请获取用户个人信息授权后，调用接口解码，返回unionID.
*/
function getUnionID(srd_session, callbackFunc) {
  let app = getApp()
  wx.hideToast()
    wx.getUserInfo({
      success: function(res) {
        let userInfo = res.userInfo;
        let nickName = userInfo.nickName;

        //保存用户信息
        app.setUserInfo(res.userInfo)

        let param = {
          method: 'wechat.smallProgram.decodeUserInfo',
          srdSession: srd_session,
          encryptedData: res.encryptedData,
          iv: res.iv,
        }
        GET(API_HOST+'/wechat/', param)
        .then(data => {
          let responseData = data.data
          checkUnionIDExist(responseData.openid + '', responseData.union_id + '', responseData.srd_session+'', param.method)
          if (!isStringEmpty(responseData.union_id)){
            //保存并查询该unionID是否有uid
            app.setWXUnionID(responseData.union_id);
            wechatUserIsBind(responseData.union_id, nickName, callbackFunc);
          }
        })
        .catch(error => {
          callbackFunc({
            succeed: false,
            message: error.message
          });
        });
      },
      fail:function(res) {
        // console.log("getUserInfoFailed:", res)
      }
    })
}

/*
  判断该微信用户是否已经绑定了有货账号,如果已绑定则返回uid等用户信息
*/
function wechatUserIsBind(unionID, nickName, callbackFunc) {
  let app = getApp()
  let param = {
    method: 'app.passport.signinByOpenID',
    openId: unionID,
    nickname: nickName,
  }
  POST(API_HOST, param)
    .then(data => {
      let responseData = data.data
      if (!isStringEmpty(responseData.is_bind) && responseData.is_bind === "Y"){ //已经绑定

        let userInfo={};
        userInfo.is_bind = responseData.is_bind;
        userInfo.mobile = responseData.mobile;
        userInfo.ssouid = responseData.ssouid;
        userInfo.uid = responseData.uid;
        app.setUserInfo(userInfo);

        app.setSessionkey(responseData.session_key);
        trigger(true)

        callbackFunc({
            succeed: true,
            message: "UID存在"
        });
      }else{
        trigger(false)
        callbackFunc({
          succeed: false,
          message: "UID不存在"
        });
      }

  })
  .catch(error => {
    trigger(false)
    callbackFunc({
      succeed: false,
      message: error.message
    });
  });
}



/*******************************************************************/
/**
 *发送验证码相关逻辑

 根据用户是否授权，分别走两套发送、校验验证码的接口:
 已授权：app.bind.sendThridBindCode、app.passport.bind
 未授权：app.message.sendSms、app.passport.autoSignin

**/
/*******************************************************************/

/*
  点击获取验证码按钮

  mobile: 手机号
  vierifycode：验证码
  areaCode：国家码
*/
function getVerifyKey(phoneNumb,areaCode, callbackFunc) {
  let app = getApp()
  if (isStringEmpty(phoneNumb) || isStringEmpty(areaCode)) {
    // console.log("获取验证码失败，手机号码或者区号不能为空")
    return;
  }

  if (isStringEmpty(app.globalData.WXUnion_ID)) {
    sendVerifyCode(phoneNumb, areaCode, callbackFunc);
  }else{
    sendVerifyCodeWithUnionId(phoneNumb, areaCode, callbackFunc);
  }
}

/*
  点击完成按钮

  phoneNumb: 手机号
  vierifycode：验证码
  areaCode：国家码
*/
function bindAction(phoneNumb, verifyCode, areaCode, callbackFunc) {
  let app = getApp()
  if (isStringEmpty(phoneNumb) || isStringEmpty(areaCode)) {
    // console.log("获取验证码失败，手机号码或者区号不能为空")
    return;
  }

  if (isStringEmpty(app.globalData.WXUnion_ID)) {
    autoSignin(phoneNumb, verifyCode,areaCode, callbackFunc);
  } else {
    checkVerifyCode(phoneNumb, verifyCode, areaCode, callbackFunc);
  }
}

/*
  用户已授权-
  1.发送验证码

  phoneNumb:手机号
  areaCode：国家码
*/
function sendVerifyCodeWithUnionId(phoneNumb, areaCode, callbackFunc) {
  let app = getApp()
  let param = {
    method: 'app.bind.sendCodeByMiniApp',
    area: areaCode,
    mobile: phoneNumb,
    open_id: app.getOpenID()
  }
  // console.log("param:", param)
  GET(API_HOST, param)
  .then(data => {
    if (data.code != 200) {
      callbackFunc({
        succeed: false,
        message: data.message
      });
    } else {
      callbackFunc({
        succeed: true,
        message: '发送成功'
      });
    }
  })
  .catch(error => {
    callbackFunc({
      succeed: false,
      message: error.message
    });
  });
}

/*
  用户已授权-
  2.校验验证码

  mobile:手机号
  vierifycode：验证码
  areaCode：国家码
*/

function checkVerifyCode(phoneNumb, verifyCode, areaCode, callbackFunc){
  var app = getApp()
  let that = this;
  //用户信息信息
  let param = {
    method: 'app.passport.bindMiniapp',
    code: verifyCode,
    mobile: phoneNumb,
    area: areaCode,
    open_id: app.globalData.WXUnion_ID,
  }
  GET(API_HOST, param)
    .then(data => {
      wx.hideToast()
      if (data.code === 200 && (data.data.uid !== null) && data.data.uid > 0 && data.data.uid !== undefined) {//验证正确
        let userInfo = {}
        userInfo.ssouid = data.data.ssouid;
        userInfo.uid = data.data.uid;
        userInfo.profile = data.data.profile;
        app.setSessionkey(data.data.session_key);
        app.setUserInfo(userInfo);
        // console.log("登录成功：", userInfo)
        if (data.data.is_register !== undefined && data.data.is_register !== null && data.data.is_register === 0) {
          let logParams = {
            YB_REGISTER_SUCCESS: 5,
          };
          logEvent(YB_REGISTER_SUCCESS, logParams);
        }
        callbackFunc({
          succeed: true,
          code: data.code,
          message: data.message,
        });
      } else {//验证错误
        callbackFunc({
          succeed: false,
          message: data.message
        });
      }
    })
    .catch(error => {
      callbackFunc({
        succeed: false,
        message: error.message
      });
    });
}

/*
  用户未授权-
  1.发送验证码

  mobile:手机号
  areaCode：国家码
*/
function sendVerifyCode(phoneNumb, areaCode, callbackFunc) {
  let app = getApp()
  let param = {
    method: 'app.message.sendSms',
    area: areaCode,
    mobile: phoneNumb,
  }
  // console.log("param:", param)
  GET(API_HOST, param)
    .then(data => {
      if (data.code != 200) {
        callbackFunc({
          succeed: false,
          message: data.message
        });
      } else {
        callbackFunc({
          succeed: true,
          message: '发送成功'
        });
      }
    })
    .catch(error => {
      callbackFunc({
        succeed: false,
        message: error.message
      });
    });
}

/*
  用户未授权-
  2.直接登录

  mobile:手机号
  vierifycode：验证码
  areaCode：国家码
*/
function autoSignin(mobile, verifyCode, areaCode,callbackFunc) {
  let app = getApp()
  //用户信息信息
  let param = {
    method: 'app.passport.autoSignin',
    profile: mobile,
    area: areaCode,
    code: verifyCode,
  }

  GET(API_HOST, param)
    .then(data => {
      if (data.code ===200 && data.data&& data.data.uid>0){

        let userInfo = {}
        userInfo.ssouid = data.data.ssouid;
        userInfo.uid = data.data.uid;
        userInfo.profile = data.data.profile;
        app.setSessionkey(data.data.session_key);
        app.setUserInfo(userInfo);
        if (data.data.is_register !== undefined && data.data.is_register !== null && data.data.is_register === 0) {
          let logParams = {
            YB_REGISTER_SUCCESS: 5,
          };
          logEvent(YB_REGISTER_SUCCESS, logParams);
        }
        callbackFunc({
          succeed: true,
          code: data.code,
          message:data.message,
        });
      }else{
        callbackFunc({
          succeed: false,
          code: data.code,
          message: data.message,
        });
      }
    })
    .catch(error => {
      callbackFunc({
        succeed: false,
        message: error.message
      });
    });
}


/*******************************************************************/
/**
 *解密通过微信授权获取到的手机号

 首先调用wechat.smallProgram.decodeUserInfo解码获得手机号
  再调用app.passport.miniAppBindByAuto接口，
  此接口会在后台做判断：
    如果该手机号【已存在】，则提示用户手动验证手机号,
    如果手机号【不存在】，则自动创建账号，并返回uid.
**/
/*******************************************************************/
function decodePhoneNumber(iv, encryptedData,callbackFunc){
  var app= getApp()
  // console.log(app.globalData)
  let param = {
    method: 'wechat.smallProgram.decodeUserInfo',
    srdSession: app.globalData.WXThird_session,
    encryptedData: encryptedData,
    iv: iv,
  }
  GET(SERVICE_HOST + '/wechat/', param)
    .then(data => {
      if(data.data.phoneNumber!==''&&data.data.countryCode!=''){
        BindMiniAppByAuto(data.data.phoneNumber, data.data.countryCode,callbackFunc)
      }
    })
    .catch(error => {
      callbackFunc({
        succeed: false,
        message: error.message
      });
    });
}

function BindMiniAppByAuto(mobile,countryCode,callbackFunc){
  var app = getApp()
  if (isStringEmpty(mobile)){
    // console.log("手机号不能为空")
    callbackFunc({
      succeed: false,
      message: "手机号为空或格式不正确",
      code: -1
    });
  }

  let param = {
    method: 'app.passport.miniAppBindByAuto',
    area: countryCode,
    mobile: mobile,
    open_id: app.globalData.WXUnion_ID,
  }
  GET(API_HOST, param)
    .then(data => {
      if(data.code===200){
        app.setSessionkey(data.data.session_key)
        app.updateUid(data.data.uid)

        if (data.data.is_register !== undefined && data.data.is_register !== null && data.data.is_register === 0) {
          let logParams = {
            YB_REGISTER_SUCCESS: 5,
          };
          logEvent(YB_REGISTER_SUCCESS, logParams);
        }
        callbackFunc({
          succeed: true,
          message: "登录成功",
          code: 200
        });
      } else{
          callbackFunc({
            succeed: false,
            message: data.message,
            code: -1
          });
      }
    })
    .catch(error => {
      callbackFunc({
        succeed: false,
        message: error.message
      });
    });

}

//测试接口，将获取到的unionID等参数，上报给服务端以便于调试
function checkUnionIDExist(openID, unionID, srdSession, method) {
  let param = {
    ops: method,
    openId: openID,
    unionId: unionID,
    srdSession: srdSession
  }
  GET(API_HOST + "/wechat/miniapp/collect/", param)
    .then(data => {
      callbackFunc({
        succeed: true,
        message: ''
      });
    })
    .catch(error => {
      callbackFunc({
        succeed: false,
        message: error.message
      });
    });
}

//
function listen(callbackFunc){
  let app = getApp()
  if (!callbackFunc || typeof (callbackFunc) !== 'function') return
  listenerList.push(callbackFunc)
}

function trigger(succeed){
  let that = this 
  for (var i = 0, fn; fn = listenerList[i++];) {
    fn.apply(that, arguments);
  }
}

module.exports = {
  wechatLoginAction,
  getUnionID,
  getVerifyKey,
  bindAction,
  decodePhoneNumber,
  listen,
}