public interface BizCountService {
    /**
     * 計數(shù)上報接口
     *
     * @param request
     * @return
     */
    ZZOpenScfBaseResult<String> reportCount(ReportCountRequest request);

    /**
     * 流水記錄處理-保存日期計數(shù)的情況
     *
     * @param msg
     * @return
     */
    boolean saveDateOpt(BizCountRecordMsg msg);

    /**
     * 流水記錄處理-更新日期計數(shù)的情況
     *
     * @param heroBizCountDate
     * @param msg
     * @return
     */
    boolean updateDateOpt(HeroBizCountDate heroBizCountDate, BizCountRecordMsg msg);

    /**
     * 計數(shù)總量查詢接口
     *
     * @param request
     * @return
     */
    ZZOpenScfBaseResult<Long> total(TotalRequest request);

    /**
     * 批量查詢總量
     *
     * @param request
     * @return
     */
    ZZOpenScfBaseResult<CountBatchResponse> countBatch(CountBatchRequest request);

    /**
     * 清零接口
     * 總量置為0，插入一條計減當前總量的記錄；不影響歷史記錄查詢
     *
     * @param request
     * @return 重置前的舊值
     */
    ZZOpenScfBaseResult<Long> clear(ClearRequest request);

    /**
     * 按時間范圍計數(shù)接口
     *
     * @param request
     * @return
     */
    ZZOpenScfBaseResult<Long> countTimeBetween(CountTimeBetweenRequest request);

    /**
     * 批量id按時間范圍計數(shù)接口
     *
     * @param request
     * @return
     */
    ZZOpenScfBaseResult<Map<Long, Long>> batchCountTimeBetween(CountTimeBetweenBatchRequest request);

    /**
     * 最近n天的計數(shù)統(tǒng)計接口
     *
     * @param request
     * @return
     */
    ZZOpenScfBaseResult<Long> countRecent(CountRecentRequest request);

    /**
     * 批量-最近n天的計數(shù)統(tǒng)計接口
     *
     * @param request
     * @return
     */
    ZZOpenScfBaseResult<Map<Long, Long>> batchCountRecent(CountRecentBatchRequest request);

    /**
     * 組合計數(shù)總量查詢接口
     *
     * @param request
     * @return
     */
    Long combineTotal(CombineTotalRequest request);
}

public enum BizCountType {

    /**
     * 用戶發(fā)帖數(shù)
     */
    USER_POST_COUNT("userPostCount","用戶發(fā)帖數(shù)"),
    /**
     * 帖子評論數(shù)
     */
    POST_REMARK_COUNT("postRemarkCount", "帖子評論數(shù)"),
    /**
     * 帖子點贊數(shù)
     */
    POST_APPROVE_COUNT("postApproveCount", "帖子點贊數(shù)"),
    /**
     * 評論列表未讀總數(shù)
     */
    REMARK_UNREAD_COUNT("remarkUnreadCount", "評論列表未讀總數(shù)"),
    /**
     * 關注列表未讀總數(shù)
     */
    ATTENTION_UNREAD_COUNT("attentionUnreadCount", "關注列表未讀總數(shù)"),
    /**
     * 點贊列表未讀總數(shù)
     */
    APPROVE_UNREAD_COUNT("approveUnreadCount", "點贊列表未讀總數(shù)"),
    /**
     * 評論點贊數(shù)
     */
    REMARK_APPROVE_COUNT("remarkApproveCount", "評論點贊數(shù)"),
    /**
     * 靠譜數(shù)
     */
    RELIABLE_COUNT("reliableCount", "靠譜數(shù)"),
    /**
     * 不靠譜數(shù)
     */
    UNRELIABLE_COUNT("unreliableCount", "不靠譜數(shù)"),
    /**
     * 近期動態(tài)個數(shù)
     */
    RECENT_COUNT("recentCount", "近期動態(tài)個數(shù)"),
    /**
     * 用戶回收單成交數(shù)
     */
    USER_RECYCLE_ORDER_COUNT("userRecycleOrderCount", "用戶回收單成交數(shù)"),
    /**
     * 用戶關注數(shù)
     */
    USER_ATTENTION_COUNT("userAttentionCount", "用戶關注數(shù)"),

    /**
     * 用戶粉絲數(shù)
     */
    USER_FOLLOWER_COUNT("userFollowerCount", "用戶粉絲數(shù)"),
    /**
     * 用戶送檢數(shù)
     */
    USER_SUBMISSION_COUNT("userSubmissionCount", "用戶送檢數(shù)"),

    /**
     * 報價單計數(shù)
     */
    PRICE_SHEET_COUNT("priceSheetCount", "報價單計數(shù)"),

    /**
     * 靠譜未讀計數(shù)
     */
    RELIABLE_UNREAD_COUNT("reliableUnreadCount", "靠譜未讀計數(shù)"),
    /**
     * 同行認證未讀計數(shù)
     */
    FELLOW_CERTIFICATE_UNREAD_COUNT("fellowCertificateUnreadCount", "同行認證未讀計數(shù)"),

    /**
     * 用戶B2B訂單賣出數(shù)
     */
    USER_B2B_ORDER_SOLD_COUNT("b2bOrderSoldCount", "用戶B2B訂單賣出計數(shù)"),

    /**
     * 用戶B2B訂單買入數(shù)
     */
    USER_B2B_ORDER_PURCHASE_COUNT("b2bOrderPurchaseCount", "用戶B2B訂單買入計數(shù)"),

    /**
     * 用戶發(fā)布商品數(shù)
     */
    USER_COMMODITY_PUBLISH_COUNT("userProductPublishCount", "用戶發(fā)布商品計數(shù)"),

    /**
     * 用戶已售商品數(shù)
     */
    USER_COMMODITY_SOLD_COUNT("userProductSoldCount", "用戶已售商品計數(shù)"),

    /**
     * 用戶已購買商品數(shù)
     */
    USER_COMMODITY_PURCHASE_COUNT("userProductPurchaseCount", "用戶已購商品計數(shù)"),
    /**
     * 商品詳情瀏覽數(shù)量
     */
    COMMODITY_BROWSE_COUNT("commodityBrowseCount", "商品詳情瀏覽數(shù)量"),
    /**
     * 商品負反饋數(shù)量
     */
    COMMODITY_NEGATIVE_FEEDBACK_COUNT("commodityNegativeFeedbackCount", "商品負反饋數(shù)量"),
    ;
    /**
     * 業(yè)務類型
     */
    private String code;
    /**
     * 業(yè)務描述
     */
    private String desc;

    public static BizCountType getByCode(String code) {
        return EnumParser.parse(BizCountType.class, BizCountType::getCode, code);
    }
}

public ZZOpenScfBaseResult<String> reportCount(ReportCountRequest request) {
        boolean valid = checkAndProcessReportRequest(request);
        if(!valid){
            return ZZOpenScfBaseResult.buildErr(-1,"參數(shù)不合法");
        }

        //執(zhí)行插入、更新總數(shù)的邏輯
        boolean locked = redissionLockHelper.tryLockBizCountTotal(request.getEntityId(), request.getBizType(), () -> {
            heroBizCountTotalManager.saveOrUpdate(request.getEntityId(), request.getBizType(), request.getCount());
        });
        if(!locked){
            log.error("lock failed,request:{}", request);
            WxWarnTemplateUtil.warnOutService("計數(shù)上報-獲取鎖異常");
            return ZZOpenScfBaseResult.buildErr(-1,"獲取鎖失敗");
        }

        //發(fā)送消息
        try {
            bizCountRecordProducer.sendBizCountRecordMsg(buildRecordMsg(request));
        }catch (Exception e){
            WxWarnTemplateUtil.warnOutService("計數(shù)上報-發(fā)送消息異常");
            log.error("send report msg error, request:{}", request, e);
        }
        //同步總量至緩存，不影響最終一致性，且緩存有有效期，所以不阻塞流程
        try {
            syncTotal2Cache(request.getBizType(), request.getEntityId());
        }catch (Exception e){
            log.error("sync total from db error, request:{}", request, e);
            WxWarnTemplateUtil.warnOutService("計數(shù)上報-同步數(shù)據(jù)至緩存異常");
        }
        return ZZOpenScfBaseResult.buildSucc("");
    }

public boolean bizCountRecord(String msgId, BizCountRecordMsg body) {
        log.info("bizCountRecord msgId={} body={}", msgId, GsonUtil.toJson(body));
        AtomicBoolean rst = new AtomicBoolean();
        boolean locked = redissionLockHelper.tryLockBizCountTotal(body.getEntityId(), body.getBizType(), () -> {
            HeroBizCountDate heroBizCountDate = heroBizCountDateManager.get(body.getEntityId(), body.getBizType().getCode(), body.getTimestamp());
            if(heroBizCountDate == null){
                rst.set(bizCountService.saveDateOpt(body));
            }
            else{
                rst.set(bizCountService.updateDateOpt(heroBizCountDate, body));
            }
        });
        if(!locked){
            log.info("bizCountRecord msgId={} body={} lock failed", msgId, GsonUtil.toJson(body));
            WxWarnTemplateUtil.warnOutService("計數(shù)消費-獲取鎖失敗");
            return false;
        }
        return rst.get();
    }

public Map<Long, Long> countTimeBetweenInternal(List<Long> entityIds, BizCountType bizType, Date start, Date end) {
        Map<Long, Long> totalMap = Maps.newHashMapWithExpectedSize(entityIds.size());
        if(!BizCommonDateUtils.containsWholeDays(start, end)){
            return heroBizCountRecordManager.computeRestTime(entityIds, bizType, start, end, Maps.newHashMap());
        }else{
            Map<Long, BizCountDateRange> dateRangeMap = heroBizCountDateManager.getDateRange(entityIds, bizType, start, end);
            Map<Long,Long> dateCountMap = heroBizCountDateManager.countDateBetween(entityIds, bizType, start, end);
            Map<Long,Long> restCountMap= heroBizCountRecordManager.computeRestTime(entityIds, bizType, start, end,dateRangeMap);
            entityIds.forEach(entityId -> {
                Long dateCount = dateCountMap.get(entityId);
                Long restCount = restCountMap.get(entityId);
                if(dateCount != null && restCount != null){
                    totalMap.put(entityId, dateCount + restCount);
                }else if(dateCount != null){
                    totalMap.put(entityId, dateCount);
                }else if(restCount != null){
                    totalMap.put(entityId, restCount);
                }
            });
        }
        return totalMap;
    }