Merge branch 'master' of http://139.186.142.91:10010/r/productDev/dmvisit
已添加15个文件
已删除1个文件
已修改29个文件
| | |
| | | public static final String WMS_GET_INVENTORYLIST_URL ="WMS_GET_INVENTORYLIST_URL" ; |
| | | public static final String WMS_OUTBOUND_PLATFROM_URL ="WMS_OUTBOUND_PLATFROM_URL" ; |
| | | public static final String TSM_PARAM ="TSM_PARAM" ; |
| | | public static final String TMS_ORDER_LIST_URL ="TMS_ORDER_LIST_URL" ; |
| | | public static final String TMS_ORDER_DETAIL_URL ="TMS_ORDER_DETAIL_URL" ; |
| | | public static final String TMS_LOCK_STATUS_URL ="TMS_LOCK_STATUS_URL" ; |
| | | 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 final String TEMPERATURE_HUMIDITY ="TEMPERATURE_HUMIDITY" ; |
| | | |
| | | public static final String HK_WXTOKEN_CONFIGID ="HK_WXTOKEN_CONFIGID" ; |
| | | public static final String HK_WXTOKEN_TAGID ="HK_WXTOKEN_TAGID" ; |
| | | public static final String WMS_TOTAL_STOCK_NUM ="WMS_TOTAL_STOCK_NUM" ; |
| | | public static final String WX_REDIRECT_URL = "WX_REDIRECT_URL"; |
| | | public static final String HK_CHANGNEI_SCREEN_INDEXCODES = "HK_CHANGNEI_SCREEN_INDEXCODES"; |
| | | public static final String CITY_XH_REASON_ID ="CITY_XH_REASON_ID" ; |
| | | public static final String ATWL_XH_PLATFORM_ID ="ATWL_XH_PLATFORM_ID" ; |
| | | public static boolean DEALING_HK_SYNCPRIVILEGE= false; |
| | | public static boolean DEALING_HK_SYNCDEVICE = false; |
| | | public static boolean DEALING_HK_SYNCPLATFORM = false; |
| | |
| | | */ |
| | | public static String getWxUrl(String code, WxUrlParams paramCode, String ywid) { |
| | | String url = code.replace("${type}",paramCode.type+"").replace("${yw}",paramCode.yw).replace("${ywid}",ywid); |
| | | try { |
| | | url = URLEncoder.encode(code.replace("${type}",paramCode.type+"").replace("${yw}",paramCode.yw).replace("${ywid}",ywid),"UTF-8"); |
| | | }catch (Exception e){ |
| | | |
| | | } |
| | | // try { |
| | | // url = URLEncoder.encode(code,"UTF-8"); |
| | | // }catch (Exception e){ |
| | | // |
| | | // } |
| | | return url; |
| | | } |
| | | |
| | |
| | | WAIT_CALL(2, "å·²ç¾å°","å·²ç¾å°"), |
| | | IN_WAIT(3, "å
¥åçå¾
","å
¥åçå¾
" ), |
| | | CALLED(4, "å·²å«å·","å·²å«å·" ), |
| | | WORKING(5, "ä½ä¸ä¸","ä½ä¸ä¸" ), |
| | | WORKING(5, "ä½ä¸ä¸","ä½ä¸ä¸" ), |
| | | DONE(6, "ä½ä¸å®æ ","ä½ä¸å®æ" ), |
| | | TRANSFERING(7, "转移ä¸","转移ä¸" ), |
| | | EXCEPTION(8, "å¼å¸¸æèµ·","å¼å¸¸æèµ·" ), |
| | |
| | | String visitTimeOutSignOut = "visitTimeOutSignOut"; |
| | | //访客ç³è¯·-æªç¾ç¦»æ°é-éç¥ï¼ç»æå®æ¥æ¶äººï¼ |
| | | String visitTimeOutSignOutNum = "visitTimeOutSignOutNum"; |
| | | //访客ç³è¯·-审æ¹éè¿éç¥ï¼ç»è¢«è®¿é®äººï¼ |
| | | String visitAuditSuccessToVisiter = "visitAuditSuccessToVisiter"; |
| | | |
| | | } |
| | | |
| | |
| | | @ExcelColumn(name="å
³èåæ°1") |
| | | private String param1; |
| | | |
| | | @ApiModelProperty(value = "ç¨äºåå¨ ä¸å¡ç¶æä¿¡æ¯ 0 =å¾
å¤ç;1=å·²åæ/å·²å¤ç;2=å·²æç»/å·²éå;3=已转交;4=å·²æ¤é",notes = "ç¨äºåå¨ ä¸å¡ç¶æä¿¡æ¯ 0 =å¾
å¤ç;1=å·²åæ/å·²å¤ç;2=å·²æç»/å·²éå;3=已转交;4=å·²æ¤é") |
| | | @ApiModelProperty(value = "ç¨äºåå¨ ä¸å¡ç¶æä¿¡æ¯ 0=å¾
å¤ç;1=å·²åæ/å·²å¤ç;2=å·²æç»/å·²éå;3=已转交;4=å·²æ¤é",notes = "ç¨äºåå¨ ä¸å¡ç¶æä¿¡æ¯ 0 =å¾
å¤ç;1=å·²åæ/å·²å¤ç;2=å·²æç»/å·²éå;3=已转交;4=å·²æ¤é") |
| | | @ExcelColumn(name="å
³èåæ°2") |
| | | private String param2; |
| | | |
| | |
| | | return ApiResponse.success( HKService.findDeviceAlarmPage(param)); |
| | | } |
| | | |
| | | @ApiOperation("ãæµ·åº·ã温湿度ç»è®¡") |
| | | @PostMapping("/getTemperatureHumidityDataPage") |
| | | @LoginNoRequired |
| | | public ApiResponse<BaseResponse> getTemperatureHumidityDataPage(@RequestBody TemperatureHumidityDataRequest request, HttpServletResponse response) { |
| | | return ApiResponse.success( HKService.temperatureHumidityDataStatistic(request)); |
| | | } |
| | | |
| | | } |
| | |
| | | RegionEnergyListResponse data=boardService.energyRegionData(); |
| | | return ApiResponse.success(data); |
| | | } |
| | | |
| | | |
| | | @LoginNoRequired |
| | | @ApiOperation("宿¶è´è·æ²çº¿") |
| | | @GetMapping("/loadCurve") |
| | |
| | | } |
| | | |
| | | |
| | | @LoginNoRequired |
| | | @ApiOperation("æ¸©æ¹¿åº¦æ°æ®") |
| | | @GetMapping("/getTemperatureHumidityData") |
| | | public ApiResponse<List<TemperatureHumidityDataVO>> getTemperatureHumidityData() { |
| | | List<TemperatureHumidityDataVO> list = boardService.getTemperatureHumidityData(); |
| | | return ApiResponse.success(list); |
| | | } |
| | | |
| | | |
| | | |
| | | } |
| | |
| | | @Api(tags = "ãçæ¿å¤§å±ãååºç©æµè¿è¡è°åº¦çæ¿çå®") |
| | | @RestController |
| | | @Slf4j |
| | | @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/board/api/platformJobRunAct") |
| | | @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/board/api/platformJobRun") |
| | | public class PlatformJobRunActController extends BaseController { |
| | | |
| | | @Autowired |
| | |
| | | BoardCarsListVO data = boardService.platformJobCarsList(); |
| | | return ApiResponse.success(data); |
| | | } |
| | | |
| | | @LoginNoRequired |
| | | @ApiOperation("æ ¹æ®è½¦çå·æ¥è¯¢ä½ä¸ä¿¡æ¯åååä¿¡æ¯éå") |
| | | @PostMapping("/getCarsJobDetails") |
| | |
| | | @ApiOperation("仿¥å
¥åºéç»è®¡") |
| | | @GetMapping("/totalInList") |
| | | public ApiResponse<List<GeneralVO>> totalInList() { |
| | | List<GeneralVO> list = new ArrayList<>(); |
| | | for (int i = 1; i < 4; i++) { |
| | | Random random = new Random(); |
| | | GeneralVO data = new GeneralVO(); |
| | | data.setName("ååºåç§°_"+i); |
| | | data.setNum(BigDecimal.valueOf(random.nextInt(1000))); |
| | | list.add(data); |
| | | } |
| | | List<GeneralVO> list = boardService.todayTotalInList(); |
| | | return ApiResponse.success(list); |
| | | } |
| | | |
| | |
| | | @Api(tags = "ãçæ¿å¤§å±ãååºç©æµè¿è¡è°åº¦çæ¿") |
| | | @RestController |
| | | @Slf4j |
| | | @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/board/api/platformJobRun") |
| | | @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/board/api/platformJobRunOld") |
| | | public class PlatformJobRunController extends BaseController { |
| | | |
| | | @Autowired |
| | |
| | | @Slf4j |
| | | @RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/board/api/security") |
| | | public class SecurityController extends BaseController { |
| | | |
| | | @Autowired |
| | | private BoardService boardService; |
| | | @Autowired |
| | | private VisitsService visitsService; |
| | | |
| | | @LoginNoRequired |
| | | @ApiOperation("ä¸å¿æ°æ®") |
| | | @GetMapping("/centerData") |
| | |
| | | SecurityBoardVO data = boardService.centerSecurityData(); |
| | | return ApiResponse.success(data); |
| | | } |
| | | |
| | | |
| | | @LoginNoRequired |
| | | @ApiOperation("ååºå®é²è®¾å¤") |
| | |
| | | WaningEventDataVO list = boardService.warningEventData(type); |
| | | return ApiResponse.success(list); |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | @LoginNoRequired |
| | |
| | | package com.doumee.core.haikang.model; |
| | | |
| | | import com.doumee.core.tms.model.TMSContants; |
| | | import com.doumee.core.utils.Constants; |
| | | import javafx.scene.effect.BlendMode; |
| | | import lombok.Data; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | |
| | | @Data |
| | | public class HKConstants { |
| | |
| | | */ |
| | | public static final String ARTEMIS_PATH = "/artemis"; |
| | | |
| | | public static void main(String[] args) { |
| | | String t ="éç¨\t-30\t100\n" + |
| | | " è¶
éæ¥è¦ (设å¤å´æ )\t-30\t8\n" + |
| | | " è¿åºåºå/路线æ¥è¦(设å¤å´æ )\t-30\t2\n" + |
| | | " 人è¸èå¤\t-30\t11\n" + |
| | | " ICå¡èå¤\t-30\t11\n" + |
| | | " äººè¸æ¯å¯¹ç»æ\t-30\t10\n" + |
| | | " ç¹æ®å¼å¸¸æ¥è¦\t-30\t12\n" + |
| | | " ååç¢°ææ¥è¦\t100\t1\n" + |
| | | " 车éå忥è¦\t100\t2\n" + |
| | | " 车è·è¿è¿æ¥è¦\t100\t3\n" + |
| | | " è¡äººç¢°ææ¥è¦\t100\t4\n" + |
| | | " é¢ç¹å鿥è¦\t100\t5\n" + |
| | | " éè·¯æ è¯è¶
鿥è¦\t100\t6\n" + |
| | | " éè·¯æ å¿è¶
鿥è¦\t100\t16\n" + |
| | | " 䏻卿æäºä»¶\t100\t17\n" + |
| | | " 车å¢è¿éè¡äººæ£æµ\t100\t19\n" + |
| | | " 车éå离å³\t100\t20\n" + |
| | | " 车éå离左\t100\t21\n" + |
| | | " è·¯å£æ¥è¦\t100\t30\n" + |
| | | " è¶
鿥è¦\t100\t31\n" + |
| | | " æé©¬çº¿è¶
é\t100\t32\n" + |
| | | " æªç¤¼è®©è¡äºº\t100\t33\n" + |
| | | " è¿è§å éè¡é©¶\t100\t34\n" + |
| | | " é¯çº¢ç¯\t100\t35\n" + |
| | | " ç²å³é©¾é©¶æ¥è¦\t101\t1\n" + |
| | | " æ¥æçµè¯æ¥è¦\t101\t2\n" + |
| | | " æ½çæ¥è¦\t101\t3\n" + |
| | | " åç¥é©¾é©¶æ¥è¦\t101\t4\n" + |
| | | " 驾驶åå¼å¸¸ (å
æ¬é©¾é©¶å离å²)\t101\t5\n" + |
| | | " 鮿¡\t101\t6\n" + |
| | | " 驾驶å人è¸èº«ä»½è¯å«äºä»¶ (驾驶忣æµå¼å¸¸ï¼äººè¸ä¸å¨åºä¸)\t101\t9\n" + |
| | | " æªç³»å®å
¨å¸¦\t101\t17\n" + |
| | | " æªç³»å®å
¨å¸¦æ¥è¦ å·¥ç¨è½¦\t101\t10\n" + |
| | | " 红å¤é»æå¢¨é\t101\t11\n" + |
| | | " åæè±ç¦»æ¹åç\t101\t18\n" + |
| | | " åæè±ç¦»æ¹åç\t101\t13\n" + |
| | | " æªæ´å®å
¨å¸½\t101\t14\n" + |
| | | " èªå¨ææ\t101\t16\n" + |
| | | " éæ³å
³é¨\t101\t29\n" + |
| | | " éæ³å¼é¨\t101\t30\n" + |
| | | " ç©ææº\t101\t31\n" + |
| | | " 饮é
驾驶\t101\t32\n" + |
| | | " éé
驾驶\t101\t33\n" + |
| | | " å¤äººè¸æ¥è¦\t101\t48\n" + |
| | | " éç¼\t101\t34\n" + |
| | | " åAEBæ¥è¦\t101\t101\n" + |
| | | " 䏿´å£ç½©æ¥è¦\t101\t100\n" + |
| | | " è忥è¦\t103\n" + |
| | | " åæ¹æ¥è¿æ¥è¦\t102\t1\n" + |
| | | " 左侧忹æ¥è¿æ¥è¦\t102\t2\n" + |
| | | " å³ä¾§åæ¹æ¥è¿æ¥è¦\t102\t3\n" + |
| | | " ååæ¥è¿æ¥è¦\t102\t4\n" + |
| | | " çä¼¼éæ³æ³¨æ°´æ¥è¦\t102\t5\n" + |
| | | " åè¶
声波æ¥è¦\t102\t238\n" + |
| | | " åè¶
声波æ¥è¦\t102\t239\n" + |
| | | " ç´§æ¥æ¥è¦\t102\t240\n" + |
| | | " æ¥å é\t104\t1\n" + |
| | | " æ¥åé\t104\t2\n" + |
| | | " 碰æ\t104\t3\n" + |
| | | " ä¾§ç¿»\t104\t4\n" + |
| | | " æ¥å·¦è½¬å¼¯\t104\t5\n" + |
| | | " æ¥å³è½¬å¼¯\t104\t6\n" + |
| | | " æ¥è½¬å¼¯(ä¸åºåå·¦åå³)\t104\t7\n" + |
| | | " å§çé¢ ç°¸\t104\t255\n" + |
| | | " æµæ¸©æ¥è¦\t170\n" + |
| | | " 驾驶åè¯ä»¶\t163\t163\n" + |
| | | " å³è½¬å¼¯è¶
é\t238\t1\n" + |
| | | " å³è½¬å¼¯ä¸å车\t238\t2\n" + |
| | | " 举åäºä»¶\t172\t1\n" + |
| | | " å¯éäºä»¶\t172\t2\n" + |
| | | " è½½éäºä»¶\t172\t3\n" + |
| | | " åè§ç²åºå¶å¨\t249 0xF9\t1\n" + |
| | | " åè§ç²åºå¶å¨\t249\t2\n" + |
| | | " åè¶
声波å¶å¨\t249\t3\n" + |
| | | " åè¶
声波å¶å¨\t249\t4\n" + |
| | | " å·¦è§ç²åºå¶å¨\t249\t5\n" + |
| | | " å³è§ç²åºå¶å¨\t249\t6\n" + |
| | | " åAEBå¶å¨\t249\t7\n" + |
| | | " åè§ç²åºé¢è¦\t249\t21\n" + |
| | | " åè§ç²åºé¢è¦\t249\t22\n" + |
| | | " åè¶
声波é¢è¦\t249\t23\n" + |
| | | " åè¶
声波é¢è¦\t249\t24\n" + |
| | | " å·¦è§ç²åºé¢è¦\t249\t25\n" + |
| | | " å³è§ç²åºé¢è¦\t249\t26\n" + |
| | | " åAEBé¢è¦\t249\t27\n" + |
| | | " 主å¨ä¸æ¥æ¥è¦äºä»¶\t160\t0\n" + |
| | | " å·¡æ£ä¸æ¥äºä»¶\t160\t1\n" + |
| | | " ç´§æ¥æ¥è¦\t25\t1\n" + |
| | | " ç´§æ¥æ¥è¦\t-32\t0\n" + |
| | | " è¶
鿥è¦\t-32\t16\n" + |
| | | " ç²å³é©¾é©¶\t-32\t32\n" + |
| | | " å±é©é¢è¦\t-32\t33\n" + |
| | | " GNSS模åæ
é\t-32\t2\n" + |
| | | " GNSSå¤©çº¿æªæ¥å
¥\t-32\t3\n" + |
| | | " GNSS天线çè·¯\t-32\t4\n" + |
| | | " ç»ç«¯ä¸»çµæºæ¬ å\t-32\t5\n" + |
| | | " ç»ç«¯ä¸»çµæºæçµ\t-32\t6\n" + |
| | | " LCDæè
æ¾ç¤ºå±æ
é\t-32\t7\n" + |
| | | " TTS模åæ
é\t-32\t46\n" + |
| | | " æå头æ
é\t-32\t9\n" + |
| | | " éè·¯è¿è¾è¯IC塿¨¡åæ
é\t-32\t34\n" + |
| | | " è¶
éé¢è¦\t-32\t43\n" + |
| | | " ç²å³é©¾é©¶é¢è¦\t-32\t35\n" + |
| | | " è¿è§è¡é©¶æ¥è¦(2019)\t-32\t45\n" + |
| | | " èå(2019)\t-32\t44\n" + |
| | | " å½å¤©ç´¯è®¡é©¾é©¶è¶
æ¶\t-32\t18\n" + |
| | | " è¶
æ¶å车\t-32\t19\n" + |
| | | " è¿åºåºå\t-32\t20\n" + |
| | | " è¿åºè·¯çº¿\t-32\t20\n" + |
| | | " 路段è¡é©¶æ¶é´ä¸è¶³/è¿é¿\t-32\t21\n" + |
| | | " 路线å离æ¥è¦\t-32\t36\n" + |
| | | " 车è¾VSSæ
é\t-32\t37\n" + |
| | | " è½¦è¾æ²¹éå¼å¸¸\t-32\t38\n" + |
| | | " 车è¾è¢«ç\t-32\t39\n" + |
| | | " 车è¾éæ³ç¹ç«\t-32\t24\n" + |
| | | " 车è¾éæ³ä½ç§»\t-32\t25\n" + |
| | | " ç¢°ææ¥è¦\t-32\t40\n" + |
| | | " ä¾§ç¿»é¢è¦\t-32\t41\n" + |
| | | " 人è¸éç¥\t-30\t13\n" + |
| | | " ä¸çæå¡\t-30\t14\n" + |
| | | " åå¨å¨æ
鿥è¦\t-30\t23\n" + |
| | | " 叿ºæäºTFå¡\t-30\t50\n" + |
| | | " å©ä½æ²¹éç¾åæ¯\t-30\t102\n" + |
| | | " 平忲¹è\t-30\t103\n" + |
| | | " æµ·æé«åº¦\t-30\t104\n" + |
| | | " ææè¯äºä»¶\t-30\t900\n" + |
| | | " è½½å®¢ä¸æè¡¨\t-33\t0\n" + |
| | | " 空转é\t-33\t2\n" + |
| | | " æ¥å é\t104\t1\n" + |
| | | " æ¥åé\t104\t2\n" + |
| | | " 碰æ\t104\t3\n" + |
| | | " ä¾§ç¿»\t104\t4\n" + |
| | | " æ¥å·¦è½¬å¼¯\t104\t5\n" + |
| | | " æ¥å³è½¬å¼¯\t104\t6\n" + |
| | | " è¿è§è¿è¥æ¥è¦\t-33\t1\n" + |
| | | " å¼å¸¸äº¤æ¥ç\t0\t1\n" + |
| | | " è½½å®¢ç¶æé¿æ¶é´åç\t0\t2\n" + |
| | | " è¶
é\t0\t3\n" + |
| | | " èè表\t0\t5\n" + |
| | | " 嫿æ¥è¦\t1\t0\n" + |
| | | " 设å¤ç ´åæ¥è¦\t1\t1\n" + |
| | | " ççç²å³æ¥è¦\t101\t1\n" + |
| | | " å¼è½¦æçµè¯æ¥è¦\t101\t2\n" + |
| | | " å¼è½¦æ½çæ¥è¦\t101\t3\n" + |
| | | " 注æå忣\t101\t4\n" + |
| | | " è¶
æ¶é©¾é©¶\t101\t8\n" + |
| | | " 驾驶忣æµå¼å¸¸(人è¸ä¸å¨åºä¸)\t101\t9\n" + |
| | | " æªç³»å®å
¨å¸¦\t101\t17\n" + |
| | | " åæè±ç¦»æ¹åç\t101\t18\n" + |
| | | " 驾驶忣æµå¼å¸¸(æªæ£æµå°é©¾é©¶å)\t101\t5\n" + |
| | | " æ¢å¤´é®æ¡\t101\t6\n" + |
| | | " 䏿´å£ç½©æ¥è¦\t101\t100\n" + |
| | | " å
¶ä»\t101\t255\n" + |
| | | " è·¯å£è¶
é\t100\t7\n" + |
| | | " ä¸ç¤¼è®©è¡äºº\t100\t18\n" + |
| | | " è¡äººé²æ\t100\t19\n" + |
| | | " 车è·ç¦»è¿è¿\t100\t3\n" + |
| | | " 车éå离å³\t100\t20\n" + |
| | | " 车éå离左\t100\t21\n" + |
| | | " åå碰æ\t100\t1\n" + |
| | | " å
¶ä»\t100\t255\n" + |
| | | " ç´§æ¥æ¥è¦\t-32\t0\n" + |
| | | " é¢è¦\t-32\t1\n" + |
| | | " 嫿å®ä½æ¨¡ååçæ
é\t-32\t2\n" + |
| | | " 嫿å®ä½å¤©çº¿æªæ¥æè
è¢«åªæ\t-32\t3\n" + |
| | | " 嫿å®ä½å¤©çº¿çè·¯\t-32\t4\n" + |
| | | " ISU ä¸»çµæºæ¬ å\t-32\t5\n" + |
| | | " ISU ä¸»çµæºæçµ\t-32\t6\n" + |
| | | " LCDæ¾ç¤ºISUæ
é\t-32\t7\n" + |
| | | " è¯é³åææ¨¡åæ
é\t-32\t8\n" + |
| | | " æå头æ
é\t-32\t9\n" + |
| | | " è®¡ä»·å¨æ
é\t-32\t10\n" + |
| | | " æå¡è¯ä»·å¨æ
é\t-32\t11\n" + |
| | | " LED广åå±å¹æ
é\t-32\t12\n" + |
| | | " LCDæ¾ç¤ºå±æ
é\t-32\t13\n" + |
| | | " å®å
¨è®¿é®æ¨¡åæ
é\t-32\t14\n" + |
| | | " LEDé¢ç¯æ
é\t-32\t15\n" + |
| | | " è¶
鿥è¦\t-32\t16\n" + |
| | | " è¿ç»é©¾é©¶è¶
æ¶\t-32\t17\n" + |
| | | " å½å¤©ç´¯è®¡é©¾é©¶è¶
æ¶\t-32\t18\n" + |
| | | " è¶
æ¶å车\t-32\t19\n" + |
| | | " è¿åºåºå/路线\t-32\t20\n" + |
| | | " 路段è¡é©¶æ¶é´ä¸è¶³\t-32\t21\n" + |
| | | " ç¦è¡è·¯æ®µè¡é©¶\t-32\t22\n" + |
| | | " 车éä¼ æå¨æ
é\t-32\t23\n" + |
| | | " 车è¾éæ³ç¹ç«\t-32\t24"; |
| | | String[] tt = t.split("\n"); |
| | | List<String> list= new ArrayList<>(); |
| | | int index = 0; |
| | | for(String s : tt){ |
| | | String[] ttt =s.split("\t"); |
| | | if(ttt.length<=2){ |
| | | System.err.println(s); |
| | | continue; |
| | | } |
| | | String sss = "type"+index+"("+ index+",\""+ttt[0].replace(" ","")+"\"," + ttt[1]+","+ttt[2]+"),"; |
| | | list.add(sss); |
| | | index++; |
| | | } |
| | | for(String s :list){ |
| | | System.out.println(s); |
| | | } |
| | | } |
| | | |
| | | public enum CarsEventType { |
| | | type0(0,"éç¨",-30,100), |
| | | type1(1,"è¶
鿥è¦(设å¤å´æ )",-30,8), |
| | | type2(2,"è¿åºåºå/路线æ¥è¦(设å¤å´æ )",-30,2), |
| | | type3(3,"人è¸èå¤",-30,11), |
| | | type4(4,"ICå¡èå¤",-30,11), |
| | | type5(5,"äººè¸æ¯å¯¹ç»æ",-30,10), |
| | | type6(6,"ç¹æ®å¼å¸¸æ¥è¦",-30,12), |
| | | type7(7,"ååç¢°ææ¥è¦",100,1), |
| | | type8(8,"车éå忥è¦",100,2), |
| | | type9(9,"车è·è¿è¿æ¥è¦",100,3), |
| | | type10(10,"è¡äººç¢°ææ¥è¦",100,4), |
| | | type11(11,"é¢ç¹å鿥è¦",100,5), |
| | | type12(12,"éè·¯æ è¯è¶
鿥è¦",100,6), |
| | | type13(13,"éè·¯æ å¿è¶
鿥è¦",100,16), |
| | | type14(14,"䏻卿æäºä»¶",100,17), |
| | | type15(15,"车å¢è¿éè¡äººæ£æµ",100,19), |
| | | type16(16,"车éå离å³",100,20), |
| | | type17(17,"车éå离左",100,21), |
| | | type18(18,"è·¯å£æ¥è¦",100,30), |
| | | type19(19,"è¶
鿥è¦",100,31), |
| | | type20(20,"æé©¬çº¿è¶
é",100,32), |
| | | type21(21,"æªç¤¼è®©è¡äºº",100,33), |
| | | type22(22,"è¿è§å éè¡é©¶",100,34), |
| | | type23(23,"é¯çº¢ç¯",100,35), |
| | | type24(24,"ç²å³é©¾é©¶æ¥è¦",101,1), |
| | | type25(25,"æ¥æçµè¯æ¥è¦",101,2), |
| | | type26(26,"æ½çæ¥è¦",101,3), |
| | | type27(27,"åç¥é©¾é©¶æ¥è¦",101,4), |
| | | type28(28,"驾驶åå¼å¸¸(å
æ¬é©¾é©¶å离å²)",101,5), |
| | | type29(29,"鮿¡",101,6), |
| | | type30(30,"驾驶å人è¸èº«ä»½è¯å«äºä»¶(驾驶忣æµå¼å¸¸ï¼äººè¸ä¸å¨åºä¸)",101,9), |
| | | type31(31,"æªç³»å®å
¨å¸¦",101,17), |
| | | type32(32,"æªç³»å®å
¨å¸¦æ¥è¦å·¥ç¨è½¦",101,10), |
| | | type33(33,"红å¤é»æå¢¨é",101,11), |
| | | type34(34,"åæè±ç¦»æ¹åç",101,18), |
| | | type35(35,"åæè±ç¦»æ¹åç",101,13), |
| | | type36(36,"æªæ´å®å
¨å¸½",101,14), |
| | | type37(37,"èªå¨ææ",101,16), |
| | | type38(38,"éæ³å
³é¨",101,29), |
| | | type39(39,"éæ³å¼é¨",101,30), |
| | | type40(40,"ç©ææº",101,31), |
| | | type41(41,"饮é
驾驶",101,32), |
| | | type42(42,"éé
驾驶",101,33), |
| | | type43(43,"å¤äººè¸æ¥è¦",101,48), |
| | | type44(44,"éç¼",101,34), |
| | | type45(45,"åAEBæ¥è¦",101,101), |
| | | type46(46,"䏿´å£ç½©æ¥è¦",101,100), |
| | | type47(47,"åæ¹æ¥è¿æ¥è¦",102,1), |
| | | type48(48,"左侧忹æ¥è¿æ¥è¦",102,2), |
| | | type49(49,"å³ä¾§åæ¹æ¥è¿æ¥è¦",102,3), |
| | | type50(50,"ååæ¥è¿æ¥è¦",102,4), |
| | | type51(51,"çä¼¼éæ³æ³¨æ°´æ¥è¦",102,5), |
| | | type52(52,"åè¶
声波æ¥è¦",102,238), |
| | | type53(53,"åè¶
声波æ¥è¦",102,239), |
| | | type54(54,"ç´§æ¥æ¥è¦",102,240), |
| | | type55(55,"æ¥å é",104,1), |
| | | type56(56,"æ¥åé",104,2), |
| | | type57(57,"碰æ",104,3), |
| | | type58(58,"ä¾§ç¿»",104,4), |
| | | type59(59,"æ¥å·¦è½¬å¼¯",104,5), |
| | | type60(60,"æ¥å³è½¬å¼¯",104,6), |
| | | type61(61,"æ¥è½¬å¼¯(ä¸åºåå·¦åå³)",104,7), |
| | | type62(62,"å§çé¢ ç°¸",104,255), |
| | | type63(63,"驾驶åè¯ä»¶",163,163), |
| | | type64(64,"å³è½¬å¼¯è¶
é",238,1), |
| | | type65(65,"å³è½¬å¼¯ä¸å车",238,2), |
| | | type66(66,"举åäºä»¶",172,1), |
| | | type67(67,"å¯éäºä»¶",172,2), |
| | | type68(68,"è½½éäºä»¶",172,3), |
| | | type69(69,"åè§ç²åºå¶å¨",249 ,1), |
| | | type70(70,"åè§ç²åºå¶å¨",249,2), |
| | | type71(71,"åè¶
声波å¶å¨",249,3), |
| | | type72(72,"åè¶
声波å¶å¨",249,4), |
| | | type73(73,"å·¦è§ç²åºå¶å¨",249,5), |
| | | type74(74,"å³è§ç²åºå¶å¨",249,6), |
| | | type75(75,"åAEBå¶å¨",249,7), |
| | | type76(76,"åè§ç²åºé¢è¦",249,21), |
| | | type77(77,"åè§ç²åºé¢è¦",249,22), |
| | | type78(78,"åè¶
声波é¢è¦",249,23), |
| | | type79(79,"åè¶
声波é¢è¦",249,24), |
| | | type80(80,"å·¦è§ç²åºé¢è¦",249,25), |
| | | type81(81,"å³è§ç²åºé¢è¦",249,26), |
| | | type82(82,"åAEBé¢è¦",249,27), |
| | | type83(83,"主å¨ä¸æ¥æ¥è¦äºä»¶",160,0), |
| | | type84(84,"å·¡æ£ä¸æ¥äºä»¶",160,1), |
| | | type85(85,"ç´§æ¥æ¥è¦",25,1), |
| | | type86(86,"ç´§æ¥æ¥è¦",-32,0), |
| | | type87(87,"è¶
鿥è¦",-32,16), |
| | | type88(88,"ç²å³é©¾é©¶",-32,32), |
| | | type89(89,"å±é©é¢è¦",-32,33), |
| | | type90(90,"GNSS模åæ
é",-32,2), |
| | | type91(91,"GNSSå¤©çº¿æªæ¥å
¥",-32,3), |
| | | type92(92,"GNSS天线çè·¯",-32,4), |
| | | type93(93,"ç»ç«¯ä¸»çµæºæ¬ å",-32,5), |
| | | type94(94,"ç»ç«¯ä¸»çµæºæçµ",-32,6), |
| | | type95(95,"LCDæè
æ¾ç¤ºå±æ
é",-32,7), |
| | | type96(96,"TTS模åæ
é",-32,46), |
| | | type97(97,"æå头æ
é",-32,9), |
| | | type98(98,"éè·¯è¿è¾è¯IC塿¨¡åæ
é",-32,34), |
| | | type99(99,"è¶
éé¢è¦",-32,43), |
| | | type100(100,"ç²å³é©¾é©¶é¢è¦",-32,35), |
| | | type101(101,"è¿è§è¡é©¶æ¥è¦(2019)",-32,45), |
| | | type102(102,"èå(2019)",-32,44), |
| | | type103(103,"å½å¤©ç´¯è®¡é©¾é©¶è¶
æ¶",-32,18), |
| | | type104(104,"è¶
æ¶å车",-32,19), |
| | | type105(105,"è¿åºåºå",-32,20), |
| | | type106(106,"è¿åºè·¯çº¿",-32,20), |
| | | type107(107,"路段è¡é©¶æ¶é´ä¸è¶³/è¿é¿",-32,21), |
| | | type108(108,"路线å离æ¥è¦",-32,36), |
| | | type109(109,"车è¾VSSæ
é",-32,37), |
| | | type110(110,"è½¦è¾æ²¹éå¼å¸¸",-32,38), |
| | | type111(111,"车è¾è¢«ç",-32,39), |
| | | type112(112,"车è¾éæ³ç¹ç«",-32,24), |
| | | type113(113,"车è¾éæ³ä½ç§»",-32,25), |
| | | type114(114,"ç¢°ææ¥è¦",-32,40), |
| | | type115(115,"ä¾§ç¿»é¢è¦",-32,41), |
| | | type116(116,"人è¸éç¥",-30,13), |
| | | type117(117,"ä¸çæå¡",-30,14), |
| | | type118(118,"åå¨å¨æ
鿥è¦",-30,23), |
| | | type119(119,"叿ºæäºTFå¡",-30,50), |
| | | type120(120,"å©ä½æ²¹éç¾åæ¯",-30,102), |
| | | type121(121,"平忲¹è",-30,103), |
| | | type122(122,"æµ·æé«åº¦",-30,104), |
| | | type123(123,"ææè¯äºä»¶",-30,900), |
| | | type124(124,"è½½å®¢ä¸æè¡¨",-33,0), |
| | | type125(125,"空转é",-33,2), |
| | | type126(126,"æ¥å é",104,1), |
| | | type127(127,"æ¥åé",104,2), |
| | | type128(128,"碰æ",104,3), |
| | | type129(129,"ä¾§ç¿»",104,4), |
| | | type130(130,"æ¥å·¦è½¬å¼¯",104,5), |
| | | type131(131,"æ¥å³è½¬å¼¯",104,6), |
| | | type132(132,"è¿è§è¿è¥æ¥è¦",-33,1), |
| | | type133(133,"å¼å¸¸äº¤æ¥ç",0,1), |
| | | type134(134,"è½½å®¢ç¶æé¿æ¶é´åç",0,2), |
| | | type135(135,"è¶
é",0,3), |
| | | type136(136,"èè表",0,5), |
| | | type137(137,"嫿æ¥è¦",1,0), |
| | | type138(138,"设å¤ç ´åæ¥è¦",1,1), |
| | | type139(139,"ççç²å³æ¥è¦",101,1), |
| | | type140(140,"å¼è½¦æçµè¯æ¥è¦",101,2), |
| | | type141(141,"å¼è½¦æ½çæ¥è¦",101,3), |
| | | type142(142,"注æå忣",101,4), |
| | | type143(143,"è¶
æ¶é©¾é©¶",101,8), |
| | | type144(144,"驾驶忣æµå¼å¸¸(人è¸ä¸å¨åºä¸)",101,9), |
| | | type145(145,"æªç³»å®å
¨å¸¦",101,17), |
| | | type146(146,"åæè±ç¦»æ¹åç",101,18), |
| | | type147(147,"驾驶忣æµå¼å¸¸(æªæ£æµå°é©¾é©¶å)",101,5), |
| | | type148(148,"æ¢å¤´é®æ¡",101,6), |
| | | type149(149,"䏿´å£ç½©æ¥è¦",101,100), |
| | | type150(150,"å
¶ä»",101,255), |
| | | type151(151,"è·¯å£è¶
é",100,7), |
| | | type152(152,"ä¸ç¤¼è®©è¡äºº",100,18), |
| | | type153(153,"è¡äººé²æ",100,19), |
| | | type154(154,"车è·ç¦»è¿è¿",100,3), |
| | | type155(155,"车éå离å³",100,20), |
| | | type156(156,"车éå离左",100,21), |
| | | type157(157,"åå碰æ",100,1), |
| | | type158(158,"å
¶ä»",100,255), |
| | | type159(159,"ç´§æ¥æ¥è¦",-32,0), |
| | | type160(160,"é¢è¦",-32,1), |
| | | type161(161,"嫿å®ä½æ¨¡ååçæ
é",-32,2), |
| | | type162(162,"嫿å®ä½å¤©çº¿æªæ¥æè
è¢«åªæ",-32,3), |
| | | type163(163,"嫿å®ä½å¤©çº¿çè·¯",-32,4), |
| | | type164(164,"ISUä¸»çµæºæ¬ å",-32,5), |
| | | type165(165,"ISUä¸»çµæºæçµ",-32,6), |
| | | type166(166,"LCDæ¾ç¤ºISUæ
é",-32,7), |
| | | type167(167,"è¯é³åææ¨¡åæ
é",-32,8), |
| | | type168(168,"æå头æ
é",-32,9), |
| | | type169(169,"è®¡ä»·å¨æ
é",-32,10), |
| | | type170(170,"æå¡è¯ä»·å¨æ
é",-32,11), |
| | | type171(171,"LED广åå±å¹æ
é",-32,12), |
| | | type172(172,"LCDæ¾ç¤ºå±æ
é",-32,13), |
| | | type173(173,"å®å
¨è®¿é®æ¨¡åæ
é",-32,14), |
| | | type174(174,"LEDé¢ç¯æ
é",-32,15), |
| | | type175(175,"è¶
鿥è¦",-32,16), |
| | | type176(176,"è¿ç»é©¾é©¶è¶
æ¶",-32,17), |
| | | type177(177,"å½å¤©ç´¯è®¡é©¾é©¶è¶
æ¶",-32,18), |
| | | type178(178,"è¶
æ¶å车",-32,19), |
| | | type179(179,"è¿åºåºå/路线",-32,20), |
| | | type180(180,"路段è¡é©¶æ¶é´ä¸è¶³",-32,21), |
| | | type181(181,"ç¦è¡è·¯æ®µè¡é©¶",-32,22), |
| | | type182(182,"车éä¼ æå¨æ
é",-32,23), |
| | | type183(183,"车è¾éæ³ç¹ç«",-32,24), |
| | | type184(184,"è忥è¦",103,null), |
| | | type185(185,"æµæ¸©æ¥è¦",170,null) |
| | | ; |
| | | |
| | | // æååé |
| | | private int key; |
| | | private Integer type ; |
| | | private Integer subType ; |
| | | private String name; |
| | | public static String getName(Integer type,Integer subType) { |
| | | for (CarsEventType c : CarsEventType.values()) { |
| | | if (Constants.equalsInteger(c.getType(),type) && Constants.equalsInteger(c.getSubType(),subType)) { |
| | | return c.getName(); |
| | | } |
| | | } |
| | | return null; |
| | | } |
| | | // æé æ¹æ³ |
| | | CarsEventType(int key, String name, Integer type,Integer subType) { |
| | | this.key = key; |
| | | this.subType = subType; |
| | | this.type = type; |
| | | this.name = name; |
| | | } |
| | | |
| | | public Integer getType() { |
| | | return type; |
| | | } |
| | | |
| | | public Integer getSubType() { |
| | | return subType; |
| | | } |
| | | |
| | | public void setSubType(Integer subType) { |
| | | this.subType = subType; |
| | | } |
| | | |
| | | public int getKey() { |
| | | return key; |
| | | } |
| | | |
| | | public void setKey(int key) { |
| | | this.key = key; |
| | | } |
| | | |
| | | public String getName() { |
| | | return name; |
| | | } |
| | | |
| | | public void setName(String name) { |
| | | this.name = name; |
| | | } |
| | | |
| | | public void setType(Integer type) { |
| | | this.type = type; |
| | | } |
| | | } |
| | | /** |
| | | åç¹ç»å½æ¨¡åèåæ è¯ï¼ |
| | | 1ãå®é²ä¸å¿ï¼afzx |
| | |
| | | String[] minitorDataSearchV1= new String[]{"/api/fem/v1/minitor/data/search","å页æ¥è¯¢è®¾å¤çæµå岿°æ®"};//å页æ¥è¯¢è®¾å¤çæµå岿°æ® |
| | | String[] minitorDataSearch= new String[]{"/api/fpms/v2/minitor/data/search","å页æ¥è¯¢è®¾å¤çæµå岿°æ®"};//å页æ¥è¯¢è®¾å¤çæµå岿°æ® |
| | | String[] userOpenidSave= new String[]{"/api/v1/oa/userOpenId/saveV2","ä¿åç¨æ·åopenIdç»å®ä¿¡æ¯å¾®ä¿¡å
¬ä¼å·"};//ä¿åç¨æ·åopenIdç»å®ä¿¡æ¯å¾®ä¿¡å
¬ä¼å· |
| | | String[] temperatureHumidityDataStatistic= new String[]{"/api/v2/public/monitor/sensor/list","æ¶é²çæ¿-4温湿度ç»è®¡"};//æ¶é²çæ¿-温湿度 |
| | | } |
| | | /** |
| | | * éå½A.55æ¶é²è®¾å¤ç±»å |
| | |
| | | public static String getTodoListPage(Map<String, String> body) throws Exception{ |
| | | return startDoGetStringArtemis(HKConstants.InterfacePath.getTodoListPage,body); |
| | | } |
| | | |
| | | /** |
| | | *æ¶é²çæ¿-4æ¸©æ¹¿åº¦æ°æ® |
| | | * @param body |
| | | * @return |
| | | */ |
| | | public static String temperatureHumidityDataStatistic(String body) { |
| | | return startDoPostStringArtemisAdmin(HKConstants.InterfacePath.temperatureHumidityDataStatistic,body); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * è·åé¨ç¦ç¹å表 |
| | | * @param body |
| | |
| | | saveInterfaceLog(body,result,path,pathStr[1]); |
| | | return result; |
| | | } |
| | | |
| | | |
| | | public static String startDoPostStringArtemisAdmin(String[] pathStr,String body){ |
| | | Map<String, String> path = getPath(pathStr[0]); |
| | | Map<String, String> header = new HashMap<>(); |
| | | header.put("userId", "admin"); |
| | | String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", header);// post请æ±application/jsonç±»ååæ° |
| | | saveInterfaceLog(body,result,path,pathStr[1]); |
| | | return result; |
| | | } |
| | | |
| | | public static String startDoGetStringArtemis(String[] pathStr,Map<String,String> body ){ |
| | | Map<String, String> path = getPath(pathStr[0]); |
| | | Map<String, String> header = new HashMap<>(); |
| | |
| | | String result = ArtemisHttpUtil.doPostStringArtemis(path, body, null, null, "application/json", header);// post请æ±application/jsonç±»ååæ° |
| | | saveInterfaceLog(body,result,path,pathStr[1]); |
| | | return result; |
| | | |
| | | } |
| | | |
| | | |
| | | public static String startDoPostStringArtemis(String[] pathStr,Map<String, String> querys,Map<String, String> header,String body){ |
| | | Map<String, String> path = getPath(pathStr[0]); |
| | | header.put("tagId", UUID.randomUUID().toString().replace("-", "")); |
| | | String result = ArtemisHttpUtil.doPostStringArtemis(path, body, querys, null, "application/json", header);// post请æ±application/jsonç±»ååæ° |
| | | saveInterfaceLog(body,result,path,pathStr[1]); |
| | | return result; |
| | | |
| | | } |
| | | /** |
| | | * ç¾ç¦»è®¿å®¢é¢çº¦ |
| | |
| | | public static String findAlarmBaseDataStatistic(String body) { |
| | | return startDoPostStringArtemis(HKConstants.InterfacePath.findAlarmBaseDataStatistic,body); |
| | | } |
| | | |
| | | /** |
| | | *å®é²çæ¿-- b |
| | | * @param body |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.haikang.model.cars.request; |
| | | |
| | | import lombok.Data; |
| | | |
| | | /** |
| | | * 设å¤å表请æ±ä¿¡æ¯ |
| | | */ |
| | | @Data |
| | | public class CarsAlarmListRequest { |
| | | |
| | | private Integer pageSize;// 页é¢å¤§å° Integer 1000 å¦ |
| | | private Integer pageNo ;//å½å页 Integer 1 |
| | | |
| | | private String deviceCode ;//设å¤ç»ç«¯ææºå· String æ æ¯ |
| | | private String startTime ;//å¼å§æ¶é´yyyy-MM-dd HH:mm:ss String æ æ¯ |
| | | private String endTime ;//ç»ææ¶é´yyyy-MM-dd HH:mm:ss String æ æ¯ |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.haikang.model.cars.response; |
| | | |
| | | import lombok.Data; |
| | | |
| | | import java.util.List; |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * 设å¤å表åå
ä¿¡æ¯ |
| | | * @param <T> |
| | | */ |
| | | @Data |
| | | public class CarsAlarmListResponse<T> { |
| | | |
| | | private String deviceCode;// 设å¤ç»ç«¯ææºå· String |
| | | private String productKey ;//è®¾å¤æå±åå·ç产åå¯é¥ String |
| | | private Integer type ;//æ¥è¦ç±»å Integer |
| | | private Integer subType ;//æ¥è¦åç±»ï¼æ¥è¦ç±»å忥è¦åç±»å¯ç¡®å®å¯ä¸æ¥è¦ç±»åï¼ Integer |
| | | private Integer level ;//æ¥è¦çº§å« 0x01:1é¢è¦ 0x02:2æ¥è¦ Integer |
| | | private Integer frontCarSpeed ;//å车é度Km/h Integer |
| | | private Integer frontDistance ;//å车/è¡äººè·ç¦» Integer |
| | | private Integer deviationType ;//å离类å 0x01:左侧å离 0x02:å³ä¾§å离 Integer |
| | | private Integer roadSignsType ;//éè·¯æ å¿è¯å«ç±»å 0x01:ééæ å¿ 0x02:é髿 å¿ 0x03:ééæ å¿ Integer |
| | | private Integer roadSignsValue ;//éè·¯æ å¿è¯å«æ°æ® Integer |
| | | private Integer speed;// 车é åä½Km/h Integer |
| | | private Integer altitude;// æµ·æé«åº¦ åä½m Short |
| | | private Double longitude;// ç»åº¦ Double |
| | | private Double latitude;// 纬度 Double |
| | | private String time;// YY-MM-DD-hh-mm-ss ï¼GMT+8æ¶é´ï¼ String |
| | | private Integer accState;// accç¶æ Integer |
| | | private Integer leftTurnState ;//左转åç¶æï¼0:å
³éï¼1:æå¼ Integer |
| | | private Integer rightTurnState;// å³è½¬åç¶æï¼0:å
³éï¼1:æå¼ Integer |
| | | private Integer wiperState;// é¨å®å¨ç¶æï¼ 0:å
³éï¼1:æå¼ Integer |
| | | private Integer brakingState;// å¶å¨ç¶æï¼0:æªå¶å¨ï¼1:å¶å¨ Integer |
| | | private Integer cardState ;//æå¡ç¶æï¼0:æªæå¡ï¼1:å·²æå¡ Integer |
| | | private Integer gpsValid;// å®ä½ç¶æï¼0:æªå®ä½ï¼1:å·²å®ä½ Integer |
| | | private String deviceId;// ç»ç«¯ID String |
| | | private String alarmSignTime ;//æ¥è¦æ è¯æ¶é´ String |
| | | private Integer index ;//åºå· Integer |
| | | private Integer attachCount;// é件个æ°ï¼éä»¶æ°>0çæ¥è¦ï¼å¯ä»¥è°ç¨âæ¥è¯¢è®¾å¤æ¥è¦éä»¶âæ¥å£æ¥è¯¢éä»¶ä¿¡æ¯ Integer |
| | | private String alarmSign ;//æ¥è¦æ è¯å· ç»ç«¯ID-æ¶é´-åºå·-éä»¶æ°é String |
| | | private Integer fatigueDegree;// ç²å³ç¨åº¦ï¼èå´1~10ãæ°å¼è¶å¤§è¡¨ç¤ºç²å³ç¨åº¦è¶ä¸¥é Integer |
| | | private String carSign;//车çé¢è²ä¸º0æ¶ï¼è¡¨ç¤ºè½¦è¾ VINï¼å¦åï¼è¡¨ç¤ºå
¬å®äº¤é管çé¨é¨é¢åçæºå¨è½¦å·ç String |
| | | private Integer areaType;//åºåãé路类å Integer |
| | | private Integer areaId ;//åºåãéè·¯ç¼å· Integer |
| | | private Integer efcType;// è¿åºæ¥è¦ç±»å(0:è¿å
¥åºåï¼1:离å¼åºå) Integer |
| | | private String qualificationNumber ;//驾驶åä»ä¸èµæ ¼è¯å· String |
| | | private Integer chanNo ;//é»è¾ééå· Integer |
| | | private String attachInfo ;//æ¥è¦éä»¶ä¿¡æ¯ï¼attachFlag为trueæ¶è¯¥å段ææï¼è¯¦ç»å段è§*表2 Object |
| | | private String efcName ;//çµåå´æ åç§° String |
| | | private String efcUuid ;//çµåå´æ uuid String |
| | | private Integer limitState ;//åºå
¥éå¶(1:ç¦æ¢é©¶å
¥ï¼2ï¼ç¦æ¢é©¶åº:3:路线å离) Integer |
| | | private String position;// æ¥è¦ä½ç½® String |
| | | private Integer moveState ;//è¿å¨ç¶æï¼0ï¼åæ¢ï¼1ï¼è¡é©¶ Integer |
| | | private Integer voltage;// çµç¶çµåï¼æ¾å¤§1000å Integer |
| | | private Integer temperature;// è®¾å¤æ¸©åº¦ï¼æ¾å¤§1000å Integer |
| | | private Integer wakeupType ;//设å¤å¤éæº Integer |
| | | private Integer Tvistatus ;//åæç¸æºå½åç¶æ Integer |
| | | private Integer LTEpower;// 4G模åä¾çµ Integer |
| | | private Integer LTEstatus;// 4G模åå¨ä½ä¿¡å· Integer |
| | | private Integer parkmode;// åè½¦çæ§æ¨¡å¼ Integer |
| | | private Integer uploadType;// 䏿¥æ¶æ¯ç±»å Integer |
| | | private Integer stayTime ;// æ¥è¦æ¶å·²ç»åççæ¶é¿ï¼åé Integer |
| | | private Long stayId ;//éç»ç¹id Long |
| | | |
| | | private String efcEventInfo;// çµåå´æ æ¥è¦è¯¦æ
ä¿¡æ¯ Object |
| | | |
| | | private String gpsData ;//æ¥è¦å¯¹åºçGPSä¿¡æ¯ Object |
| | | |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.haikang.model.cars.response; |
| | | |
| | | import lombok.Data; |
| | | |
| | | /** |
| | | * 设å¤å表åå
ä¿¡æ¯ |
| | | */ |
| | | @Data |
| | | public class CarsAlarmResultListResponse{ |
| | | |
| | | private Integer type ;//æ¥è¦ç±»å Integer |
| | | private Integer subType ;//æ¥è¦åç±»ï¼æ¥è¦ç±»å忥è¦åç±»å¯ç¡®å®å¯ä¸æ¥è¦ç±»åï¼ Integer |
| | | private String time;// YY-MM-DD-hh-mm-ss ï¼GMT+8æ¶é´ï¼ String |
| | | private String carCode;//车çå· |
| | | private String title;//ç±»ååç§° |
| | | private long timeStamp; |
| | | |
| | | } |
| | |
| | | private Integer supplementSign;// è¡¥æ¥æ è¯ï¼1ï¼è¡¥æ¥ï¼0ï¼æ£å¸¸ä¸æ¥ï¼ Integer |
| | | private String createTime;// ç³»ç»æ¶å°GPSæ¶é´yyyy-MM-dd HH:mm:ss String |
| | | private Integer status;//设å¤ç¶æ 0ï¼ç¦»çº¿ï¼1ï¼å¨çº¿ï¼2ï¼ä¼ç |
| | | private Integer jobStatus;//å·¥ä½ç¶æ //0ç©ºé² 1å¨é2离线 |
| | | private String plateNum;//车çå· |
| | | private String terminalID;// ç»ç«¯ææºå· String |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.haikang.model.cars.response; |
| | | |
| | | import lombok.Data; |
| | | |
| | | /** |
| | | * 设å¤å表åå
ä¿¡æ¯ |
| | | * @param <T> |
| | | */ |
| | | @Data |
| | | public class CarsEfcEventInfoResponse<T> { |
| | | |
| | | private String deviceCode;// 设å¤ç»ç«¯ææºå· String |
| | | private String productKey ;//è®¾å¤æå±åå·ç产åå¯é¥ String |
| | | private Integer type ;//æ¥è¦ç±»å Integer |
| | | private Integer subType ;//æ¥è¦åç±»ï¼æ¥è¦ç±»å忥è¦åç±»å¯ç¡®å®å¯ä¸æ¥è¦ç±»åï¼ Integer |
| | | private Integer level ;//æ¥è¦çº§å« 0x01:1é¢è¦ 0x02:2æ¥è¦ Integer |
| | | private Integer frontCarSpeed ;//å车é度Km/h Integer |
| | | private Integer frontDistance ;//å车/è¡äººè·ç¦» Integer |
| | | private Integer deviationType ;//å离类å 0x01:左侧å离 0x02:å³ä¾§å离 Integer |
| | | private Integer roadSignsType ;//éè·¯æ å¿è¯å«ç±»å 0x01:ééæ å¿ 0x02:é髿 å¿ 0x03:ééæ å¿ Integer |
| | | private Integer roadSignsValue ;//éè·¯æ å¿è¯å«æ°æ® Integer |
| | | private Integer speed;// 车é åä½Km/h Integer |
| | | private Integer altitude;// æµ·æé«åº¦ åä½m Short |
| | | private Double longitude;// ç»åº¦ Double |
| | | private Double latitude;// 纬度 Double |
| | | private String time;// YY-MM-DD-hh-mm-ss ï¼GMT+8æ¶é´ï¼ String |
| | | private Integer accState;// accç¶æ Integer |
| | | private Integer leftTurnState ;//左转åç¶æï¼0:å
³éï¼1:æå¼ Integer |
| | | private Integer rightTurnState;// å³è½¬åç¶æï¼0:å
³éï¼1:æå¼ Integer |
| | | private Integer wiperState;// é¨å®å¨ç¶æï¼ 0:å
³éï¼1:æå¼ Integer |
| | | private Integer brakingState;// å¶å¨ç¶æï¼0:æªå¶å¨ï¼1:å¶å¨ Integer |
| | | private Integer cardState ;//æå¡ç¶æï¼0:æªæå¡ï¼1:å·²æå¡ Integer |
| | | private Integer gpsValid;// å®ä½ç¶æï¼0:æªå®ä½ï¼1:å·²å®ä½ Integer |
| | | private String deviceId;// ç»ç«¯ID String |
| | | private String alarmSignTime ;//æ¥è¦æ è¯æ¶é´ String |
| | | private Integer index ;//åºå· Integer |
| | | private Integer attachCount;// é件个æ°ï¼éä»¶æ°>0çæ¥è¦ï¼å¯ä»¥è°ç¨âæ¥è¯¢è®¾å¤æ¥è¦éä»¶âæ¥å£æ¥è¯¢éä»¶ä¿¡æ¯ Integer |
| | | private String alarmSign ;//æ¥è¦æ è¯å· ç»ç«¯ID-æ¶é´-åºå·-éä»¶æ°é String |
| | | private Integer fatigueDegree;// ç²å³ç¨åº¦ï¼èå´1~10ãæ°å¼è¶å¤§è¡¨ç¤ºç²å³ç¨åº¦è¶ä¸¥é Integer |
| | | private String carSign;//车çé¢è²ä¸º0æ¶ï¼è¡¨ç¤ºè½¦è¾ VINï¼å¦åï¼è¡¨ç¤ºå
¬å®äº¤é管çé¨é¨é¢åçæºå¨è½¦å·ç String |
| | | private Integer areaType;//åºåãé路类å Integer |
| | | private Integer areaId ;//åºåãéè·¯ç¼å· Integer |
| | | private Integer efcType;// è¿åºæ¥è¦ç±»å(0:è¿å
¥åºåï¼1:离å¼åºå) Integer |
| | | private String qualificationNumber ;//驾驶åä»ä¸èµæ ¼è¯å· String |
| | | private Integer chanNo ;//é»è¾ééå· Integer |
| | | private String attachInfo ;//æ¥è¦éä»¶ä¿¡æ¯ï¼attachFlag为trueæ¶è¯¥å段ææï¼è¯¦ç»å段è§*表2 Object |
| | | private String efcName ;//çµåå´æ åç§° String |
| | | private String efcUuid ;//çµåå´æ uuid String |
| | | private Integer limitState ;//åºå
¥éå¶(1:ç¦æ¢é©¶å
¥ï¼2ï¼ç¦æ¢é©¶åº:3:路线å离) Integer |
| | | private String position;// æ¥è¦ä½ç½® String |
| | | private Integer moveState ;//è¿å¨ç¶æï¼0ï¼åæ¢ï¼1ï¼è¡é©¶ Integer |
| | | private Integer voltage;// çµç¶çµåï¼æ¾å¤§1000å Integer |
| | | private Integer temperature;// è®¾å¤æ¸©åº¦ï¼æ¾å¤§1000å Integer |
| | | private Integer wakeupType ;//设å¤å¤éæº Integer |
| | | private Integer Tvistatus ;//åæç¸æºå½åç¶æ Integer |
| | | private Integer LTEpower;// 4G模åä¾çµ Integer |
| | | private Integer LTEstatus;// 4G模åå¨ä½ä¿¡å· Integer |
| | | private Integer parkmode;// åè½¦çæ§æ¨¡å¼ Integer |
| | | private Integer uploadType;// 䏿¥æ¶æ¯ç±»å Integer |
| | | private Integer stayTime ;// æ¥è¦æ¶å·²ç»åççæ¶é¿ï¼åé Integer |
| | | private Long stayId ;//éç»ç¹id Long |
| | | |
| | | private String efcEventInfo;// çµåå´æ æ¥è¦è¯¦æ
ä¿¡æ¯ Object |
| | | |
| | | private String gpsData ;//æ¥è¦å¯¹åºçGPSä¿¡æ¯ Object |
| | | |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.haikang.model.param.request; |
| | | |
| | | import lombok.Data; |
| | | |
| | | @Data |
| | | public class TemperatureHumidityDataRequest { |
| | | |
| | | private Integer pageSize ;// Query Number false å页大å°ï¼1~999ï¼ |
| | | private Integer pageNo;// Query Number false å½å页ç (1~100000) |
| | | private String parentIndexCode;// Query String false e74fcf79bebb492bb750a557bfb12ab9 |
| | | |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.haikang.model.param.respose; |
| | | |
| | | import io.swagger.annotations.ApiModelProperty; |
| | | import lombok.Data; |
| | | |
| | | @Data |
| | | public class TemperatureHumidityDataResponse { |
| | | |
| | | @ApiModelProperty(value = "åç§°") |
| | | private String name ;//String false 设å¤åç§° |
| | | |
| | | @ApiModelProperty(value = "æä½æ¸©åº¦") |
| | | private String alarmLow ;//String false æä½æ¸©åº¦ |
| | | |
| | | @ApiModelProperty(value = "æé«æ¸©åº¦") |
| | | private String alarmHigh ;//String false æé«æ¸©åº¦ |
| | | |
| | | @ApiModelProperty(value = "å½åå¼") |
| | | private String latestValue ;//String false å½åå¼ |
| | | |
| | | private String indexCode ;//String false |
| | | |
| | | @ApiModelProperty(value = "ç±»åï¼temp 温度 humidity 湿度") |
| | | private String sensorType ;//String false |
| | | |
| | | private String parentIndexCode ;//String false |
| | | |
| | | @ApiModelProperty(value = "åä½") |
| | | private String unit ;//String false åä½ |
| | | |
| | | |
| | | } |
| | |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.alibaba.fastjson.TypeReference; |
| | | import com.doumee.core.haikang.model.HKConstants; |
| | | import com.doumee.core.haikang.model.cars.BaseCarsPageResponse; |
| | | import com.doumee.core.haikang.model.cars.BaseCarsResponse; |
| | | import com.doumee.core.haikang.model.cars.request.CarsAlarmListRequest; |
| | | import com.doumee.core.haikang.model.cars.request.CarsDeviceRequest; |
| | | import com.doumee.core.haikang.model.cars.request.CarsGpsRequest; |
| | | import com.doumee.core.haikang.model.cars.response.CarsDeviceDetaisResponse; |
| | | import com.doumee.core.haikang.model.cars.response.CarsDeviceResponse; |
| | | import com.doumee.core.haikang.model.cars.response.CarsGpsResponse; |
| | | import com.doumee.core.haikang.model.cars.response.*; |
| | | import com.doumee.core.haikang.model.param.BaseListPageResponse; |
| | | import com.doumee.core.haikang.model.param.BaseResponse; |
| | | import com.doumee.core.haikang.model.param.respose.FindHomeAlarmInfoPageResponse; |
| | |
| | | } |
| | | return list; |
| | | } |
| | | public static List<CarsAlarmResultListResponse> getAlarmEvemtList(List<CarsDeviceDetaisResponse> detaisResponses , Date date) { |
| | | List<CarsAlarmResultListResponse> list = new ArrayList<>(); |
| | | if(detaisResponses ==null || detaisResponses.size()==0){ |
| | | return list ; |
| | | } |
| | | CarsAlarmListRequest param = new CarsAlarmListRequest(); |
| | | param.setStartTime(DateUtil.getPlusTime2(DateUtil.getStartOfDay(date))); |
| | | param.setEndTime(DateUtil.getPlusTime2(DateUtil.getEndOfDay(date))); |
| | | param.setPageNo(1); |
| | | param.setPageSize(100); |
| | | for( CarsDeviceDetaisResponse de :detaisResponses ){ |
| | | param.setDeviceCode(de.getTerminalID()); |
| | | BaseCarsPageResponse<CarsAlarmListResponse> data = getAlarmList(param); |
| | | if(data!=null &&data.getResults()!=null){ |
| | | for(CarsAlarmListResponse model :data.getResults()){ |
| | | CarsAlarmResultListResponse tm = new CarsAlarmResultListResponse(); |
| | | tm.setTime(model.getTime()); |
| | | tm.setCarCode(de.getPlateNum()); |
| | | tm.setType(model.getType()); |
| | | tm.setSubType(model.getSubType()); |
| | | Date tmDate = DateUtil.fromStringToDate("yyyy-MM-dd HH:mm:ss", tm.getTime() ); |
| | | if(tmDate!=null){ |
| | | tm.setTimeStamp(tmDate.getTime()); |
| | | } |
| | | tm.setTitle(HKConstants.CarsEventType.getName(tm.getType(),tm.getSubType())); |
| | | list.add(tm); |
| | | } |
| | | } |
| | | } |
| | | Collections.sort(list, (o1, o2) -> { |
| | | return (int) (o1.getTimeStamp() - o2.getTimeStamp()); //ææ°éä»å¤§å°å°æåº |
| | | }); |
| | | return list; |
| | | } |
| | | |
| | | private static CarsDeviceDetaisResponse getFromListById(String key, List<CarsDeviceDetaisResponse> list) { |
| | | for(CarsDeviceDetaisResponse dd :list){ |
| | |
| | | String url = BASE_URL + "device/list/"; |
| | | TreeMap<String, String> BASE_PARAMS = getBaseParams(); |
| | | if(StringUtils.isNotBlank(param.getProductKey())){ |
| | | BASE_PARAMS.put("productKey", "");//设å¤åå·ç§é¥ |
| | | BASE_PARAMS.put("productKey", param.getProductKey());//设å¤åå·ç§é¥ |
| | | } |
| | | BASE_PARAMS.put("pageSize",Constants.equalsInteger(param.getPageSize(),0)? "100":param.getPageSize().toString());//页é¢å¤§å° |
| | | BASE_PARAMS.put("pageNo", Constants.equalsInteger(param.getPageNo(),0)? "1":param.getPageNo().toString());//å½å页 |
| | |
| | | } |
| | | return null; |
| | | } |
| | | public static BaseCarsPageResponse<CarsAlarmListResponse> getAlarmList(CarsAlarmListRequest param) { |
| | | String url = BASE_URL + "alarm/list/"; |
| | | TreeMap<String, String> BASE_PARAMS = getBaseParams(); |
| | | if(StringUtils.isNotBlank(param.getStartTime())){ |
| | | BASE_PARAMS.put("startTime", param.getStartTime()); |
| | | } |
| | | if(StringUtils.isNotBlank(param.getEndTime())){ |
| | | BASE_PARAMS.put("endTime", param.getEndTime()); |
| | | } |
| | | BASE_PARAMS.put("deviceCode", param.getDeviceCode()); |
| | | BASE_PARAMS.put("pageSize",Constants.equalsInteger(param.getPageSize(),0)? "100":param.getPageSize().toString());//页é¢å¤§å° |
| | | BASE_PARAMS.put("pageNo", Constants.equalsInteger(param.getPageNo(),0)? "1":param.getPageNo().toString());//å½å页 |
| | | String str = sendRequest(url,BASE_PARAMS); |
| | | TypeReference typeReference = |
| | | new TypeReference<BaseCarsResponse<BaseCarsPageResponse<CarsAlarmListResponse>>>(){}; |
| | | BaseCarsResponse<BaseCarsPageResponse<CarsAlarmListResponse>> result = JSONObject.parseObject(str, typeReference.getType()); |
| | | if(result!=null && Constants.equalsInteger(result.getStatus(),0)){ |
| | | return result.getData(); |
| | | } |
| | | return null; |
| | | } |
| | | } |
| | |
| | | } |
| | | |
| | | /** |
| | | *æ¶é²çæ¿-4温湿度ç»è®¡ |
| | | * @return |
| | | */ |
| | | public static BaseResponse<BaseListPageResponse<TemperatureHumidityDataResponse>> temperatureHumidityDataStatistic(TemperatureHumidityDataRequest param){ |
| | | log.info("ãæµ·åº·æ¶é²çæ¿-4温湿度ç»è®¡ã================å¼å§===="+JSONObject.toJSONString(param)); |
| | | try { |
| | | String res = HKTools.temperatureHumidityDataStatistic(JSONObject.toJSONString(param)); |
| | | TypeReference typeReference = |
| | | new TypeReference< BaseResponse<BaseListPageResponse<TemperatureHumidityDataResponse> >>(){}; |
| | | BaseResponse<BaseListPageResponse<TemperatureHumidityDataResponse>> result = JSONObject.parseObject(res, typeReference.getType()); |
| | | logResult(result,"海康æ¶é²çæ¿-4温湿度ç»è®¡"); |
| | | return result; |
| | | }catch (Exception e){ |
| | | log.error("ãæµ·åº·æ¶é²çæ¿-4温湿度ç»è®¡ã================失败====ï¼\n"+ e.getMessage()); |
| | | } |
| | | return null; |
| | | } |
| | | |
| | | |
| | | /** |
| | | *å页æ¥è¯¢æ¶é²è®¾å¤é¨ä»¶ç¶æ |
| | | * @return |
| | | */ |
| | |
| | | } |
| | | return null; |
| | | } |
| | | |
| | | /** |
| | | *æ ¹æ®ç¨æ·æ è¯è·å客æ·ç«¯TGCæ¥å£ |
| | | * @return |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model; |
| | | |
| | | import com.doumee.core.utils.Constants; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | |
| | | import java.util.List; |
| | | |
| | | public class TMSContants { |
| | | |
| | | public interface InterfacePath { |
| | | String[] getSevenArrivalStatus = new String[]{"/tms/zhyt/getSevenArrivalStatus", "ãTMSãè¿7æ¥å°è´§æ
åµ"};//TMSè¿7æ¥å°è´§æ
嵿¥å£å°å |
| | | String[] getCurrentTransportationTask = new String[]{ "ãTMSã/zhyt/getCurrentTransportationTask", "ãTMSãå½åè¿è¾ä»»å¡"};//TMSå½åè¿è¾ä»»å¡æ¥å£å°å |
| | | String[] getDistributionOfDeliveryLocations = new String[]{"/tms/zhyt/getDistributionOfDeliveryLocations", "ãTMSãå
¨å½å°è´§å°å叿¥è¯¢æ¥è¯¢"};//TMSå
¨å½å°è´§å°å叿¥è¯¢æ¥è¯¢æ¥å£å°å |
| | | String[] getRealTimeInventory = new String[]{"/tms/zhyt/getRealTimeInventory", "ãTMSã宿¶åºåæ¥è¯¢"};//TMS宿¶åºåæ¥è¯¢æ¥å£å°å |
| | | String[] getInboundOutbound = new String[]{"/tms/zhyt/getInboundOutbound", "ãTMSãåºå
¥åºè®°å½æ¥è¯¢"};//TMSåºå
¥åºè®°å½æ¥è¯¢æ¥å£å°å |
| | | String[] getIntransitDetails = new String[]{"/tms/zhyt/getIntransitDetails", "ãTMSãå¨éæç»å表"};//TMSå¨éæç»å表æ¥å£å°å |
| | | String[] getOrderList = new String[]{"/tms/zhyt/getIntransitDetails", "ãTMSãååå表æ¥è¯¢"};//TMSååå表æ¥è¯¢æ¥å£å°å |
| | | String[] getElecByContractNumberList = new String[]{"/tms/zhyt/getElecByContractNumberList", "ãTMSãååä¸éç¶æ"};//TMSååä¸éç¶ææ¥å£å°å |
| | | String[] getOrderDetailByContractNumber = new String[]{"/tms/zhyt/getOrderDetailByContractNumber", "ãTMSãåå详æ
"};//TMSåå详æ
æ¥å£å°å |
| | | String[] getGis = new String[]{"/tms/zhyt/getGis", "ãTMSãæ ¹æ®è¿è¾åå·æ¥è¯¢gis轨"};//TMSæ ¹æ®è¿è¾åå·æ¥è¯¢gis轨æ¥å£å°å |
| | | String[] getOrderStatusByContractNumber = new String[]{";//", "ãTMSãåçå½å¨æ"};//3.8订åçå½å¨æ |
| | | } |
| | | |
| | | public enum TopStatusLevel { |
| | | /** |
| | | * 订åçæ |
| | | * è¿åé
è½½ä¸ |
| | | * ä»åºåºåºä¸ |
| | | * 车è¾è¿è¾ä¸ |
| | | * å·²å°è´§ |
| | | * å·²å
¥åº |
| | | */ |
| | | ddsc(0,"订åçæ",new Integer[]{ChildStatusLevel.create.getKey()}), |
| | | ydpzz (1,"è¿åé
è½½ä¸",new Integer[]{ChildStatusLevel.ysdxc.getKey() |
| | | ,ChildStatusLevel.ysdcx.getKey() |
| | | ,ChildStatusLevel.shtg.getKey() |
| | | ,ChildStatusLevel.shwtg.getKey()}), |
| | | ckckz (2,"ä»åºåºåºä¸",new Integer[]{ChildStatusLevel.ddzhddzs.getKey() |
| | | ,ChildStatusLevel.sqzyzwc.getKey() |
| | | ,ChildStatusLevel.clqddzs.getKey()}), |
| | | clysz(3, "车è¾è¿è¾ä¸",new Integer[]{ChildStatusLevel.clqdapp.getKey()}), |
| | | ydh(4,"å·²å°è´§",new Integer[]{ChildStatusLevel.ddzhd.getKey()}), |
| | | yrk (5,"å·²å
¥åº",new Integer[]{ChildStatusLevel.ddxhd.getKey()}); |
| | | |
| | | // æååé |
| | | private int key; |
| | | private Integer[] chileIndexList ; |
| | | private String name; |
| | | |
| | | // æé æ¹æ³ |
| | | TopStatusLevel(int key, String name, Integer[] chileIndexList) { |
| | | this.key = key; |
| | | this.chileIndexList = chileIndexList; |
| | | this.name = name; |
| | | } |
| | | |
| | | public int getKey() { |
| | | return key; |
| | | } |
| | | |
| | | public void setKey(int key) { |
| | | this.key = key; |
| | | } |
| | | |
| | | public String getName() { |
| | | return name; |
| | | } |
| | | |
| | | public void setName(String name) { |
| | | this.name = name; |
| | | } |
| | | |
| | | public Integer[] getChileIndexList() { |
| | | return chileIndexList; |
| | | } |
| | | |
| | | public void setChileIndexList(Integer[] chileIndexList) { |
| | | this.chileIndexList = chileIndexList; |
| | | } |
| | | } |
| | | public interface StatusCode{ |
| | | /** |
| | | * 1-åè¿è¯ |
| | | * 2-çµåéæ±½è¿ |
| | | * 3-çµåééæ±½è¿ |
| | | * 4-GIS |
| | | * 5-APP |
| | | * 6-äººå·¥æ´æ° |
| | | */ |
| | | int zyz =1; |
| | | int dzsqy =2; |
| | | int dzsfqy =3; |
| | | int gis =4; |
| | | int app =5; |
| | | int rggx =6; |
| | | } |
| | | public enum ChildStatusLevel { |
| | | /** |
| | | 订åçæï¼åè´§ä»åºèç³»çµè¯ï¼0551-63451234ï¼ 0 订åçæï¼åè´§ä»åºèç³»çµè¯ï¼0551-63451234ï¼ |
| | | |
| | | è¿è¾åå½¢æ 1 è¿è¾åå½¢æ |
| | | è¿è¾åæ¤éï¼åå ï¼XXXï¼ -2 è¿è¾åæ¤éï¼åå ï¼XXXï¼ |
| | | è¿è¾åå®¡æ ¸æªéè¿ -1 è¿è¾åå®¡æ ¸æªéè¿ |
| | | è¿è¾åå®¡æ ¸éè¿ 2 è¿è¾åå®¡æ ¸éè¿ |
| | | è¿è¾å确认 è¿è¾å确认 |
| | | å°è¾¾è£
è´§å°-çµåéæ±½è¿ 3 车è¾å·²å°è¾¾è£
è´§å° |
| | | 车è¾å¯è¿-çµåéæ±½è¿ 4 车è¾è£
è´§å®æï¼çµåéå·²ä¸é |
| | | 车è¾å¯è¿-APP 4 车è¾è¿è¾ä¸ |
| | | å°è¾¾å¸è´§å°-APP 5 车è¾å·²å°è¾¾å¸è´§å° |
| | | å°è¾¾å¸è´§å°-çµåéæ±½è¿ 5 çµåé已解éï¼è¿è¾ä»»å¡å·²å®æ |
| | | */ |
| | | create(0,0, 0,"订åçæ",null), |
| | | ysdxc(1,1,1, "è¿è¾åå½¢æ",null), |
| | | ysdcx(2, -2,1,"è¿è¾åæ¤é",null ), |
| | | shtg(3,-1, 1,"è¿è¾åå®¡æ ¸æªéè¿",null ), |
| | | shwtg(4, 2,1,"è¿è¾åå®¡æ ¸éè¿",null), |
| | | sqzyzwc(5,6, 1,"ç³è¯·åè¿è¯å®æ","车è¾åè¿è¯ç³è¯·å®æ" ), |
| | | ddzhddzs(6,3,2,"å°è¾¾è£
è´§å°-çµåéæ±½è¿","车è¾å·²å°è¾¾è£
è´§å°" ), |
| | | clqddzs(7, 4,2,"车è¾å¯è¿-çµåéæ±½è¿","车è¾è£
è´§å®æï¼çµåéå·²ä¸é" ), |
| | | clqdapp(8, 7,3,"车è¾å¯è¿-APP","车è¾è¿è¾ä¸" ), |
| | | ddzhd(9, 8,4,"å°è¾¾å¸è´§å°-APP","车è¾å·²å°è¾¾å¸è´§å°" ), |
| | | ddxhd(10, 5,5,"å°è¾¾å¸è´§å°-çµåéæ±½è¿","çµåé已解éï¼è¿è¾ä»»å¡å·²å®æ" ), |
| | | ; |
| | | |
| | | // æååé |
| | | private Integer key; |
| | | private Integer orderStatus; |
| | | private Integer parentIndex; |
| | | private String name; |
| | | private String info; |
| | | |
| | | // æé æ¹æ³ |
| | | ChildStatusLevel(Integer key,Integer orderStatus,Integer parentIndex, String name,String info ) { |
| | | this.key = key; |
| | | this.info = info; |
| | | this.name = name; |
| | | this.orderStatus = orderStatus; |
| | | this.parentIndex = parentIndex; |
| | | } |
| | | public static Integer getParentIndexByStatus(int orderStatus) { |
| | | for (ChildStatusLevel c : ChildStatusLevel.values()) { |
| | | if (c.getOrderStatus() == orderStatus) { |
| | | return c.parentIndex; |
| | | } |
| | | } |
| | | return null; |
| | | } |
| | | public static String getInfo(int orderStatus,String defualt) { |
| | | for (ChildStatusLevel c : ChildStatusLevel.values()) { |
| | | if (c.getOrderStatus() == orderStatus) { |
| | | return StringUtils.defaultString(c.getInfo(),StringUtils.defaultString(defualt,c.getName())); |
| | | } |
| | | } |
| | | return null; |
| | | } |
| | | |
| | | public int getKey() { |
| | | return key; |
| | | } |
| | | |
| | | public void setKey(int key) { |
| | | this.key = key; |
| | | } |
| | | |
| | | public String getName() { |
| | | return name; |
| | | } |
| | | |
| | | public void setName(String name) { |
| | | this.name = name; |
| | | } |
| | | |
| | | public String getInfo() { |
| | | return info; |
| | | } |
| | | |
| | | public void setInfo(String info) { |
| | | this.info = info; |
| | | } |
| | | |
| | | public int getOrderStatus() { |
| | | return orderStatus; |
| | | } |
| | | |
| | | public void setOrderStatus(int orderStatus) { |
| | | this.orderStatus = orderStatus; |
| | | } |
| | | |
| | | public int getParentIndex() { |
| | | return parentIndex; |
| | | } |
| | | |
| | | public void setParentIndex(int parentIndex) { |
| | | this.parentIndex = parentIndex; |
| | | } |
| | | } |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.request; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import lombok.Data; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tmsååå·æ¥è¯¢è®¢åçå½å¨æè¯·æ±åæ°") |
| | | public class TmsCircleStatusListRequest { |
| | | |
| | | private String contractNumber ;//æ¯ ååå· |
| | | |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.request; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import lombok.Data; |
| | | |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tmsæ¥è¯¢GISéå请æ±åæ°") |
| | | public class TmsGisListRequest { |
| | | |
| | | private String transportCode;// å符串 è¿è¾åå· |
| | | |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.response; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import lombok.Data; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tmsæ ¹æ®ååå·æ¥è¯¢è®¢åçå½å¨æè¿ååæ°") |
| | | public class TmsCircleStatusListResponse { |
| | | /** |
| | | */ |
| | | |
| | | private String orderStatusDes ;//å符串 订åç¶ææè¿° |
| | | |
| | | private String recordDate ;//å符串 ç¶æè®°å½æ¶é´ |
| | | private Integer orderStatus;// å符串 订åç¶æç |
| | | private Integer type;// å符串 订åç¶æè®°å½ç±»å |
| | | private String canCelReason;// å符串 æ¤éåå |
| | | private String tel ;//å符串 å·ç |
| | | |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.response; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import lombok.Data; |
| | | |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tmsæ ¹æ®ååå·æ¥è¯¢è®¢åçå½å¨æè¿ååæ°") |
| | | public class TmsCircleStatusResultListResponse { |
| | | /** |
| | | */ |
| | | |
| | | private Integer key ;//å符串 ç¶æè®°å½æ¶é´ |
| | | private String name ;//å符串 订åç¶æç |
| | | private List<TmsCircleStatusListResponse> secondList ;//äºç´æ°æ®éå |
| | | |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.response; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import lombok.Data; |
| | | |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tmsæ¥è¯¢GISè¿ååæ°") |
| | | public class TmsGisListResponse { |
| | | /** |
| | | */ |
| | | |
| | | private List<TmsGisStartEndInfoResponse> startAndEndPoint;//éå èµ·ç¹ç»ç¹ä¿¡æ¯ |
| | | private List<TmsGisStatusInfoResponse> gisList ;//éå 订åç¶æç |
| | | |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.response; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import lombok.Data; |
| | | |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tmsæ¥è¯¢GIS èµ·ç¹ç»ç¹ä¿¡æ¯è¿ååæ°") |
| | | public class TmsGisStartEndInfoResponse { |
| | | /** |
| | | */ |
| | | |
| | | private String startRepertotyName;// å符串 èµ·ç¹åç§° |
| | | private String endRepertotyName;// å符串 ç»ç¹åç§° |
| | | private String startLon ;//å符串 èµ·ç¹ç»åº¦ |
| | | private String startLat;// å符串 èµ·ç¹çº¬åº¦ |
| | | private String endLon ;//å符串 ç»ç¹ç»åº¦ |
| | | private String endLat ;//å符串 ç»ç¹çº¬åº¦ |
| | | private String plateNumber;// å符串 车çå· |
| | | |
| | | private String id;//1698530035827830786, |
| | | private String transportCode;//18451, |
| | | private String startRepertotyCode;//02001, |
| | | private String endRepertotyCode;//1134030101, |
| | | private String volume;//70, |
| | | private String loadPercent;//0.5385, |
| | | private String stopNumbers;//0, |
| | | private String transportDate;//2023-09-04 10:54:52, |
| | | private String transportMethod;//4, |
| | | private String generateType;//1, |
| | | |
| | | } |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.core.tms.model.response; |
| | | |
| | | import io.swagger.annotations.ApiModel; |
| | | import lombok.Data; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | | */ |
| | | @Data |
| | | @ApiModel("tmsæ¥è¯¢GIS 订åç¶æç è¿ååæ°") |
| | | public class TmsGisStatusInfoResponse { |
| | | /** |
| | | */ |
| | | |
| | | private String startRepertotyName;// å符串 èµ·ç¹åç§° |
| | | private String endRepertotyName;// å符串 ç»ç¹åç§° |
| | | private String startLon ;//å符串 èµ·ç¹ç»åº¦ |
| | | private String startLat;// å符串 èµ·ç¹çº¬åº¦ |
| | | private String endLon ;//å符串 ç»ç¹ç»åº¦ |
| | | private String endLat ;//å符串 ç»ç¹çº¬åº¦ |
| | | private String plateNumber;// å符串 车çå· |
| | | |
| | | } |
| | |
| | | import io.swagger.annotations.ApiModel; |
| | | import lombok.Data; |
| | | |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2023/11/23 14:03 |
| | |
| | | @Data |
| | | @ApiModel("tmsåå详æ
è¿ååæ°") |
| | | public class TmsOrderInfoResponse { |
| | | /** |
| | | { |
| | | "code": 0, |
| | | "data": { |
| | | "contractNumber": "112718591", |
| | | "ncCreateDate": "2024-06-20 09:08:01", |
| | | "deliveryEnterprise": "èå æååº", |
| | | "receiveEnterprise": "宿å·å¸å·çé
éä¸å¿", |
| | | "transportCode": "39828", |
| | | "transportDate": "2024-06-20 09:04:46.0", |
| | | "driverName": "çä»å
°", |
| | | "driverTel": "19955211695", |
| | | "plateName": "çCC2585", |
| | | "orderStatus": "5", |
| | | "orderStatusDesc": "å°è¾¾å¸è´§å°-çµåéæ±½è¿" |
| | | }, |
| | | "message": "æä½æå" |
| | | } |
| | | */ |
| | | |
| | | |
| | | private String contractNumber ; //ååå· |
| | | private String deliveryEnterprise ; //åè´§å° |
| | | private String receiveEnterprise ; //å°è´§å° |
| | |
| | | private String driverTel; // |
| | | private String orderStatusDesc; // |
| | | private String plateName; //": "çCC2585", |
| | | |
| | | private String deliveryLon ; // åè´§ä»åºç»åº¦ |
| | | private String deliveryLat ; // åè´§ä»åºçº¬åº¦ |
| | | private String receiveLon ; // å¸è´§ä»åºç»åº¦ |
| | | private String receiveLat; // å¸è´§ä»åºçº¬åº¦ |
| | | private List<TmsGisListResponse> gisList; |
| | | private List<TmsCircleStatusResultListResponse> cicleStatusList; |
| | | } |
| | |
| | | paramMap.put("touser", openId); |
| | | paramMap.put("data", dataMap); |
| | | String response = HttpsUtil.postJson(postUrL, JSONObject.toJSONString(paramMap)); |
| | | log.warn("·==++--·æ¨é微信模æ¿ä¿¡æ¯è·³è½¬å°åï¼{}·--++==·", jumpUrl); |
| | | if(StringUtils.isBlank(response)){ |
| | | log.warn("·==++--·æ¨é微信模æ¿ä¿¡æ¯ï¼{}·--++==·", "失败"); |
| | | }else{ |
| | |
| | | |
| | | import com.baomidou.mybatisplus.core.mapper.BaseMapper; |
| | | import com.doumee.dao.business.model.PlatformBooks; |
| | | import com.github.yulichang.base.MPJBaseMapper; |
| | | |
| | | /** |
| | | * @author æ±è¹è¹ |
| | | * @date 2024/06/28 10:03 |
| | | */ |
| | | public interface PlatformBooksMapper extends BaseMapper<PlatformBooks> { |
| | | public interface PlatformBooksMapper extends MPJBaseMapper<PlatformBooks> { |
| | | |
| | | } |
| | |
| | | @ExcelColumn(name="被访人åå§å") |
| | | @TableField(exist = false) |
| | | private String receptMemberName; |
| | | |
| | | @ApiModelProperty(value = "被访人åçµè¯", example = "1") |
| | | @ExcelColumn(name="被访人åçµè¯") |
| | | @TableField(exist = false) |
| | | private String receptMemberMobile; |
| | | @ApiModelProperty(value = "è¢«è®¿äººåæµ·åº·ç¼ç ", example = "1") |
| | | @ExcelColumn(name="被访人åå§å") |
| | | @TableField(exist = false) |
| | |
| | | @ApiModelProperty(value = "æè®¿æ¶é´") |
| | | private String visitTime; |
| | | |
| | | @ApiModelProperty(value = "æ¾ç¤ºéç¥ç¶æ") |
| | | private String info; |
| | | |
| | | @ApiModelProperty(value = "é访人åä¿¡æ¯") |
| | | private List<Visits> withVisitsList; |
| | | |
| | |
| | | package com.doumee.dao.web.response.platformReport; |
| | | |
| | | import com.doumee.core.haikang.model.cars.response.CarsAlarmResultListResponse; |
| | | import com.doumee.core.haikang.model.cars.response.CarsDeviceDetaisResponse; |
| | | import io.swagger.annotations.ApiModelProperty; |
| | | import lombok.Data; |
| | |
| | | |
| | | @ApiModelProperty(value = "离线æ°é") |
| | | private int offlineNum; |
| | | |
| | | @ApiModelProperty(value = "æ¥è¦ä¿¡æ¯å表") |
| | | List<CarsAlarmResultListResponse> eventList; |
| | | |
| | | } |
| | |
| | | private Integer dangerDealedNum; |
| | | |
| | | |
| | | @ApiModelProperty(value = "æè®¾å¤åç±»ç»è®¡åµåµ" , hidden = true) |
| | | @ApiModelProperty(value = "æè®¾å¤åç±»ç»è®¡" , hidden = true) |
| | | private List<DeviceNumByTypeVO> deviceTypeList; |
| | | |
| | | |
| | |
| | | @ApiModelProperty(value = "è¿å
¥è½¦è¾ä½ä¸æ
åµ-已宿") |
| | | private int doneNum; |
| | | @ApiModelProperty(value = "4ä¸ªçæ§ç¹indexCodeéå") |
| | | private List<String> videoIndexCodes; |
| | | private String[] videoIndexCodes; |
| | | |
| | | @ApiModelProperty(value = "仿¥æå°å®æè®¢åç»è®¡" , hidden = true) |
| | | private List<PlatformGroupFinishVO> platformGroupFinishList; |
¶Ô±ÈÐÂÎļþ |
| | |
| | | package com.doumee.dao.web.response.platformReport; |
| | | |
| | | import com.doumee.core.haikang.model.param.respose.TemperatureHumidityDataResponse; |
| | | import io.swagger.annotations.ApiModelProperty; |
| | | import lombok.Data; |
| | | |
| | | import java.util.List; |
| | | |
| | | /** |
| | | * æ¶é²ç®¡æ§å¤§å± |
| | | * |
| | | * @Author : Rk |
| | | * @create 2024/10/25 13:53 |
| | | */ |
| | | @Data |
| | | public class TemperatureHumidityDataVO { |
| | | |
| | | @ApiModelProperty(value = "温度") |
| | | private TemperatureHumidityDataResponse temperatureData; |
| | | |
| | | |
| | | @ApiModelProperty(value = "湿度") |
| | | private TemperatureHumidityDataResponse humidityData; |
| | | |
| | | |
| | | } |
| | |
| | | @Autowired |
| | | private CarDriverMapper carDriverMapper; |
| | | |
| | | @Autowired |
| | | private VisitsMapper visitsMapper; |
| | | |
| | | @Autowired |
| | | private VisitsJoinMapper visitsJoinMapper; |
| | | private VisitsJoinMapper visitsMapper; |
| | | |
| | | @Autowired |
| | | private CarUseBookJoinMapper carUseBookJoinMapper; |
| | |
| | | if(Constants.equalsInteger(noticeType,Constants.noticesObjectType.visit) |
| | | || Constants.equalsInteger(noticeType,Constants.noticesObjectType.visitReporting)){ |
| | | //访客记å½ä¸è®¿å®¢æ¥å¤ |
| | | Visits visits = visitsJoinMapper.selectJoinOne(Visits.class, |
| | | Visits visits = visitsMapper.selectJoinOne(Visits.class, |
| | | new MPJLambdaWrapper<Visits>().selectAll(Visits.class) |
| | | .selectAs(Member::getName,Visits::getReceptMemberName) |
| | | .selectAs(Company::getName,Visits::getReceptMemberDepartment) |
| | |
| | | SmsConstants.visitContent.visitAuditFail, |
| | | approveDTO.getCheckInfo(),null |
| | | ); |
| | | if(Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)){ |
| | | SmsEmailServiceImpl.sendVisitSms(systemDictDataBiz, |
| | | emayService,smsEmailMapper,smsConfigMapper,visitsMapper,visits.getId(), |
| | | SmsConstants.visitContent.visitAuditSuccessToVisiter, |
| | | approveDTO.getCheckInfo(),null |
| | | ); |
| | | } |
| | | objCode = Constants.equalsInteger(approveDTO.getStatus(),Constants.TWO)? WxPlatConstants.visitContent.visitAuditSuccess: |
| | | WxPlatConstants.visitContent.visitAuditFail; |
| | | } |
| | |
| | | import com.doumee.dao.business.*; |
| | | import com.doumee.dao.business.dao.SmsConfigMapper; |
| | | import com.doumee.dao.business.dao.SmsEmailMapper; |
| | | import com.doumee.dao.business.join.VisitsJoinMapper; |
| | | import com.doumee.dao.business.model.*; |
| | | import com.doumee.dao.business.model.vo.ValidPhoneCodeVO; |
| | | import com.doumee.dao.system.model.SystemUser; |
| | | import com.doumee.service.business.SmsEmailService; |
| | | import com.doumee.service.business.third.EmayService; |
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | |
| | | * @param auditUser |
| | | */ |
| | | public static void sendVisitSms(SystemDictDataBiz systemDictDataBiz, EmayService emayService , com.doumee.dao.business.dao.SmsEmailMapper smsEmailMapper , SmsConfigMapper smsConfigMapper, |
| | | VisitsMapper visitsMapper, Integer objId, String objCode, String msg, List<String> auditUser){ |
| | | VisitsJoinMapper visitsMapper, Integer objId, String objCode, String msg, List<String> auditUser){ |
| | | try{ |
| | | SmsConfig smsConfig = smsConfigMapper.selectOne(new QueryWrapper<SmsConfig>().lambda().eq(SmsConfig::getCode, |
| | | objCode).last(" limit 1 ")); |
| | | //å¼å¯çä¿¡éç¥ |
| | | if(Objects.nonNull(smsConfig) || Constants.equalsInteger(smsConfig.getStatus(),Constants.ZERO)){ |
| | | String content = systemDictDataBiz.queryByCode(Constants.SMS,Constants.SMS_COMNAME).getCode() + smsConfig.getContent(); |
| | | Visits visits = visitsMapper.selectById(objId); |
| | | Visits visits = visitsMapper.selectJoinOne(Visits.class,new MPJLambdaWrapper<Visits>().selectAll(Visits.class) |
| | | .selectAs(SystemUser::getMobile,Visits::getReceptMemberMobile) |
| | | .leftJoin(SystemUser.class,SystemUser::getMemberId, Visits::getReceptMemberId) |
| | | .eq(Visits::getId,objId).last(" limit 1 ")); |
| | | if(Objects.nonNull(visits)){ |
| | | if(objCode.equals(SmsConstants.visitContent.visitAuditSuccess)){ |
| | | //æ¨çã访客ç³è¯·ãå·²ç»å®¡æ¹éè¿ï¼è¯·äº{é¢çº¦å
¥åå¼å§æ¶é´}åå¾é¨å«å®¤è®¿å®¢æºç¾å°å
¥åï¼å¦æçé®ï¼è¯·è系被访人 |
| | | //æ¨ç[访客ç³è¯·]å·²ç»å®¡æ¹éè¿ï¼è¯·éç¥è®¿å®¢äº{é¢çº¦å
¥åå¼å§æ¶é´}å
¥åï¼å¦æçé®ï¼è¯·è系被访人ã |
| | | content = content.replace("{é¢çº¦å
¥åå¼å§æ¶é´}",DateUtil.getFomartDate(visits.getStarttime(),"yyyy-MM-dd HH:mm")); |
| | | sendBusinessSms(emayService,smsEmailMapper, |
| | | Arrays.asList(visits.getPhone().split(",")),SmsConstants.visit,content,visits.getId()); |
| | |
| | | content = content.replace("{æªç¾ç¦»æ°é}",msg); |
| | | sendBusinessSms(emayService,smsEmailMapper, |
| | | Arrays.asList(visits.getPhone().split(",")),SmsConstants.visit,content,visits.getId()); |
| | | }else if(objCode.equals(SmsConstants.visitContent.visitAuditSuccessToVisiter)) { |
| | | content = content.replace("{é¢çº¦å
¥åå¼å§æ¶é´}",DateUtil.getFomartDate(visits.getStarttime(),"yyyy-MM-dd HH:mm")); |
| | | sendBusinessSms(emayService,smsEmailMapper, |
| | | Arrays.asList(visits.getReceptMemberMobile().split(",")),SmsConstants.visit,content,visits.getId()); |
| | | }else{ |
| | | //æ¨æä¸æ¡ã车è¾å
¥åç³è¯·ãéè¦å¤çï¼è¯¦ç»ä¿¡æ¯è¯·åå¾å¾®ä¿¡å
¬ä¼å·æ¥çã |
| | | sendBusinessSms(emayService,smsEmailMapper, |
| | |
| | | * @param auditUser |
| | | */ |
| | | public static void sendVisitReportSms(SystemDictDataBiz systemDictDataBiz, EmayService emayService , com.doumee.dao.business.dao.SmsEmailMapper smsEmailMapper , SmsConfigMapper smsConfigMapper, |
| | | VisitsMapper visitsMapper, Integer objId, String objCode, String msg, List<String> auditUser){ |
| | | VisitsJoinMapper visitsMapper, Integer objId, String objCode, String msg, List<String> auditUser){ |
| | | try{ |
| | | SmsConfig smsConfig = smsConfigMapper.selectOne(new QueryWrapper<SmsConfig>().lambda().eq(SmsConfig::getCode, |
| | | objCode).last(" limit 1 ")); |
| | |
| | | @Autowired |
| | | private RetentionMapper retentionMapper; |
| | | @Autowired |
| | | private VisitsMapper visitsMapper; |
| | | private VisitsJoinMapper visitsMapper; |
| | | @Autowired |
| | | private ApproveMapper approveMapper; |
| | | @Autowired |
| | |
| | | memberId) |
| | | ); |
| | | // } |
| | | |
| | | Notices notices = noticesJoinMapper.selectOne(new QueryWrapper<Notices>().lambda().eq(Notices::getObjId,visits.getId()) |
| | | .eq(Notices::getType,Constants.equalsInteger(visits.getType(),Constants.TWO)?Constants.noticesObjectType.visitReporting:Constants.noticesObjectType.visit) |
| | | .eq(Notices::getUserId,memberId) |
| | | .eq(Notices::getSendacopy,Constants.ZERO) |
| | | .last(" limit 1 ") |
| | | ); |
| | | if(Objects.nonNull(notices)){ |
| | | notices.setInfo(notices.getInfo()); |
| | | }else{ |
| | | notices.setInfo("ææ "); |
| | | } |
| | | return visitDetailVO; |
| | | } |
| | | |
| | |
| | | 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.cars.response.CarsAlarmResultListResponse; |
| | | import com.doumee.core.haikang.model.cars.response.CarsDeviceDetaisResponse; |
| | | import com.doumee.core.haikang.model.param.BaseListPageRequest; |
| | | import com.doumee.core.haikang.model.param.BaseListPageResponse; |
| | |
| | | import com.doumee.service.business.impl.VisitsServiceImpl; |
| | | import com.doumee.service.business.third.BoardService; |
| | | import com.doumee.service.business.third.WmsService; |
| | | import com.github.xiaoymin.knife4j.core.util.CollectionUtils; |
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.StringUtils; |
| | |
| | | @Autowired |
| | | private PlatformJobMapper platformJobMapper; |
| | | @Autowired |
| | | private PlatformBooksMapper platformBooksMapper; |
| | | @Autowired |
| | | private PlatformWmsDetailMapper platformWmsDetailMapper; |
| | | @Autowired |
| | | private PlatformWmsJobMapper platformWmsJobMapper; |
| | |
| | | * @return |
| | | */ |
| | | @Override |
| | | public List<GeneralVO> todayTotalInList(){ |
| | | /** |
| | | * 1å¸å
¬å¸ï¼æ ¹æ®é¢çº¦çå
¥ååå 为å¸å
¬å¸å¸è´§çä»»å¡ä¸ºå¸å
¬å¸å
¥åºçç»è®¡ï¼ |
| | | * 2鿣ä¸å¿ï¼WMSæ¨éçå
¥åºåæ®ï¼ |
| | | * 3å å·¥å
¥åºï¼é¢çº¦å
¥å为éåºå å·¥å
¥åºçï¼ä½ä¸æå°ä¸ºå®æ³°ç©æµå¸è´§æå°ï¼ï¼ |
| | | */ |
| | | String[] names = new String[]{"å¸å
¬å¸","鿣ä¸å¿","å å·¥å
¥åº"}; |
| | | String reason =systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.CITY_XH_REASON_ID).getCode(); |
| | | String platformGroupId =systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.ATWL_XH_PLATFORM_ID).getCode();; |
| | | List<GeneralVO> list = new ArrayList<>(); |
| | | for (int i = 0; i < 3; i++) { |
| | | Random random = new Random(); |
| | | GeneralVO data = new GeneralVO(); |
| | | data.setName(names[i]); |
| | | BigDecimal num =new BigDecimal(0); |
| | | if(i == 0){ |
| | | List<PlatformBooks> jobs = platformBooksMapper.selectJoinList(PlatformBooks.class, new MPJLambdaWrapper<PlatformBooks>() |
| | | .select(PlatformJob::getTotalNum) |
| | | .leftJoin(PlatformJob.class,PlatformJob::getId,PlatformBooks::getJobId) |
| | | .eq(PlatformBooks::getIsdeleted,Constants.ZERO) |
| | | .eq(PlatformBooks::getReasonId,reason) |
| | | .apply("to_days(t1.done_date) = to_days(now())") |
| | | .eq(PlatformBooks::getStatus,Constants.TWO)); |
| | | if(jobs!=null){ |
| | | for(PlatformBooks j :jobs){ |
| | | num =num.add(Constants.formatBigdecimal(j.getTotalNum())); |
| | | } |
| | | } |
| | | }else if(i ==1){ |
| | | List<PlatformJob> jobs = platformJobMapper.selectList (new MPJLambdaWrapper<PlatformJob>() |
| | | .select(PlatformJob::getTotalNum) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .eq(PlatformJob::getOrigin,Constants.ONE) |
| | | .in(PlatformJob::getStatus, Constants.PlatformJobStatus.DONE.getKey() |
| | | , Constants.PlatformJobStatus.AUTHED_LEAVE.getKey() |
| | | , Constants.PlatformJobStatus.LEAVED.getKey()) |
| | | .apply("to_days(done_date) = to_days(now())") ); |
| | | if(jobs!=null){ |
| | | for(PlatformJob j :jobs){ |
| | | num =num.add(Constants.formatBigdecimal(j.getTotalNum())); |
| | | } |
| | | } |
| | | }else{ |
| | | List<PlatformJob> jobs = platformJobMapper.selectList (new MPJLambdaWrapper<PlatformJob>() |
| | | .select(PlatformJob::getTotalNum) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .eq(PlatformJob::getPlatformGroupId,platformGroupId) |
| | | .apply("to_days(done_date) = to_days(now())") |
| | | .in(PlatformJob::getStatus, Constants.PlatformJobStatus.DONE.getKey() |
| | | , Constants.PlatformJobStatus.AUTHED_LEAVE.getKey() |
| | | , Constants.PlatformJobStatus.LEAVED.getKey()) ); |
| | | if(jobs!=null){ |
| | | for(PlatformJob j :jobs){ |
| | | num = num.add(Constants.formatBigdecimal(j.getTotalNum())); |
| | | } |
| | | } |
| | | } |
| | | data.setNum(num); |
| | | list.add(data); |
| | | } |
| | | return list; |
| | | |
| | | } |
| | | /** |
| | | * è·ååºåæ å½¢ç»ææ°æ® |
| | | * @return |
| | | */ |
| | | @Override |
| | | public BoardStockListVO stockList( ){ |
| | | BoardStockListVO data = new BoardStockListVO(); |
| | | double toatalNum = 1d; |
| | |
| | | |
| | | } |
| | | WmsBaseResponse<WmsInventoryDataResponse> response = wmsService.getInventoryList(); |
| | | if(response!=null && response.getData()!=null && response.getData().size()>=0){ |
| | | if(response!=null && response.getData()!=null && response.getData().size()>0){ |
| | | List<WmsInventoryJsonResponse> t= response.getData().get(0).getJson(); |
| | | if(t!=null &&t.size()>0){ |
| | | for(WmsInventoryJsonResponse j :t){ |
| | |
| | | public CarWorkSituationVO carWorkSituation(int limit){ |
| | | CarWorkSituationVO carWorkSituationVO = new CarWorkSituationVO(); |
| | | List<PlatformLog> platformLogList = platformLogMapper.selectList(new QueryWrapper<PlatformLog>().lambda() |
| | | .like(PlatformLog::getCreateDate,DateUtil.getCurrDate()) |
| | | .orderByDesc(PlatformLog::getCreateDate) |
| | | .last(" limit "+limit) |
| | | ); |
| | |
| | | public BoardCarsListVO platformJobCarsList(){ |
| | | BoardCarsListVO data = new BoardCarsListVO(); |
| | | List<CarsDeviceDetaisResponse> detaisResponses = HKCarOpenService.getAllCarsDetais(); |
| | | data.setCarsList(detaisResponses); |
| | | data.setCarsList(detaisResponses); |
| | | if(data.getCarsList()!=null && data.getCarsList().size()>0){ |
| | | List<String> codes = new ArrayList<>(); |
| | | //设å¤ç¶æ 0ï¼ç¦»çº¿ï¼1ï¼å¨çº¿ï¼2ï¼ä¼ç |
| | | int online = 0; |
| | | for(CarsDeviceDetaisResponse model:detaisResponses){ |
| | | if(Constants.equalsInteger(model.getStatus(),Constants.ONE) ||Constants.equalsInteger(model.getStatus(),Constants.TWO)){ |
| | | //妿æ¯å¨çº¿æè
ä¼ç ï¼æ¥è¯¢å¨éè¿æ¯ç©ºé² |
| | | if(Constants.equalsInteger(model.getStatus(),Constants.ONE) |
| | | ||Constants.equalsInteger(model.getStatus(),Constants.TWO)){ |
| | | //妿æ¯å¨çº¿æè
ä¼ç ï¼æ¥è¯¢å¨éè¿æ¯ç©ºé²ty |
| | | codes.add(model.getPlateNum()); |
| | | model.setJobStatus(Constants.ZERO); |
| | | }else |
| | | model.setJobStatus(Constants.TWO); |
| | | data.setOfflineNum(data.getOfflineNum()+1); |
| | | } |
| | | if(codes.size()>0){ |
| | | //ç¶æ 0å¾
确认 1å¾
ç¾å° 2çå¾
å«å· 3å
¥åçå¾
4å·²å«å· 5ä½ä¸ä¸ 6ä½ä¸å®æ 7è½¬ç§»ä¸ 8å¼å¸¸æèµ· 9å·²ææç¦»å 10已离å 11 å·²è¿å· 12åæ¶ï¼WMSï¼ |
| | | long busyNum = platformJobMapper.selectCount(new QueryWrapper<PlatformJob>().lambda() |
| | | List<PlatformJob> busyNum = platformJobMapper.selectList(new QueryWrapper<PlatformJob>() .lambda() |
| | | .select(PlatformJob::getCarCodeFront) |
| | | .eq(PlatformJob::getIsdeleted,Constants.ZERO) |
| | | .in(PlatformJob::getCarCodeFront,codes) |
| | | .in(PlatformJob::getStatus,Constants.PlatformJobStatus.WORKING.getKey() |
| | |
| | | ,Constants.PlatformJobStatus.WAIT_CONFIRM.getKey() |
| | | ,Constants.PlatformJobStatus.EXCEPTION.getKey()) |
| | | .groupBy(PlatformJob::getCarCodeFront)); |
| | | data.setBusyNum((int)busyNum);//å¨éæä»»å¡æ°é |
| | | data.setBusyNum( busyNum!=null ?busyNum.size():0);//å¨éæä»»å¡æ°é |
| | | data.setIdleNum(codes.size() -data.getBusyNum());//æ ä»»å¡ç©ºé²æ°é |
| | | data.setEventList(HKCarOpenService.getAlarmEvemtList(detaisResponses,new Date())); |
| | | if(busyNum != null){ |
| | | FLAG: for(CarsDeviceDetaisResponse model:detaisResponses){ |
| | | for(PlatformJob job : busyNum){ |
| | | if(StringUtils.equals(job.getCarCodeFront(),model.getPlateNum())){ |
| | | model.setJobStatus(Constants.ONE); |
| | | continue FLAG; |
| | | } |
| | | } |
| | | } |
| | | |
| | | } |
| | | } |
| | | } |
| | | |
| | |
| | | alarmDataVO.setErrNum(Constants.formatIntegerNum(response.getData().getMisReportAlarmNum())); |
| | | alarmDataVO.setLiftNum(Constants.formatIntegerNum(response.getData().getHandledAlarmNum())); |
| | | alarmDataVO.setProcessingNum(Constants.formatIntegerNum(response.getData().getUnHandedAlarmNum())); |
| | | alarmDataVO.setStartDate(start); |
| | | alarmDataVO.setEndDate(end); |
| | | }else{ |
| | | alarmDataVO.setTotalNum(Constants.ZERO); |
| | | alarmDataVO.setRealNum(Constants.ZERO); |
| | | alarmDataVO.setErrNum(Constants.ZERO); |
| | | alarmDataVO.setLiftNum(Constants.ZERO); |
| | | alarmDataVO.setProcessingNum(Constants.ZERO); |
| | | alarmDataVO.setStartDate(start); |
| | | alarmDataVO.setEndDate(end); |
| | | } |
| | |
| | | data.setDangerDealedNum(totalNum !=null?totalNum.intValue():0);//仿¥å¤ç鿣æ°é |
| | | return data; |
| | | } |
| | | |
| | | |
| | | /** |
| | | * æ¶é² æ¸©æ¹¿åº¦æ°æ® |
| | | */ |
| | | @Override |
| | | public List<TemperatureHumidityDataVO> getTemperatureHumidityData(){ |
| | | TemperatureHumidityDataRequest request = new TemperatureHumidityDataRequest(); |
| | | List<TemperatureHumidityDataVO> temperatureHumidityDataVOList = new ArrayList<>(); |
| | | request.setPageNo(1); |
| | | request.setPageSize(100); |
| | | request.setParentIndexCode(systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.TEMPERATURE_HUMIDITY).getCode()); |
| | | BaseResponse<BaseListPageResponse<TemperatureHumidityDataResponse>> response = HKService.temperatureHumidityDataStatistic(request); |
| | | if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null ){ |
| | | List<TemperatureHumidityDataResponse> temperatureHumidityDataResponseList = response.getData().getList(); |
| | | |
| | | if(CollectionUtils.isNotEmpty(temperatureHumidityDataResponseList)){ |
| | | Set<String> parentIndexCode = new HashSet<String>(temperatureHumidityDataResponseList.stream().map( |
| | | i->i.getIndexCode().replace("@0","").replace("@1","") |
| | | ).collect(Collectors.toList())); |
| | | for (String code:parentIndexCode) { |
| | | List<TemperatureHumidityDataResponse> dateList = |
| | | temperatureHumidityDataResponseList.stream().filter(i->i.getIndexCode().indexOf(code)>=Constants.ZERO).collect(Collectors.toList()); |
| | | TemperatureHumidityDataVO temperatureHumidityDataVO = new TemperatureHumidityDataVO(); |
| | | for (TemperatureHumidityDataResponse data:dateList) { |
| | | if(data.getSensorType().equals("temp")){ |
| | | temperatureHumidityDataVO.setTemperatureData(data); |
| | | }else{ |
| | | temperatureHumidityDataVO.setHumidityData(data); |
| | | } |
| | | } |
| | | temperatureHumidityDataVOList.add(temperatureHumidityDataVO); |
| | | } |
| | | } |
| | | } |
| | | return temperatureHumidityDataVOList; |
| | | } |
| | | |
| | | |
| | | |
| | | /** |
| | | * ç¨çµæ»è½è忝ãç¯æ¯ååºåç¨çµééå |
| | | * @return |
| | |
| | | 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))))); |
| | | .add(carbonWater.multiply(new BigDecimal(0.91)))).divide(new BigDecimal(1000),2,BigDecimal.ROUND_HALF_UP)); |
| | | return data; |
| | | |
| | | } |
| | |
| | | param.setPeriodType("day"); |
| | | BigDecimal total = new BigDecimal(0); |
| | | BaseResponse<EnergyTrendResponse> response = HKService.energyTrend(param); |
| | | if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) && response.getData()!=null&& response.getData().getYvalues()!=null ){ |
| | | if(response != null && StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE) |
| | | && response.getData()!=null&& response.getData().getYvalues()!=null ){ |
| | | for (int i = 0; i < response.getData().getYvalues().get(0).getValue().length; i++) { |
| | | total = total.add(new BigDecimal(StringUtils.defaultString( response.getData().getYvalues().get(0).getValue()[i],"0"))); |
| | | } |
| | |
| | | data.setRingPercent("0"); |
| | | data.setSecondRegionDataList(new ArrayList<>()); |
| | | } |
| | | return data; |
| | | if(data.getSecondRegionDataList()!=null && data.getSecondRegionDataList().size()>1){ |
| | | int index =-1; |
| | | for (int i = 0; i <data.getSecondRegionDataList().size() ; i++) { |
| | | RegionTopPowerResponse t=data.getSecondRegionDataList().get(i); |
| | | if(Constants.formatBigdecimal(t.getPercent()).compareTo(new BigDecimal(1)) == 0){ |
| | | index =i; |
| | | break; |
| | | } |
| | | } |
| | | if(index>-1){ |
| | | data.getSecondRegionDataList().remove(index);//å 餿 ¹èç¹æ°æ® |
| | | } |
| | | } |
| | | |
| | | return data; |
| | | } |
| | | /** |
| | | * è¿12ä¸ªæ°´çµæ°æ²¹èæ°æ®ç»è®¡ |
| | |
| | | VisitDataVO result = new VisitDataVO(); |
| | | result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>() |
| | | .eq(Visits::getIsdeleted,Constants.ZERO) |
| | | .apply("to_days(create_date)=to_days(now()") |
| | | .apply("to_days(create_date)=to_days(now())") |
| | | .in(Visits::getStatus,Constants.VisitStatus.pass,Constants.VisitStatus.xfSuccess )));//å¾
è®¿é® |
| | | result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>() |
| | | .eq(Visits::getIsdeleted,Constants.ZERO) |
| | | .apply("to_days(create_date)=to_days(now()") |
| | | .apply("to_days(create_date)=to_days(now())") |
| | | .in(Visits::getStatus,Constants.VisitStatus.signout,Constants.VisitStatus.signin )));//å·²ç»è®° |
| | | result.setWaitVisitNum(visitsJoinMapper.selectCount(new MPJLambdaWrapper<Visits>() |
| | | .eq(Visits::getIsdeleted,Constants.ZERO) |
| | | .apply("to_days(create_date)=to_days(now()") |
| | | .apply("to_days(create_date)=to_days(now())") |
| | | .in(Visits::getStatus,Constants.VisitStatus.signout )));//å·²ç¾ç¦» |
| | | /*PageWrap<Visits> pageWrap = new PageWrap<>(); |
| | | pageWrap.setCapacity(10); |
| | |
| | | .selectAll( PlatformJob.class) |
| | | .select("( select pl.CREATE_DATE from platform_log pl where t.id = pl.obj_id and pl.OBJ_TYPE = "+Constants.PlatformJobLogType.WORKING.getKey()+" order by pl.CREATE_DATE desc limit 1 ) as newStartDate") |
| | | //.select(" ( select sum(ifnull(pl.IO_QTY , 0 )) from platform_wms_detail pl where pl.job_id = t.id and pl.isdeleted=0 )",PlatformJob::getWorkNum) |
| | | .select(" ( case when t.total_num is null then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = t.id ) else a.total_num end )",PlatformJob::getWorkNum) |
| | | .select(" ( case when t.total_num is null then ( select sum(pwd.IO_QTY) from platform_wms_detail pwd where pwd.JOB_ID = t.id ) else t.total_num end )",PlatformJob::getWorkNum) |
| | | .apply("to_days(t.create_date) = to_days(now())") |
| | | .eq(Platform::getIsdeleted, Constants.ZERO) |
| | | .in(PlatformJob ::getStatus,new Integer[]{Constants.PlatformJobStatus.WORKING.getKey(),Constants.PlatformJobStatus.CALLED.getKey() }) |
| | |
| | | } |
| | | |
| | | } |
| | | |
| | | data.setVideoPluginUrl(getVideoUrl()); |
| | | String indexCodes = systemDictDataBiz.queryByCode(Constants.HK_PARAM,Constants.HK_CHANGNEI_SCREEN_INDEXCODES).getCode(); |
| | | if(StringUtils.isNotBlank(indexCodes)){ |
| | | data.setVideoIndexCodes(indexCodes.split(",")); |
| | | } |
| | | } |
| | | |
| | | return data; |
| | |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.doumee.biz.system.SystemDictDataBiz; |
| | | import com.doumee.core.tms.model.request.TmsLockStatusQueryRequest; |
| | | import com.doumee.core.tms.model.request.TmsOrderInfoRequest; |
| | | import com.doumee.core.tms.model.request.TmsOrderListRequest; |
| | | import com.doumee.core.tms.model.response.TmsBaseResponse; |
| | | import com.doumee.core.tms.model.response.TmsLockStatusQueryResponse; |
| | | import com.doumee.core.tms.model.response.TmsOrderInfoResponse; |
| | | import com.doumee.core.tms.model.response.TmsOrderListResponse; |
| | | import com.doumee.core.tms.model.TMSContants; |
| | | import com.doumee.core.tms.model.request.*; |
| | | import com.doumee.core.tms.model.response.*; |
| | | import com.doumee.core.utils.Constants; |
| | | import com.doumee.core.utils.HttpsUtil; |
| | | import com.doumee.core.wms.model.request.*; |
| | |
| | | import com.doumee.service.business.third.TmsService; |
| | | import com.doumee.service.business.third.WmsService; |
| | | import com.github.yulichang.wrapper.MPJLambdaWrapper; |
| | | import io.swagger.models.auth.In; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | @Override |
| | | public TmsBaseResponse<List<TmsLockStatusQueryResponse>> lockStatusQuery(TmsLockStatusQueryRequest param){ |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_LOCK_STATUS_URL).getCode(); |
| | | + TMSContants.InterfacePath.getElecByContractNumberList[0]; |
| | | |
| | | TmsBaseResponse<List<TmsLockStatusQueryResponse>> response = sendHttpRequest(url,"ãTMSãçµåéä¸éæ¶é´æ¥å£",JSONObject.toJSONString(param) |
| | | TmsBaseResponse<List<TmsLockStatusQueryResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getElecByContractNumberList[1],JSONObject.toJSONString(param) |
| | | ,new TypeReference< TmsBaseResponse<List<TmsLockStatusQueryResponse>>>(){}); |
| | | return response; |
| | | } |
| | | |
| | | /** |
| | | * è¿è¾ågis轨迹 |
| | | * æ ¹æ®åºåIDéå+ç鿡件ï¼ååå·ãå¶åå¼å§æ¥æãå¶åç»ææ¥æãåè´§å°ãå°è´§å°ãç份ï¼ééè¦ï¼ï¼è¿åååå表信æ¯ï¼æç
§æ¶é´ååºå±ç¤ºï¼ |
| | | * @param param åæ° |
| | | * @return TmsBaseResponse |
| | | */ |
| | | @Override |
| | | public List<TmsGisListResponse> gisList(TmsGisListRequest param){ |
| | | |
| | | if(param.getTransportCode()==null ){ |
| | | return new ArrayList<>(); |
| | | } |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +TMSContants.InterfacePath.getGis[0]; |
| | | TmsBaseResponse<List<TmsGisListResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getGis[1],JSONObject.toJSONString(param) |
| | | ,new TypeReference< TmsBaseResponse<List<TmsGisListResponse>>>(){}); |
| | | if(response ==null){ |
| | | return new ArrayList<>(); |
| | | }else{ |
| | | return response.getData()==null?new ArrayList<>():response.getData(); |
| | | } |
| | | } |
| | | /** |
| | | * 订åçå½å¨æ |
| | | * @param param åæ° |
| | | * @return TmsBaseResponse |
| | | */ |
| | | @Override |
| | | public List<TmsCircleStatusResultListResponse> getCicleStatusList(TmsCircleStatusListRequest param){ |
| | | List<TmsCircleStatusResultListResponse> list =new ArrayList<>(); |
| | | if(param.getContractNumber()==null ){ |
| | | return new ArrayList<>(); |
| | | } |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +TMSContants.InterfacePath.getOrderStatusByContractNumber[0]; |
| | | TmsBaseResponse<List<TmsCircleStatusListResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getOrderStatusByContractNumber[1],JSONObject.toJSONString(param) |
| | | ,new TypeReference< TmsBaseResponse<List<TmsCircleStatusListResponse>>>(){}); |
| | | |
| | | if(response ==null){ |
| | | return new ArrayList<>(); |
| | | }else{ |
| | | /** |
| | | * ddsc(0,"订åçæ",new Integer[]{ChildStatusLevel.create.getKey()}), |
| | | * ydpzz (1,"è¿åé
è½½ä¸",new Integer[]{ChildStatusLevel.ysdxc.getKey() |
| | | * ,ChildStatusLevel.ysdcx.getKey() |
| | | * ,ChildStatusLevel.shtg.getKey() |
| | | * ,ChildStatusLevel.shwtg.getKey() |
| | | * ,ChildStatusLevel.ysdcx.getKey()}), |
| | | * ckckz (2,"ä»åºåºåºä¸",new Integer[]{ChildStatusLevel.ddzhddzs.getKey() |
| | | * ,ChildStatusLevel.clqddzs.getKey()}), |
| | | * clysz(3, "车è¾è¿è¾ä¸",new Integer[]{ChildStatusLevel.clqdapp.getKey()}), |
| | | * ydh(4,"å·²å°è´§",new Integer[]{ChildStatusLevel.ddzhd.getKey()}), |
| | | * yrk |
| | | */ |
| | | for (int i = 0; i < 6; i++) { |
| | | TmsCircleStatusResultListResponse t = new TmsCircleStatusResultListResponse(); |
| | | TMSContants.TopStatusLevel tem = TMSContants.TopStatusLevel.ddsc; |
| | | if(i == 0){ |
| | | tem=TMSContants.TopStatusLevel.yrk; |
| | | } if(i == 1){ |
| | | tem=TMSContants.TopStatusLevel.ydh; |
| | | } if(i == 2){ |
| | | tem=TMSContants.TopStatusLevel.clysz; |
| | | } if(i == 4){ |
| | | tem=TMSContants.TopStatusLevel.ckckz; |
| | | } if(i == 3){ |
| | | tem=TMSContants.TopStatusLevel.ydpzz; |
| | | } if(i == 5){ |
| | | tem=TMSContants.TopStatusLevel.ddsc; |
| | | } |
| | | t.setName(tem.getName()); |
| | | t.setKey(tem.getKey()); |
| | | t.setSecondList(getSecondCircleStatusList(tem,response.getData())); |
| | | if(t.getSecondList()!=null & t.getSecondList().size()>0){ |
| | | list.add(t); |
| | | } |
| | | } |
| | | } |
| | | |
| | | return list; |
| | | } |
| | | |
| | | private List<TmsCircleStatusListResponse> getSecondCircleStatusList(TMSContants.TopStatusLevel tem, List<TmsCircleStatusListResponse> data) { |
| | | if(data ==null ||data.size()==0){ |
| | | return new ArrayList<>(); |
| | | } |
| | | List<TmsCircleStatusListResponse> list = new ArrayList<>(); |
| | | Integer[] statusList = tem.getChileIndexList(); |
| | | if(statusList!=null){ |
| | | for(Integer t :statusList){ |
| | | for(TmsCircleStatusListResponse status :data){ |
| | | if(Constants.equalsInteger(status.getOrderStatus(),Constants.FOUR) |
| | | && Constants.equalsInteger(status.getType(),TMSContants.StatusCode.app)) { |
| | | status.setOrderStatus(TMSContants.ChildStatusLevel.clqdapp.getKey()); |
| | | } |
| | | if(Constants.equalsInteger(status.getOrderStatus(),Constants.FIVE) |
| | | && Constants.equalsInteger(status.getType(),TMSContants.StatusCode.app)) { |
| | | status.setOrderStatus(TMSContants.ChildStatusLevel.ddzhd.getKey()); |
| | | } |
| | | if(Constants.equalsInteger(status.getOrderStatus(),t )){ |
| | | status.setOrderStatusDes(TMSContants.ChildStatusLevel.getInfo(status.getOrderStatus(),null)); |
| | | list.add(status); |
| | | } |
| | | } |
| | | } |
| | | } |
| | | return list; |
| | | } |
| | | |
| | | /** |
| | |
| | | param.setContractNumbers(null); |
| | | } |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_ORDER_LIST_URL).getCode(); |
| | | TmsBaseResponse<List<TmsOrderListResponse>> response = sendHttpRequest(url,"ãTMSãååå表æ¥å£",JSONObject.toJSONString(param) |
| | | +TMSContants.InterfacePath.getOrderList[0]; |
| | | TmsBaseResponse<List<TmsOrderListResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getOrderList[1],JSONObject.toJSONString(param) |
| | | ,new TypeReference< TmsBaseResponse<List<TmsOrderListResponse>>>(){}); |
| | | if(response ==null){ |
| | | return new ArrayList<>(); |
| | |
| | | */ |
| | | @Override |
| | | public TmsOrderInfoResponse orderInfo(TmsOrderInfoRequest param){ |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_ORDER_DETAIL_URL).getCode(); |
| | | TmsBaseResponse<TmsOrderInfoResponse> response = sendHttpRequest(url,"ãTMSãåå详æ
æ¥å£",JSONObject.toJSONString(param) |
| | | ,new TypeReference< TmsBaseResponse<TmsOrderInfoResponse>>(){}); |
| | | if(response ==null){ |
| | | return new TmsOrderInfoResponse(); |
| | | }else{ |
| | | return response.getData()==null?new TmsOrderInfoResponse():response.getData(); |
| | | TmsOrderInfoResponse result = new TmsOrderInfoResponse(); |
| | | if(StringUtils.isBlank(param.getContractNumber())){ |
| | | return result; |
| | | } |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +TMSContants.InterfacePath.getOrderDetailByContractNumber[0]; |
| | | TmsBaseResponse<TmsOrderInfoResponse> response = sendHttpRequest(url,TMSContants.InterfacePath.getOrderDetailByContractNumber[1],JSONObject.toJSONString(param) |
| | | ,new TypeReference< TmsBaseResponse<TmsOrderInfoResponse>>(){}); |
| | | if(response!=null && response.getData()!=null){ |
| | | result =response.getData(); |
| | | } |
| | | if(result.getTransportCode()!=null){ |
| | | TmsGisListRequest p = new TmsGisListRequest(); |
| | | p.setTransportCode(result.getTransportCode()); |
| | | result.setGisList(gisList(p)); |
| | | } |
| | | TmsCircleStatusListRequest p1 = new TmsCircleStatusListRequest(); |
| | | p1.setContractNumber(param.getContractNumber()); |
| | | result.setCicleStatusList(getCicleStatusList(p1)); |
| | | return result; |
| | | } |
| | | |
| | | /** |
| | |
| | | |
| | | FightingAdminCenterDataVO centerFightingAdminData(); |
| | | |
| | | List<TemperatureHumidityDataVO> getTemperatureHumidityData(); |
| | | |
| | | YearDeviceDataVO yearFightingAdminDeviceData(); |
| | | |
| | | List<AlarmEventDataVO> fightingAdminAlertList(); |
| | |
| | | List<TransportMeasureVO> transportMeasure(Integer queryType); |
| | | |
| | | BoardStockListVO stockList(); |
| | | |
| | | List<GeneralVO> todayTotalInList(); |
| | | } |
| | |
| | | package com.doumee.service.business.third; |
| | | |
| | | import com.doumee.core.tms.model.request.TmsLockStatusQueryRequest; |
| | | import com.doumee.core.tms.model.request.TmsOrderInfoRequest; |
| | | import com.doumee.core.tms.model.request.TmsOrderListRequest; |
| | | import com.doumee.core.tms.model.response.TmsBaseResponse; |
| | | import com.doumee.core.tms.model.response.TmsLockStatusQueryResponse; |
| | | import com.doumee.core.tms.model.response.TmsOrderInfoResponse; |
| | | import com.doumee.core.tms.model.response.TmsOrderListResponse; |
| | | import com.doumee.core.tms.model.request.*; |
| | | import com.doumee.core.tms.model.response.*; |
| | | import com.doumee.core.wms.model.request.WmsActionNoticeRequest; |
| | | import com.doumee.core.wms.model.request.WmsBaseRequest; |
| | | import com.doumee.core.wms.model.request.WmsInboundNoticeRequest; |
| | |
| | | * @return TmsBaseResponse |
| | | */ |
| | | List<TmsOrderListResponse> orderList(TmsOrderListRequest param); |
| | | |
| | | List<TmsGisListResponse> gisList(TmsGisListRequest param); |
| | | List<TmsCircleStatusResultListResponse> getCicleStatusList(TmsCircleStatusListRequest param); |
| | | /** |
| | | * åå详æ
æ¥å£ |
| | | * @param param åæ° |