Procházet zdrojové kódy

常读订单拉取弥补push接口缺失部分

huangpingkang před 1 rokem
rodič
revize
764e51e178

+ 3 - 3
job-bytedance/src/main/java/cn/com/ctop/job/bytedance/data/service/impl/ChannelServiceImpl.java

@@ -118,7 +118,7 @@ public class ChannelServiceImpl implements IChannelService {
                 int offset = 0;
                 boolean hasMore = true;
                 while (hasMore) {
-                    log.error("常读订单拉取 [{}] {}~{} {}", distributorId, thisStartTime, thisEndTime, offset);
+                    log.info("常读订单拉取 [{}] {}~{} {}", distributorId, thisStartTime, thisEndTime, offset);
                     String url = "https://www.changdunovel.com/novelsale/openapi/user/recharge/v1";
                     String ts = String.valueOf(System.currentTimeMillis()).substring(0, 10);
                     String sign = getSign(distributorId, secretKey, ts);
@@ -196,7 +196,7 @@ public class ChannelServiceImpl implements IChannelService {
                                     order.setMovieName(channelMapper.getMovieName(order.getMovieId()));
                                     order.setDyingMovieId(dyingMovieId);
                                     order.setDyingMovieName(dyingMovieName);
-
+                                    log.info("常读order:[{}]",order);
                                     adds.add(order);
                                 }
                             }
@@ -221,7 +221,7 @@ public class ChannelServiceImpl implements IChannelService {
                     promoterReportMapper.deleteInfoByErrorId(errId);
                 }
                 if (isSend != null && isSend == 1) {
-                    AlertUtils.sendMessage(Long.parseLong(distributorId), startDt, endDt, 2, "daily", 1, "changdu_order");
+                    AlertUtils.sendMessage(Long.parseLong(distributorId), thisStartTime, thisEndTime, 2, "daily", 1, "changdu_order");
                 }
             }
             log.info("[{}]番茄订单请求完成{}~{}.", distributorId, startDt, endDt);