From a7b23f21b4eaf649d29f163daccfe0d8bbabeada Mon Sep 17 00:00:00 2001
From: lidongdong <1459917685@qq.com>
Date: 星期五, 08 十一月 2024 16:48:14 +0800
Subject: [PATCH] 花城 修改运营后台花城咨询新曾报错

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/CommunityApi.java |   37 ++++++++++++++++++++++++++++++++++++-
 1 files changed, 36 insertions(+), 1 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/CommunityApi.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/CommunityApi.java
index 8dff5cd..fa4f27b 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/CommunityApi.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/CommunityApi.java
@@ -748,7 +748,42 @@
 //            }
 
         }
-        return R.fail();
+        else
+        {
+            ComActDynDO comActDynDO = new ComActDynDO();
+            BeanUtils.copyProperties(comActDynVO, comActDynDO);
+
+            comActDynDO.setCommunityId(comActDynVO.getCommunityId());
+            boolean save = comActDynService.save(comActDynDO);
+            if (save) {
+                if(comActDynVO.getCategory()!=null&&comActDynVO.getCategory()==4){
+                    comActDynVO.setId(comActDynVO.getId());
+                    comActDynVO.setCommunityId(comActDynVO.getCommunityId());
+                    rabbitTemplate.convertAndSend("huacheng.acid.message.exchange", "huacheng.acid.message.key", comActDynVO);
+                }
+                // 最多只能设置三条置顶状态,后边设置会取消先前设置的置顶
+                Integer isTopping = comActDynVO.getIsTopping();
+                boolean b = isTopping.intValue() == 1;
+                if (b) {
+                    List<ComActDynDO> list = comActDynService.list(new QueryWrapper<ComActDynDO>().lambda()
+                            .eq(ComActDynDO::getIsTopping, 1).eq(ComActDynDO::getCommunityId, comActDynVO.getCommunityId()));
+                    if (!ObjectUtils.isEmpty(list)) {
+                        int size = list.size();
+                        if (size == 4) {
+                            List<ComActDynDO> collect = list.stream().sorted(Comparator.comparing(ComActDynDO::getCreateAt))
+                                    .collect(toList());
+                            ComActDynDO comActDynDO1 = collect.get(0);
+                            comActDynDO1.setIsTopping(0);
+                            boolean update = comActDynService.updateById(comActDynDO1);
+                            if (!update) {
+                                return R.fail("修改置顶状态失败");
+                            }
+                        }
+                    }
+                }
+            }
+            return R.ok();
+        }
     }
 
     /**

--
Gitblit v1.7.1