/* eslint-disable array-callback-return */
const mysqlCli = global.yoho.utils.mysqlCli;
const _ = require('lodash');
const TABLE_COUPON = 'act_coupon';
const TABLE_COUPON_NO = 'act_coupon_no';
const TABLE_COUPON_USER = 'act_coupon_user';
const toLine = (str) => {
    return str.replace(/([A-Z])/g, '_$1').toLowerCase();
};

class CouponModel extends global.yoho.BaseModel {
    constructor(ctx) {
        super(ctx);
    }

    couponList({pageNo, pageSize, status}) {
        let str = '';

        if (status === '0' || status === '1') {
            str = `where status = ${status}`;
        }
        return mysqlCli.query(
            `select id, coupon_name couponName, coupon_desc couponDesc, shop_name shopName, shop_logo_url shopLogoUrl, status, type, sort , create_time createTime 
            from ${TABLE_COUPON} ${str}
            order by sort desc ,create_time desc
            limit :start, :page;`, {
                start: (pageNo - 1) * pageSize,
                page: _.parseInt(pageSize)
            });
    }

    couponById(id) {
        if (!id) {
            return new Promise(resolve => {
                return resolve({});
            });
        } else {
            return mysqlCli.query(
                `select id, coupon_name couponName, coupon_desc couponDesc, shop_name shopName, shop_logo_url shopLogoUrl, status, type, sort , create_time createTime 
            from ${TABLE_COUPON}
            where id = :id`, {
                id
            });
        }
    }

    couponNoAdd(obj) {
        let sql = `insert into ${TABLE_COUPON_NO} (coupon_id, coupon_no) values `;
        let arr = obj.couponNos;

        arr.map((value, index) => {
            sql += '(' + obj.couponId + ',"' + value.couponNo + '")';
            if (index !== (arr.length - 1)) {
                sql += ',';
            }
        });
        return mysqlCli.insert(sql);
    }

    async couponModify(obj) {
        if (obj.id) {
            let sql = `UPDATE ${TABLE_COUPON} SET `;
            let sqlParam = {};
            let keyArr = Object.keys(obj);

            keyArr.map((value, index) => {
                if (value !== 'id') {
                    let col = toLine(value);

                    sql += col + ' = :' + value;
                    if (index !== (keyArr.length - 1)) {
                        sql += ',';
                    }
                }
                sqlParam[value] = obj[value];
            });
            sql += ' WHERE id = :id';
            return mysqlCli.update(
                sql,
                sqlParam
            );
        } else {

            let insertId = await mysqlCli.insert(
                `insert into ${TABLE_COUPON} (coupon_name, coupon_desc, shop_name, shop_logo_url, status,type,sort)
            values (:couponName, :couponDesc, :shopName, :shopLogoUrl, :status, :type, :sort);`,
                {
                    couponName: obj.couponName,
                    couponDesc: obj.couponDesc,
                    shopName: obj.shopName,
                    shopLogoUrl: obj.shopLogoUrl,
                    status: obj.status,
                    type: obj.type,
                    sort: obj.sort
                });

            if (parseInt(obj.type) === 3) {
                let id = await mysqlCli.insert(
                    `insert into ${TABLE_COUPON_NO} (coupon_id) values (:couponId);`,
                    {
                        couponId: insertId,
                    });

                if (!id) {
                    return Promise.resolve({code: 204, result: false, message: '插入无码券失败'});
                }
            }
            return Promise.resolve({code: 200, result: true});
        }
    }


    allCouponNum(status) {
        let str = '';

        if (status === '0' || status === '1') {
            str = `where status = ${status}`;
        }
        return mysqlCli.query(
            `select count(1) as total from ${TABLE_COUPON} ${str};`
        );
    }

    couponNoCid(couponId) {
        return mysqlCli.query(`select count(1) as count from ${TABLE_COUPON_NO} where coupon_id = :couponId `, {couponId});
    }

    couponNoListJoinUser(couponId) {
        return mysqlCli.query(
            `select cn.coupon_id couponId,cn.coupon_no couponNo,cn.send_flag sendFlag,cu.user_id userId,cu.create_time createTime
            from ${TABLE_COUPON_NO} as cn left join ${TABLE_COUPON_USER} as cu
            on cu.coupon_no_id = cn.id where cn.coupon_id = :couponId`, {couponId});
    }

    couponUserListByCId(couponId) {
        return mysqlCli.query(
            `select id, coupon_id couponId,coupon_no_id couponNoId,user_id userId,create_time createTime
            from ${TABLE_COUPON_USER}
            where coupon_id = :couponId `, {couponId: couponId});
    }

    deleteCouponNoByCId(couponId) {
        return mysqlCli.query(`DELETE FROM ${TABLE_COUPON_NO} WHERE coupon_id = :couponId `, {couponId});
    }

    deleteCouponById(id) {
        return mysqlCli.query(`DELETE FROM ${TABLE_COUPON} WHERE id = :id `, {id});
    }
}

module.exports = CouponModel;