'use strict';

const Service = require('egg').Service;
const _ = require("lodash");
class DingdanService extends Service {
  async index(params) {
    let { ctx } = this
    let modelLocal = ctx.model.Dingdan
    let chanpinModel = ctx.model.Chanpin
    let returnData = { hasError: false, msg: "数据错误", list: [], allxiaoshoujine: 0 }
    //新增
    let subType = params.subType
    let returnComponent = params.returnData || []
    let paramsLocal = _.omit(params, ["subType", "returnData", "url"])
    if (subType === "add") {
      paramsLocal = paramsLocal.list[0]
      paramsLocal["update_at"] = Date.now();
      let res = await modelLocal.create(paramsLocal)
      returnData.hasError = false
      returnData.msg = "数据新增成功"
    } else if (subType === "multi") {
      paramsLocal["update_at"] = Date.now();
      let list = await this.dealList(paramsLocal.list)
      let res = await modelLocal.insertMany(list)
      returnData.hasError = false
      returnData.msg = "批量新增成功"
    } else if (subType === "del") {
      await modelLocal.updateMany({ _id: { $in: paramsLocal.ids } }, { isExit: 0, update_at: Date.now() })
      let editlist = await modelLocal.find({ tiaoma: { $in: paramsLocal.tiaomas }, isExit: 1 })
      let list = await this.dealList(editlist)
      for (let i = 0; i < list.length; i++) {
        let element = list[i];
        await modelLocal.updateOne({ _id: element._id }, element)
      }
      returnData.hasError = false
      returnData.msg = "数据删除成功"
    } else if (subType === "delAll") {
      await modelLocal.deleteMany({ "update_at": { $lt: Date.now() + 1000 * 60 * 60 * 24 } })
      returnData.hasError = false
      returnData.msg = "数据已全部删除"
    } else if (subType === "edit") {
      let list = await this.dealList(paramsLocal.list)
      let updateItem = list[0]
      updateItem["update_at"] = Date.now();
      let chanpinItemA = await chanpinModel.find({ tiaoxingma: updateItem.tiaoma })
      let chanpinItemB = await chanpinModel.find({ xiangtiaoxingma: updateItem.tiaoma })
      let chanpinItemC = await chanpinModel.find({ zuidaxiangzhuangtiaoma: updateItem.tiaoma })
      if (chanpinItemA.length || chanpinItemB.length || chanpinItemC.length) {
        updateItem = { ...updateItem }
        let res = await modelLocal.updateOne({ _id: updateItem._id }, updateItem)
        returnData.hasError = false
        returnData.msg = "数据更新成功"
      } else {
        returnData.hasError = true
        returnData.msg = "数据更新失败,请检查产品条形码是否填写正确"
      }
    } else if (subType === "get") {
      let pageSize = paramsLocal.pageSize
      let currentPage = paramsLocal.currentPage
      let paramsLocalInfo = _.omit(paramsLocal, ["pageSize", "currentPage", "url"])
      let paramsLocalInfoNotDel = { ...paramsLocalInfo, isExit: 1 }
      let res = await modelLocal.find(paramsLocalInfoNotDel).sort({ update_at: -1 }).skip((currentPage - 1) * pageSize).limit(pageSize)
      let whereOther = paramsLocalInfoNotDel["$where"]
      let paramsLocalInfoAgg = _.omit(paramsLocalInfoNotDel, ["$where"])
      if (whereOther === "this.zuigaocaigoujia > this.xiaoshoujine") {
        paramsLocalInfoAgg["$expr"] = {
          "$gt": ["$zuigaocaigoujia", "$xiaoshoujine"]
        }
      } else if (whereOther === "this.pinmingxuanxiang.length>1") {
        paramsLocalInfoAgg["$expr"] = {
          "$gt": [{ "$size": "$pinmingxuanxiang" }, 1]
        }
      }
      let allxiaoshoujine = await modelLocal.aggregate([{
        $match: paramsLocalInfoAgg,
      },
      {
        $group: { _id: null, totalSaleAmount: { $sum: '$xiaoshoujine' } }
      }])
      let resData = [];
      for (let i = 0; i < res.length; i++) {
        let elei = res[i];
        let resObj = { _id: elei._id }
        if (returnComponent.length) {
          for (let j = 0; j < returnComponent.length; j++) {
            let elej = returnComponent[j];
            resObj[elej] = elei[elej]
          }
        } else {
          resObj = elei
        }
        resData.push(resObj)
      }
      returnData.hasError = false
      returnData.msg = "查询成功"
      returnData.allxiaoshoujine = Number(Number((_.get(allxiaoshoujine, [0, "totalSaleAmount"], 0)) || 0).toFixed(2))
      returnData.list = resData
    }
    let allParamsLocalInfo = _.omit(paramsLocal, ["pageSize", "currentPage", "url"])
    let allParamsLocalInfoNotDel = { ...allParamsLocalInfo, isExit: 1 }
    let count = await modelLocal.find(allParamsLocalInfoNotDel).count()
    returnData["count"] = count
    return returnData
  }
  async dealList(list) {
    let { ctx } = this
    let listLocal = []
    let modelLocal = ctx.model.Dingdan
    let allList = await modelLocal.find({ isExit: 1 })
    let listCopy = _.concat(list, allList)
    let pinmingGroup = _.groupBy(listCopy, o => o.tiaoma)
    let pinmingOptionObj = {}
    for (let key in pinmingGroup) {
      let value = pinmingGroup[key]
      let pinmingxuxnaing = []
      for (let i = 0; i < value.length; i++) {
        let pinmingOptionItem = {}
        let element = value[i];
        pinmingOptionItem["key"] = element.pinming
        pinmingOptionItem["value"] = element.pinming
        pinmingxuxnaing.push(pinmingOptionItem)
      }
      pinmingOptionObj[key] = _.unionBy(pinmingxuxnaing, "value")
    }
    let userModel = ctx.model.User
    let chanpinModel = ctx.model.Chanpin
    for (let i = 0; i < list.length; i++) {
      let item = _.cloneDeep(list[i]);
      item["pinmingxuanxiang"] = pinmingOptionObj[item.tiaoma]
      item["danjudanweishuliang"] = item.xiaoshoushuliang
      let userItem = await userModel.find({ usercode: item.kehubianhao })
      let chanpinItemA = await chanpinModel.find({
        'tiaoxingma': { $regex: `${item.tiaoma}$`, $options: 'i' }
      })
      let chanpinItemB = await chanpinModel.find({
        'xiangtiaoxingma': { $regex: `${item.tiaoma}$`, $options: 'i' }
      })
      // 销售准备表 ： 销售订单 条码 需要匹配 产品表的 【条形码】【箱条形码】【最大箱装条码】。
      // 如果 匹配到了【条形码】，则  判断产品规则 是两级 还是 三级 ，如果两级是多少就显示多少，如果是三级 则 销售数量 除以  箱装量  如果 有余数则 只取整数， 然后 整数 * 相撞量。一个* 是两级,两个* 是三级
      // 如果 匹配到了【箱条形码】，则  销售数量 * 箱装量 。
      // 如果 匹配到了【最大箱装条码】，则  销售数量 * 最大箱装数。
      let chanpinItemC = await chanpinModel.find({
        'zuidaxiangzhuangtiaoma': { $regex: `${item.tiaoma}$`, $options: 'i' }
      })
      if (userItem.length) {
        item["kehubianhao"] = _.get(userItem, [0, "usercode"], "")
        item["changbian"] = _.get(userItem, [0, "usercode"], "")
        item["username"] = _.get(userItem, [0, "username"], "")
      } else {
        item["kehubianhao"] = ""
        item["changbian"] = ""
        item["username"] = ""
      }
      if (chanpinItemA.length) {
        item["huohao"] = _.get(chanpinItemA, [0, "daima"], "")
        item["chanpindaima"] = _.get(chanpinItemA, [0, "daima"], "")
        item["zuixiaodanweitiaoma"] = _.get(chanpinItemA, [0, "tiaoxingma"], "")
        item["xiaoshoushuliang"] = item.xiaoshoushuliang
        item.isNotSale = false
        let guigexinghao = _.get(chanpinItemA, [0, "guigexinghao"], "")
        let guigexinghaoArr = _.split(guigexinghao, "*")
        if (guigexinghaoArr.length === 2) {
          item["xiugaihouxiaoshoushuliang"] = item.xiaoshoushuliang
        } else if (guigexinghaoArr.length === 3) {
          let jishu = Number(guigexinghaoArr[2])
          if (item.xiaoshoushuliang > jishu) {
            let count = Math.floor(item.xiaoshoushuliang / jishu)
            item["xiugaihouxiaoshoushuliang"] = count * jishu
          } else {
            item["xiugaihouxiaoshoushuliang"] = item.xiaoshoushuliang
          }
        }
        item["xiaoshoujine"] = item.xiaoshoujine
        item["zuigaocaigoujia"] = _.get(chanpinItemA, [0, "zuigaocaigoujia"], 0)
        item["xiangzhuangliang"] = _.get(chanpinItemA, [0, "xiangzhuangliang"], "")
        item["zuidaxiangzhuangliang"] = _.get(chanpinItemA, [0, "zuidadanweixiangzhuangliang"], "")
        item["guigexinghao"] = _.get(chanpinItemA, [0, "guigexinghao"], "")
        item["jiliangdanwei"] = _.get(chanpinItemA, [0, "jiliangdanwei"], "")
        item["xiangtiaoma"] = _.get(chanpinItemA, [0, "xiangtiaoxingma"], "")
        item["zuidaxiangtiaoma"] = _.get(chanpinItemA, [0, "zuidaxiangzhuangtiaoma"], "")
      } else if (chanpinItemB.length) {
        item.isNotSale = false
        item["huohao"] = _.get(chanpinItemB, [0, "daima"], "")
        item["chanpindaima"] = _.get(chanpinItemB, [0, "daima"], "")
        item["zuixiaodanweitiaoma"] = _.get(chanpinItemB, [0, "tiaoxingma"], "")
        item["xiaoshoushuliang"] = item.xiaoshoushuliang
        let xiangzhuangliang = Number((_.get(chanpinItemB, [0, "xiangzhuangliang"], 1) || 1))
        item["xiugaihouxiaoshoushuliang"] = item.xiaoshoushuliang * xiangzhuangliang
        item["xiaoshoujine"] = item.xiaoshoujine
        item["zuigaocaigoujia"] = _.get(chanpinItemB, [0, "zuigaocaigoujia"], 0)
        item["xiangzhuangliang"] = _.get(chanpinItemB, [0, "xiangzhuangliang"], 0)
        item["zuidaxiangzhuangliang"] = _.get(chanpinItemB, [0, "zuidadanweixiangzhuangliang"], 0)
        item["guigexinghao"] = _.get(chanpinItemB, [0, "guigexinghao"], "")
        item["jiliangdanwei"] = _.get(chanpinItemB, [0, "jiliangdanwei"], "")
        item["xiangtiaoma"] = _.get(chanpinItemB, [0, "xiangtiaoxingma"], "")
        item["zuidaxiangtiaoma"] = _.get(chanpinItemB, [0, "zuidaxiangzhuangtiaoma"], "")
      } else if (chanpinItemC.length) {
        item.isNotSale = false
        item["huohao"] = _.get(chanpinItemC, [0, "daima"], "")
        item["chanpindaima"] = _.get(chanpinItemC, [0, "daima"], "")
        item["zuixiaodanweitiaoma"] = _.get(chanpinItemC, [0, "tiaoxingma"], "")
        item["xiaoshoushuliang"] = item.xiaoshoushuliang
        let guigexinghao = _.get(chanpinItemC, [0, "guigexinghao"], "")
        let guigexinghaoArr = _.split(guigexinghao, "*")
        let jishu = Number(guigexinghaoArr[2]) * Number(guigexinghaoArr[1])
        // let zuidadanweixiangzhuangliang = Number((_.get(chanpinItemC, [0, "zuidadanweixiangzhuangliang"], 1) || 1))
        item["xiugaihouxiaoshoushuliang"] = item.xiaoshoushuliang * Number(jishu)
        item["xiaoshoujine"] = item.xiaoshoujine
        item["zuigaocaigoujia"] = _.get(chanpinItemC, [0, "zuigaocaigoujia"], 0)
        item["xiangzhuangliang"] = _.get(chanpinItemC, [0, "xiangzhuangliang"], 0)
        item["zuidaxiangzhuangliang"] = _.get(chanpinItemC, [0, "zuidadanweixiangzhuangliang"], 0)
        item["guigexinghao"] = _.get(chanpinItemC, [0, "guigexinghao"], "")
        item["jiliangdanwei"] = _.get(chanpinItemC, [0, "jiliangdanwei"], "")
        item["xiangtiaoma"] = _.get(chanpinItemC, [0, "xiangtiaoxingma"], "")
        item["zuidaxiangtiaoma"] = _.get(chanpinItemC, [0, "zuidaxiangzhuangtiaoma"], "")
      } else {
        item["huohao"] = ""
        item["chanpindaima"] = ""
        item["zuixiaodanweitiaoma"] = ""
        item["xiaoshoushuliang"] = item.xiaoshoushuliang
        item["xiugaihouxiaoshoushuliang"] = item.xiaoshoushuliang
        item["xiaoshoujine"] = item.xiaoshoujine
        item["zuigaocaigoujia"] = 0
        item["xiangzhuangliang"] = ""
        item["zuidaxiangzhuangliang"] = ""
        item["guigexinghao"] = ""
        item["jiliangdanwei"] = ""
        item["xiangtiaoma"] = ""
        item["zuidaxiangtiaoma"] = ""
        item.isNotSale = true
      }
      listLocal.push(item)
    }
    return listLocal
  }
}

module.exports = DingdanService;