| | |
|---|
| | | import com.yeshi.fanli.service.inter.order.OrderMoneySettleService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService;
|
|---|
| | | import com.yeshi.fanli.service.manger.order.TeamSubsidyManager;
|
|---|
| | | import com.yeshi.fanli.util.Constant;
|
|---|
| | | import com.yeshi.fanli.util.TimeUtil;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|---|
| | |
|
|---|
| | |
|---|
| | |
|
|---|
| | | @Resource
|
|---|
| | | private CommonOrderService commonOrderService;
|
|---|
| | |
|
|---|
| | | // 团队奖励开始时间
|
|---|
| | | private static final long TEAM_REWARD_START_TIME = TimeUtil.convertToTimeTemp("2019-04-15", "yyyy-MM-dd");
|
|---|
| | |
|
|---|
| | | |
|---|
| | | public InviteOrderSubsidyMessageListener() {
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|---|
| | | if (dto != null) {
|
|---|
| | | // 查询出订单创建时间
|
|---|
| | | Date orderTime = commonOrderService.getThirdCreateTime(dto.getOrderId(), dto.getType());
|
|---|
| | | if (orderTime.getTime() >= TEAM_REWARD_START_TIME) {
|
|---|
| | | if (orderTime.getTime() >= Constant.NEW_ORDER_FANLI_RULE_TIME) {
|
|---|
| | | try {
|
|---|
| | | teamSubsidyManager.addOrUpdateOrder(dto.getOrderId(), dto.getType());
|
|---|
| | | return Action.CommitMessage;
|
|---|
| | |
|---|
| | | } catch (ParamsException e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | return Action.ReconsumeLater;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
