增加报警 和目标账号刷新

offline-module/src/main/java/com/tzld/piaoquan/offline/job/AutoReplyVideoDataJob.java

@@ -148,22 +148,23 @@ public class AutoReplyVideoDataJob {
             List<String> manualGhIds = new ArrayList<>();
             for (CgiReplyBucketData cgiReplyBucketData : cgiReplyBucketDataList) {
                 String ghId = cgiReplyBucketData.getGhId();
-                if (Objects.equals(cgiReplyBucketData.getStrategy(), "manual")) {
-                    GhDetailExample ghDetailExample = new GhDetailExample();
-                    ghDetailExample.createCriteria().andGhIdEqualTo(ghId).andTypeEqualTo(GhTypeEnum.THIRD_PARTY_GH.type);
-                    List<GhDetail> ghDetails = ghDetailMapper.selectByExample(ghDetailExample);
-                    if (!CollectionUtils.isEmpty(ghDetails)) {
-                        for (GhDetail ghDetail : ghDetails) {
-                            ghDetail.setStrategyStatus(StrategyStatusEnum.STRATEGY.status);
-                            ghDetailMapper.updateByPrimaryKeySelective(ghDetail);
-                        }
-                    }
-                    manualGhIds.add(cgiReplyBucketData.getGhId());
-                }
+//                if (Objects.equals(cgiReplyBucketData.getStrategy(), "manual")) {
+//                    GhDetailExample ghDetailExample = new GhDetailExample();
+//                    ghDetailExample.createCriteria().andGhIdEqualTo(ghId).andTypeEqualTo(GhTypeEnum.THIRD_PARTY_GH.type);
+//                    List<GhDetail> ghDetails = ghDetailMapper.selectByExample(ghDetailExample);
+//                    if (!CollectionUtils.isEmpty(ghDetails)) {
+//                        for (GhDetail ghDetail : ghDetails) {
+//                            ghDetail.setStrategyStatus(StrategyStatusEnum.STRATEGY.status);
+//                            ghDetailMapper.updateByPrimaryKeySelective(ghDetail);
+//                        }
+//                    }
+//                    manualGhIds.add(cgiReplyBucketData.getGhId());
+//                }
                 ghIds.add(cgiReplyBucketData.getGhId());
                 if (auditGhIds.contains(ghId)) {
                     String url = REFRESH_GZH_URL + "?ghId=" + cgiReplyBucketData.getGhId();
                     String res = httpPoolClient.get(url);
+                    log.info("refresh ghId={}, res={}", cgiReplyBucketData.getGhId(), res);
                 }
             }
             String msg = String.format("审核不通过的视频id：%s \n 配置了该视频的ghId列表：%s \n 保底视频更新为策略视频的ghId列表：%s",