update

simbabdytech · Dec 19, 2024 · c71b909 · c71b909
1 parent 90979a1
commit c71b909
Show file tree

Hide file tree

Showing 68 changed files with 90 additions and 257 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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<FailOrderPo>()
                         .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
@@ -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
@@ -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
@@ -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
@@ -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<FailOrderPo> {
 
 }
+
diff --git 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<PhoneNumberPo> {
 }
+
diff --git 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<PhoneNumberBaseMapper, PhoneNumberPo> {
 
@@ -24,11 +19,10 @@ public class PhoneNumberDao extends ServiceImpl<PhoneNumberBaseMapper, PhoneNumb
      *
      * @param phoneNumberPoList 手机号po列表
      * @return Boolean  保存成功标识：true-成功、false-失败
-     * @author JichenWang
-     * @since 2024/6/30 12:03
      */
     public Boolean insertBatch(List<PhoneNumberPo> 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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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
@@ -26,3 +26,4 @@ public Boolean triggerWorkFlow(Long workFlowId) {
         return SnailJobOpenApi.triggerWorkFlow(workFlowId).execute();
     }
 }
+
Original file line number	Diff line number	Diff line change
Expand Up		@@ -115,3 +115,4 @@ public boolean localRetryWithTryCatch2(@RequestParam("params") String params) {
		return localRemoteService.localRetryWithTryCatch2(params);
		}
		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -10,3 +10,4 @@ public BusinessException(String message) {
		}

		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -9,3 +9,4 @@ public ParamException(String message) {
		}

		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -124,3 +124,4 @@ public Long addMapReduceJob(String jobName) {

		}
		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -17,3 +17,4 @@ public JobResponseVO queryJob(Long jobId) {
		return SnailJobOpenApi.getJobDetail(jobId).execute();
		}
		}
Original file line number	Diff line number	Diff line change
Expand Up		@@ -26,3 +26,4 @@ public Boolean triggerWorkFlow(Long workFlowId) {
		return SnailJobOpenApi.triggerWorkFlow(workFlowId).execute();
		}
		}