diff --git a/muyu-common/muyu-common-saas/src/main/java/com/muyu/clw/common/many/remote/RemoteMessageDataService.java b/muyu-common/muyu-common-saas/src/main/java/com/muyu/clw/common/many/remote/RemoteMessageDataService.java new file mode 100644 index 0000000..35908dc --- /dev/null +++ b/muyu-common/muyu-common-saas/src/main/java/com/muyu/clw/common/many/remote/RemoteMessageDataService.java @@ -0,0 +1,28 @@ +package com.muyu.clw.common.many.remote; + +import com.muyu.clw.common.many.remote.factory.RemoteEnterpriseFallbackFactory; +import com.muyu.clw.common.many.remote.factory.RemoteMessageDataFallbackFactory; +import com.muyu.common.core.constant.ServiceNameConstants; +import com.muyu.common.core.domain.Result; +import com.muyu.domain.Enterprise; +import com.muyu.domain.MessageData; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.GetMapping; + +import java.util.List; + +/** + * 用户服务 + * + * @author muyu + */ +@FeignClient( + contextId = "remoteMessageDataService", + value = ServiceNameConstants.COMPANY_ENTERPRISE, + fallbackFactory = RemoteMessageDataFallbackFactory.class +) +public interface RemoteMessageDataService { + + @GetMapping("/messageData/list") + public Result> enterpriseAllList(); +} diff --git a/muyu-common/muyu-common-saas/src/main/java/com/muyu/clw/common/many/remote/factory/RemoteMessageDataFallbackFactory.java b/muyu-common/muyu-common-saas/src/main/java/com/muyu/clw/common/many/remote/factory/RemoteMessageDataFallbackFactory.java new file mode 100644 index 0000000..ac896b8 --- /dev/null +++ b/muyu-common/muyu-common-saas/src/main/java/com/muyu/clw/common/many/remote/factory/RemoteMessageDataFallbackFactory.java @@ -0,0 +1,35 @@ +package com.muyu.clw.common.many.remote.factory; + +import com.muyu.clw.common.many.remote.RemoteEnterpriseService; +import com.muyu.clw.common.many.remote.RemoteMessageDataService; +import com.muyu.common.core.domain.Result; +import com.muyu.domain.Enterprise; +import com.muyu.domain.MessageData; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.cloud.openfeign.FallbackFactory; +import org.springframework.stereotype.Component; + +import java.util.List; + +/** + * @ClassName RemoteEnterpriseFallbackFactory + * @Author AnNan.Wang + * @Date 2024/6/7 21:55 + */ + +@Component +public class RemoteMessageDataFallbackFactory implements FallbackFactory { + private static final Logger log = LoggerFactory.getLogger(RemoteMessageDataFallbackFactory.class); + + @Override + public RemoteMessageDataService create(Throwable cause) { + log.error("日志服务调用失败:{}", cause.getMessage()); + return new RemoteMessageDataService() { + @Override + public Result> enterpriseAllList() { + return Result.error("报文配置获取失败:{}"+cause.getMessage()); + } + }; + } +} diff --git a/muyu-modules/muyu-company/muyu-company-common/src/main/java/com/muyu/domain/MessageData.java b/muyu-modules/muyu-company/muyu-company-common/src/main/java/com/muyu/domain/MessageData.java new file mode 100644 index 0000000..3aa4e41 --- /dev/null +++ b/muyu-modules/muyu-company/muyu-company-common/src/main/java/com/muyu/domain/MessageData.java @@ -0,0 +1,50 @@ +package com.muyu.domain; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.muyu.common.core.web.domain.BaseEntity; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; + +/** + * 报文表 + * + * @ClassName MessageData + * @Author AnNan.Wang + * @Date 2024/6/27 9:56 + */ +@Data +@SuperBuilder +@NoArgsConstructor +@AllArgsConstructor +@TableName("message_data") +public class MessageData extends BaseEntity { + /** + * 主键 + */ + @TableId(value = "id",type = IdType.AUTO) + private Long id; + /** + * 报文标签 + */ + private String messageLabel; + /** + * 指标Key + */ + private String analyzeKey; + /** + * 起始位 + */ + private String initiationPosition; + /** + * 终止位 + */ + private String terminatePosition; + /** + * 报文类型 + */ + private String typeIdentification; +} diff --git a/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/MuYuCompanyApplication.java b/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/MuYuCompanyApplication.java index d8114d6..55f4b9e 100644 --- a/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/MuYuCompanyApplication.java +++ b/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/MuYuCompanyApplication.java @@ -1,12 +1,24 @@ package com.muyu.authentication; import com.baomidou.dynamic.datasource.spring.boot.autoconfigure.DynamicDataSourceAutoConfiguration; +import com.muyu.authentication.mapper.EnterpriseMapper; +import com.muyu.common.core.domain.Result; import com.muyu.common.security.annotation.EnableCustomConfig; import com.muyu.common.security.annotation.EnableMyFeignClients; import com.muyu.common.swagger.annotation.EnableCustomSwagger2; +import com.muyu.domain.Enterprise; +import io.netty.handler.address.DynamicAddressConnectHandler; +import org.springframework.amqp.rabbit.annotation.RabbitListener; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.ApplicationArguments; +import org.springframework.boot.ApplicationRunner; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; +import org.springframework.data.redis.core.StringRedisTemplate; + +import java.util.ArrayList; +import java.util.List; /** * 企业模块 @@ -21,4 +33,5 @@ public class MuYuCompanyApplication { public static void main (String[] args) { SpringApplication.run(MuYuCompanyApplication.class, args); } + } diff --git a/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/controller/EnterpriseController.java b/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/controller/EnterpriseController.java index 87bd06c..fb48b4f 100644 --- a/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/controller/EnterpriseController.java +++ b/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/controller/EnterpriseController.java @@ -34,7 +34,7 @@ public class EnterpriseController extends BaseController /** * 查询企业列表 */ - @RequiresPermissions("authentication:enterprise:list") +// @RequiresPermissions("authentication:enterprise:list") @GetMapping("/list") public Result> list(Enterprise enterprise) { diff --git a/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/controller/MessageDataController.java b/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/controller/MessageDataController.java new file mode 100644 index 0000000..8d0045a --- /dev/null +++ b/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/controller/MessageDataController.java @@ -0,0 +1,34 @@ +package com.muyu.authentication.controller; + +import com.muyu.authentication.service.MessageDataService; +import com.muyu.common.core.domain.Result; +import com.muyu.domain.MessageData; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; + +/** + * 报文解析配置Controller层 + * + * @ClassName MessageDataController + * @Author AnNan.Wang + * @Date 2024/6/27 10:27 + */ + +@RestController +@RequestMapping("/messageData") +public class MessageDataController { + @Autowired + private MessageDataService messageDataService; + + @GetMapping("/list") + public Result> list(){ + return Result.success( + messageDataService.messageList() + ); + } +} diff --git a/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/mapper/MessageDataMapper.java b/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/mapper/MessageDataMapper.java new file mode 100644 index 0000000..829fa12 --- /dev/null +++ b/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/mapper/MessageDataMapper.java @@ -0,0 +1,15 @@ +package com.muyu.authentication.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.muyu.domain.MessageData; + +/** + * 报文解析Mapper层 + * + * @author AnNan.Wang + * @ClassName: MessageDataMapper + * @createTime: 2024/6/27 10:33 + */ + +public interface MessageDataMapper extends BaseMapper { +} diff --git a/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/service/MessageDataService.java b/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/service/MessageDataService.java new file mode 100644 index 0000000..20e7f90 --- /dev/null +++ b/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/service/MessageDataService.java @@ -0,0 +1,19 @@ +package com.muyu.authentication.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.muyu.domain.MessageData; + +import java.util.List; + +/** + * 报文解析配置Service层 + * + * @author AnNan.Wang + * @ClassName: MessageDataService + * @createTime: 2024/6/27 10:30 + */ +public interface MessageDataService extends IService { + List messageList(); + + +} diff --git a/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/service/impl/EnterpriseServiceImpl.java b/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/service/impl/EnterpriseServiceImpl.java index f5842c5..6d51ab2 100644 --- a/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/service/impl/EnterpriseServiceImpl.java +++ b/muyu-modules/muyu-company/muyu-company-server/src/main/java/com/muyu/authentication/service/impl/EnterpriseServiceImpl.java @@ -19,9 +19,11 @@ import com.muyu.common.system.domain.SysUser; import com.muyu.common.system.remote.RemoteUserService; import com.muyu.domain.vo.EnterpriseReq; import com.muyu.many.domain.Message.MessageData; +import com.muyu.many.forewarning.EarlyWarning; import lombok.extern.log4j.Log4j2; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.ApplicationEventPublisher; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Service; import com.muyu.domain.Enterprise; @@ -40,6 +42,8 @@ public class EnterpriseServiceImpl extends ServiceImpl + implements MessageDataService { + + @Autowired + private MessageDataMapper messageDataMapper; + + @Override + public List messageList() { + return messageDataMapper.selectList(null); + } +} diff --git a/muyu-modules/muyu-modules-many/muyu-modules-many-common/src/main/java/com/muyu/many/domain/MessageAnalysis.java b/muyu-modules/muyu-modules-many/muyu-modules-many-common/src/main/java/com/muyu/many/domain/MessageAnalysis.java new file mode 100644 index 0000000..ab95d86 --- /dev/null +++ b/muyu-modules/muyu-modules-many/muyu-modules-many-common/src/main/java/com/muyu/many/domain/MessageAnalysis.java @@ -0,0 +1,57 @@ +package com.muyu.many.domain; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; + +/** + * 报文解析配置 + * + * @ClassName MessageAnalysis + * @Author AnNan.Wang + * @Date 2024/6/26 18:38 + */ + +@Data +@SuperBuilder +@NoArgsConstructor +@AllArgsConstructor +@TableName("message_analysis") +public class MessageAnalysis { + /** + * 主键 + */ + @TableId(value = "id",type = IdType.AUTO) + private Long id; + /** + * 车辆ID + */ + private Long vehicleId; + /** + * 指标项key + */ + private String analyzeKey; + /** + * 起始位 + */ + private Integer analyzeStart; + /** + * 终止位 + */ + private Integer ent; + /** + * 指标项标签 + */ + private String lable; + /** + * 类型 + */ + private String type; + + +} diff --git a/muyu-modules/muyu-modules-many/muyu-modules-many-common/src/main/java/com/muyu/many/domain/Vehicle.java b/muyu-modules/muyu-modules-many/muyu-modules-many-common/src/main/java/com/muyu/many/domain/Vehicle.java index ab94fae..4c12d12 100644 --- a/muyu-modules/muyu-modules-many/muyu-modules-many-common/src/main/java/com/muyu/many/domain/Vehicle.java +++ b/muyu-modules/muyu-modules-many/muyu-modules-many-common/src/main/java/com/muyu/many/domain/Vehicle.java @@ -112,6 +112,9 @@ public class Vehicle extends BaseEntity { @ApiModelProperty(name = "车辆类型", value = "车辆类型") private String vehicleType; + @Excel(name = "报文") + @ApiModelProperty(name = "报文", value = "报文") + private String messageDetail; /** 电子围栏ID */ @Excel(name = "电子围栏ID") @ApiModelProperty(name = "电子围栏ID", value = "电子围栏ID") diff --git a/muyu-modules/muyu-modules-many/muyu-modules-many-common/src/main/java/com/muyu/many/forewarning/EarlyWarning.java b/muyu-modules/muyu-modules-many/muyu-modules-many-common/src/main/java/com/muyu/many/forewarning/EarlyWarning.java new file mode 100644 index 0000000..3db1605 --- /dev/null +++ b/muyu-modules/muyu-modules-many/muyu-modules-many-common/src/main/java/com/muyu/many/forewarning/EarlyWarning.java @@ -0,0 +1,27 @@ +package com.muyu.many.forewarning; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; +import org.springframework.context.ApplicationEvent; + +import java.io.Serializable; + +/** + * 指标预警 + * + * @ClassName EarlyWarning + * @Author AnNan.Wang + * @Date 2024/6/25 9:37 + */ + +@Data +@SuperBuilder +@NoArgsConstructor +@AllArgsConstructor +public class EarlyWarning implements Serializable { + private Integer id; + private String name; +} diff --git a/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/MuYuManyApplication.java b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/MuYuManyApplication.java index a7b3aad..1665e8d 100644 --- a/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/MuYuManyApplication.java +++ b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/MuYuManyApplication.java @@ -1,16 +1,30 @@ package com.muyu.authentication; -import com.baomidou.dynamic.datasource.spring.boot.autoconfigure.DynamicDataSourceAutoConfiguration; +import com.alibaba.fastjson.JSON; +import com.muyu.authentication.mapper.MessageAnalysisMapper; +import com.muyu.authentication.mapper.VehicleMapper; import com.muyu.clw.common.many.datasource.holder.DynamicDataSourceHolder; +import com.muyu.clw.common.many.remote.RemoteEnterpriseService; +import com.muyu.common.core.domain.Result; import com.muyu.common.security.annotation.EnableCustomConfig; import com.muyu.common.security.annotation.EnableMyFeignClients; import com.muyu.common.swagger.annotation.EnableCustomSwagger2; +import com.muyu.domain.Enterprise; +import com.muyu.many.domain.MessageAnalysis; +import com.muyu.many.domain.Vehicle; +import org.apache.commons.collections4.map.HashedMap; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.ApplicationArguments; +import org.springframework.boot.ApplicationRunner; import org.springframework.boot.SpringApplication; -import org.springframework.boot.actuate.jdbc.DataSourceHealthIndicator; import org.springframework.boot.autoconfigure.SpringBootApplication; -import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.scheduling.annotation.EnableScheduling; +import java.util.*; +import java.util.concurrent.TimeUnit; + /** * 企业模块 * @@ -21,8 +35,35 @@ import org.springframework.scheduling.annotation.EnableScheduling; @EnableCustomSwagger2 @EnableMyFeignClients @SpringBootApplication -public class MuYuManyApplication { +public class MuYuManyApplication implements ApplicationRunner { public static void main (String[] args) { SpringApplication.run(MuYuManyApplication.class, args); } + + @Autowired + private RemoteEnterpriseService remoteEnterpriseService; + @Autowired + private VehicleMapper vehicleMapper; + @Autowired + private RedisTemplate redisTemplate; + @Autowired + private MessageAnalysisMapper messageAnalysisMapper; + + @Override + public void run(ApplicationArguments args) throws Exception { + Result> enterprised = remoteEnterpriseService.enterpriseAllList(); + List enterpriseList = enterprised.getData(); + + + for (Enterprise enterprise1 : enterpriseList) { + String ent = "ent_" + enterprise1.getContactPhone().substring(enterprise1.getContactPhone().length() - 4); + DynamicDataSourceHolder.setDynamicDataSourceKey(ent); + List vehicles = vehicleMapper.selectList(null); + List messageAnalyses = messageAnalysisMapper.selectList(null); + + for (Vehicle vehicle : vehicles) { + redisTemplate.opsForValue().set(vehicle.getVin(), JSON.toJSONString(messageAnalyses),4,TimeUnit.HOURS); + } + } + } } diff --git a/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/controller/ManyEnterpriseController.java b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/controller/ManyEnterpriseController.java index 0cc91a9..fa78ed4 100644 --- a/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/controller/ManyEnterpriseController.java +++ b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/controller/ManyEnterpriseController.java @@ -29,10 +29,4 @@ public class ManyEnterpriseController { ); } -// @PostMapping("/manyEnterpriseAdd") -// public Result manyEnterpriseAdd(@RequestBody Enterprise enterprise,@RequestHeader("ent_code")String key){ -// return Result.success( -// manyEnterpriseService.manyEnterpriseAdd(enterprise,key) -// ); -// } } diff --git a/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/controller/MessageAnalysisController.java b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/controller/MessageAnalysisController.java new file mode 100644 index 0000000..7ec20e3 --- /dev/null +++ b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/controller/MessageAnalysisController.java @@ -0,0 +1,34 @@ +package com.muyu.authentication.controller; + +import com.muyu.authentication.service.MessageAnalysisService; +import com.muyu.common.core.domain.Result; +import com.muyu.many.domain.MessageAnalysis; +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; + +import java.util.List; + +/** + * 报文解析配置的Controller层 + * + * @ClassName MessageAnalysisController + * @Author AnNan.Wang + * @Date 2024/6/26 18:40 + */ + +@RestController +@RequestMapping("/messageAnalysis") +public class MessageAnalysisController { + @Autowired + private MessageAnalysisService messageAnalysisService; + + @PostMapping("/messageAnalysisAdd") + public Result messageAnalysisAdd(@RequestBody List messageAnalysisList){ + return messageAnalysisService.messageAnalysisAdd(messageAnalysisList); + } + + +} diff --git a/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/mapper/ManyEnterpriseMapper.java b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/mapper/ManyEnterpriseMapper.java index a64981f..d475a10 100644 --- a/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/mapper/ManyEnterpriseMapper.java +++ b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/mapper/ManyEnterpriseMapper.java @@ -11,5 +11,4 @@ import com.muyu.many.domain.Enterprise ; * @createTime: 2024/6/6 15:52 */ public interface ManyEnterpriseMapper extends BaseMapper { - int enterpriseInsert(Enterprise enterprise); } diff --git a/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/mapper/MessageAnalysisMapper.java b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/mapper/MessageAnalysisMapper.java new file mode 100644 index 0000000..ae31b1a --- /dev/null +++ b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/mapper/MessageAnalysisMapper.java @@ -0,0 +1,15 @@ +package com.muyu.authentication.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.muyu.many.domain.MessageAnalysis; + +/** + * 报文解析配置的Mapper层 + * + * @author AnNan.Wang + * @ClassName: MessageAnalysisMapper + * @createTime: 2024/6/26 18:44 + */ + +public interface MessageAnalysisMapper extends BaseMapper { +} diff --git a/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/service/MessageAnalysisService.java b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/service/MessageAnalysisService.java new file mode 100644 index 0000000..4ab3022 --- /dev/null +++ b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/service/MessageAnalysisService.java @@ -0,0 +1,19 @@ +package com.muyu.authentication.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.muyu.common.core.domain.Result; +import com.muyu.many.domain.MessageAnalysis; + +import java.util.List; + +/** + * 报文解析配置的Service层 + * + * @author AnNan.Wang + * @ClassName: MessageAnalysisService + * @createTime: 2024/6/26 18:41 + */ + +public interface MessageAnalysisService extends IService { + Result messageAnalysisAdd(List messageAnalysisList); +} diff --git a/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/service/impl/MessageAnalysisServiceImpl.java b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/service/impl/MessageAnalysisServiceImpl.java new file mode 100644 index 0000000..6b5f926 --- /dev/null +++ b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/java/com/muyu/authentication/service/impl/MessageAnalysisServiceImpl.java @@ -0,0 +1,42 @@ +package com.muyu.authentication.service.impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.muyu.authentication.mapper.MessageAnalysisMapper; +import com.muyu.authentication.service.MessageAnalysisService; +import com.muyu.common.core.domain.Result; +import com.muyu.many.domain.MessageAnalysis; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * 报文解析配置实现类 + * + * @ClassName MessageAnalysisServiceImpl + * @Author AnNan.Wang + * @Date 2024/6/26 18:43 + */ + +@Service +public class MessageAnalysisServiceImpl extends ServiceImpl + implements MessageAnalysisService { + @Autowired + private MessageAnalysisMapper messageAnalysisMapper; + + @Override + public Result messageAnalysisAdd(List messageAnalysisList) { + for (MessageAnalysis messageAnalysis : messageAnalysisList) { + messageAnalysisMapper.insert( + MessageAnalysis.builder() + .analyzeKey(messageAnalysis.getAnalyzeKey()) + .analyzeStart(messageAnalysis.getAnalyzeStart()) + .ent(messageAnalysis.getEnt()) + .lable(messageAnalysis.getLable()) + .type(messageAnalysis.getType()) + .build() + ); + } + return Result.success(); + } +} diff --git a/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/resources/mapper/VehicleMapper.xml b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/resources/mapper/VehicleMapper.xml index 871fe2d..a7cb208 100644 --- a/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/resources/mapper/VehicleMapper.xml +++ b/muyu-modules/muyu-modules-many/muyu-modules-many-server/src/main/resources/mapper/VehicleMapper.xml @@ -19,6 +19,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" + @@ -29,6 +30,6 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" - select id, vin, brand, model, production_date, body_type, color, engine_capacity, fuel_type, transmission, drive_type, mileage, registration_date, license_number, vehicle_type, fence_id, create_by, create_time, update_by, update_time, remark from vehicle + select id, vin, brand, model, production_date, body_type, color, engine_capacity, fuel_type, transmission, drive_type, mileage, registration_date, license_number, vehicle_type, fence_id, create_by, create_time, update_by, update_time, remark,message_detail from vehicle