Просмотр исходного кода

分组群发 fwhGhIdList 配置修改

wangyunpeng 17 часов назад
Родитель
Сommit
1be189b836

+ 6 - 3
long-article-server/src/main/java/com/tzld/piaoquan/longarticle/service/local/impl/CoreServiceImpl.java

@@ -702,7 +702,8 @@ public class CoreServiceImpl implements CoreService {
             if (sendCount >= 1) {
             if (sendCount >= 1) {
                 return false;
                 return false;
             }
             }
-            if ((fwhGhIdList != null && fwhGhIdList.contains(planAccount.getGhId()))
+            if ((fwhGhIdList != null && fwhGhIdList.contains(planAccount.getGhId())
+                    && Objects.equals(planAccount.getPushType(), PublishGzhPushTypeEnum.auto_group_publish.getVal()))
                     || (Objects.equals(planAccount.getPushType(), PublishGzhPushTypeEnum.batch_group_publish.getVal()))) {
                     || (Objects.equals(planAccount.getPushType(), PublishGzhPushTypeEnum.batch_group_publish.getVal()))) {
                 // 服务号分组求发每天最多尝试10次
                 // 服务号分组求发每天最多尝试10次
                 if (planAccount.getRetryCount() >= 10) {
                 if (planAccount.getRetryCount() >= 10) {
@@ -846,7 +847,8 @@ public class CoreServiceImpl implements CoreService {
         }
         }
 
 
         if (Objects.equals(planAccount.getPushType(), PublishGzhPushTypeEnum.batch_group_publish.getVal())
         if (Objects.equals(planAccount.getPushType(), PublishGzhPushTypeEnum.batch_group_publish.getVal())
-                || (fwhGhIdList != null && fwhGhIdList.contains(planAccount.getGhId()))) {
+                || (fwhGhIdList != null && fwhGhIdList.contains(planAccount.getGhId())
+                && Objects.equals(planAccount.getPushType(), PublishGzhPushTypeEnum.auto_group_publish.getVal()))) {
             pushBatchGroupPushTask(planAccount, pushContentList, sendIds);
             pushBatchGroupPushTask(planAccount, pushContentList, sendIds);
         } else {
         } else {
             CreatePushTaskParam gzhPushParam = getCreatePushTaskParam(planAccount, pushContentList);
             CreatePushTaskParam gzhPushParam = getCreatePushTaskParam(planAccount, pushContentList);
@@ -1478,7 +1480,8 @@ public class CoreServiceImpl implements CoreService {
                     planAccountService.updateStatus(2, planAccountId);
                     planAccountService.updateStatus(2, planAccountId);
                 }
                 }
                 if (Objects.equals(planAccount.getPushType(), PublishGzhPushTypeEnum.batch_group_publish.getVal())
                 if (Objects.equals(planAccount.getPushType(), PublishGzhPushTypeEnum.batch_group_publish.getVal())
-                        || (fwhGhIdList != null && fwhGhIdList.contains(planAccount.getGhId()))) {
+                        || (fwhGhIdList != null && fwhGhIdList.contains(planAccount.getGhId())
+                        && Objects.equals(planAccount.getPushType(), PublishGzhPushTypeEnum.auto_group_publish.getVal()))) {
                     GroupSendResultExample groupSendResultExample = new GroupSendResultExample();
                     GroupSendResultExample groupSendResultExample = new GroupSendResultExample();
                     groupSendResultExample.createCriteria().andPushIdEqualTo(pushId);
                     groupSendResultExample.createCriteria().andPushIdEqualTo(pushId);
                     List<GroupSendResult> groupSendResults = groupSendResultMapper.selectByExample(groupSendResultExample);
                     List<GroupSendResult> groupSendResults = groupSendResultMapper.selectByExample(groupSendResultExample);