From 853e1cb34ad1b72551817ca5cc01ab89faf7c1a7 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E6=80=9D=E8=B1=AA?= <1437200870@qq.com>
Date: Mon, 2 Sep 2024 20:19:47 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E8=81=94=E6=9F=A5=E4=BF=A1?=
 =?UTF-8?q?=E6=81=AF=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../muyu/controller/TaskJoinController.java   | 11 +++---
 .../com/muyu/service/TaskJoinService.java     |  9 +++++
 .../service/impl/TaskJoinServiceImpl.java     | 39 +++++++++++++++++++
 3 files changed, 53 insertions(+), 6 deletions(-)
 create mode 100644 cloud-task-server/src/main/java/com/muyu/service/TaskJoinService.java
 create mode 100644 cloud-task-server/src/main/java/com/muyu/service/impl/TaskJoinServiceImpl.java

diff --git a/cloud-task-server/src/main/java/com/muyu/controller/TaskJoinController.java b/cloud-task-server/src/main/java/com/muyu/controller/TaskJoinController.java
index e84a329..ba836af 100644
--- a/cloud-task-server/src/main/java/com/muyu/controller/TaskJoinController.java
+++ b/cloud-task-server/src/main/java/com/muyu/controller/TaskJoinController.java
@@ -1,8 +1,10 @@
 package com.muyu.controller;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.muyu.common.core.domain.Result;
 import com.muyu.domain.TaskJoinInfo;
 import com.muyu.mapper.TaskJoinMapper;
+import com.muyu.service.TaskJoinService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -18,15 +20,12 @@ import org.springframework.web.bind.annotation.*;
 public class TaskJoinController {
 
     @Autowired
-    private TaskJoinMapper taskJoinMapper;
+    private TaskJoinService taskJoinService;
 
 
     @PostMapping(value = "addTaskJoin")
     public Result<String> addTaskJoin(@RequestBody TaskJoinInfo taskJoinInfo){
-        int insert = taskJoinMapper.insert(taskJoinInfo);
-        if(insert<=0){
-            throw new RuntimeException("失败");
-        }
-        return Result.success(null,"添加成功");
+
+        return Result.success(null,taskJoinService.addTaskJoin(taskJoinInfo));
     };
 }
diff --git a/cloud-task-server/src/main/java/com/muyu/service/TaskJoinService.java b/cloud-task-server/src/main/java/com/muyu/service/TaskJoinService.java
new file mode 100644
index 0000000..f4c9511
--- /dev/null
+++ b/cloud-task-server/src/main/java/com/muyu/service/TaskJoinService.java
@@ -0,0 +1,9 @@
+package com.muyu.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.muyu.domain.TaskJoinInfo;
+
+public interface TaskJoinService extends IService<TaskJoinInfo> {
+
+    String addTaskJoin(TaskJoinInfo taskJoinInfo);
+}
diff --git a/cloud-task-server/src/main/java/com/muyu/service/impl/TaskJoinServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskJoinServiceImpl.java
new file mode 100644
index 0000000..996d026
--- /dev/null
+++ b/cloud-task-server/src/main/java/com/muyu/service/impl/TaskJoinServiceImpl.java
@@ -0,0 +1,39 @@
+package com.muyu.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.muyu.domain.TaskJoinInfo;
+import com.muyu.mapper.TaskJoinMapper;
+import com.muyu.service.TaskJoinService;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @PackageName:com.muyu.service.impl
+ * @ClassName:TaskJoinServiceImpl
+ * @Description:
+ * @author: ￥陈思豪￥
+ * @date: 2024/9/2 20:14
+ */
+@Service
+public class TaskJoinServiceImpl extends ServiceImpl<TaskJoinMapper, TaskJoinInfo> implements TaskJoinService{
+
+    @Autowired
+    private TaskJoinMapper taskJoinMapper;
+
+    @Override
+    public String addTaskJoin(TaskJoinInfo taskJoinInfo) {
+        LambdaQueryWrapper<TaskJoinInfo> taskJoinInfoLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        taskJoinInfoLambdaQueryWrapper.eq(TaskJoinInfo::getNodeId,taskJoinInfo.getNodeId());
+        TaskJoinInfo taskJoinInfo1 = taskJoinMapper.selectOne(taskJoinInfoLambdaQueryWrapper);
+        if(taskJoinInfo1!=null){
+            taskJoinMapper.deleteById(taskJoinInfo1.getId());
+        }
+        int insert = taskJoinMapper.insert(taskJoinInfo);
+        if(insert<=0){
+            throw new RuntimeException("失败");
+        }
+        return "添加成功";
+    }
+}