Compare commits

...

20 Commits

Author SHA1 Message Date
ruyaxie 443350c8f4 Merge branch 'dev.parse' into dev 2024-09-30 18:09:42 +08:00
ruyaxie 19f99ac116 feat():修复kafka生产者 2024-09-30 16:50:07 +08:00
YangPeng e5b5222c39 Merge branch 'dev.saas' into dev 2024-09-30 16:41:54 +08:00
YangPeng d24110090c Merge branch 'dev.saas.yp' into dev
# Conflicts:
#	cloud-modules/cloud-modules-data-process/cloud-modules-data-process-common/src/main/java/com/muyu/data/basics/EventQueueConfig.java
#	cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/controller/CarAndFenceGroupMiddleController.java
#	cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/controller/CarFenceUpdateController.java
#	cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/controller/MiddleController.java
#	cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/mapper/CarAndFenceGroupMiddleMapper.java
#	cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/mapper/CarFenceUpdateMapper.java
#	cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/service/CarAndFenceGroupMiddleService.java
#	cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/service/CarFenceUpdateService.java
#	cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/service/impl/CarAndFenceGroupMiddleServiceImpl.java
#	cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/service/impl/CarFenceServiceMybaitsImpl.java
#	cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/java/com/muyu/enterpise/service/impl/CarFenceUpdateServiceImpl.java
#	cloud-modules/cloud-modules-enterprise/enterprise-cache/pom.xml
2024-09-30 16:38:41 +08:00
王鑫 14cc2afd35 Merge remote-tracking branch 'origin/dev' into dev
# Conflicts:
#	cloud-modules/cloud-modules-enterprise/enterpise-service/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-modules-enterprise/pom.xml
2024-09-30 16:30:20 +08:00
yangpeng 535eae941e Merge pull request 'feat():优化' (#29) from dev.saas.yp into dev.saas
Reviewed-on: #29
2024-09-30 14:44:23 +08:00
YangPeng bd2865ebc5 feat():优化 2024-09-30 14:43:22 +08:00
yangpeng eef2467a61 Merge pull request 'feat():优化' (#27) from dev.saas.yp into dev.saas
Reviewed-on: #27
2024-09-30 14:36:40 +08:00
YangPeng a66329500c feat():优化 2024-09-30 14:34:49 +08:00
ruyaxie f98c11e825 feat():修复Redis缓存 2024-09-30 12:27:32 +08:00
yangpeng c241897dfe Merge pull request 'dev.saas.yp' (#22) from dev.saas.yp into dev.saas
Reviewed-on: #22
2024-09-30 12:02:43 +08:00
YangPeng 6f9079ec5f feat():修改JDK版本问题 2024-09-30 12:01:29 +08:00
xieyaru070903 eff427473f Merge pull request 'feat():修复Redis' (#19) from dev.parse into dev
Reviewed-on: #19
2024-09-30 10:41:50 +08:00
ruyaxie c87bf8a2fa feat():修复Redis 2024-09-30 10:41:15 +08:00
xieyaru070903 0bb5a912f7 Merge pull request 'dev.parse' (#17) from dev.parse into dev
Reviewed-on: #17
2024-09-30 09:14:38 +08:00
ruyaxie 1d43fa7888 feat():修复cloud-common冲突 2024-09-30 09:13:45 +08:00
ruyaxie 61dc7f9277 Merge remote-tracking branch 'origin/dev.parse' into dev.parse
# Conflicts:
#	cloud-common/cloud-common-kafka/pom.xml
#	cloud-common/pom.xml
#	cloud-modules/cloud-modules-data-process/cloud-modules-data-process-server/pom.xml
#	cloud-modules/cloud-modules-data-process/cloud-modules-data-process-server/src/main/resources/bootstrap.yml
#	cloud-modules/cloud-modules-data-process/cloud-modules-data-process-server/src/main/resources/logback/dev.xml
#	cloud-modules/cloud-modules-data-process/cloud-modules-data-process-server/src/main/resources/logback/prod.xml
#	cloud-modules/cloud-modules-data-process/cloud-modules-data-process-server/src/main/resources/logback/test.xml
2024-09-30 09:12:02 +08:00
ruyaxie 6eff930c84 feat():修复代码缓存框架 2024-09-30 08:59:19 +08:00
ruyaxie ecf81cc79e feat():修复代码缓存框架 2024-09-30 01:22:53 +08:00
ruyaxie 63ebaee731 feat():修复代码缓存框架 2024-09-30 01:13:22 +08:00
135 changed files with 971 additions and 464 deletions

View File

@ -1,8 +1,11 @@
package com.muyu.common.cache; package com.muyu.common.cache;
import com.muyu.common.core.web.domain.BaseEntity;
import com.muyu.common.redis.service.RedisService; import com.muyu.common.redis.service.RedisService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import java.util.concurrent.TimeUnit;
/** /**
* *
* * @className: CacheAbsBasic * * @className: CacheAbsBasic
@ -18,16 +21,43 @@ public abstract class CacheAbsBasic <K, V> implements CacheBasic<K, V>{
@Override @Override
public void put(K key, V value) { public void put(K key, V value) {
redisService.setCacheObject(encode(key), value);
try {
redisService.setCacheObject(encode(key), value,30L,TimeUnit.MINUTES);
} catch (Exception e) {
throw new RuntimeException("运行时异常,异常信息为:{}"+e.getMessage());
}
} }
@Override @Override
public V get(K key) { public V get(K key) {
return redisService.getCacheObject(encode(key));
try {
return redisService.getCacheObject(encode(key));
} catch (Exception e) {
throw new RuntimeException("运行时异常,异常信息为:{}"+e.getMessage());
}
} }
@Override @Override
public void remove(K key) { public void remove(K key) {
redisService.deleteObject(encode(key));
try {
redisService.deleteObject(encode(key));
} catch (Exception e) {
throw new RuntimeException("运行时异常,异常信息为:{}"+e.getMessage());
}
}
@Override
public boolean hashKey(K key){
Boolean b = false;
try {
b = redisService.hasKey(encode(key));
} catch (Exception e) {
throw new RuntimeException("运行时异常,异常信息为:{}"+e.getMessage());
}
return b;
} }
} }

View File

@ -1,5 +1,10 @@
package com.muyu.common.cache; package com.muyu.common.cache;
import org.springframework.data.redis.core.TimeoutUtils;
import java.util.Date;
import java.util.concurrent.TimeUnit;
/** /**
* *
* * @className: CacheBasic * * @className: CacheBasic
@ -14,4 +19,6 @@ public interface CacheBasic<K, V> extends PrimaryKeyBasic<K> {
V get(K key); V get(K key);
void remove(K key); void remove(K key);
boolean hashKey(K key);
} }

View File

@ -1,6 +1,7 @@
package com.muyu.common.core.web.controller; package com.muyu.common.core.web.controller;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.muyu.common.core.utils.DateUtils; import com.muyu.common.core.utils.DateUtils;
import com.muyu.common.core.utils.PageUtils; import com.muyu.common.core.utils.PageUtils;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;

View File

@ -34,6 +34,11 @@
<groupId>org.projectlombok</groupId> <groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId> <artifactId>lombok</artifactId>
</dependency> </dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<scope>provided</scope>
</dependency>
</dependencies> </dependencies>
</project> </project>

View File

@ -20,8 +20,8 @@
<module>cloud-common-system</module> <module>cloud-common-system</module>
<module>cloud-common-xxl</module> <module>cloud-common-xxl</module>
<module>cloud-common-rabbit</module> <module>cloud-common-rabbit</module>
<module>cloud-common-kafka</module>
<module>cloud-common-cache</module> <module>cloud-common-cache</module>
<module>cloud-common-kafka</module>
<module>cloud-common-iotdb</module> <module>cloud-common-iotdb</module>
<module>cloud-common-caffeine</module> <module>cloud-common-caffeine</module>
</modules> </modules>

View File

@ -34,6 +34,11 @@
<groupId>io.swagger.core.v3</groupId> <groupId>io.swagger.core.v3</groupId>
<artifactId>swagger-annotations-jakarta</artifactId> <artifactId>swagger-annotations-jakarta</artifactId>
</dependency> </dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<scope>provided</scope>
</dependency>
</dependencies> </dependencies>
</project> </project>

View File

@ -0,0 +1,37 @@
package com.muyu.data.basics;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.concurrent.LinkedBlockingDeque;
/**
* @Author WangXin
* @Data 2024/9/29
* @Description
* @Version 1.0.0
*/
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class EventQueueConfig {
private LinkedBlockingDeque<EventProcessBasics> taskNodeQueue = new LinkedBlockingDeque<>();
public void addEvent(EventProcessBasics obj){
this.taskNodeQueue.add(obj);
}
public boolean hashEventNext(){
return !taskNodeQueue.isEmpty();
}
private EventProcessBasics nextTaskNode(){
return taskNodeQueue.poll();
}
}

View File

@ -4,10 +4,10 @@ server:
# nacos线上地址 # nacos线上地址
nacos: nacos:
addr: 127.0.0.1:8848 addr: 123.57.152.124:8848
user-name: nacos user-name: nacos
password: nacos password: nacos
namespace: wx namespace: five
# SPRING_AMQP_DESERIALIZATION_TRUST_ALL=true spring.amqp.deserialization.trust.all # SPRING_AMQP_DESERIALIZATION_TRUST_ALL=true spring.amqp.deserialization.trust.all
# Spring # Spring
spring: spring:
@ -59,7 +59,3 @@ spring:
- application-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} - application-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
# xxl-job 配置文件 # xxl-job 配置文件
- application-xxl-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} - application-xxl-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension}
logging:
level:
com.muyu.system.mapper: DEBUG

View File

@ -0,0 +1,36 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.muyu</groupId>
<artifactId>cloud-modules-enterprise</artifactId>
<version>3.6.3</version>
</parent>
<artifactId>enterpise-cache</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>cloud-common-cache</artifactId>
<version>${muyu.version}</version>
</dependency>
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterpise-common</artifactId>
</dependency>
</dependencies>
</project>

View File

@ -0,0 +1,43 @@
package com.muyu.enterpise.cache;
import com.muyu.common.cache.CacheAbsBasic;
import com.muyu.domain.MessageValue;
import org.springframework.stereotype.Component;
import java.util.List;
/**
* @version 1.0
* @Author xie ya ru
* @Date 2024/9/29 20:04
* @
*/
@Component
public class MessageValueCacheService extends CacheAbsBasic<String, List<MessageValue>>{
/**
*
* @return
*/
@Override
public String keyPre() {
return"messageValue:info:";
}
@Override
public String encode(String key) {
return super.encode(key);
}
/**
*
* @param key
* @return
*/
@Override
public String decode(String key) {
return key.replace("messageValue:info:","");
}
}

View File

@ -0,0 +1,30 @@
package com.muyu.enterpise.cache;
import com.muyu.common.cache.CacheAbsBasic;
import com.muyu.domain.SysCar;
import org.springframework.stereotype.Component;
/**
* @version 1.0
* @Author xie ya ru
* @Date 2024/9/30 11:06
* @
*/
@Component
public class SysCarCacheService extends CacheAbsBasic<String, SysCar> {
@Override
public String keyPre() {
return "sysCar:info:";
}
@Override
public String encode(String key) {
return super.encode(key);
}
@Override
public String decode(String key) {
return super.decode(key);
}
}

View File

@ -0,0 +1,29 @@
package com.muyu.enterpise.cache;
import com.muyu.common.cache.CacheAbsBasic;
import com.muyu.domain.SysCarType;
import org.springframework.stereotype.Component;
/**
* @version 1.0
* @Author xie ya ru
* @Date 2024/9/30 11:18
* @
*/
@Component
public class SysCarTypeCacheService extends CacheAbsBasic<String, SysCarType> {
@Override
public String keyPre() {
return "sysCarType:info:";
}
@Override
public String encode(String key) {
return super.encode(key);
}
@Override
public String decode(String key) {
return super.decode(key);
}
}

View File

@ -0,0 +1,2 @@
com.muyu.enterpise.cache.MessageValueCacheService
com.muyu.enterpise.cache.SysCarCacheService

View File

@ -0,0 +1,45 @@
package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* * @Authoryan
* * @Packagecom.muyu.car.domain
* * @Projectplues
* * @nameFenceAndGroupMiddle
* * @Date2024/9/22 09:59
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Builder
@Tag(name = "车辆和电子围栏组中间表")
@TableName(value = "car_group_middle",autoResultMap = true)
public class CarAndGroupMiddle {
/**
* id
*/
@TableId(value = "id",type = IdType.AUTO)
@Schema(name = "id")
private Long id;
/**
* id
*/
@Schema(name = "围栏id")
private Integer carId;
/**
* id
*/
@Schema(name = "围栏组id")
private Long groupId;
}

View File

@ -3,6 +3,7 @@ package com.muyu.domain;
import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.domain.req.FenceGroupUpdateReq;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@ -30,7 +31,7 @@ public class FenceGroup {
*/ */
@TableId(value = "group_id",type = IdType.AUTO) @TableId(value = "group_id",type = IdType.AUTO)
@Schema(name = "围栏组id") @Schema(name = "围栏组id")
private Integer groupId; private Long groupId;
/** /**
* *
*/ */
@ -42,5 +43,18 @@ public class FenceGroup {
@Schema(name = "围栏组状态") @Schema(name = "围栏组状态")
private Integer groupStates; private Integer groupStates;
public static FenceGroup carFenceUpdateById(Integer states, FenceGroupUpdateReq fenceGroupBuilder ){
return FenceGroup.builder()
.groupId(fenceGroupBuilder.getGroupId())
.groupStates(states)
.build();
}
public static FenceGroup closeCarFenceUpdateById(Integer states, Long groupId ){
return FenceGroup.builder()
.groupId(groupId)
.groupStates(states)
.build();
}
} }

View File

@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.web.domain.BaseEntity; import com.muyu.common.core.web.domain.BaseEntity;
import com.muyu.domain.req.MessageValueAddReq; import com.muyu.domain.req.MessageValueAddReq;
import com.muyu.domain.resp.MessageValueListResp;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@ -82,4 +83,14 @@ public class MessageValue extends BaseEntity {
.messageEndIndex(messageValueAddReq.getMessageEndIndex()) .messageEndIndex(messageValueAddReq.getMessageEndIndex())
.build(); .build();
} }
public static MessageValue addRollback(MessageValueListResp messageValueListResp){
return MessageValue.builder()
.templateId(messageValueListResp.getMessageId())
.messageType(messageValueListResp.getMessageType())
.messageCode(messageValueListResp.getMessageCode())
.messageLabel(messageValueListResp.getMessageLabel())
.messageStartIndex(messageValueListResp.getMessageStartIndex())
.messageEndIndex(messageValueListResp.getMessageEndIndex())
.build();
}
} }

View File

@ -31,7 +31,7 @@ public class SysCarType extends BaseEntity {
*/ */
@TableId(value = "id", type = IdType.AUTO) @TableId(value = "id", type = IdType.AUTO)
@Schema(name = "车辆类型主键") @Schema(name = "车辆类型主键")
private String id; private Long id;
/** /**
* *

View File

@ -0,0 +1,31 @@
package com.muyu.domain.req;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
*
* @Authoryan
* @Packagecom.muyu.domain.req
* @Projectplues
* @nameCarFenceUpdateReq
* @Date2024/9/29 20:22
*/
@Data
@AllArgsConstructor
@NoArgsConstructor
@Tag(name = "修改围栏的状态", description = "修改围栏的状态")
public class FenceGroupUpdateReq {
/**
* id
*/
@TableId(value = "group_id", type = IdType.AUTO)
@Schema(title = "围栏组Id")
private Long groupId;
}

View File

@ -6,10 +6,7 @@ import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.web.domain.BaseEntity; import com.muyu.common.core.web.domain.BaseEntity;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor; import lombok.*;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import lombok.experimental.SuperBuilder; import lombok.experimental.SuperBuilder;
import org.apache.commons.lang3.builder.ToStringBuilder; import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle; import org.apache.commons.lang3.builder.ToStringStyle;
@ -21,14 +18,13 @@ import org.apache.commons.lang3.builder.ToStringStyle;
* @date 2024-09-18 * @date 2024-09-18
*/ */
@EqualsAndHashCode(callSuper = true)
@Data @Data
@SuperBuilder @Builder
@NoArgsConstructor @NoArgsConstructor
@AllArgsConstructor @AllArgsConstructor
@TableName(value = "sys_car", autoResultMap = true) @TableName(value = "sys_car", autoResultMap = true)
@Tag(name = "车辆基础信息对象") @Tag(name = "车辆基础信息对象")
public class SysCar extends BaseEntity{ public class SysCarReq {
/** 自增主键 */ /** 自增主键 */
@TableId( type = IdType.AUTO) @TableId( type = IdType.AUTO)
@ -68,24 +64,4 @@ public class SysCar extends BaseEntity{
private Integer state; private Integer state;
@Override
public String toString() {
return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
.append("id", getId())
.append("carVin", getCarVin())
.append("carPlate", getCarPlate())
.append("carBrand", getCarBrand())
.append("carModel", getCarModel())
.append("carType", getCarType())
.append("warnStrategy", getWarnStrategy())
.append("groupCode", getGroupCode())
.append("state", getState())
.append("createBy", getCreateBy())
.append("createTime", getCreateTime())
.append("updateBy", getUpdateBy())
.append("updateTime", getUpdateTime())
.append("remark", getRemark())
.toString();
}
} }

View File

@ -3,6 +3,7 @@ package com.muyu.domain.resp;
import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.domain.SysCar;
import io.swagger.v3.oas.annotations.media.Schema; import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@ -89,19 +90,19 @@ public class SysCarResp {
@Schema(description = "启用状态") @Schema(description = "启用状态")
private Integer state; private Integer state;
@Override
public String toString() { public static SysCarResp reverseResp(SysCar sysCar){
return "SysCarResp{" + return SysCarResp.builder()
"id=" + id + .id(sysCar.getId())
", carVin='" + carVin + '\'' + .carVin(sysCar.getCarVin())
", carPlate='" + carPlate + '\'' + .carPlate(sysCar.getCarPlate())
", carBrand='" + carBrand + '\'' + .carBrand(sysCar.getCarBrand())
", carModel='" + carModel + '\'' + .carModel(sysCar.getCarModel())
", carType=" + carType + .carType(sysCar.getCarType())
", sysTypeName='" + sysTypeName + '\'' + .warnStrategy(sysCar.getWarnStrategy())
", warnStrategy=" + warnStrategy + .groupCode(sysCar.getGroupCode())
", groupCode='" + groupCode + '\'' + .state(sysCar.getState())
", state=" + state + .build();
'}';
} }
} }

View File

@ -83,6 +83,14 @@
<groupId>com.muyu</groupId> <groupId>com.muyu</groupId>
<artifactId>cloud-common-xxl</artifactId> <artifactId>cloud-common-xxl</artifactId>
</dependency> </dependency>
<!-- cache缓存框架 -->
<dependency>
<groupId>com.muyu</groupId>
<artifactId>enterpise-cache</artifactId>
<version>${muyu.version}</version>
</dependency>
</dependencies> </dependencies>
<build> <build>

View File

@ -0,0 +1,42 @@
package com.muyu.controller;
import com.muyu.common.core.domain.Result;
import com.muyu.domain.FenceGroup;
import com.muyu.service.CarAndFenceGroupMiddleService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
*
* @Authoryan
* @Packagecom.muyu.controller
* @Projectplues
* @nameCarAndFenceGroupMiddleController
* @Date2024/9/29 20:09
*/
@RequestMapping("/carandfencemiddle")
@RestController
@AllArgsConstructor
@Log4j2
@Tag(name = "车辆和围栏组中间表")
public class CarAndFenceGroupMiddleController {
@Autowired
private CarAndFenceGroupMiddleService carAndFenceGroupMiddleService;
/**
* id
*/
@PostMapping("/addFenceGroupAddCarMiddle")
@Operation(summary = "根据围栏组和车辆的id添加中间表",description = "根据围栏组和车辆的id添加中间表")
public Result addFenceGroupAddCarMiddle(@RequestParam("carId") Integer carId , @RequestBody List<FenceGroup> fenceGroups ){
boolean b = carAndFenceGroupMiddleService.saveBatch(fenceGroups,carId);
return Result.success("成功");
}
}

View File

@ -1,9 +1,9 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.domain.CarFenceClazz; import com.muyu.domain.CarFenceClazz;
import com.muyu.service.CarFenceClazzService; import com.muyu.enterpise.service.CarFenceClazzService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;

View File

@ -1,12 +1,12 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.domain.CarFence; import com.muyu.domain.CarFence;
import com.muyu.domain.req.CarFenceReq; import com.muyu.domain.req.CarFenceReq;
import com.muyu.domain.resp.CarFenceResq; import com.muyu.domain.resp.CarFenceResq;
import com.muyu.service.CarFenceService; import com.muyu.enterpise.service.CarFenceService;
import com.muyu.service.CarFenceServiceMybaits; import com.muyu.enterpise.service.CarFenceServiceMybaits;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;

View File

@ -1,8 +1,8 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.domain.CarFenceType; import com.muyu.domain.CarFenceType;
import com.muyu.service.CarFenceTypeService; import com.muyu.enterpise.service.CarFenceTypeService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;

View File

@ -0,0 +1,58 @@
package com.muyu.controller;
import com.muyu.common.core.domain.Result;
import com.muyu.domain.FenceGroup;
import com.muyu.domain.req.FenceGroupUpdateReq;
import com.muyu.service.CarFenceUpdateService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
/**
*
* @Authoryan
* @Packagecom.muyu.controller
* @Projectplues
* @nameCarFenceUpdateController
* @Date2024/9/30 09:10
*
*/
@RestController
@RequestMapping("/fenceUpdate")
@AllArgsConstructor
@Log4j2
@Tag(name = "修改围栏组的状态")
public class CarFenceUpdateController {
@Autowired
private CarFenceUpdateService carFenceUpdateService;
/**
*
*/
@PutMapping("/activate")
@Operation(summary = "启动围栏状态",description = "启动围栏状态")
public Result activate(@RequestBody FenceGroupUpdateReq fenceGroupUpdateReq){
Integer states = 0;
boolean b = carFenceUpdateService.updateById(FenceGroup.carFenceUpdateById(states, fenceGroupUpdateReq));
return Result.success("成功");
}
/**
*
* @param groupId
* @return
*/
@GetMapping("/updateFenceGroupById")
@Operation(summary = "修改围栏状态为关闭",description = "修改围栏状态为关闭")
public Result updateFenceGroupById(@RequestParam("groupId") Long groupId){
Integer states = 1;
carFenceUpdateService.updateById(FenceGroup.closeCarFenceUpdateById(states,groupId));
return Result.success("成功");
}
}

View File

@ -1,8 +1,8 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.service.CarTypeService; import com.muyu.enterpise.service.CarTypeService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

View File

@ -1,4 +1,4 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
@ -7,7 +7,7 @@ import com.muyu.domain.req.FaultCodeAddReq;
import com.muyu.domain.req.FaultCodeListReq; import com.muyu.domain.req.FaultCodeListReq;
import com.muyu.domain.req.FaultCodeUpdReq; import com.muyu.domain.req.FaultCodeUpdReq;
import com.muyu.domain.resp.FaultCodeTotalListResp; import com.muyu.domain.resp.FaultCodeTotalListResp;
import com.muyu.service.FaultCodeService; import com.muyu.enterpise.service.FaultCodeService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

View File

@ -1,4 +1,4 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
@ -7,7 +7,7 @@ import com.muyu.domain.FaultCondition;
import com.muyu.domain.req.FaultConditionAddReq; import com.muyu.domain.req.FaultConditionAddReq;
import com.muyu.domain.req.FaultConditionListReq; import com.muyu.domain.req.FaultConditionListReq;
import com.muyu.domain.req.FaultConditionUpdReq; import com.muyu.domain.req.FaultConditionUpdReq;
import com.muyu.service.FaultConditionService; import com.muyu.enterpise.service.FaultConditionService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

View File

@ -1,6 +1,6 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.service.FaultLabelService; import com.muyu.enterpise.service.FaultLabelService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

View File

@ -1,7 +1,7 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.domain.req.FaultLogListReq; import com.muyu.domain.req.FaultLogListReq;
import com.muyu.service.FaultLogService; import com.muyu.enterpise.service.FaultLogService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

View File

@ -1,10 +1,10 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.domain.CarFaultRule; import com.muyu.domain.CarFaultRule;
import com.muyu.domain.FaultRule; import com.muyu.domain.FaultRule;
import com.muyu.service.FaultRuleService; import com.muyu.enterpise.service.FaultRuleService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

View File

@ -1,6 +1,6 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.service.FaultTypeService; import com.muyu.enterpise.service.FaultTypeService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

View File

@ -1,8 +1,8 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.domain.FenceGroup; import com.muyu.domain.FenceGroup;
import com.muyu.service.FenceGroupService; import com.muyu.enterpise.service.FenceGroupService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;

View File

@ -1,11 +1,11 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.domain.message.Message; import com.muyu.domain.message.Message;
import com.muyu.domain.message.MessageReq; import com.muyu.domain.message.MessageReq;
import com.muyu.domain.message.MessageSendReq; import com.muyu.domain.message.MessageSendReq;
import com.muyu.service.MessageService; import com.muyu.enterpise.service.MessageService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

View File

@ -1,10 +1,10 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.domain.MessageTemplate; import com.muyu.domain.MessageTemplate;
import com.muyu.domain.req.MessageTemplateAddReq; import com.muyu.domain.req.MessageTemplateAddReq;
import com.muyu.domain.resp.MessageTemplateListResp; import com.muyu.domain.resp.MessageTemplateListResp;
import com.muyu.service.MessageTemplateService; import com.muyu.enterpise.service.MessageTemplateService;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

View File

@ -1,4 +1,4 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController; import com.muyu.common.core.web.controller.BaseController;
@ -6,15 +6,14 @@ import com.muyu.domain.MessageValue;
import com.muyu.domain.req.MessageValueAddReq; import com.muyu.domain.req.MessageValueAddReq;
import com.muyu.domain.req.MessageValueReq; import com.muyu.domain.req.MessageValueReq;
import com.muyu.domain.resp.MessageValueListResp; import com.muyu.domain.resp.MessageValueListResp;
import com.muyu.service.MessageValueService; import com.muyu.enterpise.cache.MessageValueCacheService;
import com.muyu.enterpise.service.MessageValueService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.util.List; import java.util.List;
/** /**
@ -33,8 +32,8 @@ public class MessageValueController extends BaseController {
@Autowired @Autowired
private MessageValueService messageValueService; private MessageValueService messageValueService;
@Resource @Autowired
private RedisTemplate<String,MessageValue> redisTemplate; private MessageValueCacheService messageValueCacheService;
/** /**
* *
@ -56,7 +55,6 @@ public class MessageValueController extends BaseController {
@PostMapping("/") @PostMapping("/")
@Operation(summary = "添加报文数据", description = "新增报文数据") @Operation(summary = "添加报文数据", description = "新增报文数据")
public Result<String> save(@RequestBody MessageValueAddReq messageValueAddReq){ public Result<String> save(@RequestBody MessageValueAddReq messageValueAddReq){
redisTemplate.boundValueOps("messageValue:" +messageValueAddReq.getTemplateId()).increment(1);
messageValueService.save(MessageValue.addBuild(messageValueAddReq)); messageValueService.save(MessageValue.addBuild(messageValueAddReq));
return Result.success("添加成功"); return Result.success("添加成功");
} }
@ -82,12 +80,4 @@ public class MessageValueController extends BaseController {
} }
@PostMapping({"/findByTemplateId/{stringVin}"})
@Operation(
summary = "根据车辆类型查询报文模版ID",
description = "根据车辆类型查询报文模版ID"
)
public Result<Long> findByTemplateId(@PathVariable("stringVin") String stringVin) {
return Result.success(this.messageValueService.findByTemplateId(stringVin), "查询成功");
}
} }

View File

@ -3,6 +3,7 @@ package com.muyu.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.domain.FenceGroup; import com.muyu.domain.FenceGroup;
import com.muyu.domain.req.CarFenceAdd; import com.muyu.domain.req.CarFenceAdd;
import com.muyu.domain.req.FenceGroupUpdateReq;
import com.muyu.service.CarFenceServiceMybaits; import com.muyu.service.CarFenceServiceMybaits;
import com.muyu.service.MiddleService; import com.muyu.service.MiddleService;
import io.swagger.v3.oas.annotations.Operation; import io.swagger.v3.oas.annotations.Operation;
@ -28,23 +29,17 @@ import java.util.List;
@Tag(name = "中间表添加",description = "添加") @Tag(name = "中间表添加",description = "添加")
@Log4j2 @Log4j2
public class MiddleController { public class MiddleController {
@Autowired
private MiddleService middleService;
@Autowired @Autowired
private CarFenceServiceMybaits carFenceServiceMybaits; private CarFenceServiceMybaits carFenceServiceMybaits;
/** /**
* *
*/ */
@PostMapping("/addCarFence") @PostMapping("/addCarFence")
@Operation(summary = "添加中间",description = "添加中间") @Operation(summary = "添加中间围栏和围栏组",description = "添加中间")
public Result addCarFence(@RequestParam("fenceGroupId") Integer fenceGroupId, @RequestBody List<CarFenceAdd> carFences){ public Result addCarFence(@RequestParam("fenceGroupId") Integer fenceGroupId, @RequestBody List<CarFenceAdd> carFences){
carFenceServiceMybaits.addFenceGroup(fenceGroupId,carFences); boolean i = carFenceServiceMybaits.saveBatch(carFences,fenceGroupId);
System.out.println("围栏组Id"+fenceGroupId); return i?Result.success("添加成功"):Result.error("失败");
System.out.println("围栏Id"+carFences);
return Result.success("成功");
} }
/** /**
@ -55,18 +50,11 @@ public class MiddleController {
@GetMapping("/updateFenceGroupById") @GetMapping("/updateFenceGroupById")
@Operation(summary = "修改围栏状态",description = "修改围栏状态") @Operation(summary = "修改围栏状态",description = "修改围栏状态")
public Result updateFenceGroupById(@RequestParam("groupId") Integer groupId){ public Result updateFenceGroupById(@RequestParam("groupId") Integer groupId){
carFenceServiceMybaits.updateFenceGroupById(groupId);
return Result.success(carFenceServiceMybaits.updateFenceGroupById(groupId)); return Result.success();
} }
/**
*
*/
@GetMapping("/activate")
@Operation(summary = "启动围栏状态",description = "启动围栏状态")
public Result activate(@RequestParam("groupId") Integer groupId){
return Result.success(carFenceServiceMybaits.activate(groupId));
}
/** /**
* id * id
@ -74,20 +62,12 @@ public class MiddleController {
@GetMapping("/BoundFenceGroup") @GetMapping("/BoundFenceGroup")
@Operation(summary = "根据围栏组的id查询绑定的围栏的中间表",description = "根据围栏组的id查询绑定的围栏的中间表") @Operation(summary = "根据围栏组的id查询绑定的围栏的中间表",description = "根据围栏组的id查询绑定的围栏的中间表")
public Result BoundFenceGroup(@RequestParam("groupId") Integer groupId){ public Result BoundFenceGroup(@RequestParam("groupId") Integer groupId){
carFenceServiceMybaits.BoundFenceGroup(groupId);
return Result.success(carFenceServiceMybaits.BoundFenceGroup(groupId));
}
/**
* id
*/
@PostMapping("/addFenceGroupAddCarMiddle")
@Operation(summary = "根据围栏组和车辆的id添加中间表",description = "根据围栏组和车辆的id添加中间表")
public Result addFenceGroupAddCarMiddle(@RequestParam("carId") Integer carId , @RequestBody List<FenceGroup> fenceGroups ){
carFenceServiceMybaits.addFenceGroupAddCarMiddle(carId,fenceGroups);
return Result.success(); return Result.success();
} }
/** /**
* *
*/ */

View File

@ -1,4 +1,4 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController; import com.muyu.common.core.web.controller.BaseController;
@ -6,8 +6,10 @@ import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.common.security.annotation.RequiresPermissions; import com.muyu.common.security.annotation.RequiresPermissions;
import com.muyu.common.security.utils.SecurityUtils; import com.muyu.common.security.utils.SecurityUtils;
import com.muyu.domain.SysCar; import com.muyu.domain.SysCar;
import com.muyu.domain.req.SysCarReq;
import com.muyu.domain.resp.SysCarResp; import com.muyu.domain.resp.SysCarResp;
import com.muyu.service.SysCarService; import com.muyu.enterpise.cache.SysCarCacheService;
import com.muyu.enterpise.service.SysCarService;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
@ -29,15 +31,18 @@ public class SysCarController extends BaseController
@Resource @Resource
private SysCarService sysCarService; private SysCarService sysCarService;
@Resource
private SysCarCacheService sysCarCacheService;
/** /**
* *
*/ */
@RequiresPermissions("car:car:list") @RequiresPermissions("car:car:list")
@GetMapping("/list") @GetMapping("/list")
public Result<TableDataInfo<SysCarResp>> list(SysCar sysCar) public Result<TableDataInfo<SysCarResp>> list(SysCarReq sysCarReq)
{ {
startPage(); startPage();
List<SysCarResp> list = sysCarService.selectSysCarList(sysCar); List<SysCarResp> list = sysCarService.selectSysCarList(sysCarReq);
return getDataTable(list); return getDataTable(list);
} }
@ -62,7 +67,9 @@ public class SysCarController extends BaseController
if (sysCarService.checkIdUnique(sysCar)) { if (sysCarService.checkIdUnique(sysCar)) {
return error("新增 车辆基础信息 '" + sysCar + "'失败,车辆基础信息已存在"); return error("新增 车辆基础信息 '" + sysCar + "'失败,车辆基础信息已存在");
} }
sysCar.setCreateBy(SecurityUtils.getUsername()); sysCar.setCreateBy(SecurityUtils.getUsername());
sysCarCacheService.put(sysCar.getCarVin(),sysCar);
return toAjax(sysCarService.save(sysCar)); return toAjax(sysCarService.save(sysCar));
} }

View File

@ -1,4 +1,4 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.poi.ExcelUtil; import com.muyu.common.core.utils.poi.ExcelUtil;
@ -7,7 +7,7 @@ import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.common.security.annotation.RequiresPermissions; import com.muyu.common.security.annotation.RequiresPermissions;
import com.muyu.common.security.utils.SecurityUtils; import com.muyu.common.security.utils.SecurityUtils;
import com.muyu.domain.SysCarFault; import com.muyu.domain.SysCarFault;
import com.muyu.service.ISysCarFaultService; import com.muyu.enterpise.service.ISysCarFaultService;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletResponse; import jakarta.servlet.http.HttpServletResponse;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;

View File

@ -1,10 +1,12 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.common.core.web.controller.BaseController; import com.muyu.common.core.web.controller.BaseController;
import com.muyu.common.core.web.page.TableDataInfo; import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.domain.SysCarType; import com.muyu.domain.SysCarType;
import com.muyu.service.SysTypeService; import com.muyu.enterpise.cache.SysCarCacheService;
import com.muyu.enterpise.cache.SysCarTypeCacheService;
import com.muyu.enterpise.service.SysTypeService;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
@ -29,6 +31,9 @@ public class SysTypeController extends BaseController {
@Resource @Resource
private SysTypeService sysTypeService; private SysTypeService sysTypeService;
@Resource
private SysCarTypeCacheService sysCarTypeCacheService;
/** /**
* *
@ -37,6 +42,10 @@ public class SysTypeController extends BaseController {
public Result<TableDataInfo<SysCarType>> list() { public Result<TableDataInfo<SysCarType>> list() {
startPage(); startPage();
List<SysCarType> list = sysTypeService.selectSysTypeList(); List<SysCarType> list = sysTypeService.selectSysTypeList();
for (SysCarType sysCarType : list) {
sysCarTypeCacheService.put(String.valueOf(sysCarType.getId()),sysCarType);
}
return getDataTable(list); return getDataTable(list);
} }
} }

View File

@ -1,4 +1,4 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.poi.ExcelUtil; import com.muyu.common.core.utils.poi.ExcelUtil;
@ -6,7 +6,7 @@ import com.muyu.common.core.web.controller.BaseController;
import com.muyu.common.core.web.page.TableDataInfo; import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.common.security.utils.SecurityUtils; import com.muyu.common.security.utils.SecurityUtils;
import com.muyu.domain.WarnLogs; import com.muyu.domain.WarnLogs;
import com.muyu.service.IWarnLogsService; import com.muyu.enterpise.service.IWarnLogsService;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletResponse; import jakarta.servlet.http.HttpServletResponse;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;

View File

@ -1,4 +1,4 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.poi.ExcelUtil; import com.muyu.common.core.utils.poi.ExcelUtil;
@ -6,7 +6,7 @@ import com.muyu.common.core.web.controller.BaseController;
import com.muyu.common.core.web.page.TableDataInfo; import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.common.security.utils.SecurityUtils; import com.muyu.common.security.utils.SecurityUtils;
import com.muyu.domain.WarnRule; import com.muyu.domain.WarnRule;
import com.muyu.service.IWarnRuleService; import com.muyu.enterpise.service.IWarnRuleService;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletResponse; import jakarta.servlet.http.HttpServletResponse;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;

View File

@ -1,4 +1,4 @@
package com.muyu.controller; package com.muyu.enterpise.controller;
import com.muyu.common.core.domain.Result; import com.muyu.common.core.domain.Result;
import com.muyu.common.core.utils.poi.ExcelUtil; import com.muyu.common.core.utils.poi.ExcelUtil;
@ -6,7 +6,7 @@ import com.muyu.common.core.web.controller.BaseController;
import com.muyu.common.core.web.page.TableDataInfo; import com.muyu.common.core.web.page.TableDataInfo;
import com.muyu.common.security.utils.SecurityUtils; import com.muyu.common.security.utils.SecurityUtils;
import com.muyu.domain.WarnStrategy; import com.muyu.domain.WarnStrategy;
import com.muyu.service.IWarnStrategyService; import com.muyu.enterpise.service.IWarnStrategyService;
import io.swagger.v3.oas.annotations.tags.Tag; import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.servlet.http.HttpServletResponse; import jakarta.servlet.http.HttpServletResponse;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;

View File

@ -0,0 +1,19 @@
package com.muyu.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.common.core.web.controller.BaseController;
import com.muyu.domain.CarAndGroupMiddle;
import org.apache.ibatis.annotations.Mapper;
/**
*
* @Authoryan
* @Packagecom.muyu.mapper
* @Projectplues
* @nameCarAndFenceGroupMiddleMapper
* @Date2024/9/29 20:12
*/
@Mapper
public interface CarAndFenceGroupMiddleMapper extends BaseMapper<CarAndGroupMiddle> {
}

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.CarFenceClazz; import com.muyu.domain.CarFenceClazz;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.CarFence; import com.muyu.domain.CarFence;

View File

@ -1,8 +1,9 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.CarFence; import com.muyu.domain.CarFence;
import com.muyu.domain.CarMiddle; import com.muyu.domain.CarMiddle;
import com.muyu.domain.FenceAndGroupMiddle; import com.muyu.domain.CarAndGroupMiddle;
import com.muyu.domain.FenceGroup; import com.muyu.domain.FenceGroup;
import com.muyu.domain.req.CarFenceGroup; import com.muyu.domain.req.CarFenceGroup;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
@ -19,7 +20,7 @@ import java.util.List;
* * @Date2024/9/22 19:25 * * @Date2024/9/22 19:25
*/ */
@Mapper @Mapper
public interface CarFenceServiceMybaitsMapper { public interface CarFenceServiceMybaitsMapper extends BaseMapper<CarMiddle> {
void fenceAdd(CarFenceGroup carFence); void fenceAdd(CarFenceGroup carFence);
@ -32,17 +33,6 @@ public interface CarFenceServiceMybaitsMapper {
*/ */
Integer addFenceGroup(@Param("fenceGroupId") Integer fenceGroupId, @Param("id") Integer id); Integer addFenceGroup(@Param("fenceGroupId") Integer fenceGroupId, @Param("id") Integer id);
/**
*
* @param groupId
* @return
*/
void updateFenceGroupById(@Param("groupId") Integer groupId);
/**
*
*/
void activate(@Param("groupId") Integer groupId);
/** /**
* id * id
@ -71,12 +61,12 @@ public interface CarFenceServiceMybaitsMapper {
* @param carId * @param carId
* @return * @return
*/ */
List<FenceAndGroupMiddle> selectBoundGFenceGroup(@Param("carId") Integer carId); List<CarAndGroupMiddle> selectBoundGFenceGroup(@Param("carId") Integer carId);
/** /**
* *
* @param carGroupId * @param carGroupId
* @return * @return
*/ */
FenceGroup selectGroup(@Param("carGroupId") Integer carGroupId); FenceGroup selectGroup(@Param("carGroupId") Long carGroupId);
} }

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.CarFenceType; import com.muyu.domain.CarFenceType;

View File

@ -0,0 +1,18 @@
package com.muyu.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.CarFence;
import com.muyu.domain.FenceGroup;
import org.apache.ibatis.annotations.Mapper;
/**
*
* @Authoryan
* @Packagecom.muyu.mapper
* @Projectplues
* @nameCarFenceUpdateMapper
* @Date2024/9/30 09:13
*/
@Mapper
public interface CarFenceUpdateMapper extends BaseMapper<FenceGroup> {
}

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.CarType; import com.muyu.domain.CarType;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.FaultCode; import com.muyu.domain.FaultCode;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.FaultCondition; import com.muyu.domain.FaultCondition;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.FaultLabel; import com.muyu.domain.FaultLabel;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.FaultLog; import com.muyu.domain.FaultLog;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.FaultRule; import com.muyu.domain.FaultRule;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.FaultType; import com.muyu.domain.FaultType;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.FenceGroup; import com.muyu.domain.FenceGroup;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.message.Message; import com.muyu.domain.message.Message;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.MessageTemplate; import com.muyu.domain.MessageTemplate;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.MessageValue; import com.muyu.domain.MessageValue;
@ -14,6 +14,5 @@ import org.apache.ibatis.annotations.Select;
*/ */
@Mapper @Mapper
public interface MessageValueMapper extends BaseMapper<MessageValue> { public interface MessageValueMapper extends BaseMapper<MessageValue> {
@Select({"SELECT sct.message_template_id FROM sys_car sc LEFT JOIN sys_car_type sct on sct.id = sc.car_type WHERE sc.car_vin = ${stringVin}"})
Long findByTemplateId(String stringVin);
} }

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.SysCarFault; import com.muyu.domain.SysCarFault;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.SysCar; import com.muyu.domain.SysCar;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.SysCarType; import com.muyu.domain.SysCarType;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.muyu.domain.WarnLogs; import com.muyu.domain.WarnLogs;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;

View File

@ -1,4 +1,4 @@
package com.muyu.mapper; package com.muyu.enterpise.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;

View File

@ -0,0 +1,22 @@
package com.muyu.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.CarAndGroupMiddle;
import com.muyu.domain.FenceGroup;
import java.util.List;
/**
*
* @Authoryan
* @Packagecom.muyu.service
* @Projectplues
* @nameCarAndFenceGroupMiddleService
* @Date2024/9/29 20:10
*/
public interface CarAndFenceGroupMiddleService extends IService<CarAndGroupMiddle> {
/**
* id
*/
boolean saveBatch(List<FenceGroup> fenceGroups, Integer carId);
}

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.CarFenceClazz; import com.muyu.domain.CarFenceClazz;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;

View File

@ -1,6 +1,8 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.CarFence; import com.muyu.domain.CarFence;
import com.muyu.domain.CarMiddle;
import com.muyu.domain.FenceGroup; import com.muyu.domain.FenceGroup;
import com.muyu.domain.req.CarFenceAdd; import com.muyu.domain.req.CarFenceAdd;
@ -14,15 +16,18 @@ import java.util.List;
* * @nameCarFenceServiceMybaits * * @nameCarFenceServiceMybaits
* * @Date2024/9/22 19:24 * * @Date2024/9/22 19:24
*/ */
public interface CarFenceServiceMybaits { public interface CarFenceServiceMybaits extends IService<CarMiddle> {
void add(Integer fenceGroupId, List<Integer> carFenceId);
/** /**
* *
*
* @param fenceGroupId * @param fenceGroupId
* @param carFences * @param carFences
* @return
*/ */
void addFenceGroup(Integer fenceGroupId, List<CarFenceAdd> carFences); boolean saveBatch(List<CarFenceAdd> carFences, Integer fenceGroupId);
/** /**
* *
@ -31,19 +36,18 @@ public interface CarFenceServiceMybaits {
*/ */
Object updateFenceGroupById(Integer groupId); Object updateFenceGroupById(Integer groupId);
/** /**
* *
*/ */
Object activate(Integer groupId); Object activate(Integer groupId);
/** /**
* id * id
*/ */
List<CarFence> BoundFenceGroup(Integer groupId); List<CarFence> BoundFenceGroup(Integer groupId);
/**
* id
*/
void addFenceGroupAddCarMiddle(Integer id, List<FenceGroup> fenceGroups);
/** /**
* *
@ -51,4 +55,6 @@ public interface CarFenceServiceMybaits {
*/ */
List<FenceGroup> selectBoundGFenceGroup(Integer carId); List<FenceGroup> selectBoundGFenceGroup(Integer carId);
} }

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.CarFenceType; import com.muyu.domain.CarFenceType;

View File

@ -0,0 +1,16 @@
package com.muyu.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.CarFence;
import com.muyu.domain.FenceGroup;
/**
*
* @Authoryan
* @Packagecom.muyu.service
* @Projectplues
* @nameCarFenceUpdateService
* @Date2024/9/30 09:12
*/
public interface CarFenceUpdateService extends IService<FenceGroup> {
}

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.CarType; import com.muyu.domain.CarType;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.FaultCondition; import com.muyu.domain.FaultCondition;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.muyu.domain.CarFaultRule; import com.muyu.domain.CarFaultRule;
import com.muyu.domain.FaultReport; import com.muyu.domain.FaultReport;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.FaultLabel; import com.muyu.domain.FaultLabel;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.FaultLog; import com.muyu.domain.FaultLog;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.FaultRule; import com.muyu.domain.FaultRule;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.FaultType; import com.muyu.domain.FaultType;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.FenceGroup; import com.muyu.domain.FenceGroup;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.SysCarFault; import com.muyu.domain.SysCarFault;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.WarnLogs; import com.muyu.domain.WarnLogs;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.WarnRule; import com.muyu.domain.WarnRule;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.WarnStrategy; import com.muyu.domain.WarnStrategy;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.message.Message; import com.muyu.domain.message.Message;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.MessageTemplate; import com.muyu.domain.MessageTemplate;

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.MessageValue; import com.muyu.domain.MessageValue;
@ -27,6 +27,6 @@ public interface MessageValueService extends IService<MessageValue> {
* @param str * @param str
*/ */
void test(String str); void test(String str);
Long findByTemplateId(String stringVin);
} }

View File

@ -1,7 +1,8 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.SysCar; import com.muyu.domain.SysCar;
import com.muyu.domain.req.SysCarReq;
import com.muyu.domain.resp.SysCarResp; import com.muyu.domain.resp.SysCarResp;
import java.util.List; import java.util.List;
@ -26,7 +27,7 @@ public interface SysCarService extends IService<SysCar> {
* @param sysCar * @param sysCar
* @return * @return
*/ */
public List<SysCarResp> selectSysCarList(SysCar sysCar); public List<SysCarResp> selectSysCarList(SysCarReq sysCarReq);
/** /**
* id * id

View File

@ -1,4 +1,4 @@
package com.muyu.service; package com.muyu.enterpise.service;
import com.baomidou.mybatisplus.extension.service.IService; import com.baomidou.mybatisplus.extension.service.IService;
import com.muyu.domain.SysCarType; import com.muyu.domain.SysCarType;

View File

@ -0,0 +1,41 @@
package com.muyu.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.domain.CarAndGroupMiddle;
import com.muyu.domain.FenceGroup;
import com.muyu.mapper.CarAndFenceGroupMiddleMapper;
import com.muyu.service.CarAndFenceGroupMiddleService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
/**
*
* @Authoryan
* @Packagecom.muyu.service.impl
* @Projectplues
* @nameCarAndFenceGroupMiddleServiceImpl
* @Date2024/9/29 20:11
*/
@Service
public class CarAndFenceGroupMiddleServiceImpl extends ServiceImpl<CarAndFenceGroupMiddleMapper, CarAndGroupMiddle> implements CarAndFenceGroupMiddleService {
@Autowired
private CarAndFenceGroupMiddleMapper carAndFenceGroupMiddleMapper;
/**
* id
*/
@Override
public boolean saveBatch(List<FenceGroup> fenceGroups, Integer carId) {
List<CarAndGroupMiddle> list = fenceGroups.stream().map(fenceGroup -> {
CarAndGroupMiddle carAndGroupMiddle = new CarAndGroupMiddle();
//获取围栏组的id
carAndGroupMiddle.setGroupId(fenceGroup.getGroupId());
carAndGroupMiddle.setCarId(carId);
return carAndGroupMiddle;
}).toList();
boolean b = this.saveBatch(list);
return b;
}
}

View File

@ -1,9 +1,9 @@
package com.muyu.service.impl; package com.muyu.enterpise.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.domain.CarFenceClazz; import com.muyu.domain.CarFenceClazz;
import com.muyu.mapper.CarFenceClazzMapper; import com.muyu.enterpise.mapper.CarFenceClazzMapper;
import com.muyu.service.CarFenceClazzService; import com.muyu.enterpise.service.CarFenceClazzService;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
/** /**

View File

@ -1,4 +1,4 @@
package com.muyu.service.impl; package com.muyu.enterpise.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@ -9,10 +9,10 @@ import com.muyu.domain.CarFenceClazz;
import com.muyu.domain.CarFenceType; import com.muyu.domain.CarFenceType;
import com.muyu.domain.req.CarFenceReq; import com.muyu.domain.req.CarFenceReq;
import com.muyu.domain.resp.CarFenceResq; import com.muyu.domain.resp.CarFenceResq;
import com.muyu.mapper.CarFenceMapper; import com.muyu.enterpise.mapper.CarFenceMapper;
import com.muyu.service.CarFenceClazzService; import com.muyu.enterpise.service.CarFenceClazzService;
import com.muyu.service.CarFenceService; import com.muyu.enterpise.service.CarFenceService;
import com.muyu.service.CarFenceTypeService; import com.muyu.enterpise.service.CarFenceTypeService;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;

View File

@ -1,12 +1,16 @@
package com.muyu.service.impl; package com.muyu.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.common.core.utils.StringUtils;
import com.muyu.domain.CarFence; import com.muyu.domain.CarFence;
import com.muyu.domain.CarMiddle; import com.muyu.domain.CarMiddle;
import com.muyu.domain.FenceAndGroupMiddle; import com.muyu.domain.CarAndGroupMiddle;
import com.muyu.domain.FenceGroup; import com.muyu.domain.FenceGroup;
import com.muyu.domain.req.CarFenceAdd; import com.muyu.domain.req.CarFenceAdd;
import com.muyu.mapper.CarFenceServiceMybaitsMapper; import com.muyu.mapper.CarFenceServiceMybaitsMapper;
import com.muyu.service.CarFenceServiceMybaits; import com.muyu.service.CarFenceServiceMybaits;
import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@ -22,59 +26,36 @@ import java.util.List;
* * @Date2024/9/22 19:24 * * @Date2024/9/22 19:24
*/ */
@Service @Service
public class CarFenceServiceMybaitsImpl implements CarFenceServiceMybaits { @Log4j2
public class CarFenceServiceMybaitsImpl extends ServiceImpl<CarFenceServiceMybaitsMapper,CarMiddle> implements CarFenceServiceMybaits {
@Autowired @Autowired
private CarFenceServiceMybaitsMapper carFenceServiceMybaitsMapper; private CarFenceServiceMybaitsMapper carFenceServiceMybaitsMapper;
/**
*
* @param fenceGroupId
* @param carFenceId
*/
@Override
public void add(Integer fenceGroupId, List<Integer> carFenceId) {
for (Integer integer : carFenceId) {
Integer addMiddle = carFenceServiceMybaitsMapper.addGroup(fenceGroupId,integer);
}
}
/** /**
* *
*
* @param fenceGroupId * @param fenceGroupId
* @param carFences * @param carFences
*/
@Override
public void addFenceGroup(Integer fenceGroupId, List<CarFenceAdd> carFences) {
for (CarFenceAdd carFence : carFences) {
Integer id = carFence.getId();
Integer addMiddle = carFenceServiceMybaitsMapper.addFenceGroup(fenceGroupId,id);
}
}
/**
*
* @param groupId
* @return * @return
*/ */
@Override @Override
public Object updateFenceGroupById(Integer groupId) { public boolean saveBatch(List<CarFenceAdd> carFences, Integer fenceGroupId) {
carFenceServiceMybaitsMapper.updateFenceGroupById(groupId); List<CarMiddle> list = carFences.stream().map(carFenceAdd -> {
return null; CarMiddle carMiddle = new CarMiddle();
carMiddle.setCarFenceId(carFenceAdd.getId());
carMiddle.setCarGroupId(fenceGroupId);
return carMiddle;
}).toList();
boolean b = this.saveBatch(list);
return b;
} }
/**
*
*/
@Override
public Object activate(Integer groupId) {
carFenceServiceMybaitsMapper.activate(groupId);
return null;
}
/** /**
* id * id
@ -93,20 +74,9 @@ public class CarFenceServiceMybaitsImpl implements CarFenceServiceMybaits {
return carFences; return carFences;
} }
/**
* id
*/
@Override
public void addFenceGroupAddCarMiddle(Integer id, List<FenceGroup> fenceGroups) {
//遍历集合
for (FenceGroup fenceGroup : fenceGroups) {
//获取围栏组的id
Integer groupId = fenceGroup.getGroupId();
carFenceServiceMybaitsMapper.addFenceGroupAddCarMiddle(id,groupId);
}
}
/** /**
* *
@ -115,18 +85,22 @@ public class CarFenceServiceMybaitsImpl implements CarFenceServiceMybaits {
@Override @Override
public List<FenceGroup> selectBoundGFenceGroup(Integer carId) { public List<FenceGroup> selectBoundGFenceGroup(Integer carId) {
/*根据id查询围栏组的id*/ /*根据id查询围栏组的id*/
List<FenceAndGroupMiddle> list = carFenceServiceMybaitsMapper.selectBoundGFenceGroup(carId); List<CarAndGroupMiddle> list = carFenceServiceMybaitsMapper.selectBoundGFenceGroup(carId);
ArrayList<FenceGroup> fenceGroups = new ArrayList<>(); ArrayList<FenceGroup> fenceGroups = new ArrayList<>();
/*循环*/ /*循环*/
for (FenceAndGroupMiddle fenceAndGroupMiddle : list) { for (CarAndGroupMiddle fenceAndGroupMiddle : list) {
/** /**
* id * id
*/ */
Integer carGroupId = fenceAndGroupMiddle.getGroupId(); Long carGroupId = fenceAndGroupMiddle.getGroupId();
//获取围栏组的数据 并 存入list //获取围栏组的数据 并 存入list
fenceGroups.add(carFenceServiceMybaitsMapper.selectGroup(carGroupId)); fenceGroups.add(carFenceServiceMybaitsMapper.selectGroup(carGroupId));
} }
return fenceGroups; return fenceGroups;
} }
} }

View File

@ -1,9 +1,9 @@
package com.muyu.service.impl; package com.muyu.enterpise.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.domain.CarFenceType; import com.muyu.domain.CarFenceType;
import com.muyu.mapper.CarFenceTypeMapper; import com.muyu.enterpise.mapper.CarFenceTypeMapper;
import com.muyu.service.CarFenceTypeService; import com.muyu.enterpise.service.CarFenceTypeService;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
/** /**

View File

@ -0,0 +1,26 @@
package com.muyu.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.muyu.domain.CarFence;
import com.muyu.domain.FenceGroup;
import com.muyu.mapper.CarFenceUpdateMapper;
import com.muyu.service.CarFenceUpdateService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
*
* @Authoryan
* @Packagecom.muyu.service.impl
* @Projectplues
* @nameCarFenceUpdateServiceImpl
* @Date2024/9/30 09:12
*
*/
@Service
public class CarFenceUpdateServiceImpl extends ServiceImpl<CarFenceUpdateMapper, FenceGroup> implements CarFenceUpdateService {
@Autowired
private CarFenceUpdateMapper carFenceUpdateMapper;
}

Some files were not shown because too many files have changed in this diff Show More