推客分佣单入库

yanxuan-wx-store-sharer-biz/src/main/java/com/netease/yanxuan/wx/store/sharer/biz/service/impl/CommissionOrderServiceImpl.java

@@ -21,6 +21,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
 import java.util.Date;
+import java.util.List;
 
 
 /**
@@ -68,22 +69,28 @@ public class CommissionOrderServiceImpl implements ICommissionOrderService {
 
     @Override
     public void doCommissionOrderSync(Long startTime, Long endTime) {
+        log.info("[op:doCommissionOrderSync] start update time range [{} ~ {}]", startTime, endTime);
         WeChatCommissionOrderListVO listVO;
         String nextKey = null;
+        List<WeChatCommissionOrderItemVO> dataList;
         while (true) {
             listVO = weChatCommissionOrderListRequest.handle(startTime, endTime, nextKey, COMMISSION_ORDER_SYNC_PAGE_SIZE);
             if (null == listVO || CollectionUtils.isEmpty(listVO.getList())) {
+                log.info("[op:doCommissionOrderSync] listVO is empty");
                 return;
             }
+            dataList = listVO.getList();
+            log.info("[op:doCommissionOrderSync] list size:{}", dataList.size());
+            for (WeChatCommissionOrderItemVO itemVO : dataList) {
+                // 推客分佣单入库
+                doSyncCommissionOrder(itemVO.getOrder_id(), itemVO.getSku_id());
+            }
             Boolean hasMore = listVO.getHas_more();
             nextKey = listVO.getNext_key();
             if(StringUtils.isBlank(nextKey) || (null != hasMore && !hasMore)){
+                log.info("[op:doCommissionOrderSync] is not has more");
                 return;
             }
-            for (WeChatCommissionOrderItemVO itemVO : listVO.getList()) {
-                // 推客分佣单入库
-                doSyncCommissionOrder(itemVO.getOrder_id(), itemVO.getSku_id());
-            }
         }
     }