提交 a4abffa7 authored 作者: Whispa's avatar Whispa

commit

上级 2331af00
...@@ -78,6 +78,24 @@ public class TbCfHomePageEntityController extends Controller { ...@@ -78,6 +78,24 @@ public class TbCfHomePageEntityController extends Controller {
return null; return null;
} }
@GetMapping("/home/clientWithFcm")
public Result getClientList( @RequestParam(value = "pageNo",required = false,defaultValue = "20") Integer pageNo, @RequestParam(value = "pageSize",required = false,defaultValue = "20") Integer pageSize){
List<TbCfUserInfo> allByFcmIsNotNull = userRepository.findAllByFcmIsNotNull(PageRequest.of(pageNo, pageSize));
return new Result<>(allByFcmIsNotNull);
}
@GetMapping("/home/sendNotification/byCode/{code}")
public Result sendFcm(@PathVariable("code") String id,@RequestParam("content") String content,@RequestParam("title") String title){
Optional<TbCfUserInfo> byId = userRepository.findByCode(id);
if( byId.isPresent() && byId.get().hasFcm() ){
TbCfUserInfo userInfo = byId.get();
sendNotification(userInfo.getFcm(),title,content);
return new Result();
}
return new Result(ResultCodeEnum.SUCCESS.getCode(),"No firebase messaging token found");
}
@GetMapping("/home/middleColumn") @GetMapping("/home/middleColumn")
public Result getMiddleColumn( @RequestParam(value = "limit", defaultValue = "4") Integer limit){ public Result getMiddleColumn( @RequestParam(value = "limit", defaultValue = "4") Integer limit){
......
...@@ -169,7 +169,7 @@ public class UserController extends Controller { ...@@ -169,7 +169,7 @@ public class UserController extends Controller {
return new Result(); return new Result();
} }
return new Result(ResultCodeEnum.SUCCESS.getCode(),"No fire messaging found"); return new Result(ResultCodeEnum.SUCCESS.getCode(),"No firebase messaging token found");
} }
......
package com.example.afrishop_v3.repository; package com.example.afrishop_v3.repository;
import com.example.afrishop_v3.models.TbCfUserInfo; import com.example.afrishop_v3.models.TbCfUserInfo;
import org.springframework.data.domain.Pageable;
import org.springframework.data.repository.PagingAndSortingRepository; import org.springframework.data.repository.PagingAndSortingRepository;
import java.util.List;
import java.util.Optional; import java.util.Optional;
public interface UserRepository extends PagingAndSortingRepository<TbCfUserInfo,String> { public interface UserRepository extends PagingAndSortingRepository<TbCfUserInfo,String> {
...@@ -13,4 +15,5 @@ public interface UserRepository extends PagingAndSortingRepository<TbCfUserInfo, ...@@ -13,4 +15,5 @@ public interface UserRepository extends PagingAndSortingRepository<TbCfUserInfo,
Optional<TbCfUserInfo> findFirstByEmail(String s); Optional<TbCfUserInfo> findFirstByEmail(String s);
Optional<TbCfUserInfo> findByCode(String s); Optional<TbCfUserInfo> findByCode(String s);
boolean existsByCode(String code); boolean existsByCode(String code);
List<TbCfUserInfo> findAllByFcmIsNotNull(Pageable pageable);
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论