diff --git a/consumer/src/main/java/cn/lili/timetask/handler/impl/order/OrderEveryDayTaskExecute.java b/consumer/src/main/java/cn/lili/timetask/handler/impl/order/OrderEveryDayTaskExecute.java index 6370b260..8e9f2e6a 100644 --- a/consumer/src/main/java/cn/lili/timetask/handler/impl/order/OrderEveryDayTaskExecute.java +++ b/consumer/src/main/java/cn/lili/timetask/handler/impl/order/OrderEveryDayTaskExecute.java @@ -2,8 +2,6 @@ package cn.lili.timetask.handler.impl.order; import cn.hutool.core.date.DateTime; import cn.hutool.core.date.DateUtil; -import cn.hutool.core.util.ObjectUtil; -import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONUtil; import cn.lili.common.enums.ResultCode; import cn.lili.common.exception.ServiceException; @@ -88,14 +86,30 @@ public class OrderEveryDayTaskExecute implements EveryDayExecute { throw new ServiceException(ResultCode.ORDER_SETTING_ERROR); } - //自动确认收货 - completedOrder(orderSetting); - //自动好评 - memberEvaluation(orderSetting); - //关闭允许售后申请 - closeAfterSale(orderSetting); - //关闭允许投诉 - closeComplaint(orderSetting); + try { + //自动确认收货 + completedOrder(orderSetting); + } catch (Exception e) { + log.error(e.getMessage(), e); + } + try { + //自动好评 + memberEvaluation(orderSetting); + } catch (Exception e) { + log.error(e.getMessage(), e); + } + try { + //关闭允许售后申请 + closeAfterSale(orderSetting); + } catch (Exception e) { + log.error(e.getMessage(), e); + } + try { + //关闭允许投诉 + closeComplaint(orderSetting); + } catch (Exception e) { + log.error(e.getMessage(), e); + } } /** @@ -115,12 +129,16 @@ public class OrderEveryDayTaskExecute implements EveryDayExecute { queryWrapper.le(Order::getLogisticsTime, receiveTime); List list = orderService.list(queryWrapper); - //判断是否有符合条件的订单,进行订单完成处理 - if (!list.isEmpty()) { - List receiveSnList = list.stream().map(Order::getSn).collect(Collectors.toList()); - for (String orderSn : receiveSnList) { - orderService.systemComplete(orderSn); + try { + //判断是否有符合条件的订单,进行订单完成处理 + if (!list.isEmpty()) { + List receiveSnList = list.stream().map(Order::getSn).collect(Collectors.toList()); + for (String orderSn : receiveSnList) { + orderService.systemComplete(orderSn); + } } + } catch (Exception e) { + log.error(e.getMessage(), e); } } @@ -152,7 +170,12 @@ public class OrderEveryDayTaskExecute implements EveryDayExecute { memberEvaluationDTO.setDescriptionScore(5); memberEvaluationDTO.setServiceScore(5); - memberEvaluationService.addMemberEvaluation(memberEvaluationDTO, false); + try { + memberEvaluationService.addMemberEvaluation(memberEvaluationDTO, false); + + } catch (Exception e) { + log.error(e.getMessage(), e); + } } } } @@ -164,7 +187,6 @@ public class OrderEveryDayTaskExecute implements EveryDayExecute { * @param orderSetting 订单设置 */ private void closeAfterSale(OrderSetting orderSetting) { - //订单关闭售后申请时间 = 当前时间 - 自动关闭售后申请天数 DateTime receiveTime = DateUtil.offsetDay(DateUtil.date(), -orderSetting.getCloseAfterSale()); @@ -187,7 +209,7 @@ public class OrderEveryDayTaskExecute implements EveryDayExecute { orderItemService.update(lambdaUpdateWrapper); //修改订售后状态 List orderItemsList = orderItems.stream() - .map((orderItem)->{ + .map((orderItem) -> { orderItem.setAfterSaleStatus(OrderItemAfterSaleStatusEnum.EXPIRED.name()); return orderItem; }) diff --git a/framework/src/main/java/cn/lili/common/properties/RocketmqCustomProperties.java b/framework/src/main/java/cn/lili/common/properties/RocketmqCustomProperties.java index 934057ac..cfc001ff 100644 --- a/framework/src/main/java/cn/lili/common/properties/RocketmqCustomProperties.java +++ b/framework/src/main/java/cn/lili/common/properties/RocketmqCustomProperties.java @@ -19,6 +19,7 @@ import org.springframework.stereotype.Component; @ConfigurationProperties(prefix = "lili.data.rocketmq") public class RocketmqCustomProperties { + private String promotionTopic; private String promotionGroup; diff --git a/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberEvaluationServiceImpl.java b/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberEvaluationServiceImpl.java index 94e7239f..6877a97a 100644 --- a/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberEvaluationServiceImpl.java +++ b/framework/src/main/java/cn/lili/modules/member/serviceimpl/MemberEvaluationServiceImpl.java @@ -122,6 +122,9 @@ public class MemberEvaluationServiceImpl extends ServiceImpl