server/system_service/src/main/java/com/doumee/core/utils/Constants.java
@@ -139,6 +139,8 @@ public static final String TMS_INTERFACE_URL_PREFIX ="TMS_INTERFACE_URL_PREFIX" ; public static final String MYSQL_BACKUP_CDOE ="MYSQL_BACKUP_CDOE" ; public static final String MYSQL_BACKUP_DIR ="MYSQL_BACKUP_DIR" ; public static final String EVENT_FILES_PRIVATE_DOMAIN ="EVENT_FILES_PRIVATE_DOMAIN" ; public static final String EVENT_FILES_PUBLIC_DOMAIN ="EVENT_FILES_PUBLIC_DOMAIN" ; public static boolean DEALING_HK_SYNCPRIVILEGE= false; public static boolean DEALING_HK_SYNCDEVICE = false; public static boolean DEALING_HK_SYNCPLATFORM = false; @@ -378,6 +380,16 @@ int invalid =9; } public interface RetentionCarType{ //车è¾ç±»å 0å é¨è½¦è¾ 1ç¸å ³æ¹è½¦è¾ 2è®¿å®¢è½¦è¾ 3å è¿ç©æµè½¦ 4å¤åè½¦è¾ 5å¸å ¬å¸å¸è´§è½¦ int internal = 0; int relation = 1; int visitor = 2; int selfTruck = 3; int outTruck = 4; int cityComTruck = 5; } public interface EmpowerStatus{ //ä¸å¡éææä¸åç¶æ 0å¾ ä¸å 1å·²ä¸å 2ä¸åæå 3已忶 4ä¸å失败 5ä»»å¡ä¸è½½å·²ç»æ @@ -458,6 +470,14 @@ d = d.setScale(4, BigDecimal.ROUND_HALF_UP); return d; } public static BigDecimal formatBigdecimal2Float(BigDecimal d) { if (d == null) { d = new BigDecimal(0.0); } //ä¿ç两ä½å°æ°ä¸åèäºå ¥ d = d.setScale(2, BigDecimal.ROUND_HALF_UP); return d; } server/system_service/src/main/java/com/doumee/core/utils/DateUtil.java
@@ -460,7 +460,7 @@ * @return String * @throws Exception */ public static String getPlusTime(Date date) throws Exception { public static String getPlusTime(Date date) { if (date == null) return null; try { server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/board/SecurityController.java
@@ -1,12 +1,18 @@ package com.doumee.cloud.board; import com.doumee.api.BaseController; import com.doumee.config.annotation.CloudRequiredPermission; import com.doumee.config.annotation.LoginNoRequired; import com.doumee.core.haikang.model.param.respose.PageRegionInfoResponse; import com.doumee.core.haikang.model.param.respose.RuleEventSearchResponse; import com.doumee.core.model.ApiResponse; import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; import com.doumee.core.utils.Constants; import com.doumee.dao.admin.response.PCWorkPlatformDataVO; import com.doumee.dao.business.model.Visits; import com.doumee.dao.web.response.platformReport.*; import com.doumee.service.business.VisitsService; import com.doumee.service.business.third.BoardService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; @@ -15,10 +21,7 @@ import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.*; import java.math.BigDecimal; import java.util.ArrayList; @@ -40,32 +43,14 @@ @Autowired private BoardService boardService; @Autowired private VisitsService visitsService; @LoginNoRequired @ApiOperation("ä¸å¿æ°æ®") @GetMapping("/centerData") public ApiResponse<SecurityBoardVO> centerData() { SecurityBoardVO data = new SecurityBoardVO(); Random random = new Random(); data.setParkingLotTotal(random.nextInt(200)); data.setFreeParkingLot(random.nextInt(data.getParkingLotTotal())); data.setInternalCarTotal(random.nextInt(100)); data.setRelatedCarTotal(random.nextInt(100)); data.setVisitCarTotal(random.nextInt(100)); data.setInParkCarTotal(data.getInternalCarTotal() + data.getRelatedCarTotal() + data.getVisitCarTotal()); data.setInternalTotal(random.nextInt(100)); data.setRelatedTotal(random.nextInt(100)); data.setVisitTotal(random.nextInt(100)); data.setInParkTotal(data.getInternalTotal() + data.getRelatedTotal() + data.getVisitTotal()); data.setDeviceTotal(random.nextInt(20)); data.setErrTotal(random.nextInt(20)); data.setInternalJobCarTotal(random.nextInt(20)); data.setVisitJobCarTotal(random.nextInt(20)); data.setRelatedJobCarTotal(random.nextInt(20)); public ApiResponse<SecurityBoardVO> centerSecurityData() { SecurityBoardVO data = boardService.centerSecurityData(); return ApiResponse.success(data); } @@ -75,16 +60,6 @@ @GetMapping("/securityDeviceData") public ApiResponse<List<SecurityDeviceDataVO>> securityDeviceData() { List<SecurityDeviceDataVO> list = boardService.securityDeviceData(); /* Random random = new Random(); for (int i = 1; i <= 3; i++) { SecurityDeviceDataVO data = new SecurityDeviceDataVO(); data.setDeviceType("设å¤ç±»å_"+i); data.setOnlineNum(random.nextInt(10)); data.setOfflineDeviceNum(random.nextInt(10)); data.setTotalNum(data.getOnlineNum() + data.getOfflineDeviceNum() ); list.add(data); }*/ return ApiResponse.success(list); } @LoginNoRequired @@ -93,18 +68,8 @@ @ApiImplicitParam(paramType = "query", dataType = "Integer", name = "type", value = "ç±»å 0å ¨é¨ 1åºååè¦ 2è¡ä¸ºåè¦", required = false) }) @GetMapping("/warningEventData") public ApiResponse<List<WaningEventDataVO>> warningEventData(Integer type) { List<WaningEventDataVO> list = boardService.warningEventData(type); /* Random random = new Random(); for (int i = 1; i <= 3; i++) { SecurityDeviceDataVO data = new SecurityDeviceDataVO(); data.setDeviceType("设å¤ç±»å_"+i); data.setOnlineNum(random.nextInt(10)); data.setOfflineDeviceNum(random.nextInt(10)); data.setTotalNum(data.getOnlineNum() + data.getOfflineDeviceNum() ); list.add(data); }*/ public ApiResponse<WaningEventDataVO> warningEventData(Integer type) { WaningEventDataVO list = boardService.warningEventData(type); return ApiResponse.success(list); } @@ -115,15 +80,24 @@ @ApiOperation("访客æ»çæ åµ") @GetMapping("/visitRetentionData") public ApiResponse<List<VisitRetentionDataVO>> visitRetentionData() { PageWrap<Visits> pageWrap = new PageWrap<>(); pageWrap.setCapacity(10); pageWrap.setPage(1); pageWrap.setModel(new Visits()); pageWrap.getModel().setLevelStatus(Constants.ZERO); pageWrap.getModel().setStatus(Constants.TWO); PageData<Visits> resut = visitsService.retentionPage(pageWrap); List<VisitRetentionDataVO> list = new ArrayList<>(); Random random = new Random(); for (int i = 1; i <= 3; i++) { VisitRetentionDataVO data = new VisitRetentionDataVO(); data.setName("å°æ_"+i); data.setCompanyName("è¿ç»´ç»_"+i); data.setTimeOutMinute(Long.valueOf(random.nextInt(200))); list.add(data); if(resut !=null && resut.getRecords() !=null && resut.getRecords().size()>0){ for (Visits model : resut.getRecords()) { VisitRetentionDataVO data = new VisitRetentionDataVO(); data.setName(model.getName()); data.setCompanyName(model.getCompanyName()); data.setTimeOutMinute(Constants.formatIntegerNum(model.getTimeOut())); list.add(data); } } return ApiResponse.success(list); } @@ -152,11 +126,23 @@ } @LoginNoRequired @ApiOperation("å¹³éºç»æåºåé忥å£") @GetMapping("/regionList") public ApiResponse<List<PageRegionInfoResponse>> regionList(CarmeraListVO param) { @PostMapping("/regionList") public ApiResponse<List<PageRegionInfoResponse>> regionList(@RequestBody CarmeraListVO param) { return ApiResponse.success(boardService.regionList(param)); } @LoginNoRequired @ApiOperation("è·åçæ§æµææ¾å°å") @GetMapping("/getCarmeraPreviemUrl") public ApiResponse<String> getCarmeraPreviemUrl(CarmeraListVO param) { return ApiResponse.success(boardService.getCarmeraPreviemUrl(param)); } @LoginNoRequired @ApiOperation("仿¥è®¿å®¢åæåæ»çè®¿å®¢æ°æ®éå") @GetMapping("/visitSecurityData") public ApiResponse<VisitDataVO> visitSecurityData ( ){ VisitDataVO data = boardService.visitSecurityData(); return ApiResponse.success(data); } } server/visits/dmvisit_admin/src/main/resources/bootstrap.yml
@@ -1,6 +1,6 @@ spring: profiles: active: dev active: pro application: name: visitsAdmin # å®å ¨é ç½® server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKConstants.java
@@ -149,6 +149,7 @@ String[] ruleEventSearch= new String[]{"/api/v2/ruleEvent/search","å®é²çæ¿-仿¥åè¦äºä»¶-æ ¹æ®eventTypeåæ®µ3"};//å®é²çæ¿-仿¥åè¦äºä»¶-æ ¹æ®eventTypeåæ®µ3[å¾ç] String[] getSecureDevStatusList= new String[]{"/api/secureDataService/v2/getSecureDevStatusList","å®é²çæ¿-ååºå®é²è®¾å¤-åç±»å设å¤ç¶ææ°æ®å表"};//å®é²çæ¿-ååºå®é²è®¾å¤-åç±»å设å¤ç¶ææ°æ®å表 String[] getSecureDevStatusTotal= new String[]{"/api/secureDataService/v2/getSecureDevStatusTotal","ç»è®¡ååºæ»ä½çå®é²è®¾å¤æ°éï¼å¨çº¿æ°ãå¨çº¿çã离线æ°ã离线ç"};//ç»è®¡ååºæ»ä½çå®é²è®¾å¤æ°éï¼å¨çº¿æ°ãå¨çº¿çã离线æ°ã离线ç String[] getParkingStatistics= new String[]{"/api/dataBoardService/v1/getParkingStatistics","å®é²çæ¿--ååºå®æ¶è½¦æ°é4"};//å®é²çæ¿--ååºå®æ¶è½¦æ°é4 } /** * éå½A.55æ¶é²è®¾å¤ç±»å server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java
@@ -783,6 +783,13 @@ return startDoPostStringArtemis(HKConstants.InterfacePath.getSecureDevStatusTotal,body); } /** * ç»å®é²çæ¿--ååºå®æ¶è½¦æ°é4 * @return */ public static String getParkingStatistics() { return startDoGetStringArtemis(HKConstants.InterfacePath.getParkingStatistics,null); } /** * è·åæå°ç¶æ * @return */ server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/RuleEventFiledOptionsRequest.java
@@ -1,12 +1,13 @@ package com.doumee.core.haikang.model.param.request; import com.doumee.core.haikang.model.param.BaseListPageRequest; import lombok.Data; import java.util.List; @Data public class RuleEventFiledOptionsRequest { public class RuleEventFiledOptionsRequest { private String fieldName;// String false åæ®µåç§° private String fieldValue ;//String false åæ®µå¼ private String type;// String false æ¥è¯¢ç±»åï¼å¯éèå´ï¼eqï¼ç¸çï¼ãneq(ä¸ç¸ç)ãlikeï¼ç±»ä¼¼ï¼ãltï¼å°äºï¼ãgtï¼å¤§äºï¼ãlteï¼å°äºçäºï¼ãgteï¼å¤§äºçäºï¼ãinï¼èå´ï¼ãnotIn(èå´ä¹å¤)ãinï¼fieldValueçå¼å¯ä»¥å¡«å¤ä¸ªï¼ç¨è±æéå·åéãnotNull(ä¸ä¸ºç©º)ãisNull(为空)ãrecently(æè¿)ã private String fieldValue ;//String false åæ®µå¼ private String type;// String false æ¥è¯¢ç±»åï¼å¯éèå´ï¼eqï¼ç¸çï¼ãneq(ä¸ç¸ç)ãlikeï¼ç±»ä¼¼ï¼ãltï¼å°äºï¼ãgtï¼å¤§äºï¼ãlteï¼å°äºçäºï¼ãgteï¼å¤§äºçäºï¼ãinï¼èå´ï¼ãnotIn(èå´ä¹å¤)ãinï¼fieldValueçå¼å¯ä»¥å¡«å¤ä¸ªï¼ç¨è±æéå·åéãnotNull(ä¸ä¸ºç©º)ãisNull(为空)ãrecently(æè¿)ã } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/RuleEventSearchRequest.java
@@ -10,4 +10,6 @@ private String[] regionIds;// Array false ååºå¯¹åºåºåidä¿¡æ¯,item ç±»å: stringï¼ä¼ 空listæ¥å ¨é¨ private String includeBool;// Number false æ¯å¦å å«ä¸çº§åèç¹,0-ä¸å å«,1-å å« private List<RuleEventFiledOptionsRequest > filedOptions;// Array false çéåæ®µå表> private List<SortRequest > sorts;//æåºé¤å®¿ } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/SortRequest.java
@@ -8,5 +8,8 @@ private String field ;// string False æåºå段ï¼å¯¹åºæ¥è¯¢ç¨çåæ°åç§° private String sort ;// string False æåºè§åï¼ascï¼æ£åºï¼ descï¼ååº private String sortField ;// String false æåºå段 private String sortType ;// s String false æåºç±»åï¼æ¯ædescãasc } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/respose/ParkingStatisticResponse.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,12 @@ package com.doumee.core.haikang.model.param.respose; import lombok.Data; import java.math.BigDecimal; @Data public class ParkingStatisticResponse { private TodayCarDataResponse todayCarDataDto;//BigDecimal Object false 仿¥å å¤é¨è½¦è¾æ°æ®Dto private TodayParkingDataResponse todayParkingDataDto ;//Object false 仿¥è½¦ä½æ°æ® } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/respose/RuleEventSearchDataResponse.java
@@ -1,5 +1,6 @@ package com.doumee.core.haikang.model.param.respose; import com.alibaba.fastjson.annotation.JSONField; import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Data; @@ -45,5 +46,6 @@ private String level_color;// String false level_color private String plan_exec_status;// String false plan_exec_status @JsonProperty(value = "_image_url") @JSONField(name = "_image_url") private String imgurl;// String false ææå¾çå°å } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/respose/TodayCarDataResponse.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,12 @@ package com.doumee.core.haikang.model.param.respose; import lombok.Data; import java.math.BigDecimal; @Data public class TodayCarDataResponse { private Integer innerCarCount;// Number false å é¨è½¦è¾æ°é private Integer outerCarCount ;//Number false å¤é¨è½¦è¾æ°é } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/respose/TodayParkingDataResponse.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,17 @@ package com.doumee.core.haikang.model.param.respose; import lombok.Data; import java.math.BigDecimal; @Data public class TodayParkingDataResponse { private Integer leftPlace ;//Number false å©ä½è½¦ä½æ°é private Integer totalPlace ;//umber false æ»è½¦ä½æ°é private String usePlace;// String false å·²ç¨è½¦ä½æ°é private BigDecimal useRate ;//Number false 车ä½ä½¿ç¨ç private String parkName ;//String false å车åºåç§° private String parkSyscode ;//String false å车åºå¯ä¸æ è¯ private String statisticsTime ;//String false ç»è®¡æ è¯ } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/service/HKService.java
@@ -1480,7 +1480,7 @@ TypeReference typeReference = new TypeReference< BaseResponse<BaseListPageResponse<PageCameraInfoResponse>> >(){}; BaseResponse<BaseListPageResponse<PageCameraInfoResponse>> result = JSONObject.parseObject(res, typeReference.getType()); logResult(result,"海康å页è·åçæ§ç¹èµæº"); // logResult(result,"海康å页è·åçæ§ç¹èµæº"); return result; }catch (Exception e){ log.error("ãæµ·åº·å页è·åçæ§ç¹èµæºã================失败====ï¼\n"+ e.getMessage()); @@ -1527,13 +1527,13 @@ *å®é²çæ¿-仿¥åè¦äºä»¶-æ ¹æ®eventTypeåæ®µ3 * @return */ public static BaseResponse< RuleEventSearchResponse> ruleEventSearch(RuleEventSearchRequest param){ public static BaseResponse<BaseListPageResponse<RuleEventSearchDataResponse>> ruleEventSearch(RuleEventSearchRequest param){ log.info("ãæµ·åº·å®é²çæ¿-仿¥åè¦äºä»¶-æ ¹æ®eventTypeåæ®µ3ã================å¼å§===="+JSONObject.toJSONString(param)); try { String res = HKTools.ruleEventSearch(JSONObject.toJSONString(param)); TypeReference typeReference = new TypeReference< BaseResponse<RuleEventSearchResponse> >(){}; BaseResponse<RuleEventSearchResponse> result = JSONObject.parseObject(res, typeReference.getType()); new TypeReference< BaseResponse<BaseListPageResponse<RuleEventSearchDataResponse>> >(){}; BaseResponse<BaseListPageResponse<RuleEventSearchDataResponse>> result = JSONObject.parseObject(res, typeReference.getType()); logResult(result,"海康å®é²çæ¿-仿¥åè¦äºä»¶-æ ¹æ®eventTypeåæ®µ3"); return result; }catch (Exception e){ @@ -1542,6 +1542,24 @@ return null; } /** *ç»è®¡ç»å®é²çæ¿--ååºå®æ¶è½¦æ°é4 * @return */ public static BaseResponse<ParkingStatisticResponse> getParkingStatistics(){ log.info("ãæµ·åº·å®é²çæ¿--ååºå®æ¶è½¦æ°é4ã================å¼å§===="); try { String res = HKTools.getParkingStatistics(); TypeReference typeReference = new TypeReference< BaseResponse<ParkingStatisticResponse>>(){}; BaseResponse<ParkingStatisticResponse> result = JSONObject.parseObject(res, typeReference.getType()); logResult(result,"海康å®é²çæ¿--ååºå®æ¶è½¦æ°é4"); return result; }catch (Exception e){ log.error("ãæµ·åº·å®é²çæ¿--ååºå®æ¶è½¦æ°é4ã================失败====ï¼\n"+ e.getMessage()); } return null; } /** *ç»è®¡ååºæ»ä½çå®é²è®¾å¤æ°éï¼å¨çº¿æ°ãå¨çº¿çã离线æ°ã离线ç * @return */ server/visits/dmvisit_service/src/main/java/com/doumee/dao/admin/response/CarEventDTO.java
@@ -98,6 +98,9 @@ @ApiModelProperty(value = "ç»ç»ç±»åï¼0=ç¸å ³æ¹ï¼1=å é¨") private String companyType; @ApiModelProperty(value = "车è¾ç±»å 0å é¨è½¦è¾ 1ç¸å ³æ¹è½¦è¾ 2è®¿å®¢è½¦è¾ 3å è¿ç©æµè½¦ 4å¤åè½¦è¾ 5å¸å ¬å¸å¸è´§è½¦ ") private String carType; @ApiModelProperty(value = "å§å") @ExcelColumn(name="å§å",index = 7,width = 16) private String personName; server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/CarsMapper.java
@@ -2,6 +2,7 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.doumee.dao.business.model.Cars; import com.github.yulichang.base.MPJBaseMapper; import java.util.List; @@ -9,6 +10,6 @@ * @author æ±è¹è¹ * @date 2023/11/30 15:33 */ public interface CarsMapper extends BaseMapper<Cars> { public interface CarsMapper extends MPJBaseMapper<Cars> { } server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/CarEvent.java
@@ -222,6 +222,11 @@ @ApiModelProperty(value = "人åç¼ç ") private Integer memberId ; @ApiModelProperty(value = "车è¾ç±»å 0å é¨è½¦è¾ 1ç¸å ³æ¹è½¦è¾ 2è®¿å®¢è½¦è¾ 3å è¿ç©æµè½¦ 4å¤åè½¦è¾ 5å¸å ¬å¸å¸è´§è½¦ ") private Integer carType ; @ApiModelProperty(value = "人åç¼ç ") @TableField(exist = false) private Integer companyId ; // æ¡ä»¶æ¥è¯¢åæ° server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/Cars.java
@@ -171,6 +171,10 @@ //@ExcelColumn(name="é¨é¨") @TableField(exist = false) private String companyName; @ApiModelProperty(value = "é¨é¨ç±»å", example = "1") //@ExcelColumn(name="é¨é¨") @TableField(exist = false) private Integer companyType; @ApiModelProperty(value = "车主æ¯å¦å é¤", example = "1") @TableField(exist = false) private Integer memberDeleted; server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/Retention.java
@@ -84,7 +84,8 @@ @ApiModelProperty(value = "海康é¨ç¦åç§°") @ExcelColumn(name="è¿åé¨ç¦" ,index = 6,width = 12) private String deviceName; @ApiModelProperty(value = "车è¾ç±»å 0å é¨è½¦è¾ 1ç¸å ³æ¹è½¦è¾ 2è®¿å®¢è½¦è¾ 3å è¿ç©æµè½¦ 4å¤åè½¦è¾ 5å¸å ¬å¸å¸è´§è½¦ ") private Integer carType ; @ApiModelProperty(value = "海康é¨ç¦ç¼ç ") private String deviceIndex; @@ -120,6 +121,9 @@ @ApiModelProperty(value = "ç±»å 0å³å¡å ¬å¸ 1å é¨ç»ç»") @TableField(exist = false) private Integer companyType; @ApiModelProperty(value = "ç±»å 0访客 1å é¨äººå") @TableField(exist = false) private Integer memberType; @ApiModelProperty(value = "å¼å§æ¶é´") @TableField(exist = false) server/visits/dmvisit_service/src/main/java/com/doumee/dao/web/response/platformReport/InMemberDataVO.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,42 @@ package com.doumee.dao.web.response.platformReport; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import java.math.BigDecimal; /** * è®¿å®¢åæ * * @Author : Rk * @create 2024/10/25 10:59 */ @Data public class InMemberDataVO { @ApiModelProperty(value = "å¾ è®¿é®æ°é") private Integer waitVisitNum; @ApiModelProperty(value = "å¾ è®¿é®å æ¯") private BigDecimal waitVisitRata; @ApiModelProperty(value = "å·²ç»è®°æ°é") private Integer registerVisitNum; @ApiModelProperty(value = "å·²ç»è®°å æ¯") private BigDecimal registerVisitRata; @ApiModelProperty(value = "å·²ç¦»å¼æ°é") private Integer levelNum; @ApiModelProperty(value = "已离å¼å æ¯") private BigDecimal levelRata; @ApiModelProperty(value = "æ»çæ°é") private Integer retentionNum; @ApiModelProperty(value = "æ»çå æ¯") private BigDecimal retentionRata; } server/visits/dmvisit_service/src/main/java/com/doumee/dao/web/response/platformReport/SecurityBoardVO.java
@@ -17,49 +17,50 @@ @ApiModelProperty(value = "æ»è½¦ä½æ°é") private Integer parkingLotTotal; private int parkingLotTotal; @ApiModelProperty(value = "å©ä½è½¦ä½æ°é") private Integer freeParkingLot; private int freeParkingLot; @ApiModelProperty(value = "车ä½ä½¿ç¨ç") private BigDecimal parkingUseRate; @ApiModelProperty(value = "å工车è¾") private Integer internalCarTotal; private int internalCarTotal; @ApiModelProperty(value = "ç¸å ³æ¹è½¦è¾") private Integer relatedCarTotal; private int relatedCarTotal; @ApiModelProperty(value = "访客车è¾") private Integer visitCarTotal; private int visitCarTotal; @ApiModelProperty(value = "å½åå¨å人æ°") private Integer inParkTotal; private int inParkTotal; @ApiModelProperty(value = "å¨åå é¨äººåæ°é") private Integer internalTotal; private int internalTotal; @ApiModelProperty(value = "å¨åç¸å ³æ¹æ°é") private Integer relatedTotal; private int relatedTotal; @ApiModelProperty(value = "å¨å访客æ°é") private Integer visitTotal; private int visitTotal; @ApiModelProperty(value = "å½åå¨åè½¦è¾æ»æ°") private Integer inParkCarTotal; private int inParkCarTotal; @ApiModelProperty(value = "å½åè®¾å¤æ»æ°") private Integer deviceTotal; private int deviceTotal; @ApiModelProperty(value = "å½åæ¥è¦æ»æ°") private Integer errTotal; private int errTotal; @ApiModelProperty(value = "å è¿è½¦ï¼å®æ³°èªæè½¦ï¼") private Integer internalJobCarTotal; private int internalJobCarTotal; @ApiModelProperty(value = "å¤åè¿è¾è½¦è¾") private Integer relatedJobCarTotal; private int relatedJobCarTotal; @ApiModelProperty(value = "å¸å ¬å¸è½¦è¾") private Integer visitJobCarTotal; private int visitJobCarTotal; //TODO å®é²åè¦ server/visits/dmvisit_service/src/main/java/com/doumee/dao/web/response/platformReport/VisitDataVO.java
@@ -4,6 +4,7 @@ import lombok.Data; import java.math.BigDecimal; import java.util.List; /** * è®¿å®¢åæ @@ -15,28 +16,30 @@ public class VisitDataVO { @ApiModelProperty(value = "å¾ è®¿é®æ°é") private Integer waitVisitNum; private long waitVisitNum; @ApiModelProperty(value = "å¾ è®¿é®å æ¯") private BigDecimal waitVisitRata; @ApiModelProperty(value = "å·²ç»è®°æ°é") private Integer registerVisitNum; private long registerVisitNum; @ApiModelProperty(value = "å·²ç»è®°å æ¯") private BigDecimal registerVisitRata; @ApiModelProperty(value = "å·²ç¦»å¼æ°é") private Integer levelNum; private long levelNum; @ApiModelProperty(value = "已离å¼å æ¯") private BigDecimal levelRata; @ApiModelProperty(value = "æ»çæ°é") private Integer retentionNum; private long retentionNum; @ApiModelProperty(value = "æ»çå æ¯") private BigDecimal retentionRata; @ApiModelProperty(value = "访客æ»çæ åµ") private List<VisitRetentionDataVO> visitRetentionDataList; } server/visits/dmvisit_service/src/main/java/com/doumee/dao/web/response/platformReport/VisitRetentionDataVO.java
@@ -19,6 +19,6 @@ private String companyName; @ApiModelProperty(value = "è¶ æ¶æ¶é¿ åä½ï¼åé") private Long timeOutMinute; private int timeOutMinute; } server/visits/dmvisit_service/src/main/java/com/doumee/dao/web/response/platformReport/WaningEventDataListVO.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,28 @@ package com.doumee.dao.web.response.platformReport; import io.swagger.annotations.ApiModelProperty; import lombok.Data; /** * ååºå®é²è®¾å¤ * * @Author : Rk * @create 2024/10/25 10:59 */ @Data public class WaningEventDataListVO { @ApiModelProperty(value = "æ é¢") private String title; @ApiModelProperty(value = "å¾çå°å") private String img; @ApiModelProperty(value = "æ¶é´") private String createDate; @ApiModelProperty(value = "åçå°ç¹") private String addr; @ApiModelProperty(value = "å 容") private String content; } server/visits/dmvisit_service/src/main/java/com/doumee/dao/web/response/platformReport/WaningEventDataVO.java
@@ -4,6 +4,7 @@ import lombok.Data; import java.util.Date; import java.util.List; /** * ååºå®é²è®¾å¤ @@ -14,17 +15,10 @@ @Data public class WaningEventDataVO { @ApiModelProperty(value = "æ é¢") private String title; @ApiModelProperty(value = "å¾çå°å") private String img; @ApiModelProperty(value = "æ¶é´") private String createDate; @ApiModelProperty(value = "åçå°ç¹") private String addr; @ApiModelProperty(value = "å 容") private String content; @ApiModelProperty(value = "åè¦æ»æ°") private int total; @ApiModelProperty(value = "åè¦æ°é(æè¿10æ¡ï¼") private List<WaningEventDataListVO> list; } server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/CarEventServiceImpl.java
@@ -318,7 +318,6 @@ IPage<CarEvent> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper<CarEvent> queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); queryWrapper .leftJoin(Member.class,Member::getId,CarEvent::getMemberId) .leftJoin(Company.class,Company::getId,Member::getCompanyId); server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformServiceImpl.java
@@ -381,6 +381,7 @@ bean.setUseRata( bean.getWorkCountTime().multiply(new BigDecimal(100)).divide(sumTime,BigDecimal.ROUND_HALF_DOWN,2) ); bean.setUseRata(Constants.formatBigdecimal2Float(bean.getUseRata()));//强å¶ä¿ç两ä½å°æ° } } return platformList; server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/VisitsServiceImpl.java
@@ -133,6 +133,8 @@ @Autowired private EmayService emayService; @Override public Integer create(Visits visits) { visitsMapper.insert(visits); @@ -1262,10 +1264,7 @@ QueryWrapper<Visits> wrapper = new QueryWrapper<>(visits); return visitsMapper.selectCount(wrapper); } @Override public PageData<Visits> retentionPage(PageWrap<Visits> pageWrap) { public static PageData<Visits> retentionPageBiz(PageWrap<Visits> pageWrap, VisitsJoinMapper visitsJoinMapper,SystemDictDataBiz systemDictDataBiz) { String code= systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.TIMEOUT_WARNING).getCode(); IPage<Visits> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper<Visits> queryWrapper = new MPJLambdaWrapper<>(); @@ -1277,9 +1276,7 @@ queryWrapper.leftJoin(Member.class,Member::getId,Visits::getReceptMemberId); queryWrapper.leftJoin(Company.class,Company::getId,Member::getCompanyId); queryWrapper.leftJoin(" member m on m.id= t.MEMBER_ID"); queryWrapper.eq(Objects.nonNull(pageWrap.getModel().getLevelStatus()),Visits::getStatus,Constants.VisitStatus.signin); queryWrapper.apply(Objects.nonNull(pageWrap.getModel().getLevelStatus())," TIMESTAMPDIFF( MINUTE, NOW(), t.OUT_DATE) <= "+code+" "); queryWrapper.ne("m.type ",Constants.TWO); @@ -1308,6 +1305,11 @@ return PageData.from(result); } @Override public PageData<Visits> retentionPage(PageWrap<Visits> pageWrap) { return retentionPageBiz(pageWrap,visitsJoinMapper,systemDictDataBiz); } @Override server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncPushServiceImpl.java
@@ -834,6 +834,44 @@ event.setPlatePicUrl(getHkImgUrl(request.getData().getPicUrl().getPlatePicUrl())); } if(StringUtils.isNotBlank(event.getPlateNos())){ Cars carModel = carsMapper.selectJoinOne(Cars.class,new MPJLambdaWrapper<Cars>() .selectAll(Cars.class ) .selectAs(Company::getType,Cars::getCompanyType) .leftJoin(Company.class,Company::getId,Cars::getGroupId) .eq(Cars::getCode,event.getPlateNos()) .eq(Cars::getIsdeleted,Constants.ZERO) .last(" limit 1")); if(carModel!=null){ //0宿³°å ¬å¡è½¦ 1宿³°èªæç©æµè½¦ 2å ¶å® event.setMemberId(carModel.getMemberId()); event.setCompanyId(carModel.getGroupId()); if(Constants.equalsInteger(carModel.getType(),Constants.ONE)){ event.setCarType(Constants.RetentionCarType.selfTruck); }else { if(Constants.equalsInteger(carModel.getCompanyType(),Constants.ONE)){ event.setCarType(Constants.RetentionCarType.internal);//å é¨è½¦è¾ }else{ event.setCarType(Constants.RetentionCarType.relation);//ç¸å ³æ¹è½¦è¾ } } } PlatformJob carTypeJob = platformJobMapper.selectOne(new QueryWrapper<PlatformJob>().lambda() .eq(PlatformJob::getCarCodeFront,event.getPlateNos()) .eq(PlatformJob::getIsdeleted,Constants.ZERO) .orderByAsc(PlatformJob::getCreateDate) .last(" limit 1")); if(carTypeJob!=null){ //ä½ä¸ç±»å 0èªæè½¦å¸è´§ 1èªæè½¦è£ è´§ 2å¤å车å¸è´§ 3å¤åè½¦è£ è´§ 4å¸å ¬å¸å¤å车å¸è´§ if(Constants.equalsInteger(carTypeJob.getType(),Constants.FOUR)){ event.setCarType(Constants.RetentionCarType.cityComTruck);//å¸å ¬å¸è½¦è¾ }else if(Constants.equalsInteger(carTypeJob.getType(),Constants.TWO) || Constants.equalsInteger(carTypeJob.getType(),Constants.THREE)){ event.setCarType(Constants.RetentionCarType.outTruck);//å¤å车 }else{ event.setCarType(Constants.RetentionCarType.selfTruck);//èªæè½¦ } } ParkBook cars = parkBookMapper.selectOne(new QueryWrapper<ParkBook>().lambda() .eq(ParkBook::getCarCode,event.getPlateNos()) .eq(ParkBook::getIsdeleted,Constants.ZERO ) @@ -884,9 +922,6 @@ } } }; }else{ Visits visits = visitsMapper.selectOne(new QueryWrapper<Visits>().lambda() .eq(Visits::getCarNos,event.getPlateNos()) @@ -898,12 +933,13 @@ if(visits!=null){ //æè¿ä½¿ç¨è¯¥è½¦çç³è¯·äººï¼å·²å°è¾¾ï¼ event.setMemberId(visits.getMemberId()); event.setCarType(Constants.RetentionCarType.visitor); } } if(Constants.formatIntegerNum(request.getEventType()) == HKConstants.EventTypes.PARK_PASS_IN.getKey()){ //妿æ¯å ¥åæ¾è¡ delRetentionList.add(event.getPlateNos()); retentionList.add(getRetentionModelByParkRequest(request)); retentionList.add(getRetentionModelByParkRequest(request,event)); inoutDayCount.setInCarNum(Constants.formatIntegerNum(inoutDayCount.getInCarNum())+1); }else if(Constants.formatIntegerNum(request.getEventType()) == HKConstants.EventTypes.PARK_PASS_OUT.getKey()){ //妿æ¯åºåºæ¾è¡ @@ -914,12 +950,15 @@ return event; } private Retention getRetentionModelByParkRequest(EventParkInfoRequest request) { private Retention getRetentionModelByParkRequest(EventParkInfoRequest request,CarEvent event) { Retention retention = new Retention(); retention.setIsdeleted(Constants.ZERO); retention.setCreateDate(DateUtil.getISO8601DateByStr(request.getHappenTime())); retention.setCarNo(request.getData().getPlateNo()); retention.setType(Constants.THREE); retention.setMemberId(event.getMemberId()); retention.setCarType(event.getCarType()); retention.setCompanyId(event.getCompanyId()); // retention.setDeviceName(request.getSrcName()); // retention.setDeviceIndex(request.getSrcIndex()); return retention; server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/BoardServiceImpl.java
@@ -2,31 +2,35 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; import com.doumee.core.haikang.model.HKConstants; import com.doumee.core.haikang.model.param.BaseListPageResponse; import com.doumee.core.haikang.model.param.BaseResponse; import com.doumee.core.haikang.model.param.BaseListPageRequest; import com.doumee.core.haikang.model.param.request.RuleEventFiledOptionsRequest; import com.doumee.core.haikang.model.param.request.RuleEventSearchRequest; import com.doumee.core.haikang.model.param.request.SecureDevStatusTotalRequest; import com.doumee.core.haikang.model.param.request.SensorStatusListRequest; import com.doumee.core.haikang.model.param.request.*; import com.doumee.core.haikang.model.param.respose.*; import com.doumee.core.haikang.service.HKService; import com.doumee.core.model.ApiResponse; import com.doumee.core.model.PageData; import com.doumee.core.model.PageWrap; import com.doumee.core.utils.Constants; import com.doumee.core.utils.DateUtil; import com.doumee.core.utils.Utils; import com.doumee.dao.business.*; import com.doumee.dao.business.join.VisitsJoinMapper; import com.doumee.dao.business.model.*; import com.doumee.dao.system.model.SystemDictData; import com.doumee.dao.web.reqeust.SavePlatformWarnEventDTO; import com.doumee.dao.web.response.platformReport.*; import com.doumee.service.business.impl.PlatformJobServiceImpl; import com.doumee.service.business.impl.VisitsServiceImpl; import com.doumee.service.business.third.BoardService; import com.github.yulichang.wrapper.MPJLambdaWrapper; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.checkerframework.checker.units.qual.C; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -45,6 +49,8 @@ @Autowired private PlatformLogMapper platformLogMapper; @Autowired private SystemDictDataBiz systemDictDataBiz; @Autowired private PlatformWarnEventMapper platformWarnEventMapper; @Autowired private PlatformJobMapper platformJobMapper; @@ -52,6 +58,10 @@ private PlatformWmsDetailMapper platformWmsDetailMapper; @Autowired private PlatformMapper platformMapper; @Autowired private VisitsJoinMapper visitsJoinMapper; @Autowired private RetentionMapper retentionMapper; @Autowired private PlatformGroupMapper platformGroupMapper; /** @@ -93,7 +103,9 @@ return data; } private void initReginCameralList(List<PageRegionInfoResponse> allList,String name) { List<CarmeraListVO> carmeraListVOList = cameraList(null); CarmeraListVO re = new CarmeraListVO(); re.setName(name); List<CarmeraListVO> carmeraListVOList = cameraList(re); if(carmeraListVOList!=null && carmeraListVOList.size()>0){ for(PageRegionInfoResponse p : allList){ for(CarmeraListVO c : carmeraListVOList){ @@ -176,13 +188,15 @@ List<CarmeraListVO> data = new ArrayList<>(); for(PageCameraInfoResponse p : allList){ CarmeraListVO t = new CarmeraListVO(); t.setIndexCode(p.getCameraIndexCode()); t.setReginCode(p.getRegionIndexCode()); t.setName(p.getCameraName()); t.setStatus(p.getStatus()); t.setStatusName(p.getStatusName()); data.add(t); if(StringUtils.isBlank(req.getName()) ||StringUtils.contains(p.getCameraName(),req.getName())){ CarmeraListVO t = new CarmeraListVO(); t.setIndexCode(p.getCameraIndexCode()); t.setReginCode(p.getRegionIndexCode()); t.setName(p.getCameraName()); t.setStatus(p.getStatus()); t.setStatusName(p.getStatusName()); data.add(t); } } return data; } @@ -299,7 +313,10 @@ @Override public List<SecurityDeviceDataVO> securityDeviceData(){ List<SecurityDeviceDataVO> list = new ArrayList<>(); BaseResponse<List<SecureDevStatusListResponse>> result = HKService.getSecureDevStatusList(new SecureDevStatusTotalRequest()) ; SecureDevStatusTotalRequest request =new SecureDevStatusTotalRequest(); request.setIncludeBool(""); request.setRegionIds(new String[]{}); BaseResponse<List<SecureDevStatusListResponse>> result = HKService.getSecureDevStatusList(request) ; if(result!=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE) && result.getData()!=null){ List<SecureDevStatusListResponse> rlist = result.getData(); for(SecureDevStatusListResponse r :rlist){ @@ -324,32 +341,172 @@ return list; } @Override public List<WaningEventDataVO> warningEventData(Integer type){ List<WaningEventDataVO> list = new ArrayList<>(); public WaningEventDataVO warningEventData(Integer type){ WaningEventDataVO lastResult = new WaningEventDataVO(); List<WaningEventDataListVO> list = new ArrayList<>(); RuleEventSearchRequest request = new RuleEventSearchRequest(); request.setPageNo(1); request.setPageSize(10); request.setFiledOptions(new ArrayList<>()); request.setSorts(new ArrayList<>()); RuleEventFiledOptionsRequest file = new RuleEventFiledOptionsRequest(); file.setFieldName("event_type"); file.setFieldValue("131588");//å®é²åè¦ file.setType("eq"); file.setType("in"); request.getFiledOptions().add(file); BaseResponse< RuleEventSearchResponse> result = HKService.ruleEventSearch(request); SortRequest sort = new SortRequest(); sort.setSortField("happen_time"); sort.setSortType("desc"); request.getSorts().add(sort); BaseResponse<BaseListPageResponse< RuleEventSearchDataResponse>> result = HKService.ruleEventSearch(request); if(result!=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE) && result.getData()!=null){ List<RuleEventSearchDataResponse> rlist = result.getData().getList(); lastResult.setTotal(result.getData().getTotal()); if(rlist!=null){ String privateIp =systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.EVENT_FILES_PRIVATE_DOMAIN).getCode(); String publicIp =systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.EVENT_FILES_PUBLIC_DOMAIN).getCode(); for(RuleEventSearchDataResponse r :rlist){ WaningEventDataVO data = new WaningEventDataVO(); WaningEventDataListVO data = new WaningEventDataListVO(); data.setAddr(r.getSrc_name()); data.setImg(r.getImage_url()); if(data.getImg()!=null){ data.setImg(data.getImg().replace(privateIp,publicIp)); } data.setTitle(r.getEvent_type_name()); data.setCreateDate(r.getCreate_time()); data.setCreateDate(DateUtil.getPlusTime(DateUtil.getISO8601DateByStr(r.getHappen_time()))); // data.setContent(r.get); list.add(data); } } } return list; lastResult.setList(list); return lastResult; } @Override public String getCarmeraPreviemUrl(CarmeraListVO param){ CameraPreviewURLsRequest request = new CameraPreviewURLsRequest(); request.setCameraIndexCode(param.getIndexCode()); BaseResponse<CamerasPreviewURLsResponse> result = HKService.cameraPreviewURLs(request); if(result!=null && StringUtils.equals(result.getCode(),HKConstants.RESPONSE_SUCCEE) && result.getData()!=null){ return result.getData().getUrl(); } return null; } @Override public VisitDataVO visitSecurityData(){ //å¾ è®¿é®ãå·²ç»è®°ãå·²ç¦»å¼ VisitDataVO result = new VisitDataVO(); result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>() .eq(Visits::getIsdeleted,Constants.ZERO) .in(Visits::getStatus,Constants.VisitStatus.pass,Constants.VisitStatus.xfSuccess )));//å¾ è®¿é® result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>() .eq(Visits::getIsdeleted,Constants.ZERO) .in(Visits::getStatus,Constants.VisitStatus.signout,Constants.VisitStatus.signin )));//å·²ç»è®° result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>() .eq(Visits::getIsdeleted,Constants.ZERO) .in(Visits::getStatus,Constants.VisitStatus.signout )));//å·²ç¾ç¦» PageWrap<Visits> pageWrap = new PageWrap<>(); pageWrap.setCapacity(10); pageWrap.setPage(1); pageWrap.setModel(new Visits()); pageWrap.getModel().setLevelStatus(Constants.ZERO); pageWrap.getModel().setStatus(Constants.TWO); PageData<Visits> visitsPageData = VisitsServiceImpl.retentionPageBiz(pageWrap,visitsJoinMapper,systemDictDataBiz); List<VisitRetentionDataVO> list = new ArrayList<>(); if(visitsPageData !=null && visitsPageData.getRecords() !=null && visitsPageData.getRecords().size()>0){ for (Visits model : visitsPageData.getRecords()) { VisitRetentionDataVO data = new VisitRetentionDataVO(); data.setName(model.getName()); data.setCompanyName(model.getCompanyName()); data.setTimeOutMinute(Constants.formatIntegerNum(model.getTimeOut())); list.add(data); } result.setRetentionNum(visitsPageData.getTotal()); } result.setVisitRetentionDataList(list);//访客æ»çæ°æ®éå return result; } @Override public SecurityBoardVO centerSecurityData(){ SecurityBoardVO data = new SecurityBoardVO(); getParkingCarsNum(data);//è·åè½¦ä½æ°æ® Random random = new Random(); List<Retention> retentionList = retentionMapper.selectJoinList(Retention.class, new MPJLambdaWrapper<Retention>() .selectAll(Retention.class) .selectAs(Company::getType,Retention::getCompanyType) .leftJoin(Company.class,Company::getId,Retention::getCompanyId) ); //仿¥å¨åäººæ° data.setInParkTotal( (int) retentionList.stream().filter(i->!Constants.equalsInteger(i.getType(),Constants.THREE)).count() ); //å¨åé¿æç¸å ³æ¹äººæ° data.setInternalTotal( (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO) && Constants.equalsInteger(i.getCompanyType(),Constants.ZERO)).count() ); //å¨å访客æ°é data.setVisitTotal( (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ONE)&&Objects.isNull(i.getCompanyType())).count() ); //å¨åè½¦è¾ data.setInternalCarTotal( (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)).count() ); //å¨åç¸å ³æ¹è½¦è¾ data.setRelatedCarTotal( (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE) &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.relation)).count() ); //å é¨è½¦è¾ data.setInternalCarTotal( (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE) &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.internal)).count() ); //æ¥è®¿è½¦è¾ data.setVisitCarTotal( (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE) &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.visitor)).count() ); //èªç±ç©æµè½¦æ°é data.setVisitCarTotal( (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE) &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.selfTruck)).count() ); //å¸å ¬å¸å¸è´§è½¦æ°é data.setInternalJobCarTotal( (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE) &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.cityComTruck)).count() ); //å¤å车æ°é data.setRelatedJobCarTotal( (int) retentionList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE) &&Constants.equalsInteger(i.getCarType(),Constants.RetentionCarType.outTruck)).count() ); return data; } private void getParkingCarsNum(SecurityBoardVO data) { try { BaseResponse<ParkingStatisticResponse> response = HKService.getParkingStatistics(); if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) || response.getData()==null ||response.getData().getTodayParkingDataDto() == null){ return; } data.setParkingLotTotal(Constants.formatIntegerNum(response.getData().getTodayParkingDataDto().getTotalPlace()));//æ»è½¦ä½ data.setFreeParkingLot(Constants.formatIntegerNum(response.getData().getTodayParkingDataDto().getLeftPlace()));//å©ä½è½¦ä½ data.setParkingUseRate(Constants.formatBigdecimal(response.getData().getTodayParkingDataDto().getUseRate()));//车ä½ä½¿ç¨ç }catch (Exception e){ } } @Override @@ -361,22 +518,6 @@ .eq(Platform::getIsdeleted, Constants.ZERO) .orderByAsc(Platform::getSortnum) ); /** * WAIT_CONFIRM(0, "å¾ ç¡®è®¤","å¾ ç¡®è®¤" ), * WART_SIGN_IN(1, "å¾ ç¾å°","å¾ ç¾å°" ), * WAIT_CALL(2, "å·²ç¾å°","å·²ç¾å°"), * IN_WAIT(3, "å ¥åçå¾ ","å ¥åçå¾ " ), * CALLED(4, "å·²å«å·","å·²å«å·" ), * WORKING(5, "ä½ä¸ä¸","ä½ä¸ä¸" ), * DONE(6, "ä½ä¸å®æ ","ä½ä¸å®æ" ), * TRANSFERING(7, "转移ä¸","转移ä¸" ), * EXCEPTION(8, "å¼å¸¸æèµ·","å¼å¸¸æèµ·" ), * AUTHED_LEAVE(9, "å·²ææç¦»å","å·²ææç¦»å" ), * LEAVED(10, "已离å ","已离å " ), * OVER_NUMBER(11, "å·²è¿å·","å·²è¿å·" ), * CANCEL(12, "已忶","已忶" ), */ if(platformList!=null && platformList.size()>0){ List<PlatformJob> jobList = platformJobMapper.selectJoinList(PlatformJob.class, new MPJLambdaWrapper<PlatformJob>() .selectAll( PlatformJob.class) server/visits/dmvisit_service/src/main/java/com/doumee/service/business/third/BoardService.java
@@ -51,5 +51,11 @@ List<SecurityDeviceDataVO> securityDeviceData(); List<WaningEventDataVO> warningEventData(Integer type); WaningEventDataVO warningEventData(Integer type); String getCarmeraPreviemUrl(CarmeraListVO param); SecurityBoardVO centerSecurityData(); VisitDataVO visitSecurityData(); }