qianniaoQueue/Jobs/Cache/CustomerCache.Class.php

<?php
/**
 * 客户统计部分埋点
 * Created by PhpStorm.
 * User: wxj
 * Date: 2019/11/14
 * Time: 11:58
 */

namespace Jobs\Cache;

use Mall\Framework\Core\ResultWrapper;
use Mall\Framework\Factory;

class CustomerCache
{
    private $cache;
    protected $key = '';
    protected $registerSmsCountKey = 'todayCreateOrderCustomer::'; //今日下单用户key
    protected $customerExpire = 10;//过期时间为一天
    protected $allCustomerNumKey = 'allCustomerNum';//全部客户数量key
    protected $lastMonthNewCustomerKey = 'lastMonthNewCustomer';//新增客户数量:最近30天新增，且没有成功付款的客户 key
    protected $interestCustomerKey = 'interestCustomer';//兴趣人群数量:近7天有加购行为，但没有成功付款的客户

    public function __construct()
    {
        $this->key = $this->registerSmsCountKey . date('Ymd', time());
        $this->cache = Factory::cache('user');
    }

    /***************************** 今日下单用户相关 start **********************************/

    /**
     * 下单时调用此方法，添加一条客户下单信息  todayCreateOrderCustomer::20190101:0001:0002:0003
     * @param $enterpriseId
     * @param $provinceCode
     * @param $cityCode
     * @param $districtCode
     * @param $customerId
     * @param $shopId
     * @return bool|ResultWrapper
     */
    public function cacheCustomerOrderInfo($enterpriseId, $provinceCode = null, $cityCode = null, $districtCode = null, $customerId, $shopId = null)
    {
        if (empty($enterpriseId) || empty($customerId)) {
            return false;
        }
        $this->key = $this->key . '::enterprise_' . $enterpriseId;
        $this->cache->zincrby($this->key, 1, $customerId);//存全国
        $this->cache->expire($this->key, $this->customerExpire);

        if (!empty($provinceCode)) {
            $key = $this->key . '::areaCode_' . $provinceCode;
            $this->cache->zincrby($key, 1, $customerId);//存省
            $this->cache->expire($key, $this->customerExpire);
        }

        if (!empty($cityCode)) {
            $key = $this->key . '::areaCode_' . $cityCode;
            $this->cache->zincrby($key, 1, $customerId);//存市
            $this->cache->expire($key, $this->customerExpire);
        }

        if (!empty($districtCode)) {
            $key = $this->key . '::areaCode_' . $districtCode;
            $this->cache->zincrby($key, 1, $customerId);//存区
            $this->cache->expire($key, $this->customerExpire);
        }

        if (!empty($shopId)) {
            $key = $this->key . '::shopId_' . $shopId;
            $this->cache->zincrby($key, 1, $customerId);
            $this->cache->expire($key, $this->customerExpire);
        }
        return true;
    }

    /**
     * 今日下单用户统计，按地区搜索
     * @param $enterpriseId 企业id
     * code不传则查的是全国的客户下单信息
     * @param $code
     * @param $shopId
     * @return array
     */
    public function getTodayCustomerOrderInfo($enterpriseId, $code = null, $shopId = null)
    {
        $key = $this->key . '::enterprise_' . $enterpriseId;
        if (!empty($code)) {
            $key .= '::areaCode_' . $code;
        }
        if (!empty($shopId)) {
            $key .= '::shopId_' . $shopId;
        }
        $result = $this->cache->zrange($key, 0, -1);
        return $result ? $result : [];
    }

    /***************************** 今日下单用户相关 end **********************************/

    /***************************** 全部客户数量相关 start **********************************/

    /**
     * 增加客户数量：每次客户注册调用此方法
     * @param $enterpriseId
     * @return bool
     */
    public function incrCustomerNum($enterpriseId)
    {
        $result = $this->cache->incr($this->allCustomerNumKey . '::' . $enterpriseId);
        return $result ? true : false;
    }

    /**
     * 获取当前客户总数
     * @param $enterpriseId
     * @return bool
     */
    public function getAllCustomerNum($enterpriseId)
    {
        return $this->cache->get($this->allCustomerNumKey . '::' . $enterpriseId);
    }

    /***************************** 全部客户数量相关 end **********************************/


    /***************************** 新增客户数量相关 start **********************************/

    /**
     * 新增客户 customerId  score存时间戳   注册用户时调用此方法
     * @param $customerId
     * @param $enterpriseId
     * @return bool
     */
    public function incrCustomer($customerId, $enterpriseId)
    {
        $result = $this->cache->zadd($this->lastMonthNewCustomerKey . '::' . $enterpriseId, time(), $customerId);
        return $result ? true : false;
    }

    /**
     * 删除所有企业注册超过30天的用户
     * @return bool   true代表有数据被删除  false相反
     */
    public function delCustomerOfOneMonthAgo()
    {
        //获取所有key  ['lastMonthNewCustomer::12','lastMonthNewCustomer::11']
        $keysList = $this->cache->keys($this->lastMonthNewCustomerKey . '*');
        $oneMonthAgoTimestamp = strtotime("-30 day");
        foreach ($keysList as $value) {
            $keyArr = explode('::', $value);
            $result = $this->cache->zremrangebyscore($this->lastMonthNewCustomerKey . '::' . $keyArr[2], 0, $oneMonthAgoTimestamp);
            if (!$result) {
                return false;//没有数据可删除也返回false
            }
        }
        return true;
    }

    /**
     * 客户下单后删除客户信息
     * @param $customerId
     * @param $enterpriseId
     * @return bool
     */
    public function delCustomerAfterPlaceOrder($customerId, $enterpriseId)
    {
        $result = $this->cache->zrem($this->lastMonthNewCustomerKey . '::' . $enterpriseId, $customerId);
        return $result ? true : false;
    }
    /***************************** 新增客户数量相关 end **********************************/

    /***************************** 兴趣人群数量 : 近7天加购行为 start **********************************/
    /**
     * 加入购物车 customerId  score存时间戳   注册用户时调用此方法
     * @param $customerId
     * @param $enterpriseId
     * @return bool
     */
    public function incrInterestCustomer($customerId, $enterpriseId)
    {
        $result = $this->cache->zadd($this->interestCustomerKey . '::' . $enterpriseId, time(), $customerId);
        return $result ? true : false;
    }

    /**
     * 删除所有企业加购超过7天的用户
     * @return bool   true代表有数据被删除  false相反
     */
    public function delInterestCustomerOfSevenDaysAgo()
    {
        //获取所有key  ['lastMonthNewCustomer::12','lastMonthNewCustomer::11']
        $keysList = $this->cache->keys($this->interestCustomerKey . '*');
        $SeveralDaysAgoTimestamp = strtotime("-7 day");
        foreach ($keysList as $value) {
            $keyArr = explode('::', $value);
            $result = $this->cache->zremrangebyscore($this->interestCustomerKey . '::' . $keyArr[2], 0, $SeveralDaysAgoTimestamp);
            if (!$result) {
                return false;//没有数据可删除也返回false
            }
        }
        return true;
    }

    /**
     * 客户成功付款后删除信息
     * @param $customerId
     * @param $enterpriseId
     * @return bool
     */
    public function delInterestCustomerAfterPay($customerId, $enterpriseId)
    {
        $result = $this->cache->zrem($this->interestCustomerKey . '::' . $enterpriseId, $customerId);
        return $result ? true : false;
    }

    /***************************** 近7天加购行为 end **********************************/


}