用户注册信息

yujian

2020-01-18 f4a0f2acc63d7785eab108419a4e16f5f688cb95

 fanli/src/main/java/com/yeshi/fanli/service/impl/order/tb/TaoBaoWeiQuanOrderServiceImpl.java

@@ -6,6 +6,7 @@
import javax.annotation.Resource;



import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;



import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoWeiQuanOrderMapper;

import com.yeshi.fanli.entity.bus.msg.MsgOrderDetail;

@@ -13,6 +14,7 @@
import com.yeshi.fanli.entity.order.CommonOrder;

import com.yeshi.fanli.entity.taobao.TaoBaoWeiQuanOrder;

import com.yeshi.fanli.service.inter.order.CommonOrderService;

import com.yeshi.fanli.service.inter.order.UserOrderWeiQuanRecordService;

import com.yeshi.fanli.service.inter.order.msg.MsgOrderDetailService;

import com.yeshi.fanli.service.inter.order.msg.UserOrderMsgNotificationService;

import com.yeshi.fanli.service.inter.order.tb.TaoBaoWeiQuanOrderService;

@@ -32,6 +34,10 @@
   @Resource

   private CommonOrderService commonOrderService;



   @Resource

   private UserOrderWeiQuanRecordService userOrderWeiQuanRecordService;



   @Transactional(rollbackFor = Exception.class)

   @Override

   public void addWeiQuanOrder(TaoBaoWeiQuanOrder order) {

      if (order == null)

@@ -41,8 +47,7 @@
            .selectByOrderIdAndOrderItemId(order.getOrderId(), order.getOrderItemId());

      if (taoBaoWeiQuanOrder != null) {

         // 已经是最新的状态了

         if (taoBaoWeiQuanOrder.getState() != null && (taoBaoWeiQuanOrder.getState().contains("维权成功")

               || taoBaoWeiQuanOrder.getState().contains("维权失败")))

         if (taoBaoWeiQuanOrder.getState() != null && (taoBaoWeiQuanOrder.getState().contains("维权成功")))

            return;

         // 更新金额，状态与时间

         TaoBaoWeiQuanOrder update = new TaoBaoWeiQuanOrder();

@@ -65,21 +70,28 @@
                  updateCommonOrder.setState(CommonOrder.STATE_WQ);

                  updateCommonOrder.setUpdateTime(new Date());

                  commonOrderService.updateByPrimaryKeySelective(updateCommonOrder);

                  userOrderWeiQuanRecordService.addTaoBaoWeiQuan(taoBaoWeiQuanOrder);

               }



               List<MsgOrderDetail> msgList = msgOrderDetailService.listMsgOrderByOrderId(order.getOrderId());

               for (MsgOrderDetail msg : msgList) {

                  if (msg.getType() == MsgTypeOrderTypeEnum.fanli) {

                     userOrderMsgNotificationService.orderFanLiStateChanged(msg.getUser().getId(),

                           order.getOrderId(), Constant.SOURCE_TYPE_TAOBAO, null, null, CommonOrder.STATE_WQ);

                  } else if (msg.getType() == MsgTypeOrderTypeEnum.invite) {

                     userOrderMsgNotificationService.orderInviteStateChanged(msg.getUser().getId(),

                           order.getOrderId(), Constant.SOURCE_TYPE_TAOBAO, null, null, CommonOrder.STATE_WQ);

                  } else if (msg.getType() == MsgTypeOrderTypeEnum.share) {

                     userOrderMsgNotificationService.orderShareStateChanged(msg.getUser().getId(),

                           order.getOrderId(), Constant.SOURCE_TYPE_TAOBAO, null, null, CommonOrder.STATE_WQ);

                  }

               }

               // 维权状态不需要消息

               // List<MsgOrderDetail> msgList =

               // msgOrderDetailService.listMsgOrderByOrderId(order.getOrderId());

               // for (MsgOrderDetail msg : msgList) {

               // if (msg.getType() == MsgTypeOrderTypeEnum.fanli) {

               // userOrderMsgNotificationService.orderFanLiStateChanged(msg.getUser().getId(),

               // order.getOrderId(), Constant.SOURCE_TYPE_TAOBAO, null,

               // null, CommonOrder.STATE_WQ);

               // } else if (msg.getType() == MsgTypeOrderTypeEnum.invite)

               // {

               // userOrderMsgNotificationService.orderInviteStateChanged(msg.getUser().getId(),

               // order.getOrderId(), Constant.SOURCE_TYPE_TAOBAO, null,

               // null, CommonOrder.STATE_WQ);

               // } else if (msg.getType() == MsgTypeOrderTypeEnum.share) {

               // userOrderMsgNotificationService.orderShareStateChanged(msg.getUser().getId(),

               // order.getOrderId(), Constant.SOURCE_TYPE_TAOBAO, null,

               // null, CommonOrder.STATE_WQ);

               // }

               // }

            }

         } catch (Exception e) {



@@ -88,6 +100,18 @@
         order.setCreateTime(new Date());

         order.setUpdateTime(new Date());

         taoBaoWeiQuanOrderMapper.insertSelective(order);

         if (order.getState().contains("维权成功")) {

            // 更改CommonOrder的状态

            CommonOrder commonOrder = commonOrderService.selectBySourceTypeAndTradeId(Constant.SOURCE_TYPE_TAOBAO,

                  order.getOrderItemId());

            if (commonOrder != null) {

               CommonOrder updateCommonOrder = new CommonOrder(commonOrder.getId());

               updateCommonOrder.setState(CommonOrder.STATE_WQ);

               updateCommonOrder.setUpdateTime(new Date());

               commonOrderService.updateByPrimaryKeySelective(updateCommonOrder);

               userOrderWeiQuanRecordService.addTaoBaoWeiQuan(order);

            }

         }

      }

   }



@@ -121,4 +145,8 @@
      return taoBaoWeiQuanOrderMapper.selectByOrderItem(tradeId);

   }



   @Override

   public List<TaoBaoWeiQuanOrder> listByBeginWeiQuan(int page, int pageSize) {

      return taoBaoWeiQuanOrderMapper.listByBeginWeiQuan((page - 1) * pageSize, pageSize);

   }

}