新增极光推送功能及设备id存储到Redis的逻辑

alexyang
1 parent 2b422cef
Showing 6 changed files with 165 additions and 0 deletions
sl-express-ms-base-service/pom.xml
sl-express-ms-base-service/src/main/java/com/sl/ms/base/config/JPushConfig.java
sl-express-ms-base-service/src/main/java/com/sl/ms/base/service/base/impl/MessageServiceImpl.java
sl-express-ms-base-service/src/test/java/com/sl/ms/base/jpush/JPushTest.java
sl-express-ms-web-courier/src/main/java/com/sl/ms/web/courier/service/impl/LoginServiceImpl.java
sl-express-ms-web-courier/src/main/java/com/sl/ms/web/courier/vo/login/AccountLoginVO.java
@@ -103,6 +103,12 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-redis</artifactId>
         </dependency>
+        <!-- jiguang-sdk -->
+        <dependency>
+            <groupId>io.github.jpush</groupId>
+            <artifactId>jiguang-sdk</artifactId>
+            <version>5.2.13</version>
+        </dependency>
     </dependencies>
  
     <build>
+package com.sl.ms.base.config;
+
+import cn.jiguang.sdk.api.PushApi;
+import feign.Logger;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Slf4j
+@Configuration
+public class JPushConfig {
+
+    @Bean
+    public PushApi pushApi() {
+        return new PushApi.Builder()
+                // .setClient(new feign.okhttp.OkHttpClient(okHttpClient)) // sdk默认使用的feign-okhttp，可自定义，可选
+                // .setOptions(new Request.Options(10, TimeUnit.SECONDS, 60, TimeUnit.SECONDS, true)) // 可自定义超时参数，可选
+                // .setRetryer(new Retryer.Default(100, SECONDS.toMillis(1), 5)) // 可自定义重试参数，可选
+                // .setLoggerLevel(Logger.Level.FULL) // 可自定义日志打印级别，可选
+                .setAppKey("6f7829173a8ccb6c34653947") // 必填
+                .setMasterSecret("d9f1963450bcd235eb2d3175") // 必填
+                .setLoggerLevel(Logger.Level.FULL)
+                .build();
+    }
+}
@@ -3,6 +3,12 @@ package com.sl.ms.base.service.base.impl;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.ObjectUtil;
+import cn.jiguang.sdk.api.PushApi;
+import cn.jiguang.sdk.bean.push.PushSendParam;
+import cn.jiguang.sdk.bean.push.PushSendResult;
+import cn.jiguang.sdk.bean.push.audience.Audience;
+import cn.jiguang.sdk.bean.push.message.notification.NotificationMessage;
+import cn.jiguang.sdk.constants.ApiConstants;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
@@ -13,15 +19,20 @@ import com.sl.ms.base.domain.base.MessageAddDTO;
 import com.sl.ms.base.domain.base.MessageDTO;
 import com.sl.ms.base.domain.base.MessageQueryDTO;
 import com.sl.ms.base.domain.constants.MessageConstants;
+import com.sl.ms.base.domain.enums.MessageBussinessTypeEnum;
 import com.sl.ms.base.entity.base.MessageEntity;
 import com.sl.ms.base.mapper.base.MessageMapper;
 import com.sl.ms.base.service.base.MessageService;
 import com.sl.transport.common.exception.SLException;
 import com.sl.transport.common.util.PageResponse;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
  
+import javax.annotation.Resource;
 import java.time.LocalDateTime;
+import java.util.Arrays;
 import java.util.Collections;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -30,8 +41,15 @@ import java.util.stream.Collectors;
  * 消息相关业务
  */
 @Service
+@Slf4j
 public class MessageServiceImpl extends ServiceImpl<MessageMapper, MessageEntity> implements MessageService {
  
+    @Resource
+    private StringRedisTemplate stringRedisTemplate;
+
+    @Resource
+    private PushApi pushApi;
+
     /**
      * 新增消息
      *
@@ -46,6 +64,34 @@ public class MessageServiceImpl extends ServiceImpl&lt;MessageMapper, MessageEntity
         this.save(entity);
     }
  
+    private void sendJPush(MessageAddDTO messageAddDTO) {
+        if (messageAddDTO.getBussinessType().equals(MessageBussinessTypeEnum.COURIER.getCode())) {
+            String redisKey = "courier:device:" + messageAddDTO.getUserId();
+            String deviceId = stringRedisTemplate.opsForValue().get(redisKey);
+            if (ObjectUtil.isNotEmpty(deviceId)) {
+                PushSendParam param = new PushSendParam();
+
+                NotificationMessage notificationMessage = new NotificationMessage();
+                notificationMessage.setAlert(messageAddDTO.getTitle());
+                param.setNotification(notificationMessage);
+
+                // 目标人群
+                Audience audience = new Audience();
+                audience.setRegistrationIdList(Collections.singletonList(deviceId));
+
+                // 指定目标
+                param.setAudience(audience);
+
+                // 或者发送所有平台
+                param.setPlatform(ApiConstants.Platform.ALL);
+
+                // 发送
+                PushSendResult result = pushApi.send(param);
+                log.info("result:{}", result);
+            }
+        }
+    }
+
     /**
      * 标记已读
      *
+package com.sl.ms.base.jpush;
+
+import cn.jiguang.sdk.api.PushApi;
+import cn.jiguang.sdk.bean.push.PushSendParam;
+import cn.jiguang.sdk.bean.push.PushSendResult;
+import cn.jiguang.sdk.bean.push.audience.Audience;
+import cn.jiguang.sdk.bean.push.message.notification.NotificationMessage;
+import cn.jiguang.sdk.constants.ApiConstants;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.Map;
+
+@Slf4j
+@SpringBootTest
+public class JPushTest {
+    @Autowired
+    private PushApi pushApi;
+
+    @Test
+    public void send() {
+        PushSendParam param = new PushSendParam();
+        // 通知内容
+        NotificationMessage.Android android = new NotificationMessage.Android();
+        android.setAlert("this is android alert");
+        android.setTitle("this is android title");
+
+        NotificationMessage.IOS iOS = new NotificationMessage.IOS();
+        Map<String, String> iOSAlert = new HashMap<>();
+        iOSAlert.put("title", "this is iOS title");
+        iOSAlert.put("subtitle", "this is iOS subtitle");
+        iOS.setAlert(iOSAlert);
+
+        Map<String, Object> extrasMap = new HashMap<>();
+        Map<String, Object> extrasParamMap = new HashMap<>();
+        extrasParamMap.put("key1", "value1");
+        extrasParamMap.put("key2", "value2");
+        extrasMap.put("params", extrasParamMap);
+        android.setExtras(extrasMap);
+        iOS.setExtras(extrasMap);
+
+        NotificationMessage notificationMessage = new NotificationMessage();
+        notificationMessage.setAlert("this is alert");
+        notificationMessage.setAndroid(android);
+        notificationMessage.setIos(iOS);
+        param.setNotification(notificationMessage);
+
+        // 目标人群
+        Audience audience = new Audience();
+        audience.setRegistrationIdList(Arrays.asList("170976fa8ba46cae79f", "170976fa8ba46cae79f"));
+        // 指定目标
+         param.setAudience(audience);
+
+        // 或者发送所有人
+//        param.setAudience(ApiConstants.Audience.ALL);
+
+        // 或者发送所有平台
+         param.setPlatform(ApiConstants.Platform.ALL);
+
+        // 短信补充
+        // param.setSmsMessage();
+
+        // 回调
+        // param.setCallback();
+
+        // 发送
+        PushSendResult result = pushApi.send(param);
+        log.info("result:{}", result);
+    }
+}
@@ -8,6 +8,7 @@ import com.sl.ms.web.courier.vo.login.AccountLoginVO;
 import com.sl.ms.web.courier.vo.login.LoginVO;
 import com.sl.transport.common.vo.R;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Service;
  
 import javax.annotation.Resource;
@@ -18,6 +19,9 @@ public class LoginServiceImpl implements LoginService {
     @Resource
     private AuthTemplate authTemplate;
  
+    @Resource
+    private StringRedisTemplate stringRedisTemplate;
+
     /**
      * 根据用户名和密码进行登录
      *
@@ -34,6 +38,14 @@ public class LoginServiceImpl implements LoginService {
             return R.error(loginResult.getMsg());
         }
  
+        // 设备 id 存储到 Redis
+        String deviceId = "170976fa8ba46cae79f"; //accountLoginVO.getDeviceId();
+        if (deviceId != null) {
+            Long userId = loginResult.getData().getUser().getId();
+            String redisKey = "courier:device:" + userId;
+            stringRedisTemplate.opsForValue().set(redisKey, deviceId);
+        }
+
         return R.success(new LoginVO(loginResult.getData().getToken().getToken()));
     }
 }
@@ -15,5 +15,7 @@ public class AccountLoginVO {
     @ApiModelProperty(value = "登录密码", required = true)
     @NotNull(message = "登录密码不能为空")
     private String password;
+    @ApiModelProperty(value = "推送设备")
+    private String deviceId;
  
 }