|
@@ -7,14 +7,11 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
7
|
7
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
8
|
8
|
import com.huiju.estateagents.base.ResponseBean;
|
9
|
9
|
import com.huiju.estateagents.common.CommConstant;
|
10
|
|
-import com.huiju.estateagents.entity.TaLiveActivity;
|
11
|
|
-import com.huiju.estateagents.entity.TaMiniapp;
|
12
|
|
-import com.huiju.estateagents.entity.TaShareContent;
|
|
10
|
+import com.huiju.estateagents.entity.*;
|
13
|
11
|
import com.huiju.estateagents.mapper.TaLiveActivityMapper;
|
14
|
|
-import com.huiju.estateagents.service.IMiniAppService;
|
15
|
|
-import com.huiju.estateagents.service.ITaLiveActivityService;
|
16
|
|
-import com.huiju.estateagents.service.ITaMiniappService;
|
17
|
|
-import com.huiju.estateagents.service.TaShareContentService;
|
|
12
|
+import com.huiju.estateagents.service.*;
|
|
13
|
+import org.apache.commons.collections.CollectionUtils;
|
|
14
|
+import org.apache.commons.lang3.StringUtils;
|
18
|
15
|
import org.slf4j.Logger;
|
19
|
16
|
import org.slf4j.LoggerFactory;
|
20
|
17
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
@@ -22,6 +19,8 @@ import org.springframework.stereotype.Service;
|
22
|
19
|
import org.springframework.transaction.annotation.Transactional;
|
23
|
20
|
|
24
|
21
|
import java.time.LocalDateTime;
|
|
22
|
+import java.util.ArrayList;
|
|
23
|
+import java.util.List;
|
25
|
24
|
|
26
|
25
|
/**
|
27
|
26
|
* <p>
|
|
@@ -48,6 +47,15 @@ public class TaLiveActivityServiceImpl extends ServiceImpl<TaLiveActivityMapper,
|
48
|
47
|
@Autowired
|
49
|
48
|
private TaLiveActivityMapper taLiveActivityMapper;
|
50
|
49
|
|
|
50
|
+ @Autowired
|
|
51
|
+ private TaPosterServiceImpl taPosterService;
|
|
52
|
+
|
|
53
|
+ @Autowired
|
|
54
|
+ private ShareContentServiceImpl shareContentService;
|
|
55
|
+
|
|
56
|
+ @Autowired
|
|
57
|
+ private TdPosterTemplateServiceImpl posterTemplateService;
|
|
58
|
+
|
51
|
59
|
|
52
|
60
|
@Override
|
53
|
61
|
public ResponseBean taLiveActivityAdd(TaLiveActivity taLiveActivity) {
|
|
@@ -83,8 +91,8 @@ public class TaLiveActivityServiceImpl extends ServiceImpl<TaLiveActivityMapper,
|
83
|
91
|
shareContent.setTargetId(taLiveActivity.getLiveActivityId().toString());
|
84
|
92
|
shareContent.setShareContentTitle("直播看房,在线答疑,快上车~");
|
85
|
93
|
shareContent.setShareContentImg(taLiveActivity.getDetailImg());
|
86
|
|
- shareContent.setShareContentType("live");
|
87
|
|
- shareContent.setStatus(1);
|
|
94
|
+ shareContent.setShareContentType(CommConstant.LIVE);
|
|
95
|
+ shareContent.setStatus(CommConstant.STATUS_NORMAL);
|
88
|
96
|
shareContent.setCreateDate(LocalDateTime.now());
|
89
|
97
|
taShareContentService.save(shareContent);
|
90
|
98
|
|
|
@@ -102,11 +110,25 @@ public class TaLiveActivityServiceImpl extends ServiceImpl<TaLiveActivityMapper,
|
102
|
110
|
ResponseBean responseBean = new ResponseBean();
|
103
|
111
|
IPage<TaLiveActivity> pg = new Page<>(pageNum, pageSize);
|
104
|
112
|
QueryWrapper<TaLiveActivity> queryWrapper = new QueryWrapper<>();
|
105
|
|
- queryWrapper.like("live_activity_title", liveActivityTitle);
|
106
|
|
- queryWrapper.eq("city_id", cityId);
|
107
|
|
- queryWrapper.eq("building_id", buildingId);
|
108
|
|
- queryWrapper.eq("live_detail_type", liveDetailType);
|
109
|
|
- queryWrapper.eq("status", status);
|
|
113
|
+
|
|
114
|
+ if (orgId != null) {
|
|
115
|
+ queryWrapper.eq("org_id", orgId);
|
|
116
|
+ }
|
|
117
|
+ if (StringUtils.isNotBlank(liveActivityTitle)) {
|
|
118
|
+ queryWrapper.like("live_activity_title", liveActivityTitle);
|
|
119
|
+ }
|
|
120
|
+ if (StringUtils.isNotBlank(cityId)) {
|
|
121
|
+ queryWrapper.eq("city_id", cityId);
|
|
122
|
+ }
|
|
123
|
+ if (StringUtils.isNotBlank(buildingId)) {
|
|
124
|
+ queryWrapper.eq("building_id", buildingId);
|
|
125
|
+ }
|
|
126
|
+ if (StringUtils.isNotBlank(liveDetailType)) {
|
|
127
|
+ queryWrapper.eq("live_detail_type", liveDetailType);
|
|
128
|
+ }
|
|
129
|
+ if (status != null) {
|
|
130
|
+ queryWrapper.eq("status", status);
|
|
131
|
+ }
|
110
|
132
|
queryWrapper.orderByDesc("create_date");
|
111
|
133
|
IPage<TaLiveActivity> result = page(pg, queryWrapper);
|
112
|
134
|
responseBean.addSuccess(result);
|
|
@@ -117,11 +139,51 @@ public class TaLiveActivityServiceImpl extends ServiceImpl<TaLiveActivityMapper,
|
117
|
139
|
public ResponseBean addVisitNum(String id) {
|
118
|
140
|
ResponseBean responseBean = new ResponseBean();
|
119
|
141
|
Boolean result = taLiveActivityMapper.addVisitNum(id);
|
120
|
|
- if(result){
|
|
142
|
+ if (result) {
|
121
|
143
|
responseBean.addSuccess("成功");
|
122
|
144
|
return responseBean;
|
123
|
145
|
}
|
124
|
146
|
responseBean.addError("fail");
|
125
|
147
|
return responseBean;
|
126
|
148
|
}
|
|
149
|
+
|
|
150
|
+ @Override
|
|
151
|
+ public ResponseBean getLiveActivityDetailById(String id) {
|
|
152
|
+ logger.info("getLiveActivityDetailById 接收参数:id:{}", id);
|
|
153
|
+
|
|
154
|
+ ResponseBean responseBean = new ResponseBean();
|
|
155
|
+ TaLiveActivity result = getById(id);
|
|
156
|
+ if (result == null) {
|
|
157
|
+ responseBean.addSuccess(null);
|
|
158
|
+ return responseBean;
|
|
159
|
+ }
|
|
160
|
+
|
|
161
|
+ // 获取海报信息
|
|
162
|
+ QueryWrapper<TaPoster> queryWrapper = new QueryWrapper<>();
|
|
163
|
+ queryWrapper.eq("target_id", id + "");
|
|
164
|
+ queryWrapper.eq("target_type", CommConstant.LIVE);
|
|
165
|
+ queryWrapper.eq("status", CommConstant.STATUS_NORMAL);
|
|
166
|
+ List<TaPoster> posterList = taPosterService.list(queryWrapper);
|
|
167
|
+
|
|
168
|
+ List<TaPoster> resultPosterList = new ArrayList<>();
|
|
169
|
+ if (CollectionUtils.isNotEmpty(posterList)) {
|
|
170
|
+ for (TaPoster poster : posterList) {
|
|
171
|
+ QueryWrapper<TdPosterTemplate> templateQueryWrapper = new QueryWrapper<>();
|
|
172
|
+ templateQueryWrapper.eq("status", CommConstant.STATUS_NORMAL);
|
|
173
|
+ templateQueryWrapper.eq("type ", "liveActivity");
|
|
174
|
+ List<TdPosterTemplate> posterTemplate = posterTemplateService.list(templateQueryWrapper);
|
|
175
|
+
|
|
176
|
+ poster.setTemplates(posterTemplate);
|
|
177
|
+ resultPosterList.add(poster);
|
|
178
|
+ }
|
|
179
|
+ }
|
|
180
|
+
|
|
181
|
+ // 获取分享内容信息
|
|
182
|
+ List<TaShareContent> shareContentList = shareContentService.getPostersForTarget(id + "", CommConstant.LIVE);
|
|
183
|
+
|
|
184
|
+ result.setPosters(resultPosterList);
|
|
185
|
+ result.setShareContents(shareContentList);
|
|
186
|
+ responseBean.addSuccess(result);
|
|
187
|
+ return responseBean;
|
|
188
|
+ }
|
127
|
189
|
}
|