/**
 * Created by qiujun on 2018/4/13.
 */
const ShoesModel = require('../models/shoes');
const _ = require('lodash');
const INVALID_PARAMS = '参数错误';
const http = require('http');

const shoes = {
    /**
     *检查并添加好友
     * @param req
     * @param res
     * @param next
     */
    async checkAddFriends(req, res) {
        let {unionId, friendUnionId, actId = 27} = req.query;

        if (!unionId || !friendUnionId) {
            return res.json({
                code: 400,
                message: INVALID_PARAMS
            });
        }
        if (unionId === friendUnionId) {
            return res.json({
                code: 401,
                message: '自己不能挑战自己'
            });
        }

        try {
            let checkFriend = await req.ctx(ShoesModel).checkFriends(unionId, friendUnionId);

            if (checkFriend && checkFriend.length > 0) {
                return res.json({
                    code: 200,
                    data: checkFriend[0],
                    message: '查询好友成功'
                });
            } else {
                let addFriend = await req.ctx(ShoesModel).addFriends(actId, unionId, friendUnionId);

                // console.log(addFriend);
                return res.json({
                    code: 200,
                    data: addFriend,
                    message: '添加好友成功'
                });
            }
        } catch (err) {
            return res.json(err);
        }
    },

    /**
     * 查询用户游戏记录
     * @param req
     * @param res
     * @returns {Promise.<void>}
     */
    async checkUserPlayed(req, res) {
        let {actId = 27, unionId} = req.query;

        try {
            let userInfo = await req.ctx(ShoesModel).checkUserPlayed(actId, unionId);
            let result = [];

            // console.log(userInfo);

            _.each(userInfo.data || [], (obj) => {
                // console.log(obj);
                result.push(obj);
            });

            return res.json({
                code: 200,
                count: result.length || 0,
                data: result,
                phone: userInfo.phone || 0,
                message: '查询用户游戏信息成功'
            });
        } catch (err) {
            return res.json(err);
        }
    },

    /**
     * 保存用户游戏记录
     * @param req
     * @param res
     * @returns {Promise.<void>}
     */
    async saveUserResult(req, res) {
        let {actId = 29, unionId, list = [], question} = req.body;

        if (list === []) {
            return res.json({
                code: 204,
                actId: actId,
                unionId: unionId,
                message: INVALID_PARAMS
            });
        } else if (parseInt(question, 10) === 0) {
            try {
                list = JSON.parse(list);
                let userInfo = await req.ctx(ShoesModel).getUserId(unionId);
                let userId = 0;
                let result = [];

                if (userInfo.length > 0) {
                    userId = userInfo[0].id;
                }

                if (userId) {
                    let getUserPlayed = await req.ctx(ShoesModel).getUserPlayedInfo(actId, unionId);

                    // console.log(getUserPlayed);

                    if (getUserPlayed.code === 200 || (getUserPlayed.data && getUserPlayed.data.length === 0)) {
                        for (let i = 0; i < list.length; i++) {
                            let qsObj = list[i];
                            let qs = await req.ctx(ShoesModel).
                            saveResult(
                                actId,
                                userId,
                                qsObj.questionId,
                                qsObj.userSelectOption || 'F',
                                qsObj.isCorrect,
                                qsObj.time || 1000
                            );

                            result.push(qs);
                        }

                        return res.json({
                            code: 200,
                            userId,
                            actId,
                            unionId,
                            data: result,
                            message: '插入用户结果成功'
                        });
                    } else {
                        return res.json({
                            code: 205,
                            message: '请勿重复提交数据'
                        });
                    }

                } else {
                    return res.json({
                        code: 204,
                        message: '插入用户结果失败'
                    });
                }
            } catch (err) {
                return res.send(err);
            }

        } else {
            res.json({
                code: 201,
                message: '用户已经进行过游戏'
            });
        }
    },

    /**
     * 保存用户游戏记录
     * @param req
     * @param res
     * @returns {Promise.<void>}
     */
    async saveUserResultWithToken(req, res) {
        let {actId = 29, unionId, list = [], question, token} = req.body;

        if (list === [] || !token) {
            return res.json({
                code: 400,
                actId: actId,
                unionId: unionId,
                message: INVALID_PARAMS
            });
        } else if (parseInt(question, 10) === 0) {
            let session_token = req.session.shoesToken;

            // console.log('save:', session_token, token);
            if (session_token !== token) {
                return res.json({
                    code: 400,
                    message: INVALID_PARAMS,
                    data: token + '_' + (session_token || '0')
                });
            }

            try {
                list = JSON.parse(list);
                let userInfo = await req.ctx(ShoesModel).getUserId(unionId);
                let userId = 0;
                let result = [];

                if (userInfo.length > 0) {
                    userId = userInfo[0].id;
                }

                if (userId) {
                    let getUserPlayed = await req.ctx(ShoesModel).getUserPlayedInfo(actId, unionId);

                    // console.log(getUserPlayed);

                    if (getUserPlayed.code === 200 || (getUserPlayed.data && getUserPlayed.data.length === 0)) {
                        for (let i = 0; i < list.length; i++) {
                            let qsObj = list[i];
                            let qs = await req.ctx(ShoesModel).
                            saveResult(
                                actId,
                                userId,
                                qsObj.questionId,
                                qsObj.userSelectOption || 'F',
                                qsObj.isCorrect,
                                qsObj.time || 1000,
                                qsObj.click || 0
                            );

                            result.push(qs);
                        }

                        return res.json({
                            code: 200,
                            userId,
                            actId,
                            unionId,
                            data: result,
                            message: '插入用户结果成功'
                        });
                    } else {
                        return res.json({
                            code: 205,
                            message: '请勿重复提交数据'
                        });
                    }

                } else {
                    return res.json({
                        code: 204,
                        message: '插入用户结果失败'
                    });
                }
            } catch (err) {
                return res.send(err);
            }

        } else {
            res.json({
                code: 201,
                message: '用户已经进行过游戏'
            });
        }
    },

    /**
     * 可以重复游戏的保存用户信息
     * @param req
     * @param res
     * @returns {Promise.<void>}
     */
    async saveUserResultWithReplay(req, res) {
      let {actId = 37, unionId, list = [], token} = req.body;

      if (list === [] || !token) {
        return res.json({
          code: 400,
          actId: actId,
          unionId: unionId,
          message: INVALID_PARAMS
        });
      } else {
        let session_token = req.session.shoesToken;

        // console.log('save:', session_token, token);
        if (session_token !== token) {
          return res.json({
            code: 400,
            message: INVALID_PARAMS,
            data: token + '_' + (session_token || '0')
          });
        }

        try {
          list = JSON.parse(list);
          let userInfo = await req.ctx(ShoesModel).getUserId(unionId);

          let userId = 0;
          let result = [];

          if (userInfo.length > 0) {
            userId = userInfo[0].id;
          }



          if (userId) {
            let getUserPlayed = await req.ctx(ShoesModel).getUserPlayedInfo(actId, unionId);

            if (getUserPlayed.code === 200 || (getUserPlayed.data && getUserPlayed.data.length === 0)) {
              for (let i = 0; i < list.length; i++) {
                let qsObj = list[i];
                let qs = await req.ctx(ShoesModel).
                saveResult(
                  actId,
                  userId,
                  qsObj.questionId,
                  qsObj.userSelectOption || 'F',
                  qsObj.isCorrect,
                  qsObj.time || 1000,
                  qsObj.cts || 1
                );

                result.push(qs);
              }

              return res.json({
                code: 200,
                userId,
                actId,
                unionId,
                data: result,
                message: '插入用户结果成功'
              });
            } else {
              let scoreInfo = await req.ctx(ShoesModel).getUserRankScore(unionId, actId, 10);
              let newScoreInfo = {
                score: 0,
                playTime: 0,
                clickTimes: 0
              };
              let canUpdate = false;

              for (let i = 0; i < list.length; i++) {
                newScoreInfo.score += parseInt(list[i].isCorrect, 10) ? 10 : 0;
                newScoreInfo.playTime += list[i].time;
                newScoreInfo.clickTimes += list[i].cts || 1;
              }

              if (newScoreInfo.score > scoreInfo.score) { // 分数比原来高的情况
                canUpdate = true;
              } else if (newScoreInfo.score === scoreInfo.score) { // 分数和原来相同时，看点击次数多少
                if (newScoreInfo.clickTimes < scoreInfo.clickTimes) { // 点击次数少于原来
                  canUpdate = true;
                } else if (newScoreInfo.clickTimes === scoreInfo.clickTimes) { // 点击次数等于原来，看时间长短
                  if (newScoreInfo.playTime < scoreInfo.playTime) {
                    canUpdate = true;
                  }
                }
              }

              if (canUpdate) {
                await req.ctx(ShoesModel).deleteUserPlayInfo(actId, userId);
                for (let i = 0; i < list.length; i++) {
                  let qsObj = list[i];
                  let qs = await req.ctx(ShoesModel).
                  saveResult(
                    actId,
                    userId,
                    qsObj.questionId,
                    qsObj.userSelectOption || 'F',
                    qsObj.isCorrect,
                    qsObj.time || 1000,
                    qsObj.cts || 1
                  );

                  result.push(qs);
                }

                return res.json({
                  code: 200,
                  userId,
                  actId,
                  unionId,
                  data: newScoreInfo,
                  message: '插入用户结果成功'
                });
              } else {
                return res.json({
                  code: 200,
                  userId,
                  actId,
                  unionId,
                  data: [],
                  message: '无需更新用户信息'
                });
              }
            }

          } else {
            return res.json({
              code: 204,
              message: '插入用户结果失败'
            });
          }
        } catch (err) {
          return res.send(err);
        }
      }
    },

    /**
     * 获取用户得分以及好友得分列表
     * @param req
     * @param res
     * @returns {Promise.<void>}
     */
    async getUserShareInfo(req, res) {
        let {unionId, actId = 29, per = 10} = req.query;

        if (!unionId) {
            return res.json({
                code: 400,
                message: INVALID_PARAMS
            });
        }
        try {
            let scoreInfo = await req.ctx(ShoesModel).getUserScore(unionId, actId, per);

            let friendsInfo = await req.ctx(ShoesModel).getFriendsScoreList(scoreInfo.userid, actId, per, scoreInfo.score);

            return res.json(
                {
                    code: 200,
                    message: '好友得分列表',
                    data: {
                        currentUser: scoreInfo,
                        record: friendsInfo.record,
                        friendList: friendsInfo.friendList
                    }
                }
            );
        } catch (err) {
            return res.json(err);
        }
    },

    /**
     * 获取全球排名信息
     * @param req
     * @param res
     * @returns {Promise.<void>}
     */
    async getUserPlayInfo(req, res) {
        let {unionId, actId = 29, per = 10} = req.query;

        if (!unionId) {
            return res.json({
                code: 400,
                message: INVALID_PARAMS
            });
        }
        try {
            let scoreInfo = await req.ctx(ShoesModel).getUserRankScore(unionId, actId, per);

            let friendsInfo = await req.ctx(ShoesModel).getAllUserScoreList(actId, per);

            return res.json(
                {
                    code: 200,
                    message: '全球排名列表',
                    data: {
                        currentUser: scoreInfo,
                        friendList: friendsInfo
                    }
                }
            );
        } catch (err) {
            return res.json(err);
        }
    },

    /**
     * 获取用户手机及排名列表
     * @param req
     * @param res
     * @returns {Promise.<void>}
     */
    async getUserPhoneList(req, res) {
        let {actId = 37, per = 10, limit = 150} = req.query;

        try {
            let friendsInfo = await req.ctx(ShoesModel).getUserPhoneList(actId, per, limit);

            let htmlHead = `<table cellpadding="0" cellspacing="0" border="1" width="100%">
                            <tr style="background-color: #00aeef;">
                                <td width="12%" height="30px">名次</td>
                                <td width="12%" height="30px">手机</td>
                                <td width="12%" height="30px">昵称</td>
                                <td width="12%" height="30px">得分</td>
                                <td width="12%" height="30px">时间</td>
                                <td width="12%" height="30px">点击</td>
                                <td width="12%" height="30px">userId</td>
                                <td width="12%" height="30px">日期</td>
                            </tr>`;

            let innerHtml = '';

            _.each(friendsInfo, item => {
                innerHtml += `<tr><td>${item.rank}</td>
                              <td>${item.userPhone}</td>
                              <td>${item.nickname}</td>
                              <td>${item.score}</td>
                              <td>${item.playTime / 1000}s</td>
                              <td>${item.clickTimes}</td>
                              <td>${item.userId}</td>
                              <td>${item.createTime}</td></tr>`;
            });

            let htmlEnd = '</table>';

            return res.send(htmlHead + innerHtml + htmlEnd);
        } catch (err) {
            return res.json(err);
        }
    },

    /**
     * 删除用户的游戏信息
     */
    deleteUserPlayInfo(req, res) {
        let {actId, userId = ''} = req.query;

        if (!actId || !userId) {
            return res.json({
                code: 400,
                message: INVALID_PARAMS
            });
        }

        let userIds = userId.toString().replace(/，/g, ',').split(',');

        return req.ctx(ShoesModel).deleteUserPlayInfo(actId, userIds).then(result => {
            res.json({
                code: 200,
                userId: result.userId,
                actId: result.actId,
                message: `已成功删除${result.data}条数据`
            });
        });
    },

    async getImageData(req, res, next) {

        let pic_url = req.query.image;

        if (!pic_url) {
            return res.json({
                code: 400,
                message: INVALID_PARAMS
            });
        }

        return new Promise((resolve, reject) => {
            http.get(pic_url, (reqs) => {
                let chunks = [];
                let size = 0;

                reqs.on('data', (data) => {
                    chunks.push(data);
                    size += data.length;
                });
                reqs.on('end', () => {
                    let data = Buffer.concat(chunks, size);
                    let base64Image = 'data:image/jpg;base64,' + data.toString('base64');

                    return resolve(base64Image);
                });
                reqs.on('error', () => {
                    return reject(pic_url);
                });
            });
        }).then(result => {
            res.json({
                data: result
            });
        }).catch(err => {
          next(err);
        });
    },

    /**
     * 获取答题的token
     * @param req
     * @param res
     */
    getShoesToken(req, res) {
        let referer = req.get('Referer');
        let token = Math.random().toString(16).substring(2, 15);

        referer = 'https://ad.yoho.cn'; // 用于测试，记得要删

        if (referer && referer.indexOf('ad.yoho.cn') > 0) {
            req.session.shoesToken = token;

            // console.log('shoesToken:', req.session.shoesToken);
            res.json({
                data: token,
            });
        } else {
            res.json({
                data: '0'
            });
        }
    }
};

module.exports = shoes;