diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/AbstractDriverService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/AbstractDriverService.java index 5513a6a..edae461 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/AbstractDriverService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/AbstractDriverService.java @@ -39,60 +39,14 @@ public class AbstractDriverService implements IDriverService { } - public JSONObject getCommonDeviceInfo(T t) { - JSONObject map = new JSONObject(); - try { - Class tClass = t.getClass(); - Method methodMode = tClass.getMethod("getMode"); - Method methodMove = tClass.getMethod("getMove"); - Integer mode = (Integer) methodMode.invoke(t); - Integer move = (Integer) methodMove.invoke(t); - /* map.put("move",StageActorUtil.getMove(move)); - map.put("hasGoods",StageActorUtil.getHasGoods(move)); - map.put("mode",StageActorUtil.getMode(mode)); - map.put("isOnline",StageActorUtil.getIsOnline(mode));*/ - } catch (NoSuchMethodException e) { - e.printStackTrace(); - } catch (InvocationTargetException e) { - e.printStackTrace(); - } catch (IllegalAccessException e) { - e.printStackTrace(); - } - return map; - } - - public JSONObject getCommonDeviceInfo(T t, int i) { - JSONObject map = new JSONObject(); - try { - Class tClass = t.getClass(); - Method methodMode = tClass.getMethod("getMode"); - Integer mode = (Integer) methodMode.invoke(t); - /* map.put("mode",StageActorUtil.getMode(mode)); - map.put("isOnline",StageActorUtil.getIsOnline(mode));*/ - } catch (NoSuchMethodException e) { - e.printStackTrace(); - } catch (InvocationTargetException e) { - e.printStackTrace(); - } catch (IllegalAccessException e) { - e.printStackTrace(); - } - return map; - } - public JSONObject getCommonDeviceInfo(T t, int i, int j) { JSONObject map = new JSONObject(); try { Class tClass = t.getClass(); - Method methodMode = tClass.getMethod("getMode"); - Method methodMove = tClass.getMethod("getMove"); Method methodGetHasGoods = tClass.getMethod("getHasGoods"); Method methodGetIsonline = tClass.getMethod("getIsonline"); - Integer mode = (Integer) methodMode.invoke(t); - Integer move = (Integer) methodMove.invoke(t); Integer hasGoods = (Integer) methodGetHasGoods.invoke(t); Boolean isOnline = (Boolean) methodGetIsonline.invoke(t); - /* map.put("mode",StageActorUtil.getMode(mode,0)); - map.put("move",StageActorUtil.getMove(move));*/ map.put("hasGoods", hasGoods); map.put("isOnline", isOnline); } catch (NoSuchMethodException e) { diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/IDriverService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/IDriverService.java index 6cc99ae..276788b 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/IDriverService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/IDriverService.java @@ -14,7 +14,10 @@ public interface IDriverService { JSONObject getDeviceInfo(Device device); /** - * 获取db值 + * getDbValue + * @param device + * @param dbName + * @return */ Integer getDbValue(Device device, String dbName); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/StandardOrdinarySiteDevice.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/StandardOrdinarySiteDevice.java index 235e4f5..fddd360 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/StandardOrdinarySiteDevice.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/StandardOrdinarySiteDevice.java @@ -16,7 +16,6 @@ public class StandardOrdinarySiteDevice extends AbstractDriverService { public JSONObject getDeviceInfo(Device device) { StandardOrdinarySiteDeviceDriver standardOrdinarySiteDeviceDriver = (StandardOrdinarySiteDeviceDriver) device.getDeviceDriver(); JSONObject jo = new JSONObject(); -// jo.put("move", StageActorUtil.getMove(standardOrdinarySiteDeviceDriver.getHasGoods())); jo.put("container", standardOrdinarySiteDeviceDriver.getContainer()); jo.put("hasGoods", standardOrdinarySiteDeviceDriver.getHasGoods()); jo.put("isOnline", true); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/base/CommonMapper.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/base/CommonMapper.java index b074fae..f5f8dd7 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/base/CommonMapper.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/base/CommonMapper.java @@ -16,18 +16,35 @@ import org.apache.ibatis.annotations.Mapper; */ @Mapper public interface CommonMapper extends BaseMapper { + /** + * 查询 + * @return + */ default QueryChainWrapper query() { return ChainWrappers.queryChain(this); } + /** + * lambdaQuery + * @return + */ default LambdaQueryChainWrapper lambdaQuery() { return ChainWrappers.lambdaQueryChain(this); } + /** + * 更新 + * @return + */ default UpdateChainWrapper update() { return ChainWrappers.updateChain(this); } + /** + * lambdaUpdate + * @return + */ + default LambdaUpdateChainWrapper lambdaUpdate() { return ChainWrappers.lambdaUpdateChain(this); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/base/QueryHelpMybatisPlus.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/base/QueryHelpMybatisPlus.java index 74d45de..1fe773d 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/base/QueryHelpMybatisPlus.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/common/base/QueryHelpMybatisPlus.java @@ -20,7 +20,13 @@ import java.util.List; @Slf4j public class QueryHelpMybatisPlus { - // TODO DataPermission + /** + * + * @param query + * @param + * @param + * @return + */ public static QueryWrapper getPredicate(Q query) { QueryWrapper queryWrapper = new QueryWrapper<>(); if (query == null) { @@ -47,7 +53,6 @@ public class QueryHelpMybatisPlus { // 模糊多字段 if (ObjectUtil.isNotEmpty(blurry)) { String[] blurrys = blurry.split(","); - //queryWrapper.or(); queryWrapper.and(wrapper -> { for (String blurry1 : blurrys) { String column = humpToUnderline(blurry1); @@ -62,7 +67,6 @@ public class QueryHelpMybatisPlus { String finalAttributeName = attributeName; switch (q.type()) { case EQUAL: - //queryWrapper.and(wrapper -> wrapper.eq(finalAttributeName, val)); queryWrapper.eq(attributeName, val); break; case GREATER_THAN: @@ -88,11 +92,6 @@ public class QueryHelpMybatisPlus { queryWrapper.in(finalAttributeName, (Collection) val); } break; -// case NOT_IN: -// if (CollUtil.isNotEmpty((Collection) val)) { -// queryWrapper.notIn(finalAttributeName, (Collection) val); -// } -// break; case NOT_EQUAL: queryWrapper.ne(finalAttributeName, val); break; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/DequeCustomerDeviceStrategy.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/DequeCustomerDeviceStrategy.java index 6610fba..4718fe5 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/DequeCustomerDeviceStrategy.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/DequeCustomerDeviceStrategy.java @@ -16,16 +16,18 @@ public class DequeCustomerDeviceStrategy implements DeviceStrategy { public DequeCustomerDeviceStrategy() { } + @Override public String getCode() { return DequeCustomerDeviceStrategy.class.getSimpleName(); } + @Override public String getName() { return "自定义队列策略"; } + @Override public WaitingInstructionDeque strategy(List instructions, String device_code) { - //WaitingInstructionDeque deque = this.instructionService.findWaitingInstructionDequeByDeviceCode(device_code); System.out.println("自定义队列策略"); Map> factory = new HashMap(); @@ -45,14 +47,12 @@ public class DequeCustomerDeviceStrategy implements DeviceStrategy { List sort_keys = new LinkedList(); sort_keys.addAll(keys); Collections.sort(sort_keys); -// SortUtlEx.sort(sort_keys, this.comparator); Iterator var12 = sort_keys.iterator(); while (var12.hasNext()) { String string = (String) var12.next(); List list2 = (List) factory.get(string); if (list2 != null && list2.size() > 0) { - //deque.offerIfNotExists((Instruction)list2.get(0)); } } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/DequeDefaultDeviceStrategy.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/DequeDefaultDeviceStrategy.java index 9ea5d8b..b6f6d3f 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/DequeDefaultDeviceStrategy.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/DequeDefaultDeviceStrategy.java @@ -17,16 +17,18 @@ public class DequeDefaultDeviceStrategy implements DeviceStrategy { public DequeDefaultDeviceStrategy() { } + @Override public String getCode() { return DequeDefaultDeviceStrategy.class.getSimpleName(); } + @Override public String getName() { return "默认队列策略"; } + @Override public WaitingInstructionDeque strategy(List instructions, String device_code) { - //WaitingInstructionDeque deque = this.instructionService.findWaitingInstructionDequeByDeviceCode(device_code); System.out.println("默认队列策略"); Map> factory = new HashMap(); @@ -46,14 +48,12 @@ public class DequeDefaultDeviceStrategy implements DeviceStrategy { List sort_keys = new LinkedList(); sort_keys.addAll(keys); Collections.sort(sort_keys); -// SortUtlEx.sort(sort_keys, this.comparator); Iterator var12 = sort_keys.iterator(); while (var12.hasNext()) { String string = (String) var12.next(); List list2 = (List) factory.get(string); if (list2 != null && list2.size() > 0) { - //deque.offerIfNotExists((Instruction)list2.get(0)); } } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/DeviceStrategy.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/DeviceStrategy.java index 825aae0..d7f66cf 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/DeviceStrategy.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/DeviceStrategy.java @@ -5,10 +5,24 @@ import org.nl.acs.instruction.domain.Instruction; import java.util.List; public interface DeviceStrategy { + /** + * 获取名称 + * @return + */ String getName(); + /** + * 获取Code + * @return + */ String getCode(); + /** + * 策略 + * @param instructions + * @param device_code + * @return + */ default WaitingInstructionDeque strategy(List instructions, String device_code) { throw new RuntimeException("未实现"); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/StackerStrategyDto.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/StackerStrategyDto.java index 9bf7875..26124e0 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/StackerStrategyDto.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/StackerStrategyDto.java @@ -5,9 +5,13 @@ import java.util.List; public class StackerStrategyDto { private String deviceCode; - //策略 + /** + * 策略 + */ private List plan = new ArrayList(); - //禁止策略 暂时未开发 + /** + * 禁止策略 暂时未开发 + */ private List forbid = new ArrayList(); public StackerStrategyDto() { diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/StockinFirstDeviceStrategy.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/StockinFirstDeviceStrategy.java index 6cee311..ee112c3 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/StockinFirstDeviceStrategy.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/StockinFirstDeviceStrategy.java @@ -16,16 +16,18 @@ public class StockinFirstDeviceStrategy implements DeviceStrategy { public StockinFirstDeviceStrategy() { } + @Override public String getCode() { return StockinFirstDeviceStrategy.class.getSimpleName(); } + @Override public String getName() { return "入库优先策略"; } + @Override public WaitingInstructionDeque strategy(List instructions, String device_code) { - //WaitingInstructionDeque deque = this.instructionService.findWaitingInstructionDequeByDeviceCode(device_code); System.out.println("入库优先策略"); Map> factory = new HashMap(); @@ -45,14 +47,12 @@ public class StockinFirstDeviceStrategy implements DeviceStrategy { List sort_keys = new LinkedList(); sort_keys.addAll(keys); Collections.sort(sort_keys); -// SortUtlEx.sort(sort_keys, this.comparator); Iterator var12 = sort_keys.iterator(); while (var12.hasNext()) { String string = (String) var12.next(); List list2 = (List) factory.get(string); if (list2 != null && list2.size() > 0) { - //deque.offerIfNotExists((Instruction)list2.get(0)); } } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/StockoutFirstDeviceStrategy.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/StockoutFirstDeviceStrategy.java index 1051f45..adb2302 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/StockoutFirstDeviceStrategy.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/StockoutFirstDeviceStrategy.java @@ -16,16 +16,18 @@ public class StockoutFirstDeviceStrategy implements DeviceStrategy { public StockoutFirstDeviceStrategy() { } + @Override public String getCode() { return StockoutFirstDeviceStrategy.class.getSimpleName(); } + @Override public String getName() { return "出库优先策略"; } + @Override public WaitingInstructionDeque strategy(List instructions, String device_code) { - //WaitingInstructionDeque deque = this.instructionService.findWaitingInstructionDequeByDeviceCode(device_code); System.out.println("出库优先策略"); Map> factory = new HashMap(); @@ -45,14 +47,12 @@ public class StockoutFirstDeviceStrategy implements DeviceStrategy { List sort_keys = new LinkedList(); sort_keys.addAll(keys); Collections.sort(sort_keys); -// SortUtlEx.sort(sort_keys, this.comparator); Iterator var12 = sort_keys.iterator(); while (var12.hasNext()) { String string = (String) var12.next(); List list2 = (List) factory.get(string); if (list2 != null && list2.size() > 0) { - //deque.offerIfNotExists((Instruction)list2.get(0)); } } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/rest/CustomPolicyController.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/rest/CustomPolicyController.java index 4e65afa..53653ba 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/rest/CustomPolicyController.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/rest/CustomPolicyController.java @@ -77,8 +77,8 @@ public class CustomPolicyController { } @GetMapping("/updateOn") - @Log("自定义策略列表") - @ApiOperation("自定义策略列表") + @Log("是否启用") + @ApiOperation("是否启用") public ResponseEntity updateOn(@RequestParam Long id, @RequestParam Integer is_on) { customPolicyService.updateOn(id, is_on); return new ResponseEntity<>(HttpStatus.OK); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/CustomPolicyService.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/CustomPolicyService.java index 4581c9b..1d4bebb 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/CustomPolicyService.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/CustomPolicyService.java @@ -17,21 +17,56 @@ import java.util.Map; */ public interface CustomPolicyService extends CommonService { + /** + * 分页查询 + * @param whereJson + * @param page + * @return + */ PageInfo queryAll(Map whereJson, Pageable page); + /** + * 新增 + * @param dto + */ void create(CustomPolicyDTO dto); + /** + * 更新 + * @param dto + */ void update(CustomPolicyDTO dto); + /** + * 删除 + * @param ids + */ void deleteAll(String[] ids); + /** + * 新增自定义策略 + * @param customPolicyPlantVO + */ void createPlant(CustomPolicyPlantVO customPolicyPlantVO); + /** + * 自定义策略列表 + * @param id + * @return + */ CustomPolicyPlantVO plantList(Long id); + /** + * 是否启用 + * @param id + * @param is_on + */ void updateOn(Long id, Integer is_on); - DeviceStrategy findByCode(String var1); + /** + * 获取设备策略 + * @return + */ List findDeviceStrategyOption(); } diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/enums/CustomPolicyTaskTypeEnum.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/enums/CustomPolicyTaskTypeEnum.java index b0d4dc2..803b1c8 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/enums/CustomPolicyTaskTypeEnum.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/enums/CustomPolicyTaskTypeEnum.java @@ -7,11 +7,21 @@ package org.nl.acs.custompolicy.server.enums; import lombok.AllArgsConstructor; import lombok.Getter; + @Getter @AllArgsConstructor public enum CustomPolicyTaskTypeEnum { + /** + * 入库 + */ IN(1, "入库"), + /** + * 出库 + */ OUT(2, "出库"), + /** + * 移库 + */ MOVE(3, "移库"); Integer code; diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/impl/CustomPolicyServiceImpl.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/impl/CustomPolicyServiceImpl.java index e735570..1638e09 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/impl/CustomPolicyServiceImpl.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/impl/CustomPolicyServiceImpl.java @@ -143,7 +143,7 @@ public class CustomPolicyServiceImpl extends CommonServiceImpl strategys = this.findAllDeviceStrategy(); Iterator var3 = strategys.iterator(); @@ -160,6 +160,7 @@ public class CustomPolicyServiceImpl extends CommonServiceImpl findDeviceStrategyOption() { List strategys = this.findAllDeviceStrategy(); List strings = new ArrayList<>(); diff --git a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/mapper/CustomPolicyMapper.java b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/mapper/CustomPolicyMapper.java index 2aff3cc..628f557 100644 --- a/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/mapper/CustomPolicyMapper.java +++ b/acs/nladmin-system/nlsso-server/src/main/java/org/nl/acs/custompolicy/server/mapper/CustomPolicyMapper.java @@ -16,5 +16,9 @@ import java.util.Set; @Repository public interface CustomPolicyMapper extends CommonMapper { + /** + * 批量更新 + * @param idsSet + */ void upBatchIds(@Param("ids") Set idsSet); }