diff --git a/src/main/java/com/example/bo/PhoneNumberBo.java b/src/main/java/com/example/bo/PhoneNumberBo.java index 0254f16..7bc888f 100644 --- a/src/main/java/com/example/bo/PhoneNumberBo.java +++ b/src/main/java/com/example/bo/PhoneNumberBo.java @@ -5,9 +5,6 @@ /** * excel表格手机号BO - * - * @author JiChenWang - * @since 2024/6/27 20:28 */ @Data public class PhoneNumberBo { diff --git a/src/main/java/com/example/config/SwaggerConfig.java b/src/main/java/com/example/config/SwaggerConfig.java index 675d4d0..0c186b2 100644 --- a/src/main/java/com/example/config/SwaggerConfig.java +++ b/src/main/java/com/example/config/SwaggerConfig.java @@ -10,11 +10,6 @@ import org.springframework.context.annotation.Configuration; -/** - * @author: www.byteblogs.com - * @date : 2023-07-17 18:19 - * @since 2.1.0 - */ @Configuration public class SwaggerConfig { @@ -47,9 +42,3 @@ public GroupedOpenApi adminApi() { .build(); } } - - - - - - diff --git a/src/main/java/com/example/controller/JobController.java b/src/main/java/com/example/controller/JobController.java index ec8e713..84dc918 100644 --- a/src/main/java/com/example/controller/JobController.java +++ b/src/main/java/com/example/controller/JobController.java @@ -1,21 +1,13 @@ package com.example.controller; import com.aizuda.snailjob.client.job.core.dto.JobResponseVO; -import com.example.handler.TestAddJobHandler; -import com.example.handler.TestQueryJobHandler; -import com.example.handler.TestTriggerJobHandler; -import com.example.handler.TestUpdateJobHandler; -import com.example.handler.TestUpdateJobStatusHandler; +import com.example.handler.*; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.tags.Tag; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; -/** - * @author opensnail - * @date 2024-10-19 10:41:25 - * @since sj_1.2.0-beta2 - */ + @RestController @RequestMapping("/open-api/job") @Tag(name = "JobOpenApi", description = "通过OpenApi可以灵活的实现对Job的增、改、查功能") diff --git a/src/main/java/com/example/controller/LocalAndRemoteRetryController.java b/src/main/java/com/example/controller/LocalAndRemoteRetryController.java index 23d9a4a..43c20fc 100644 --- a/src/main/java/com/example/controller/LocalAndRemoteRetryController.java +++ b/src/main/java/com/example/controller/LocalAndRemoteRetryController.java @@ -115,3 +115,4 @@ public boolean localRetryWithTryCatch2(@RequestParam("params") String params) { return localRemoteService.localRetryWithTryCatch2(params); } } + diff --git a/src/main/java/com/example/controller/LocalRetryController.java b/src/main/java/com/example/controller/LocalRetryController.java index 373aef8..8fa8419 100644 --- a/src/main/java/com/example/controller/LocalRetryController.java +++ b/src/main/java/com/example/controller/LocalRetryController.java @@ -1,5 +1,6 @@ package com.example.controller; +import com.example.service.LocalRetryService; import com.example.vo.OrderVo; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Parameter; @@ -9,14 +10,7 @@ import io.swagger.v3.oas.annotations.tags.Tag; import org.apache.ibatis.annotations.Param; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.GetMapping; -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.RequestParam; -import org.springframework.web.bind.annotation.RestController; - -import com.example.service.LocalRetryService; +import org.springframework.web.bind.annotation.*; @RestController @RequestMapping("/local") @@ -187,3 +181,4 @@ public boolean localRetryWithTryCatch2(@RequestParam("params") String params) { return localRetryService.localRetryWithTryCatch2(params); } } + diff --git a/src/main/java/com/example/controller/ManualRetryExecutorController.java b/src/main/java/com/example/controller/ManualRetryExecutorController.java index 7e3693a..7a63880 100644 --- a/src/main/java/com/example/controller/ManualRetryExecutorController.java +++ b/src/main/java/com/example/controller/ManualRetryExecutorController.java @@ -1,5 +1,6 @@ package com.example.controller; +import com.example.service.ManualRetryExecutorMethodService; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Parameter; import io.swagger.v3.oas.annotations.media.Schema; @@ -10,8 +11,6 @@ import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; -import com.example.service.ManualRetryExecutorMethodService; - @RestController @RequestMapping("/manual") @Tag(name = "模拟手动执行重试案例", description = "手动执行重试上报") @@ -31,3 +30,4 @@ public void remoteRetryWithCallback(@Parameter(name = "params", description = " manualRetryExecutorMethodService.myExecutorMethod(params); } } + diff --git a/src/main/java/com/example/controller/RemoteRetryController.java b/src/main/java/com/example/controller/RemoteRetryController.java index 1ed2f28..1b7c4ba 100644 --- a/src/main/java/com/example/controller/RemoteRetryController.java +++ b/src/main/java/com/example/controller/RemoteRetryController.java @@ -1,23 +1,16 @@ package com.example.controller; -import java.util.Random; -import java.util.UUID; - +import com.example.service.RemoteRetryService; +import com.example.vo.OrderVo; import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Parameter; import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.tags.Tag; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.PathVariable; -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.RequestParam; -import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.bind.annotation.*; -import com.example.vo.OrderVo; -import com.example.service.RemoteRetryService; +import java.util.Random; +import java.util.UUID; @RestController @RequestMapping("/remote") @@ -243,3 +236,4 @@ public boolean localRetryWithTryCatch2(@RequestParam("params") String params) { return remoteRetryService.localRetryWithTryCatch2(params); } } + diff --git a/src/main/java/com/example/controller/WorkflowCallbackController.java b/src/main/java/com/example/controller/WorkflowCallbackController.java index 689af74..1c5600e 100644 --- a/src/main/java/com/example/controller/WorkflowCallbackController.java +++ b/src/main/java/com/example/controller/WorkflowCallbackController.java @@ -8,11 +8,7 @@ import java.util.List; -/** - * @author xiaowoniu - * @date 2024-01-03 21:09:14 - * @since 2.6.0 - */ + @RestController @RequestMapping("/workflow/callback") @Slf4j diff --git a/src/main/java/com/example/controller/WorkflowController.java b/src/main/java/com/example/controller/WorkflowController.java index 3039104..d9aafe7 100644 --- a/src/main/java/com/example/controller/WorkflowController.java +++ b/src/main/java/com/example/controller/WorkflowController.java @@ -3,16 +3,11 @@ import com.example.handler.TestTriggerJobHandler; import com.example.handler.TestUpdateJobStatusHandler; import io.swagger.v3.oas.annotations.Operation; -import io.swagger.v3.oas.annotations.Parameter; import io.swagger.v3.oas.annotations.tags.Tag; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.*; -/** - * @author opensnail - * @date 2024-10-19 10:41:25 - * @since sj_1.2.0-beta2 - */ + @RestController @RequestMapping("/open-api/workflow") @Tag(name = "JobOpenApi", description = "通过OpenApi可以灵活的实现对的Workflow触发和更新状态功能") diff --git a/src/main/java/com/example/customized/MultiParamIdempotentGenerate.java b/src/main/java/com/example/customized/MultiParamIdempotentGenerate.java index 880ebf2..fc01f36 100644 --- a/src/main/java/com/example/customized/MultiParamIdempotentGenerate.java +++ b/src/main/java/com/example/customized/MultiParamIdempotentGenerate.java @@ -1,10 +1,9 @@ package com.example.customized; +import cn.hutool.crypto.SecureUtil; import com.aizuda.snailjob.client.core.IdempotentIdGenerate; import com.aizuda.snailjob.common.core.model.IdempotentIdContext; import com.example.vo.OrderVo; - -import cn.hutool.crypto.SecureUtil; import lombok.extern.slf4j.Slf4j; @Slf4j @@ -23,3 +22,4 @@ public String idGenerate(IdempotentIdContext idempotentIdContext) throws Excepti return SecureUtil.md5(orderVo.getOrderId()); } } + diff --git a/src/main/java/com/example/customized/OrderCompleteCallback.java b/src/main/java/com/example/customized/OrderCompleteCallback.java index 78b1b88..95dcf68 100644 --- a/src/main/java/com/example/customized/OrderCompleteCallback.java +++ b/src/main/java/com/example/customized/OrderCompleteCallback.java @@ -28,7 +28,7 @@ public class OrderCompleteCallback implements RetryCompleteCallback { public void doSuccessCallback(String sceneName, String executorName, Object[] objects) { // 重试成功后删除失败表中的数据 OrderVo orderVo = JsonUtil.parseObject(JsonUtil.toJsonString(objects[1]), OrderVo.class); - log.info("远程重试成功,场景{},执行器{},参数信息", sceneName, executorName, JSONUtil.toJsonStr(objects)); + log.info("远程重试成功,场景{},执行器{},参数信息{}", sceneName, executorName, JSONUtil.toJsonStr(objects)); failOrderBaseMapper.delete( new LambdaQueryWrapper() .eq(FailOrderPo::getOrderId, orderVo.getOrderId()) @@ -44,7 +44,7 @@ public void doSuccessCallback(String sceneName, String executorName, Object[] ob @Override public void doMaxRetryCallback(String sceneName, String executorName, Object[] objects) { OrderVo orderVo = JsonUtil.parseObject(JsonUtil.toJsonString(objects[1]), OrderVo.class); - log.info("远程重试达到最大限度,场景{},执行器{},参数信息", sceneName, executorName, JSONUtil.toJsonStr(objects)); + log.info("远程重试达到最大限度,场景{},执行器{},参数信息{}", sceneName, executorName, JSONUtil.toJsonStr(objects)); // 重试失败后插入订单失败信息 failOrderBaseMapper.insert(FailOrderPo.builder() .orderId(orderVo.getOrderId()) diff --git a/src/main/java/com/example/customized/OrderIdempotentIdGenerate.java b/src/main/java/com/example/customized/OrderIdempotentIdGenerate.java index d43366d..bfcaf63 100644 --- a/src/main/java/com/example/customized/OrderIdempotentIdGenerate.java +++ b/src/main/java/com/example/customized/OrderIdempotentIdGenerate.java @@ -1,11 +1,10 @@ package com.example.customized; +import cn.hutool.crypto.SecureUtil; import com.aizuda.snailjob.client.core.IdempotentIdGenerate; import com.aizuda.snailjob.common.core.model.IdempotentIdContext; import com.example.vo.OrderVo; -import cn.hutool.crypto.SecureUtil; - public class OrderIdempotentIdGenerate implements IdempotentIdGenerate { @@ -17,3 +16,4 @@ public String idGenerate(IdempotentIdContext idempotentIdContext) throws Excepti } } + diff --git a/src/main/java/com/example/customized/OrderRetryMethod.java b/src/main/java/com/example/customized/OrderRetryMethod.java index 60dfdd8..938bad1 100644 --- a/src/main/java/com/example/customized/OrderRetryMethod.java +++ b/src/main/java/com/example/customized/OrderRetryMethod.java @@ -1,12 +1,10 @@ package com.example.customized; -import org.springframework.stereotype.Component; - +import cn.hutool.json.JSONUtil; import com.aizuda.snailjob.client.core.strategy.ExecutorMethod; import com.example.vo.OrderVo; - -import cn.hutool.json.JSONUtil; import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; @Slf4j @Component @@ -20,3 +18,4 @@ public Object doExecute(Object params) { throw new ArithmeticException("自定义的异常处理类处理"); } } + diff --git a/src/main/java/com/example/customized/SingleParamIdempotentGenerate.java b/src/main/java/com/example/customized/SingleParamIdempotentGenerate.java index f3bd60e..eaea827 100644 --- a/src/main/java/com/example/customized/SingleParamIdempotentGenerate.java +++ b/src/main/java/com/example/customized/SingleParamIdempotentGenerate.java @@ -1,10 +1,9 @@ package com.example.customized; +import cn.hutool.crypto.SecureUtil; import com.aizuda.snailjob.client.core.IdempotentIdGenerate; import com.aizuda.snailjob.common.core.model.IdempotentIdContext; -import cn.hutool.crypto.SecureUtil; - public class SingleParamIdempotentGenerate implements IdempotentIdGenerate { @Override @@ -14,3 +13,4 @@ public String idGenerate(IdempotentIdContext idempotentIdContext) throws Excepti return SecureUtil.md5(params); } } + diff --git a/src/main/java/com/example/dao/FailOrderBaseMapper.java b/src/main/java/com/example/dao/FailOrderBaseMapper.java index b5fed83..fa098dc 100644 --- a/src/main/java/com/example/dao/FailOrderBaseMapper.java +++ b/src/main/java/com/example/dao/FailOrderBaseMapper.java @@ -1,11 +1,11 @@ package com.example.dao; -import org.springframework.stereotype.Repository; - import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.example.po.FailOrderPo; +import org.springframework.stereotype.Repository; @Repository public interface FailOrderBaseMapper extends BaseMapper { } + diff --git a/src/main/java/com/example/dao/PhoneNumberBaseMapper.java b/src/main/java/com/example/dao/PhoneNumberBaseMapper.java index 94f6fa3..1f48aa5 100644 --- a/src/main/java/com/example/dao/PhoneNumberBaseMapper.java +++ b/src/main/java/com/example/dao/PhoneNumberBaseMapper.java @@ -6,10 +6,8 @@ /** * 手机号mapper - * - * @author JiChenWang - * @since 2024/6/30 11:55 */ @Repository public interface PhoneNumberBaseMapper extends BaseMapper { } + diff --git a/src/main/java/com/example/dao/PhoneNumberDao.java b/src/main/java/com/example/dao/PhoneNumberDao.java index c26cb72..ead9aa7 100644 --- a/src/main/java/com/example/dao/PhoneNumberDao.java +++ b/src/main/java/com/example/dao/PhoneNumberDao.java @@ -7,12 +7,7 @@ import java.util.List; -/** - * TODO - * - * @author JiChenWang - * @since 2024/6/30 11:58 - */ + @Service public class PhoneNumberDao extends ServiceImpl { @@ -24,11 +19,10 @@ public class PhoneNumberDao extends ServiceImpl phoneNumberPoList) { return this.saveBatch(phoneNumberPoList); } } + diff --git a/src/main/java/com/example/exception/BusinessException.java b/src/main/java/com/example/exception/BusinessException.java index 3c14602..d60c0ac 100644 --- a/src/main/java/com/example/exception/BusinessException.java +++ b/src/main/java/com/example/exception/BusinessException.java @@ -10,3 +10,4 @@ public BusinessException(String message) { } } + diff --git a/src/main/java/com/example/exception/ParamException.java b/src/main/java/com/example/exception/ParamException.java index e129674..58f8739 100644 --- a/src/main/java/com/example/exception/ParamException.java +++ b/src/main/java/com/example/exception/ParamException.java @@ -9,3 +9,4 @@ public ParamException(String message) { } } + diff --git a/src/main/java/com/example/executor/ManualRetryExecutorTask.java b/src/main/java/com/example/executor/ManualRetryExecutorTask.java index e6552cc..3726a08 100644 --- a/src/main/java/com/example/executor/ManualRetryExecutorTask.java +++ b/src/main/java/com/example/executor/ManualRetryExecutorTask.java @@ -1,10 +1,9 @@ package com.example.executor; +import cn.hutool.json.JSONUtil; import com.aizuda.snailjob.client.core.annotation.ExecutorMethodRegister; import com.aizuda.snailjob.client.core.strategy.ExecutorMethod; import com.example.vo.OrderVo; - -import cn.hutool.json.JSONUtil; import lombok.extern.slf4j.Slf4j; @ExecutorMethodRegister(scene = ManualRetryExecutorTask.SCENE) @@ -24,3 +23,4 @@ public Object doExecute(Object params) { return true; } } + diff --git a/src/main/java/com/example/handler/LocalAndRemoteRetryHandler.java b/src/main/java/com/example/handler/LocalAndRemoteRetryHandler.java index e579d65..efec654 100644 --- a/src/main/java/com/example/handler/LocalAndRemoteRetryHandler.java +++ b/src/main/java/com/example/handler/LocalAndRemoteRetryHandler.java @@ -7,11 +7,7 @@ import java.util.Random; -/** - * @author: xiaowoniu - * @date : 2024-02-05 - * @since : 3.1.0 - */ + @Component public class LocalAndRemoteRetryHandler { diff --git a/src/main/java/com/example/handler/OnlyLocalRetryHandler.java b/src/main/java/com/example/handler/OnlyLocalRetryHandler.java index fbbb98d..3208491 100644 --- a/src/main/java/com/example/handler/OnlyLocalRetryHandler.java +++ b/src/main/java/com/example/handler/OnlyLocalRetryHandler.java @@ -7,11 +7,7 @@ import java.util.Random; -/** - * @author: xiaowoniu - * @date : 2024-02-05 - * @since : 3.1.0 - */ + @Component public class OnlyLocalRetryHandler { diff --git a/src/main/java/com/example/handler/OnlyRemoteRetryHandler.java b/src/main/java/com/example/handler/OnlyRemoteRetryHandler.java index c0b7363..63491c0 100644 --- a/src/main/java/com/example/handler/OnlyRemoteRetryHandler.java +++ b/src/main/java/com/example/handler/OnlyRemoteRetryHandler.java @@ -7,11 +7,7 @@ import java.util.Random; -/** - * @author: xiaowoniu - * @date : 2024-02-05 - * @since : 3.1.0 - */ + @Component public class OnlyRemoteRetryHandler { diff --git a/src/main/java/com/example/handler/TestAddJobHandler.java b/src/main/java/com/example/handler/TestAddJobHandler.java index 385ea96..07e413b 100644 --- a/src/main/java/com/example/handler/TestAddJobHandler.java +++ b/src/main/java/com/example/handler/TestAddJobHandler.java @@ -124,3 +124,4 @@ public Long addMapReduceJob(String jobName) { } } + diff --git a/src/main/java/com/example/handler/TestQueryJobHandler.java b/src/main/java/com/example/handler/TestQueryJobHandler.java index 23b8eb0..4420d41 100644 --- a/src/main/java/com/example/handler/TestQueryJobHandler.java +++ b/src/main/java/com/example/handler/TestQueryJobHandler.java @@ -17,3 +17,4 @@ public JobResponseVO queryJob(Long jobId) { return SnailJobOpenApi.getJobDetail(jobId).execute(); } } + diff --git a/src/main/java/com/example/handler/TestTriggerJobHandler.java b/src/main/java/com/example/handler/TestTriggerJobHandler.java index d93bd4e..da44be1 100644 --- a/src/main/java/com/example/handler/TestTriggerJobHandler.java +++ b/src/main/java/com/example/handler/TestTriggerJobHandler.java @@ -26,3 +26,4 @@ public Boolean triggerWorkFlow(Long workFlowId) { return SnailJobOpenApi.triggerWorkFlow(workFlowId).execute(); } } + diff --git a/src/main/java/com/example/handler/TestUpdateJobHandler.java b/src/main/java/com/example/handler/TestUpdateJobHandler.java index 290ad5b..210db70 100644 --- a/src/main/java/com/example/handler/TestUpdateJobHandler.java +++ b/src/main/java/com/example/handler/TestUpdateJobHandler.java @@ -75,3 +75,4 @@ public Boolean updateMapReduceJob(Long jobId) { } } + diff --git a/src/main/java/com/example/handler/TestUpdateJobStatusHandler.java b/src/main/java/com/example/handler/TestUpdateJobStatusHandler.java index 9041be2..9886c55 100644 --- a/src/main/java/com/example/handler/TestUpdateJobStatusHandler.java +++ b/src/main/java/com/example/handler/TestUpdateJobStatusHandler.java @@ -34,3 +34,4 @@ public Boolean updateWorkFlowStatus(Long workFlowId, Long status) { .execute(); } } + diff --git a/src/main/java/com/example/job/TestAnnoJobExecutor.java b/src/main/java/com/example/job/TestAnnoJobExecutor.java index 777f599..cfdffae 100644 --- a/src/main/java/com/example/job/TestAnnoJobExecutor.java +++ b/src/main/java/com/example/job/TestAnnoJobExecutor.java @@ -5,11 +5,7 @@ import com.aizuda.snailjob.client.model.ExecuteResult; import org.springframework.stereotype.Component; -/** - * @author www.byteblogs.com - * @date 2023-09-28 22:54:07 - * @since 2.4.0 - */ + @Component @JobExecutor(name = "testJobExecutor") public class TestAnnoJobExecutor { diff --git a/src/main/java/com/example/job/TestAnnoJobExecutorSleep10s.java b/src/main/java/com/example/job/TestAnnoJobExecutorSleep10s.java index a9300e2..77b1e4e 100644 --- a/src/main/java/com/example/job/TestAnnoJobExecutorSleep10s.java +++ b/src/main/java/com/example/job/TestAnnoJobExecutorSleep10s.java @@ -6,11 +6,7 @@ import com.aizuda.snailjob.common.core.util.JsonUtil; import org.springframework.stereotype.Component; -/** - * @author www.byteblogs.com - * @date 2023-09-28 22:54:07 - * @since 2.4.0 - */ + @Component @JobExecutor(name = "testAnnoJobExecutorSleep10s") public class TestAnnoJobExecutorSleep10s { diff --git a/src/main/java/com/example/job/TestAnnoJobExecutorSleep1s.java b/src/main/java/com/example/job/TestAnnoJobExecutorSleep1s.java index 51e8f8f..b035fc6 100644 --- a/src/main/java/com/example/job/TestAnnoJobExecutorSleep1s.java +++ b/src/main/java/com/example/job/TestAnnoJobExecutorSleep1s.java @@ -6,11 +6,7 @@ import com.aizuda.snailjob.common.core.util.JsonUtil; import org.springframework.stereotype.Component; -/** - * @author www.byteblogs.com - * @date 2023-09-28 22:54:07 - * @since 2.4.0 - */ + @Component @JobExecutor(name = "testAnnoJobExecutorSleep1s") public class TestAnnoJobExecutorSleep1s { diff --git a/src/main/java/com/example/job/TestAnnoJobExecutorSleep30s.java b/src/main/java/com/example/job/TestAnnoJobExecutorSleep30s.java index a3e0afb..9320069 100644 --- a/src/main/java/com/example/job/TestAnnoJobExecutorSleep30s.java +++ b/src/main/java/com/example/job/TestAnnoJobExecutorSleep30s.java @@ -6,11 +6,7 @@ import com.aizuda.snailjob.common.core.util.JsonUtil; import org.springframework.stereotype.Component; -/** - * @author www.byteblogs.com - * @date 2023-09-28 22:54:07 - * @since 2.4.0 - */ + @Component @JobExecutor(name = "testAnnoJobExecutorSleep30s") public class TestAnnoJobExecutorSleep30s { diff --git a/src/main/java/com/example/job/TestAnnoJobExecutorSleep5s.java b/src/main/java/com/example/job/TestAnnoJobExecutorSleep5s.java index 0a17c17..cb23005 100644 --- a/src/main/java/com/example/job/TestAnnoJobExecutorSleep5s.java +++ b/src/main/java/com/example/job/TestAnnoJobExecutorSleep5s.java @@ -7,11 +7,7 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; -/** - * @author www.byteblogs.com - * @date 2023-09-28 22:54:07 - * @since 2.4.0 - */ + @Component @Slf4j @JobExecutor(name = "testAnnoJobExecutorSleep5s") diff --git a/src/main/java/com/example/job/TestAnnoMapJobExecutor.java b/src/main/java/com/example/job/TestAnnoMapJobExecutor.java index 4f6da29..e2ec81d 100644 --- a/src/main/java/com/example/job/TestAnnoMapJobExecutor.java +++ b/src/main/java/com/example/job/TestAnnoMapJobExecutor.java @@ -8,10 +8,7 @@ import com.google.common.collect.Lists; import org.springframework.stereotype.Component; -/** - * @author: opensnail - * @date : 2024-06-26 - */ + @Component @JobExecutor(name = "testAnnoMapJobExecutor") public class TestAnnoMapJobExecutor { @@ -38,3 +35,4 @@ public ExecuteResult lastMapExecute(MapArgs mapArgs, MapHandler mapHandler) { } } + diff --git a/src/main/java/com/example/job/TestAnnoMapReduceJobExecutor.java b/src/main/java/com/example/job/TestAnnoMapReduceJobExecutor.java index c976281..cfc2e97 100644 --- a/src/main/java/com/example/job/TestAnnoMapReduceJobExecutor.java +++ b/src/main/java/com/example/job/TestAnnoMapReduceJobExecutor.java @@ -9,17 +9,10 @@ import com.aizuda.snailjob.client.job.core.dto.MergeReduceArgs; import com.aizuda.snailjob.client.job.core.dto.ReduceArgs; import com.aizuda.snailjob.client.model.ExecuteResult; -import com.aizuda.snailjob.common.core.util.JsonUtil; import com.google.common.collect.Lists; import org.springframework.stereotype.Component; -import java.util.List; -import java.util.stream.Collectors; -/** - * @author: opensnail - * @date : 2024-06-26 - */ @Component @JobExecutor(name = "testAnnoMapReduceJobExecutor") public class TestAnnoMapReduceJobExecutor { diff --git a/src/main/java/com/example/job/TestBroadcastJobExecutor.java b/src/main/java/com/example/job/TestBroadcastJobExecutor.java index faf506e..349d239 100644 --- a/src/main/java/com/example/job/TestBroadcastJobExecutor.java +++ b/src/main/java/com/example/job/TestBroadcastJobExecutor.java @@ -1,10 +1,5 @@ package com.example.job; -/** - * @author zhengweilin - * @version 1.0.0 - * @date 2024/01/22 - */ import com.aizuda.snailjob.client.job.core.annotation.JobExecutor; import com.aizuda.snailjob.client.job.core.dto.JobArgs; diff --git a/src/main/java/com/example/job/TestClassJobExecutor.java b/src/main/java/com/example/job/TestClassJobExecutor.java index 404dcdb..d4126dd 100644 --- a/src/main/java/com/example/job/TestClassJobExecutor.java +++ b/src/main/java/com/example/job/TestClassJobExecutor.java @@ -5,11 +5,7 @@ import com.aizuda.snailjob.client.model.ExecuteResult; import org.springframework.stereotype.Component; -/** - * @author www.byteblogs.com - * @date 2023-09-28 22:54:07 - * @since 2.4.0 - */ + @Component public class TestClassJobExecutor extends AbstractJobExecutor { diff --git a/src/main/java/com/example/job/TestExcelAnalyseMapJobExecutor.java b/src/main/java/com/example/job/TestExcelAnalyseMapJobExecutor.java index a82e5ba..17e3173 100644 --- a/src/main/java/com/example/job/TestExcelAnalyseMapJobExecutor.java +++ b/src/main/java/com/example/job/TestExcelAnalyseMapJobExecutor.java @@ -23,9 +23,6 @@ /** * 解析excel文件中的手机号码,并将错误的手机号分片入库 - * - * @author JiChenWang - * @since 2024/6/30 10:37 */ @Slf4j @Component @@ -42,8 +39,6 @@ public class TestExcelAnalyseMapJobExecutor { * 比如文档中的手机号总量为307条,每100条一个分组,分组结果为[{0,99}, {100, 199}, {200,299}, {300, 307}] * * @return ExecuteResult - * @author JichenWang - * @since 2024/6/30 10:48 */ @MapExecutor public ExecuteResult rootMapExecute(MapArgs mapArgs, MapHandler> mapHandler) { @@ -58,7 +53,7 @@ public ExecuteResult rootMapExecute(MapArgs mapArgs, MapHandler> mapH // 设置区间范围 ranges = TestMapReduceJobExecutor.doSharding(0L, phoneNumberCheckBo.getTotal(), BATCH_SIZE); } catch (Exception e) { - log.error("文件读取异常", e.getMessage()); + log.error("文件读取异常{}", e.getMessage()); } return mapHandler.doMap(ranges, "TWO_MAP"); @@ -67,8 +62,6 @@ public ExecuteResult rootMapExecute(MapArgs mapArgs, MapHandler> mapH /** * @param mapArgs * @return ExecuteResult - * @author JichenWang - * @since 2024/6/30 11:05 */ @MapExecutor(taskName = "TWO_MAP") public ExecuteResult monthMapExecute(MapArgs mapArgs) { @@ -83,7 +76,7 @@ public ExecuteResult monthMapExecute(MapArgs mapArgs) { PhoneNumberExcelListener phoneNumberExcelListener = new PhoneNumberExcelListener(phoneNumberCheckBo, false, BATCH_SIZE); EasyExcel.read(numberInputStream, PhoneNumberBo.class, phoneNumberExcelListener).sheet().headRowNumber(mapResult.get(0) + 1).doReadSync(); } catch (Exception e) { - log.error("文件读取异常:", e.getMessage()); + log.error("文件读取异常:{}", e.getMessage()); } // 如果正确手机号不为空,则入库 diff --git a/src/main/java/com/example/job/TestExcelAnalyseMapReduceJobExecutor.java b/src/main/java/com/example/job/TestExcelAnalyseMapReduceJobExecutor.java index aeaeb9a..5fbd1f5 100644 --- a/src/main/java/com/example/job/TestExcelAnalyseMapReduceJobExecutor.java +++ b/src/main/java/com/example/job/TestExcelAnalyseMapReduceJobExecutor.java @@ -24,9 +24,6 @@ /** * 解析校验Excel中的手机号,统计出错手机号数量,并返回错误手机号详情 - * - * @author JichenWang - * @since 2024/6/27 19:52 */ @Slf4j @Component @@ -40,8 +37,6 @@ public class TestExcelAnalyseMapReduceJobExecutor { * 比如文档中的手机号总量为307条,每100条一个分组,分组结果为[{0,99}, {100, 199}, {200,299}, {300, 307}] * * @return ExecuteResult - * @author JichenWang - * @since 2024/6/29 14:03 */ @MapExecutor public ExecuteResult rootMapExecute(MapArgs mapArgs, MapHandler> mapHandler) { @@ -56,7 +51,7 @@ public ExecuteResult rootMapExecute(MapArgs mapArgs, MapHandler> mapH // 设置区间范围 ranges = TestMapReduceJobExecutor.doSharding(0L, phoneNumberCheckBo.getTotal(), BATCH_SIZE); } catch (Exception e) { - log.error("文件读取异常", e.getMessage()); + log.error("文件读取异常: {}", e.getMessage()); } return mapHandler.doMap(ranges, "TWO_MAP"); } @@ -65,8 +60,6 @@ public ExecuteResult rootMapExecute(MapArgs mapArgs, MapHandler> mapH * 处理每个分组内容,如读取{0,99}区间的手机号,并解析 * * @return ExecuteResult - * @author JichenWang - * @since 2024/6/29 14:04 */ @MapExecutor(taskName = "TWO_MAP") public ExecuteResult monthMapExecute(MapArgs mapArgs) { @@ -81,7 +74,7 @@ public ExecuteResult monthMapExecute(MapArgs mapArgs) { PhoneNumberExcelListener phoneNumberExcelListener = new PhoneNumberExcelListener(phoneNumberCheckBo, false, BATCH_SIZE); EasyExcel.read(numberInputStream, PhoneNumberBo.class, phoneNumberExcelListener).sheet().headRowNumber(mapResult.get(0) + 1).doReadSync(); } catch (Exception e) { - log.error("文件读取异常:", e.getMessage()); + log.error("文件读取异常:{}", e.getMessage()); } return ExecuteResult.success(phoneNumberCheckBo); @@ -110,8 +103,6 @@ public ExecuteResult mergeReduceExecute(MergeReduceArgs mergeReduceArgs) { * * @param phoneNumberCheckBoStr 手机号校验BO字符串 * @return PhoneNumberCheckBo 汇总手机号校验结果BO - * @author JichenWang - * @since 2024/6/29 14:24 */ private PhoneNumberCheckBo buildGatherPhoneNumberCheckBo(String phoneNumberCheckBoStr) { final List phoneNumberCheckBoList = JSONArray.parseArray(phoneNumberCheckBoStr, PhoneNumberCheckBo.class); diff --git a/src/main/java/com/example/job/TestMapJobExecutor.java b/src/main/java/com/example/job/TestMapJobExecutor.java index 2f1cf0f..f652e9c 100644 --- a/src/main/java/com/example/job/TestMapJobExecutor.java +++ b/src/main/java/com/example/job/TestMapJobExecutor.java @@ -2,7 +2,6 @@ import com.aizuda.snailjob.client.job.core.MapHandler; import com.aizuda.snailjob.client.job.core.dto.MapArgs; - import com.aizuda.snailjob.client.job.core.executor.AbstractMapExecutor; import com.aizuda.snailjob.client.model.ExecuteResult; import com.aizuda.snailjob.common.core.util.JsonUtil; @@ -23,10 +22,6 @@ /** * 以下是一个统计某电商公司商家的一年的营业额的计算过程 - * - * @author: opensnail - * @date : 2024-06-13 - * @since : sj_1.1.0 */ @Component public class TestMapJobExecutor extends AbstractMapExecutor { diff --git a/src/main/java/com/example/job/TestMapReduceJobExecutor.java b/src/main/java/com/example/job/TestMapReduceJobExecutor.java index a3515c6..b8456e2 100644 --- a/src/main/java/com/example/job/TestMapReduceJobExecutor.java +++ b/src/main/java/com/example/job/TestMapReduceJobExecutor.java @@ -25,10 +25,6 @@ /** * 以下是一个统计某电商公司商家的一年的营业额的计算过程 - * - * @author: opensnail - * @date : 2024-06-13 - * @since : sj_1.1.0 */ @Component public class TestMapReduceJobExecutor extends AbstractMapReduceExecutor { @@ -56,7 +52,6 @@ public ExecuteResult doJobMapExecute(MapArgs mapArgs, MapHandler mapHandler) { // 模拟统计营业额 int turnover = new Random().nextInt(1000000); return ExecuteResult.success(turnover); - } @Override diff --git a/src/main/java/com/example/job/TestMyMapExecutor.java b/src/main/java/com/example/job/TestMyMapExecutor.java index ddf1cc9..cb9e2c7 100644 --- a/src/main/java/com/example/job/TestMyMapExecutor.java +++ b/src/main/java/com/example/job/TestMyMapExecutor.java @@ -2,22 +2,13 @@ import com.aizuda.snailjob.client.job.core.MapHandler; import com.aizuda.snailjob.client.job.core.dto.MapArgs; -import com.aizuda.snailjob.client.job.core.dto.MergeReduceArgs; -import com.aizuda.snailjob.client.job.core.dto.ReduceArgs; import com.aizuda.snailjob.client.job.core.executor.AbstractMapExecutor; -import com.aizuda.snailjob.client.job.core.executor.AbstractMapReduceExecutor; import com.aizuda.snailjob.client.model.ExecuteResult; import com.aizuda.snailjob.common.core.constant.SystemConstants; import com.google.common.collect.Lists; import org.springframework.stereotype.Component; -import java.util.List; -/** - * @author opensnail - * @date 2024-07-07 12:06:57 - * @since sj_1.1.0 - */ @Component public class TestMyMapExecutor extends AbstractMapExecutor { diff --git a/src/main/java/com/example/job/TestMyMapReduceExecutor.java b/src/main/java/com/example/job/TestMyMapReduceExecutor.java index ebba70c..0c913cf 100644 --- a/src/main/java/com/example/job/TestMyMapReduceExecutor.java +++ b/src/main/java/com/example/job/TestMyMapReduceExecutor.java @@ -12,11 +12,7 @@ import java.util.List; -/** - * @author opensnail - * @date 2024-07-07 12:06:57 - * @since sj_1.1.0 - */ + @Component public class TestMyMapReduceExecutor extends AbstractMapReduceExecutor { diff --git a/src/main/java/com/example/job/TestPartitionJobExecutor.java b/src/main/java/com/example/job/TestPartitionJobExecutor.java index e7e2097..b9f2c73 100644 --- a/src/main/java/com/example/job/TestPartitionJobExecutor.java +++ b/src/main/java/com/example/job/TestPartitionJobExecutor.java @@ -1,10 +1,5 @@ package com.example.job; -/** - * @author zhengweilin - * @version 1.0.0 - * @date 2024/01/22 - */ import com.aizuda.snailjob.client.job.core.annotation.JobExecutor; import com.aizuda.snailjob.client.job.core.dto.JobArgs; diff --git a/src/main/java/com/example/job/TestSyncLogPrintExecutor.java b/src/main/java/com/example/job/TestSyncLogPrintExecutor.java index c157592..bc20555 100644 --- a/src/main/java/com/example/job/TestSyncLogPrintExecutor.java +++ b/src/main/java/com/example/job/TestSyncLogPrintExecutor.java @@ -15,9 +15,7 @@ import java.util.concurrent.TimeUnit; /** - * @author PT - * @date 2024-09-02 上午10:50 - * @Description 线程异步情况下日志打印,场景:定时调用接口更新数据, + * 线程异步情况下日志打印,场景:定时调用接口更新数据, * 由于数据量每天大小不一致,无法界定执行时间,所以需要异步执行,但是异步执行时日志也需要进行打印 */ @Slf4j diff --git a/src/main/java/com/example/job/TestWorkflowAnnoJobExecutor.java b/src/main/java/com/example/job/TestWorkflowAnnoJobExecutor.java index f92ba24..9f2591a 100644 --- a/src/main/java/com/example/job/TestWorkflowAnnoJobExecutor.java +++ b/src/main/java/com/example/job/TestWorkflowAnnoJobExecutor.java @@ -3,18 +3,13 @@ import com.aizuda.snailjob.client.job.core.annotation.JobExecutor; import com.aizuda.snailjob.client.job.core.dto.JobArgs; import com.aizuda.snailjob.client.model.ExecuteResult; -import com.aizuda.snailjob.common.core.util.JsonUtil; import com.aizuda.snailjob.common.log.SnailJobLog; import com.example.po.FailOrderPo; import org.springframework.stereotype.Component; import java.util.Random; -/** - * @author www.byteblogs.com - * @date 2023-09-28 22:54:07 - * @since 2.6.0 - */ + @Component @JobExecutor(name = "testWorkflowAnnoJobExecutor") public class TestWorkflowAnnoJobExecutor { diff --git a/src/main/java/com/example/listener/MySnailJobListener.java b/src/main/java/com/example/listener/MySnailJobListener.java index ddcf051..526a2a4 100644 --- a/src/main/java/com/example/listener/MySnailJobListener.java +++ b/src/main/java/com/example/listener/MySnailJobListener.java @@ -20,3 +20,4 @@ public void failureOnRetry(String sceneName, String executorClassName, Throwable } } + diff --git a/src/main/java/com/example/listener/PhoneNumberExcelListener.java b/src/main/java/com/example/listener/PhoneNumberExcelListener.java index 725a356..bf694e7 100644 --- a/src/main/java/com/example/listener/PhoneNumberExcelListener.java +++ b/src/main/java/com/example/listener/PhoneNumberExcelListener.java @@ -76,3 +76,4 @@ public PhoneNumberExcelListener(PhoneNumberCheckBo phoneNumberCheckBo, Boolean f this.batchSize = batchSize; } } + diff --git a/src/main/java/com/example/listener/SnailJobChannelReconnectListener.java b/src/main/java/com/example/listener/SnailJobChannelReconnectListener.java index b983160..7f02714 100644 --- a/src/main/java/com/example/listener/SnailJobChannelReconnectListener.java +++ b/src/main/java/com/example/listener/SnailJobChannelReconnectListener.java @@ -13,3 +13,4 @@ public void onApplicationEvent(SnailChannelReconnectEvent event) { SnailJobLog.LOCAL.info("这个一个重连事件"); } } + diff --git a/src/main/java/com/example/listener/SnailJobClosedListener.java b/src/main/java/com/example/listener/SnailJobClosedListener.java index aae0ec5..a2e4250 100644 --- a/src/main/java/com/example/listener/SnailJobClosedListener.java +++ b/src/main/java/com/example/listener/SnailJobClosedListener.java @@ -13,3 +13,4 @@ public void onApplicationEvent(SnailClientClosedEvent event) { SnailJobLog.LOCAL.info("这是一个SnailJob关闭完成事件"); } } + diff --git a/src/main/java/com/example/listener/SnailJobClosingListener.java b/src/main/java/com/example/listener/SnailJobClosingListener.java index fc5d779..74cf84f 100644 --- a/src/main/java/com/example/listener/SnailJobClosingListener.java +++ b/src/main/java/com/example/listener/SnailJobClosingListener.java @@ -13,3 +13,4 @@ public void onApplicationEvent(SnailClientClosingEvent event) { SnailJobLog.LOCAL.info("这是一个SnailJob开始关闭事件"); } } + diff --git a/src/main/java/com/example/listener/SnailJobStartedListener.java b/src/main/java/com/example/listener/SnailJobStartedListener.java index b3fa612..4a432c6 100644 --- a/src/main/java/com/example/listener/SnailJobStartedListener.java +++ b/src/main/java/com/example/listener/SnailJobStartedListener.java @@ -13,3 +13,4 @@ public void onApplicationEvent(SnailClientStartedEvent event) { SnailJobLog.LOCAL.info("这是一个SnailJob启动完成事件"); } } + diff --git a/src/main/java/com/example/listener/SnailJobStartingListener.java b/src/main/java/com/example/listener/SnailJobStartingListener.java index 12e3784..372e094 100644 --- a/src/main/java/com/example/listener/SnailJobStartingListener.java +++ b/src/main/java/com/example/listener/SnailJobStartingListener.java @@ -13,3 +13,4 @@ public void onApplicationEvent(SnailClientStartingEvent event) { SnailJobLog.LOCAL.info("这是一个SnailJob启动事件"); } } + diff --git a/src/main/java/com/example/po/FailOrderPo.java b/src/main/java/com/example/po/FailOrderPo.java index d9bbf31..030fd99 100644 --- a/src/main/java/com/example/po/FailOrderPo.java +++ b/src/main/java/com/example/po/FailOrderPo.java @@ -1,16 +1,15 @@ package com.example.po; -import java.time.LocalDateTime; - import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; - import lombok.AllArgsConstructor; import lombok.Builder; import lombok.Data; import lombok.NoArgsConstructor; +import java.time.LocalDateTime; + /** * 处理失败的订单信息表 */ @@ -39,3 +38,4 @@ public class FailOrderPo { private LocalDateTime updateDate; } + diff --git a/src/main/java/com/example/po/PhoneNumberPo.java b/src/main/java/com/example/po/PhoneNumberPo.java index 5b1b204..f30a657 100644 --- a/src/main/java/com/example/po/PhoneNumberPo.java +++ b/src/main/java/com/example/po/PhoneNumberPo.java @@ -10,9 +10,6 @@ /** * phone_number - * - * @author JiChenWang - * @since 2024/6/30 11:48 */ @TableName("phone_number") @Data diff --git a/src/main/java/com/example/service/LocalRemoteService.java b/src/main/java/com/example/service/LocalRemoteService.java index ca37c72..b47fb87 100644 --- a/src/main/java/com/example/service/LocalRemoteService.java +++ b/src/main/java/com/example/service/LocalRemoteService.java @@ -1,9 +1,6 @@ package com.example.service; -/** - * @author: www.byteblogs.com - * @date : 2023-09-06 09:02 - */ + public interface LocalRemoteService { void localRemote(); diff --git a/src/main/java/com/example/service/LocalRetryService.java b/src/main/java/com/example/service/LocalRetryService.java index 2e452cd..e91d333 100644 --- a/src/main/java/com/example/service/LocalRetryService.java +++ b/src/main/java/com/example/service/LocalRetryService.java @@ -4,10 +4,7 @@ import com.aizuda.snailjob.client.core.retryer.RetryType; import com.example.vo.OrderVo; -/** - * @author: www.byteblogs.com - * @date : 2023-09-06 09:03 - */ + public interface LocalRetryService { void localRetry(String params); diff --git a/src/main/java/com/example/service/ManualRetryExecutorMethodService.java b/src/main/java/com/example/service/ManualRetryExecutorMethodService.java index 4e859c5..c84bfd4 100644 --- a/src/main/java/com/example/service/ManualRetryExecutorMethodService.java +++ b/src/main/java/com/example/service/ManualRetryExecutorMethodService.java @@ -1,9 +1,6 @@ package com.example.service; -/** - * @author: www.byteblogs.com - * @date : 2023-09-06 09:04 - */ + public interface ManualRetryExecutorMethodService { void myExecutorMethod(String params); diff --git a/src/main/java/com/example/service/RemoteRetryService.java b/src/main/java/com/example/service/RemoteRetryService.java index 6faf082..49b96b5 100644 --- a/src/main/java/com/example/service/RemoteRetryService.java +++ b/src/main/java/com/example/service/RemoteRetryService.java @@ -2,10 +2,7 @@ import com.example.vo.OrderVo; -/** - * @author: www.byteblogs.com - * @date : 2023-09-06 09:04 - */ + public interface RemoteRetryService { void remoteRetry(String params); diff --git a/src/main/java/com/example/service/impl/LocalRemoteServiceImpl.java b/src/main/java/com/example/service/impl/LocalRemoteServiceImpl.java index fd59c0b..0dc0348 100644 --- a/src/main/java/com/example/service/impl/LocalRemoteServiceImpl.java +++ b/src/main/java/com/example/service/impl/LocalRemoteServiceImpl.java @@ -12,10 +12,6 @@ /** * 模拟先本地再远程重试案例 - * - * @author www.byteblogs.com - * @date 2023-07-18 22:19:30 - * @since 2.1.0 */ @Service @RequiredArgsConstructor @@ -89,3 +85,4 @@ public boolean localRetryWithTwoRetryMethod(String params) { } } + diff --git a/src/main/java/com/example/service/impl/LocalRetryServiceImpl.java b/src/main/java/com/example/service/impl/LocalRetryServiceImpl.java index d451a58..7590aba 100644 --- a/src/main/java/com/example/service/impl/LocalRetryServiceImpl.java +++ b/src/main/java/com/example/service/impl/LocalRetryServiceImpl.java @@ -1,17 +1,16 @@ package com.example.service.impl; +import com.aizuda.snailjob.client.core.annotation.Retryable; import com.aizuda.snailjob.client.core.retryer.RetryType; import com.example.customized.OrderRetryMethod; +import com.example.exception.ParamException; import com.example.handler.OnlyLocalRetryHandler; import com.example.service.LocalRetryService; import com.example.vo.OrderVo; -import com.example.exception.ParamException; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; -import com.aizuda.snailjob.client.core.annotation.Retryable; - /** * snail-job中的本地重试demo */ @@ -157,3 +156,4 @@ public boolean localRetryWithTryCatch2(String params) { } } + diff --git a/src/main/java/com/example/service/impl/ManualRetryExecutorMethodServiceImpl.java b/src/main/java/com/example/service/impl/ManualRetryExecutorMethodServiceImpl.java index f1e7109..bb15654 100644 --- a/src/main/java/com/example/service/impl/ManualRetryExecutorMethodServiceImpl.java +++ b/src/main/java/com/example/service/impl/ManualRetryExecutorMethodServiceImpl.java @@ -31,3 +31,4 @@ public void myExecutorMethod(String params) { } } + diff --git a/src/main/java/com/example/service/impl/RemoteRetryServiceImpl.java b/src/main/java/com/example/service/impl/RemoteRetryServiceImpl.java index 9da8a9b..b7bf9e4 100644 --- a/src/main/java/com/example/service/impl/RemoteRetryServiceImpl.java +++ b/src/main/java/com/example/service/impl/RemoteRetryServiceImpl.java @@ -1,24 +1,19 @@ package com.example.service.impl; -import java.util.concurrent.TimeUnit; - import cn.hutool.core.lang.Assert; +import com.aizuda.snailjob.client.core.annotation.Retryable; import com.aizuda.snailjob.client.core.intercepter.RetrySiteSnapshot; +import com.aizuda.snailjob.client.core.retryer.RetryType; import com.aizuda.snailjob.common.core.enums.RetryStatusEnum; +import com.example.customized.*; import com.example.handler.OnlyRemoteRetryHandler; import com.example.service.RemoteRetryService; +import com.example.vo.OrderVo; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; -import com.aizuda.snailjob.client.core.annotation.Retryable; -import com.aizuda.snailjob.client.core.retryer.RetryType; -import com.example.customized.MultiParamIdempotentGenerate; -import com.example.customized.OrderIdempotentIdGenerate; -import com.example.customized.OrderCompleteCallback; -import com.example.customized.OrderRetryMethod; -import com.example.customized.SingleParamIdempotentGenerate; -import com.example.vo.OrderVo; +import java.util.concurrent.TimeUnit; /** * snail-job中的远程重试 @@ -163,3 +158,4 @@ public boolean remoteRetryWithCompleteCallback(String scene, OrderVo orderVo) { } + diff --git a/src/main/java/com/example/spi/MySnailJobListener.java b/src/main/java/com/example/spi/MySnailJobListener.java index bb67603..2a3bc64 100644 --- a/src/main/java/com/example/spi/MySnailJobListener.java +++ b/src/main/java/com/example/spi/MySnailJobListener.java @@ -4,10 +4,7 @@ import com.aizuda.snailjob.common.core.util.JsonUtil; import lombok.extern.slf4j.Slf4j; -/** - * @author: www.byteblogs.com - * @date : 2023-08-28 11:20 - */ + @Slf4j public class MySnailJobListener implements SnailJobListener { diff --git a/src/main/java/com/example/spi/TTLRetrySiteSnapshotContext.java b/src/main/java/com/example/spi/TTLRetrySiteSnapshotContext.java index 68866f1..b69fcdf 100644 --- a/src/main/java/com/example/spi/TTLRetrySiteSnapshotContext.java +++ b/src/main/java/com/example/spi/TTLRetrySiteSnapshotContext.java @@ -3,10 +3,7 @@ import com.aizuda.snailjob.client.core.RetrySiteSnapshotContext; import com.alibaba.ttl.TransmittableThreadLocal; -/** - * @author: www.byteblogs.com - * @date : 2023-08-28 11:30 - */ + public class TTLRetrySiteSnapshotContext implements RetrySiteSnapshotContext { private final ThreadLocal threadLocal; diff --git a/src/main/java/com/example/util/CodeGen.java b/src/main/java/com/example/util/CodeGen.java index 2e82204..75afff1 100644 --- a/src/main/java/com/example/util/CodeGen.java +++ b/src/main/java/com/example/util/CodeGen.java @@ -45,3 +45,4 @@ public static void main(String[] args) { } } + diff --git a/src/main/java/com/example/vo/OrderVo.java b/src/main/java/com/example/vo/OrderVo.java index 5f33af9..7be0cdc 100644 --- a/src/main/java/com/example/vo/OrderVo.java +++ b/src/main/java/com/example/vo/OrderVo.java @@ -1,10 +1,5 @@ package com.example.vo; -import java.math.BigDecimal; -import java.time.LocalDateTime; -import java.util.List; - -//import io.swagger.annotations.ApiModelProperty; import io.swagger.v3.oas.annotations.media.Schema; import lombok.AllArgsConstructor; import lombok.Builder; @@ -21,3 +16,4 @@ public class OrderVo { @Schema(description = "订单来源信息,1-手机端下单 2-PC端下单", accessMode = Schema.AccessMode.READ_WRITE) private Integer source; // 订单来源信息,1-手机端下单 2-PC端下单 } + diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index d0b2516..d57c770 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -44,7 +44,7 @@ snail-job: # 任务调度服务器信息 server: # 服务器IP地址(或域名);集群时建议通过 nginx 做负载均衡 - host: 127.0.0.1 + host: 10.125.60.86 # 服务器通讯端口(不是后台管理页面服务端口) port: 1788 # 命名空间 @@ -54,6 +54,6 @@ snail-job: # 接入组 token token: SJ_Wyz3dmsdbDOkDujOTSSoBjGQP1BMsVnj # 客户端绑定IP,必须服务器可以访问到;默认自动推断,在服务器无法调度客户端时需要手动配置 - host: 127.0.0.1 + host: 10.125.60.86 # 客户端通讯端口,默认 1789 port: 1789