feign fix

community-api/src/main/java/com/tanpu/community/api/beans/qo/ThemeQo.java

@@ -4,7 +4,7 @@ import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
 import java.time.LocalDateTime;
-import java.util.List;
+import java.util.Map;
 
 @Data
 public class ThemeQo {
@@ -57,7 +57,7 @@ public class ThemeQo {
     private Long likeAmount;
 
     @ApiModelProperty("附件")
-    private List<Object> attachment;
+    private Map<String,Object> attachment;
 
     private Object attachmentInfo;
 

community-service/src/main/java/com/tanpu/community/feign/tanpuroom/FeignClientForTanpuroom.java

@@ -14,7 +14,7 @@ import org.springframework.web.bind.annotation.RequestParam;
 import java.util.List;
 
 //@FeignClient(value = "service-tanpuroom", contextId = "tanpuroom", fallbackFactory = FeignBackClientForTanpuroom.class, path = "/tanpuroom")
-@FeignClient(value = "service-tanpuroom", contextId = "tanpuroom", fallbackFactory = FeignBackClientForTanpuroom.class, path = "http://127.0.0.1:8194/tanpuroom")
+@FeignClient(value = "service-tanpuroom", contextId = "tanpuroom", fallbackFactory = FeignBackClientForTanpuroom.class, url = "http://127.0.0.1:8086/tanpuroom")
 public interface FeignClientForTanpuroom {
 
 

community-service/src/main/java/com/tanpu/community/feign/zhibo/FeignClientForZhibo.java

@@ -12,8 +12,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 
 import java.util.List;
 
-@FeignClient(value = "service-zhibo", fallbackFactory = FeignbackForZhibo.class, path = "/zhibo")
-//@FeignClient(value = "service-zhibo", fallbackFactory = FeignbackForZhibo.class, url = "http://127.0.0.1:8183/zhibo")
+//@FeignClient(value = "service-zhibo", fallbackFactory = FeignbackForZhibo.class, path = "/zhibo")
+@FeignClient(value = "service-zhibo", fallbackFactory = FeignbackForZhibo.class, url = "http://127.0.0.1:8183/zhibo")
 public interface FeignClientForZhibo {
 
     @ApiOperation(value = "根据直播间id查询直播间信息")

community-service/src/main/java/com/tanpu/community/manager/ThemeManager.java

 package com.tanpu.community.manager;
 
 import com.tanpu.common.api.CommonResp;
+import com.tanpu.common.exception.BizException;
 import com.tanpu.community.api.beans.ForwardThemeReq;
 import com.tanpu.community.api.beans.qo.MainTextQo;
 import com.tanpu.community.api.beans.qo.ThemeQo;
@@ -11,11 +12,12 @@ import com.tanpu.community.api.enums.CollectionTypeEnum;
 import com.tanpu.community.api.enums.CommentTypeEnum;
 import com.tanpu.community.api.enums.ThemeTypeEnum;
 import com.tanpu.community.dao.entity.community.*;
+import com.tanpu.community.feign.course.FeignClientForCourse;
+import com.tanpu.community.feign.course.vo.CourseDetailExt;
 import com.tanpu.community.feign.product.FeignClientForProducts;
 import com.tanpu.community.feign.tanpuroom.FeignClientForTanpuroom;
-import com.tanpu.community.feign.tanpuroom.vo.CurriCulumInfoDetailDto;
-import com.tanpu.community.feign.tanpuroom.vo.CurriculumDetailVo;
-import com.tanpu.community.feign.vo.*;
+import com.tanpu.community.feign.vo.ProductInfoVO;
+import com.tanpu.community.feign.vo.ShortVideoBaseInfoResp;
 import com.tanpu.community.feign.zhibo.FeignClientForZhibo;
 import com.tanpu.community.feign.zhibo.vo.ZhiboDetailVO;
 import com.tanpu.community.service.*;
@@ -29,11 +31,7 @@ import javax.annotation.Resource;
 import java.time.Duration;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
-import java.util.Arrays;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Set;
-import java.util.stream.Collectors;
+import java.util.*;
 
 @Service
 public class ThemeManager {
@@ -82,6 +80,9 @@ public class ThemeManager {
     @Resource
     private FeignClientForProducts feignClientForProducts;
 
+    @Autowired
+    private FeignClientForCourse feignClientForCourse;
+
     public void publishTheme(CreateThemeReq req, String userId) {
         ThemeEntity themeEntity = new ThemeEntity();
         BeanUtils.copyProperties(req, themeEntity);
@@ -113,7 +114,7 @@ public class ThemeManager {
 
     //计算迄今时间
     private String calUpToNowTime(LocalDateTime start) {
-        Duration between = Duration.between(LocalDateTime.now(), start);
+        Duration between = Duration.between(start, LocalDateTime.now());
         long duration = between.toMinutes();
         if (duration < 1) {
             return "刚刚";
@@ -211,13 +212,14 @@ public class ThemeManager {
         for (ThemeQo themeQO : themeQos) {
             //附件列表
             List<ThemeAttachmentEntity> attachments = themeAttachmentService.selectByThemeId(themeQO.getId());
-            if (CollectionUtils.isEmpty(attachments)) {
-                continue;
+            if (!CollectionUtils.isEmpty(attachments)) {
+                HashMap<String,Object> attachmentQos= new HashMap<>();
+                attachments.forEach(o->attachmentQos.put(o.getAttchId(),transferAttachment(o,userId)));
+                themeQO.setAttachment(attachmentQos);
             }
-            List<Object> obs = attachments.stream().map(themeAttachmentEntity -> transferAttachment(themeAttachmentEntity, userId)).collect(Collectors.toList());
-            themeQO.setAttachment(obs);
-            //是否关注作者
+            //迄今时间
             themeQO.setUpToNowTime(calUpToNowTime(themeQO.getCreateTime()));
+            //是否关注作者
             String authorId = themeQO.getAuthorId();
             Set<String> fansSet = new HashSet<>(fansRelService.queryFansByFollowerId(userId));
             themeQO.setFollow(fansSet.contains(authorId));
@@ -225,6 +227,8 @@ public class ThemeManager {
             HomePageEntity userEntity = homePageService.selectByUserId(userId);
             themeQO.setUserImg(userEntity.getHeadImg());
             themeQO.setNickName(userEntity.getNickName());
+
+
         }
         return themeQos;
     }
@@ -245,16 +249,25 @@ public class ThemeManager {
                 return zhiboDetailVOCommonResp.getData();
 //                return zhiboService.selectByid(themeAttachment.getAttchId());
             case 3:
-                String[] attachmentIds= new String[]{attachmentId};
+                String[] attachmentIds = new String[]{attachmentId};
                 CommonResp<List<ShortVideoBaseInfoResp>> shortVideoBaseInfo =
                         feignClientForTanpuroom.getShortVideoBaseInfo(Arrays.asList(attachmentIds));
                 return shortVideoBaseInfo.getData().get(0);
 //                CurriculumResEntity curriculumResEntity = curriculumResService.selectShortVideo(themeAttachment.getAttchId());
 //                return curriculumResEntity;
             case 4:
-                CurriCulumInfoDetailDto curriCulumInfoDetailDto = CurriCulumInfoDetailDto.builder().curriculumId(attachmentId).userId(userId).build();
-                CommonResp<CurriculumDetailVo> curriculumDetailVoCommonResp = feignClientForTanpuroom.queryCurriculumDetail(curriCulumInfoDetailDto);
-                return curriculumDetailVoCommonResp.getData();
+                String[] split = attachmentId.split(",");
+                if (split.length != 2) {
+                    throw new BizException("课程id格式错误：" + attachmentId);
+                }
+                String courseId = split[0];
+                String packageId = split[1];
+                CommonResp<CourseDetailExt> courseIdDetailInfo = feignClientForCourse.getCourseIdDetailInfo(courseId, packageId);
+                return courseIdDetailInfo.getData();
+
+//                CurriCulumInfoDetailDto curriCulumInfoDetailDto = CurriCulumInfoDetailDto.builder().curriculumId(attachmentId).userId(userId).build();
+//                CommonResp<CurriculumDetailVo> curriculumDetailVoCommonResp = feignClientForTanpuroom.queryCurriculumDetail(curriCulumInfoDetailDto);
+//                return curriculumDetailVoCommonResp.getData();
 //                curriculumResEntity = curriculumResService.selectById(themeAttachment.getAttchId());
 //
 //                OrderFlowEntity orderFlowEntity = orderFlowService.queryByUserAndProId(themeAttachment.getThemeId(), userId);

pom.xml

@@ -18,6 +18,7 @@
         <spring.boot.version>2.3.11.RELEASE</spring.boot.version>
         <spring-cloud.version>Hoxton.SR11</spring-cloud.version>
         <project.version>1.0.0-SNAPSHOT</project.version>
+        <springfox-version>2.9.2</springfox-version>
     </properties>
 
     <modules>