Преглед на файлове

公众号计划状态切换

wangyunpeng преди 2 месеца
родител
ревизия
c0918ad9ba

+ 2 - 2
api-module/src/main/java/com/tzld/piaoquan/api/component/AigcApiService.java

@@ -181,11 +181,11 @@ public class AigcApiService {
         return params;
     }
 
-    public void closePublishPlan(String externalId) {
+    public void changePublishPlanStatus(String externalId, Integer status) {
         String url = aigcApiHost + "/publish/plan/updatePlanStatus";
         JSONObject params = new JSONObject();
         params.put("id", externalId);
-        params.put("status", 0);
+        params.put("status", status);
         try {
             String post = httpPoolClient.post(url, getAigcPostParam(params));
             JSONObject res = JSONObject.parseObject(post);

+ 14 - 1
api-module/src/main/java/com/tzld/piaoquan/api/service/contentplatform/impl/ContentPlatformPlanServiceImpl.java

@@ -162,7 +162,7 @@ public class ContentPlatformPlanServiceImpl implements ContentPlatformPlanServic
         gzhPlanMapper.updateByPrimaryKeySelective(plan);
         if (PublishStageEnum.PLATFORM.getVal() == plan.getPublishStage()) {
             // 调用aigc删除发布计划
-            aigcApiService.closePublishPlan(plan.getExternalId());
+            aigcApiService.changePublishPlanStatus(plan.getExternalId(), 0);
         }
     }
 
@@ -209,6 +209,19 @@ public class ContentPlatformPlanServiceImpl implements ContentPlatformPlanServic
             gzhPlan.setCreateTimestamp(now);
             planMapperExt.insertGzhPlanReturnId(gzhPlan);
         } else {
+            ContentPlatformGzhPlan oldPlan = gzhPlanMapper.selectByPrimaryKey(param.getId());
+            if (PublishStageEnum.USER.getVal() == param.getPublishStage()) {
+                if (StringUtils.hasText(oldPlan.getExternalId())) {
+                    aigcApiService.changePublishPlanStatus(account.getExternalId(), 0);
+                }
+            } else {
+                if (StringUtils.hasText(oldPlan.getExternalId())) {
+                    aigcApiService.changePublishPlanStatus(account.getExternalId(), 1);
+                } else {
+                    String externalId = aigcApiService.createPublishPlan(account.getExternalId(), account.getName());
+                    gzhPlan.setExternalId(externalId);
+                }
+            }
             gzhPlan.setId(param.getId());
             gzhPlanMapper.updateByPrimaryKeySelective(gzhPlan);
         }