Browse Source

🚀 消息推送模块

master
wangxiang 2 years ago
parent
commit
7638c62c14
  1. 2
      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

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

@ -1,6 +1,7 @@
package com.cloud.kicc.commonbiz.controller; package com.cloud.kicc.commonbiz.controller;
import cn.hutool.core.lang.UUID;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
@ -57,6 +58,7 @@ public class PushApplicationController {
@ApiOperation("保存") @ApiOperation("保存")
@PostMapping("/save") @PostMapping("/save")
public R save(@Valid @RequestBody PushApplication pushApplication) { public R save(@Valid @RequestBody PushApplication pushApplication) {
pushApplication.setMessageSecret(UUID.randomUUID().toString().replace("-",""));
iPushApplicationService.save(pushApplication); iPushApplicationService.save(pushApplication);
return R.ok(); return R.ok();
} }

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

@ -59,7 +59,7 @@ public class PushApplicationServiceImpl extends ServiceImpl<PushApplicationMappe
} }
R<User> result = remoteUserService.selectByUserId(pushMessage.getFromUserId(), SecurityConstants.FROM_IN); R<User> result = remoteUserService.selectByUserId(pushMessage.getFromUserId(), SecurityConstants.FROM_IN);
if (result == null || result.getData() == null) { if (result == null || result.getData() == null) {
throw new UsernameNotFoundException("用户不存在"); throw new CheckedException("用户不存在");
} }
// 第三方发送前较验数据 // 第三方发送前较验数据
if (result.getData().getUserType().equals("9")) { if (result.getData().getUserType().equals("9")) {

Loading…
Cancel
Save