Sfoglia il codice sorgente

增加记录修改

xueyiming 7 mesi fa
parent
commit
4cd6945904

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

@@ -522,7 +522,6 @@ public class CoreServiceImpl implements CoreService {
                         //插入rootSource
                         rootSourceService.addRootSource(publishMiniprogramBo, planAccount, publishArticleData);
 
-                        //TODO 更新match表
                         JSONObject jsonObject = new JSONObject();
                         jsonObject.put("uid", publishMiniprogramBo.getUid());
                         jsonObject.put("source", publishMiniprogramBo.getSource());
@@ -535,12 +534,12 @@ public class CoreServiceImpl implements CoreService {
                         jsonArray.add(jsonObject);
 
                         PublishMiniprogram publishMiniprogram = new PublishMiniprogram();
-                        BeanUtils.copyProperties(publishMiniprogram, publishMiniprogramBo);
+                        BeanUtils.copyProperties(publishMiniprogramBo, publishMiniprogram);
                         publishMiniprogramMapper.insertSelective(publishMiniprogram);
                         publishMiniprogramList.add(publishMiniprogram);
                     }
                     String traceId = contentService.updateMatchContent(publishArticleData.getSourceId(), planAccount.getGhId(), jsonArray);
-
+                    videoService.miniProgramVideoOff(traceId);
                 }
 
                 List<PublishMiniprogramParam> publishCardList = new ArrayList<>();
@@ -633,6 +632,15 @@ public class CoreServiceImpl implements CoreService {
         }
     }
 
+    public static void main(String[] args) {
+        PublishMiniprogram publishMiniprogram = new PublishMiniprogram();
+        PublishMiniprogramBo publishMiniprogramBo = new PublishMiniprogramBo();
+        publishMiniprogramBo.setAppName("cccc");
+        BeanUtils.copyProperties(publishMiniprogramBo, publishMiniprogram);
+        System.out.println(publishMiniprogram);
+    }
+
+
     @Override
     public void getPushStatus() {
         PublishContentExample example = new PublishContentExample();

+ 2 - 0
long-article-server/src/main/java/com/tzld/piaoquan/longarticle/service/remote/VideoService.java

@@ -5,4 +5,6 @@ import com.tzld.piaoquan.longarticle.model.bo.VideoDetail;
 public interface VideoService {
 
     VideoDetail publish(String ossPath, String uid, String title, String platform, String traceId);
+
+    void miniProgramVideoOff(String traceId);
 }

+ 12 - 6
long-article-server/src/main/java/com/tzld/piaoquan/longarticle/service/remote/impl/VideoServiceImpl.java

@@ -8,6 +8,7 @@ import com.tzld.piaoquan.longarticle.model.bo.VideoDetail;
 import com.tzld.piaoquan.longarticle.service.remote.VideoService;
 import com.tzld.piaoquan.longarticle.utils.HttpClientUtil;
 import com.tzld.piaoquan.longarticle.utils.HttpPoolClientUtil;
+import com.tzld.piaoquan.longarticle.utils.LarkRobotUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
@@ -101,11 +102,16 @@ public class VideoServiceImpl implements VideoService {
     }
 
     @Override
-    public void miniProgramVideoOff(String traceId) throws IOException {
-        String apiUrl = "http://47.99.132.47:8111/get_off_videos";
-        log.info("miniProgramVideoOff,traceId:{}", traceId);
-        com.alibaba.fastjson.JSONObject params = new com.alibaba.fastjson.JSONObject();
-        params.put("traceId", traceId);
-        String post = HTTP_POOL_CLIENT_UTIL_DEFAULT.post(apiUrl, params.toJSONString());
+    public void miniProgramVideoOff(String traceId) {
+        try {
+            String apiUrl = "http://47.99.132.47:8111/get_off_videos";
+            log.info("miniProgramVideoOff,traceId:{}", traceId);
+            com.alibaba.fastjson.JSONObject params = new com.alibaba.fastjson.JSONObject();
+            params.put("traceId", traceId);
+            String post = HTTP_POOL_CLIENT_UTIL_DEFAULT.post(apiUrl, params.toJSONString());
+        } catch (Exception e) {
+            LarkRobotUtil.sendMessage("get_off_videos失败  traceId=" + traceId);
+            log.error("miniProgramVideoOff error {}", e.getMessage());
+        }
     }
 }