hlm_pl_mall/app/crontab/controller/Minutes.php

<?php

namespace app\crontab\controller;

use app\common\logic\Queue;
use think\facade\Cache;
use think\facade\Db;

/**
 
 * 
 
 * 
 * ----------------------------------------------------------------------------
 * 
 
 * 定时器
 */
class Minutes extends BaseCron
{


    /**
     * 默认方法
     */
    public function index()
    {
        $this->_cron_common();
        $this->_cron_mail_send();
        $this->_cron_pintuan();
        $this->_cron_bonus();
        $this->_cron_pbargain();
        $this->_cron_presell();
        $this->_cron_sms();
    }

    /**
     * 短信的处理
     */
    private function _cron_sms()
    {
        $smslog_model = model('smslog');
        $condition = array();
        $condition[] = array('smslog_state', '=', 0);
        $smslog_list = $smslog_model->getSmsList($condition, '', 100, 'smslog_id asc');
        $sms = new \sendmsg\Sms();
        foreach ($smslog_list as $val) {
            $smslog_param = json_decode($val['smslog_msg'], true);
            $smslog_msg = $smslog_param['message'];
            $send_result = $sms->send($val['smslog_phone'], $smslog_param);
            if ($send_result['code'] == true) {
                $smslog_state = 1;
            } else {
                $smslog_state = 2;
            }
            $condition = array();
            $condition[] = array('smslog_id', '=', $val['smslog_id']);
            $update = array(
                'smslog_state' => $smslog_state,
                'smslog_msg' => $smslog_msg,
                'smslog_smstime' => TIMESTAMP,
            );
            $smslog_model->editSms($update, $condition);
        }
    }
    /**
     * 预售活动的状态的处理
     */
    private function _cron_presell()
    {
        $presell_model = model('presell');
        //自动开始时间到期的店铺预售活动
        $condition = array();
        $condition[] = array('presell_state', '=', 1);
        $condition[] = array('presell_start_time', '<', TIMESTAMP);
        $presell_model->editPresell(array('presell_state' => 2), $condition);
        //自动结束时间过期的店铺预售活动
        $condition = array();
        $condition[] = array('presell_end_time', '<', TIMESTAMP);
        $presell_model->endPresell($condition);
        //预售结束后72小时未付尾款取消订单
        $order_model = model('order');
        $logic_order = model('order', 'logic');
        $condition = array();
        $condition[] = array('presell_deposit_amount', '>', 0);
        $condition[] = array('presell_end_time', '<', TIMESTAMP - 72 * 3600);
        $condition[] = array('order_state', 'in', [ORDER_STATE_NEW, ORDER_STATE_DEPOSIT, ORDER_STATE_REST]);

        $order_list = $order_model->getOrderList($condition, 100);
        foreach ($order_list as $order_info) {
            $logic_order->changeOrderStateCancel($order_info, 'system', '预售结束后72小时未付尾款取消订单');
        }
    }



    /**
     * 砍价活动的状态的处理
     */
    private function _cron_pbargain()
    {
        $pbargain_model = model('pbargain');
        //自动开始时间到期的店铺砍价活动
        $condition = array();
        $condition[] = array('bargain_state', '=', 1);
        $condition[] = array('bargain_begintime', '<', TIMESTAMP);
        $pbargain_model->editBargain(array('bargain_state' => 2), $condition);
        //自动结束时间过期的店铺砍价活动
        $condition = array();
        $condition[] = array('bargain_endtime', '<', TIMESTAMP);
        $pbargain_model->endBargain($condition);
        //自动结束砍价失败的用户砍价活动
        $pbargainorder_model = model('pbargainorder');
        $condition = 'bargainorder_state=1 AND bargainorder_endtime<' . TIMESTAMP . ' AND bargainorder_times<bargain_total';
        $pbargainorder_model->editPbargainorder($condition, array('bargainorder_state' => 3));
    }



    /**
     * 拼团相关处理
     */
    private function _cron_pintuan()
    {
        $ppintuan_model = model('ppintuan');
        $ppintuangroup_model = model('ppintuangroup');
        $ppintuanorder_model = model('ppintuanorder');
        //自动关闭时间过期的店铺拼团活动
        $condition = array();
        $condition[] = array('pintuan_end_time', '<', TIMESTAMP);
        $ppintuan_model->endPintuan($condition);


        //查看正在进行开团的列表.
        $condition = array();
        $condition[] = array('pintuangroup_state', '=', 1);
        $pintuangroup_list = $ppintuangroup_model->getPpintuangroupList($condition);

        $success_ids = array(); #拼团开团成功的拼团开团ID
        $fail_ids = array(); #拼团开团失败的拼团开团ID
        foreach ($pintuangroup_list as $key => $pintuangroup) {

            //判断当前参团是否已过期
            if (TIMESTAMP >= $pintuangroup['pintuangroup_starttime'] + $pintuangroup['pintuangroup_limit_hour'] * 3600) {

                //当已参团人数  大于 当前开团的  参团人数   
                if ($pintuangroup['pintuangroup_joined'] >= $pintuangroup['pintuangroup_limit_number']) {

                    //满足开团人数,查看对应的订单是否付款,未付款则拼团失败,订单取消,订单款项退回.
                    $condition = array();
                    $condition[] = array('ppintuanorder.pintuangroup_id', '=', $pintuangroup['pintuangroup_id']);

                    if (!$pintuangroup['pintuangroup_is_virtual']) {
                        $condition[] = array('order.order_state', '=', 20);
                        $count = Db::name('ppintuanorder')->alias('ppintuanorder')->join('order order', 'order.order_id=ppintuanorder.order_id')->where($condition)->count();
                    } else {
                        $condition[] = array('vrorder.order_state', '=', 20);
                        $count = Db::name('ppintuanorder')->alias('ppintuanorder')->join('vrorder vrorder', 'vrorder.order_id=ppintuanorder.order_id')->where($condition)->count();
                    }
                    if ($count == $pintuangroup['pintuangroup_joined']) {
                        //表示全部付款,拼团成功
                        $success_ids[] = $pintuangroup['pintuangroup_id'];
                    } else {
                        $fail_ids[] = $pintuangroup['pintuangroup_id'];
                    }
                } else {
                    //未满足开团人数
                    $fail_ids[] = $pintuangroup['pintuangroup_id'];
                }
            }
        }

        $condition = array();
        //在拼团失败的所有订单，已经付款的订单列表，取消订单,并且退款，未付款的订单自动取消订单
        $condition[] = array('ppintuanorder.pintuangroup_id', 'in', implode(',', $fail_ids));
        $condition[] = array('ppintuanorder.pintuanorder_type', '=', 0);
        $condition[] = array('order.order_state', '=', 20);
        $ppintuanorder_list = Db::name('ppintuanorder')->field('order.*')->alias('ppintuanorder')->join('order order', 'order.order_id=ppintuanorder.order_id')->where($condition)->select()->toArray();

        //针对已付款,拼团没成功的订单,进行取消订单以及退款操作
        $order_model = model('order');
        $logic_order = model('order', 'logic');

        foreach ($ppintuanorder_list as $key => $order_info) {
            try {
                Db::startTrans();
                $logic_order->changeOrderStateCancel($order_info, 'system', '系统', '拼团未成功系统自动关闭订单', true, false, true);
            } catch (\Exception $e) {
                Db::rollback();
                continue;
            }
            Db::commit();
        }


        $condition = array();
        $condition[] = array('ppintuanorder.pintuangroup_id', 'in', implode(',', $fail_ids));
        $condition[] = array('ppintuanorder.pintuanorder_type', '=', 1);
        $condition[] = array('vrorder.order_state', '=', 20);
        $ppintuanorder_list = Db::name('ppintuanorder')->field('vrorder.*')->alias('ppintuanorder')->join('vrorder vrorder', 'vrorder.order_id=ppintuanorder.order_id')->where($condition)->select()->toArray();

        $logic_vrorder = model('vrorder', 'logic');

        foreach ($ppintuanorder_list as $key => $order_info) {
            $logic_vrorder->changeOrderStateCancel($order_info, 'system', '系统', '拼团未成功系统自动关闭订单', false);
        }

        //失败修改拼团相关数据库信息
        $condition = array();
        $condition[] = array('pintuangroup_id', 'in', implode(',', $fail_ids));
        $ppintuangroup_model->failPpintuangroup($condition);

        //成功修改拼团相关数据库信息
        $condition = array();
        $condition[] = array('pintuangroup_is_virtual', '=', 0);
        $condition[] = array('pintuangroup_id', 'in', implode(',', $success_ids));
        $condition2 = array();
        $condition2[] = array('pintuangroup_id', 'in', implode(',', $success_ids));
        $ppintuangroup_model->successPpintuangroup($condition, $condition2);
        //给成功拼团的虚拟订单发送兑换码
        $vrorder_model = model('vrorder');
        $condition = array();
        $condition[] = array('order_promotion_type', '=', 2);
        $condition[] = array('promotions_id', 'in', implode(',', $success_ids));
        $vrorder_list = $vrorder_model->getVrorderList($condition, 1000);
        foreach ($vrorder_list as $vrorder) {
            if ($vrorder['virtual_type'] == 0) {
                $vrorder_model->addVrorderCode($vrorder);
            } else {
                $logic_vrorder = model('vrorder', 'logic');
                $logic_vrorder->changeOrderStateSuccess($vrorder['order_id']);
            }
            $condition = array();
            $condition[] = array('pintuangroup_id', '=', $vrorder['promotions_id']);
            $ppintuangroup_model->successPpintuangroup($condition, $condition);
        }
    }

    /**
     * 处理过期红包
     */
    private function _cron_bonus()
    {
        $condition = array();
        $condition[] = array('bonus_endtime', '<', TIMESTAMP);
        $condition[] = array('bonus_state', '=', 1);
        $data = array(
            'bonus_state' => 2,
        );
        model('bonus')->editBonus($condition, $data);
    }

    /**
     * 发送邮件消息
     */
    private function _cron_mail_send()
    {
        //每次发送数量
        $_num = 50;
        $storemsgcron_model = model('mailcron');
        $cron_array = $storemsgcron_model->getMailCronList(array(), $_num);
        if (!empty($cron_array)) {
            $email = new \sendmsg\Email();
            $mail_array = array();
            foreach ($cron_array as $val) {
                $return = $email->send_sys_email($val['mailcron_address'], $val['mailcron_subject'], $val['mailcron_contnet']);
                if ($return) {
                    // 记录需要删除的id
                    $mail_array[] = $val['mailcron_id'];
                }
            }
            // 删除已发送的记录
            $storemsgcron_model->delMailCron(array(array('mailcron_id', 'in', $mail_array)));
        }
    }

    /**
     * 执行通用任务
     */
    private function _cron_common()
    {

        //查找待执行任务
        $cron_model = model('cron');
        $cron = $cron_model->getCronList(array(array('cron_exetime', '<=', TIMESTAMP)));

        if (!is_array($cron)) return;
        $cron_array = array();
        $QueueLogic = new Queue();
        foreach ($cron as $v) {
            $value = unserialize($v['cron_value']);
            $key = $v['cron_type'];
            $res = $QueueLogic->$key($value);
            if ($res['code']) {
                $cron_model->delCron(array(array('cron_id', '=', $v['cron_id'])));
            }
        }
    }
}