Package com.bytedesk.core.push

Class PushRestService

java.lang.Object

com.bytedesk.core.base.BaseRestService<PushEntity,PushRequest,PushResponse>

com.bytedesk.core.push.PushRestService

@Service
public class PushRestService
extends BaseRestService<PushEntity,PushRequest,PushResponse>

Field Summary

Fields

Modifier and Type	Field	Description
private final BytedeskProperties	bytedeskProperties
private final IpService	ipService
private final org.modelmapper.ModelMapper	modelMapper
private final PushFilterService	pushFilterService
private final PushRepository	pushRepository
private final PushServiceEmail	pushServiceEmail
private final PushServiceSms	pushServiceSms
private final UidUtils	uidUtils
private final UserService	userService

Fields inherited from class com.bytedesk.core.base.BaseRestService

authService

Constructor Summary

Constructors

Constructor	Description
PushRestService()

Method Summary

Modifier and Type	Method	Description
void	autoOutdateCode()
PushResponse	convertToResponse(PushEntity entity)
PushResponse	create(PushRequest pushRequest)
protected org.springframework.data.jpa.domain.Specification<PushEntity>	createSpecification(PushRequest request)	创建Specification对象，子类必须实现 用于queryByOrg的通用实现
void	delete(PushRequest entity)
void	deleteByUid(String uid)
protected PushEntity	doSave(PushEntity entity)	子类实现具体的保存逻辑
protected org.springframework.data.domain.Page<PushEntity>	executePageQuery(org.springframework.data.jpa.domain.Specification<PushEntity> spec, org.springframework.data.domain.Pageable pageable)	执行分页查询，子类必须实现 用于queryByOrg的通用实现
Boolean	existsByStatusAndTypeAndReceiver(PushStatusEnum status, String type, String receiver)
Optional<PushEntity>	findByDeviceUid(String deviceUid)
Optional<PushEntity>	findByStatusAndReceiverAndContent(PushStatusEnum status, String receiver, String content)
Optional<PushEntity>	findByUid(String uid)
List<PushEntity>	findStatusPending()
PushEntity	handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e, PushEntity entity)
org.springframework.data.domain.Page<PushResponse>	queryByOrg(PushRequest request)	通用的queryByOrg实现 子类如果有特殊逻辑可以重写此方法
org.springframework.data.domain.Page<PushResponse>	queryByUser(PushRequest request)	通用的queryByUser实现 子类如果有特殊逻辑可以重写此方法
PushEntity	save(PushEntity push)	保存实体，带重试机制
PushResponse	scan(PushRequest pushRequest, jakarta.servlet.http.HttpServletRequest request)
PushResponse	scanConfirm(PushRequest pushRequest, jakarta.servlet.http.HttpServletRequest request)
PushResponse	scanQuery(PushRequest pushRequest, jakarta.servlet.http.HttpServletRequest request)
Boolean	sendCode(AuthRequest authRequest, jakarta.servlet.http.HttpServletRequest request)
PushResponse	update(PushRequest request)
Boolean	validateCode(String receiver, String code, jakarta.servlet.http.HttpServletRequest request)

Methods inherited from class com.bytedesk.core.base.BaseRestService

deleteByOrgUid, findByOrgUid, getUidFromRequest, queryByUid, recover, setUserUidToRequest

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

pushRepository

private final PushRepository pushRepository

modelMapper

private final org.modelmapper.ModelMapper modelMapper

uidUtils

private final UidUtils uidUtils

pushServiceEmail

private final PushServiceEmail pushServiceEmail

pushServiceSms

private final PushServiceSms pushServiceSms

userService

private final UserService userService

bytedeskProperties

private final BytedeskProperties bytedeskProperties

ipService

private final IpService ipService

pushFilterService

private final PushFilterService pushFilterService

Constructor Details

PushRestService

public PushRestService()

Method Details

sendCode

public Boolean sendCode(AuthRequest authRequest,
 jakarta.servlet.http.HttpServletRequest request)

validateCode

public Boolean validateCode(String receiver,
 String code,
 jakarta.servlet.http.HttpServletRequest request)

scanQuery

public PushResponse scanQuery(PushRequest pushRequest,
 jakarta.servlet.http.HttpServletRequest request)

scan

public PushResponse scan(PushRequest pushRequest,
 jakarta.servlet.http.HttpServletRequest request)

scanConfirm

public PushResponse scanConfirm(PushRequest pushRequest,
 jakarta.servlet.http.HttpServletRequest request)

create

public PushResponse create(PushRequest pushRequest)

Specified by:

create in class BaseRestService<PushEntity,PushRequest,PushResponse>

findByStatusAndReceiverAndContent

public Optional<PushEntity> findByStatusAndReceiverAndContent(PushStatusEnum status,
 String receiver,
 String content)

findByDeviceUid

public Optional<PushEntity> findByDeviceUid(String deviceUid)

existsByStatusAndTypeAndReceiver

public Boolean existsByStatusAndTypeAndReceiver(PushStatusEnum status,
 String type,
 String receiver)

save

@Caching(put=@CachePut(value="push",key="#push.receiver"))
public PushEntity save(PushEntity push)

Description copied from class: BaseRestService

保存实体，带重试机制

Overrides:

save in class BaseRestService<PushEntity,PushRequest,PushResponse>

doSave

protected PushEntity doSave(PushEntity entity)

Description copied from class: BaseRestService

子类实现具体的保存逻辑

Specified by:

doSave in class BaseRestService<PushEntity,PushRequest,PushResponse>

handleOptimisticLockingFailureException

public PushEntity handleOptimisticLockingFailureException(org.springframework.orm.ObjectOptimisticLockingFailureException e,
 PushEntity entity)

Specified by:

handleOptimisticLockingFailureException in class BaseRestService<PushEntity,PushRequest,PushResponse>

findStatusPending

public List<PushEntity> findStatusPending()

autoOutdateCode

@Async
public void autoOutdateCode()

queryByOrg

public org.springframework.data.domain.Page<PushResponse> queryByOrg(PushRequest request)

Description copied from class: BaseRestService

通用的queryByOrg实现 子类如果有特殊逻辑可以重写此方法

Overrides:

queryByOrg in class BaseRestService<PushEntity,PushRequest,PushResponse>

queryByUser

public org.springframework.data.domain.Page<PushResponse> queryByUser(PushRequest request)

Description copied from class: BaseRestService

通用的queryByUser实现 子类如果有特殊逻辑可以重写此方法

Overrides:

queryByUser in class BaseRestService<PushEntity,PushRequest,PushResponse>

findByUid

public Optional<PushEntity> findByUid(String uid)

Specified by:

findByUid in class BaseRestService<PushEntity,PushRequest,PushResponse>

update

public PushResponse update(PushRequest request)

Specified by:

update in class BaseRestService<PushEntity,PushRequest,PushResponse>

deleteByUid

public void deleteByUid(String uid)

Specified by:

deleteByUid in class BaseRestService<PushEntity,PushRequest,PushResponse>

delete

public void delete(PushRequest entity)

Specified by:

delete in class BaseRestService<PushEntity,PushRequest,PushResponse>

convertToResponse

public PushResponse convertToResponse(PushEntity entity)

Specified by:

convertToResponse in class BaseRestService<PushEntity,PushRequest,PushResponse>

createSpecification

protected org.springframework.data.jpa.domain.Specification<PushEntity> createSpecification(PushRequest request)

Description copied from class: BaseRestService

创建Specification对象，子类必须实现 用于queryByOrg的通用实现

Specified by:

createSpecification in class BaseRestService<PushEntity,PushRequest,PushResponse>

executePageQuery

protected org.springframework.data.domain.Page<PushEntity> executePageQuery(org.springframework.data.jpa.domain.Specification<PushEntity> spec,
 org.springframework.data.domain.Pageable pageable)

Description copied from class: BaseRestService

执行分页查询，子类必须实现 用于queryByOrg的通用实现

Specified by:

executePageQuery in class BaseRestService<PushEntity,PushRequest,PushResponse>