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/EnergyController.java
@@ -2,12 +2,15 @@ import com.doumee.api.BaseController; import com.doumee.config.annotation.LoginNoRequired; import com.doumee.core.haikang.model.param.respose.RegionEnergyListResponse; import com.doumee.core.model.ApiResponse; import com.doumee.core.utils.Constants; import com.doumee.dao.web.response.platformReport.*; import com.doumee.service.business.third.BoardService; import io.swagger.annotations.*; 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; @@ -30,36 +33,16 @@ @Slf4j @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/board/api/energy") public class EnergyController extends BaseController { @Autowired private BoardService boardService; @LoginNoRequired @ApiOperation("ä¸å¿æ°æ®") @GetMapping("/centerData") public ApiResponse<EnergyBoardVO> centerData() { EnergyBoardVO data = new EnergyBoardVO(); Random random = new Random(); data.setSmokeBoxTotal(random.nextInt(20000)); data.setCarbon(new BigDecimal(random.nextInt(1000))); data.setElectricityQuantity(random.nextInt(1000)); data.setElectricityYear(new BigDecimal(random.nextInt(10))); data.setElectricityMonth(new BigDecimal(random.nextInt(10))); data.setWaterQuantity(new BigDecimal(random.nextInt(1000))); data.setWaterYear(new BigDecimal(random.nextInt(10))); data.setWaterMonth(new BigDecimal(random.nextInt(10))); EnergyBoardVO data =boardService.centerEnergyData(); data.setGasQuantity(new BigDecimal(random.nextInt(1000))); data.setGasYear(new BigDecimal(random.nextInt(10))); data.setGasMonth(new BigDecimal(random.nextInt(10))); data.setOfficeQuantity(random.nextInt(20)); data.setPowerQuantity(random.nextInt(20)); data.setWorkHouseQuantity(random.nextInt(20)); data.setParkQuantity(random.nextInt(20)); data.setTodayElectricity(random.nextInt(20)); data.setMonthElectricity(random.nextInt(20)); data.setYesterdayElectricity(random.nextInt(20)); return ApiResponse.success(data); } @@ -68,17 +51,18 @@ @LoginNoRequired @ApiOperation("ç¨çµæ»è½è忝ãç¯æ¯ååºåç¨çµééå") @GetMapping("/energyRegionData") public ApiResponse< RegionEnergyListResponse> energyRegionData() { RegionEnergyListResponse data=boardService.energyRegionData(); return ApiResponse.success(data); } @LoginNoRequired @ApiOperation("宿¶è´è·æ²çº¿") @GetMapping("/loadCurve") public ApiResponse<List<EnergyDataVO>> loadCurve() { List<EnergyDataVO> loadCurveList = new ArrayList<>(); Random random = new Random(); for (int i = 1; i <= 23; i++) { EnergyDataVO data = new EnergyDataVO(); data.setTimeData(StringUtils.leftPad(i+"",2,"0") +":00"); data.setEnergy(new BigDecimal(random.nextInt(200))); loadCurveList.add(data); } List<EnergyDataVO> loadCurveList =boardService.loadEnergyCurve(); return ApiResponse.success(loadCurveList); } @@ -88,17 +72,10 @@ @ApiOperation("æè½èãæ²¹èåæ") @GetMapping("/energyDataList") @ApiImplicitParams({ @ApiImplicitParam(paramType = "query", dataType = "Integer", name = "type", value = "æ¥è¯¢ç±»åï¼0=æ°´ï¼1=æ°ï¼2=çµï¼3=æ²¹è", required = true), @ApiImplicitParam(paramType = "query", dataType = "Integer", name = "type", value = "æ¥è¯¢ç±»åï¼0=æ°´ï¼1=æ°ï¼2=æ²¹èï¼3=ç¨çµ", required = true), }) public ApiResponse<List<EnergyDataVO>> energyDataList(@RequestParam Integer type) { List<EnergyDataVO> energyDataVOList = new ArrayList<>(); Random random = new Random(); for (int i = 1; i <= 12; i++) { EnergyDataVO data = new EnergyDataVO(); data.setTimeData(i +"æ"); data.setEnergy(new BigDecimal(random.nextInt(200))); energyDataVOList.add(data); } List<EnergyDataVO> energyDataVOList = boardService.energyDataList(type); return ApiResponse.success(energyDataVOList); } @@ -107,23 +84,7 @@ @ApiOperation("ä¸ææ²¹èæè¡") @GetMapping("/lastMonthOil") public ApiResponse<List<OilDataVO>> lastMonthOil() { List<OilDataVO> oilDataVOList = new ArrayList<>(); Random random = new Random(); BigDecimal maxOil = BigDecimal.ZERO; BigDecimal lastOil = BigDecimal.ZERO; for (int i = 1; i <= 7; i++) { OilDataVO oilDataVO = new OilDataVO(); oilDataVO.setCarNo("çA8" + random.nextInt(9) + random.nextInt(9) + random.nextInt(9) + random.nextInt(9)); if(i==1){ oilDataVO.setQuantity(new BigDecimal(random.nextInt(100))); maxOil = oilDataVO.getQuantity(); }else{ oilDataVO.setQuantity(new BigDecimal(random.nextInt(lastOil.intValue()))); } lastOil = oilDataVO.getQuantity(); oilDataVO.setMaxOil(maxOil); oilDataVOList.add(oilDataVO); } List<OilDataVO> oilDataVOList = boardService.energyLastMonthOilSort(); return ApiResponse.success(oilDataVOList); } } 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,13 @@ 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 String[] getCurrentMonthDataByMeterType= new String[]{"/api/board/v1/getCurrentMonthDataByMeterType","è½èçæ¿-1.è·åæ¬æç¨è½æ»é-èªç¶æ"};//è½èçæ¿-1.è·åæ¬æç¨è½æ»é-èªç¶æ String[] regionTopPower= new String[]{"/api/board/v1/region/topPower","è½èçæ¿-2.è·ååºåç¨è½åNä½"};//è½èçæ¿-2.è·ååºåç¨è½åNä½ String[] regionEnergyList= new String[]{"/api/board/v1/getRegionEnergyList","è½èçæ¿-3.è·åååºåç¨è½åæ»è½è"};//è½èçæ¿-3.è·åååºåç¨è½åæ»è½è String[] lastMonthFeeByMeterType= new String[]{"/api/board/v1/getLastMonthFeeByMeterType","è½èçæ¿-4.è·å䏿ç¨è½è´¹ç¨ï¼ä¸å¤©å·æ°ï¼åæ¨æä¸ªç¹å·"};//è½èçæ¿-4.è·å䏿ç¨è½è´¹ç¨ï¼ä¸å¤©å·æ°ï¼åæ¨æä¸ªç¹å· String[] energyTodayLoadData= new String[]{"/api/v1/exhibition/energy/getTodayLoadData","è½èçæ¿-5.ååºå®æ¶è´è·æ²çº¿"};//è½èçæ¿-5.ååºå®æ¶è´è·æ²çº¿ String[] energyTrend= new String[]{"/api/v1/report/energyTrend","è½èçæ¿-6æææ¥è¯¢è¿12个æçç¨çµæ»éæ°æ®"};//è½èçæ¿-6æææ¥è¯¢è¿12个æçç¨çµæ»éæ°æ® } /** * éå½A.55æ¶é²è®¾å¤ç±»å server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java
@@ -775,6 +775,14 @@ return startDoPostStringArtemis(HKConstants.InterfacePath.getSecureDevStatusList,body); } /** * è½èçæ¿-6æææ¥è¯¢è¿12个æçç¨çµæ»éæ°æ® * @param body * @return */ public static String energyTrend(String body) { return startDoPostStringArtemis(HKConstants.InterfacePath.energyTrend,body); } /** * ç»è®¡ååºæ»ä½çå®é²è®¾å¤æ°éï¼å¨çº¿æ°ãå¨çº¿çã离线æ°ã离线ç * @param body * @return @@ -783,6 +791,48 @@ return startDoPostStringArtemis(HKConstants.InterfacePath.getSecureDevStatusTotal,body); } /** * ç»å®é²çæ¿--ååºå®æ¶è½¦æ°é4 * @return */ public static String getParkingStatistics() { return startDoGetStringArtemis(HKConstants.InterfacePath.getParkingStatistics,null); } /** * è½èçæ¿-1.è·åæ¬æç¨è½æ»é-èªç¶æ * @return */ public static String getCurrentMonthDataByMeterType(Map<String,String> powerType) { return startDoGetStringArtemis(HKConstants.InterfacePath.getCurrentMonthDataByMeterType,powerType); } /** * è½èçæ¿-2.è·ååºåç¨è½åNä½ * @return */ public static String regionTopPower(Map<String,String> params) { return startDoGetStringArtemis(HKConstants.InterfacePath.regionTopPower,params); } /** * è½èçæ¿-3.è·åååºåç¨è½åæ»è½è * @return */ public static String regionEnergyList(Map<String,String> params) { return startDoGetStringArtemis(HKConstants.InterfacePath.regionEnergyList,params); } /** * è½èçæ¿-4.è·å䏿ç¨è½è´¹ç¨ï¼ä¸å¤©å·æ°ï¼åæ¨æä¸ªç¹å· * @return */ public static String lastMonthFeeByMeterType(Map<String,String> params) { return startDoGetStringArtemis(HKConstants.InterfacePath.lastMonthFeeByMeterType,params); } /** * è½èçæ¿-5.ååºå®æ¶è´è·æ²çº¿ * @return */ public static String energyTodayLoadData( ) { return startDoGetStringArtemis(HKConstants.InterfacePath.energyTodayLoadData,null); } /** * è·åæå°ç¶æ * @return */ server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/EnergyTrendRequest.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,13 @@ package com.doumee.core.haikang.model.param.request; import lombok.Data; @Data public class EnergyTrendRequest { private String date;// String true æ¥æ private int meterType;// Number true 仪表类å(1:çµè¡¨;2:水表;3:æ°è¡¨;4:ç表) private String nodeId ;//String true çéèç¹id private int nodeType ;//Number true çéèç¹ç±»åï¼1é¨é¨/2åºå private String periodType;// String true ç»è®¡ç»´åº¦day/quarter/month/year/custom private String showType;// String true å±ç¤ºç»´åº¦:1è¿6个æ/2è¿4个å£åº¦/3è¿3å¹´--------4:æ¥æç±»å } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/RegionTopPowerRequest.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,14 @@ 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 RegionTopPowerRequest { private int powerType ;//Query Number true è½æºç±»å çµ-1 æ°´-2 æ°-3 ç-4 private String timeType;// Query String true month,è¡¨ç¤ºæ¬æ private int top;// Query Number true åå 个åºåæ° } 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/EnergyTodayLoadDataResponse.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,10 @@ package com.doumee.core.haikang.model.param.respose; import lombok.Data; @Data public class EnergyTodayLoadDataResponse { private String extra ;// String false è¾ å©åæ®µï¼ å端ä¸ç¨ private String name ;// String false æ¨ªåæ ï¼æé¥¼ç¶å¾çå ç´ å¼ï¼ private String value;// String false çºµåæ ï¼æé¥¼ç¶å¾çå ç´ åç§°ï¼ } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/respose/EnergyTrendResponse.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,16 @@ package com.doumee.core.haikang.model.param.respose; import lombok.Data; import java.util.List; @Data public class EnergyTrendResponse { private String names;// String false names private String pwValues ;//String false pwValues private String avgValues;// String false å¹³å弿°æ® private String timeNameList ;//String false timeNameList private String[] xvalues;// Array false xè½´æä»½ private List<EnergyTrendYvalueResponse> yvalues;// Array false yè½´ } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/respose/EnergyTrendYvalueResponse.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,10 @@ package com.doumee.core.haikang.model.param.respose; import lombok.Data; @Data public class EnergyTrendYvalueResponse { private String name;// String false yè½´åç§° private String[] value ;// Array false yè½´å¼ } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/respose/LastMonthFeeByMeterTypeResponse.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,19 @@ package com.doumee.core.haikang.model.param.respose; import lombok.Data; import java.util.List; @Data public class LastMonthFeeByMeterTypeResponse { private String value;// String false æ°å¼ private String quota;// String false é¢å®é private String samePercent;// String false 忝 private Boolean samePercentAbnorml;// Boolean false 忝æ¯å¦å¼å¸¸ï¼è¶ è¿éå¼ï¼ private String ringPercent ;//String false ç¯æ¯ private Boolean ringPercentAbnorml ;//Boolean false ç¯æ¯æ¯å¦å¼å¸¸ï¼è¶ è¿éå¼ï¼ private Boolean privateOpen ;//Boolean false éç§å¼å¯ private String innerFeeValue ;//String false è´¹ç¨ private String feeSamePercent ;//String false è´¹ç¨åæ¯ private String feeRingPercent ;//String false è´¹ç¨ç¯æ¯ } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/respose/MonthDataByMeterTypeResponse.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,17 @@ package com.doumee.core.haikang.model.param.respose; import lombok.Data; @Data public class MonthDataByMeterTypeResponse { private String value ;//String false æ°å¼ private String quota;// String false é¢å®é private String samePercent;// String false 忝 private Boolean samePercentAbnorml;// Boolean false 忝æ¯å¦å¼å¸¸ï¼è¶ è¿éå¼ï¼ private String ringPercent;// String false ç¯æ¯ private Boolean ringPercentAbnorml ;//Boolean false ç¯æ¯æ¯å¦å¼å¸¸ï¼è¶ è¿éå¼ï¼ private Boolean privateOpen ;//Boolean false éç§å¼å¯ private String innerFeeValue ;//String false è´¹ç¨ private String feeSamePercent ;//String false è´¹ç¨åæ¯ private String feeRingPercent ;//String false è´¹ç¨ç¯æ¯ } 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/RegionEnergyListResponse.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,19 @@ package com.doumee.core.haikang.model.param.respose; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import java.math.BigDecimal; import java.util.List; @Data public class RegionEnergyListResponse { @ApiModelProperty(value = "æ ¹èç¹æ»è½è") private String rootValue ;// String false @ApiModelProperty(value = "忝") private String samePercent;// String false 忝 @ApiModelProperty(value = "ç¯æ¯") private String ringPercent;// String false ç¯æ¯ @ApiModelProperty(value = "äºçº§åºåè½èæ°æ®") private List<RegionTopPowerResponse> secondRegionDataList ;//Array false äºçº§åºåè½èæ°æ® } server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/respose/RegionTopPowerResponse.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,16 @@ package com.doumee.core.haikang.model.param.respose; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import java.math.BigDecimal; @Data public class RegionTopPowerResponse { @ApiModelProperty(value = "åºååç§°") private String name;// String false åºååç§° @ApiModelProperty(value = "å¼") private BigDecimal value ;//Number false å¼ @ApiModelProperty(value = "å æ¯") private BigDecimal percent ;//Number 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,17 +1527,134 @@ *å®é²çæ¿-仿¥åè¦äºä»¶-æ ¹æ®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){ log.error("ãæµ·åº·å®é²çæ¿-仿¥åè¦äºä»¶-æ ¹æ®eventTypeåæ®µ3ã================失败====ï¼\n"+ e.getMessage()); } 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; } /** * è½èçæ¿-3.è·åååºåç¨è½åæ»è½è * @param powerType è½æºç±»å çµ-1 æ°´-2 æ°-3 ç-4 * @return */ public static BaseResponse<RegionEnergyListResponse> regionEnergyList(String powerType){ log.info("ãæµ·åº·è½èçæ¿-3.è·åååºåç¨è½åæ»è½èã================å¼å§===="); try { Map<String,String> map = new HashMap<>(); map.put("powerType",powerType); String res = HKTools.regionEnergyList(map); TypeReference typeReference = new TypeReference< BaseResponse<RegionEnergyListResponse>>(){}; BaseResponse<RegionEnergyListResponse> result = JSONObject.parseObject(res, typeReference.getType()); logResult(result,"ãæµ·åº·è½èçæ¿-3.è·åååºåç¨è½åæ»è½èã"); return result; }catch (Exception e){ log.error("ãæµ·åº·è½èçæ¿-3.è·åååºåç¨è½åæ»è½èã================失败====ï¼\n"+ e.getMessage()); } return null; } /** * è½èçæ¿-4.è·å䏿ç¨è½è´¹ç¨ï¼ä¸å¤©å·æ°ï¼åæ¨æä¸ªç¹å· * @param powerType è½æºç±»å çµ-1 æ°´-2 æ°-3 ç-4 * @return */ public static BaseResponse<LastMonthFeeByMeterTypeResponse> lastMonthFeeByMeterType(String powerType){ log.info("ãæµ·åº·è½èçæ¿-4.è·å䏿ç¨è½è´¹ç¨ï¼ä¸å¤©å·æ°ï¼åæ¨æä¸ªç¹å·ã================å¼å§===="); try { Map<String,String> map = new HashMap<>(); map.put("powerType",powerType); String res = HKTools.lastMonthFeeByMeterType(map); TypeReference typeReference = new TypeReference< BaseResponse<LastMonthFeeByMeterTypeResponse>>(){}; BaseResponse<LastMonthFeeByMeterTypeResponse> result = JSONObject.parseObject(res, typeReference.getType()); logResult(result,"ãæµ·åº·è½èçæ¿-4.è·å䏿ç¨è½è´¹ç¨ï¼ä¸å¤©å·æ°ï¼åæ¨æä¸ªç¹å·ã"); return result; }catch (Exception e){ log.error("ãæµ·åº·è½èçæ¿-4.è·å䏿ç¨è½è´¹ç¨ï¼ä¸å¤©å·æ°ï¼åæ¨æä¸ªç¹å·ã================失败====ï¼\n"+ e.getMessage()); } return null; } /** * 海康è½èçæ¿-5.ååºå®æ¶è´è·æ²çº¿ * @return */ public static BaseResponse<List<EnergyTodayLoadDataResponse>> energyTodayLoadData(){ log.info("ãæµ·åº·è½èçæ¿-5.ååºå®æ¶è´è·æ²çº¿ã================å¼å§===="); try { String res = HKTools.energyTodayLoadData(); TypeReference typeReference = new TypeReference< BaseResponse<List<EnergyTodayLoadDataResponse>>>(){}; BaseResponse<List<EnergyTodayLoadDataResponse>> result = JSONObject.parseObject(res, typeReference.getType()); logResult(result,"ãæµ·åº·è½èçæ¿-5.ååºå®æ¶è´è·æ²çº¿ã"); return result; }catch (Exception e){ log.error("ãæµ·åº·è½èçæ¿-5.ååºå®æ¶è´è·æ²çº¿ã================失败====ï¼\n"+ e.getMessage()); } return null; } /** * è½èçæ¿-2.è·ååºåç¨è½åNä½ * @param param * @return */ public static BaseResponse<List<RegionTopPowerResponse>> regionTopPower(RegionTopPowerRequest param){ log.info("ãæµ·åº·è½èçæ¿-2.è·ååºåç¨è½åNä½ã================å¼å§===="); try { String res = HKTools.regionTopPower(toMap(param)); TypeReference typeReference = new TypeReference< BaseResponse<List<RegionTopPowerResponse>>>(){}; BaseResponse<List<RegionTopPowerResponse>> result = JSONObject.parseObject(res, typeReference.getType()); logResult(result,"海康è½èçæ¿-2.è·ååºåç¨è½åNä½"); return result; }catch (Exception e){ log.error("ãæµ·åº·è½èçæ¿-2.è·ååºåç¨è½åNä½ã================失败====ï¼\n"+ e.getMessage()); } return null; } /** * è½èçæ¿-1.è·åæ¬æç¨è½æ»é-èªç¶æ * @param powerType è½æºç±»å çµ-1 æ°´-2 æ°-3 ç-4 * @return */ public static BaseResponse<MonthDataByMeterTypeResponse> getCurrentMonthDataByMeterType(String powerType){ log.info("ãè½èçæ¿-1.è·åæ¬æç¨è½æ»é-èªç¶æã================å¼å§===="); try { Map<String,String> map = new HashMap<>(); map.put("powerType",powerType); String res = HKTools.getCurrentMonthDataByMeterType(map); TypeReference typeReference = new TypeReference< BaseResponse<MonthDataByMeterTypeResponse>>(){}; BaseResponse<MonthDataByMeterTypeResponse> result = JSONObject.parseObject(res, typeReference.getType()); logResult(result,"è½èçæ¿-1.è·åæ¬æç¨è½æ»é-èªç¶æ"); return result; }catch (Exception e){ log.error("ãè½èçæ¿-1.è·åæ¬æç¨è½æ»é-èªç¶æã================失败====ï¼\n"+ e.getMessage()); } return null; } @@ -1578,6 +1695,24 @@ return null; } /** *è½èçæ¿-6æææ¥è¯¢è¿12个æçç¨çµæ»éæ°æ® * @return */ public static BaseResponse<EnergyTrendResponse> energyTrend(EnergyTrendRequest param){ log.info("ãæµ·åº·è½èçæ¿-6æææ¥è¯¢è¿12个æçç¨çµæ»éæ°æ®ã================å¼å§===="+JSONObject.toJSONString(param)); try { String res = HKTools.energyTrend(JSONObject.toJSONString(param)); TypeReference typeReference = new TypeReference< BaseResponse<EnergyTrendResponse>>(){}; BaseResponse<EnergyTrendResponse> result = JSONObject.parseObject(res, typeReference.getType()); logResult(result,"海康è½èçæ¿-6æææ¥è¯¢è¿12个æçç¨çµæ»éæ°æ®"); return result; }catch (Exception e){ log.error("ãæµ·åº·è½èçæ¿-6æææ¥è¯¢è¿12个æçç¨çµæ»éæ°æ®ã================失败====ï¼\n"+ e.getMessage()); } return null; } /** *æ ¹æ®ç¨æ·æ è¯è·å客æ·ç«¯TGCæ¥å£ * @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/PlatformWaterGas.java
@@ -53,8 +53,8 @@ @ApiModelProperty(value = "æåºç ", example = "1") private Integer sortnum; @ApiModelProperty(value = "ç±»å 0ç¨æ°´ 1ç¨æ° 2ç¨æ²¹", example = "1") @ExcelColumn(name="ç±»å",valueMapping = "0=ç¨æ°´;1=ç¨æ°;2=ç¨æ²¹;",index = 0) @ApiModelProperty(value = "ç±»å 0ç¨æ°´ 1ç¨æ° 2ç¨æ²¹ 3", example = "1") @ExcelColumn(name="ç±»å",valueMapping = "0=ç¨æ°´;1=ç¨æ°;2=ç¨æ²¹;3=çç®±;",index = 0) private Integer type; @ApiModelProperty(value = "æ°é (ç¨çµé¡¿ï¼ç¨çµåº¦ï¼ æ²¹èLï¼", example = "1") @@ -72,6 +72,9 @@ @ApiModelProperty(value = "å¼å§æ¶é´") @TableField(exist = false) private Date startTime; @ApiModelProperty(value = "å¹´ææ¶é´") @TableField(exist = false) private String timeInfoStr; @ApiModelProperty(value = "å¼å§æ¶é´") @TableField(exist = false) private Date endTime; 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/EnergyBoardVO.java
@@ -22,76 +22,24 @@ @ApiModelProperty(value = "ç¢³ææ¾ åä½ å¨") private BigDecimal carbon; @ApiModelProperty(value = "䏿ç¨çµ åä½ kw·h") private Integer electricityQuantity; @ApiModelProperty(value = "ç¨çµç¯æ¯") private BigDecimal electricityYear; @ApiModelProperty(value = "ç¨çµåæ¯") private BigDecimal electricityMonth; @ApiModelProperty(value = "䏿ç¨çµ åä½ kw·h æ»éã忝ãç¯æ¯") private EnergyModelDataVO electricityQuantity; @ApiModelProperty(value = "ä¸æç¨æ°´ åä½ t") private BigDecimal waterQuantity; @ApiModelProperty(value = "ç¨æ°´ç¯æ¯") private BigDecimal waterYear; @ApiModelProperty(value = "ç¨æ°´åæ¯") private BigDecimal waterMonth; @ApiModelProperty(value = "ä¸æç¨æ°´ åä½ t æ»éã忝ãç¯æ¯ ") private EnergyModelDataVO waterQuantity; @ApiModelProperty(value = "ä¸æç¨æ° åä½ æ»éã忝ãç¯æ¯ ") private EnergyModelDataVO gasQuantity; @ApiModelProperty(value = "ä¸æç¨æ° åä½ ") private BigDecimal gasQuantity; @ApiModelProperty(value = "仿¥ç¨çµ åä½ kw·hï¼æ»éã忝ãç¯æ¯") private EnergyModelDataVO todayElectricity; @ApiModelProperty(value = "ç¨æ°ç¯æ¯") private BigDecimal gasYear; @ApiModelProperty(value = "æ¬æç¨çµ åä½ kw·h æ»éã忝ãç¯æ¯") private EnergyModelDataVO monthElectricity; @ApiModelProperty(value = "ç¨æ°åæ¯") private BigDecimal gasMonth; @ApiModelProperty(value = "æ¨æ¥ç¨çµ åä½ kw·h æ»éã忝ãç¯æ¯") private EnergyModelDataVO yesterdayElectricity; @ApiModelProperty(value = "åå ¬æ¥¼ç¨çµ åä½ kw·h") private Integer officeQuantity; @ApiModelProperty(value = "æååºç¨çµ åä½ kw·h") private Integer productHouseQuantity; @ApiModelProperty(value = "èåå·¥æ¿ç¨çµ åä½ kw·h") private Integer workHouseQuantity; @ApiModelProperty(value = "ç©æµååºç¨çµ åä½ kw·h") private Integer parkQuantity; @ApiModelProperty(value = "å¨åç«æ¿ç¨çµ åä½ kw·h") private Integer powerQuantity; @ApiModelProperty(value = "仿¥ç¨çµ åä½ kw·h") private Integer todayElectricity; @ApiModelProperty(value = "æ¬æç¨çµ åä½ kw·h") private Integer monthElectricity; @ApiModelProperty(value = "æ¨æ¥ç¨çµ åä½ kw·h") private Integer yesterdayElectricity; @ApiModelProperty(value = "宿¶è´è·æ²çº¿",hidden = true) private List<EnergyDataVO> loadCurveList; @ApiModelProperty(value = "æè½èåæ - æ°´",hidden = true) private List<EnergyDataVO> energyDataWaterList; @ApiModelProperty(value = "æè½èåæ - æ°",hidden = true) private List<EnergyDataVO> energyDataGasList; @ApiModelProperty(value = "æè½èåæ - çµ",hidden = true) private List<EnergyDataVO> energyDataElectricityList; @ApiModelProperty(value = "ææ²¹èåæ",hidden = true) private List<EnergyDataVO> oilList; @ApiModelProperty(value = "ä¸ææ²¹èæè¡",hidden = true) private List<OilDataVO> lastMonthOilList; } server/visits/dmvisit_service/src/main/java/com/doumee/dao/web/response/platformReport/EnergyModelDataVO.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,31 @@ package com.doumee.dao.web.response.platformReport; import io.swagger.annotations.ApiModelProperty; import lombok.Data; import java.math.BigDecimal; /** * Created by IntelliJ IDEA. * * @Author : Rk * @create 2024/10/25 16:25 */ @Data public class EnergyModelDataVO { @ApiModelProperty(value = "æ»é") private String total; @ApiModelProperty(value = "æ»é",hidden = true) private BigDecimal totalNum; @ApiModelProperty(value = "ç¯æ¯") private String ringRate; @ApiModelProperty(value = "ç¯æ¯å¼",hidden = true) private BigDecimal ringNum; @ApiModelProperty(value = "忝") private String sameRate; @ApiModelProperty(value = "忝å¼" ,hidden = true) private BigDecimal sameNum; } 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,10 @@ @Autowired private PlatformLogMapper platformLogMapper; @Autowired private PlatformWaterGasMapper platformWaterGasMapper; @Autowired private SystemDictDataBiz systemDictDataBiz; @Autowired private PlatformWarnEventMapper platformWarnEventMapper; @Autowired private PlatformJobMapper platformJobMapper; @@ -52,6 +60,10 @@ private PlatformWmsDetailMapper platformWmsDetailMapper; @Autowired private PlatformMapper platformMapper; @Autowired private VisitsJoinMapper visitsJoinMapper; @Autowired private RetentionMapper retentionMapper; @Autowired private PlatformGroupMapper platformGroupMapper; /** @@ -93,7 +105,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 +190,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 +315,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 +343,432 @@ 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 List<EnergyDataVO> loadEnergyCurve(){ List<EnergyDataVO> loadCurveList = new ArrayList<>(); try { BaseResponse<List<EnergyTodayLoadDataResponse>> response = HKService.energyTodayLoadData(); if(response == null || !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) || response.getData()==null ){ for (EnergyTodayLoadDataResponse model :response.getData()) { EnergyDataVO data = new EnergyDataVO(); data.setTimeData(model.getName()); data.setEnergy(new BigDecimal(model.getName())); loadCurveList.add(data); } } }catch (Exception e){ e.printStackTrace(); } return loadCurveList; } @Override public List<OilDataVO> energyLastMonthOilSort(){ List<OilDataVO> oilDataVOList = new ArrayList<>(); //ä¸ææ²¹è List<PlatformWaterGas> list = platformWaterGasMapper.selectList(new QueryWrapper<PlatformWaterGas>().lambda() .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) .eq(PlatformWaterGas::getType,Constants.TWO) .apply("DATE_FORMAT(time_info, '%Y-%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL 1 MONTH), '%Y-%m')") .orderByDesc(PlatformWaterGas::getNum) .last("limit 30" ) ); for (PlatformWaterGas model :list) { OilDataVO oilDataVO = new OilDataVO(); oilDataVO.setCarNo(model.getCarCode()); oilDataVO.setQuantity(model.getNum()); oilDataVOList.add(oilDataVO); } return oilDataVOList; } /** * ç¨çµæ»è½è忝ãç¯æ¯ååºåç¨çµééå * @return */ @Override public EnergyBoardVO centerEnergyData(){ EnergyBoardVO data = new EnergyBoardVO(); Random random = new Random(); PlatformWaterGas smoke= platformWaterGasMapper.selectOne(new QueryWrapper<PlatformWaterGas>() .select("sum(num) as num") .lambda() .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) .eq(PlatformWaterGas::getType,Constants.THREE) .apply("year(time_info) = year(now())") .last("limit 1 " )); data.setSmokeBoxTotal(0); if(smoke!=null){ data.setSmokeBoxTotal(Constants.formatBigdecimal(smoke.getNum()).intValue());//å½å¹´çç®±æ° } BigDecimal carbonGas = new BigDecimal(0);//æ¬æç¨æ° BigDecimal carbonWater = new BigDecimal(0);//æ¬æç¨æ°´ BigDecimal carbonElec = new BigDecimal(0);//ç¨çµ data.setTodayElectricity(getDefaultData());//仿¥ç¨çµ data.setElectricityQuantity(getDefaultData());//䏿ç¨çµ data.setWaterQuantity(getDefaultData());//ä¸æç¨æ°´ data.setGasQuantity(getDefaultData());//ä¸æç¨æ° data.setMonthElectricity(getDefaultData());//æ¬æç¨çµ data.setYesterdayElectricity(getDefaultData());//æ¨æ¥ç¨çµ getMonthElectricityData(data.getMonthElectricity());//éè¿å®é²å¹³è·åæ¬ææ°æ® carbonElec = new BigDecimal(StringUtils.defaultString(data.getMonthElectricity().getTotal(), "0")); getLastMonthElectricityData(data.getElectricityQuantity());//éè¿å®é²å¹³è·åä¸ææ°æ® String firstDate = DateUtil.getFirstDayOfThisMonth() +" 00:00:00"; Date month0 = DateUtil.getDateFromString(firstDate); Date month1 = DateUtil.increaseMonth(month0,-1);//䏿 Date month2 = DateUtil.increaseMonth(month0,-2);//ä¸ä¸æ Date month3 = DateUtil.increaseMonth(month0,-12);//å»å¹´åæ List<PlatformWaterGas> list = platformWaterGasMapper.selectList(new QueryWrapper<PlatformWaterGas>() .lambda() .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) .in(PlatformWaterGas::getType,Constants.ZERO,Constants.ONE) .in(PlatformWaterGas::getTimeInfo,month0,month1,month3,month2) ); if(list!=null){ //ç±»å 0ç¨æ°´ 1ç¨æ° 2ç¨æ²¹ for(PlatformWaterGas model : list){ if(Constants.equalsInteger(model.getType(),Constants.ONE)){ if(model.getTimeInfo().getTime() == month0.getTime()){ carbonGas = Constants.formatBigdecimal(model.getNum()); } if(model.getTimeInfo().getTime() == month1.getTime()){ data.getGasQuantity().setTotalNum(Constants.formatBigdecimal(model.getNum()) ); data.getGasQuantity().setTotal(Constants.formatBigdecimal(model.getNum())+""); } if(model.getTimeInfo().getTime() == month2.getTime()){ data.getGasQuantity().setSameNum(Constants.formatBigdecimal(model.getNum()) ); } if(model.getTimeInfo().getTime() == month3.getTime()){ data.getGasQuantity().setRingNum(Constants.formatBigdecimal(model.getNum()) ); } }else if(Constants.equalsInteger(model.getType(),Constants.ZERO)){ if(model.getTimeInfo().getTime() == month0.getTime()){ carbonWater = Constants.formatBigdecimal(model.getNum()); } if(model.getTimeInfo().getTime() == month1.getTime()){ data.getWaterQuantity().setTotalNum(Constants.formatBigdecimal(model.getNum()) ); data.getWaterQuantity().setTotal(Constants.formatBigdecimal(model.getNum())+""); } if(model.getTimeInfo().getTime() == month2.getTime()){ data.getWaterQuantity().setSameNum(Constants.formatBigdecimal(model.getNum()) ); } if(model.getTimeInfo().getTime() == month3.getTime()){ data.getWaterQuantity().setRingNum(Constants.formatBigdecimal(model.getNum()) ); } } } } if( data.getGasQuantity().getTotalNum().compareTo(new BigDecimal(0)) !=0){ //计ç®ç¨æ°åæ¯ç¯æ¯ data.getGasQuantity().setSameRate(Constants.formatBigdecimal4Float(data.getGasQuantity().getSameNum().divide(data.getGasQuantity().getTotalNum())).doubleValue()*100 +""); data.getGasQuantity().setRingRate(Constants.formatBigdecimal4Float(data.getGasQuantity().getRingNum().divide(data.getGasQuantity().getTotalNum())).doubleValue()*100 +""); } if( data.getWaterQuantity().getTotalNum().compareTo(new BigDecimal(0)) !=0){ // //计ç®ç¨æ°´åæ¯ç¯æ¯ data.getWaterQuantity().setSameRate(Constants.formatBigdecimal4Float(data.getWaterQuantity().getSameNum().divide(data.getWaterQuantity().getTotalNum())).doubleValue()*100 +""); data.getWaterQuantity().setRingRate(Constants.formatBigdecimal4Float(data.getWaterQuantity().getRingNum().divide(data.getWaterQuantity().getTotalNum())).doubleValue()*100 +""); } /*计ç®ç¢³æéï¼ä»¥ä¸ä¸ä¸ªå ç´ ä¹å 1)ç¨çµçäºæ°§åç¢³ææ¾é(kg)=èçµé(kWh)x0.785ï¼ 2) å¤©ç¶æ°äºæ°§åç¢³ææ¾é(kg)=å¤©ç¶æ°ä½¿ç¨é(m3)Ã0.19ï¼ 3) èªæ¥æ°´äºæ°§åç¢³ææ¾é(kg)=èªæ¥æ°´ä½¿ç¨é(m3)Ã0.91ï¼*/ data.setCarbon(Constants.formatBigdecimal2Float((carbonElec.multiply(new BigDecimal(0.785))) .add(carbonGas.multiply(new BigDecimal(0.19))) .add(carbonWater.multiply(new BigDecimal(0.91))))); return data; } /** * éè¿å®é²å¹³è·åæ¬ææ°æ® * @param data */ private void getMonthElectricityData(EnergyModelDataVO data) { BaseResponse<MonthDataByMeterTypeResponse> response = HKService.getCurrentMonthDataByMeterType("1"); if(response != null && !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ){ data.setRingRate(StringUtils.defaultString(response.getData().getRingPercent(),"0")); data.setSameRate(StringUtils.defaultString(response.getData().getSamePercent(),"0")); data.setTotal(StringUtils.defaultString(response.getData().getValue(),"0")); } } /** * éè¿å®é²å¹³è·åä¸ææ°æ® * @param data */ private void getLastMonthElectricityData(EnergyModelDataVO data) { BaseResponse<LastMonthFeeByMeterTypeResponse> response = HKService.lastMonthFeeByMeterType("1"); if(response != null && !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ){ data.setRingRate(StringUtils.defaultString(response.getData().getRingPercent(),"0")); data.setSameRate(StringUtils.defaultString(response.getData().getSamePercent(),"0")); data.setTotal(StringUtils.defaultString(response.getData().getValue(),"0")); } } private EnergyModelDataVO getDefaultData() { EnergyModelDataVO data = new EnergyModelDataVO(); data.setTotal("0"); data.setSameRate("0"); data.setRingRate("0"); data.setTotalNum(new BigDecimal(0)); data.setSameNum(new BigDecimal(0)); data.setRingNum(new BigDecimal(0)); return data; } /** * ç¨çµæ»è½è忝ãç¯æ¯ååºåç¨çµééå * @return */ @Override public RegionEnergyListResponse energyRegionData(){ RegionEnergyListResponse data = null; BaseResponse<RegionEnergyListResponse> response = HKService.regionEnergyList("1"); if(response != null && !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ){ data = response.getData(); } if(data == null){ data = new RegionEnergyListResponse(); data.setSecondRegionDataList(new ArrayList<>()); data.setRootValue("0"); data.setSamePercent("0"); data.setRingPercent("0"); data.setSecondRegionDataList(new ArrayList<>()); } return data; } /** * è¿12ä¸ªæ°´çµæ°æ²¹èæ°æ®ç»è®¡ * @param type * @return */ @Override public List<EnergyDataVO> energyDataList(Integer type){ List<EnergyDataVO> energyDataVOList = new ArrayList<>(); List<OilDataVO> oilDataVOList = new ArrayList<>(); Date lastMonth = DateUtil.increaseMonth(new Date(),-11); if(type >=0 && type <=2){ //ç¨æ°´ç¨çµç¨æ° List<PlatformWaterGas> list = platformWaterGasMapper.selectList(new QueryWrapper<PlatformWaterGas>() .select("DATE_FORMAT(TIME_INFO,'yyyy-MM') as time_info_str,sum(num) as num") .lambda() .eq(PlatformWaterGas::getIsdeleted,Constants.ZERO) .eq(PlatformWaterGas::getType,type) .apply("time_info BETWEEN DATE_SUB(CURDATE(), INTERVAL 12 MONTH) AND CURDATE()")//è¿12个æ .last(" groupby DATE_FORMAT(TIME_INFO,'yyyy-MM')") ); for (int i = 0; i < 12; i++) { Date tempDate = DateUtil.increaseMonth(lastMonth,i); EnergyDataVO data = new EnergyDataVO(); data.setTimeData(DateUtil.getFomartDate(tempDate,"YYYY-MM")); data.setEnergy(new BigDecimal(0)); if(list!=null){ for(PlatformWaterGas m : list){ if(StringUtils.equals(m.getTimeInfoStr(),data.getTimeData())){ data.setEnergy(Constants.formatBigdecimal(m.getNum())); } } } energyDataVOList.add(data); } }else{ for (int i = 0; i < 12; i++) { Date tempDate = DateUtil.increaseMonth(lastMonth,i); EnergyDataVO data = new EnergyDataVO(); data.setTimeData(DateUtil.getFomartDate(tempDate,(i+1)+"æ")); data.setEnergy(new BigDecimal(0)); energyDataVOList.add(data); } //妿æ¯ç¨çµæ°æ® EnergyTrendRequest param = new EnergyTrendRequest(); param.setDate(DateUtil.getFomartDate(new Date(),"yyyy"));//年份 param.setMeterType(1); param.setNodeType(2); param.setNodeId("root000000"); param.setPeriodType("year"); BaseResponse<EnergyTrendResponse> response = HKService.energyTrend(param); if(response != null && !StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null&& response.getData().getYvalues()!=null ){ for (int i = 0; i < 12; i++) { if(response.getData().getYvalues().size()>0 &&response.getData().getYvalues().get(0).getValue().length>i){ //åç¸åºçåæ°å¼ energyDataVOList.get(0).setEnergy(new BigDecimal(response.getData().getYvalues().get(0).getValue()[i])); } } } } return energyDataVOList; } @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);//è·åè½¦ä½æ°æ® 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 +780,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
@@ -3,6 +3,7 @@ import com.doumee.core.haikang.model.param.respose.PageFireChannelInfoResponse; import com.doumee.core.haikang.model.param.respose.PageRegionInfoResponse; import com.doumee.core.haikang.model.param.respose.PageSensorStatusResponse; import com.doumee.core.haikang.model.param.respose.RegionEnergyListResponse; import com.doumee.core.tms.model.request.TmsLockStatusQueryRequest; import com.doumee.core.tms.model.request.TmsOrderInfoRequest; import com.doumee.core.tms.model.request.TmsOrderListRequest; @@ -51,5 +52,21 @@ List<SecurityDeviceDataVO> securityDeviceData(); List<WaningEventDataVO> warningEventData(Integer type); WaningEventDataVO warningEventData(Integer type); String getCarmeraPreviemUrl(CarmeraListVO param); SecurityBoardVO centerSecurityData(); VisitDataVO visitSecurityData(); List<EnergyDataVO> loadEnergyCurve(); List<OilDataVO> energyLastMonthOilSort(); List<EnergyDataVO> energyDataList(Integer type); RegionEnergyListResponse energyRegionData(); EnergyBoardVO centerEnergyData(); }