|
|
|
@ -78,6 +78,13 @@ public class PushConcernFanController {
@@ -78,6 +78,13 @@ public class PushConcernFanController {
|
|
|
|
|
@ApiOperation("保存") |
|
|
|
|
@PostMapping("/save") |
|
|
|
|
public R save(@Valid @RequestBody PushConcernFan pushConcernFan) { |
|
|
|
|
// 考虑:先删除数据在新增,防止安卓不做限制能多次关注导致脏数据
|
|
|
|
|
iPushConcernFanService.remove(Wrappers.<PushConcernFan>lambdaQuery() |
|
|
|
|
.eq(PushConcernFan::getConcernUserId, pushConcernFan.getConcernUserId()) |
|
|
|
|
.eq(PushConcernFan::getFanUserId, pushConcernFan.getFanUserId())); |
|
|
|
|
iPushConcernFanTypeService.remove(Wrappers.<PushConcernFanType>lambdaQuery() |
|
|
|
|
.eq(PushConcernFanType::getConcernUserId, pushConcernFan.getConcernUserId()) |
|
|
|
|
.eq(PushConcernFanType::getFanUserId, pushConcernFan.getFanUserId())); |
|
|
|
|
iPushConcernFanService.save(pushConcernFan); |
|
|
|
|
// 同步推送类型
|
|
|
|
|
if (pushConcernFan.getStatus() == PushAuditStatusEnum.APPROVED.getValue()) { |
|
|
|
@ -167,6 +174,10 @@ public class PushConcernFanController {
@@ -167,6 +174,10 @@ public class PushConcernFanController {
|
|
|
|
|
// 同步推送类型
|
|
|
|
|
if (status == PushAuditStatusEnum.APPROVED.getValue()) { |
|
|
|
|
PushConcernFan pushConcernFan = iPushConcernFanService.getById(id); |
|
|
|
|
// 考虑:先删除数据在新增,防止安卓不做限制能多次关注导致脏数据
|
|
|
|
|
iPushConcernFanTypeService.remove(Wrappers.<PushConcernFanType>lambdaQuery() |
|
|
|
|
.eq(PushConcernFanType::getConcernUserId, pushConcernFan.getConcernUserId()) |
|
|
|
|
.eq(PushConcernFanType::getFanUserId, pushConcernFan.getFanUserId())); |
|
|
|
|
List<PushType> pushTypes = iPushTypeService.list(Wrappers.<PushType>lambdaQuery() |
|
|
|
|
.eq(PushType::getCreateById, pushConcernFan.getConcernUserId())); |
|
|
|
|
List<PushConcernFanType> pushConcernFanTypes = pushTypes.stream().map(item -> new PushConcernFanType() |
|
|
|
|