框架任务api增加，增删改接口及实现

snowy-plugin/snowy-plugin-dev/snowy-plugin-dev-func/src/main/java/vip/xiaonuo/dev/modular/job/provider/DevJobApiProvider.java

@@ -12,8 +12,19 @@
  */
 package vip.xiaonuo.dev.modular.job.provider;
 
+import com.alibaba.fastjson.JSONObject;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import vip.xiaonuo.dev.api.DevJobApi;
+import vip.xiaonuo.dev.modular.job.entity.DevJob;
+import vip.xiaonuo.dev.modular.job.param.DevJobAddParam;
+import vip.xiaonuo.dev.modular.job.param.DevJobEditParam;
+import vip.xiaonuo.dev.modular.job.param.DevJobIdParam;
+import vip.xiaonuo.dev.modular.job.service.DevJobService;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * 定时任务API接口实现类
@@ -21,6 +32,71 @@ import vip.xiaonuo.dev.api.DevJobApi;
  * @author xuyuxiang
  * @date 2022/9/2 16:06
  */
+@Slf4j
 @Service
 public class DevJobApiProvider implements DevJobApi {
+    @Resource
+    private DevJobService devJobService;
+
+    @Override
+    public JSONObject addJob(JSONObject addParam) {
+        JSONObject result = new JSONObject();
+        try {
+            DevJobAddParam devJobAddParam = JSONObject.toJavaObject(addParam, DevJobAddParam.class);
+            DevJob devJob = devJobService.add(devJobAddParam);
+            result.put("data", devJob);
+            result.put("code", 200);
+            result.put("msg", "任务添加成功");
+            return result;
+        } catch (Exception e) {
+            log.error("任务添加失败", e);
+            return JSONObject.parseObject("{\"code\":500,\"msg\":\"任务添加失败\"}");
+        }
+    }
+
+    @Override
+    public JSONObject editJob(JSONObject editParam) {
+        JSONObject result = new JSONObject();
+        try {
+            String jobId = editParam.getString("id");
+            if(jobId == null || jobId.isEmpty()){
+                return JSONObject.parseObject("{\"code\":500,\"msg\":\"入参任务ID不存在\"}");
+            }
+            DevJob devJob = devJobService.queryEntity(jobId);
+            if(devJob == null){
+                return JSONObject.parseObject("{\"code\":500,\"msg\":\"ID:"+jobId+" 此任务不存在\"}");
+            }
+            DevJobEditParam devJobEditParam = JSONObject.toJavaObject(editParam, DevJobEditParam.class);
+            devJobService.edit(devJobEditParam);
+            result.put("code", 200);
+            result.put("msg", "任务添加成功");
+            return result;
+        } catch (Exception e) {
+            log.error("任务修改失败", e);
+            return JSONObject.parseObject("{\"code\":500,\"msg\":\"任务修改失败\"}");
+        }
+    }
+
+    @Override
+    public JSONObject deleteJob(List<String> ids) {
+        JSONObject result = new JSONObject();
+        try {
+            if(ids == null || ids.isEmpty()){
+                return JSONObject.parseObject("{\"code\":500,\"msg\":\"入参任务ID集合不存在\"}");
+            }
+            List<DevJobIdParam> devJobIdParamList = new ArrayList<DevJobIdParam>();
+            for(String id : ids){
+                DevJobIdParam devJobIdParam = new DevJobIdParam();
+                devJobIdParam.setId(id);
+                devJobIdParamList.add(devJobIdParam);
+            }
+            devJobService.delete(devJobIdParamList);
+            result.put("code", 200);
+            result.put("msg", "任务删除成功");
+            return result;
+        } catch (Exception e) {
+            log.error("任务删除失败", e);
+            return JSONObject.parseObject("{\"code\":500,\"msg\":\"任务删除失败\"}");
+        }
+    }
 }

snowy-plugin/snowy-plugin-dev/snowy-plugin-dev-func/src/main/java/vip/xiaonuo/dev/modular/job/service/impl/DevJobApiServiceImpl.java

@@ -1,92 +0,0 @@
-package vip.xiaonuo.dev.modular.job.service.impl;
-
-import com.alibaba.fastjson.JSONObject;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import lombok.extern.slf4j.Slf4j;
-import vip.xiaonuo.dev.api.DevJobApi;
-import vip.xiaonuo.dev.modular.job.entity.DevJob;
-import vip.xiaonuo.dev.modular.job.mapper.DevJobMapper;
-import vip.xiaonuo.dev.modular.job.param.DevJobAddParam;
-import vip.xiaonuo.dev.modular.job.param.DevJobEditParam;
-import vip.xiaonuo.dev.modular.job.param.DevJobIdParam;
-import vip.xiaonuo.dev.modular.job.service.DevJobService;
-import org.springframework.stereotype.Service;
-import javax.annotation.Resource;
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * @PackageName:vip.xiaonuo.dev.modular.job.service.impl
- * @ClassName:DevJobApiServiceImpl
- * @Author ZSS
- * @Date 2025-07-24 10:19
- * @Note: 任务接口实现类
- **/
-@Slf4j
-@Service("DevJobApiServiceImpl")
-public class DevJobApiServiceImpl extends ServiceImpl<DevJobMapper, DevJob> implements DevJobApi {
-    @Resource
-    private DevJobService devJobService;
-
-    @Override
-    public JSONObject addJob(JSONObject addParam) {
-        JSONObject result = new JSONObject();
-        try {
-            DevJobAddParam devJobAddParam = JSONObject.toJavaObject(addParam, DevJobAddParam.class);
-            DevJob devJob = devJobService.add(devJobAddParam);
-            result.put("data", devJob);
-            result.put("code", 200);
-            result.put("msg", "任务添加成功");
-            return result;
-        } catch (Exception e) {
-            log.error("任务添加失败", e);
-            return JSONObject.parseObject("{\"code\":500,\"msg\":\"任务添加失败\"}");
-        }
-    }
-
-    @Override
-    public JSONObject editJob(JSONObject editParam) {
-        JSONObject result = new JSONObject();
-        try {
-            String jobId = editParam.getString("id");
-            if(jobId == null || jobId.isEmpty()){
-                return JSONObject.parseObject("{\"code\":500,\"msg\":\"入参任务ID不存在\"}");
-            }
-            DevJob devJob = devJobService.queryEntity(jobId);
-            if(devJob == null){
-                return JSONObject.parseObject("{\"code\":500,\"msg\":\"ID:"+jobId+" 此任务不存在\"}");
-            }
-            DevJobEditParam devJobEditParam = JSONObject.toJavaObject(editParam, DevJobEditParam.class);
-            devJobService.edit(devJobEditParam);
-            result.put("code", 200);
-            result.put("msg", "任务添加成功");
-            return result;
-        } catch (Exception e) {
-            log.error("任务修改失败", e);
-            return JSONObject.parseObject("{\"code\":500,\"msg\":\"任务修改失败\"}");
-        }
-    }
-
-    @Override
-    public JSONObject deleteJob(List<String> ids) {
-        JSONObject result = new JSONObject();
-        try {
-            if(ids == null || ids.isEmpty()){
-                return JSONObject.parseObject("{\"code\":500,\"msg\":\"入参任务ID集合不存在\"}");
-            }
-            List<DevJobIdParam> devJobIdParamList = new ArrayList<DevJobIdParam>();
-            for(String id : ids){
-                DevJobIdParam devJobIdParam = new DevJobIdParam();
-                devJobIdParam.setId(id);
-                devJobIdParamList.add(devJobIdParam);
-            }
-            devJobService.delete(devJobIdParamList);
-            result.put("code", 200);
-            result.put("msg", "任务删除成功");
-            return result;
-        } catch (Exception e) {
-            log.error("任务删除失败", e);
-            return JSONObject.parseObject("{\"code\":500,\"msg\":\"任务删除失败\"}");
-        }
-    }
-}