feat:预约充值
feat:迁移third模块的定时任务到quartz模块
This commit is contained in:
1 parent
7f9fac355a
commit
40f3229e01
23 files changed
+403
-1137
No files matched your search
+32
@@ -0,0 +1,32 @@
|
||||
package com.bsd.pjcloud.thirdparty.api.feign;
|
||||
|
||||
import com.bsd.pjcloud.common.core.constant.ServiceNameConstants;
|
||||
import com.bsd.pjcloud.common.core.util.R;
|
||||
import com.bsd.pjcloud.common.feign.annotation.NoToken;
|
||||
import org.springframework.cloud.openfeign.FeignClient;
|
||||
import org.springframework.web.bind.annotation.PostMapping;
|
||||
|
||||
/**
|
||||
* daemon-quartz 定时触发 thirdparty App消息Push投递的内部 Feign 契约。
|
||||
*/
|
||||
@FeignClient(contextId = "remoteThirdPushDeliveryService", value = ServiceNameConstants.THIRDPARTY_SERVICE)
|
||||
public interface RemoteThirdPushDeliveryService {
|
||||
|
||||
/**
|
||||
* 扫描并处理所有租户到期的投递任务;条件更新领取保证重复触发幂等。
|
||||
*
|
||||
* @return 本轮成功领取并处理的任务数量
|
||||
*/
|
||||
@NoToken
|
||||
@PostMapping("/third-push-delivery/inner/process-due")
|
||||
R<Integer> processDueDeliveries();
|
||||
|
||||
/**
|
||||
* 分批物理清理超过保留期的收件箱、终态投递和供应商尝试日志。
|
||||
*
|
||||
* @return 本轮实际清理记录数量
|
||||
*/
|
||||
@NoToken
|
||||
@PostMapping("/third-push-delivery/inner/cleanup")
|
||||
R<Integer> cleanupExpiredRecords();
|
||||
}
|
||||
+5
@@ -1,13 +1,18 @@
|
||||
package com.bsd.pjcloud.thirdparty.vo.pay;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Builder;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
/**
|
||||
* thirdparty 任务分发结果,供 Quartz 判断服务是否接受本轮触发。
|
||||
*/
|
||||
@Data
|
||||
@Builder
|
||||
// Feign 响应经 Jackson 反序列化必须有无参构造器;@Builder 依赖全参构造器,两者都要显式声明
|
||||
@NoArgsConstructor
|
||||
@AllArgsConstructor
|
||||
public class ThirdPaymentTaskDispatchVo {
|
||||
/** 已接收任务数。 */
|
||||
private int acceptedCount;
|
||||
|
||||
Reference in new issue
Block a user