xyzshop/crontab/control/command.php

<?php
/**
 * Created by PhpStorm.
 * User: stanley-king
 * Date: 2017/9/28
 * Time: 上午10:16
 */

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

require_once(BASE_ROOT_PATH . '/helper/notify_helper.php');
require_once(BASE_ROOT_PATH . '/helper/stat_helper.php');
require_once(BASE_ROOT_PATH . '/helper/predeposit_helper.php');
require_once(BASE_DATA_PATH . '/mobile/omsid.php');
require_once(BASE_ROOT_PATH . '/helper/bonus_helper.php');
require_once(BASE_ROOT_PATH . '/helper/bonus/witholder.php');
require_once(BASE_ROOT_PATH . '/helper/notify_helper.php');
require_once(BASE_ROOT_PATH . '/helper/account_helper.php');
require_once(BASE_ROOT_PATH . '/data/mobile/lrlz_staff.php');


class commandControl extends BaseCronControl
{
    public function __construct()
    {
        parent::__construct();
    }

    //中秋节给员工发红包
    public function zqbonusOp()
    {
        $staffs  = lrlz_staff();
        $type_sn = '76341506502791044726';
        bonus_helper::send_mobile($type_sn,$staffs,2);
    }
    #犯了一个低级错误，把时间2017年，写成了2016年
    public function refund0928BonusOp()
    {
        $items = Model()->query('SELECT * FROM lrlz_order WHERE pd_amount=0 AND LENGTH(bonus_rate) > 0 AND add_time > UNIX_TIMESTAMP(DATE (\'2017-09-28 00:00:00\')) AND order_state = 0');
        if(empty($items)) return;
        foreach ($items as $item) {
            $order_sn = $item['order_sn'];
            $member_id = intval($item['buyer_id']);
            account_helper::order_cancel($order_sn,$member_id,true);
        }
    }
    public function init_commentsOp()
    {
        $mod = Model('goods');
        $i = 0;
        while (true)
        {
            $start = $i * 1000;
            $items = Model()->table('evaluate_goods')->field('geval_commonid,geval_goodsid')->order('geval_id asc')->limit("{$start},1000")->select();
            if(empty($items)) {
                return;
            }
            $i++;

            foreach ($items as $item)
            {
                $cid = intval($item['geval_commonid']);
                if($cid <= 0) continue;
                $mod->editGoodsCommon(['comments' => array('exp', "comments+1")],['goods_commonid' => $cid]);
            }
        }
    }
}