From 23f7b250c00597ad89282075460a4c27dffe1ada Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期六, 19 一月 2019 17:39:06 +0800 Subject: [PATCH] Merge branch 'dev-msg' --- fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoWeiQuanOrderServiceImpl.java | 31 +++++++++++++++++++++++++++++++ 1 files changed, 31 insertions(+), 0 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoWeiQuanOrderServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoWeiQuanOrderServiceImpl.java index 50fb869..1dfbb55 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoWeiQuanOrderServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/taobao/TaoBaoWeiQuanOrderServiceImpl.java @@ -8,13 +8,24 @@ import org.springframework.stereotype.Service; import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoWeiQuanOrderMapper; +import com.yeshi.fanli.entity.bus.msg.MsgOrderDetail; +import com.yeshi.fanli.entity.bus.msg.MsgOrderDetail.MsgTypeOrderTypeEnum; +import com.yeshi.fanli.entity.order.CommonOrder; import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder; +import com.yeshi.fanli.service.inter.msg.MsgOrderDetailService; +import com.yeshi.fanli.service.inter.msg.UserOrderMsgNotificationService; import com.yeshi.fanli.service.inter.taobao.TaoBaoWeiQuanOrderService; @Service public class TaoBaoWeiQuanOrderServiceImpl implements TaoBaoWeiQuanOrderService { @Resource private TaoBaoWeiQuanOrderMapper taoBaoWeiQuanOrderMapper; + + @Resource + private UserOrderMsgNotificationService userOrderMsgNotificationService; + + @Resource + private MsgOrderDetailService msgOrderDetailService; @Override public void addWeiQuanOrder(TaoBaoWeiQuanOrder order) { @@ -38,6 +49,26 @@ update.setUpdateTime(new Date()); update.setWeiQuanFinishTime(order.getWeiQuanFinishTime()); taoBaoWeiQuanOrderMapper.updateByPrimaryKeySelective(update); + + try { + if (order.getState().equalsIgnoreCase("缁存潈鎴愬姛")) { + List<MsgOrderDetail> msgList = msgOrderDetailService.listMsgOrderByOrderId(order.getOrderId()); + for (MsgOrderDetail msg : msgList) { + if (msg.getType() == MsgTypeOrderTypeEnum.fanli) { + userOrderMsgNotificationService.orderFanLiStateChanged(msg.getUser().getId(), + order.getOrderId(), null, null, CommonOrder.STATE_WQ); + } else if (msg.getType() == MsgTypeOrderTypeEnum.invite) { + userOrderMsgNotificationService.orderInviteStateChanged(msg.getUser().getId(), + order.getOrderId(), null, null, CommonOrder.STATE_WQ); + } else if (msg.getType() == MsgTypeOrderTypeEnum.share) { + userOrderMsgNotificationService.orderShareStateChanged(msg.getUser().getId(), + order.getOrderId(), null, null, CommonOrder.STATE_WQ); + } + } + } + } catch (Exception e) { + + } } else { order.setCreateTime(new Date()); order.setUpdateTime(new Date()); -- Gitblit v1.8.0