Browse Source

feat: 企业推送消息接口

master
wangxiang 2 years ago
parent
commit
f9f748d2b1
  1. 4
      kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/PushApplicationController.java
  2. 2
      kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/PushApplicationServiceImpl.java

4
kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/PushApplicationController.java

@ -10,6 +10,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; @@ -10,6 +10,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.cloud.kicc.common.core.api.R;
import com.cloud.kicc.common.core.constant.AppConstants;
import com.cloud.kicc.common.core.exception.CheckedException;
import com.cloud.kicc.common.security.annotation.Inner;
import com.cloud.kicc.common.security.util.SecurityUtils;
import com.cloud.kicc.commonbiz.api.entity.PushApplication;
import com.cloud.kicc.commonbiz.api.entity.PushChatMessage;
@ -95,7 +96,8 @@ public class PushApplicationController { @@ -95,7 +96,8 @@ public class PushApplicationController {
}
@PostMapping("/enterpriseSend")
@ApiOperation(value = "企业推送消息")
@ApiOperation("企业推送消息")
@Inner(false)
public R enterpriseMessageSend(@Valid @RequestBody PushChatMessage pushChatMessage) {
iPushApplicationService.enterpriseMessageSend(pushChatMessage);
return R.ok(true);

2
kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/PushApplicationServiceImpl.java

@ -71,7 +71,7 @@ public class PushApplicationServiceImpl extends ServiceImpl<PushApplicationMappe @@ -71,7 +71,7 @@ public class PushApplicationServiceImpl extends ServiceImpl<PushApplicationMappe
// 过滤掉黑名单用户
List<PushBlacklist> pushBlacklists = iPushBlacklistService.list(Wrappers.<PushBlacklist>lambdaQuery().eq(PushBlacklist::getFanUserId, pushChatMessage.getUserId()));
pushBlacklists.forEach(item -> pushChatMessage.getAlias().replaceAll(item.getConcernUserId() + ",|$", ""));
pushBlacklists.forEach(item -> pushChatMessage.setAlias(pushChatMessage.getAlias().replaceAll(item.getConcernUserId() + ",|$", "")));
// 查询推送用户设置的推送类型,如果参数中没有指定则采用默认的推送类型

Loading…
Cancel
Save