cmbYouku_Api/app/cmd/AgreementPaySendSms.php

<?php

namespace app\cmd;

use app\config\BusinessCacheKey;
use app\model\Order;
use app\model\Sign;
use app\service\PayService;
use app\service\util\RedisService;
use app\sms\AliSms;
use think\Collection;
use think\console\Command;
use think\console\Input;
use think\console\Output;
use think\facade\Log;

class AgreementPaySendSms extends Command
{
    protected int $count = 0;
    protected int $successCount = 0;
    protected int $failedCount = 0;

    protected function configure()
    {
        $this->setName('agreementPaySendSms')
            ->setDescription('招商银行协议扣款前发送短信');
    }

    protected function execute(Input $input, Output $output)
    {
        $redis = RedisService::getRedisInstance();
        Sign::where(['sign_status' => Sign::SIGN_STATUS_SUCCESS])->field('*')->chunk(50, function (Collection $signCollection) use (&$output, $redis) {
            foreach ($signCollection as $collection) {
                // 查询是否已经生成过订单
                $order = Order::getPaidOrderByAgreementId($collection->m_agreement_id);
                if ($order->isEmpty() || empty($collection->agree_recharge_time) || $order->order_status != Order::STATUS_RECHARGE_SUCCESS) {
                    continue;
                }
                //  使用redis，判断消息短时间，不会重复发送
                $cacheKeys = BusinessCacheKey::AGREEMENT_PAY_SEND_SMS;
                $cacheKey = $cacheKeys['key'] . "_" . $collection->mobile;
                $key = $redis->get($cacheKey);
                if (!empty($key)) {
                    continue;
                }
                // 该协议号扣款订单次数
                $orderCount = Order::getCountByAgreementId($collection->m_agreement_id);
                if ($orderCount == 12) { // 1年扣款12次
                    continue;
                }
                $oneYearAgo = strtotime("-1 year", time());
                if ($oneYearAgo > strtotime($collection->create_time)) { // 签约时间超过一年
                    continue;
                }
                $currentTimestamp = strtotime(date('Y-m-d'));
                $agreeRechargeTime = $collection->agree_recharge_time;
                $day = env('cmb.agree_pay_day');
                if ($currentTimestamp != $agreeRechargeTime + ($day - 1) * 24 * 60 * 60) { //未到发送短信的时间,只发送刚满30天的记录，超过30天不再发送
                    continue;
                }
                if (empty($collection->mobile)) {
                    continue;
                }
                $this->count += 1;
                //  开始发送扣款短信
                $res = AliSms::sendSms(['phone_numbers' => $collection->mobile], 3);
                $redis->set($cacheKey, true, 'ex', $cacheKeys['ttl']);
                if ($res['code'] == 200) {
                    $this->successCount += 1;
                    $output->writeln("短信发送受理成功");
                } else {
                    $this->failedCount += 1;
                    $output->writeln("手机号" . $collection->mobile . "发送短信失败:" . $res['message']);
                }
            }
        });
        Log::info(sprintf("扣款前发送短信执行情况：执行成功，累计 %s, 受理成功 %s, 失败 %s", $this->count, $this->successCount, $this->failedCount));
        $output->writeln(sprintf("执行成功，累计 %s, 受理成功 %s, 失败 %s", $this->count, $this->successCount, $this->failedCount));
    }
}