package com.zy.asrs.task.support;
|
|
import com.alibaba.fastjson.JSON;
|
import com.core.common.Cools;
|
import com.zy.system.entity.Config;
|
import com.zy.system.service.ConfigService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.LinkedHashSet;
|
import java.util.List;
|
|
@Slf4j
|
@Service
|
public class AutoFrontLocMoveConfigResolver {
|
|
public static final String CONFIG_CODE = "AutoFrontLocMove";
|
|
private static final int DEFAULT_INTERVAL_SECONDS = 60;
|
private static final long DEFAULT_USER_ID = 9527L;
|
|
@Autowired
|
private ConfigService configService;
|
|
/**
|
* 从 sys_config 读取 JSON 配置。
|
* 配置缺失、停用或解析失败时，回退成“关闭状态”的默认配置。
|
*/
|
public AutoFrontLocMoveSettings resolve() {
|
AutoFrontLocMoveSettings settings = defaults();
|
Config config = configService.selectConfigByCode(CONFIG_CODE);
|
if (!isConfigEnabled(config)) {
|
return settings;
|
}
|
try {
|
AutoFrontLocMoveSettings parsed = JSON.parseObject(config.getValue(), AutoFrontLocMoveSettings.class);
|
if (parsed == null) {
|
return settings;
|
}
|
normalize(parsed);
|
return parsed;
|
} catch (Exception e) {
|
log.error("前排补货移库配置解析失败，code={}, value={}", CONFIG_CODE, config.getValue(), e);
|
return settings;
|
}
|
}
|
|
AutoFrontLocMoveSettings defaults() {
|
AutoFrontLocMoveSettings settings = new AutoFrontLocMoveSettings();
|
settings.setEnabled(false);
|
settings.setIntervalSeconds(DEFAULT_INTERVAL_SECONDS);
|
settings.setUserId(DEFAULT_USER_ID);
|
settings.setRules(new ArrayList<>());
|
return settings;
|
}
|
|
void normalize(AutoFrontLocMoveSettings settings) {
|
if (settings.getIntervalSeconds() == null || settings.getIntervalSeconds() <= 0) {
|
settings.setIntervalSeconds(DEFAULT_INTERVAL_SECONDS);
|
}
|
if (settings.getUserId() == null || settings.getUserId() <= 0L) {
|
settings.setUserId(DEFAULT_USER_ID);
|
}
|
List<AutoFrontLocMoveSettings.Rule> normalizedRules = new ArrayList<>();
|
if (!Cools.isEmpty(settings.getRules())) {
|
for (AutoFrontLocMoveSettings.Rule rule : settings.getRules()) {
|
if (rule == null || rule.getCrnNo() == null) {
|
continue;
|
}
|
List<Integer> frontRows = parseRows(rule.getFrontRows());
|
if (frontRows.isEmpty()) {
|
continue;
|
}
|
// 解析结果预先挂在 rule 上，调度执行时直接使用，避免每次扫描重复拆字符串。
|
rule.setFrontRowList(frontRows);
|
rule.setSourceRowList(parseRows(rule.getSourceRows()));
|
normalizedRules.add(rule);
|
}
|
}
|
settings.setRules(normalizedRules);
|
if (normalizedRules.isEmpty()) {
|
settings.setEnabled(false);
|
}
|
}
|
|
List<Integer> parseRows(String rawRows) {
|
LinkedHashSet<Integer> rows = new LinkedHashSet<>();
|
if (Cools.isEmpty(rawRows)) {
|
return new ArrayList<>();
|
}
|
String[] parts = rawRows.split(",");
|
for (String part : parts) {
|
String token = part == null ? null : part.trim();
|
if (Cools.isEmpty(token)) {
|
continue;
|
}
|
if (token.contains("-")) {
|
String[] range = token.split("-");
|
if (range.length != 2) {
|
continue;
|
}
|
Integer start = safeParseInt(range[0]);
|
Integer end = safeParseInt(range[1]);
|
if (start == null || end == null || start <= 0 || end <= 0) {
|
continue;
|
}
|
// 支持正序/倒序区间，例如 1-3 或 20-18。
|
int step = start <= end ? 1 : -1;
|
for (int row = start; ; row += step) {
|
rows.add(row);
|
if (row == end) {
|
break;
|
}
|
}
|
continue;
|
}
|
Integer row = safeParseInt(token);
|
if (row != null && row > 0) {
|
rows.add(row);
|
}
|
}
|
return new ArrayList<>(rows);
|
}
|
|
private boolean isConfigEnabled(Config config) {
|
return config != null
|
&& config.getStatus() != null
|
&& config.getStatus() == 1
|
&& !Cools.isEmpty(config.getValue());
|
}
|
|
private Integer safeParseInt(String raw) {
|
try {
|
return Integer.parseInt(raw.trim());
|
} catch (Exception ignore) {
|
return null;
|
}
|
}
|
}
|
