精选库更新改为1个小时更新2000条数据

admin

2019-06-03 a1c01c3b1df1034eecd0e35a0bf75cf0a2bf5d92

 fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java

@@ -17,18 +17,21 @@


import com.yeshi.fanli.dao.mybatis.order.CommonOrderGoodsMapper;

import com.yeshi.fanli.dao.mybatis.order.CommonOrderMapper;

import com.yeshi.fanli.dao.mybatis.order.CommonOrderTradeIdMapMapper;

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

import com.yeshi.fanli.entity.bus.user.HongBaoV2;

import com.yeshi.fanli.entity.bus.user.UserInfo;

import com.yeshi.fanli.entity.bus.user.UserSystemCouponRecord;

import com.yeshi.fanli.entity.order.CommonOrder;

import com.yeshi.fanli.entity.order.CommonOrderGoods;

import com.yeshi.fanli.entity.order.CommonOrderTradeIdMap;

import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum;

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

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

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

import com.yeshi.fanli.exception.order.CommonOrderException;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;

import com.yeshi.fanli.service.inter.config.ConfigService;

import com.yeshi.fanli.service.inter.config.SystemCouponService;

@@ -78,6 +81,9 @@


   @Resource

   private HongBaoV2Service hongBaoV2Service;



   @Resource

   private CommonOrderTradeIdMapMapper commonOrderTradeIdMapMapper;



   // 奖励订单图片

   public final static String PIC_REWARD = "http://img.flqapp.com/resource/order/order_state_reward.png";

@@ -597,6 +603,7 @@
                  taoBaoGoods = TaoKeApiUtil.getSimpleGoodsInfo(taoBaoOrder.getAuctionId());

               } catch (TaobaoGoodsDownException e) {

                  e.printStackTrace();

                  LogHelper.errorDetailInfo(e, "AUCTIONID:"+taoBaoOrder.getAuctionId(), "");

                  taoBaoGoods = TaoBaoUtil.getSimpleGoodsBrief(taoBaoOrder.getAuctionId());

               }

               if (taoBaoGoods != null) {

@@ -613,6 +620,10 @@
            commonOrder.setStateWholeOrder(wholeOrderState);

            commonOrderMapper.insertSelective(commonOrder);



            // 插入映射，保证交易ID的完整性

            commonOrderTradeIdMapMapper.insertSelective(

                  new CommonOrderTradeIdMap(commonOrder.getId(), commonOrder.getTradeId(), new Date(),commonOrder.getSourceType()));



            commonOrderList.add(commonOrder);

            continue;

         } else {// 修改

@@ -622,19 +633,25 @@
               continue;

            }

            CommonOrder newCommonOrder = TaoBaoOrderUtil.convert(taoBaoOrder);

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

            updateCommonOrder.seteIncome(newCommonOrder.geteIncome());

            updateCommonOrder.setEstimate(newCommonOrder.getEstimate());

            updateCommonOrder.setPayment(newCommonOrder.getPayment());

            updateCommonOrder.setSettlement(newCommonOrder.getSettlement());

            updateCommonOrder.setSettleTime(newCommonOrder.getSettleTime());

            updateCommonOrder.setState(newCommonOrder.getState());

            updateCommonOrder.setStateWholeOrder(wholeOrderState);

            updateCommonOrder.setUpdateTime(new Date());

            updateCommonOrder.setTradeId(newCommonOrder.getTradeId());

            commonOrderMapper.updateByPrimaryKeySelective(updateCommonOrder);

            commonOrderList.add(commonOrderMapper.selectByPrimaryKey(updateCommonOrder.getId()));

            continue;



            // 交易ID一致才修改

            if (commonOrder.getTradeId() != null

                  && commonOrder.getTradeId().equalsIgnoreCase(newCommonOrder.getTradeId())) {



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

               updateCommonOrder.seteIncome(newCommonOrder.geteIncome());

               updateCommonOrder.setEstimate(newCommonOrder.getEstimate());

               updateCommonOrder.setPayment(newCommonOrder.getPayment());

               updateCommonOrder.setSettlement(newCommonOrder.getSettlement());

               updateCommonOrder.setSettleTime(newCommonOrder.getSettleTime());

               updateCommonOrder.setState(newCommonOrder.getState());

               updateCommonOrder.setStateWholeOrder(wholeOrderState);

               updateCommonOrder.setUpdateTime(new Date());

               updateCommonOrder.setTradeId(newCommonOrder.getTradeId());

               commonOrderMapper.updateByPrimaryKeySelective(updateCommonOrder);

               commonOrderList.add(commonOrderMapper.selectByPrimaryKey(updateCommonOrder.getId()));

            } else

               commonOrderList.add(commonOrder);

         }

      }

      return commonOrderList;