diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/base/CommonFinalParam.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/base/CommonFinalParam.java index bb66ffb..9624160 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/base/CommonFinalParam.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/base/CommonFinalParam.java @@ -12,6 +12,11 @@ import org.springframework.stereotype.Component; public class CommonFinalParam { private final String DELETE = "0"; + /** + * 分隔符 + */ + private final String BARRE = "-"; + private final String POINT = "."; /** * 开门 */ diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/device_driver/DeviceDriverConfigDto.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/device_driver/DeviceDriverConfigDto.java index 9a3b070..b4c669f 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/device_driver/DeviceDriverConfigDto.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/device_driver/DeviceDriverConfigDto.java @@ -1,21 +1,32 @@ package org.nl.acs.device.device_driver; +import lombok.Data; import org.nl.acs.device.service.dto.DeviceExtraDto; import java.util.List; import java.util.Map; - +@Data public class DeviceDriverConfigDto { - //设备驱动类型 + /** + * 设备驱动类型 + */ private String type; - //设备标识 + /** + * 设备标识 + */ private String device_id; - //设备编码 + /** + * 设备编码 + */ private String device_code; - //扩展属性 + /** + * 扩展属性 + */ private List exaList; - //设备读db块列表 + /** + * 设备读db块列表 + */ private List dbReadList; private List dbWriteList; } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/device_driver/DriverTypeEnum.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/device_driver/DriverTypeEnum.java index bdbf284..28e9973 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/device_driver/DriverTypeEnum.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/device_driver/DriverTypeEnum.java @@ -43,18 +43,27 @@ public enum DriverTypeEnum { DOUBLE_STATION_STACKER(16, "double_station_stacker", "标准版-双工位堆垛机", "double_station_stacker"); - //驱动索引 + /** + * 驱动索引 + */ private int index; - //驱动编码 + /** + * 驱动编码 + */ private String code; - // 驱动名字 + /** + * 驱动名字 + */ private String name; - //驱动描述 + /** + * 驱动描述 + */ private String desc; - //设备驱动类型 + /** + * 设备驱动类型 + */ private String type; - // 构造方法 DriverTypeEnum(int index, String code, String name, String type) { this.index = index; this.code = code; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/device_driver/standard_inspect/ItemProtocol.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/device_driver/standard_inspect/ItemProtocol.java index 0728746..24304d7 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/device_driver/standard_inspect/ItemProtocol.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/device_driver/standard_inspect/ItemProtocol.java @@ -5,7 +5,6 @@ import lombok.extern.slf4j.Slf4j; import java.util.ArrayList; import java.util.List; -//RD3.RD3.225.to_command @Slf4j public class ItemProtocol { public static String item_heartbeat = "heartbeat"; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceController.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceController.java index 04aa0cf..ca3cf63 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceController.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceController.java @@ -41,17 +41,9 @@ public class DeviceController { private final DeviceService deviceService; - @Autowired - private DeviceMappers deviceMappers; - /* - @Log("导出设备服务") - @ApiOperation("导出设备服务") - @GetMapping(value = "/download") - //@PreAuthorize("@el.check('device:list')") - public void download(HttpServletResponse response, DeviceQueryParam query) throws IOException { - deviceService.download(deviceService.queryAll(query), response); - }*/ + + @GetMapping @Log("查询设备") @ApiOperation("查询设备") diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceErpmappingController.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceErpmappingController.java index 7eacd8a..669144c 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceErpmappingController.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceErpmappingController.java @@ -31,7 +31,6 @@ public class DeviceErpmappingController { @GetMapping @Log("查询设备-ERP映射") @ApiOperation("查询设备-ERP映射") - //@PreAuthorize("@el.check('acsDeviceErpmapping:list')") public ResponseEntity query(@RequestParam Map whereJson, Pageable page) { return new ResponseEntity<>(acsDeviceErpmappingService.queryAll(whereJson, page), HttpStatus.OK); } @@ -39,7 +38,6 @@ public class DeviceErpmappingController { @PostMapping @Log("新增设备-ERP映射") @ApiOperation("新增设备-ERP映射") - //@PreAuthorize("@el.check('acsDeviceErpmapping:add')") public ResponseEntity create(@Validated @RequestBody AcsDeviceErpmappingDto dto) { acsDeviceErpmappingService.create(dto); return new ResponseEntity<>(HttpStatus.CREATED); @@ -48,7 +46,6 @@ public class DeviceErpmappingController { @PutMapping @Log("修改设备-ERP映射") @ApiOperation("修改设备-ERP映射") - //@PreAuthorize("@el.check('acsDeviceErpmapping:edit')") public ResponseEntity update(@Validated @RequestBody AcsDeviceErpmappingDto dto) { acsDeviceErpmappingService.update(dto); return new ResponseEntity<>(HttpStatus.NO_CONTENT); @@ -56,7 +53,6 @@ public class DeviceErpmappingController { @Log("删除设备-ERP映射") @ApiOperation("删除设备-ERP映射") - //@PreAuthorize("@el.check('acsDeviceErpmapping:del')") @DeleteMapping public ResponseEntity delete(@RequestBody String[] ids) { acsDeviceErpmappingService.deleteAll(ids); @@ -66,7 +62,6 @@ public class DeviceErpmappingController { @Log("导出设备-ERP映射") @ApiOperation("导出设备-ERP映射") @GetMapping(value = "/download") - //@PreAuthorize("@el.check('acsDeviceErpmapping:list')") public void download(HttpServletResponse response, @RequestParam Map whereJson) throws IOException { acsDeviceErpmappingService.download(acsDeviceErpmappingService.queryAll(whereJson), response); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceExtraController.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceExtraController.java index 743cf3e..5913e67 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceExtraController.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceExtraController.java @@ -30,7 +30,6 @@ public class DeviceExtraController { @GetMapping @Log("查询设备扩展") @ApiOperation("查询设备扩展") - //@PreAuthorize("@el.check('deviceExtra:list')") public ResponseEntity query(DeviceExtraQueryParam query, Pageable pageable) { return new ResponseEntity<>(deviceExtraService.queryAll(query, pageable), HttpStatus.OK); } @@ -38,7 +37,6 @@ public class DeviceExtraController { @PostMapping @Log("新增设备扩展") @ApiOperation("新增设备扩展") - //@PreAuthorize("@el.check('deviceExtra:add')") public ResponseEntity create(@Validated @RequestBody DeviceExtraDto resources) { return new ResponseEntity<>(deviceExtraService.insert(resources), HttpStatus.CREATED); } @@ -46,7 +44,6 @@ public class DeviceExtraController { @PutMapping @Log("修改设备扩展") @ApiOperation("修改设备扩展") - //@PreAuthorize("@el.check('deviceExtra:edit')") public ResponseEntity update(@Validated @RequestBody DeviceExtraDto resources) { deviceExtraService.updateById(resources); return new ResponseEntity<>(HttpStatus.NO_CONTENT); @@ -55,7 +52,6 @@ public class DeviceExtraController { @DeleteMapping @Log("删除设备扩展") @ApiOperation("删除设备扩展") - //@PreAuthorize("@el.check('deviceExtra:del')") public ResponseEntity delete(@RequestBody Set ids) { deviceExtraService.removeByIds(ids); return new ResponseEntity<>(HttpStatus.OK); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceRunpointController.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceRunpointController.java index d1781e0..6eff3db 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceRunpointController.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceRunpointController.java @@ -29,7 +29,6 @@ public class DeviceRunpointController { @GetMapping @Log("查询设备点位") @ApiOperation("查询设备点位") - //@PreAuthorize("@el.check('deviceRunpoint:list')") public ResponseEntity query(DeviceRunpointQueryParam query, Pageable pageable) { return new ResponseEntity<>(deviceRunpointService.queryAll(query, pageable), HttpStatus.OK); } @@ -37,7 +36,6 @@ public class DeviceRunpointController { @PostMapping @Log("新增设备点位") @ApiOperation("新增设备点位") - //@PreAuthorize("@el.check('deviceRunpoint:add')") public ResponseEntity create(@Validated @RequestBody DeviceRunpointDto resources) { return new ResponseEntity<>(deviceRunpointService.insert(resources), HttpStatus.CREATED); } @@ -45,7 +43,6 @@ public class DeviceRunpointController { @PutMapping @Log("修改设备点位") @ApiOperation("修改设备点位") - //@PreAuthorize("@el.check('deviceRunpoint:edit')") public ResponseEntity update(@Validated @RequestBody DeviceRunpointDto resources) { deviceRunpointService.updateById(resources); return new ResponseEntity<>(HttpStatus.NO_CONTENT); @@ -54,7 +51,6 @@ public class DeviceRunpointController { @DeleteMapping @Log("删除设备点位") @ApiOperation("删除设备点位") - //@PreAuthorize("@el.check('deviceRunpoint:del')") public ResponseEntity delete(@RequestBody Set ids) { deviceRunpointService.removeByIds(ids); return new ResponseEntity<>(HttpStatus.OK); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceisonlineController.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceisonlineController.java index c9daf60..c585e02 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceisonlineController.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/rest/DeviceisonlineController.java @@ -29,7 +29,6 @@ public class DeviceisonlineController { @GetMapping @Log("查询设备在线状态") @ApiOperation("查询设备在线状态") - //@PreAuthorize("@el.check('deviceisonline:list')") public ResponseEntity query(DeviceisonlineQueryParam query, Pageable pageable) { return new ResponseEntity<>(deviceisonlineService.queryAll(query, pageable), HttpStatus.OK); } @@ -37,7 +36,6 @@ public class DeviceisonlineController { @PostMapping @Log("新增设备在线状态") @ApiOperation("新增设备在线状态") - //@PreAuthorize("@el.check('deviceisonline:add')") public ResponseEntity create(@Validated @RequestBody DeviceisonlineDto resources) { return new ResponseEntity<>(deviceisonlineService.insert(resources), HttpStatus.CREATED); } @@ -45,7 +43,6 @@ public class DeviceisonlineController { @PutMapping @Log("修改设备在线状态") @ApiOperation("修改设备在线状态") - //@PreAuthorize("@el.check('deviceisonline:edit')") public ResponseEntity update(@Validated @RequestBody DeviceisonlineDto resources) { deviceisonlineService.updateById(resources); return new ResponseEntity<>(HttpStatus.NO_CONTENT); @@ -54,7 +51,6 @@ public class DeviceisonlineController { @DeleteMapping @Log("删除设备在线状态") @ApiOperation("删除设备在线状态") - //@PreAuthorize("@el.check('deviceisonline:del')") public ResponseEntity delete(@RequestBody Set ids) { deviceisonlineService.removeByIds(ids); return new ResponseEntity<>(HttpStatus.OK); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/DeviceService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/DeviceService.java index 02307a1..444189c 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/DeviceService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/DeviceService.java @@ -186,8 +186,8 @@ public interface DeviceService extends CommonService { JSONArray selectConveyorList(); /** - * 根据区域查询设备 - * + * 通过region获取device + * @param region * @return */ JSONArray selectDeviceListByRegion(String region); @@ -264,6 +264,10 @@ public interface DeviceService extends CommonService { */ void responseAgv(JSONObject form); + /** + * 自动创建任务 + * @param json + */ void autoCreateTask(JSONObject json); /** @@ -273,46 +277,84 @@ public interface DeviceService extends CommonService { */ void unlock(List deviceCodes); + /** + * 清理任务 + * @param json + */ void cleanTask(JSONObject json); + /** + * 清理材料 + * @param json + */ void cleanMaterial(JSONObject json); /** * 根据设备标识查询设备驱动配置,如果未配置过,就从驱动配置定义找,否则从数据库里面找 - * * @param device_id + * @param driver_code + * @return */ JSONObject queryDriverConfigByDeviceId(String device_id, String driver_code); /** * DB测试读 - * + * @param map * @return */ JSONArray testRead(Map map); /** * DB测试写 - * - * @return + * @param map */ void testWrite(Map map); + /** + * 导出设备协议 + * @param queryDeviceProtocol + * @param response + */ void downDeviceDBloadCSV(JSONArray queryDeviceProtocol, HttpServletResponse response); + /** + * 导出文件 + * @param queryDeviceProtocol + * @param response + */ void downDeviceDBloadOumulongCSV(JSONArray queryDeviceProtocol, HttpServletResponse response); + /** + * 根据设备类型查询已配置设备 + * @param type + * @return + */ JSONArray selectDeviceListByType(String type); /** * 根据货架号,查询扩展信息 + * @param device_code + * @return */ JSONObject queryStorageExtra(String device_code); + /** + * 查询条码 + * @param code + * @return + * @throws Exception + */ String queryScannerByCode(String code) throws Exception; + /** + * 加载货位信息 + */ void reload(); + /** + * 查找所有货位 + * @return + */ List queryAllStorageCell(); /** @@ -322,18 +364,38 @@ public interface DeviceService extends CommonService { */ List findAllStorageCellFromCache(); + /** + * 根据code获取地址 + * @param code + * @return + */ int queryAddressBydeviceCode(String code); + /** + * 根据地址获取货位编码 + * @param address + * @return + */ String queryDeviceCodeByAddress(int address); + /** + * 获取缓存设备 + * @return + */ List findCacheDevice(); + /** + * 更新条码 + * @param json + * @throws Exception + */ void updateBarcode(JSONObject json) throws Exception; /** * 根据驱动编码获取db信息 * * @param driver_code + * @return */ JSONObject queryDBInfoByDriverCode(String driver_code); @@ -346,8 +408,18 @@ public interface DeviceService extends CommonService { */ void downloadProtocolConfig(JSONObject whereJson, HttpServletResponse response) throws IOException; + /** + * 导出Smart设备协议CSV + * @param queryDeviceProtocol + * @param response + */ void downDeviceDBloadSmartCSV(JSONArray queryDeviceProtocol, HttpServletResponse response); + /** + * 导出FX5U设备协议CSV + * @param queryDeviceProtocol + * @param response + */ void downDeviceDBloadFX5UCSV(JSONArray queryDeviceProtocol, HttpServletResponse response); /** @@ -361,8 +433,8 @@ public interface DeviceService extends CommonService { /** * 下拉框查询设备驱动 - * * @param device_code + * @return */ JSONArray selectDriverCodeList(String device_code); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/impl/DeviceErpmappingServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/impl/DeviceErpmappingServiceImpl.java index ea909c3..c99e57f 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/impl/DeviceErpmappingServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/impl/DeviceErpmappingServiceImpl.java @@ -40,11 +40,9 @@ import java.util.*; */ @Service @AllArgsConstructor -// @CacheConfig(cacheNames = DeviceErpmappingService.CACHE_KEY) @Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class) public class DeviceErpmappingServiceImpl extends CommonServiceImpl implements DeviceErpmappingService { - // private final RedisUtils redisUtils; private final DeviceErpmappingMapper deviceErpmappingMapper; private final DeviceMapper deviceMapper; @@ -66,7 +64,6 @@ public class DeviceErpmappingServiceImpl extends CommonServiceImpl implements DeviceExtraService { - // private final RedisUtils redisUtils; private final DeviceExtraMapper deviceExtraMapper; @Override @@ -66,7 +64,6 @@ public class DeviceExtraServiceImpl extends CommonServiceImpl implements DeviceRunpointService { - // private final RedisUtils redisUtils; private final DeviceRunpointMapper deviceRunpointMapper; @Override @@ -50,7 +48,6 @@ public class DeviceRunpointServiceImpl extends CommonServiceImpl ids) { - // delCaches(ids); return deviceRunpointMapper.deleteBatchIds(ids); } @@ -86,39 +81,4 @@ public class DeviceRunpointServiceImpl extends CommonServiceImpl ids) { - for (String id: ids) { - delCaches(id); - } - }*/ - - /* - @Override - public void download(List all, HttpServletResponse response) throws IOException { - List> list = new ArrayList<>(); - for (DeviceRunpointDto deviceRunpoint : all) { - Map map = new LinkedHashMap<>(); - map.put("设备编码", deviceRunpoint.getDeviceCode()); - map.put("有货状态", deviceRunpoint.getHasgoods()); - map.put("载具号", deviceRunpoint.getContainer()); - map.put("任务号", deviceRunpoint.getTaskno()); - map.put("备注", deviceRunpoint.getRemark()); - map.put("是否启用", deviceRunpoint.getIsActive()); - map.put("是否删除", deviceRunpoint.getIsDelete()); - map.put("创建者", deviceRunpoint.getCreateBy()); - map.put("创建时间", deviceRunpoint.getCreateTime()); - map.put("修改者", deviceRunpoint.getUpdateBy()); - map.put("修改时间", deviceRunpoint.getUpdateTime()); - map.put("物料类型", deviceRunpoint.getMaterialType()); - map.put("批次", deviceRunpoint.getBatch()); - map.put("锁定", deviceRunpoint.getIslock()); - list.add(map); - } - FileUtil.downloadExcel(list, response); - }*/ } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/impl/DeviceServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/impl/DeviceServiceImpl.java index aebf5a5..2282eb6 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/impl/DeviceServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/impl/DeviceServiceImpl.java @@ -94,26 +94,20 @@ import java.util.*; @Service @AllArgsConstructor @Slf4j -// @CacheConfig(cacheNames = DeviceService.CACHE_KEY) @Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class) public class DeviceServiceImpl extends CommonServiceImpl implements DeviceService, ApplicationAutoInitial { - // private final RedisUtils redisUtils; private final DeviceMapper deviceMapper; private final RouteLineMapper routeLineMapper; - // private final StageActorMapper stageActorMapper; private final StorageCellMapper storageCellMapper; private final DeviceExtraMapper deviceExtraMapper; private final DeviceRunpointMapper deviceRunpointMapper; - private final StageMapper stageMapper; private final DeviceExtraService deviceExtraService; private final OpcService opcService; - private final RedisUtils redisUtils; private final OpcPlcService opcPlcService; private final DeviceDriverDefinationAppService deviceDriverDefinationAppService; private final DeviceAppService deviceAppService; - private final ISysParamService paramService; private final ISysDictService iSysDictService; List storageCells = new ArrayList<>(); @@ -948,9 +942,10 @@ public class DeviceServiceImpl extends CommonServiceImpl i @Override public void changeDeviceStatus(JSONObject form) { + CommonFinalParam commonFinalParam = new CommonFinalParam(); String device_code = form.getString("device_code"); - if (StrUtil.contains(device_code, "-") && StrUtil.count(device_code, "-") == 2) { - String[] point = device_code.split("-"); + if (StrUtil.contains(device_code, commonFinalParam.getBARRE()) && StrUtil.count(device_code, commonFinalParam.getBARRE()) == 2) { + String[] point = device_code.split(commonFinalParam.getBARRE()); device_code = point[0]; } //需要数量 @@ -966,7 +961,7 @@ public class DeviceServiceImpl extends CommonServiceImpl i String islock = form.getString("islock"); String requireSucess = form.getString("requireSucess"); String fullrequireSucess = form.getString("fullrequireSucess"); - if (device_code.indexOf(".") != -1) { + if (device_code.indexOf(commonFinalParam.getPOINT()) != -1) { device_code = device_code.substring(0, device_code.indexOf(".")); } Device device = deviceAppService.findDeviceByCode(device_code); @@ -1644,7 +1639,7 @@ public class DeviceServiceImpl extends CommonServiceImpl i } /** - * 加载货位信息 + * 加载货位信息 */ @Override public void reload() { diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/impl/DeviceisonlineServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/impl/DeviceisonlineServiceImpl.java index 05f14ed..2f56784 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/impl/DeviceisonlineServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/impl/DeviceisonlineServiceImpl.java @@ -25,11 +25,9 @@ import java.util.*; */ @Service @AllArgsConstructor -// @CacheConfig(cacheNames = DeviceisonlineService.CACHE_KEY) @Transactional(propagation = Propagation.SUPPORTS, readOnly = true, rollbackFor = Exception.class) public class DeviceisonlineServiceImpl extends CommonServiceImpl implements DeviceisonlineService { - // private final RedisUtils redisUtils; private final DeviceisonlineMapper deviceisonlineMapper; @Override @@ -50,7 +48,6 @@ public class DeviceisonlineServiceImpl extends CommonServiceImpl { - String queryDeviceProtocolSql = "SELECT " + + String QUERY_DEVICE_PROTOCOL_SQL = "SELECT " + "d.device_id AS device_id," + "d.device_code AS device_code," + "d.driver_code AS driver_code," + @@ -31,7 +31,7 @@ public interface DeviceExtraMapper extends CommonMapper { "LEFT JOIN acs_device d ON e.device_id = d.device_id " + "LEFT JOIN acs_opc opc ON d.opc_server_id = opc.opc_id " + "LEFT JOIN acs_opc_plc plc ON d.opc_plc_id = plc.plc_id "; - String wrapperDeviceProtocolSql = queryDeviceProtocolSql + " ${ew.customSqlSegment} " + "ORDER BY d.device_code,e.extra_name"; + String WRAPPER_DEVICE_PROTOCOL_SQL = QUERY_DEVICE_PROTOCOL_SQL + " ${ew.customSqlSegment} " + "ORDER BY d.device_code,e.extra_name"; /** * 设备协议分页查询 @@ -40,7 +40,7 @@ public interface DeviceExtraMapper extends CommonMapper { * @param

* @return */ - @Select(wrapperDeviceProtocolSql) + @Select(WRAPPER_DEVICE_PROTOCOL_SQL)

> P queryDeviceProtocolPage(P page, @Param("ew") Wrapper queryWrapper); /** @@ -48,7 +48,7 @@ public interface DeviceExtraMapper extends CommonMapper { * @param queryWrapper * @return */ - @Select(wrapperDeviceProtocolSql) + @Select(WRAPPER_DEVICE_PROTOCOL_SQL) List selectDeviceProtocolList(@Param("ew") Wrapper queryWrapper); /** diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/mapper/DeviceMapper.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/mapper/DeviceMapper.java index 450740f..3fd6369 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/mapper/DeviceMapper.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device/service/mapper/DeviceMapper.java @@ -14,18 +14,22 @@ import org.springframework.stereotype.Repository; */ @Repository public interface DeviceMapper extends CommonMapper { - String queryDeviceSql = "SELECT d.*, dict.label AS device_type_name, dict2.label AS region_name " + + String QUERY_DEVICE_SQL = "SELECT d.*, dict.label AS device_type_name, dict2.label AS region_name " + "FROM " + "ACS_DEVICE d " + "LEFT JOIN sys_dict dict ON dict.value = d.device_type " + "AND dict.`code` = 'device_type' " + "LEFT JOIN sys_dict dict2 ON dict2.value = d.region " + "AND dict2.`code` = 'region_type' "; - String wrapperDeviceSql = queryDeviceSql + " ${ew.customSqlSegment}"; + String WRAPPER_DEVICE_SQL = QUERY_DEVICE_SQL + " ${ew.customSqlSegment}"; /** * 分页查询 + * @param page + * @param queryWrapper + * @param

+ * @return */ - @Select(wrapperDeviceSql) + @Select(WRAPPER_DEVICE_SQL)

> P queryPage(P page, @Param("ew") Wrapper queryWrapper); }