xyzshop/admin/control/person_bonus.php

<?php
/**
 * 会员红包管理
 *
 ***/

defined('InShopNC') or exit('Access Invalid!');

require_once(BASE_ROOT_PATH . '/helper/algorithm.php');
require_once(BASE_ROOT_PATH . '/helper/bonus_helper.php');
require_once(BASE_ROOT_PATH . '/helper/account_helper.php');
require_once(BASE_ROOT_PATH . '/helper/member_helper.php');
require_once(BASE_ROOT_PATH . '/helper/sms_helper.php');
require_once(BASE_ROOT_PATH . '/mobile/util/errcode.php');
require_once(BASE_ROOT_PATH . '/helper/util_helper.php');
require_once(BASE_ROOT_PATH . '/helper/employee_award.php');
require_once(BASE_ROOT_PATH . '/admin/control/control.php');

class person_bonusControl extends SystemControl
{
    const EXPORT_SIZE = 5000;
    public function __construct()
    {
        parent::__construct();
        Language::read('points');

    }

    public function addOp()
    {
        if (chksubmit())
        {
            $obj_validate = new Validator();
            $obj_validate->validateparam = array(
                array("input"=>$_POST["bonus_rate"],   "require"=>"true",'validator'=>'Compare','operator'=>' >= ','to'=> 1,"message" => '红包抵扣率必须大于0'),
                array("input"=>$_POST["bonus_amount"], "require"=>"true",'validator'=>'Compare','operator'=>' >= ','to'=> 0.01,"message" => '金额最少一分钱')
            );
            $error = $obj_validate->validate();
            if ($error != ''){
                showMessage($error,'','','error');
            }

            $optype = intval($_POST['operatetype']);
            if ($optype == 1)
            {
                $params = $this->add_params($_POST,$error);
                if($params == false) {
                    showMessage($error,'index.php?act=person_bonus&op=add','','error');
                } else {
                    QueueClient::push('sendBonusAndSMS',$params);
                    showMessage(Language::get('nc_common_save_succ'),'index.php?act=person_bonus&op=add');
                }
            }
            else
            {
                $members = member_helper::from_mobiles($_POST['members'],$error);
                if(!empty($members))
                {
                    $rate = intval($_POST['bonus_rate']);
                    $amount = doubleval($_POST['bonus_amount']);
                    foreach ($members as $member) {
                        $member_id = $member['member_id'];
                        $ret = account_helper::withhold_bonus($rate,$amount,$member_id);
                    }

                    showMessage(Language::get('nc_common_save_succ'),'index.php?act=person_bonus&op=add');
                } else {
                    showMessage("手机列表为空",'index.php?act=person_bonus&op=add','','error');
                }
            }
        }
        else
        {
            $items = Model()->table('sms_template')->where(array('disable' => 0))->field('yuntx_id,title,content')->select();
            Tpl::output('sms_tpls',$items);
            Tpl::showpage('person_bonus.add');
        }
    }


    private function add_params($input, &$err)
    {
        $params= [];

        $params['member']['input_type'] = $input['input_type'];
        if(empty($input['members'])) {
            $err = "手机号码或者SQL语句为空";
            return false;
        } else {
            $params['member']['data'] = $input['members'];
        }
        $params['member']['ex_brand'] = $input['ex_brand'] == 'on' ? true : false;
        $params['member']['ex_lrlz']  = $input['ex_lrlz'] == 'on' ? true : false;

        $params['bonus']['rate'] = intval($input['bonus_rate']);;
        $params['bonus']['amount'] = doubleval($input['bonus_amount']);;
        $params['bonus']['bless'] = $input['bonus_bless'];
        $params['bonus']['can_share'] = intval($input['can_share']);

        $params['sms']['open'] = $input['send_sms'] == 'on' ? true : false;
        if($params['sms']['open'])
        {
            $tmpid = $input['sms_template'];
            if($tmpid <= 0) {
                $err = "错误的短信模版";
                return false;
            }
            $params['sms']['template_id'] = $tmpid;
        }

        return $params;
    }

    public function checkmemberOp()
    {
        $name = trim($_GET['name']);
        if (!$name){
            echo ''; die;
        }
        $obj_member = Model('member');
        $member_info = $obj_member->getMemberInfo(['member_mobile' => $name,'member_mobile_bind' => 1]);
        if (is_array($member_info) && count($member_info)>0){
            echo json_encode(array('id'=>$member_info['member_id'],'name'=>$name,'points'=>$member_info['member_points']));
        }else {
            echo ''; die;
        }
    }

    public function promotionOp()
    {
        if(chksubmit())
        {
            $copies = intval($_POST['copies']);
            if($copies <=0 ) {
                $copies = 1;
            }

            if($copies == 1)
            {
                $maker = new bonus\activity_bonus();
                $ret = $maker->make($_POST);
                if($ret == false) {
                    $err = $maker->err();
                    showMessage($err,'index.php?act=person_bonus&op=promotion','','error');
                } else {
                    Tpl::output('type_sn',$ret['type_sn']);
                    Tpl::output('bonus_url',$ret['url']);
                    Tpl::showpage('person_bonus.activity');
                }
            }
            else
            {
                $urls = [];
                for($i = 0; $i < $copies; ++$i)
                {
                    $maker = new bonus\activity_bonus();
                    $ret = $maker->make($_POST);
                    if($ret != false) {
                        $urls[] = $ret['url'];
                    }
                }

                $bonus_url = implode(",",$urls);
                Tpl::output('type_sn',"multi_type_sn");
                Tpl::output('bonus_url',$bonus_url);
                Tpl::showpage('person_bonus.activity');
            }
        }
        else
        {
            Tpl::showpage('person_bonus.activity');
        }
    }

    public function annual_meetingOp()
    {
        if(chksubmit())
        {
            $awards  = intval($_POST['awards']);
            $members = trim($_POST['members']);

            if(empty($awards) || empty($members)) {
                showMessage('奖项、员工工号 不能为空','index.php?act=person_bonus&op=annual_meeting','','error');
                return;
            }
            else {
                $awarder = new employee_award();
                $awarder->send($awards,$members);
                showMessage(Language::get('nc_common_save_succ'),'index.php?act=person_bonus&op=annual_meeting');
            }
        }
        else {
            Tpl::showpage('person_bonus.annual_meeting');
        }
    }
}