From 0b0bb8d04653207ab402a47e215dcaee1ac25c40 Mon Sep 17 00:00:00 2001 From: zhang xu <2125563902@qq.com> Date: Sat, 18 May 2024 11:56:30 +0800 Subject: [PATCH] =?UTF-8?q?text:(=E6=B5=8B=E8=AF=95)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../muyu/etl/domain/ConnectionFactory.java | 72 ++++++++++++++++++ .../com/muyu/etl/mapper/StudentMapper.java | 33 +++++++++ .../com/muyu/etl/service/StudentService.java | 27 +++++++ .../etl/service/impl/BrandReqServiceImpl.java | 73 +++++++++++++++++++ 4 files changed, 205 insertions(+) create mode 100644 muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/ConnectionFactory.java create mode 100644 muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/mapper/StudentMapper.java create mode 100644 muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/service/StudentService.java create mode 100644 muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/service/impl/BrandReqServiceImpl.java diff --git a/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/ConnectionFactory.java b/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/ConnectionFactory.java new file mode 100644 index 0000000..00710c5 --- /dev/null +++ b/muyu-modules/muyu-etl/muyu-etl-common/src/main/java/com/muyu/etl/domain/ConnectionFactory.java @@ -0,0 +1,72 @@ +package com.muyu.etl.domain; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * @ClassDescription: + * @JdkVersion: 17 + * @Author: zhangxu + * @Created: 2024/5/16 15:06 + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +public class ConnectionFactory { + + + + private String host; + + private String port; + + private String virtualHost; + + private String username; + + private String password; + + public String getHost() { + return host; + } + + public void setHost(String host) { + this.host = host; + } + + public String getPort() { + return port; + } + + public void setPort(String port) { + this.port = port; + } + + public String getVirtualHost() { + return virtualHost; + } + + public void setVirtualHost(String virtualHost) { + this.virtualHost = virtualHost; + } + + public String getUsername() { + return username; + } + + public void setUsername(String username) { + this.username = username; + } + + public String getPassword() { + return password; + } + + public void setPassword(String password) { + this.password = password; + } + + + +} diff --git a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/mapper/StudentMapper.java b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/mapper/StudentMapper.java new file mode 100644 index 0000000..6d20338 --- /dev/null +++ b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/mapper/StudentMapper.java @@ -0,0 +1,33 @@ +package com.muyu.etl.mapper; + +import com.muyu.etl.domain.Student; +import org.apache.ibatis.annotations.Mapper; + +import java.util.List; + +/** + * @ClassDescription: + * @JdkVersion: 17 + * @Author: zhangxu + * @Created: 2024/5/17 19:54 + */ +@Mapper +public interface StudentMapper { + + + List studentList(); + + List studentListByDeptId(Long deptId); + + Student studentById(Long id); + + int insertStudent(Student student); + + int updateStudent(Student student); + + int deleteStudent(Long id); + + int deleteStudentList(List ids); + + +} diff --git a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/service/StudentService.java b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/service/StudentService.java new file mode 100644 index 0000000..cc5e639 --- /dev/null +++ b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/service/StudentService.java @@ -0,0 +1,27 @@ +package com.muyu.etl.service; + +import com.muyu.etl.domain.Student; + +import java.util.List; + +/** + * @ClassDescription: + * @JdkVersion: 17 + * @Author: zhangxu + * @Created: 2024/5/17 19:55 + */ +public interface StudentService { + + List studentList(); + + void insertStudent(Student student); + + void updateStudent(Student student); + + void deleteStudent(Student student); + + void deleteStudentList(List studentList); + + Student getStudent(Student student); + +} diff --git a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/service/impl/BrandReqServiceImpl.java b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/service/impl/BrandReqServiceImpl.java new file mode 100644 index 0000000..090cb08 --- /dev/null +++ b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/service/impl/BrandReqServiceImpl.java @@ -0,0 +1,73 @@ +package com.muyu.etl.service.impl; + +import com.muyu.common.core.domain.Result; +import com.muyu.common.security.utils.SecurityUtils; +import com.muyu.etl.domain.req.BrandReq; +import com.muyu.etl.mapper.BrandMapper; +import com.muyu.etl.service.BrandReqService; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.Date; +import java.util.List; + +/** + * @ClassDescription: + * @JdkVersion: 17 + * @Author: zhangxu + * @Created: 2024/5/16 20:58 + */ +@Service +public class BrandReqServiceImpl implements BrandReqService { + + @Autowired + private BrandMapper brandMapper; + + + @Override + public List getBrandReqList(BrandReq brandReq) { + List brandList = brandMapper.getBrandList(brandReq); + return brandList; + } + + @Override + public List getBrandReqListByDeptId(BrandReq brandReq) { + List brandList = brandMapper.getBrandList(brandReq); + return brandList; + } + + @Override + public Result updateBrandReq(BrandReq brandReq) { + String username = SecurityUtils.getUsername(); + brandReq.setUpdateBy(String.valueOf(new Date())); + int update = brandMapper.update(); + return Result.success(update); + } + + @Override + public Result updateBrandReqList(List brandReqList) { + String username = SecurityUtils.getUsername(); + return null; + } + + @Override + public Result deleteBrandReq(BrandReq brandReq) { + int delete = brandMapper.delete(brandReq); + return Result.success(delete); + } + + @Override + public Result deleteBrandReqList(List brandReqList) { + + return Result.success(); + } + + @Override + public Result insertBrandReq(BrandReq brandReq) { + int insert = brandMapper.insert(); + if (insert > 0) { + return Result.success(); + } + return Result.error(); + } +}