diff --git a/cloud-task-common/src/main/java/com/muyu/common/domian/NodeJoint.java b/cloud-task-common/src/main/java/com/muyu/common/domian/NodeJoint.java new file mode 100644 index 0000000..da217b0 --- /dev/null +++ b/cloud-task-common/src/main/java/com/muyu/common/domian/NodeJoint.java @@ -0,0 +1,45 @@ +package com.muyu.common.domian; + +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; + +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +@TableName(value = "node_joint") +public class NodeJoint { + + /** + * id + */ + @TableId(value = "id",type = IdType.AUTO) + private Long id; + /** + * 任务id + */ + private Long taskId; + /** + * 任务id + */ + private Long nodeId; + /** + * 联查方式 + */ + private String joint; + /** + * 字段 + */ + private String oneFie; + /** + * 字段 + */ + private String twoFie; + + +} diff --git a/cloud-task-common/src/main/java/com/muyu/common/domian/NodeTable.java b/cloud-task-common/src/main/java/com/muyu/common/domian/NodeTable.java index fd9935e..2894b0a 100644 --- a/cloud-task-common/src/main/java/com/muyu/common/domian/NodeTable.java +++ b/cloud-task-common/src/main/java/com/muyu/common/domian/NodeTable.java @@ -1,5 +1,7 @@ package com.muyu.common.domian; +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; import lombok.AllArgsConstructor; import lombok.Builder; @@ -16,6 +18,7 @@ public class NodeTable { /** * 主键 */ + @TableId(value = "id",type = IdType.AUTO) private Long id; /** * 节点id diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/controller/NodeJointController.java b/cloud-task-server/src/main/java/com/muyu/task/server/controller/NodeJointController.java new file mode 100644 index 0000000..e918d5f --- /dev/null +++ b/cloud-task-server/src/main/java/com/muyu/task/server/controller/NodeJointController.java @@ -0,0 +1,39 @@ +package com.muyu.task.server.controller; + +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.muyu.common.core.domain.Result; +import com.muyu.common.domian.NodeJoint; +import com.muyu.task.server.service.NodeJointService; +import org.springframework.beans.factory.annotation.Autowired; +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.RestController; + +@RestController +@RequestMapping("nodeJoint") +public class NodeJointController { + + @Autowired + private NodeJointService nodeJointService; + + + @PostMapping("add") + public Result save(@RequestBody NodeJoint nodeJoint){ + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("node_id",nodeJoint.getNodeId()); + nodeJointService.remove(wrapper); + boolean save = nodeJointService.save(nodeJoint); + return Result.success(save); + } + + + + + + + + + + +} diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/mapper/NodeJointMapper.java b/cloud-task-server/src/main/java/com/muyu/task/server/mapper/NodeJointMapper.java new file mode 100644 index 0000000..8a4f39c --- /dev/null +++ b/cloud-task-server/src/main/java/com/muyu/task/server/mapper/NodeJointMapper.java @@ -0,0 +1,9 @@ +package com.muyu.task.server.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.muyu.common.domian.NodeJoint; +import org.apache.ibatis.annotations.Mapper; + +@Mapper +public interface NodeJointMapper extends BaseMapper { +} diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/service/NodeJointService.java b/cloud-task-server/src/main/java/com/muyu/task/server/service/NodeJointService.java new file mode 100644 index 0000000..2d3bae0 --- /dev/null +++ b/cloud-task-server/src/main/java/com/muyu/task/server/service/NodeJointService.java @@ -0,0 +1,7 @@ +package com.muyu.task.server.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.muyu.common.domian.NodeJoint; + +public interface NodeJointService extends IService { +} diff --git a/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/NodeJointServiceImpl.java b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/NodeJointServiceImpl.java new file mode 100644 index 0000000..000f487 --- /dev/null +++ b/cloud-task-server/src/main/java/com/muyu/task/server/service/impl/NodeJointServiceImpl.java @@ -0,0 +1,11 @@ +package com.muyu.task.server.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.muyu.common.domian.NodeJoint; +import com.muyu.task.server.mapper.NodeJointMapper; +import com.muyu.task.server.service.NodeJointService; +import org.springframework.stereotype.Service; + +@Service +public class NodeJointServiceImpl extends ServiceImpl implements NodeJointService { +}