好单库转链支持

admin

2020-06-15 3e4ef41ffacd7f5fda2e81c3810cd11a6375b83c

 fanli/src/main/java/com/yeshi/fanli/service/impl/order/dividents/TeamDividentsSourceOrderServiceImpl.java

@@ -1,5 +1,6 @@
package com.yeshi.fanli.service.impl.order.dividents;



import java.math.BigDecimal;

import java.util.Date;

import java.util.List;



@@ -22,45 +23,21 @@
   private TeamDividentsSourceOrderMapper teamDividentsSourceOrderMapper;



   @Override

   public void addTeamDividentsSourceOrder(TeamDividentsSourceOrder order)

   public TeamDividentsSourceOrder addTeamDividentsSourceOrder(TeamDividentsSourceOrder order)

         throws TeamDividentsSourceOrderException, ParamsException {

      if (order == null || order.getMoney() == null || StringUtil.isNullOrEmpty(order.getOrderNo())

            || order.getSourceType() == null || order.getState() == null || order.getUid() == null

            || order.getPreSendTime() == null)

            || order.getSourceType() == null || order.getState() == null || order.getUid() == null)

         throw new ParamsException(1, "参数不完整");



      TeamDividentsSourceOrder sourceOrder = selectByOrderNoSourceType(order.getOrderNo(), order.getSourceType());

      if (sourceOrder != null)

         throw new TeamDividentsSourceOrderException(1, "订单已存在");

         throw new TeamDividentsSourceOrderException(TeamDividentsSourceOrderException.CODE_EXIST, "订单已存在");



      if (order.getCreateTime() == null)

         order.setCreateTime(new Date());

      teamDividentsSourceOrderMapper.insertSelective(order);

   }



   @Override

   public List<TeamDividentsSourceOrder> listCanSendByUidAndPreSendTime(Long uid, Date preSendTime, int page,

         int pageSize) {

      return teamDividentsSourceOrderMapper.lisByUidAndPreSendTimeAndState(uid, preSendTime,

            TeamDividentsSourceOrder.STATE_CAN_SEND, (page - 1) * pageSize, pageSize);

   }



   @Override

   public long countCanSendByUidAndPreSendTime(Long uid, Date preSendTime) {

      return teamDividentsSourceOrderMapper.countByUidAndPreSendTimeAndState(uid, preSendTime,

            TeamDividentsSourceOrder.STATE_CAN_SEND);

   }



   @Override

   public List<Long> listCanSendUidByPreSendTime(Date preSendTime, int page, int pageSize) {

      return teamDividentsSourceOrderMapper.listUidByPreSendTimeAndState(preSendTime,

            TeamDividentsSourceOrder.STATE_CAN_SEND, (page - 1) * pageSize, pageSize);

   }



   @Override

   public Long countCanSendUidByPreSendTime(Date preSendTime) {

      return teamDividentsSourceOrderMapper.countUidByPreSendTimeAndState(preSendTime,

            TeamDividentsSourceOrder.STATE_CAN_SEND);

      return order;

   }



   @Override

@@ -112,4 +89,48 @@


   }



   @Transactional(rollbackFor = Exception.class)

   @Override

   public void orderSettle(String orderNo, int sourceType, Date preSendTime, BigDecimal income) {

      TeamDividentsSourceOrder order = selectByOrderNoSourceType(orderNo, sourceType);

      if (order == null)

         return;

      if (order.getState() == TeamDividentsSourceOrder.STATE_UNKOWN) {

         TeamDividentsSourceOrder update = new TeamDividentsSourceOrder();

         update.setId(order.getId());

         update.setMoney(income);

         update.setState(TeamDividentsSourceOrder.STATE_CAN_SEND);

         update.setPreSendTime(preSendTime);

         update.setUpdateTime(new Date());

         teamDividentsSourceOrderMapper.updateByPrimaryKeySelective(update);

      }



   }



   @Override

   public void updateMoney(String orderNo, int sourceType, BigDecimal money) {



      TeamDividentsSourceOrder order = selectByOrderNoSourceType(orderNo, sourceType);

      if (order == null)

         return;

      if (order.getState() == TeamDividentsSourceOrder.STATE_UNKOWN) {

         TeamDividentsSourceOrder update = new TeamDividentsSourceOrder();

         update.setId(order.getId());

         update.setMoney(money);

         update.setUpdateTime(new Date());

         teamDividentsSourceOrderMapper.updateByPrimaryKeySelective(update);

      }



   }



   @Override

   public List<TeamDividentsSourceOrder> listByOrderNoOrUid(String orderNo, Long uid) {

      return null;

   }



   @Override

   public List<TeamDividentsSourceOrder> listByOrderNo(String orderNo) {

      return teamDividentsSourceOrderMapper.listByOrderNo(orderNo);

   }

	
}