黄尔冬 / net_iou

/**
 * Created by Tommy Huang on 18/04/02.
 */
const config = require('config-lite')({
  config_basedir: __dirname,
  config_dir: 'config'
})
const moment = require('moment')
const _ = require('lodash')
const uuid = require('uuid/v4')
const qr = require('qr-image')
const Helper = require('./helper')
const Op = require('sequelize').Op

const User = require('../models').User
const BorrowList = require('../models').BorrowList
const Friendship = require('../models').Friendship
const Period = require('../models').Period
const Repayment = require('../models').Repayment
const OverdueRecord = require('../models').OverdueRecord
const Redis = require('../models/redis')

exports.create = async function(req, res) {
  try {
    const idFromToken = req.user.userId
    const id = req.body.userId
    const amount = parseInt(req.body.amount) || 0
    const role = req.body.role
    const target = req.body.target
    const start = req.body.start
    const end = req.body.end
    const rate = req.body.rate
    const rateValue = parseFloat(req.body.rateValue) || 0
    const usage = req.body.usage
    const explanation = req.body.explanation || ''
    const imgs = req.files || []
    if (!id || !role || !target || !start || !end || !usage ||!amount)  throw new Error('参数错误')
    if (idFromToken !== id) throw new Error('token check fail')
    if (amount <= 0) throw new Error('非法的借款金额')
    if (parseInt(rate.slice(0, rate.length - 1)) !== rateValue * 100 || rateValue < 0.00 || rateValue > 0.24) throw new Error('非法利率参数')
    const startDate = moment(start)
    const endDate = moment(end)
    const now = moment()
    if (startDate.isAfter(now)) throw new Error('借款日期不能晚于今天')
    if (endDate.isBefore(now.startOf('day'))) throw new Error('还款日期不能早于今天')    
    if (startDate.isAfter(endDate)) throw new Error('还款日期最早为借款当日')
    const user = await User.findOne({where: {id: id}})
    if (!user) throw new Erro('用户不存在')
    let imgSrc = []
    if (imgs.length) {
      imgSrc = await Promise.all(imgs.map(async (item) => {
        let fileName = `${uuid()}.${item.mimetype.split('/')[1]}`
        let buffer = item.buffer
        if (buffer.size >= 2000000) {
          buffer = await Helper.imageCompression(item.buffer, 1200)
        }
        await Helper.writeFile(`${config.img.iouImg}/${fileName}`, buffer)
        return fileName
      }))
    }
    imgSrc = imgSrc.join(',')
    let newBorrowList = {
      id: uuid(),
      amount: amount,
      startDate: startDate.format(),
      endDate: endDate.format(), 
      rate: rateValue,
      usage: usage,
      explanation: explanation,
      imgs: imgSrc,
      targetName: target,
      sponsorId: user.id
    }
    if (role === 'borrower') {
      newBorrowList.borrowerId = user.id
    } else {
      newBorrowList.creditorId = user.id
    }
    let result = await BorrowList.create(newBorrowList)
    let firstPeriod = await Period.create({
      id: uuid(),
      borrowListId: result.id,
      amount: result.amount,
      startDate: result.startDate,
      endDate: result.endDate,
      rate: result.rate,
    })
    res.json({
      success: 1,
      id: result.id
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `创建失败:${e.message}`
    })
  }
}

exports.get = async function (req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.query.userId
    const id = req.query.id
    if (!id || !userId) throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    let info = await BorrowList.findOne({
      where: {
        id: id,
        deleted: false
      },
      attributes: { exclude: ['deleted', 'qr', 'updated_at'] },
      include: [{
        model: User,
        required: false,
        as: 'Borrower',
        attributes: ['id', 'name', 'username', 'headimgurl']
      }, {
        model: User,
        required: false,
        as: 'Creditor',
        attributes: ['id', 'name', 'username', 'headimgurl']
      }]
    })
    if (!info) throw new Error('未找到对应的借条')
    if (info.sponsorId !== userId) {
      if (info.status === '未发起') {
        throw new Error('未找到对应的借条')
      } else if (info.status === '待确认') {
        if (!info.borrowerId || !info.creditorId) {
          const target = await User.findOne({where: {id: userId}})
          if (target.name) {
            if (target.name === info.targetName) {
              let update = {}
              !!info.borrowerId ? update.creditorId = userId : update.borrowerId = userId
              await info.update(update)
            } else {
              let update = {status: '已驳回'}
              update.reason = !!info.borrowerId ? '填写的出借人姓名与邀请对象的姓名不符，系统自动驳回' : '填写的借款人姓名与邀请对象的姓名不符，系统自动驳回'
              await info.update(update)
              throw new Error('未找到对应的借条')
            }
          }
        } else {
          if (info.creditorId !== userId && info.borrowerId !== userId) throw new Error('未找到对应的借条')
        }
      } else {
        if (info.creditorId !== userId && info.borrowerId !== userId) throw new Error('未找到对应的借条')
      } 
    }
    res.json({
      success: 1,
      info: info
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `获取失败:${e.message}`
    })
  }
}

exports.getIndexList = async function (req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.query.userId
    if (!userId) throw new Error('参数错误')
    // if (idFromToken !== userId) throw new Error('token check fail')
    let [borrowList, creditList, borrowedAmount, creditedAmout] = await Promise.all([
      BorrowList.findAll({
        where: {
          deleted: false,
          borrowerId: userId,
          status: ['未发起', '待确认', '已驳回']
        },
        attributes: ['id', 'amount', 'start_date', 'end_date', 'rate', 'status', 'targetName'],
        include: [{
          model: User,
          required: false,
          as: 'Creditor',
          attributes: ['id', 'name', 'username', 'headimgurl']
        }],
        order: [['created_at', 'DESC']],
        limit: 10
      }),
      BorrowList.findAll({
        where: {
          deleted: false,
          creditorId: userId,
          status: ['未发起', '待确认', '已驳回']
        },
        attributes: ['id', 'amount', 'start_date', 'end_date', 'rate', 'status', 'targetName'],
        include: [{
          model: User,
          required: false,
          as: 'Borrower',
          attributes: ['id', 'name', 'username', 'headimgurl']
        }],
        order: [['created_at', 'DESC']],
        limit: 10
      }),
      BorrowList.sum('amount', {where: {
        deleted: false,
        borrowerId: userId,
        status: ['已生效']
      }}),
      BorrowList.sum('amount', {where: {
        deleted: false,
        creditorId: userId,
        status: ['已生效']
      }}),
    ])
    borrowList = borrowList.map((item) => {
      return buildIndexListInfo(item.dataValues, 'borrow')
    })
    creditList = creditList.map((item) => {
      return buildIndexListInfo(item.dataValues, 'credit')
    })
    res.json({
      success: 1,
      borrowedAmount: borrowedAmount || 0,
      creditedAmout: creditedAmout || 0,
      list: {
        borrow: borrowList,
        credit: creditList
      }
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `获取失败:${e.message}`
    })
  }
}

/**
 * 生成首页需要的借条列表格式
 * @param {Object} item 借条数据对象
 * @param {String} type 正在借款：'borrow', 正在出借： ’credit‘
 */
function buildIndexListInfo(item, type) {
  console.log(item)
  const duration = moment(item.end_date).diff(moment(item.start_date), 'days')
  const timeRemain = moment(item.end_date).diff(moment(), 'days')
  const target = type === 'borrow' ? item.Creditor : item.Borrower
  const avatar = target ? target.headimgurl : null
  item = Object.assign(item, {
    duration: duration,
    timeRemain: timeRemain,
    target: target,
    avatar: avatar,
  })
  return item
}

exports.submitIOU = async function(req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.body.userId
    const id = req.body.id
    const password = req.body.password
    if (!id || !userId || !password )  throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    let [user, list] = await Promise.all([
      User.findOne({where: {id: userId}}),
      BorrowList.findOne({
        where: {id: id, sponsorId: userId, status: ['未发起', '已驳回']},
        include: [{model: Period}]
      })
    ]) 
    if (!user) throw new Error('用户不存在')
    if (!list) throw new Error('未找到对应的借条')
    if (!Helper.passwdCheck(password, user.password)) throw new Error('交易密码不正确')
    const shareUrl = Helper.buildShareUrl(list.id)
    const qrImg = qr.imageSync(shareUrl, { type: 'svg' })        
    let update = {
      qr: qrImg
    }
    if (user.id === list.creditorId) {
      update.creditorAgree = true
      update.status = '待确认'
      update.borrowerId = null
    }
    if (user.id === list.borrowerId) {
      update.borrowerAgree = true
      update.status = '待确认'
      update.creditorId = null 
    }
    let [updateList, updatePeriod] = await Promise.all([
      list.update(update),
      Period.update({status: '待确认'}, {
        where: {borrowListId: list.id,}
      })
    ])
    res.json({
      success: 1,
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `借条提交失败：${e.message}`
    })
  }
}

exports.deleteIOU = async function(req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.body.userId
    const id = req.body.id
    const password = req.body.password
    if (!id || !userId || !password )  throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    let [user, list] = await Promise.all([
      User.findOne({where: {id: userId}}),
      BorrowList.findOne({where: {id: id, sponsorId: userId, status: ['未发起', '已驳回']}})
    ]) 
    if (!user) throw new Error('用户不存在')
    if (!list) throw new Error('未找到对应的借条')
    if (!Helper.passwdCheck(password, user.password)) throw new Error('交易密码不正确')
    let [listDelete, preiodDelete] = await Promise.all([
      list.update({deleted: true}),
      Period.update({deleted: true}, {
        where: {borrowListId: list.id,}
      })
    ])
    res.json({
      success: 1,
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `借条删除失败：${e.message}`
    })
  }
}

exports.comfirmIOU = async function(req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.body.userId
    const id = req.body.id
    const password = req.body.password
    if (!id || !userId || !password )  throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    let [user, list] = await Promise.all([
      User.findOne({where: {id: userId}}),
      BorrowList.findOne({
        where: {id: id, status: '待确认', deleted: false},
        include: [{model: Period, where: {status: '待确认', deleted: false, isExtension: false}}]
      })
    ]) 
    if (!user) throw new Error('用户不存在')
    if (!list) throw new Error('未找到对应的借条')
    if (list.creditorId !== userId && list.borrowerId !== userId) throw new Error('未找到对应的借条')
    if (!Helper.passwdCheck(password, user.password)) throw new Error('交易密码不正确')
    if (user.name !== list.targetName) throw new Error('借条信息与您的身份信息不符，无法确认该借条')
    let update = {}
    if (list.borrowerId === user.id && list.sponsorId !== user.id) {
      update.borrowerAgree = true      
      update.status = '已生效'
    } else if (list.creditorId === user.id && list.sponsorId !== user.id) {
      update.creditorAgree = true   
      update.status = '已生效'
    }
    let [result, preiod, friends] = await Promise.all([
      list.update(update),
      Period.update({status: '已生效'}, {where: {borrowListId: list.id, status: '待确认', deleted: false, isExtension: false}}),
      Friendship.findOne({
        where: {userId: user.id, friendId: list.sponsorId},
      })
    ]) 
    if (!friends) {
      friends = await Friendship.bulkCreate([
        {userId: user.id, friendId: list.sponsorId},
        {friendId: user.id, userId: list.sponsorId},        
      ])
    }
    res.json({
      success: 1,
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `借条确认失败：${e.message}`
    })
  }
}

exports.rejectIOU = async function(req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.body.userId
    const id = req.body.id
    const password = req.body.password
    if (!id || !userId || !password )  throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    let [user, list] = await Promise.all([
      User.findOne({where: {id: userId}}),
      BorrowList.findOne({where: {id: id, status: '待确认'}})
    ]) 
    if (!user) throw new Error('用户不存在')
    if (!list) throw new Error('未找到对应的借条')
    if (list.creditorId !== userId && list.borrowerId !== userId) throw new Error('未找到对应的借条')
    if (!Helper.passwdCheck(password, user.password)) throw new Error('交易密码不正确')
    if (user.name !== list.targetName) throw new Error('借条信息与您的身份信息不符，无法驳回该借条')    
    let [listResult, preiodResult] = await Promise.all([
        list.update({
        status: '已驳回',
        reason: `${list.borrowerId === user.id ? '借款' : '出借'}方主动驳回`
      }),
      Period.update({
        status: '已驳回',
      }, {where: {borrowListId: list.id, status: '待确认', deleted: false, isExtension: false}})
    ])
    res.json({
      success: 1,
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `借条驳回失败：${e.message}`
    })
  }
}

exports.shareInfo = async function(req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.query.userId
    const id = req.query.id
    if (!id || !userId)  throw new Error('未找到对应的借条')
    if (idFromToken !== userId) throw new Error('token check fail')
    let list = await BorrowList.findOne({
      where: {
        id: id, 
        sponsorId: userId, 
        status: '待确认'
      }
    })
    if (!list) throw new Error('未找到对应的借条')
    const shareUrl = Helper.buildShareUrl(list.id)
    let qrImg = list.qr
    if (!qrImg) {
      qrImg = qr.imageSync(shareUrl, { type: 'svg' })        
      await list.update({qr: qrImg})
    }
    res.json({
      success: 1,
      img: qrImg,
      url: shareUrl,
      amount: list.amount,
      startDate: list.startDate,
      endDate: list.endDate
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `${e.message}`
    })
  }
}

exports.getHistory = async function (req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.query.userId
    const type = req.query.type
    const search = req.query.search || ''
    const status = req.query.status || ''
    let sort = req.query.sort || ''
    if (!userId || !type || (type !== 'borrow' && type !== 'credit')) throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')

    let where = {
      deleted: false,
      status: ['已生效', '已逾期']
    }
    let order = [['endDate', 'ASC']]
    if (type === 'borrow') {
      where.borrowerId = userId
      target = 'Creditor'
    } else {
      where.creditorId = userId
      target = 'Borrower'
    }
    if (status !== '') where.status = status
    sort = sort.split(',')
    if (sort.length === 2 && (sort[1] === 'DESC' || sort[1] === 'ASC')) order = [sort]
    let list = await BorrowList.findAll({
      where: where,
      attributes: ['id', 'amount', 'start_date', 'end_date', 'rate', 'status', 'targetName'],
      include: [{
        model: User,
        where: {
          name: {
            [Op.like]: `%${search}%`
          }
        },
        as: target,
        attributes: ['id', 'name', 'username', 'headimgurl']
      }],
      order: order,
    })
    const times = list.length
    let total = 0
    let interest = 0
    let result = []
    list = list.map((item) => {
      let result =  buildIndexListInfo(item.dataValues, type)
      total += result.amount
      interest += (result.amount * result.rate / 365 * result.duration)
      return result
    })
    interest = Math.floor(interest * 100) / 100
    res.json({
      success: 1,
      list: list,
      overview: {
        total: total,
        interest: interest,
        times: times
      }
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `获取失败:${e.message}`
    })
  }
}

exports.getListExtendPreiod = async function (req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.query.userId
    const id = req.query.id || ''
    if (!userId || !id) throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    let [list, newCount] = await Promise.all([
      Period.findAll({where: {borrowListId: id, isExtension: true}}),
      Period.count({where: {borrowListId: id, isExtension: true, status: '待确认'}})
    ])
    res.json({
      success: 1,
      list: list,
      newCount: newCount
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `获取失败:${e.message}`
    })
  }
}

exports.getConfirmedInfo = async function (req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.query.userId
    const id = req.query.id
    const kind = req.query.kind || 'borrow'
    if (!id || !userId) throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    let where = {
      id: id,
      deleted: false,
      status: ['已生效', '已还清', '已逾期']
    }
    kind === 'borrow' ? where.borrowerId = userId : where.creditorId = userId
    let info = await BorrowList.findOne({
      where: where,
      attributes: { exclude: ['deleted', 'qr', 'updated_at', 'sponsorId', 'creditorAgree', 'borrowerAgree', 'targetName', 'created_at', 'imgs'] },
      include: [{
        model: User,
        as: 'Borrower',
        attributes: ['id', 'name', 'username', 'headimgurl']
      }, {
        model: User,
        as: 'Creditor',
        attributes: ['id', 'name', 'username', 'headimgurl']
      }, {
        model: Period,
        required: false,
        where: {borrowListId: id, isExtension: true, deleted: false},
        attributes: ['id', 'start_date', 'end_date', 'rate', 'status', 'amount', 'created_at']
      }, {
        model: Repayment,
        required: false,
        where: {borrowListId: id, deleted: false},
        attributes: ['id', 'repayment_date', 'status', 'amount']
      }]
    })
    if (!info) throw new Error('未找到对应的借条')    
    let timeRemain = 0
    let duration = moment(info.endDate).diff(moment(info.startDate), 'days')
    if (info.status === '已生效') {
      timeRemain = moment(info.endDate).diff(moment(), 'days')
    }
    if (info.status === '已逾期') {
      timeRemain = moment().diff(moment(info.endDate), 'days')
    }
    info.dataValues.timeRemain = timeRemain
    info.dataValues.duration = duration
    res.json({
      success: 1,
      info: info
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `获取失败:${e.message}`
    })
  }
}

exports.createRepayment = async function (req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.body.userId
    const id = req.body.id
    const password = req.body.password
    if (!id || !userId || !password) throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    const [user, list, repayment] = await Promise.all([
      User.findOne({where: {id: userId}}),
      BorrowList.findOne({where: {id: id, status: ['已生效', '已逾期'], borrowerId: userId}}),
      Repayment.findAll({
        where: {
          borrowListId: id,
          status: '待确认'
        }
      })
    ])
    if (!user) throw new Error('用户不存在')
    if (!Helper.passwdCheck(password, user.password)) throw new Error('交易密码不正确')
    if (!list) throw new Error('未找到对应的借条')
    if (!!repayment.length) throw new Error('您有还款请求正待确认中，请勿重复提交')
    let duration = moment(list.endDate).diff(moment(list.startDate), 'days')
    let amount = Math.floor(list.amount * list.rate / 365 * duration * 100) / 100 + list.amount
    let newRepayment = await Repayment.create({
      id: uuid(),
      borrowListId: list.id,
      amount: amount,
      repaymentDate: moment().format(),
    })
    res.json({
      success: 1,
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `${e.message}`
    })
  }
}

exports.writeOffs = async function (req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.body.userId
    const id = req.body.id
    const password = req.body.password
    if (!id || !userId || !password) throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    const [user, list] = await Promise.all([
      User.findOne({where: {id: userId}}),
      BorrowList.findOne({
        where: {id: id, status: ['已生效', '已逾期'], creditorId: userId},
        include: [{
          model: OverdueRecord,
          required: false
        }]
      }),
    ])
    if (!user) throw new Error('用户不存在')
    if (!Helper.passwdCheck(password, user.password)) throw new Error('交易密码不正确')
    if (!list) throw new Error('未找到对应的借条')
    const repaymentDate = moment().startOf('day').format()
    if (list.status !== '已逾期' && !list.overdue_records.length) {
      let [listUpdate, repaymentUpdate] = await Promise.all([
        list.update({
          status: '已还清'
        }),
        Repayment.update({status: '交易关闭'}, {where: {borrowListId: list.id, status: '待确认'}})
      ])
    } else {
      let [listUpdate, repaymentUpdate, updateOverdueRecords] = await Promise.all([
        list.update({
          status: '已还清',
          repaymentDate: repaymentDate
        }),
        Repayment.update({status: '交易关闭'}, {where: {borrowListId: list.id, status: '待确认'}}),
        list.overdue_records[0].update({
          status: '已还清',
          endDate: repaymentDate
        })
      ])
    }
    res.json({
      success: 1,
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `${e.message}`
    })
  }
}

exports.repaymentConfirm = async function (req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.body.userId
    const id = req.body.id
    const password = req.body.password
    if (!id || !userId || !password) throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    const [user, list] = await Promise.all([
      User.findOne({where: {id: userId}}),
      BorrowList.findOne({
        where: {id: id, status: ['已生效', '已逾期'], creditorId: userId},
        attributes: ['id', 'creditorId', 'status'],
        include: [{
          model: Repayment,
          where: {
            status: '待确认'
          }
        }, {
          model: OverdueRecord,
          required: false
        }]
      }),
    ])
    if (!user) throw new Error('用户不存在')
    if (!Helper.passwdCheck(password, user.password)) throw new Error('交易密码不正确')
    if (!list) throw new Error('未找到对应的还款记录')
    const repaymentDate = moment().startOf('day').format()
    if (list.status !== '已逾期' && !list.overdue_records.length) {
      let [listUpdate, repaymentUpdate] = await Promise.all([
        list.update({
          status: '已还清'
        }),
        Repayment.update({status: '已确认'}, {where: {id: list.repayment_records[0].id}})
      ])
    } else {
      let [listUpdate, repaymentUpdate, updateOverdueRecords] = await Promise.all([
        list.update({
          status: '已还清',
          repaymentDate: repaymentDate
        }),
        Repayment.update({status: '已确认'}, {where: {id: list.repayment_records[0].id}}),
        list.overdue_records[0].update({
          status: '已还清',
          endDate: repaymentDate
        })
      ])
    }
    res.json({
      success: 1,
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `${e.message}`
    })
  }
}

exports.repaymentReject = async function (req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.body.userId
    const id = req.body.id
    const password = req.body.password
    if (!id || !userId || !password) throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    const [user, list] = await Promise.all([
      User.findOne({where: {id: userId}}),
      BorrowList.findOne({
        where: {id: id, status: ['已生效', '已逾期'], creditorId: userId},
        attributes: ['id', 'creditorId', 'status'],
        include: [{
          model: Repayment,
          where: {
            status: '待确认'
          }
        }]
      }),
    ])
    if (!user) throw new Error('用户不存在')
    if (!Helper.passwdCheck(password, user.password)) throw new Error('交易密码不正确')
    if (!list) throw new Error('未找到对应的还款记录')
    let repaymentUpdate = await Repayment.update({status: '已驳回'}, {where: {id: list.repayment_records[0].id}})
    res.json({
      success: 1,
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `${e.message}`
    })
  }
}

exports.createExtendPreiod =  async function (req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.body.userId
    const id = req.body.id
    const password = req.body.password
    let endDate =  req.body.endDate
    if (!id || !userId || !password || !endDate) throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    const [user, list] = await Promise.all([
      User.findOne({where: {id: userId}}),
      BorrowList.findOne({
        where: {id: id, status: ['已生效', '已逾期'], creditorId: userId},
        attributes: ['id', 'creditorId', 'borrowerId', 'endDate', 'status', 'rate', 'amount'],
        include: [{
          model: Period,
          required: false,
          where: {
            status: '待确认',
            deleted: false
          }
        }]
      }),
    ])
    if (!user) throw new Error('用户不存在')
    if (!Helper.passwdCheck(password, user.password)) throw new Error('交易密码不正确')
    if (!list) throw new Error('未找到对应的借条')
    if (!!list.periods.length) throw new Error('您有还款请求正待确认中，请勿重复提交')
    const startDate = moment(list.endDate)
    endDate = moment(endDate)
    const now = moment()
    if (endDate.isBefore(now.startOf('day'))) throw new Error('展期结束日期不能早于今天') 
    if (startDate.isAfter(endDate)) throw new Erro('展期结束日期最早为展期开始当日')
    let period = await Period.create({
      id: uuid(),
      borrowListId: list.id,
      startDate: startDate.format(),
      endDate: endDate.format(),
      rate: list.rate,
      amount: list.amount,
      isExtension: true,
      status: '待确认'
    })
    res.json({
      success: 1,
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `${e.message}`
    })
  }
}

exports.periodConfirm = async function (req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.body.userId
    const id = req.body.id
    const password = req.body.password
    if (!id || !userId || !password) throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    const [user, list] = await Promise.all([
      User.findOne({where: {id: userId}}),
      BorrowList.findOne({
        where: {id: id, status: ['已生效', '已逾期'], borrowerId: userId},
        attributes: ['id', 'creditorId', 'borrowerId', 'endDate', 'status', 'rate', 'amount'],
        include: [{
          model: Period,
          where: {
            status: '待确认',
            deleted: false
          }
        }, {
          model: OverdueRecord,
          required: false
        }]
      }),
    ])
    if (!user) throw new Error('用户不存在')
    if (!Helper.passwdCheck(password, user.password)) throw new Error('交易密码不正确')
    if (!list) throw new Error('未找到对应的展期记录')
    let newEnd = moment(list.periods[0].endDate)
    let newStatus = newEnd.isAfter(moment()) ? '已生效' : '已逾期'
    if (list.status !== '已逾期' && !list.overdue_records.length) {
      let [listUpdate, periodUpdate] = await Promise.all([
        list.update({
          status: newStatus,
          endDate: newEnd.format()
        }),
        Period.update({status: '已确认'}, {where: {id: list.periods[0].id}})
      ])
    } else {
      const repaymentDate = moment().startOf('day').format()
      let [listUpdate, periodUpdate, updateOverdueRecords] = await Promise.all([
        list.update({
          status: newStatus,
          endDate: newEnd.format()
        }),
        Period.update({status: '已确认'}, {where: {id: list.periods[0].id}}),
        list.overdue_records[0].update({
          status: '已展期',
          endDate: repaymentDate
        })
      ])
    }
    res.json({
      success: 1,
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `${e.message}`
    })
  }
}

exports.periodReject = async function (req, res) {
  try {
    const idFromToken = req.user.userId
    const userId = req.body.userId
    const id = req.body.id
    const password = req.body.password
    if (!id || !userId || !password) throw new Error('参数错误')
    if (idFromToken !== userId) throw new Error('token check fail')
    const [user, list] = await Promise.all([
      User.findOne({where: {id: userId}}),
      BorrowList.findOne({
        where: {id: id, status: ['已生效', '已逾期'], borrowerId: userId},
        attributes: ['id', 'creditorId', 'borrowerId', 'endDate', 'status', 'rate', 'amount'],
        include: [{
          model: Period,
          where: {
            status: '待确认',
            deleted: false
          }
        }]
      }),
    ])
    if (!user) throw new Error('用户不存在')
    if (!Helper.passwdCheck(password, user.password)) throw new Error('交易密码不正确')
    if (!list) throw new Error('未找到对应的展期记录')
    let periodUpdate = await Period.update({status: '已拒绝'}, {where: {id: list.periods[0].id}})
    res.json({
      success: 1,
    })
  } catch (e) {
    console.log(e)
    res.json({
      success: 0,
      msg: `${e.message}`
    })
  }
}

exports.overdueCheck = async function() {
  try {
    let newOverdueList = await BorrowList.findAll({
      where: {
        status: '已生效',
        endDate: {
          [Op.lt]: moment().format()
        }
      }
    })
    const ids = []
    let newOverdueRecordItems = newOverdueList.map((item) => {
      ids.push(item.id)
      return {
        id: uuid(),
        userId: item.borrowerId,
        borrowListId: item.id,
        startDate: moment().startOf('day').format()
      }
    })  
    let [statusUpdate, newOverdueRecords] = await Promise.all([
      BorrowList.update({status: '已逾期'}, {
        where: {
          id: ids
        }
      }),
      OverdueRecord.bulkCreate(newOverdueRecordItems)
    ])
  } catch (e) {
    console.log(e)
  }
}