lin
2024-03-25 9f8f9d13c42ca8cdccbf351069082a5fdccef2e4
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
package org.springblade.modules.article.service.impl;
 
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springblade.common.cache.SysCache;
import org.springblade.common.utils.RoleUtil;
import org.springblade.common.utils.SpringUtils;
import org.springblade.core.secure.utils.AuthUtil;
import org.springblade.core.tool.utils.SpringUtil;
import org.springblade.modules.article.entity.Article;
import org.springblade.modules.article.entity.ArticleIntegralEntity;
import org.springblade.modules.article.mapper.ArticleMapper;
import org.springblade.modules.article.service.ArticleService;
import org.springblade.modules.article.service.IArticleIntegralService;
import org.springblade.modules.article.vo.ArticleVO;
import org.springblade.modules.district.entity.DistrictEntity;
import org.springblade.modules.district.service.IDistrictService;
import org.springblade.modules.property.entity.PropertyCompanyDistrictEntity;
import org.springblade.modules.property.entity.PropertyCompanyEntity;
import org.springblade.modules.property.service.IPropertyCompanyDistrictService;
import org.springblade.modules.property.service.IPropertyCompanyService;
import org.springblade.modules.property.service.IPropertyDistrictUserService;
import org.springframework.stereotype.Service;
 
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
 
/**
 * @author zhongrj
 * @title 资讯服务实现层
 */
@Service
 
public class ArticleServiceImpl extends ServiceImpl<ArticleMapper, Article> implements ArticleService {
 
 
    /**
     * 查询资讯分页信息
     *
     * @param page
     * @param article 资讯对象
     * @return
     */
    @Override
    public IPage<Article> selectArticlePage(IPage<Article> page, ArticleVO article) {
        String userRole = AuthUtil.getUserRole();
        // 物业身份,只查询该物业公司下的公告
        // if (userRole.contains("wygly") || userRole.contains("wyxmjl")) {
        //     // 物业公司 有哪些小区
        //     IPropertyCompanyDistrictService bean = SpringUtils.getBean(IPropertyCompanyDistrictService.class);
        //     List<PropertyCompanyDistrictEntity> list = bean.list(Wrappers.<PropertyCompanyDistrictEntity>lambdaQuery()
        //         .eq(PropertyCompanyDistrictEntity::getUserId, AuthUtil.getUserId()));
        //     List<String> collect = list.stream().map(PropertyCompanyDistrictEntity::getDistrictId).collect(Collectors.toList());
        //     article.setDistrictIdList(collect);
        // }
        if (RoleUtil.isProperty(userRole)) {
            // 查询小区id
            IPropertyDistrictUserService propertyDistrictUserService = SpringUtils.getBean(IPropertyDistrictUserService.class);
            List<String> districtIds = propertyDistrictUserService.selectPropertyDistrictByUserId(AuthUtil.getUserId());
            // 通过用户机构查询用户的物业公司
            IPropertyCompanyService bean = SpringUtil.getBean(IPropertyCompanyService.class);
            PropertyCompanyEntity companyEntity = bean.getOne(Wrappers.<PropertyCompanyEntity>lambdaQuery()
                .eq(PropertyCompanyEntity::getDeptId, AuthUtil.getDeptId()).last("limit 1"));
            if (companyEntity != null) {
                IPropertyCompanyDistrictService bean2 = SpringUtils.getBean(IPropertyCompanyDistrictService.class);
                // 通过物业公司,查询小区
                List<PropertyCompanyDistrictEntity> propertyCompanyDistrictEntityList = bean2.list(Wrappers.<PropertyCompanyDistrictEntity>lambdaQuery()
                    .eq(PropertyCompanyDistrictEntity::getPropertyCompanyId, companyEntity.getId()));
                if (propertyCompanyDistrictEntityList.size() > 0) {
                    List<String> collect = propertyCompanyDistrictEntityList.stream().map(i -> i.getDistrictId()).collect(Collectors.toList());
                    districtIds.addAll(collect);
                }
            }
            article.setDistrictIdList(districtIds);
            if (districtIds.size() == 0) {
                return page.setRecords(new ArrayList<>());
            }
            article.setPropertyFlag(1);
        }
        if (userRole.contains("jdgly")) {
            IDistrictService districtService = SpringUtils.getBean(IDistrictService.class);
            List<String> regionChildCodesList = SysCache.getRegionChildCodesByDeptId(AuthUtil.getDeptId());
            List<DistrictEntity> list = districtService.list(Wrappers.<DistrictEntity>lambdaQuery().in(DistrictEntity::getCommunityCode, regionChildCodesList));
            if (list.size() > 0) {
                article.setDistrictIdList(list.stream().map(item -> item.getId()).collect(Collectors.toList()));
            }
        }
        return page.setRecords(baseMapper.selectArticlePage(page, article));
    }
 
    /**
     * 查询资讯分页信息
     *
     * @param page
     * @param article 资讯对象
     * @return
     */
    @Override
    public IPage<ArticleVO> selectArticlePageByApp(IPage<ArticleVO> page, ArticleVO article) {
        // 查询用户小区的id
        String districId = baseMapper.getDistrictId(article.getHouseCode());
        article.setDistrictId(districId);
        article.setUserId(AuthUtil.getUserId());
        List<ArticleVO> articleVOS = baseMapper.selectArticlePageByApp(page, article);
        return page.setRecords(articleVOS);
    }
 
    @Override
    public IPage<Article> selectArticleG(IPage<Article> page, ArticleVO article) {
        return page.setRecords(baseMapper.selectArticleG(page, article));
    }
 
    /**
     * 查询资讯分页信息(角色权限)
     *
     * @param page
     * @param article 资讯对象
     * @return
     */
    @Override
    public IPage<Article> pageDate(IPage<Article> page, ArticleVO article) {
        return page.setRecords(baseMapper.pageDate(page, article));
    }
 
    /**
     * 查询资讯分页信息(敏感词预警)
     *
     * @param page
     * @param article 资讯对象
     * @return
     */
    @Override
    public IPage<Article> pageWords(IPage<Article> page, ArticleVO article) {
        return page.setRecords(baseMapper.pageWords(page, article));
    }
 
    @Override
    public IPage<Article> pageCollectList(IPage<Article> page, ArticleVO article) {
        return page.setRecords(baseMapper.pageCollectList(page, article));
    }
 
    /**
     * 查询资讯分页信息(角色权限)附带评论点赞数
     *
     * @param page
     * @param article 资讯对象
     * @return
     */
    @Override
    public IPage<Article> pageLikes(IPage<Article> page, ArticleVO article) {
        return page.setRecords(baseMapper.pageLikes(page, article));
    }
 
    @Override
    public IPage<Article> pageCollect(IPage<Article> page, ArticleVO article) {
        return page.setRecords(baseMapper.pageCollect(page, article));
    }
 
    /**
     * 批量更新
     *
     * @return
     */
    @Override
    public Boolean upcomment(String ids, String type) {
        return baseMapper.upcomment(ids, type);
    }
 
    @Override
    public ArticleVO getArticleOne(ArticleVO article) {
        if (article.getType() != null && article.getType().equals(4)) {
            article.setParentId("1740566650527752194");
        } else {
            article.setParentId("1722966265111248897");
        }
        ArticleVO articleVO = baseMapper.getArticleOne(article);
        return articleVO;
    }
 
    @Override
    public List<ArticleVO> getArticleByDistrictId(ArticleVO article) {
        List<String> stringList = Arrays.asList(article.getDistrictId().split(","));
        article.setDistrictIdList(stringList);
        return baseMapper.getArticleByDistrictId(article);
    }
 
    /**
     * 文章信息更新
     * @param objectUpdateWrapper
     * @param id
     * @param houseCode
     * @return
     */
    @Override
    public boolean updateArticle(UpdateWrapper<Article> objectUpdateWrapper, Long id, String houseCode) {
        boolean update = update(null, objectUpdateWrapper);
        if (update){
            // 查询对应的文章
            Article article = getById(id);
            // 只有反诈的有浏览积分
            if (article.getType()==6) {
                // 添加浏览记录信息
                ArticleIntegralEntity integralEntity = new ArticleIntegralEntity();
                integralEntity.setScore(article.getScore());
                integralEntity.setArticleId(id);
                integralEntity.setHouseCode(houseCode);
                // 插入记录
                update = SpringUtils.getBean(IArticleIntegralService.class).save(integralEntity);
            }
        }
        // 返回
        return update;
    }
}