去除final使用@Autowired
This commit is contained in:
@@ -12,7 +12,6 @@ import cn.lili.modules.order.order.entity.dto.OrderMessage;
|
||||
import cn.lili.modules.order.trade.entity.enums.AfterSaleStatusEnum;
|
||||
import cn.lili.timetask.handler.EveryDayExecute;
|
||||
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@@ -23,13 +22,14 @@ import org.springframework.stereotype.Service;
|
||||
* @date 2020-07-03 11:20
|
||||
*/
|
||||
@Service
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class DistributionOrderExecute implements OrderStatusChangeEvent, EveryDayExecute, AfterSaleStatusChangeEvent {
|
||||
|
||||
//分销订单
|
||||
private final DistributionOrderService distributionOrderService;
|
||||
@Autowired
|
||||
private DistributionOrderService distributionOrderService;
|
||||
//分销订单持久层
|
||||
private final DistributionOrderMapper distributionOrderMapper;
|
||||
@Autowired
|
||||
private DistributionOrderMapper distributionOrderMapper;
|
||||
|
||||
|
||||
@Override
|
||||
|
||||
@@ -4,8 +4,6 @@ package cn.lili.event.impl;
|
||||
import cn.lili.event.GoodsCommentCompleteEvent;
|
||||
import cn.lili.modules.goods.service.GoodsSkuService;
|
||||
import cn.lili.modules.member.entity.dos.MemberEvaluation;
|
||||
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
@@ -16,11 +14,11 @@ import org.springframework.stereotype.Service;
|
||||
* @date 2020-07-03 11:20
|
||||
*/
|
||||
@Service
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class GoodsSkuExecute implements GoodsCommentCompleteEvent {
|
||||
|
||||
//商品
|
||||
private final GoodsSkuService goodsSkuService;
|
||||
@Autowired
|
||||
private GoodsSkuService goodsSkuService;
|
||||
|
||||
|
||||
@Override
|
||||
|
||||
@@ -23,13 +23,15 @@ import org.springframework.stereotype.Service;
|
||||
* @date 2020-07-03 11:20
|
||||
*/
|
||||
@Service
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
|
||||
public class MemberPointExecute implements MemberRegisterEvent, GoodsCommentCompleteEvent {
|
||||
|
||||
//配置
|
||||
private final SettingService settingService;
|
||||
@Autowired
|
||||
private SettingService settingService;
|
||||
//会员
|
||||
private final MemberService memberService;
|
||||
@Autowired
|
||||
private MemberService memberService;
|
||||
|
||||
@Override
|
||||
public void memberRegister(Member member) {
|
||||
|
||||
@@ -15,10 +15,10 @@ import org.springframework.stereotype.Service;
|
||||
* @date 2020-07-03 11:20
|
||||
*/
|
||||
@Service
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class MemberWalletExecute implements MemberRegisterEvent {
|
||||
|
||||
private final MemberWalletService memberWalletService;
|
||||
@Autowired
|
||||
private MemberWalletService memberWalletService;
|
||||
|
||||
@Override
|
||||
public void memberRegister(Member member) {
|
||||
|
||||
@@ -31,12 +31,12 @@ import java.util.Map;
|
||||
* @date 2020-07-03 11:20
|
||||
**/
|
||||
@Service
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class NoticeMessageExecute implements TradeEvent, OrderStatusChangeEvent, AfterSaleStatusChangeEvent, MemberPointChangeEvent, MemberWithdrawalEvent {
|
||||
|
||||
private final NoticeMessageService noticeMessageService;
|
||||
|
||||
private final OrderService orderService;
|
||||
@Autowired
|
||||
private NoticeMessageService noticeMessageService;
|
||||
@Autowired
|
||||
private OrderService orderService;
|
||||
|
||||
|
||||
@Override
|
||||
|
||||
@@ -22,10 +22,10 @@ import java.util.List;
|
||||
* @date 2020-07-03 11:20
|
||||
**/
|
||||
@Service
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class OrderCreateReceiptExecute implements TradeEvent {
|
||||
|
||||
private final ReceiptService receiptService;
|
||||
@Autowired
|
||||
private ReceiptService receiptService;
|
||||
|
||||
@Override
|
||||
public void orderCreate(TradeDTO tradeDTO) {
|
||||
|
||||
@@ -22,13 +22,14 @@ import org.springframework.stereotype.Service;
|
||||
* @date 2021-03-13 16:58
|
||||
*/
|
||||
@Service
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class PaymentExecute implements OrderStatusChangeEvent {
|
||||
|
||||
//支付日志
|
||||
private final PaymentService paymentService;
|
||||
@Autowired
|
||||
private PaymentService paymentService;
|
||||
//订单
|
||||
private final OrderService orderService;
|
||||
@Autowired
|
||||
private OrderService orderService;
|
||||
|
||||
@Override
|
||||
public void orderChange(OrderMessage orderMessage) {
|
||||
|
||||
@@ -12,7 +12,6 @@ import cn.lili.modules.order.order.service.OrderService;
|
||||
import cn.lili.modules.promotion.entity.dos.PromotionGoods;
|
||||
import cn.lili.modules.promotion.entity.enums.PromotionTypeEnum;
|
||||
import cn.lili.modules.promotion.service.PromotionGoodsService;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.data.redis.core.StringRedisTemplate;
|
||||
import org.springframework.data.redis.core.script.DefaultRedisScript;
|
||||
@@ -28,20 +27,25 @@ import java.util.List;
|
||||
* @date 2020-07-03 11:20
|
||||
*/
|
||||
@Service
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class StockUpdateExecute implements OrderStatusChangeEvent {
|
||||
|
||||
//Redis
|
||||
private final StringRedisTemplate stringRedisTemplate;
|
||||
private final DefaultRedisScript<Boolean> quantityScript;
|
||||
@Autowired
|
||||
private StringRedisTemplate stringRedisTemplate;
|
||||
@Autowired
|
||||
private DefaultRedisScript<Boolean> quantityScript;
|
||||
//订单
|
||||
private final OrderService orderService;
|
||||
@Autowired
|
||||
private OrderService orderService;
|
||||
//规格商品
|
||||
private final GoodsSkuService goodsSkuService;
|
||||
@Autowired
|
||||
private GoodsSkuService goodsSkuService;
|
||||
//促销商品
|
||||
private final PromotionGoodsService promotionGoodsService;
|
||||
@Autowired
|
||||
private PromotionGoodsService promotionGoodsService;
|
||||
//缓存
|
||||
private final Cache cache;
|
||||
@Autowired
|
||||
private Cache cache;
|
||||
|
||||
@Override
|
||||
public void orderChange(OrderMessage orderMessage) {
|
||||
|
||||
@@ -6,7 +6,6 @@ import cn.lili.modules.message.util.WechatMessageUtil;
|
||||
import cn.lili.modules.order.cart.entity.dto.TradeDTO;
|
||||
import cn.lili.modules.order.order.entity.dto.OrderMessage;
|
||||
import cn.lili.modules.order.order.entity.vo.OrderVO;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
@@ -20,7 +19,6 @@ import org.springframework.stereotype.Service;
|
||||
*/
|
||||
@Slf4j
|
||||
@Service
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class WechatMessageExecute implements OrderStatusChangeEvent, TradeEvent {
|
||||
|
||||
@Autowired
|
||||
|
||||
@@ -4,7 +4,6 @@ import cn.hutool.json.JSONUtil;
|
||||
import cn.lili.common.rocketmq.tags.AfterSaleTagsEnum;
|
||||
import cn.lili.event.AfterSaleStatusChangeEvent;
|
||||
import cn.lili.modules.order.order.entity.dos.AfterSale;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.rocketmq.common.message.MessageExt;
|
||||
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
|
||||
@@ -22,12 +21,12 @@ import java.util.List;
|
||||
*/
|
||||
@Slf4j
|
||||
@Component
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
@RocketMQMessageListener(topic = "${lili.data.rocketmq.after-sale-topic}", consumerGroup = "${lili.data.rocketmq.after-sale-group}")
|
||||
public class AfterSaleMessageListener implements RocketMQListener<MessageExt> {
|
||||
|
||||
//售后订单状态
|
||||
private final List<AfterSaleStatusChangeEvent> afterSaleStatusChangeEvents;
|
||||
@Autowired
|
||||
private List<AfterSaleStatusChangeEvent> afterSaleStatusChangeEvents;
|
||||
|
||||
@Override
|
||||
public void onMessage(MessageExt messageExt) {
|
||||
|
||||
@@ -36,24 +36,30 @@ import java.util.List;
|
||||
**/
|
||||
@Component
|
||||
@Slf4j
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
@RocketMQMessageListener(topic = "${lili.data.rocketmq.goods-topic}", consumerGroup = "${lili.data.rocketmq.goods-group}")
|
||||
public class GoodsMessageListener implements RocketMQListener<MessageExt> {
|
||||
|
||||
//ES商品
|
||||
private final EsGoodsIndexService goodsIndexService;
|
||||
@Autowired
|
||||
private EsGoodsIndexService goodsIndexService;
|
||||
//店铺
|
||||
private final StoreService storeService;
|
||||
@Autowired
|
||||
private StoreService storeService;
|
||||
//商品
|
||||
private final GoodsService goodsService;
|
||||
@Autowired
|
||||
private GoodsService goodsService;
|
||||
//商品
|
||||
private final GoodsSkuService goodsSkuService;
|
||||
@Autowired
|
||||
private GoodsSkuService goodsSkuService;
|
||||
//用户足迹
|
||||
private final FootprintService footprintService;
|
||||
@Autowired
|
||||
private FootprintService footprintService;
|
||||
//商品收藏
|
||||
private final GoodsCollectionService goodsCollectionService;
|
||||
@Autowired
|
||||
private GoodsCollectionService goodsCollectionService;
|
||||
//商品评价
|
||||
private final List<GoodsCommentCompleteEvent> goodsCommentCompleteEvents;
|
||||
@Autowired
|
||||
private List<GoodsCommentCompleteEvent> goodsCommentCompleteEvents;
|
||||
@Override
|
||||
public void onMessage(MessageExt messageExt) {
|
||||
|
||||
|
||||
@@ -10,7 +10,6 @@ import cn.lili.modules.member.entity.dos.MemberSign;
|
||||
import cn.lili.modules.member.entity.dto.MemberPointMessage;
|
||||
import cn.lili.modules.member.entity.dto.MemberWithdrawalMessage;
|
||||
import cn.lili.modules.member.service.MemberSignService;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.rocketmq.common.message.MessageExt;
|
||||
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
|
||||
@@ -28,18 +27,21 @@ import java.util.List;
|
||||
**/
|
||||
@Component
|
||||
@Slf4j
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
@RocketMQMessageListener(topic = "${lili.data.rocketmq.member-topic}", consumerGroup = "${lili.data.rocketmq.member-group}")
|
||||
public class MemberMessageListener implements RocketMQListener<MessageExt> {
|
||||
|
||||
//会员签到
|
||||
private final MemberSignService memberSignService;
|
||||
@Autowired
|
||||
private MemberSignService memberSignService;
|
||||
//会员积分变化
|
||||
private final List<MemberPointChangeEvent> memberPointChangeEvents;
|
||||
@Autowired
|
||||
private List<MemberPointChangeEvent> memberPointChangeEvents;
|
||||
//会员提现
|
||||
private final List<MemberWithdrawalEvent> memberWithdrawalEvents;
|
||||
@Autowired
|
||||
private List<MemberWithdrawalEvent> memberWithdrawalEvents;
|
||||
//会员注册
|
||||
private final List<MemberRegisterEvent> memberSignEvents;
|
||||
@Autowired
|
||||
private List<MemberRegisterEvent> memberSignEvents;
|
||||
|
||||
|
||||
@Override
|
||||
|
||||
@@ -17,12 +17,12 @@ import org.springframework.stereotype.Component;
|
||||
* @since 2020/12/9
|
||||
*/
|
||||
@Component
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
@RocketMQMessageListener(topic = "${lili.data.rocketmq.notice-topic}", consumerGroup = "${lili.data.rocketmq.notice-group}")
|
||||
public class NoticeMessageListener implements RocketMQListener<MessageExt> {
|
||||
|
||||
//站内信
|
||||
private final NoticeMessageService noticeMessageService;
|
||||
@Autowired
|
||||
private NoticeMessageService noticeMessageService;
|
||||
|
||||
@Override
|
||||
public void onMessage(MessageExt messageExt) {
|
||||
|
||||
@@ -30,18 +30,21 @@ import java.util.List;
|
||||
* @since 2020/12/9
|
||||
*/
|
||||
@Component
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
@RocketMQMessageListener(topic = "${lili.data.rocketmq.notice-send-topic}", consumerGroup = "${lili.data.rocketmq.notice-send-group}")
|
||||
public class NoticeSendMessageListener implements RocketMQListener<MessageExt> {
|
||||
|
||||
//会员
|
||||
private final MemberMapper memberMapper;
|
||||
@Autowired
|
||||
private MemberMapper memberMapper;
|
||||
//短信
|
||||
private final SmsUtil smsUtil;
|
||||
@Autowired
|
||||
private SmsUtil smsUtil;
|
||||
//店铺消息
|
||||
private final StoreMessageService storeMessageService;
|
||||
@Autowired
|
||||
private StoreMessageService storeMessageService;
|
||||
//店铺
|
||||
private final StoreService storeService;
|
||||
@Autowired
|
||||
private StoreService storeService;
|
||||
|
||||
@Override
|
||||
public void onMessage(MessageExt messageExt) {
|
||||
|
||||
@@ -7,7 +7,6 @@ import cn.lili.event.OrderStatusChangeEvent;
|
||||
import cn.lili.event.TradeEvent;
|
||||
import cn.lili.modules.order.cart.entity.dto.TradeDTO;
|
||||
import cn.lili.modules.order.order.entity.dto.OrderMessage;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.rocketmq.common.message.MessageExt;
|
||||
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
|
||||
@@ -25,16 +24,18 @@ import java.util.List;
|
||||
**/
|
||||
@Component
|
||||
@Slf4j
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
@RocketMQMessageListener(topic = "${lili.data.rocketmq.order-topic}", consumerGroup = "${lili.data.rocketmq.order-group}")
|
||||
public class OrderMessageListener implements RocketMQListener<MessageExt> {
|
||||
|
||||
//交易
|
||||
private final List<TradeEvent> tradeEvent;
|
||||
@Autowired
|
||||
private List<TradeEvent> tradeEvent;
|
||||
//订单状态
|
||||
private final List<OrderStatusChangeEvent> orderStatusChangeEvents;
|
||||
@Autowired
|
||||
private List<OrderStatusChangeEvent> orderStatusChangeEvents;
|
||||
//缓存
|
||||
private final Cache<Object> cache;
|
||||
@Autowired
|
||||
private Cache<Object> cache;
|
||||
|
||||
@Override
|
||||
public void onMessage(MessageExt messageExt) {
|
||||
|
||||
@@ -19,13 +19,14 @@ import java.util.List;
|
||||
* @date 2021/2/18 3:45 下午
|
||||
*/
|
||||
@Component
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class BillExecute implements EveryDayExecute {
|
||||
|
||||
//结算单
|
||||
private final BillService billService;
|
||||
@Autowired
|
||||
private BillService billService;
|
||||
//店铺详情
|
||||
private final StoreDetailMapper storeDetailMapper;
|
||||
@Autowired
|
||||
private StoreDetailMapper storeDetailMapper;
|
||||
|
||||
/**
|
||||
* 1.查询今日待结算的商家
|
||||
|
||||
@@ -7,7 +7,6 @@ import cn.lili.modules.member.entity.dos.MemberEvaluation;
|
||||
import cn.lili.modules.member.mapper.MemberEvaluationMapper;
|
||||
import cn.lili.timetask.handler.EveryDayExecute;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@@ -21,12 +20,13 @@ import java.util.Map;
|
||||
* @date 2021/3/18 3:23 下午
|
||||
*/
|
||||
@Component
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class GoodsExecute implements EveryDayExecute {
|
||||
//会员评价
|
||||
private final MemberEvaluationMapper memberEvaluationMapper;
|
||||
@Autowired
|
||||
private MemberEvaluationMapper memberEvaluationMapper;
|
||||
//商品
|
||||
private final GoodsMapper goodsMapper;
|
||||
@Autowired
|
||||
private GoodsMapper goodsMapper;
|
||||
|
||||
/**
|
||||
* 查询已上架的商品的评价数量并赋值
|
||||
|
||||
@@ -28,12 +28,14 @@ import java.util.stream.Collectors;
|
||||
**/
|
||||
@Slf4j
|
||||
@Component
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
|
||||
public class CancelOrderTaskExecute implements EveryMinuteExecute {
|
||||
//订单
|
||||
private final OrderService orderService;
|
||||
@Autowired
|
||||
private OrderService orderService;
|
||||
//设置
|
||||
private final SettingService settingService;
|
||||
@Autowired
|
||||
private SettingService settingService;
|
||||
|
||||
|
||||
@Override
|
||||
|
||||
@@ -19,7 +19,6 @@ import cn.lili.modules.system.service.SettingService;
|
||||
import cn.lili.timetask.handler.EveryDayExecute;
|
||||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
||||
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Component;
|
||||
@@ -34,17 +33,21 @@ import java.util.stream.Collectors;
|
||||
**/
|
||||
@Slf4j
|
||||
@Component
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
|
||||
public class OrderEveryDayTaskExecute implements EveryDayExecute {
|
||||
|
||||
//订单
|
||||
private final OrderService orderService;
|
||||
@Autowired
|
||||
private OrderService orderService;
|
||||
//订单货物
|
||||
private final OrderItemService orderItemService;
|
||||
@Autowired
|
||||
private OrderItemService orderItemService;
|
||||
//设置
|
||||
private final SettingService settingService;
|
||||
@Autowired
|
||||
private SettingService settingService;
|
||||
//会员评价
|
||||
private final MemberEvaluationService memberEvaluationService;
|
||||
@Autowired
|
||||
private MemberEvaluationService memberEvaluationService;
|
||||
|
||||
/**
|
||||
* 执行每日任务
|
||||
|
||||
@@ -29,21 +29,27 @@ import java.util.List;
|
||||
* @date 2021/3/18 3:23 下午
|
||||
*/
|
||||
@Component
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
|
||||
public class PromotionEverydayExecute implements EveryDayExecute {
|
||||
|
||||
//Mongo
|
||||
private final MongoTemplate mongoTemplate;
|
||||
@Autowired
|
||||
private MongoTemplate mongoTemplate;
|
||||
//满额活动
|
||||
private final FullDiscountService fullDiscountService;
|
||||
@Autowired
|
||||
private FullDiscountService fullDiscountService;
|
||||
//拼团
|
||||
private final PintuanService pintuanService;
|
||||
@Autowired
|
||||
private PintuanService pintuanService;
|
||||
//优惠券
|
||||
private final CouponService couponService;
|
||||
@Autowired
|
||||
private CouponService couponService;
|
||||
//会员优惠券
|
||||
private final MemberCouponService memberCouponService;
|
||||
@Autowired
|
||||
private MemberCouponService memberCouponService;
|
||||
//促销商品
|
||||
private final PromotionGoodsService promotionGoodsService;
|
||||
@Autowired
|
||||
private PromotionGoodsService promotionGoodsService;
|
||||
|
||||
|
||||
/**
|
||||
|
||||
@@ -3,7 +3,6 @@ package cn.lili.timetask.handler.impl.statistics;
|
||||
import cn.lili.modules.statistics.model.dos.MemberStatisticsData;
|
||||
import cn.lili.modules.statistics.service.MemberStatisticsDataService;
|
||||
import cn.lili.timetask.handler.EveryDayExecute;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Component;
|
||||
@@ -19,11 +18,11 @@ import java.util.Date;
|
||||
*/
|
||||
@Slf4j
|
||||
@Component
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class MemberStatisticsExecute implements EveryDayExecute {
|
||||
|
||||
//会员统计
|
||||
private final MemberStatisticsDataService memberStatisticsDataService;
|
||||
@Autowired
|
||||
private MemberStatisticsDataService memberStatisticsDataService;
|
||||
|
||||
@Override
|
||||
public void execute() {
|
||||
|
||||
@@ -6,7 +6,6 @@ import cn.lili.common.security.enums.UserEnums;
|
||||
import cn.lili.config.properties.StatisticsProperties;
|
||||
import cn.lili.modules.statistics.model.vo.OnlineMemberVO;
|
||||
import cn.lili.timetask.handler.EveryHourExecute;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@@ -23,13 +22,14 @@ import java.util.stream.Collectors;
|
||||
* @date 2021-02-21 09:47
|
||||
*/
|
||||
@Component
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class OnlineMemberStatistics implements EveryHourExecute {
|
||||
|
||||
//缓存
|
||||
private final Cache cache;
|
||||
@Autowired
|
||||
private Cache cache;
|
||||
//统计小时
|
||||
private final StatisticsProperties statisticsProperties;
|
||||
@Autowired
|
||||
private StatisticsProperties statisticsProperties;
|
||||
|
||||
|
||||
@Override
|
||||
|
||||
@@ -24,12 +24,13 @@ import java.util.List;
|
||||
* @date 2021/3/15 5:30 下午
|
||||
*/
|
||||
@Component
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class StoreRatingExecute implements EveryDayExecute {
|
||||
//店铺
|
||||
private final StoreService storeService;
|
||||
@Autowired
|
||||
private StoreService storeService;
|
||||
//会员评价
|
||||
private final MemberEvaluationMapper memberEvaluationMapper;
|
||||
@Autowired
|
||||
private MemberEvaluationMapper memberEvaluationMapper;
|
||||
|
||||
|
||||
@Override
|
||||
|
||||
@@ -8,7 +8,6 @@ import cn.lili.modules.statistics.model.dos.PlatformViewData;
|
||||
import cn.lili.modules.statistics.service.PlatformViewDataService;
|
||||
import cn.lili.timetask.handler.EveryDayExecute;
|
||||
import lombok.Data;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
@@ -28,12 +27,13 @@ import java.util.List;
|
||||
*/
|
||||
@Slf4j
|
||||
@Component
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class PageViewStatisticsExecute implements EveryDayExecute {
|
||||
//缓存
|
||||
private final Cache cache;
|
||||
@Autowired
|
||||
private Cache cache;
|
||||
//平台PV统计
|
||||
private final PlatformViewDataService platformViewDataService;
|
||||
@Autowired
|
||||
private PlatformViewDataService platformViewDataService;
|
||||
|
||||
@Override
|
||||
public void execute() {
|
||||
|
||||
@@ -6,7 +6,6 @@ import cn.lili.common.trigger.interfaces.TimeTriggerExecutor;
|
||||
import cn.lili.common.trigger.model.TimeTriggerMsg;
|
||||
import cn.lili.common.trigger.util.TimeTriggerUtil;
|
||||
import cn.lili.common.utils.SpringContextUtil;
|
||||
import lombok.RequiredArgsConstructor;
|
||||
import lombok.extern.slf4j.Slf4j;
|
||||
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
|
||||
import org.apache.rocketmq.spring.core.RocketMQListener;
|
||||
@@ -21,11 +20,10 @@ import org.springframework.stereotype.Component;
|
||||
*/
|
||||
@Component
|
||||
@Slf4j
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
@RocketMQMessageListener(topic = "${lili.data.rocketmq.promotion-topic}", consumerGroup = "${lili.data.rocketmq.promotion-group}")
|
||||
public class TimeTriggerConsumer implements RocketMQListener<TimeTriggerMsg> {
|
||||
|
||||
private final Cache<Integer> cache;
|
||||
@Autowired
|
||||
private Cache<Integer> cache;
|
||||
|
||||
@Override
|
||||
public void onMessage(TimeTriggerMsg timeTriggerMsg) {
|
||||
|
||||
@@ -26,16 +26,19 @@ import org.springframework.stereotype.Component;
|
||||
*/
|
||||
@Slf4j
|
||||
@Component(TimeExecuteConstant.PROMOTION_EXECUTOR)
|
||||
@RequiredArgsConstructor(onConstructor = @__(@Autowired))
|
||||
public class PromotionTimeTriggerExecutor implements TimeTriggerExecutor {
|
||||
//促销
|
||||
private final PromotionService promotionService;
|
||||
@Autowired
|
||||
private PromotionService promotionService;
|
||||
//Rocketmq
|
||||
private final RocketmqCustomProperties rocketmqCustomProperties;
|
||||
@Autowired
|
||||
private RocketmqCustomProperties rocketmqCustomProperties;
|
||||
//延时任务
|
||||
private final TimeTrigger timeTrigger;
|
||||
@Autowired
|
||||
private TimeTrigger timeTrigger;
|
||||
//订单
|
||||
private final OrderService orderService;
|
||||
@Autowired
|
||||
private OrderService orderService;
|
||||
|
||||
|
||||
@Override
|
||||
|
||||
Reference in New Issue
Block a user