From 637e67fdb0dae7c94e6e262e3074f6cd32f8ab77 Mon Sep 17 00:00:00 2001 From: liuguijing <123456> Date: Wed, 31 Jan 2024 16:24:00 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9Esensor=E5=92=8Cpoint=E8=A1=A8?= =?UTF-8?q?=E7=9A=84=E5=A2=9E=E5=88=A0=E6=94=B9=E6=9F=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/xydl/cac/entity/NPoint.java | 57 +++++++++++++++++ .../java/com/xydl/cac/entity/NSensor.java | 59 +++++++++++++++++ .../xydl/cac/repository/NPointRepository.java | 15 +++++ .../cac/repository/NSensorRepository.java | 15 +++++ .../com/xydl/cac/service/NPointService.java | 22 +++++++ .../com/xydl/cac/service/NSensorService.java | 21 ++++++ .../cac/service/impl/NPointServiceImpl.java | 64 +++++++++++++++++++ .../cac/service/impl/NSensorServiceImpl.java | 61 ++++++++++++++++++ 8 files changed, 314 insertions(+) create mode 100644 src/main/java/com/xydl/cac/entity/NPoint.java create mode 100644 src/main/java/com/xydl/cac/entity/NSensor.java create mode 100644 src/main/java/com/xydl/cac/repository/NPointRepository.java create mode 100644 src/main/java/com/xydl/cac/repository/NSensorRepository.java create mode 100644 src/main/java/com/xydl/cac/service/NPointService.java create mode 100644 src/main/java/com/xydl/cac/service/NSensorService.java create mode 100644 src/main/java/com/xydl/cac/service/impl/NPointServiceImpl.java create mode 100644 src/main/java/com/xydl/cac/service/impl/NSensorServiceImpl.java diff --git a/src/main/java/com/xydl/cac/entity/NPoint.java b/src/main/java/com/xydl/cac/entity/NPoint.java new file mode 100644 index 0000000..5388276 --- /dev/null +++ b/src/main/java/com/xydl/cac/entity/NPoint.java @@ -0,0 +1,57 @@ +package com.xydl.cac.entity; + +import io.swagger.annotations.ApiModel; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import javax.persistence.*; +import java.util.ArrayList; +import java.util.List; + +/** + * @author jignjing + * @date 2024-01-31 + **/ +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +@Entity +@Table(name = "n_point") +@ApiModel("装置点表") +public class NPoint { + + @Id + @GeneratedValue(strategy = GenerationType.IDENTITY) + @Column(name = "id") + private Integer id; + + @Column(name = "sensor_id") + private String sensorId; + + @Column(name = "filed") + private String filed; + + @Column(name = "filed_desc") + private Integer filedDesc; + + @Column(name = "point_id") + private Integer pointId; + + @Column(name = "type") + private Integer type; + + + + @Transient + private List children; + + public void addChild(NPoint item) { + if (children == null) { + children = new ArrayList<>(); + } + children.add(item); + } +} \ No newline at end of file diff --git a/src/main/java/com/xydl/cac/entity/NSensor.java b/src/main/java/com/xydl/cac/entity/NSensor.java new file mode 100644 index 0000000..37440fc --- /dev/null +++ b/src/main/java/com/xydl/cac/entity/NSensor.java @@ -0,0 +1,59 @@ +package com.xydl.cac.entity; + +import io.swagger.annotations.ApiModel; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import javax.persistence.*; +import java.util.ArrayList; +import java.util.List; + +/** + * @author jignjing + * @date 2024-01-31 + **/ +@Data +@Builder +@AllArgsConstructor +@NoArgsConstructor +@Entity +@Table(name = "n_sensor") +@ApiModel("装置表") +public class NSensor { + + @Id + @GeneratedValue(strategy = GenerationType.IDENTITY) + @Column(name = "id") + private Integer id; + + @Column(name = "name") + private String name; + + @Column(name = "phase") + private String phase; + + @Column(name = "table_name") + private String tableName; + + @Column(name = "sensor_code") + private String sensorCode; + + @Column(name = "equipment_code") + private String equipmentId; + + @Column(name = "status") + private Integer status; + + + @Transient + private List children; + + public void addChild(NSensor item) { + if (children == null) { + children = new ArrayList<>(); + } + children.add(item); + } +} \ No newline at end of file diff --git a/src/main/java/com/xydl/cac/repository/NPointRepository.java b/src/main/java/com/xydl/cac/repository/NPointRepository.java new file mode 100644 index 0000000..a896c05 --- /dev/null +++ b/src/main/java/com/xydl/cac/repository/NPointRepository.java @@ -0,0 +1,15 @@ +package com.xydl.cac.repository; + +import com.xydl.cac.entity.NPoint; +import org.springframework.data.jpa.repository.JpaRepository; +import org.springframework.data.jpa.repository.JpaSpecificationExecutor; +import org.springframework.stereotype.Repository; + +import java.util.Optional; + + +@Repository +public interface NPointRepository extends JpaRepository, JpaSpecificationExecutor { + + Optional findById(Integer id); +} \ No newline at end of file diff --git a/src/main/java/com/xydl/cac/repository/NSensorRepository.java b/src/main/java/com/xydl/cac/repository/NSensorRepository.java new file mode 100644 index 0000000..035226b --- /dev/null +++ b/src/main/java/com/xydl/cac/repository/NSensorRepository.java @@ -0,0 +1,15 @@ +package com.xydl.cac.repository; + +import com.xydl.cac.entity.NSensor; +import org.springframework.data.jpa.repository.JpaRepository; +import org.springframework.data.jpa.repository.JpaSpecificationExecutor; +import org.springframework.stereotype.Repository; + +import java.util.Optional; + + +@Repository +public interface NSensorRepository extends JpaRepository, JpaSpecificationExecutor { + + Optional findById(Integer id); +} \ No newline at end of file diff --git a/src/main/java/com/xydl/cac/service/NPointService.java b/src/main/java/com/xydl/cac/service/NPointService.java new file mode 100644 index 0000000..4bee750 --- /dev/null +++ b/src/main/java/com/xydl/cac/service/NPointService.java @@ -0,0 +1,22 @@ +package com.xydl.cac.service; + +import com.xydl.cac.entity.NPoint; +import org.springframework.data.domain.Page; + +import java.util.List; + +public interface NPointService { + + List listAll(); + + Page list(int pageNum, int pageSize); + + NPoint add(NPoint item) throws Exception; + + void update(NPoint item) throws Exception; + + void delete(Integer id); + + NPoint detail(Integer id) throws Exception; + +} diff --git a/src/main/java/com/xydl/cac/service/NSensorService.java b/src/main/java/com/xydl/cac/service/NSensorService.java new file mode 100644 index 0000000..9d4c1f2 --- /dev/null +++ b/src/main/java/com/xydl/cac/service/NSensorService.java @@ -0,0 +1,21 @@ +package com.xydl.cac.service; + +import com.xydl.cac.entity.NSensor; +import org.springframework.data.domain.Page; + +import java.util.List; + +public interface NSensorService { + List listAll(); + + Page list(int pageNum, int pageSize); + + NSensor add(NSensor item) throws Exception; + + void update(NSensor item) throws Exception; + + void delete(Integer id); + + NSensor detail(Integer id) throws Exception; + +} diff --git a/src/main/java/com/xydl/cac/service/impl/NPointServiceImpl.java b/src/main/java/com/xydl/cac/service/impl/NPointServiceImpl.java new file mode 100644 index 0000000..40236cc --- /dev/null +++ b/src/main/java/com/xydl/cac/service/impl/NPointServiceImpl.java @@ -0,0 +1,64 @@ +package com.xydl.cac.service.impl; + +import com.xydl.cac.entity.NPoint; +import com.xydl.cac.entity.NSensor; +import com.xydl.cac.repository.NPointRepository; +import com.xydl.cac.repository.NSensorRepository; +import com.xydl.cac.service.NPointService; +import com.xydl.cac.service.NSensorService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.data.domain.Page; +import org.springframework.data.domain.PageRequest; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import javax.annotation.Resource; +import java.util.List; +import java.util.Optional; + +@Service +@Slf4j +@Transactional(rollbackFor = Exception.class) +public class NPointServiceImpl implements NPointService { + + @Resource + NPointRepository repository; + + @Override + public List listAll() { + List list = repository.findAll(); + return list; + } + + @Override + public Page list(int pageNum, int pageSize) { + PageRequest request = PageRequest.of(pageNum, pageSize); + Page result = repository.findAll(request); + return result; + } + + @Override + public NPoint add(NPoint item) throws Exception { + item.setId(null); + return repository.save(item); + } + + @Override + public void update(NPoint item) throws Exception { + repository.save(item); + } + + @Override + public void delete(Integer id) { + repository.deleteById(id); + } + + @Override + public NPoint detail(Integer id) throws Exception { + Optional optional = repository.findById(id); + if (!optional.isPresent()) { + throw new Exception("未找到该记录"); + } + return optional.get(); + } +} diff --git a/src/main/java/com/xydl/cac/service/impl/NSensorServiceImpl.java b/src/main/java/com/xydl/cac/service/impl/NSensorServiceImpl.java new file mode 100644 index 0000000..7472f0d --- /dev/null +++ b/src/main/java/com/xydl/cac/service/impl/NSensorServiceImpl.java @@ -0,0 +1,61 @@ +package com.xydl.cac.service.impl; + +import com.xydl.cac.entity.NSensor; +import com.xydl.cac.repository.NSensorRepository; +import com.xydl.cac.service.NSensorService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.data.domain.Page; +import org.springframework.data.domain.PageRequest; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import javax.annotation.Resource; +import java.util.List; +import java.util.Optional; + +@Service +@Slf4j +@Transactional(rollbackFor = Exception.class) +public class NSensorServiceImpl implements NSensorService { + @Resource + NSensorRepository repository; + + @Override + public List listAll() { + List list = repository.findAll(); + return list; + } + + @Override + public Page list(int pageNum, int pageSize) { + PageRequest request = PageRequest.of(pageNum, pageSize); + Page result = repository.findAll(request); + return result; + } + + @Override + public NSensor add(NSensor item) throws Exception { + item.setId(null); + return repository.save(item); + } + + @Override + public void update(NSensor item) throws Exception { + repository.save(item); + } + + @Override + public void delete(Integer id) { + repository.deleteById(id); + } + + @Override + public NSensor detail(Integer id) throws Exception { + Optional optional = repository.findById(id); + if (!optional.isPresent()) { + throw new Exception("未找到该记录"); + } + return optional.get(); + } + +}