新增 藏品分享发送消息接口

ch-wx-api/src/main/java/com/wwdz/ch/wx/entity/request/ItemRequestDto.java

@@ -9,6 +9,8 @@ import java.util.List;
 public class ItemRequestDto implements Entity {
     // 藏品id
     private Long id;
+    // 藏品id
+    private Long itemId;
     // 用户id
     private Long userId;
     // 收藏册id

ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/ItemServiceImpl.java

@@ -809,6 +809,7 @@ public class ItemServiceImpl implements ItemService {
 
             Map<String, Object> map = new HashMap<>();
             map.put("link", link);
+            logger.info("【请求结束】获取小程序链接成功");
             return Result.success(map);
         } catch (Exception e) {
             logger.error("获取小程序链接失败", e);
@@ -858,6 +859,22 @@ public class ItemServiceImpl implements ItemService {
         }
     }
 
+    @Override
+    public Result shareSendMessage(ItemRequestDto dto, HttpServletRequest request) {
+        try {
+            // 发送消息
+            Long userId = userTokenManager.getUserId(request.getHeader("Authorization"));
+            if (Objects.nonNull(userId)) {
+                sendMessage(dto.getItemId(), userId, MessageEnum.TypeEnum.SHARE.getCode());
+            }
+            logger.info("【请求结束】分享发送消息成功");
+            return Result.success();
+        } catch (Exception e) {
+            logger.error("分享发送消息失败", e);
+            return Result.failed("分享发送消息失败");
+        }
+    }
+
     private String getVideosImage(String vedios) {
         String video = "";
         String[] images = vedios.split(";");

ch-wx-api/src/main/java/com/wwdz/ch/wx/service/ItemService.java

@@ -121,4 +121,13 @@ public interface ItemService {
      * @return
      */
     Result uploadVideo(MultipartFile file);
+
+    /**
+     * 分享藏品发送消息
+     *
+     * @param dto
+     * @param request
+     * @return
+     */
+    Result shareSendMessage(ItemRequestDto dto, HttpServletRequest request);
 }

ch-wx-api/src/main/java/com/wwdz/ch/wx/web/WxItemController.java

@@ -203,6 +203,16 @@ public class WxItemController {
         return itemService.getLink(dto.getPageUrl(), dto.getLoginType(), request);
     }
 
+    @ApiOperation(value = "分享发送消息")
+    @PostMapping("/shareSendMessage")
+    public Result shareSendMessage(@RequestBody ItemRequestDto dto, HttpServletRequest request) {
+        logger.info("【请求开始】分享发送消息,请求参数:{}", JSON.toJSONString(dto));
+        if (Objects.isNull(dto.getItemId())) {
+            return Result.failed("请选择被分享的藏品");
+        }
+        return itemService.shareSendMessage(dto, request);
+    }
+
     @ApiOperation("图片上传")
     @PostMapping(value ="/uploadImage")
     public Result uploadImage(@RequestParam("image") MultipartFile file) {