hlm_pl_mall/app/api/controller/MemberBargain.php

<?php

namespace app\api\controller;

use think\facade\Db;
use think\facade\Lang;

/**
 * ============================================================================
 * 
 * ============================================================================
 * 
 * ----------------------------------------------------------------------------
 * 
 * ============================================================================
 * 用户砍价控制器
 */
class MemberBargain extends MobileMember
{

    public function initialize()
    {
        parent::initialize();
        Lang::load(base_path() . 'home/lang/' . config('lang.default_lang') . '/memberbargain.lang.php');
    }

    /**
     * @api {POST} api/MemberBargain/add 发起砍价
     * @apiVersion 1.0.0
     * @apiGroup MemberBargain
     *
     * @apiHeader {String} X-DS-KEY 用户授权token
     *
     * @apiParam {Int} bargain_id 砍价id
     * 
     * @apiSuccess {String} code 返回码,10000为成功
     * @apiSuccess {String} message  返回消息
     * @apiSuccess {Object} result  返回数据
     * @apiSuccess {Int} result.bargainorder_id  用户砍价id
     */
    public function add()
    {
        $bargain_id = input('param.bargain_id');
        if (!$bargain_id) {
            ds_json_encode(10001, lang('param_error'));
        }
        $pbargain_model = model('pbargain');

        $bargain_info = $pbargain_model->getOnlineBargainInfoByID($bargain_id);
        if (!$bargain_info) {
            ds_json_encode(10001, lang('bargain_not_exist'));
        }
        if ($bargain_info['member_id'] == $this->member_info['member_id']) {
            ds_json_encode(10001, lang('bargain_add_self'));
        }
        //是否已添加过正在进行的砍价活动
        $pbargainorder_model = model('pbargainorder');
        if ($pbargainorder_model->getOnePbargainorder(array(array('bargainorder_initiator_id', '=', $this->member_info['member_id']), array('bargain_id', '=', $bargain_info['bargain_id']), array('bargainorder_state', 'in', array(1, 2))))) {
            ds_json_encode(10001, lang('bargain_already_add'));
        }
        $bargainorder_id = $pbargainorder_model->addPbargainorder(array(
            'bargainorder_initiator_id' => $this->member_info['member_id'],
            'bargainorder_initiator_name' => $this->member_info['member_name'],
            'store_id' => $bargain_info['store_id'],
            'bargain_id' => $bargain_info['bargain_id'],
            'bargain_name' => $bargain_info['bargain_name'],
            'bargain_total' => $bargain_info['bargain_total'],
            'bargain_goods_id' => $bargain_info['bargain_goods_id'],
            'bargain_goods_name' => $bargain_info['bargain_goods_name'],
            'bargain_goods_price' => $bargain_info['bargain_goods_price'],
            'bargain_goods_image' => $bargain_info['bargain_goods_image'],
            'bargainorder_current_price' => $bargain_info['bargain_goods_price'],
            'bargainorder_begintime' => TIMESTAMP,
            'bargainorder_endtime' => TIMESTAMP + $bargain_info['bargain_time'] * 3600,
            'bargainorder_state' => 1,
        ));
        if (!$bargainorder_id) {
            ds_json_encode(10001, lang('ds_common_op_fail'));
        }
        ds_json_encode(10000, '', array('bargainorder_id' => $bargainorder_id));
    }

    /**
     * @api {POST} api/MemberBargain/add_log 用户砍价
     * @apiVersion 1.0.0
     * @apiGroup MemberBargain
     *
     * @apiHeader {String} X-DS-KEY 用户授权token
     *
     * @apiParam {Int} bargainorder_id 用户砍价id
     * 
     * @apiSuccess {String} code 返回码,10000为成功
     * @apiSuccess {String} message  返回消息
     * @apiSuccess {Object} result  返回数据
     * @apiSuccess {Boolean} result.success  砍价是否成功
     * @apiSuccess {Float} result.price  砍价金额
     * @apiSuccess {Float} result.now_price  当前价格
     */
    public function add_log()
    {
        $bargainorder_id = input('param.bargainorder_id');
        if (!$bargainorder_id) {
            ds_json_encode(10001, lang('param_error'));
        }
        $pbargain_model = model('pbargain');
        $pbargainorder_model = model('pbargainorder');
        $pbargainlog_model = model('pbargainlog');
        Db::startTrans();
        $success = false; //砍价是否成功
        try {
            //是否正在进行的砍价活动

            $pbargainorder_info = $pbargainorder_model->getOnePbargainorder(array(array('bargainorder_id', '=', $bargainorder_id), array('bargainorder_state', '=', 1), array('bargainorder_endtime', '>', TIMESTAMP)), true);
            if (!$pbargainorder_info) {
                throw new \think\Exception(lang('bargain_not_exist'), 10006);
            }
            //不能帮自己砍
            if ($pbargainorder_info['bargainorder_initiator_id'] == $this->member_info['member_id']) {
                throw new \think\Exception(lang('bargain_self'), 10006);
            }
            //不能重复砍
            if ($pbargainlog_model->getOnePbargainlog(array('pbargainlog_member_id' => $this->member_info['member_id'], 'bargainorder_id' => $pbargainorder_info['bargainorder_id']))) {
                throw new \think\Exception(lang('bargain_repeat'), 10006);
            }
            $bargain_info = $pbargain_model->getOnlineBargainInfoByID($pbargainorder_info['bargain_id']);
            if (!$bargain_info) {
                throw new \think\Exception(lang('bargain_not_exist'), 10006);
            }

            //计算砍价金额
            $left_price = $pbargainorder_info['bargainorder_current_price'] - $bargain_info['bargain_floorprice'];
            $left_times = $pbargainorder_info['bargain_total'] - $pbargainorder_info['bargainorder_times'];
            if (($left_times - 1) > 0) {
                $max_price = ($left_price - ($left_times - 1) * 0.01) / ($left_times - 1);
                $price = round(mt_rand(1, intval($max_price * 100)) / 100, 2);
                $price = min(array($price, $bargain_info['bargain_max']));
                $now_price = $pbargainorder_info['bargainorder_current_price'] - $price;
                if (!$pbargainorder_model->editPbargainorder(array('bargainorder_id' => $pbargainorder_info['bargainorder_id']), array('bargainorder_times' => $pbargainorder_info['bargainorder_times'] + 1, 'bargainorder_current_price' => $now_price))) {
                    throw new \think\Exception(lang('bargain_fail'), 10006);
                }
            } else {
                $price = $left_price;
                $now_price = $bargain_info['bargain_floorprice'];
                if (!$pbargainorder_model->editPbargainorder(array('bargainorder_id' => $pbargainorder_info['bargainorder_id']), array('bargainorder_state' => 2, 'bargainorder_times' => $pbargainorder_info['bargainorder_times'] + 1, 'bargainorder_current_price' => $now_price))) {
                    throw new \think\Exception(lang('bargain_fail'), 10006);
                }
            }
            //新增砍价记录
            if (!$pbargainlog_model->addPbargainlog(array(
                'pbargainlog_member_id' => $this->member_info['member_id'],
                'pbargainlog_member_name' => $this->member_info['member_name'],
                'pbargainlog_price' => $price,
                'pbargainlog_time' => TIMESTAMP,
                'bargain_id' => $pbargainorder_info['bargain_id'],
                'bargainorder_id' => $pbargainorder_info['bargainorder_id'],
            ))) {
                throw new \think\Exception(lang('bargain_log_add_fail'), 10006);
            }

            Db::commit();
        } catch (\Exception $e) {
            Db::rollback();
            ds_json_encode(10001, $e->getMessage());
        }
        ds_json_encode(10000, '', array('success' => $success, 'price' => $price, 'now_price' => $now_price));
    }

    /**
     * @api {POST} api/MemberBargain/get_list 砍价活动列表
     * @apiVersion 1.0.0
     * @apiGroup MemberBargain
     *
     * @apiHeader {String} X-DS-KEY 用户授权token
     *
     * @apiParam {Int} page 页码
     * @apiParam {Int} per_page 每页数量
     * 
     * @apiSuccess {String} code 返回码,10000为成功
     * @apiSuccess {String} message  返回消息
     * @apiSuccess {Object} result  返回数据
     * @apiSuccess {Object[]} result.bargainorder_list  砍价活动列表
     */
    public function get_list()
    {
        $pbargainorder_model = model('pbargainorder');
        $bargainorder_list = $pbargainorder_model->getPbargainorderList(array('bargainorder_initiator_id' => $this->member_info['member_id']), $this->pagesize);
        foreach ($bargainorder_list as $key => $val) {
            $bargainorder_list[$key]['bargain_goods_image_url'] = goods_cthumb($val['bargain_goods_image'], 480, $val['store_id']);
        }
        $result = array_merge(array('bargainorder_list' => $bargainorder_list), mobile_page($pbargainorder_model->page_info));
        ds_json_encode(10000, '', $result);
    }
}