igds-core/src/main/java/com/ld/igds/common/impl/CommonDataServiceImpl.java
@@ -7,7 +7,6 @@ import com.ld.igds.common.dto.THDto; import com.ld.igds.common.mapper.CommonMapper; import com.ld.igds.constant.Constant; import com.ld.igds.constant.DepotStatus; import com.ld.igds.constant.RedisConst; import com.ld.igds.inout.InoutConstant; import com.ld.igds.inout.dto.InoutData; @@ -19,7 +18,6 @@ import com.ld.igds.util.RedisUtil; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.dom4j.CDATA; import org.springframework.stereotype.Service; import javax.annotation.Resource; igds-core/src/main/java/com/ld/igds/constant/RedisConst.java
@@ -72,127 +72,127 @@ /** * ä»åºå表KEY */ public static final String KEY_DEPOT = "KEY_DEPOT"; public static final String KEY_DEPOT = "DEPOT_DATA"; /** * ä»åºåæ°å表KEY */ public static final String KEY_DEPOT_CONF = "KEY_DEPOT_CONF"; public static final String KEY_DEPOT_CONF = "DEPOT_CONF"; /** * åæºå表KEY */ public static final String KEY_DEVICE_SER_LIST = "KEY_SER_LIST"; public static final String KEY_DEVICE_SER_LIST = "SER_LIST"; /** * 设å¤å表 */ public static final String KEY_DEVICE_LIST = "KEY_DEVICE_LIST"; public static final String KEY_DEVICE_LIST = "DEVICE_LIST"; /** * 设å¤å表 */ public static final String KEY_DEVICE_IOT_LIST = "KEY_DEVICE_IOT_LIST"; public static final String KEY_DEVICE_IOT_LIST = "DEVICE_IOT_LIST"; /** * ä»åºååæºçå¤å¯¹å¤å ³ç³»éå */ public static final String KEY_DEPOT_SER_LIST = "KEY_DEPOT_SER_LIST"; public static final String KEY_DEPOT_SER_LIST = "DEPOT_SER_LIST"; /** * 建çç©ä¿¡æ¯ */ public static final String KEY_BUILDING_LIST = "KEY_BUILDING_LIST"; public static final String KEY_BUILDING_LIST = "BUILDING_LIST"; /** * æ§è¡å½ä»¤KEYåç¼ */ public static final String KEY_ORDER_PRE = "KEY_ORDER"; public static final String KEY_ORDER_PRE = "ORDER"; /** * ææ°ç²®æ ä¿¡æ¯ç¼åå表ï¼ç¨äºåæ¾å½åææ°çç²®æ ä¿¡æ¯ */ public static final String KEY_GRAIN = "KEY_GRAIN"; public static final String KEY_GRAIN = "GRAIN_DATA"; /** * ææ°æ°ä½ä¿¡æ¯ç¼åå表 */ public static final String KEY_GAS_DATA = "KEY_GAS_DATA"; public static final String KEY_GAS_DATA = "GAS_DATA"; /** * ç³»ç»é ç½®KEY */ public static final String KEY_SYS_CONF = "KEY_SYS_CONF"; public static final String KEY_SYS_CONF = "SYS_CONF"; /** * ç²®åºç温湿度信æ¯ç¼å */ public static final String KEY_DEPOT_TH_PREFIX = "KEY_DEPOT_TH_PREFIX"; public static final String KEY_DEPOT_TH_PREFIX = "DEPOT_TH_PREFIX"; /** * ä»¥åæºæè ä»åºä¸ºåä½åå¨ç仿¸©ä»æ¹¿ç¼åæ æ ç¾ */ public static final String KEY_T_TH = "KEY_T_TH"; public static final String KEY_T_TH = "T_TH"; /** * åæ¾æ°è±¡ä¿¡æ¯çKEY */ public static final String KEY_WEATHER_INFO = "KEY_WEATHER_INFO"; public static final String KEY_WEATHER_INFO = "WEATHER_INFO"; /** * æ ¹æ®ä»åºç¼ç åæ¾ææ°çè½èæ°æ®ä¿¡æ¯ */ public static final String KEY_ES_DATA_MAP = "KEY_ES_DATA_MAP"; public static final String KEY_ES_DATA_MAP = "ES_DATA_MAP"; /** * ç³»ç»ä¸ç»ç»å表 */ public static final String KEY_DEPT_LIST = "KEY_DEPT_LIST"; public static final String KEY_DEPT_LIST = "DEPT_LIST"; /** * å¶æ°®æºé ç½®å表 */ public static final String KEY_N2_CONF_LIST = "KEY_N2_CONF_LIST"; public static final String KEY_N2_CONF_LIST = "N2_CONF_LIST"; /** * ææ°æ°åä¿¡æ¯ç¼åå表 */ public static final String KEY_PRESSURE_DATA = "KEY_PRESSURE_DATA"; public static final String KEY_PRESSURE_DATA = "PRESSURE_DATA"; /** * ç³»ç»é ç½®çæåæºä¿¡æ¯ç¼å */ public static final String KEY_CAMERA_LIST = "KEY_CAMERA_LIST"; public static final String KEY_CAMERA_LIST = "CAMERA_LIST"; /** * ä¸ç»´é ç½®å ³èä¿¡æ¯key */ public static final String KEY_THREE_CONF = "KEY_THREE_CONF"; public static final String KEY_THREE_CONF = "THREE_CONF"; /** * 临æ¶ç¼åKEYåç¼ */ public static final String KEY_TEMP_PREFIX = "KEY_TEMP_"; public static final String KEY_TEMP_PREFIX = "TEMP_"; /** * æ°éçæµåæ°å表KEY--åä¸ªè®¾å¤ */ public static final String KEY_QUANTITY_CONF = "KEY_QUANTITY_CONF"; public static final String KEY_QUANTITY_CONF = "QUANTITY_CONF"; /** * ä»åºè´¨éå·¡æ£æ°æ®ç¼å */ public static final String KEY_DEPOT_QUALITY = "KEY_DEPOT_QUALITY"; public static final String KEY_DEPOT_QUALITY = "DEPOT_QUALITY"; /** * ä»åºæ¶²ä½æ°æ®ç¼å */ public static final String KEY_DEPOT_HEIGHT = "KEY_DEPOT_HEIGHT"; public static final String KEY_DEPOT_HEIGHT = "DEPOT_HEIGHT"; /** * ä»åºç©èç½å ³iotè®¾å¤æ¸©æ¹¿åº¦ç¼åkey */ public static final String KEY_IOT_DEPOT_TEMP_HUM = "KEY_IOT_DEPOT_TEMP_HUM"; public static final String KEY_IOT_DEPOT_TEMP_HUM = "IOT_DEPOT_TEMP_HUM"; /** * å个æ°éæ£æµæå¡ */ @@ -201,11 +201,11 @@ /** * è¦åé ç½®å表KEY */ public static final String KEY_WARN_CONF = "KEY_WARN_CONF"; public static final String KEY_WARN_CONF = "WARN_CONF"; /** * é¨ç£è®¾å¤é ç½®å表 */ public static final String KEY_DOOR_SENSOR_LIST = "KEY_DOOR_SENSOR_LIST"; public static final String KEY_DOOR_SENSOR_LIST = "DOOR_SENSOR_LIST"; } igds-core/src/main/java/com/ld/igds/inout/ApiInoutManager.java
ÎļþÃû´Ó igds-inout/src/main/java/com/ld/igds/inout/manager/ApiInoutManager.java ÐÞ¸Ä @@ -1,6 +1,5 @@ package com.ld.igds.inout.manager; package com.ld.igds.inout; import com.ld.igds.io.InoutApiService; import com.ld.igds.io.constant.ProtocolEnum; import org.springframework.beans.BeansException; import org.springframework.context.ApplicationContext; @@ -20,12 +19,12 @@ public class ApiInoutManager implements ApplicationContextAware { public static Map<String, InoutApiService> remoteMap = new HashMap<>(); public static Map<String, ApiInoutService> remoteMap = new HashMap<>(); @Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { Map<String, InoutApiService> grainMap = applicationContext.getBeansOfType(InoutApiService.class); Map<String, ApiInoutService> grainMap = applicationContext.getBeansOfType(ApiInoutService.class); for (String key : grainMap.keySet()) { remoteMap.put(grainMap.get(key).getProtocol(), grainMap.get(key)); @@ -38,8 +37,8 @@ * @param protocol æå±åè®® * @return */ public InoutApiService getApiService(String protocol) { InoutApiService apiService = remoteMap.get(protocol); public ApiInoutService getApiService(String protocol) { ApiInoutService apiService = remoteMap.get(protocol); if (null == apiService) { apiService = remoteMap.get(ProtocolEnum.TCP_DEFAULT.getCode()); } igds-core/src/main/java/com/ld/igds/inout/ApiInoutService.java
¶Ô±ÈÐÂÎļþ @@ -0,0 +1,74 @@ package com.ld.igds.inout; import com.ld.igds.inout.dto.ApiInoutData; /** * @Desc: åºå ¥åºç¸å ³è®¾å¤è°ç¨æ¥å£ * @author: Andy * @update-time: 2023/5/29 */ public interface ApiInoutService { /** * è·ååè®® * * @return */ String getProtocol(); /** * éè¿åè®®è·åä¸å¡éçç»æ * * @param param * @return */ ApiInoutData getIcCardNum(ApiInoutData param); /** * è·å车çè¯å«ç»æ * * @param param * @return */ ApiInoutData getPlateNum(ApiInoutData param); /** * 车çè¯å«åå§å * * @param param * @return */ String initLpr(ApiInoutData param); /** * 鏿ºæ§å¶-actionCodeå deviceId * * @param param * @return */ String gateControl(ApiInoutData param); /** * è¯é³ææ¾--è¿ç¨è°ç¨è¯é³ææ¾ * * @param param actionCode å msgä¸å¯ä¸ºç©º * @return */ String noticeRadio(ApiInoutData param); /** * LEDå±å¹æ¨éä¿¡æ¯ * * @param param actionCode å msgä¸å¯ä¸ºç©º * @return */ String noticeLed(ApiInoutData param); } igds-core/src/main/java/com/ld/igds/inout/dto/ApiInoutData.java
ÎļþÃû´Ó igds-core/src/main/java/com/ld/igds/inout/dto/InoutApiData.java ÐÞ¸Ä @@ -11,28 +11,19 @@ * åºå ¥åºæµç¨è¿ç¨ä¸ï¼è½¦ç失败ï¼è¯»å¡å¨ç设å¤çå ¬å ±åæ°åä¼ é对象 */ @Data public class InoutApiData implements Serializable { public class ApiInoutData implements Serializable { private static final long serialVersionUID = 1L; @PropertyDef(label = "主é®") private String id; @PropertyDef(label = "ç»ç»ç¼ç ") private String companyId; @PropertyDef(label = "æå±åºç¹") private String deptId; @PropertyDef(label = "åºå ¥åºé å¥åºå·") private String sort = "1"; @PropertyDef(label = "设å¤é¡ºåº") private int inOrder = 1; @PropertyDef(label = "æå±æµç¨") private String inoutProgress; @PropertyDef(label = "设å¤åç§°") private String name; @@ -40,10 +31,8 @@ @PropertyDef(label = "设å¤åºåå·/设å¤ç¼ç ") private String sn; @PropertyDef(label = "åæºIP") private String ip; @PropertyDef(label = "åæºç«¯å£") private Integer port; @PropertyDef(label = "å¸å·") @@ -57,9 +46,6 @@ @PropertyDef(label = "æ§å¶ç«¯å£") private Integer portCtrl; @PropertyDef(label = "WEB端å£") private Integer portWeb; @PropertyDef(label = "设å¤ç±»å") private String type; @@ -88,9 +74,6 @@ private Date time = new Date(); //设å¤ç¼ç // private String deviceId; //ä¿¡æ¯ private String msg; @@ -103,18 +86,22 @@ //ç§°éä¿¡æ¯ private double weight = 0.0; //å¨ä½ç¼ç ï¼ä¾å¦å¼é¸æº-å ³é¸æºç private String actionCode; public InoutApiData() { //å¨ä½ç¼ç ï¼è®¾å¤ç¼å· private String deviceId; public ApiInoutData() { super(); } public InoutApiData(InoutConf conf) { public ApiInoutData(InoutConf conf) { this.id = conf.getId(); this.companyId = conf.getCompanyId(); this.deptId = conf.getDeptId(); this.sort = conf.getSort(); this.inOrder = conf.getInOrder(); this.inoutProgress = conf.getInoutProgress(); this.name = conf.getName(); this.sn = conf.getSn(); this.ip = conf.getIp(); @@ -123,7 +110,6 @@ this.pwd = conf.getPwd(); this.chanNum = conf.getChanNum(); this.portCtrl = conf.getPortCtrl(); this.portWeb = conf.getPortWeb(); this.type = conf.getType(); this.status = conf.getStatus(); this.protocol = conf.getProtocol(); igds-core/src/main/java/com/ld/igds/io/InoutApiService.java
ÎļþÒÑɾ³ý igds-core/src/main/java/com/ld/igds/io/impl/DefaultInoutApiServiceImpl.java
@@ -1,7 +1,7 @@ package com.ld.igds.io.impl; import com.ld.igds.inout.dto.InoutApiData; import com.ld.igds.io.InoutApiService; import com.ld.igds.inout.dto.ApiInoutData; import com.ld.igds.inout.ApiInoutService; import com.ld.igds.io.constant.ProtocolEnum; import org.springframework.stereotype.Repository; @@ -9,7 +9,7 @@ * @author */ @Repository public class DefaultInoutApiServiceImpl implements InoutApiService { public class DefaultInoutApiServiceImpl implements ApiInoutService { @Override public String getProtocol() { @@ -17,52 +17,32 @@ } @Override public InoutApiData getPlateNum(InoutApiData param) { public ApiInoutData getPlateNum(ApiInoutData param) { return param; } @Override public String reConnectLpr(InoutApiData param) { public String initLpr(ApiInoutData param) { return null; } @Override public String initLpr(InoutApiData param) { public String gateControl(ApiInoutData param) { return null; } @Override public String gateControl(InoutApiData param) { public String noticeRadio(ApiInoutData param) { return null; } @Override public String addWhitePlate(InoutApiData param) { public String noticeLed(ApiInoutData param) { return null; } @Override public String delWhitePlate(InoutApiData apiData) { return null; } @Override public String noticeRadio(InoutApiData param) { return null; } @Override public String gatewayStatus(InoutApiData param) { return null; } @Override public String noticeWeightDone(InoutApiData param) { return null; } @Override public InoutApiData getIcCardNum(InoutApiData param) { public ApiInoutData getIcCardNum(ApiInoutData param) { return null; } igds-core/src/main/java/com/ld/igds/models/InoutConf.java
@@ -31,7 +31,7 @@ private String companyId; @Column(name = "DEPT_ID_", length = 40) @PropertyDef(label = "æå±åºç¹") @PropertyDef(label = "æå±åºåº") private String deptId; @Column(name = "SORT_", length = 2) @@ -78,9 +78,9 @@ @PropertyDef(label = "æ§å¶ç«¯å£") private Integer portCtrl; @Column(name = "PORT_WEB_") @PropertyDef(label = "WEB端å£") private Integer portWeb; // @Column(name = "PORT_WEB_") // @PropertyDef(label = "WEB端å£") // private Integer portWeb; @Column(name = "TYPE_", length = 10) @PropertyDef(label = "设å¤ç±»å") @@ -91,7 +91,7 @@ private String status; @Column(name = "PROTOCOL_", length = 40) @PropertyDef(label = "åæºåè®®", description = "ä¸åååæä¸åçåè®®") @PropertyDef(label = "åè®®", description = "ä¸åååæä¸åçåè®®") private String protocol; @Column(name = "PLAY_TYPE_", length = 25) @@ -133,7 +133,6 @@ this.pwd = conf.getPwd(); this.chanNum = conf.getChanNum(); this.portCtrl = conf.getPortCtrl(); this.portWeb = conf.getPortWeb(); this.type = conf.getType(); this.status = conf.getStatus(); this.protocol = conf.getProtocol(); igds-inout/src/main/java/com/ld/igds/inout/controller/InoutController.java
@@ -89,10 +89,10 @@ // è·ååºå ¥åºé ç½®ä¿¡æ¯ List<InoutConf> listInoutConf = inoutCommonManager.getListInoutConf(user.getCompanyId(), deptId); // 车çè¯å«åæ°å°è£ InoutConf conf = inoutCommonManager.getInoutConf(listInoutConf, sort, InoutConstant.CONF_TYPE_10, InoutConstant.PROGRESS_REGISTER, 1); if(null != conf) conf.setSort(sort); view.addObject("lprDto", conf); //åå§å车çè¯å« igds-inout/src/main/java/com/ld/igds/inout/controller/InoutDeviceController.java
@@ -2,7 +2,7 @@ import com.ld.igds.constant.RespCodeEnum; import com.ld.igds.data.PageResponse; import com.ld.igds.inout.dto.InoutApiData; import com.ld.igds.inout.dto.ApiInoutData; import com.ld.igds.inout.dto.InoutCameraDto; import com.ld.igds.inout.dto.InoutSnapImgDto; import com.ld.igds.inout.manager.InoutDeviceManager; @@ -35,7 +35,7 @@ */ @ResponseBody @RequestMapping("/flush-lpr") public PageResponse<InoutApiData> flushPlate(@RequestBody InoutApiData param) { public PageResponse<ApiInoutData> flushPlate(@RequestBody ApiInoutData param) { if (StringUtils.isEmpty(param.getProtocol())) { param.setErrorMsg("å½å车çè¯å«æªé ç½®é讯åè®®ï¼æ æ³æ§è¡"); @@ -64,7 +64,7 @@ */ @ResponseBody @RequestMapping("/ic-card-num") public PageResponse<InoutApiData> getIcCardNum(@RequestBody InoutApiData param) { public PageResponse<ApiInoutData> getIcCardNum(@RequestBody ApiInoutData param) { if (StringUtils.isEmpty(param.getProtocol())) { param.setErrorMsg("å½åæºæ §å¡æªé ç½®é讯åè®®ï¼æ æ³æ§è¡"); @@ -83,39 +83,6 @@ } return new PageResponse<>(RespCodeEnum.CODE_1007.getCode(), param.getErrorMsg()); } /** * éæ°è¿æ¥ç³»ç»-车çè¯å« * * @return */ @ResponseBody @RequestMapping("/reset-lpr") public PageResponse<String> resetLpr(@RequestBody InoutApiData param) { String result = "æ§è¡å®æ"; if (StringUtils.isEmpty(param.getProtocol())) { result = "å½å车çè¯å«æªé ç½®é讯åè®®ï¼æ æ³æ§è¡"; return new PageResponse<>(RespCodeEnum.CODE_1007.getCode(), result); } if (null == param.getIp()) { result = "åºå ¥åºé ç½®ä¸æ²¡æé ç½®å¦å ¥ç»è®°ç车çè¯å«"; return new PageResponse<>(RespCodeEnum.CODE_1007.getCode(), result); } result = inoutDeviceManager.reConnectLpr(param); if (null == result) { return new PageResponse<String>(RespCodeEnum.CODE_0000, "æ§è¡æå"); } return new PageResponse<>(RespCodeEnum.CODE_1007.getCode(), result); } /** @@ -202,7 +169,7 @@ */ @RequestMapping("/notice-weight-done") public @ResponseBody PageResponse<String> noticeWeightDone(@RequestBody InoutApiData param) { PageResponse<String> noticeWeightDone(@RequestBody ApiInoutData param) { String msg = inoutDeviceManager.noticeWeightDone(param); igds-inout/src/main/java/com/ld/igds/inout/manager/InoutDeviceManager.java
@@ -6,12 +6,13 @@ import com.ld.igds.camera.data.ApiCameraResp; import com.ld.igds.camera.data.ApiSnapReq; import com.ld.igds.file.CoreFileService; import com.ld.igds.inout.ApiInoutManager; import com.ld.igds.inout.InoutConstant; import com.ld.igds.inout.dto.InoutApiData; import com.ld.igds.inout.dto.ApiInoutData; import com.ld.igds.inout.dto.InoutCameraDto; import com.ld.igds.inout.dto.InoutData; import com.ld.igds.inout.dto.InoutSnapImgDto; import com.ld.igds.io.InoutApiService; import com.ld.igds.inout.ApiInoutService; import com.ld.igds.io.constant.ProtocolEnum; import com.ld.igds.m.service.InoutCommonService; import com.ld.igds.models.InoutConf; @@ -49,7 +50,7 @@ private ApiCameraManager apiCameraManager; public InoutApiData getPlateNum(InoutApiData param) { public ApiInoutData getPlateNum(ApiInoutData param) { //å¦æä½¿ç¨çæ¯å°ç£ æä»¶è·åï¼åéè¦è°æ´è®¾å¤ä¸ºå°ç£ æä»¶ä¿¡æ¯ if (ProtocolEnum.TCP_FZZY_WEIGHT.getCode().equals(param.getProtocol())) { @@ -60,7 +61,7 @@ return param; } InoutApiData pluginWeight = new InoutApiData(); ApiInoutData pluginWeight = new ApiInoutData(); pluginWeight = param; pluginWeight.setIp(conf.getIp()); pluginWeight.setPort(conf.getPort()); @@ -74,7 +75,7 @@ return apiInoutManager.getApiService(param.getProtocol()).getPlateNum(param); } public InoutApiData getIcCardNum(InoutApiData param) { public ApiInoutData getIcCardNum(ApiInoutData param) { return apiInoutManager.getApiService(param.getProtocol()).getIcCardNum(param); } @@ -119,14 +120,9 @@ if (null == conf) return; InoutApiData lprData = new InoutApiData(conf); ApiInoutData lprData = new ApiInoutData(conf); apiInoutManager.getApiService(conf.getProtocol()).initLpr(lprData); } public String reConnectLpr(InoutApiData param) { return apiInoutManager.getApiService(param.getProtocol()).reConnectLpr(param); } @@ -134,7 +130,7 @@ * @param param * @return */ public String noticeWeightDone(InoutApiData param) { public String noticeWeightDone(ApiInoutData param) { //è·åç§°é主æ§å¨é ç½® InoutConf conf = getWeightGateway(param.getCompanyId(), param.getDeptId(), param.getSort()); @@ -142,14 +138,14 @@ return "ç§°éä¸»æ§æªé ç½®ï¼æ¯æå¤±è´¥"; } InoutApiData apiData = new InoutApiData(conf); ApiInoutData apiData = new ApiInoutData(conf); apiData.setPlateNum(param.getPlateNum()); apiData.setInoutProgress(param.getInoutProgress()); apiData.setTime(new Date()); InoutApiService inoutApiService = apiInoutManager.getApiService(conf.getProtocol()); ApiInoutService inoutApiService = apiInoutManager.getApiService(conf.getProtocol()); return inoutApiService.noticeWeightDone(apiData); // return inoutApiService.noticeWeightDone(apiData); TODO return null; } /** @@ -215,7 +211,7 @@ return; } InoutApiData apiData = new InoutApiData(conf); ApiInoutData apiData = new ApiInoutData(conf); apiData.setTime(new Date()); apiData.setRepeat(2); apiData.setWeight(snapImgDto.getWeight()); @@ -244,13 +240,13 @@ log.debug("-------------ç»è®°å®æï¼å¢å 车çç½åå-----------{}", imgDto.getPlateNum()); InoutApiService inoutApiService = apiInoutManager.getApiService(list.get(0).getProtocol()); ApiInoutService inoutApiService = apiInoutManager.getApiService(list.get(0).getProtocol()); InoutApiData apiData; ApiInoutData apiData; for (InoutConf conf : list) { apiData = new InoutApiData(conf); apiData = new ApiInoutData(conf); apiData.setPlateNum(imgDto.getPlateNum()); inoutApiService.addWhitePlate(apiData); // inoutApiService.addWhitePlate(apiData); } } @@ -262,13 +258,14 @@ return; } InoutApiService inoutApiService = apiInoutManager.getApiService(list.get(0).getProtocol()); ApiInoutService inoutApiService = apiInoutManager.getApiService(list.get(0).getProtocol()); InoutApiData apiData; ApiInoutData apiData; for (InoutConf conf : list) { apiData = new InoutApiData(conf); apiData = new ApiInoutData(conf); apiData.setPlateNum(data.getPlateNum()); inoutApiService.delWhitePlate(apiData); // inoutApiService.delWhitePlate(apiData); TODO } } igds-inout/src/main/java/com/ld/igds/io/notify/NotifyLprService.java
@@ -1,7 +1,7 @@ package com.ld.igds.io.notify; import com.ld.igds.inout.dto.InoutApiData; import com.ld.igds.inout.dto.ApiInoutData; /** * 车çè¯å«ä¿¡æ¯éç¥ @@ -22,9 +22,9 @@ * * @param lprDto */ void notify(InoutApiData lprDto); void notify(ApiInoutData lprDto); InoutApiData getLpr(String key); ApiInoutData getLpr(String key); void remove(String key); @@ -33,5 +33,5 @@ * @param sn * @param lprDto */ void setLpr(String sn, InoutApiData lprDto); void setLpr(String sn, ApiInoutData lprDto); } igds-inout/src/main/java/com/ld/igds/io/notify/impl/NotifyLprServiceImpl.java
@@ -2,7 +2,7 @@ import com.ld.igds.constant.BizType; import com.ld.igds.constant.RedisConst; import com.ld.igds.inout.dto.InoutApiData; import com.ld.igds.inout.dto.ApiInoutData; import com.ld.igds.io.notify.NotifyLprService; import com.ld.igds.util.ContextUtil; import com.ld.igds.util.RedisUtil; @@ -27,12 +27,11 @@ @SuppressWarnings("static-access") @Override public void notify(InoutApiData plate) { public void notify(ApiInoutData plate) { if (null == plate) return; WebSocketPacket packet = new WebSocketPacket(); packet.setCompanyId(ContextUtil.getDefaultCompanyId()); packet.setBizType(BizType.INOUT_IN.getCode()); packet.setBizTag(plate.getInoutProgress()); packet.setUserId(plate.getUserId()); packet.setBizId("PLATE_NUM"); @@ -45,9 +44,9 @@ @Override public InoutApiData getLpr(String key) { public ApiInoutData getLpr(String key) { key = RedisConst.buildKey(ContextUtil.getDefaultCompanyId(),KEY_LPR,key); InoutApiData lprDto = (InoutApiData) redisUtil.get(key); ApiInoutData lprDto = (ApiInoutData) redisUtil.get(key); if(null == lprDto) return null; return lprDto; } @@ -59,7 +58,7 @@ } @Override public void setLpr(String sn, InoutApiData lprDto) { public void setLpr(String sn, ApiInoutData lprDto) { String key = RedisConst.buildKey(ContextUtil.getDefaultCompanyId(),KEY_LPR,sn); redisUtil.set(key,lprDto, 60 * 60); } igds-inout/src/main/java/com/ld/igds/m/view/InoutConf.view.xml
@@ -103,11 +103,11 @@ </PropertyDef> <PropertyDef name="ip"> <Property></Property> <Property name="label">åæºIP</Property> <Property name="label">IPå°å</Property> </PropertyDef> <PropertyDef name="port"> <Property name="dataType">Integer</Property> <Property name="label">åæºç«¯å£</Property> <Property name="label">设å¤ç«¯å£</Property> </PropertyDef> <PropertyDef name="loginId"> <Property></Property> @@ -119,7 +119,7 @@ </PropertyDef> <PropertyDef name="chanNum"> <Property name="dataType">int</Property> <Property name="label">ææéé</Property> <Property name="label">ééå·</Property> </PropertyDef> <PropertyDef name="portCtrl"> <Property name="dataType">Integer</Property> @@ -190,7 +190,7 @@ </PropertyDef> <PropertyDef name="errorMsg"> <Property></Property> <Property name="label">夿³¨ä¿¡æ¯</Property> <Property name="label">å¼å¸¸è¯´æ</Property> </PropertyDef> </DataType> </Model> @@ -382,11 +382,6 @@ <Editor/> </AutoFormElement> <AutoFormElement> <Property name="name">status</Property> <Property name="property">status</Property> <Editor/> </AutoFormElement> <AutoFormElement> <Property name="name">ip</Property> <Property name="property">ip</Property> <Editor/> @@ -397,6 +392,29 @@ <Editor/> </AutoFormElement> <AutoFormElement> <Property name="name">status</Property> <Property name="property">status</Property> <Editor/> </AutoFormElement> <AutoFormElement> <Property name="name">inOrder</Property> <Property name="property">inOrder</Property> <Editor/> </AutoFormElement> </AutoForm> </Children> </FieldSet> <FieldSet layoutConstraint="padding:10"> <Property name="caption">æå头é ç½®</Property> <Buttons/> <Children> <AutoForm> <Property name="dataSet">dsMain</Property> <Property name="cols">*,*</Property> <Property name="labelAlign">right</Property> <Property name="labelSeparator">ï¼</Property> <Property name="labelWidth">100</Property> <AutoFormElement> <Property name="name">loginId</Property> <Property name="property">loginId</Property> <Editor/> @@ -406,19 +424,6 @@ <Property name="property">pwd</Property> <Editor/> </AutoFormElement> </AutoForm> </Children> </FieldSet> <FieldSet layoutConstraint="padding:10"> <Property name="caption">ææåå ¶å®é ç½®</Property> <Buttons/> <Children> <AutoForm> <Property name="dataSet">dsMain</Property> <Property name="cols">*,*</Property> <Property name="labelAlign">right</Property> <Property name="labelSeparator">ï¼</Property> <Property name="labelWidth">100</Property> <AutoFormElement> <Property name="name">chanNum</Property> <Property name="property">chanNum</Property> @@ -450,16 +455,6 @@ <AutoFormElement layoutConstraint="colSpan:2"> <Property name="name">remark</Property> <Property name="property">remark</Property> <Editor/> </AutoFormElement> <AutoFormElement> <Property name="name">errorMsg</Property> <Property name="property">errorMsg</Property> <Editor/> </AutoFormElement> <AutoFormElement> <Property name="name">inOrder</Property> <Property name="property">inOrder</Property> <Editor/> </AutoFormElement> </AutoForm> igds-protocol-block/src/main/java/com/ld/igds/protocol/weight/FzzyWeightServiceImpl.java
@@ -1,14 +1,17 @@ package com.ld.igds.protocol.weight; import com.alibaba.fastjson.JSONObject; import com.ld.igds.inout.dto.InoutApiData; import com.ld.igds.io.InoutApiService; import com.ld.igds.inout.dto.ApiInoutData; import com.ld.igds.inout.ApiInoutService; import com.ld.igds.io.constant.ProtocolEnum; import com.ld.igds.util.HttpUtils; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.time.DateFormatUtils; import org.springframework.stereotype.Component; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.FutureTask; @@ -20,7 +23,7 @@ */ @Slf4j @Component public class FzzyWeightServiceImpl implements InoutApiService { public class FzzyWeightServiceImpl implements ApiInoutService { @Override @@ -33,7 +36,7 @@ * @return */ @Override public InoutApiData getPlateNum(InoutApiData param) { public ApiInoutData getPlateNum(ApiInoutData param) { if (null == param.getSn()) { @@ -87,18 +90,7 @@ * @return */ @Override public String reConnectLpr(InoutApiData param) { return "å½åæ¨¡å¼æ éé置车çè¯å«"; } /** * ä¸éè¦å®ç° * * @param param * @return */ @Override public String initLpr(InoutApiData param) { public String initLpr(ApiInoutData param) { return "å½åæ¨¡å¼æ éåå§å车çè¯å«"; } @@ -110,7 +102,7 @@ * @return */ @Override public String gateControl(InoutApiData param) { public String gateControl(ApiInoutData param) { return null; } @@ -120,8 +112,7 @@ * @param param deviceIdåactionCode ä¸å¯ä¸ºç©º * @return */ @Override public String addWhitePlate(InoutApiData param) { public String addWhitePlate(ApiInoutData param) { FutureTask<String> futureTask = new FutureTask<>(new WeightGatewayRemoteTask(param, new String[]{WeightUtil.ACTION_CODE_10})); ExecutorService executorService = Executors.newCachedThreadPool(); @@ -137,8 +128,7 @@ * @param param * @return */ @Override public String delWhitePlate(InoutApiData param) { public String delWhitePlate(ApiInoutData param) { FutureTask<String> futureTask = new FutureTask<>(new WeightGatewayRemoteTask(param, new String[]{WeightUtil.ACTION_CODE_11})); ExecutorService executorService = Executors.newCachedThreadPool(); executorService.submit(futureTask); @@ -154,7 +144,7 @@ * @return */ @Override public String noticeRadio(InoutApiData param) { public String noticeRadio(ApiInoutData param) { FutureTask<String> futureTask = new FutureTask<>(new WeightGatewayRemoteTask(param, new String[]{WeightUtil.ACTION_CODE_30})); ExecutorService executorService = Executors.newCachedThreadPool(); @@ -164,10 +154,6 @@ return "SUCCESS"; } @Override public String gatewayStatus(InoutApiData param) { return null; } /** * ç§°é宿 --è°ç¨å线ç¨å®ç° @@ -175,9 +161,7 @@ * @param param * @return */ @Override public String noticeWeightDone(InoutApiData param) { public String noticeWeightDone(ApiInoutData param) { FutureTask<String> futureTask = new FutureTask<>(new WeightGatewayRemoteTask(param, new String[]{WeightUtil.ACTION_CODE_60, WeightUtil.ACTION_CODE_30})); ExecutorService executorService = Executors.newCachedThreadPool(); executorService.submit(futureTask); @@ -191,7 +175,7 @@ * @return */ @Override public InoutApiData getIcCardNum(InoutApiData param) { public ApiInoutData getIcCardNum(ApiInoutData param) { try { @@ -230,4 +214,10 @@ return param; } @Override public String noticeLed(ApiInoutData param) { // TODO Auto-generated method stub return null; } } igds-protocol-block/src/main/java/com/ld/igds/protocol/weight/WeightGatewayRemoteTask.java
@@ -1,7 +1,7 @@ package com.ld.igds.protocol.weight; import com.alibaba.fastjson.JSONObject; import com.ld.igds.inout.dto.InoutApiData; import com.ld.igds.inout.dto.ApiInoutData; import com.ld.igds.util.HttpUtils; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.time.DateFormatUtils; @@ -15,16 +15,16 @@ @Slf4j public class WeightGatewayRemoteTask implements Callable<String> { private InoutApiData param; private ApiInoutData param; private String[] actionCodes; public InoutApiData getParam() { public ApiInoutData getParam() { return param; } public void setParam(InoutApiData param) { public void setParam(ApiInoutData param) { this.param = param; } @@ -39,7 +39,7 @@ public WeightGatewayRemoteTask() { } public WeightGatewayRemoteTask(InoutApiData param, String[] actionCodes) { public WeightGatewayRemoteTask(ApiInoutData param, String[] actionCodes) { this.param = param; this.actionCodes = actionCodes; } igds-web/src/main/resources/static/admin/inout/style.css
@@ -758,7 +758,7 @@ .kccz-r-btnbox { width: 86px; width: 110px; position: absolute; right: 0; top: 0; @@ -767,10 +767,32 @@ .kccz-r-btn { display: block; width: 84px; width: 110px; height: 78px; border: 1px solid #e7eaed; text-align: center; } .kccz-r-div{ display: block; height: 78px; border: 1px solid #e7eaed; background: #53adce; text-align: center; } .kccz-r-div span{ display: inline-block; width: 100px; margin: 10px 0 0px; height: 40px; font-size: 18px; font-weight: bold; color: #FFF; } .kccz-r-div p { color: #fff; } .kccz-r-btn span { @@ -812,6 +834,7 @@ background: #53adce; } .kccz-r-btn1:hover .kccz-r-pz, .kccz-r-btn1.active .kccz-r-pz { background: url(../../images/icon-camera-h.png) no-repeat; igds-web/src/main/resources/static/favicon-fzzy.icoBinary files differ
igds-web/src/main/resources/templates/admin/inout/in-register.html
@@ -7,9 +7,8 @@ <meta http-equiv="X-UA-Compatible" content="IE=edge,chrome=1"> <meta name="renderer" content="webkit"> <title>åºå ¥åºç®¡ç-å ¥åºç»è®°</title> <link rel="stylesheet" type="text/css" th:href="@{../../static/plugins/layui/css/layui.css?v=2.5.5}"> th:href="@{../../static/plugins/layui/css/layui.css}"> <link rel="stylesheet" type="text/css" th:href="@{../../static/admin/inout/style.css}"> @@ -19,7 +18,6 @@ } .kccz-r-con2 { /* height: 230px; */ padding-right: 120px; position: relative; margin-top: 10px; @@ -29,18 +27,9 @@ .kccz-r-vedio { width: 100%; height: 280px; /* background: #dee6ec; */ background: #000; color: #FFF; text-align: center; } .kccz-r-btnbox { width: 100px; position: absolute; right: 0px; top: 0px; z-index: 99; } .layui-form-label { @@ -83,6 +72,7 @@ .rkbk-search-input{ background: #FFF !important; } .rkbk-search-input.bg-date { background: #FFF !important; } @@ -106,59 +96,44 @@ onclick="submit()"> <i><img th:src="@{../../static/images/icon-ok.png}"/></i> 宿ç»è®° </button> <button class="rkbk-quick-btn layui-btn btn-violet" onclick="resetPlateNum()"> <i><img th:src="@{../../static/images/icon-che.png}"/></i>é置车çè¯å« </button> </div> <!--æµç¨å¼å¯¼--> <div class="rk-step-wrap fr"> <ul class="rk-step"> <li id="progress-register" class="active rk-step-first"> <span class="rk-step-span"> <img th:src="@{../../static/images/icon-dengji.png}"/> <li id="progress-register" class="active rk-step-first"><span class="rk-step-span"> <img th:src="@{../../static/images/icon-dengji.png}" /> </span> <p>å ¥åºç»è®°</p> </li> <li id="progress-check"> <span class="rk-step-span"> <img th:src="@{../../static/images/icon-zhijian.png}"/> <p>å ¥åºç»è®°</p></li> <li id="progress-check"><span class="rk-step-span"> <img th:src="@{../../static/images/icon-zhijian.png}" /> </span> <p>æ¦æ ·è´¨æ£</p> </li> <li id="progress-fullWeight"> <span class="rk-step-span"> <p>æ¦æ ·è´¨æ£</p></li> <li id="progress-fullWeight"><span class="rk-step-span"> <img th:src="@{../../static/images/icon-chengzhong.png}"/> </span> <p>满车称é</p> </li> <li id="progress-hand"> <span class="rk-step-span"> <img th:src="@{../../static/images/icon-xiehuo.png}"/> <p>满车称é</p></li> <li id="progress-hand"><span class="rk-step-span"> <img th:src="@{../../static/images/icon-xiehuo.png}" /> </span> <p>å ¥åºå¼ä»</p> </li> <li id="progress-emptyWeight"> <span class="rk-step-span"> <p>å ¥åºå¼ä»</p></li> <li id="progress-emptyWeight"><span class="rk-step-span"> <img th:src="@{../../static/images/icon-chengzhong.png}"/> </span> <p>空车称é</p> </li> <li id="progress-cardBack"> <span class="rk-step-span"> <p>空车称é</p></li> <li id="progress-cardBack"><span class="rk-step-span"> <img th:src="@{../../static/images/icon-banli.png}"/> </span> <p>离åºç¡®è®¤</p> </li> <p>离åºç¡®è®¤</p></li> </ul> </div> <!--æµç¨å¼å¯¼ç»æ--> </div> <!-- 主ä½ä¿¡æ¯ --> <form class="layui-form" action="" id="form-data" lay-filter="form-data"> <form class="layui-form" action="" id="form-data" lay-filter="form-data"> <div class="rkbk-con"> <div class="radius-6 rkbk-left-wrap fl"> @@ -223,8 +198,9 @@ <div class="layui-form-item"> <label class="layui-form-label">æ° æï¼</label> <div class="layui-input-block"> <input type="text" name="userNation" id="userNation" placeholder="请è¾å ¥" autocomplete="off" class="layui-input rkbk-search-input"> <input type="text" name="userNation" id="userNation" placeholder="请è¾å ¥" autocomplete="off" class="layui-input rkbk-search-input"> </div> </div> @@ -254,8 +230,7 @@ <div class="rkbk-quick layui-text-center"> <button id="button_readID" type="button" onclick="flushIdCard()" class="rkbk-quick-btn layui-btn btn-blue">读åèº«ä»½è¯ </button> class="rkbk-quick-btn layui-btn btn-blue">读å身份è¯</button> </div> </div> @@ -269,14 +244,14 @@ <div class="rkbk-left"> <div class="rkbk-tit"> <i></i> <h3>è¿è¾ä¿¡æ¯</h3> <h3>ç»è®°ä¿¡æ¯</h3> </div> <div class="rkbk-left-form rkbk-right-form"> <div class="layui-form-item"> <input type="button" value="读å¡" class="rkbk-r-btn fr layui-btn" onclick="flushICCard()"/> <label class="layui-form-label color-red">æºæ §å¡å·ï¼</label> onclick="flushICCard()" /> <label class="layui-form-label color-red">æºæ §å¡å·ï¼</label> <div class="layui-input-block"> <input type="text" name="intelCard" id="intelCard" required lay-verify="required" placeholder="å æ¾å¡ï¼åç¹å»è¯»å¡" @@ -287,23 +262,24 @@ <div class="layui-form-item"> <input type="button" value="读车ç" class="rkbk-r-btn fr layui-btn layui-btn-normal" onclick="flushPlateNum()"/> <label class="layui-form-label color-red">è¿è¾è½¦çï¼</label> onclick="flushPlateNum()" /> <label class="layui-form-label color-red">è¿è¾è½¦çï¼</label> <div class="layui-input-block"> <input type="text" name="plateNum" id="plateNum" placeholder="æ 车ç车è¾ï¼å¡«å æ 车ç" lay-verify="required" autocomplete="off" class="layui-input rkbk-search-input"> <input type="text" name="plateNum" id="plateNum" placeholder="æ 车ç车è¾ï¼å¡«å æ 车ç" lay-verify="required" autocomplete="off" class="layui-input rkbk-search-input"> </div> </div> <div class="layui-form-item"> <div class="layui-inline"> <label class="layui-form-label">è¿è¾æ¹å¼ï¼</label> <label class="layui-form-label">è¿è¾å·¥å ·ï¼</label> <div class="layui-input-inline"> <input type="radio" name="transType" value="1" title="汽车" checked> <input type="radio" name="transType" value="2" title="ç«è½¦"> <input type="radio" name="transType" value="3" title="è½®è¹"> <input type="radio" name="transType" value="9" title="å ¶ä»"> <input type="radio" name="transType" value="1" title="汽车" checked> <input type="radio" name="transType" value="2" title="ç«è½¦"> <input type="radio" name="transType" value="3" title="è½®è¹"> <input type="radio" name="transType" value="9" title="å ¶ä»"> </div> </div> </div> @@ -317,17 +293,17 @@ <h3>ç»è®°è§é¢</h3> </div> <div class="kccz-r-con2"> <div class="kccz-r-vedio" id="kccz-r-video1"> </div> <div class="kccz-r-vedio" id="kccz-r-video1"></div> <div class="kccz-r-btnbox"> <a href="javascript:;" class="kccz-r-btn kccz-r-btn1 active"> <span class="kccz-r-pz"></span> <div class="kccz-r-div"> <span>æªè¯å«</span> <p>车çè¯å«</p> </a> <a href="javascript:;" class="kccz-r-btn mt-10"> <span id="pz-img" class="kccz-r-img"></span> <p id="pz-text">èªå¨ææ</p> </div> <a href="javascript:;" class="kccz-r-btn kccz-r-btn1 active mt-10"> <span class="kccz-r-pz"></span> <p>ç³»ç»èªå¨ææ</p> </a> </div> </div> </div> @@ -367,7 +343,8 @@ <script th:src="@{../../static/admin/inout/in-register.js}"></script> <!-- å¼¹åºæ¡çä¿¡æ¯ --> <div class="layui-tab-content" id="dialog-from-notify" style="display: none;"> <div class="layui-tab-content" id="dialog-from-notify" style="display: none;"> <table class="layui-table"> <colgroup> <col width="100">