admin
2019-08-19 27920d99bc5925de113aa4f0c22dbba3dcea672f
fanli/src/main/java/com/yeshi/fanli/service/impl/order/OrderProcessServiceImpl.java
@@ -16,7 +16,9 @@
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.yeshi.utils.NumberUtil;
import com.google.gson.Gson;
import com.yeshi.fanli.dao.mybatis.HongBaoV2Mapper;
import com.yeshi.fanli.dao.mybatis.UserInfoMapper;
import com.yeshi.fanli.dao.mybatis.money.UserMoneyDetailMapper;
@@ -227,6 +229,7 @@
   @Override
   public void fanli() {
      LogHelper.test("处理返利到账");
      // 获取主红包
      List<HongBaoV2> hongBaoList = hongBaoV2Mapper.listCanBalanceHongBaoByType(HongBaoV2.TYPE_ZIGOU, 1000);
      //
@@ -461,8 +464,12 @@
   public void weiQuanOrder(List<TaoBaoWeiQuanOrder> orderList) {
      if (orderList != null)
         for (TaoBaoWeiQuanOrder order : orderList) {
            if (order.getState().contains("维权成功")) {
               CMQManager.getInstance().addWeiQuanOrderMsg(order);
            try {
               if (order.getState().contains("维权成功")) {
                  CMQManager.getInstance().addWeiQuanOrderMsg(order);
               }
            } catch (Exception e) {
               LogHelper.error("维权订单加入到队列出错:"+order!=null?new Gson().toJson(order):null);
            }
         }
   }
@@ -973,7 +980,7 @@
         return;
      String uidStr = order.getExt1();
      Long uid = null;
      if (!StringUtil.isNullOrEmpty(uidStr))
      if (!StringUtil.isNullOrEmpty(uidStr) && NumberUtil.isNumeric(uidStr))
         uid = Long.parseLong(uidStr);
      Long positionId = order.getOrderItemList().get(0).getPositionId();
      if (positionId == JDApiUtil.POSITION_FANLI)// 返利订单
@@ -1016,7 +1023,7 @@
      // 加入订单
      Order oldOrder = orderMapper.selectOrderByOrderIdAndOrderType(jdOrder.getOrderId() + "",
            Constant.SOURCE_TYPE_JD);
      if (uid == null && oldOrder.getBeizhu().contains("补单"))
      if (uid == null && oldOrder != null && oldOrder.getBeizhu() != null && oldOrder.getBeizhu().contains("补单"))
         uid = oldOrder.getUserInfo().getId();
      if (uid == null)
@@ -1131,7 +1138,7 @@
      // 加入订单
      Order oldOrder = orderMapper.selectOrderByOrderIdAndOrderType(pddOrder.getOrderSn(), Constant.SOURCE_TYPE_PDD);
      if (uid == null && oldOrder.getBeizhu().contains("补单"))
      if (uid == null && oldOrder != null && oldOrder.getBeizhu() != null && oldOrder.getBeizhu().contains("补单"))
         uid = oldOrder.getUserInfo().getId();
      if (uid == null)
@@ -1205,4 +1212,25 @@
         }
      }
   }
   @Override
   public void repairCommonOrderByByTaoBaoOrder(String orderId) {
      //根据订单号查询淘宝订单
      List<TaoBaoOrder>  orderList=   taoBaoOrderService.getTaoBaoOrderByOrderId(orderId);
      if(orderList!=null)
         for(TaoBaoOrder order:orderList)
         {
            //根据交易ID查询常规订单
         CommonOrder commonOrder=   commonOrderService.selectBySourceTypeAndTradeId(Constant.SOURCE_TYPE_TAOBAO, order.getTradeId());
         //修复orderby
         if(commonOrder!=null)
         {CommonOrder update=new CommonOrder(commonOrder.getId());
         update.setOrderBy(order.getOrderBy());
         update.setUpdateTime(new Date());
         commonOrderService.updateByPrimaryKeySelective(update);
         }
         }
   }
}