diff --git a/muyu-modules/muyu-business/muyu-business-common/src/main/java/com/business/common/Select/BreakdownSel.java b/muyu-modules/muyu-business/muyu-business-common/src/main/java/com/business/common/Select/BreakdownSel.java index 6933a9b..5c1abc1 100644 --- a/muyu-modules/muyu-business/muyu-business-common/src/main/java/com/business/common/Select/BreakdownSel.java +++ b/muyu-modules/muyu-business/muyu-business-common/src/main/java/com/business/common/Select/BreakdownSel.java @@ -11,6 +11,10 @@ import java.util.Date; @Data public class BreakdownSel{ + /** + * 车辆 + */ + private String vin; /** * 多 */ diff --git a/muyu-modules/muyu-business/muyu-business-common/src/main/java/com/business/common/domain/FenceGroups.java b/muyu-modules/muyu-business/muyu-business-common/src/main/java/com/business/common/domain/FenceGroups.java index 5302f9b..c920236 100644 --- a/muyu-modules/muyu-business/muyu-business-common/src/main/java/com/business/common/domain/FenceGroups.java +++ b/muyu-modules/muyu-business/muyu-business-common/src/main/java/com/business/common/domain/FenceGroups.java @@ -1,5 +1,6 @@ package com.business.common.domain; +import com.business.common.middle.GroupFenceDev; import lombok.Data; import java.util.List; @@ -17,4 +18,9 @@ public class FenceGroups { * 围栏组名称 */ private String groupsName; + /** + * 围栏组所属电子围栏 + */ + private List fenceList; + } diff --git a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/controller/BreakdownController.java b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/controller/BreakdownController.java index bcdbb1f..ce99e47 100644 --- a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/controller/BreakdownController.java +++ b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/controller/BreakdownController.java @@ -6,14 +6,18 @@ import com.business.common.domain.FaultCode; import com.business.common.domain.Sources; import com.business.common.psvm.FaultInfo; import com.muyu.common.core.domain.Result; +import com.muyu.common.core.utils.poi.ExcelUtil; import com.muyu.common.core.web.controller.BaseController; import com.muyu.common.core.web.page.TableDataInfo; +import com.muyu.common.log.annotation.Log; +import com.muyu.common.log.enums.BusinessType; import com.muyu.goods.incident.mq.Producer; import com.muyu.goods.service.IBreakdownService; import lombok.extern.log4j.Log4j2; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; +import javax.servlet.http.HttpServletResponse; import java.util.Date; import java.util.List; import java.util.Map; @@ -27,21 +31,26 @@ public class BreakdownController extends BaseController { @Autowired private Producer producer; - /** - * 分页 - * @return - */ - /** - * 查询故障列表 - */ @GetMapping("/list") - public Result> list( ) + public Result> list(Breakdown breakdown) { startPage(); - List list = service.selectBreakdownList(); + List list = service.selectBreakdownList(breakdown); return getDataTable(list); } + /** + * 导出故障列表 + */ + @Log(title = "故障", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, Breakdown breakdown) + { + List list = service.selectBreakdownList(breakdown); + ExcelUtil util = new ExcelUtil(Breakdown.class); + util.exportExcel(response, list, "故障数据"); + } + @PostMapping("/lists") public Result> lists() { List list = service.lists(); diff --git a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/controller/MapController.java b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/controller/MapController.java index df01fe0..f89f3a3 100644 --- a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/controller/MapController.java +++ b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/controller/MapController.java @@ -1,6 +1,7 @@ package com.muyu.goods.controller; import com.business.common.dev.CarFenceGroupsDev; +import com.business.common.domain.Path; import com.business.common.middle.CarFenceDev; import com.business.common.middle.CarGroupsDev; import com.business.common.middle.GroupFenceDev; @@ -45,7 +46,7 @@ public class MapController extends BaseController { * @return */ @PostMapping("selectFenceGroupsById/{carId}") - public Result>> selectFenceGroupsById(@PathVariable Long carId){ + public Result> selectFenceGroupsById(@PathVariable Long carId){ return success(iMapService.selectFenceGroupsById(carId)); } @@ -66,7 +67,7 @@ public class MapController extends BaseController { * @return */ @PostMapping("getSel") - public Result getSel(@RequestBody Pences list){ + public Result getSel(@RequestBody List list){ return success(iMapService.getSel(list)); } diff --git a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/mapper/BreakdownMapper.java b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/mapper/BreakdownMapper.java index caddda6..07896ea 100644 --- a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/mapper/BreakdownMapper.java +++ b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/mapper/BreakdownMapper.java @@ -4,7 +4,6 @@ import com.business.common.Select.BreakdownSel; import com.business.common.domain.Breakdown; import com.business.common.domain.Car; import com.business.common.domain.FaultCode; -import com.business.common.psvm.FaultInfo; import org.apache.ibatis.annotations.Param; import java.util.List; @@ -19,7 +18,13 @@ public interface BreakdownMapper { Car selectVinCar(@Param("vin") String vin); - List selectBreakdownList(); + /** + * 查询故障列表 + * + * @param breakdown 故障 + * @return 故障集合 + */ + public List selectBreakdownList(Breakdown breakdown); List> pies(BreakdownSel breakdownSel); diff --git a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/mapper/MapMapper.java b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/mapper/MapMapper.java index 6ea7c80..b1b5769 100644 --- a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/mapper/MapMapper.java +++ b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/mapper/MapMapper.java @@ -12,7 +12,7 @@ import java.util.List; public interface MapMapper { - List selectFenceGroups(); + List selectFenceGroups(); List selectFence(); @@ -43,4 +43,6 @@ public interface MapMapper { FenceGroups selectFenceGroupsByOne(); void indexCarGroupsDev(@Param("carId") Long carId, @Param("groupsId") Long groupsId); + + void indexFence(Fence fence); } diff --git a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/IBreakdownService.java b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/IBreakdownService.java index ac357ea..8231853 100644 --- a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/IBreakdownService.java +++ b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/IBreakdownService.java @@ -4,17 +4,18 @@ import com.business.common.Select.BreakdownSel; import com.business.common.domain.Breakdown; import com.business.common.domain.FaultCode; import com.business.common.domain.Sources; -import com.business.common.psvm.FaultInfo; import java.util.List; import java.util.Map; public interface IBreakdownService { /** - * 故障记录 - * @return + * 查询故障列表 + * + * @param breakdown 故障 + * @return 故障集合 */ - List selectBreakdownList(); + public List selectBreakdownList(Breakdown breakdown); List lists(); diff --git a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/IMapService.java b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/IMapService.java index 6973e16..3f26303 100644 --- a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/IMapService.java +++ b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/IMapService.java @@ -1,6 +1,7 @@ package com.muyu.goods.service; import com.business.common.dev.CarFenceGroupsDev; +import com.business.common.domain.Path; import com.business.common.middle.CarFenceDev; import com.business.common.middle.CarGroupsDev; import com.business.common.middle.GroupFenceDev; @@ -17,9 +18,9 @@ public interface IMapService { List selectFence(); - List> selectFenceGroupsById(Long carId); + List selectFenceGroupsById(Long carId); - String getSel(Pences list); + String getSel(List list); String deleteFence(Long fenceId); diff --git a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/impl/BreakdownService.java b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/impl/BreakdownService.java index abfc2bb..661f055 100644 --- a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/impl/BreakdownService.java +++ b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/impl/BreakdownService.java @@ -5,7 +5,6 @@ import com.business.common.domain.Breakdown; import com.business.common.domain.Car; import com.business.common.domain.FaultCode; import com.business.common.domain.Sources; -import com.business.common.psvm.FaultInfo; import com.muyu.common.goods.domain.Enterprise; import com.muyu.common.goods.remote.RemoteSourcesService; import com.muyu.common.system.domain.SysUser; @@ -29,13 +28,15 @@ public class BreakdownService implements IBreakdownService { private RemoteSourcesService remoteSourcesService; /** - * 故障记录 - * @param breakdown - * @return + * 查询故障列表 + * + * @param breakdown 故障 + * @return 故障 */ @Override - public List selectBreakdownList() { - return mapper.selectBreakdownList(); + public List selectBreakdownList(Breakdown breakdown) + { + return mapper.selectBreakdownList(breakdown); } @Override diff --git a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/impl/MapService.java b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/impl/MapService.java index b89acd2..f31de1a 100644 --- a/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/impl/MapService.java +++ b/muyu-modules/muyu-business/muyu-business-server/src/main/java/com/muyu/goods/service/impl/MapService.java @@ -2,6 +2,7 @@ package com.muyu.goods.service.impl; import com.alibaba.fastjson.JSONObject; import com.business.common.dev.CarFenceGroupsDev; +import com.business.common.domain.Path; import com.business.common.middle.CarFenceDev; import com.business.common.middle.CarGroupsDev; import com.business.common.middle.GroupFenceDev; @@ -16,6 +17,7 @@ import org.springframework.transaction.annotation.Transactional; import java.util.ArrayList; import java.util.List; +import java.util.Random; import java.util.stream.Collectors; @Service @@ -30,6 +32,10 @@ public class MapService implements IMapService { @Override public List selectFenceGroups() { List fenceGroupsList = mapMapper.selectFenceGroups(); + for (FenceGroups fenceGroups : fenceGroupsList) { + List groupFenceDevs = selectGroupFence().stream().filter(groupFenceDev -> groupFenceDev.getGroupsId() == fenceGroups.getGroupsId()).collect(Collectors.toList()); + fenceGroups.setFenceList(groupFenceDevs); + } return fenceGroupsList; } @@ -49,16 +55,19 @@ public class MapService implements IMapService { * @return */ @Override - public List> selectFenceGroupsById(Long carId) { + public List selectFenceGroupsById(Long carId) { List carGroupsDevs = selectCarGroups(); - List carGroupsDevList = carGroupsDevs.stream().filter(group -> group.getCarId() == carId).collect(Collectors.toList()); - List> listList = new ArrayList<>(); + List groupsDevs = carGroupsDevs.stream().filter(carGroupsDev -> carGroupsDev.getCarId() == carId).collect(Collectors.toList()); + //围栏组和电子围栏 List groupFenceDevs = selectGroupFence(); - for (CarGroupsDev carGroupsDev : carGroupsDevList) { - List groupFenceDevList = groupFenceDevs.stream().filter(group -> group.getGroupsId() == carGroupsDev.getGroupsId()).collect(Collectors.toList()); - listList.add(groupFenceDevList); + List groupFenceDevList = new ArrayList<>(); + for (CarGroupsDev groupsDev : groupsDevs) { + for (GroupFenceDev groupFenceDev : groupFenceDevs.stream().filter(groupFenceDev -> groupFenceDev.getGroupsId() == groupsDev.getGroupsId()).collect(Collectors.toList())) { + groupFenceDevList.add(groupFenceDev); + } } - return listList; + System.out.println(groupFenceDevList); + return groupFenceDevList; } /** @@ -67,9 +76,17 @@ public class MapService implements IMapService { * @return */ @Override - public String getSel(Pences pences) { - System.out.println(pences); - return JSONObject.toJSONString(pences); + public String getSel(List list) { + Fence fence = new Fence(); + String jsonString = JSONObject.toJSONString(list); + System.out.println(jsonString); + fence.setPolygonPoints(jsonString); + Random random = new Random(); + int i = random.nextInt(4); + fence.setFenceName(String.valueOf(i)); + System.out.println(fence); +// mapMapper.indexFence(fence); + return jsonString; } /** diff --git a/muyu-modules/muyu-business/muyu-business-server/src/main/resources/bootstrap.yml b/muyu-modules/muyu-business/muyu-business-server/src/main/resources/bootstrap.yml index ef538bf..5806aa5 100644 --- a/muyu-modules/muyu-business/muyu-business-server/src/main/resources/bootstrap.yml +++ b/muyu-modules/muyu-business/muyu-business-server/src/main/resources/bootstrap.yml @@ -23,14 +23,6 @@ spring: # 共享配置 shared-configs: - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} - kafka: - bootstrap-servers: 129.211.23.219:9200 # kafka集群地址 - consumer: - group-id: my-group #消费者组id - auto-offset-reset: earliest #默认偏移量位置 - key-deserializer: org.apache.kafka.common.serialization.StringDeserializer #键序列化器 - value-deserializer: org.apache.kafka.common.serialization.StringDeserializer #值序列化器 - enable-auto-commit: false # 是否自动提交offset logging: level: com.muyu.rule.mapper: DEBUG diff --git a/muyu-modules/muyu-business/muyu-business-server/src/main/resources/mapper/rule/BreakdownMapper.xml b/muyu-modules/muyu-business/muyu-business-server/src/main/resources/mapper/rule/BreakdownMapper.xml index f6ce8d5..eaca45e 100644 --- a/muyu-modules/muyu-business/muyu-business-server/src/main/resources/mapper/rule/BreakdownMapper.xml +++ b/muyu-modules/muyu-business/muyu-business-server/src/main/resources/mapper/rule/BreakdownMapper.xml @@ -60,12 +60,18 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" select * from car where vin = #{vin}; - + + + and vin = #{vin} + and fault_start_time >= #{faultStartTime} + and fault_start_time <= #{faultEndTime} + select * from status