|
@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
|
5
|
5
|
import com.huiju.estateagents.base.BaseController;
|
6
|
6
|
import com.huiju.estateagents.base.ResponseBean;
|
7
|
7
|
import com.huiju.estateagents.common.CommConstant;
|
|
8
|
+import com.huiju.estateagents.common.StringUtils;
|
8
|
9
|
import com.huiju.estateagents.entity.ExtendContent;
|
9
|
10
|
import com.huiju.estateagents.entity.TaLiveActivity;
|
10
|
11
|
import com.huiju.estateagents.service.IExtendContentService;
|
|
@@ -61,7 +62,7 @@ public class TaLiveActivityController extends BaseController {
|
61
|
62
|
ResponseBean responseBean = new ResponseBean();
|
62
|
63
|
try {
|
63
|
64
|
IPage<TaLiveActivity> result = iTaLiveActivityService.listLiveActivityByCondition(pageNum, pageSize, getOrgId(request),
|
64
|
|
- liveActivityTitle, cityId, buildingId, status,getTaPersonBuildingListByUserId(request));
|
|
65
|
+ liveActivityTitle, cityId, buildingId, status, getTaPersonBuildingListByUserId(request));
|
65
|
66
|
responseBean.addSuccess(result);
|
66
|
67
|
|
67
|
68
|
} catch (Exception e) {
|
|
@@ -107,18 +108,18 @@ public class TaLiveActivityController extends BaseController {
|
107
|
108
|
ResponseBean responseBean = new ResponseBean();
|
108
|
109
|
try {
|
109
|
110
|
List<Integer> liveActivityIds = new ArrayList<>();
|
110
|
|
- for(TaLiveActivity activity : taLiveActivity){
|
|
111
|
+ for (TaLiveActivity activity : taLiveActivity) {
|
111
|
112
|
liveActivityIds.add(activity.getLiveActivityId());
|
112
|
113
|
}
|
113
|
114
|
QueryWrapper<ExtendContent> queryWrapper = new QueryWrapper<>();
|
114
|
|
- queryWrapper.eq("org_id",getOrgId(request));
|
115
|
|
- queryWrapper.eq("content_type",CommConstant.LIVE);
|
116
|
|
- queryWrapper.in("target_id",liveActivityIds);
|
|
115
|
+ queryWrapper.eq("org_id", getOrgId(request));
|
|
116
|
+ queryWrapper.eq("content_type", CommConstant.LIVE);
|
|
117
|
+ queryWrapper.in("target_id", liveActivityIds);
|
117
|
118
|
List<ExtendContent> list = iExtendContentService.list(queryWrapper);
|
118
|
119
|
list.forEach(e -> {
|
119
|
120
|
e.setStatus(CommConstant.NOT_PUBLISH);
|
120
|
121
|
});
|
121
|
|
- if (list.size() > 0){
|
|
122
|
+ if (list.size() > 0) {
|
122
|
123
|
iExtendContentService.updateBatchById(list);
|
123
|
124
|
}
|
124
|
125
|
|
|
@@ -146,23 +147,27 @@ public class TaLiveActivityController extends BaseController {
|
146
|
147
|
taLiveActivity.setLiveActivityId(id);
|
147
|
148
|
taLiveActivity.setUpdateUser(getUserId(request).toString());
|
148
|
149
|
QueryWrapper<ExtendContent> queryWrapper = new QueryWrapper<>();
|
149
|
|
- queryWrapper.eq("org_id",getOrgId(request));
|
150
|
|
- queryWrapper.eq("content_type",CommConstant.LIVE);
|
151
|
|
- queryWrapper.eq("target_id",taLiveActivity.getLiveActivityId());
|
|
150
|
+ queryWrapper.eq("org_id", getOrgId(request));
|
|
151
|
+ queryWrapper.eq("content_type", CommConstant.LIVE);
|
|
152
|
+ queryWrapper.eq("target_id", taLiveActivity.getLiveActivityId());
|
152
|
153
|
List<ExtendContent> list = iExtendContentService.list(queryWrapper);
|
153
|
|
- if (CommConstant.NOT_PUBLISH.equals(taLiveActivity.getStatus())){
|
|
154
|
+ if (CommConstant.NOT_PUBLISH.equals(taLiveActivity.getStatus())) {
|
154
|
155
|
list.forEach(e -> {
|
155
|
156
|
e.setStatus(CommConstant.NOT_PUBLISH);
|
156
|
157
|
});
|
157
|
|
- }else{
|
|
158
|
+ } else {
|
158
|
159
|
list.forEach(e -> {
|
159
|
160
|
e.setStatus(CommConstant.IS_PUBLISH);
|
160
|
161
|
});
|
161
|
162
|
}
|
162
|
|
- if (list.size() > 0){
|
|
163
|
+ if (list.size() > 0) {
|
163
|
164
|
iExtendContentService.updateBatchById(list);
|
164
|
165
|
}
|
165
|
166
|
|
|
167
|
+ if(!StringUtils.isEmpty(taLiveActivity.getLiveRoomParam())){
|
|
168
|
+ taLiveActivity.setLiveAppPath(taLiveActivity.getLiveRoomParam().replace(".html",""));
|
|
169
|
+ }
|
|
170
|
+
|
166
|
171
|
if (iTaLiveActivityService.updateById(taLiveActivity)) {
|
167
|
172
|
responseBean.addSuccess(taLiveActivity);
|
168
|
173
|
} else {
|
|
@@ -252,7 +257,8 @@ public class TaLiveActivityController extends BaseController {
|
252
|
257
|
ResponseBean responseBean = new ResponseBean();
|
253
|
258
|
try {
|
254
|
259
|
status = status == null ? 1 : status;
|
255
|
|
- IPage<TaLiveActivity> result = iTaLiveActivityService.listLiveActivityByCondition(pageNum, pageSize, getOrgId(request),
|
|
260
|
+ Integer orgId = getOrgId(request);
|
|
261
|
+ IPage<TaLiveActivity> result = iTaLiveActivityService.listLiveActivityByCondition(pageNum, pageSize, orgId,
|
256
|
262
|
liveActivityTitle, cityId, buildingId, status, getTaPersonBuildingListByUserId(request));
|
257
|
263
|
responseBean.addSuccess(result);
|
258
|
264
|
|