调整淘宝订单与维权订单爬取

admin

2019-07-24 c8a99ed8218fe034e9c33236969fcbec9eac75bb

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

@@ -17,29 +17,46 @@


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.dto.pdd.PDDGoodsDetail;

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.goods.CommonGoods;

import com.yeshi.fanli.entity.jd.JDGoods;

import com.yeshi.fanli.entity.jd.JDOrder;

import com.yeshi.fanli.entity.jd.JDOrderItem;

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.order.HongBaoOrder;

import com.yeshi.fanli.entity.pdd.PDDOrder;

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;

import com.yeshi.fanli.service.inter.goods.CommonGoodsService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoV2Service;

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

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

import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService;

import com.yeshi.fanli.service.inter.user.UserSystemCouponService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.MoneyBigDecimalUtil;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.factory.CommonOrderGoodsFactory;

import com.yeshi.fanli.util.factory.goods.CommonOrderFactory;

import com.yeshi.fanli.util.jd.JDApiUtil;

import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;

import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;

import com.yeshi.fanli.vo.msg.ClientTextStyleVO;

import com.yeshi.fanli.vo.order.CommonOrderGoodsVO;

@@ -58,31 +75,41 @@


   @Resource

   private CommonOrderGoodsMapper commonOrderGoodsMapper;

	


   @Resource

   private JumpDetailV2Service jumpDetailV2Service;

	


   @Resource

   private ConfigService configService;

	


   @Resource

   private UserSystemCouponService userSystemCouponService;

	


   @Resource

   private UserSystemCouponRecordService userSystemCouponRecordService;

	


   @Resource

   private SystemCouponService systemCouponService;

	
	
   // 奖励订单图片

   public final static String PIC_REWARD= "http://192.168.1.200/icon/jl.png";

	
   // 免单状态图片

   public final static String PIC_FREE_ON = "http://192.168.1.200/icon/state1.png";

   public final static String PIC_FREE_FAIL =  "http://192.168.1.200/icon/state2.png";

   public final static String PIC_FREE_SUCCEED =  "http://192.168.1.200/icon/state3.png";



   @Resource

   private HongBaoV2Service hongBaoV2Service;



   @Resource

   private CommonOrderTradeIdMapMapper commonOrderTradeIdMapMapper;



   @Resource

   private CommonGoodsService commonGoodsService;



   @Resource

   private HongBaoOrderService hongBaoOrderService;



   // 奖励订单图片

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



   // 免单状态图片

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

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

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



   @Override

   public int insert(CommonOrder record) {

@@ -155,8 +182,7 @@


      return listOrder;

   }

	
	


   @Override

   public Map<String, BigDecimal> countHistoryOrder(Long uid, Integer day) {

      return commonOrderMapper.countHistoryOrder(uid, day);

@@ -187,14 +213,13 @@
   public void listDataFactory(List<CommonOrderVO> listOrder, List<CommonOrderVO> listGoods, Long uid) {



      List<String> listNo = new ArrayList<String>();

      for (CommonOrderVO commonOrderVO:  listOrder) {

      for (CommonOrderVO commonOrderVO : listOrder) {

         listNo.add(commonOrderVO.getOrderNo());

      }

		


      // 已经使用券订单

      List<UserSystemCouponRecord> couponRecordList = userSystemCouponRecordService.getRecordByOrderNoList(listNo);

		
		


      /* 组合商品信息 */

      for (CommonOrderVO commonOrder : listGoods) {



@@ -248,7 +273,7 @@
                  totalSettlement = commonOrder.getTotalPayment();

               }

               // 实付款

               commonGoodsVO.setActualPay("实付款：¥" + totalSettlement);

               commonGoodsVO.setActualPay("付款金额：¥" + totalSettlement);



               listOrderGoods.add(commonGoodsVO);



@@ -269,10 +294,10 @@


      SimpleDateFormat format = new SimpleDateFormat("yyyy.MM.dd HH:mm");

      SimpleDateFormat formatday = new SimpleDateFormat("yyyy.MM.dd");

		


      // 是否存在奖励券

      boolean hasRewardCoupon = userSystemCouponService.hasRewardCoupon(uid);

		


      /* 组织订单状态 等信息 */

      for (CommonOrderVO order : listOrder) {



@@ -364,7 +389,7 @@
            order.setOrderOrigin("2");

            order.setHongBaoTypePic(CommonOrder.TYPE_SHARE);

            signList.add(CommonOrder.TYPE_SHARE);

				


         } else if (HongBaoV2.TYPE_YAOQING == hongBaoType || HongBaoV2.TYPE_YIJI == hongBaoType

               || HongBaoV2.TYPE_ERJI == hongBaoType || HongBaoV2.TYPE_SHARE_YIJI == hongBaoType

               || HongBaoV2.TYPE_SHARE_ERJI == hongBaoType) {

@@ -434,110 +459,119 @@
         hongBaoMap.put("content", hongbaoInfo + " ¥" + hongBao.setScale(2, BigDecimal.ROUND_DOWN).toString());

         hongBaoMap.put("fontColor", hongbaoInfoFontColor);

         order.setHongBaoInfo(hongBaoMap);

			
			
         // 是否免单商品

         boolean freeOrder = false;

         // 是否奖励成功

         boolean rewardSuccess = false;

         // 奖励订单、免单

         if (couponRecordList != null && couponRecordList.size() > 0) {

				
            for (UserSystemCouponRecord couponRecord: couponRecordList) {

               // 订单号匹配

               if (order.getOrderNo().equals(couponRecord.getOrderNo())) {

						
                  String systemCouponType = couponRecord.getCouponType();

                  Integer state = couponRecord.getState();

						
                  // 奖励订单: 且成功

                  if (CouponTypeEnum.rebatePercentCoupon.name().equals(systemCouponType)

                        && UserSystemCouponRecord.STATE_SUCCESS == state) {

                     rewardSuccess = true;

                     signList.add(PIC_REWARD); // 加入奖励成功图片

							
                  } else if (CouponTypeEnum.freeCoupon.name().equals(systemCouponType)

                        || CouponTypeEnum.welfareFreeCoupon.name().equals(systemCouponType)) {

							
                      if (UserSystemCouponRecord.STATE_FREE_ON == state) {

                        // 免单中

                         freeOrder = true;

                         signList.add(PIC_FREE_ON);

                     } else if (UserSystemCouponRecord.STATE_SUCCESS == state) {

                        // 免单成功

                        freeOrder = true;

                        signList.add(PIC_FREE_SUCCEED);

                     } else if (UserSystemCouponRecord.STATE_FAIL_RULE == state || UserSystemCouponRecord.STATE_FAIL_DRAWBACK == state) {

                        // 规则不匹配、退款

                        freeOrder = true;

                        signList.add(PIC_FREE_FAIL);

                     } 


         // 非自购的订单 不显示返利、免单详情

         if (HongBaoV2.TYPE_ZIGOU != hongBaoType) {

            // 订单标识

            order.setSignList(signList);



         } else {



            // 是否免单商品

            boolean freeOrder = false;

            // 是否奖励成功

            boolean rewardSuccess = false;



            // 奖励订单、免单 使用记录

            if (couponRecordList != null && couponRecordList.size() > 0) {



               for (UserSystemCouponRecord couponRecord : couponRecordList) {

                  // 订单号匹配

                  if (order.getOrderNo().equals(couponRecord.getOrderNo())) {



                     String systemCouponType = couponRecord.getCouponType();

                     Integer state = couponRecord.getState();



                     // 奖励订单: 且成功

                     if (CouponTypeEnum.rebatePercentCoupon.name().equals(systemCouponType)

                           && UserSystemCouponRecord.STATE_SUCCESS == state) {

                        rewardSuccess = true;

                        signList.add(PIC_REWARD); // 加入奖励成功图片



                     } else if (CouponTypeEnum.freeCoupon.name().equals(systemCouponType)

                           || CouponTypeEnum.welfareFreeCoupon.name().equals(systemCouponType)) {



                        if (UserSystemCouponRecord.STATE_FREE_ON == state) {

                           // 免单中

                           freeOrder = true;

                           signList.add(PIC_FREE_ON);

                        } else if (UserSystemCouponRecord.STATE_SUCCESS == state) {

                           // 免单成功

                           freeOrder = true;

                           signList.add(PIC_FREE_SUCCEED);

                        } else if (UserSystemCouponRecord.STATE_FAIL_RULE == state

                              || UserSystemCouponRecord.STATE_FAIL_DRAWBACK == state) {

                           // 规则不匹配、退款

                           freeOrder = true;

                           signList.add(PIC_FREE_FAIL);

                        }

                     }



                     break;

                  }

						
                  break;

               }

            }



            // 订单标识

            order.setSignList(signList);



            boolean rewardOrder = false;



            int type = 1; // 1 常规跳转页面 2弹出选项（奖励券）

            if (rewardSuccess) {

               // 奖励成功

               rewardOrder = true;

            } else if (hasRewardCoupon && !freeOrder && HongBaoV2.TYPE_ZIGOU == hongBaoType

                  && HongBaoV2.STATE_YILINGQU == hongBaoState) {

               // 有可用的奖励券 、非免单订单 、且已到账的 、返利订单

               type = 2;

               rewardOrder = true;

            }



            if (rewardOrder) {

               ClientTextStyleVO rewardStyleVO = new ClientTextStyleVO();

               // 奖励券进度详情

               rewardStyleVO.setContent("返利奖励 >");

               rewardStyleVO.setColor("#E5005C");

               rewardStyleVO.setBottomColor("#FFDCEA");



               Map<String, Object> jumpLink = new HashMap<String, Object>();

               jumpLink.put("orderNo", order.getOrderNo());



               Map<String, Object> jump = new HashMap<String, Object>();

               jump.put("type", type);

               jump.put("params", jumpLink);

               jump.put("jumpDetail", jumpDetailV2Service.getByTypeCache("rewardCouponDetail"));



               Map<String, Object> rewardMap = new HashMap<String, Object>();

               rewardMap.put("text", rewardStyleVO);

               rewardMap.put("jump", jump);



               order.setRewardDetail(rewardMap);

            }



            if (freeOrder) {

               ClientTextStyleVO rewardStyleVO = new ClientTextStyleVO();

               // 返利、免单详情

               rewardStyleVO.setContent("免单详情 >");

               rewardStyleVO.setColor("#E5005C");

               rewardStyleVO.setBottomColor("#FFDCEA");



               Map<String, Object> jumpLink = new HashMap<String, Object>();

               jumpLink.put("orderNo", order.getOrderNo());



               Map<String, Object> jump = new HashMap<String, Object>();

               jump.put("type", 1); // 页面跳转

               jump.put("params", jumpLink);

               jump.put("jumpDetail", jumpDetailV2Service.getByTypeCache("freeCouponDetail"));



               Map<String, Object> rewardMap = new HashMap<String, Object>();

               rewardMap.put("text", rewardStyleVO);

               rewardMap.put("jump", jump);



               order.setRewardDetail(rewardMap);

            }

         }

			
         // 订单标识

         order.setSignList(signList);

			
         boolean rewardOrder = false;

			
         int type = 1; // 1 常规跳转页面  2弹出选项（奖励券）

         if (rewardSuccess) {

            // 奖励成功

            rewardOrder = true; 
         } else if(hasRewardCoupon && !freeOrder && HongBaoV2.STATE_YILINGQU == hongBaoState) {

            // 有可用的奖励券 、非免单订单 、且已到账的

            type = 2;

            rewardOrder = true; 
         }

			
         if (rewardOrder) {  
            ClientTextStyleVO rewardStyleVO = new ClientTextStyleVO();

            // 奖励券进度详情

            rewardStyleVO.setContent("返利奖励 >");

            rewardStyleVO.setColor( "#E5005C");

            rewardStyleVO.setBottomColor("#FFDCEA");

				
            Map<String, Object> jumpLink = new HashMap<String,Object>();

            jumpLink.put("orderNo", order.getOrderNo());

				
            Map<String, Object> jump = new HashMap<String,Object>();

            jump.put("type", type); 
             jump.put("params", jumpLink);

             jump.put("jumpDetail", jumpDetailV2Service.getByTypeCache("rewardCouponDetail"));

				
             Map<String, Object> rewardMap = new HashMap<String,Object>();

             rewardMap.put("text", rewardStyleVO);

             rewardMap.put("jump", jump);

	    		
            order.setRewardDetail(rewardMap);

         }

			
         if (freeOrder) {  
            ClientTextStyleVO rewardStyleVO = new ClientTextStyleVO();

            // 返利、免单详情

            rewardStyleVO.setContent("免单详情 >");

            rewardStyleVO.setColor( "#E5005C");

            rewardStyleVO.setBottomColor("#FFDCEA");

				
            Map<String, Object> jumpLink = new HashMap<String,Object>();

            jumpLink.put("orderNo", order.getOrderNo());

				
            Map<String, Object> jump = new HashMap<String,Object>();

            jump.put("type", 1); // 页面跳转

             jump.put("params", jumpLink);

             jump.put("jumpDetail", jumpDetailV2Service.getByTypeCache("freeCouponDetail"));

				
             Map<String, Object> rewardMap = new HashMap<String,Object>();

             rewardMap.put("text", rewardStyleVO);

             rewardMap.put("jump", jump);

	    		
            order.setRewardDetail(rewardMap);

         }

			
      }

   }



@@ -568,64 +602,220 @@
         wholeOrderState = CommonOrder.STATE_WHOLE_ORDER_BUFENYOUXIAO;



      for (TaoBaoOrder taoBaoOrder : taoBaoOrders) {

         CommonOrder commonOrder = commonOrderMapper.selectByOrderNoAndOrderTypeAndOrderBy(taoBaoOrder.getOrderId(),

               Constant.SOURCE_TYPE_TAOBAO, taoBaoOrder.getOrderBy());

         if (commonOrder == null)// 新增

         CommonOrder newCommonOrder = TaoBaoOrderUtil.convert(taoBaoOrder);

         CommonOrderGoods cog = new CommonOrderGoods();

         cog.setGoodsId(taoBaoOrder.getAuctionId() + "");

         cog.setGoodsType(Constant.SOURCE_TYPE_TAOBAO);

         newCommonOrder.setCommonOrderGoods(cog);

         newCommonOrder.setStateWholeOrder(wholeOrderState);

         // 订单商品插入

         List<CommonOrderGoods> commonGoodsList = commonOrderGoodsMapper.listByGoodsIdAndGoodsType(cog.getGoodsId(),

               cog.getGoodsType());

         if (commonGoodsList.size() <= 0)// 不存在就插入商品

         {

            commonOrder = TaoBaoOrderUtil.convert(taoBaoOrder);

            CommonOrderGoods goods = new CommonOrderGoods();

            goods.setGoodsId(taoBaoOrder.getAuctionId() + "");

            goods.setGoodsType(Constant.SOURCE_TYPE_TAOBAO);



            // 商品是否已经插入

            List<CommonOrderGoods> commonGoodsList = commonOrderGoodsMapper

                  .listByGoodsIdAndGoodsType(goods.getGoodsId(), goods.getGoodsType());

            if (commonGoodsList.size() <= 0)// 不存在就插入商品

            {

               TaoBaoGoodsBrief taoBaoGoods = null;

            TaoBaoGoodsBrief taoBaoGoods = null;

            try {

               taoBaoGoods = TaoKeApiUtil.getSimpleGoodsInfo(taoBaoOrder.getAuctionId());

            } catch (TaobaoGoodsDownException e) {

               e.printStackTrace();

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

               try {

                  taoBaoGoods = TaoKeApiUtil.getSimpleGoodsInfo(taoBaoOrder.getAuctionId());

               } catch (TaobaoGoodsDownException e) {

                  e.printStackTrace();

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

               } catch (Exception e1) {

                  CommonGoods commonGoods = commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType(

                        taoBaoOrder.getAuctionId(), Constant.SOURCE_TYPE_TAOBAO);

                  if (commonGoods != null)

                     taoBaoGoods = TaoBaoUtil.convert(commonGoods);

               }

               if (taoBaoGoods != null) {

                  goods = CommonOrderGoodsFactory.create(taoBaoGoods);

               }

               goods.setCreateTime(new Date());

               goods.setUpdateTime(new Date());

               commonOrderGoodsMapper.insertSelective(goods);

            } else

               goods.setId(commonGoodsList.get(commonGoodsList.size() - 1).getId());

            commonOrder.setCommonOrderGoods(goods);

            commonOrder.setUserInfo(new UserInfo(uid));

            commonOrder.setCreateTime(new Date());

            commonOrder.setStateWholeOrder(wholeOrderState);

            commonOrderMapper.insertSelective(commonOrder);



            commonOrderList.add(commonOrder);

            continue;

         } else {// 修改

            // 已经结算或者已经失效的订单不处理

            if (commonOrder.getState() == CommonOrder.STATE_JS || commonOrder.getState() == CommonOrder.STATE_SX) {

               commonOrderList.add(commonOrder);

               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());

            commonOrderMapper.updateByPrimaryKeySelective(updateCommonOrder);

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

            continue;

            if (taoBaoGoods != null) {

               cog = CommonOrderGoodsFactory.create(taoBaoGoods);

            }

            cog.setCreateTime(new Date());

            cog.setUpdateTime(new Date());

            commonOrderGoodsMapper.insertSelective(cog);

         }

         newCommonOrder.setUserInfo(new UserInfo(uid));

         commonOrderList.add(addCommonOrder(newCommonOrder));

      }

      return commonOrderList;

   }



   @Transactional

   @Override

   public List<CommonOrder> addPDDOrder(List<PDDOrder> pddOrderList, Long uid) throws CommonOrderException {

      List<CommonOrder> commonOrderList = new ArrayList<>();

      // 判断所有的订单状态

      int invalidCount = 0;

      for (PDDOrder order : pddOrderList) {

         if (order.getOrderStatus() == -1 || order.getOrderStatus() == 4 || order.getOrderStatus() == 8) {

            invalidCount++;

         }

      }

      // 获取整体订单的状态

      int wholeOrderState = 0;

      if (pddOrderList.size() == invalidCount)

         wholeOrderState = CommonOrder.STATE_WHOLE_ORDER_SHIXIAO;

      else if (invalidCount == 0)

         wholeOrderState = CommonOrder.STATE_WHOLE_ORDER_YOUXIAO;

      else

         wholeOrderState = CommonOrder.STATE_WHOLE_ORDER_BUFENYOUXIAO;



      for (PDDOrder pddOrder : pddOrderList) {

         CommonOrder newCommonOrder = CommonOrderFactory.create(pddOrder);

         CommonOrderGoods cog = new CommonOrderGoods();

         cog.setGoodsId(pddOrder.getGoodsId() + "");

         cog.setGoodsType(Constant.SOURCE_TYPE_PDD);

         newCommonOrder.setCommonOrderGoods(cog);

         newCommonOrder.setStateWholeOrder(wholeOrderState);

         // 订单商品插入

         List<CommonOrderGoods> commonGoodsList = commonOrderGoodsMapper.listByGoodsIdAndGoodsType(cog.getGoodsId(),

               cog.getGoodsType());

         if (commonGoodsList.size() <= 0)// 不存在就插入商品

         {

            PDDGoodsDetail pddGoods = null;

            pddGoods = PinDuoDuoApiUtil.getGoodsDetail(Long.parseLong(cog.getGoodsId()));

            if (pddGoods != null) {

               cog = CommonOrderGoodsFactory.create(pddGoods);

            }

            cog.setCreateTime(new Date());

            cog.setUpdateTime(new Date());

            commonOrderGoodsMapper.insertSelective(cog);

            newCommonOrder.setCommonOrderGoods(cog);

         }

         newCommonOrder.setUserInfo(new UserInfo(uid));

         commonOrderList.add(addCommonOrder(newCommonOrder));

      }

      return commonOrderList;

   }



   @Transactional

   @Override

   public List<CommonOrder> addJDOrder(JDOrder jdOrder, Long uid) throws CommonOrderException {

      List<CommonOrder> commonOrderList = new ArrayList<>();

      // 判断所有的订单状态

      int invalidCount = 0;

      for (JDOrderItem tb : jdOrder.getOrderItemList()) {

         if (tb.getValidCode() < 16) {

            invalidCount++;

         }

      }



      // 获取整体订单的状态

      int wholeOrderState = 0;

      if (jdOrder.getOrderItemList().size() == invalidCount)

         wholeOrderState = CommonOrder.STATE_WHOLE_ORDER_SHIXIAO;

      else if (invalidCount == 0)

         wholeOrderState = CommonOrder.STATE_WHOLE_ORDER_YOUXIAO;

      else

         wholeOrderState = CommonOrder.STATE_WHOLE_ORDER_BUFENYOUXIAO;



      List<JDOrderItem> orderItemList = jdOrder.getOrderItemList();

      jdOrder.setOrderItemList(null);



      for (JDOrderItem itemOrder : orderItemList) {

         itemOrder.setOrder(jdOrder);

         CommonOrder newCommonOrder = CommonOrderFactory.create(itemOrder);

         CommonOrderGoods cog = new CommonOrderGoods();

         cog.setGoodsId(itemOrder.getSkuId() + "");

         cog.setGoodsType(Constant.SOURCE_TYPE_JD);

         newCommonOrder.setCommonOrderGoods(cog);

         newCommonOrder.setStateWholeOrder(wholeOrderState);

         // 订单商品插入

         List<CommonOrderGoods> commonGoodsList = commonOrderGoodsMapper.listByGoodsIdAndGoodsType(cog.getGoodsId(),

               cog.getGoodsType());

         if (commonGoodsList.size() <= 0)// 不存在就插入商品

         {

            JDGoods goods = JDApiUtil.getGoodsDetail(itemOrder.getSkuId());



            if (goods != null) {

               cog = CommonOrderGoodsFactory.create(goods);

            }

            cog.setCreateTime(new Date());

            cog.setUpdateTime(new Date());

            commonOrderGoodsMapper.insertSelective(cog);

         }

         newCommonOrder.setUserInfo(new UserInfo(uid));

         commonOrderList.add(addCommonOrder(newCommonOrder));

      }

      return commonOrderList;

   }



   /**

    * 添加订单

    * 
    * @param commonOrder

    */

   @Transactional

   private CommonOrder addCommonOrder(CommonOrder commonOrder) throws CommonOrderException {

      // 判断商品是否存在

      if (commonOrder == null)

         throw new CommonOrderException(1, "订单为空");

      if (commonOrder.getUserInfo() == null)

         throw new CommonOrderException(2, "订单用户为空");



      if (commonOrder.getCommonOrderGoods() == null || commonOrder.getCommonOrderGoods().getGoodsId() == null

            || commonOrder.getCommonOrderGoods().getGoodsType() == null)

         throw new CommonOrderException(3, "订单商品为空");

      // 不存在就插入，存在就不管

      CommonOrderGoods goods = commonOrder.getCommonOrderGoods();



      // 之前不存在于数据库

      if (commonOrder.getCommonOrderGoods().getId() == null) {

         List<CommonOrderGoods> commonGoodsList = commonOrderGoodsMapper

               .listByGoodsIdAndGoodsType(goods.getGoodsId(), goods.getGoodsType());



         if (commonGoodsList == null || commonGoodsList.size() < 1) {// 不存在

            commonOrderGoodsMapper.insertSelective(goods);

         } else {// 存在

            goods = commonGoodsList.get(0);

         }

         if (goods.getId() == null)

            throw new CommonOrderException(4, "商品插入失败");

         commonOrder.setCommonOrderGoods(goods);

      }



      CommonOrder oldCommonOrder = null;



      if (!StringUtil.isNullOrEmpty(commonOrder.getTradeId()))

         oldCommonOrder = commonOrderMapper.selectBySourceTypeAndTradeId(commonOrder.getSourceType(),

               commonOrder.getTradeId());

      else

         oldCommonOrder = commonOrderMapper.selectByOrderNoAndOrderTypeAndOrderBy(commonOrder.getOrderNo(),

               commonOrder.getSourceType(), commonOrder.getOrderBy());



      if (oldCommonOrder == null)// 新增

      {

         commonOrder.setCreateTime(new Date());

         commonOrderMapper.insertSelective(commonOrder);

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

         commonOrderTradeIdMapMapper.insertSelective(new CommonOrderTradeIdMap(commonOrder.getId(),

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

         return commonOrder;

      } else {// 修改

         // 已经结算，已经失效，状态未改变的订单不处理

         if (oldCommonOrder.getState() == CommonOrder.STATE_JS || oldCommonOrder.getState() == CommonOrder.STATE_SX

               || (oldCommonOrder.getState().intValue() == commonOrder.getState())) {

            return oldCommonOrder;

         }

         // 交易ID一致才修改

         if (commonOrder.getTradeId() != null

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

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

            updateCommonOrder.seteIncome(commonOrder.geteIncome());

            updateCommonOrder.setEstimate(commonOrder.getEstimate());

            updateCommonOrder.setPayment(commonOrder.getPayment());

            updateCommonOrder.setSettlement(commonOrder.getSettlement());

            updateCommonOrder.setSettleTime(commonOrder.getSettleTime());

            updateCommonOrder.setState(commonOrder.getState());

            updateCommonOrder.setStateWholeOrder(commonOrder.getStateWholeOrder());

            updateCommonOrder.setUpdateTime(new Date());

            updateCommonOrder.setTradeId(commonOrder.getTradeId());

            commonOrderMapper.updateByPrimaryKeySelective(updateCommonOrder);

            return commonOrderMapper.selectByPrimaryKey(updateCommonOrder.getId());

         } else

            return oldCommonOrder;

      }

   }



   @Override

@@ -784,6 +974,29 @@
            order.setHongBaoState(3);

         }



         List<HongBaoV2> listhb = hongBaoV2Service.listChildrenById(order.getHongbaoId());

         if (listhb != null && listhb.size() > 0) {

            if (listhb.size() == 1) {

               UserInfo userInfo = listhb.get(0).getUserInfo();

               if (userInfo != null) {

                  order.setLevelOneId(userInfo.getId() + "");

                  order.setLevelOneMoney(listhb.get(0).getMoney() + "");

               }

            } else if (listhb.size() == 2) {

               UserInfo userInfo = listhb.get(0).getUserInfo();

               if (userInfo != null) {

                  order.setLevelOneId(userInfo.getId() + "");

                  order.setLevelOneMoney(listhb.get(0).getMoney() + "");

               }



               UserInfo userInfo2 = listhb.get(1).getUserInfo();

               if (userInfo2 != null) {

                  order.setLevelTwoId(userInfo2.getId() + "");

                  order.setLevelTwoMoney(listhb.get(1).getMoney() + "");

               }

            }

         }



      }



      return list;

@@ -797,7 +1010,7 @@
   }



   @Override

   public CommonOrderVO getInfoByOrderNo(Long uid,String orderNo) throws CommonOrderException{

   public CommonOrderVO getInfoByOrderNo(Long uid, String orderNo) throws CommonOrderException {

      List<CommonOrderVO> list = getOrderByUid(1, uid, null, null, null, orderNo, null, null, null);

      if (list == null || list.size() == 0) {

         return null;

@@ -805,9 +1018,10 @@
         return list.get(0);

      }

   }

	


   @Override

   public CommonOrderVO getCommonOrderByOrderNo(Long uid, String orderNo, Integer orderState) throws CommonOrderException {

   public CommonOrderVO getCommonOrderByOrderNo(Long uid, String orderNo, Integer orderState)

         throws CommonOrderException {



      CommonOrderVO commonOrderVO = commonOrderMapper.getCommonOrderByOrderNo(uid, orderNo, orderState);

      // 订单信息为空

@@ -877,7 +1091,7 @@
               totalSettlement = commonOrder.getTotalPayment();

            }

            // 实付款

            commonGoodsVO.setActualPay("实付款：¥" + totalSettlement);

            commonGoodsVO.setActualPay("付款金额：¥" + totalSettlement);



            listOrderGoods.add(commonGoodsVO);



@@ -897,9 +1111,10 @@


      return commonOrderVO;

   }

	


   @Override

   public List<CommonOrderVO> getCouponHongbaoByOrderNo(Long uid, Integer hongBaoState, String orderNo) throws CommonOrderException {

   public List<CommonOrderVO> getCouponHongbaoByOrderNo(Long uid, Integer hongBaoState, String orderNo)

         throws CommonOrderException {



      List<CommonOrderVO> listOrder = commonOrderMapper.getCouponHongbaoByOrderNo(uid, hongBaoState, orderNo);



@@ -922,38 +1137,84 @@
      return listOrder;

   }



	
   @Override

   public JSONObject getRewardJumpInfo(String orderNo) {

		


      JSONObject map = new JSONObject();

      // 订单标识

      List<String> signList = new ArrayList<String>();

      signList.add(CommonOrder.TYPE_FANLI);

      signList.add(PIC_REWARD); // 加入奖励成功图片

      map.put("signList", signList);

		
		


      ClientTextStyleVO rewardStyleVO = new ClientTextStyleVO();

      // 奖励券进度详情

      rewardStyleVO.setContent("返利奖励 >");

      rewardStyleVO.setColor( "#E5005C");

      rewardStyleVO.setColor("#E5005C");

      rewardStyleVO.setBottomColor("#FFDCEA");

		
      Map<String, Object> jumpLink = new HashMap<String,Object>();



      Map<String, Object> jumpLink = new HashMap<String, Object>();

      jumpLink.put("orderNo", orderNo);

		
      Map<String, Object> jump = new HashMap<String,Object>();

      jump.put("type", 1); 
       jump.put("params", jumpLink);

       jump.put("jumpDetail", jumpDetailV2Service.getByTypeCache("rewardCouponDetail"));

		
       Map<String, Object> rewardMap = new HashMap<String,Object>();

       rewardMap.put("text", rewardStyleVO);

       rewardMap.put("jump", jump);

    	
       map.put("rewardDetail", rewardMap);

    	


      Map<String, Object> jump = new HashMap<String, Object>();

      jump.put("type", 1);

      jump.put("params", jumpLink);

      jump.put("jumpDetail", jumpDetailV2Service.getByTypeCache("rewardCouponDetail"));



      Map<String, Object> rewardMap = new HashMap<String, Object>();

      rewardMap.put("text", rewardStyleVO);

      rewardMap.put("jump", jump);



      map.put("rewardDetail", rewardMap);



      return map;

   }



   @Override

   public CommonOrder selectBySourceTypeAndTradeId(int sourceType, String tradeId) {



      return commonOrderMapper.selectBySourceTypeAndTradeId(sourceType, tradeId);

   }



   @Transactional

   @Override

   public void deleteErrorCommonOrder(Long coId) {

      // 查询是否返利到账

      HongBaoOrder hongBaoOrder = hongBaoOrderService.selectDetailByCommonOrderId(coId);

      if (hongBaoOrder.getHongBaoV2().getState() == HongBaoV2.STATE_YILINGQU)

         return;

      List<HongBaoV2> hongBaoList = hongBaoV2Service.listChildrenById(hongBaoOrder.getHongBaoV2().getId());

      boolean canDelete = true;

      for (HongBaoV2 child : hongBaoList)

         if (child.getState() == HongBaoV2.STATE_YILINGQU) {

            canDelete = false;

            break;

         }

      // 不能删除

      if (!canDelete)

         return;



      // 删除child

      for (HongBaoV2 child : hongBaoList)

         hongBaoV2Service.deleteByPrimaryKey(child.getId());

      // 删除主红包

      hongBaoV2Service.deleteByPrimaryKey(hongBaoOrder.getHongBaoV2().getId());

      // 删除hongbaoOrder

      hongBaoOrderService.deleteByPrimaryKey(hongBaoOrder.getId());

      // 删除CommonOrder

      commonOrderMapper.deleteByPrimaryKey(hongBaoOrder.getCommonOrder().getId());

   }



   @Override

   public List<CommonOrder> listBySourceTypeAndTradeId(int sourceType, String tradeId) {

      return commonOrderMapper.listBySourceTypeAndTradeId(sourceType, tradeId);

   }



   @Override

   public List<CommonOrder> listBySourceTypeAndStateAndThirdCrateTime(int sourceType, Integer state, Long minTime,

         Long maxTime, int page, int pageSize) {

      return commonOrderMapper.listBySourceTypeAndStateAndThirdCrateTime(sourceType, state, minTime, maxTime,

            (page - 1) * pageSize, pageSize);

   }



}