app极光推送

business-service/src/main/java/com/ozs/service/entity/UserRegistrationid.java

@@ -0,0 +1,21 @@
+package com.ozs.service.entity;
+
+import io.swagger.annotations.ApiModel;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author : sunhh
+ * @create 2023/3/14 17:02
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Builder
+@ApiModel("用户RegistrationID表")
+public class UserRegistrationid {
+    private String userId;
+    private String registrationId;
+}

business-service/src/main/java/com/ozs/service/mapper/UserRegistrationidMapper.java

@@ -0,0 +1,17 @@
+package com.ozs.service.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.ozs.service.entity.SvcAddress;
+import com.ozs.service.entity.UserRegistrationid;
+import org.apache.ibatis.annotations.Mapper;
+
+/**
+ * @Author : sunhh
+ * @create 2023/3/14 17:10
+ */
+@Mapper
+public interface UserRegistrationidMapper extends BaseMapper<UserRegistrationid> {
+    int updateRegistrationID(UserRegistrationid userRegistrationid);
+
+    int addRegistrationID(UserRegistrationid userRegistrationid);
+}

business-service/src/main/java/com/ozs/service/service/UserRegistrationidService.java

@@ -0,0 +1,12 @@
+package com.ozs.service.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.ozs.service.entity.UserRegistrationid;
+
+/**
+ * @Author : sunhh
+ * @create 2023/3/14 17:07
+ */
+public interface UserRegistrationidService extends IService<UserRegistrationid> {
+    Integer addRegistrationID(UserRegistrationid userRegistrationid);
+}

business-service/src/main/java/com/ozs/service/service/impl/UserRegistrationidServiceImpl.java

@@ -0,0 +1,38 @@
+package com.ozs.service.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ozs.service.entity.UserRegistrationid;
+import com.ozs.service.mapper.UserRegistrationidMapper;
+import com.ozs.service.service.UserRegistrationidService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.ObjectUtils;
+
+import java.util.List;
+
+/**
+ * @Author : sunhh
+ * @create 2023/3/14 17:08
+ */
+@Service
+public class UserRegistrationidServiceImpl extends ServiceImpl<UserRegistrationidMapper, UserRegistrationid> implements UserRegistrationidService {
+    @Autowired
+    private UserRegistrationidMapper userRegistrationidMapper;
+
+    @Override
+    public Integer addRegistrationID(UserRegistrationid userRegistrationid) {
+        LambdaQueryWrapper<UserRegistrationid> lw = new LambdaQueryWrapper<UserRegistrationid>();
+        if (!ObjectUtils.isEmpty(userRegistrationid.getUserId())) {
+            lw.in(UserRegistrationid::getUserId, userRegistrationid.getUserId());
+        }
+        List<UserRegistrationid> userRegistrationids = userRegistrationidMapper.selectList(lw);
+        int add = 0;
+        if (userRegistrationids.size() > 0) {
+            add = userRegistrationidMapper.updateRegistrationID(userRegistrationid);
+        } else {
+            add = userRegistrationidMapper.insert(userRegistrationid);
+        }
+        return add;
+    }
+}

business-service/src/main/resources/mapper/service/UserRegistrationidMapper.xml

@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.ozs.service.mapper.UserRegistrationidMapper">
+
+    <update id="updateRegistrationID" parameterType="com.ozs.service.entity.UserRegistrationid">
+        update user_registrationid
+        <set>
+            <if test="registration_id != null and registration_id != 0">
+                registration_id = #{registrationId}
+            </if>
+        </set>
+        where user_id = #{userId}
+    </update>
+</mapper>

hazard-admin/src/main/java/com/ozs/web/controller/app/JPushAppController.java

@@ -0,0 +1,39 @@
+package com.ozs.web.controller.app;
+
+import com.ozs.common.core.controller.BaseController;
+import com.ozs.common.core.domain.AjaxResult;
+import com.ozs.common.utils.StringUtils;
+import com.ozs.service.entity.UserRegistrationid;
+import com.ozs.service.service.UserRegistrationidService;
+import io.swagger.annotations.ApiOperation;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.multipart.MultipartFile;
+
+/**
+ * @Author : sunhh
+ * @create 2023/3/14 16:36
+ */
+@Slf4j
+@RestController
+@RequestMapping("/jPushApp")
+public class JPushAppController extends BaseController {
+    @Autowired
+    private UserRegistrationidService userRegistrationidService;
+
+    /**
+     * 存储RegistrationID
+     */
+    @PostMapping("/addRegistrationID")
+    @ApiOperation("存储RegistrationID")
+    public AjaxResult addRegistrationID(@RequestBody UserRegistrationid userRegistrationid) {
+        if (StringUtils.isBlank(userRegistrationid.getUserId()) || StringUtils.isBlank(userRegistrationid.getRegistrationId())) {
+            return AjaxResult.error("userId,RegistrationID 不能为空！");
+        }
+        return toAjax(userRegistrationidService.addRegistrationID(userRegistrationid));
+    }
+}