Skip to content

H
HYH.APSJ
Commit fa5b9c03 authored by DESKTOP-VKRD9QF\Administration's avatar DESKTOP-VKRD9QF\Administration
Browse files
Options

离散参数修改，公共分页和list查询修改

parent d98a5bf6
Hide whitespace changes
Inline Side-by-side
Showing with 977 additions and 411 deletions
src/main/java/com/aps/controller/common/ChromosomeDataController.java
View file @ fa5b9c03
...@@ -4,6 +4,7 @@ import com.aps.common.util.R; ...@@ -4,6 +4,7 @@ import com.aps.common.util.R;
import com.aps.entity.Algorithm.Chromosome; import com.aps.entity.Algorithm.Chromosome;
import com.aps.entity.basic.Entry; import com.aps.entity.basic.Entry;
import com.aps.entity.basic.MachineOption; import com.aps.entity.basic.MachineOption;
import com.aps.entity.common.FieldInfo;
import com.aps.entity.common.Paged; import com.aps.entity.common.Paged;
import com.aps.service.common.ChromosomeDataService; import com.aps.service.common.ChromosomeDataService;
import com.aps.service.plan.PlanResultService; import com.aps.service.plan.PlanResultService;
...@@ -179,6 +180,26 @@ public class ChromosomeDataController { ...@@ -179,6 +180,26 @@ public class ChromosomeDataController {
} }
/**
* 获取实体的字段信息
* 示例:
* - 文件实体: GET /queryChromosome/order/info?sceneId=xxx
* - 数据库实体: GET /queryChromosome/user/info
*
* @param sceneId 场景ID (文件实体可选，数据库实体不需要)
* @param entityName 实体名称 (如: order, entry, machine, user, department等)
* @return 字段信息列表
*/
@GetMapping("/{entityName}/info")
@Operation(summary = "获取实体字段信息", description = "根据实体名称获取字段名称、类型等信息，支持文件实体和数据库实体")
public R<List<FieldInfo>> getEntityInfo(
@Parameter(description = "实体名称", required = true)
@PathVariable String entityName) {
List<FieldInfo> fieldInfos = chromosomeDataService.getEntityInfo(entityName);
return R.ok(fieldInfos);
}
......
src/main/java/com/aps/entity/basic/Entry.java
View file @ fa5b9c03
...@@ -143,8 +143,8 @@ public class Entry { ...@@ -143,8 +143,8 @@ public class Entry {
private BigDecimal singleOut;//单件产出 private BigDecimal singleOut;//单件产出
private double changeLineTime;//换模时间 private double changeLineTime;//换模时间
private BigDecimal setupTime;//准备时间 private BigDecimal setupTime;//准备时间
private int teardownTime; // 收尾时间（后处理时间） private int teardownTime; // （后处理时间）
private int preTime; // 收尾时间（后处理时间） private int preTime; // （前处理时间）
//常数时间 //常数时间
private int constTime; private int constTime;
private String equipCode;//设备编码 private String equipCode;//设备编码
......
src/main/java/com/aps/entity/basic/Order.java
View file @ fa5b9c03
...@@ -12,46 +12,168 @@ import java.util.List; ...@@ -12,46 +12,168 @@ import java.util.List;
*/ */
@Data @Data
public class Order { public class Order {
/**
* 自增主键
*/
private int id; private int id;
/**
* 订单ID
*/
private String orderId; private String orderId;
/**
* 订单编码
*/
private String orderCode; private String orderCode;
/**
* 产品ID
*/
private int productId; private int productId;
/**
* 物料ID
*/
private String materialId; private String materialId;
/**
* 物料编码
*/
private String materialCode; private String materialCode;
/**
* 物料名称
*/
private String materialName; private String materialName;
/**
* 系列
*/
private String serie; private String serie;
/**
* 工艺路线ID
*/
private Integer routingId; private Integer routingId;
/**
* 工艺路线编码
*/
private String routingCode; private String routingCode;
private double quantity = 100; // 100个
/**
* 订单数量，默认值：100
*/
private double quantity = 100;
/**
* 生产数量
*/
private double sYQuantity; private double sYQuantity;
/**
* 开始日期
*/
private LocalDateTime startDate; private LocalDateTime startDate;
/**
* 到期日期
*/
private LocalDateTime dueDate; private LocalDateTime dueDate;
/**
* 组开始日期
*/
private LocalDateTime groupStartDate; private LocalDateTime groupStartDate;
/**
* 组到期日期
*/
private LocalDateTime groupDueDate; private LocalDateTime groupDueDate;
/**
* 订单完成时间
*/
private LocalDateTime orderCompletion; private LocalDateTime orderCompletion;
/**
* 订单开始时间
*/
private LocalDateTime orderStart; private LocalDateTime orderStart;
/**
* 机器加工时间
*/
private double machineProcessingTime; private double machineProcessingTime;
/**
* 订单流程
*/
private double orderFlow; private double orderFlow;
/**
* 订单生产时间
*/
private double orderProductTime; private double orderProductTime;
/**
* 延误时间
*/
private double tardiness; private double tardiness;
/**
* 优先级
*/
private int priority; private int priority;
/**
* 是否可拆分，默认值：false
*/
private boolean canSplit = false; private boolean canSplit = false;
/**
* 是否可中断，默认值：false
*/
private boolean canInterrupt = false; private boolean canInterrupt = false;
/**
* 实际优先级
*/
private double actualPriority; private double actualPriority;
/**
* 主ID
*/
private String mainId; private String mainId;
/*使用这个半成品的成品工单*/
private List<Integer> FinishOrderId ; /**
* 使用这个半成品的成品工单
*/
private List<Integer> FinishOrderId ;
/**
* 是否新创建，默认值：false
*/
private boolean newCreate = false; private boolean newCreate = false;
/**
* 是否创建BOM，默认值：false
*/
private boolean createBom = false; private boolean createBom = false;
/// <summary> /**
/// 关联的成品工序ID（核心：明确该半成品服务于哪个成品工序） * 关联的成品工序ID（核心：明确该半成品服务于哪个成品工序）
/// </summary> */
private List<Integer> TargetFinishedOperationId; private List<Integer> TargetFinishedOperationId;
private double delayHours;//延迟时间
/**
//物料需求 * 延迟时间
*/
private double delayHours;
/**
* 物料需求
*/
private List<OrderMaterialRequirement> materialRequirementList; private List<OrderMaterialRequirement> materialRequirementList;
} }
\ No newline at end of file
src/main/java/com/aps/entity/common/Paged.java
View file @ fa5b9c03
...@@ -7,22 +7,23 @@ import java.util.List; ...@@ -7,22 +7,23 @@ import java.util.List;
import java.util.Optional; import java.util.Optional;
/** /**
* *
* @Title: PagedGridResult.java * @Title: PagedGridResult.java
* @Package com.lei.utils * @Package com.lei.utils
* @Description: 用来返回分页Grid的数据格式 * @Description: 用来返回分页Grid的数据格式
*/ */
public class Paged { public class Paged {
private Integer pageIndex=1; //当前页 private Integer pageIndex=1; //当前页
private Integer pageSize=1000; //每页多少条 private Integer pageSize=1000; //每页多少条
private Integer total=0;// 特殊设置，总记录数，如果前台带有此值，则分页查询时不查询总数。 private Integer total=0;// 特殊设置，总记录数，如果前台带有此值，则分页查询时不查询总数。
private List<String> sortByList=new ArrayList<>(); // 多字段排序列表，格式如["type asc", "id desc"]
private String sortBy=""; //排序字段 private String sortBy=""; //排序字段
private Boolean desc=true; //是否倒序 private Boolean desc=true; //是否倒序
private String fields="";// 返回的字段 private String fields=""; // 返回的字段
private String table;// 返回的表 private String table=""; // 返回的表
//分组字段名称
private String groupName; private String groupName;
private Boolean and=true; // 条件逻辑关系，true为与关系，false为或关系
private List<ConditionEntity> conditions=new ArrayList<>(); //条件集合 private List<ConditionEntity> conditions=new ArrayList<>(); //条件集合
...@@ -125,4 +126,20 @@ public class Paged { ...@@ -125,4 +126,20 @@ public class Paged {
public void setTotal(Integer total) { public void setTotal(Integer total) {
this.total = total; this.total = total;
} }
public List<String> getSortByList() {
return sortByList;
}
public void setSortByList(List<String> sortByList) {
this.sortByList = sortByList;
}
public Boolean getAnd() {
return and;
}
public void setAnd(Boolean and) {
this.and = and;
}
} }
src/main/java/com/aps/service/Algorithm/GeneticDecoder.java
View file @ fa5b9c03
...@@ -914,11 +914,14 @@ if(finishedOrder==null||finishedOrder.size()==0) ...@@ -914,11 +914,14 @@ if(finishedOrder==null||finishedOrder.size()==0)
// setupTime = (prev.getProductId() != operation.getProductId()) // setupTime = (prev.getProductId() != operation.getProductId())
// ? (int) discreteParameterMatrixService.getDiscreteParameterMatrixValue(prev, operation) // ? (int) discreteParameterMatrixService.getDiscreteParameterMatrixValue(prev, operation)
// : 0; // : 0;
DiscreteParameterMatrixService service = SpringContextUtil.getBean(DiscreteParameterMatrixService.class); DiscreteParameterMatrixService discreteParameterMatrixService = SpringContextUtil.getBean(DiscreteParameterMatrixService.class);
DiscreteParameterDurationService discreteParameterDurationService = SpringContextUtil.getBean(DiscreteParameterDurationService.class);
double discreteParameterMatrixValue = service.getDiscreteParameterMatrixValue( operation,prev); double discreteParameterDurationValue = discreteParameterDurationService.calculateChangeoverTime(prev, operation, machine, _allOperations, earliestStartTime,machineTasks);
setupTime = (int) discreteParameterMatrixValue; double discreteParameterMatrixValue = discreteParameterMatrixService.getDiscreteParameterMatrixValue(operation, prev);
setupTime = (int) Math.max(discreteParameterDurationValue, discreteParameterMatrixValue);
// setupTime = (int) discreteParameterMatrixValue;
......
src/main/java/com/aps/service/DiscreteParameterDurationService.java
View file @ fa5b9c03
...@@ -19,8 +19,8 @@ import java.util.List; ...@@ -19,8 +19,8 @@ import java.util.List;
public interface DiscreteParameterDurationService extends IService<DiscreteParameterDuration> { public interface DiscreteParameterDurationService extends IService<DiscreteParameterDuration> {
double calculateChangeoverTime(List<GAScheduleResult> existingGenes, double calculateChangeoverTime(Entry lastEntry,
Entry operation, Entry entry,
Machine machine, Machine machine,
List<Entry> allOperations,int startTime); List<Entry> allOperations,int startTime,List<GAScheduleResult> machineTasks);
} }
src/main/java/com/aps/service/common/ChromosomeDataService.java
View file @ fa5b9c03
...@@ -4,7 +4,10 @@ import cn.hutool.core.bean.BeanUtil; ...@@ -4,7 +4,10 @@ import cn.hutool.core.bean.BeanUtil;
import com.aps.common.util.R; import com.aps.common.util.R;
import com.aps.entity.Algorithm.Chromosome; import com.aps.entity.Algorithm.Chromosome;
import com.aps.entity.ProdProcessExec; import com.aps.entity.ProdProcessExec;
import com.aps.entity.Algorithm.GlobalOperationInfo;
import com.aps.entity.Algorithm.IDAndChildID.GroupResult;
import com.aps.entity.basic.Entry; import com.aps.entity.basic.Entry;
import com.aps.entity.basic.Machine;
import com.aps.entity.basic.MachineOption; import com.aps.entity.basic.MachineOption;
import com.aps.entity.basic.Order; import com.aps.entity.basic.Order;
import com.aps.entity.common.*; import com.aps.entity.common.*;
...@@ -15,12 +18,15 @@ import com.fasterxml.jackson.databind.SerializationFeature; ...@@ -15,12 +18,15 @@ import com.fasterxml.jackson.databind.SerializationFeature;
import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule; import com.fasterxml.jackson.datatype.jsr310.JavaTimeModule;
import org.springframework.beans.BeanUtils; import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource; import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate; import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
import java.lang.reflect.Field; import java.lang.reflect.Field;
import java.lang.reflect.Modifier;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.math.RoundingMode; import java.math.RoundingMode;
import java.time.LocalDateTime; import java.time.LocalDateTime;
...@@ -31,6 +37,7 @@ import java.util.*; ...@@ -31,6 +37,7 @@ import java.util.*;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@Service @Service
@Slf4j
public class ChromosomeDataService { public class ChromosomeDataService {
@Autowired @Autowired
...@@ -41,6 +48,9 @@ public class ChromosomeDataService { ...@@ -41,6 +48,9 @@ public class ChromosomeDataService {
@Autowired @Autowired
private NamedParameterJdbcTemplate namedParameterJdbcTemplate; private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
@Autowired
private JdbcTemplate jdbcTemplate;
@Autowired @Autowired
private Map<String, EntityConfig> entityConfigMap; private Map<String, EntityConfig> entityConfigMap;
...@@ -51,7 +61,7 @@ public class ChromosomeDataService { ...@@ -51,7 +61,7 @@ public class ChromosomeDataService {
* 根据场景ID和实体名称查询Chromosome中的数据 * 根据场景ID和实体名称查询Chromosome中的数据
*/ */
ObjectMapper objectMapper = new ObjectMapper() ObjectMapper objectMapper = new ObjectMapper()
.registerModule(new JavaTimeModule()) .registerModule(new JavaTimeModule())
.configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, false); .configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, false);
// public Object queryChromosomeData(String sceneId, String entityName) { // public Object queryChromosomeData(String sceneId, String entityName) {
...@@ -67,7 +77,7 @@ public class ChromosomeDataService { ...@@ -67,7 +77,7 @@ public class ChromosomeDataService {
// } // }
// } // }
/** /**
* 驼峰命名转下划线大写：prodProduct -> PROD_PRODUCT * 驼峰命名转下划线大写：prodProduct -> PROD_PRODUCT, apsOder -> APS_ORDER
*/ */
private String camelCaseToUnderScoreUpperCase(String camelCase) { private String camelCaseToUnderScoreUpperCase(String camelCase) {
if (camelCase == null || camelCase.isEmpty()) { if (camelCase == null || camelCase.isEmpty()) {
...@@ -90,8 +100,172 @@ public class ChromosomeDataService { ...@@ -90,8 +100,172 @@ public class ChromosomeDataService {
result.append(Character.toUpperCase(c)); result.append(Character.toUpperCase(c));
} }
// 特殊处理：apsOder -> APS_ORDER
if (result.toString().equals("APS_ODER")) {
return "APS_ORDER";
}
return result.toString(); return result.toString();
} }
/**
* 获取实体的字段信息
* @param entityName 实体名称
* @return 字段信息列表
*/
public List<FieldInfo> getEntityInfo(String entityName) {
List<FieldInfo> fieldInfos = new ArrayList<>();
// 获取实体配置
EntityConfig config = getEntityConfig(entityName);
// 处理文件实体
if (config.getDataSource() == DataSourceType.FILE) {
// 实体类映射
Map<String, Class<?>> fileEntityClassMap = new HashMap<>();
fileEntityClassMap.put("order", Order.class);
fileEntityClassMap.put("entry", Entry.class);
fileEntityClassMap.put("machine", Machine.class);
fileEntityClassMap.put("machineoption", MachineOption.class);
fileEntityClassMap.put("prodprocessexec", ProdProcessExec.class);
fileEntityClassMap.put("globaloperationinfo", GlobalOperationInfo.class);
fileEntityClassMap.put("groupresult", GroupResult.class);
// 获取实体类
Class<?> entityClass = fileEntityClassMap.get(entityName.toLowerCase());
// 如果没有找到实体类，返回空列表
if (entityClass == null) {
return fieldInfos;
}
// 通过反射获取所有字段（包括父类字段）
List<Field> fields = new ArrayList<>();
Class<?> currentClass = entityClass;
while (currentClass != null && currentClass != Object.class) {
fields.addAll(Arrays.asList(currentClass.getDeclaredFields()));
currentClass = currentClass.getSuperclass();
}
// 获取字段描述映射
Map<String, String> fieldDescriptions = getFieldDescriptions(entityName);
// 遍历字段，生成FieldInfo
for (Field field : fields) {
// 跳过静态字段
if (Modifier.isStatic(field.getModifiers())) {
continue;
}
FieldInfo fieldInfo = new FieldInfo();
fieldInfo.setFieldName(field.getName());
fieldInfo.setFieldType(field.getType().getSimpleName());
// 设置字段描述
fieldInfo.setDescription(fieldDescriptions.getOrDefault(field.getName(), ""));
fieldInfo.setDataSource(config.getDataSource().name());
fieldInfo.setEntityName(entityName);
fieldInfos.add(fieldInfo);
}
}
// 处理数据库实体
else {
try {
// 获取数据库连接
java.sql.Connection connection = jdbcTemplate.getDataSource().getConnection();
// 获取数据库元数据
java.sql.DatabaseMetaData metaData = connection.getMetaData();
// 获取表名
String tableName = config.getTableName();
// 获取表的列信息
java.sql.ResultSet columns = metaData.getColumns(null, null, tableName, null);
// 遍历列信息，生成FieldInfo
while (columns.next()) {
FieldInfo fieldInfo = new FieldInfo();
fieldInfo.setFieldName(columns.getString("COLUMN_NAME"));
fieldInfo.setFieldType(columns.getString("TYPE_NAME"));
fieldInfo.setDescription(columns.getString("REMARKS"));
fieldInfo.setDataSource(config.getDataSource().name());
fieldInfo.setEntityName(entityName);
fieldInfos.add(fieldInfo);
}
// 关闭资源
columns.close();
connection.close();
} catch (Exception e) {
log.error("获取数据库表字段信息失败: {}", e.getMessage(), e);
}
}
return fieldInfos;
}
/**
* 获取指定实体的字段描述映射
* @param entityName 实体名称
* @return 字段描述映射
*/
private Map<String, String> getFieldDescriptions(String entityName) {
Map<String, String> fieldDescriptions = new HashMap<>();
// 根据实体名称返回对应的字段描述
switch (entityName.toLowerCase()) {
case "order":
// Order实体字段描述
fieldDescriptions.put("id", "自增主键");
fieldDescriptions.put("orderId", "订单ID");
fieldDescriptions.put("orderCode", "订单编码");
fieldDescriptions.put("productId", "产品ID");
fieldDescriptions.put("materialId", "物料ID");
fieldDescriptions.put("materialCode", "物料编码");
fieldDescriptions.put("materialName", "物料名称");
fieldDescriptions.put("serie", "系列");
fieldDescriptions.put("routingId", "工艺路线ID");
fieldDescriptions.put("routingCode", "工艺路线编码");
fieldDescriptions.put("quantity", "订单数量，默认值：100");
fieldDescriptions.put("sYQuantity", "生产数量");
fieldDescriptions.put("startDate", "开始日期");
fieldDescriptions.put("dueDate", "到期日期");
fieldDescriptions.put("groupStartDate", "组开始日期");
fieldDescriptions.put("groupDueDate", "组到期日期");
fieldDescriptions.put("orderCompletion", "订单完成时间");
fieldDescriptions.put("orderStart", "订单开始时间");
fieldDescriptions.put("machineProcessingTime", "机器加工时间");
fieldDescriptions.put("orderFlow", "订单流程");
fieldDescriptions.put("orderProductTime", "订单生产时间");
fieldDescriptions.put("tardiness", "延误时间");
fieldDescriptions.put("priority", "优先级");
fieldDescriptions.put("canSplit", "是否可拆分，默认值：false");
fieldDescriptions.put("canInterrupt", "是否可中断，默认值：false");
fieldDescriptions.put("actualPriority", "实际优先级");
fieldDescriptions.put("mainId", "主ID");
fieldDescriptions.put("FinishOrderId", "使用这个半成品的成品工单");
fieldDescriptions.put("newCreate", "是否新创建，默认值：false");
fieldDescriptions.put("createBom", "是否创建BOM，默认值：false");
fieldDescriptions.put("TargetFinishedOperationId", "关联的成品工序ID（核心：明确该半成品服务于哪个成品工序）");
fieldDescriptions.put("delayHours", "延迟时间");
fieldDescriptions.put("materialRequirementList", "物料需求");
break;
// 可以继续添加其他实体的字段描述
case "entry":
// Entry实体字段描述
// 后续可以补充
break;
case "machine":
// Machine实体字段描述
// 后续可以补充
break;
}
return fieldDescriptions;
}
/** /**
* 根据场景ID和实体名称查询Chromosome中的分页数据，带条件过滤 * 根据场景ID和实体名称查询Chromosome中的分页数据，带条件过滤
*/ */
...@@ -120,43 +294,40 @@ public class ChromosomeDataService { ...@@ -120,43 +294,40 @@ public class ChromosomeDataService {
entryConfig.setEntityName("entry"); entryConfig.setEntityName("entry");
entryConfig.setDataSource(DataSourceType.FILE); entryConfig.setDataSource(DataSourceType.FILE);
entryConfig.setFieldName("allOperations"); entryConfig.setFieldName("allOperations");
Object entryData = queryFileData(sceneId, entryConfig); Object entryData = queryFileData(sceneId, entryConfig);
if (entryData instanceof List) { if (entryData instanceof List) {
List<?> entryList = (List<?>) entryData; List<?> entryList = (List<?>) entryData;
List<MachineOption> resultMachineOptions = new ArrayList<>(); List<Object> resultEntries = new ArrayList<>();
// 过滤Entry列表，只保留与场景ID匹配的Entry // 先将Entry对象转换为Object对象，方便后续处理
for (Object obj : entryList) { for (Object obj : entryList) {
if (obj instanceof Entry) { if (obj instanceof Entry) {
Entry entry = (Entry) obj; Entry entry = (Entry) obj;
// 检查Entry的SceneId是否匹配 // 检查Entry的SceneId是否匹配
if (entry.getSceneId() != null && !entry.getSceneId().equals(sceneId)) { if (entry.getSceneId() == null || entry.getSceneId().equals(sceneId)) {
continue; // 跳过不属于当前场景的Entry resultEntries.add(obj);
}
// 检查Entry是否满足其他条件
boolean matchesOtherConditions = true;
if (!CollectionUtils.isEmpty(paged.getConditions())) {
for (ConditionEntity condition : paged.getConditions()) {
if (condition != null && !"sceneId".equalsIgnoreCase(condition.getFieldName())) {
if (!matchesCondition(entry, condition.getFieldName(), condition.getFieldValue(),
ConditionEnum.getByName(condition.getConditionalType()))) {
matchesOtherConditions = false;
break;
}
}
}
} }
}
if (matchesOtherConditions && entry.getMachineOptions() != null) { }
// 如果Entry满足所有条件，添加其MachineOptions
// 应用条件过滤，支持AND/OR关系
if (!CollectionUtils.isEmpty(paged.getConditions())) {
resultEntries = filterDataByConditions(resultEntries, paged.getConditions(), paged.getAnd());
}
// 提取符合条件的Entry的MachineOptions
List<MachineOption> resultMachineOptions = new ArrayList<>();
for (Object obj : resultEntries) {
if (obj instanceof Entry) {
Entry entry = (Entry) obj;
if (entry.getMachineOptions() != null) {
resultMachineOptions.addAll(entry.getMachineOptions()); resultMachineOptions.addAll(entry.getMachineOptions());
} }
} }
} }
return (List<Object>) (List<?>) resultMachineOptions; return (List<Object>) (List<?>) resultMachineOptions;
} else { } else {
return new ArrayList<>(); return new ArrayList<>();
...@@ -164,36 +335,26 @@ public class ChromosomeDataService { ...@@ -164,36 +335,26 @@ public class ChromosomeDataService {
} else if ("order".equalsIgnoreCase(config.getEntityName())) { } else if ("order".equalsIgnoreCase(config.getEntityName())) {
// 特殊处理：当实体是Order时，使用orderId字段进行查询 // 特殊处理：当实体是Order时，使用orderId字段进行查询
Object data = queryFileData(sceneId, config); Object data = queryFileData(sceneId, config);
if (data instanceof List) { if (data instanceof List) {
List<?> orderList = (List<?>) data; List<?> orderList = (List<?>) data;
List<Order> resultOrders = new ArrayList<>(); List<Object> resultOrders = new ArrayList<>();
// 过滤Order列表，只保留与场景ID匹配的Order（如果Order中有SceneId的话） // 先将Order对象转换为Object对象，方便后续处理
for (Object obj : orderList) { for (Object obj : orderList) {
if (obj instanceof Order) { if (obj instanceof Order) {
Order order = (Order) obj; resultOrders.add(obj);
// 检查Order是否满足条件
boolean matchesOtherConditions = true;
if (!CollectionUtils.isEmpty(paged.getConditions())) {
for (ConditionEntity condition : paged.getConditions()) {
if (condition != null && !"sceneId".equalsIgnoreCase(condition.getFieldName())) {
if (!matchesCondition(order, condition.getFieldName(), condition.getFieldValue(),
ConditionEnum.getByName(condition.getConditionalType()))) {
matchesOtherConditions = false;
break;
}
}
}
}
if (matchesOtherConditions) {
resultOrders.add(order);
}
} }
} }
return (List<Object>) (List<?>) resultOrders; // 应用条件过滤，支持AND/OR关系
if (!CollectionUtils.isEmpty(paged.getConditions())) {
resultOrders = filterDataByConditions(resultOrders, paged.getConditions(), paged.getAnd());
}
// 应用排序
List<Object> sortedData = sortData(resultOrders, paged);
return sortedData;
} else { } else {
return new ArrayList<>(); return new ArrayList<>();
} }
...@@ -324,7 +485,7 @@ public class ChromosomeDataService { ...@@ -324,7 +485,7 @@ public class ChromosomeDataService {
try { try {
String fieldName = config.getFieldName(); String fieldName = config.getFieldName();
// // 特殊处理：当实体是ProdProcessExec时，使用allOperations字段 // // 特殊处理：当实体是ProdProcessExec时，使用allOperations字段
// if ("prodprocessexec".equalsIgnoreCase(config.getEntityName())) { // if ("prodprocessexec".equalsIgnoreCase(config.getEntityName())) {
// fieldName = "allOperations"; // fieldName = "allOperations";
...@@ -334,26 +495,26 @@ public class ChromosomeDataService { ...@@ -334,26 +495,26 @@ public class ChromosomeDataService {
if ("machineoption".equalsIgnoreCase(config.getEntityName())) { if ("machineoption".equalsIgnoreCase(config.getEntityName())) {
fieldName = "allOperations"; fieldName = "allOperations";
} }
Field field = Chromosome.class.getDeclaredField(fieldName); Field field = Chromosome.class.getDeclaredField(fieldName);
field.setAccessible(true); field.setAccessible(true);
Object result = field.get(chromosome); Object result = field.get(chromosome);
// // 如果实体是ProdProcessExec，但数据源是Entry，则进行转换 // // 如果实体是ProdProcessExec，但数据源是Entry，则进行转换
// if ("prodprocessexec".equalsIgnoreCase(config.getEntityName())) { // if ("prodprocessexec".equalsIgnoreCase(config.getEntityName())) {
// return convertEntryToProdProcessExec(result); // return convertEntryToProdProcessExec(result);
// } // }
// 如果实体是MachineOption，提取Entry中的MachineOption列表 // 如果实体是MachineOption，提取Entry中的MachineOption列表
if ("machineoption".equalsIgnoreCase(config.getEntityName())) { if ("machineoption".equalsIgnoreCase(config.getEntityName())) {
return extractMachineOptionsFromEntries(result); return extractMachineOptionsFromEntries(result);
} }
// 如果实体是KpiMetrics，直接返回结果 // 如果实体是KpiMetrics，直接返回结果
if ("kpimetrics".equalsIgnoreCase(config.getEntityName())) { if ("kpimetrics".equalsIgnoreCase(config.getEntityName())) {
return result; return result;
} }
return result; return result;
} catch (NoSuchFieldException e) { } catch (NoSuchFieldException e) {
throw new RuntimeException("Chromosome类中未找到字段: " + config.getFieldName(), e); throw new RuntimeException("Chromosome类中未找到字段: " + config.getFieldName(), e);
...@@ -367,7 +528,7 @@ public class ChromosomeDataService { ...@@ -367,7 +528,7 @@ public class ChromosomeDataService {
*/ */
private Map<String, Object> queryFileDataWithConditions(String sceneId, EntityConfig config, Paged paged) { private Map<String, Object> queryFileDataWithConditions(String sceneId, EntityConfig config, Paged paged) {
Object data; Object data;
// 特殊处理：当实体是MachineOption时，需要先获取Entry列表，再提取符合条件的Entry的MachineOption // 特殊处理：当实体是MachineOption时，需要先获取Entry列表，再提取符合条件的Entry的MachineOption
if ("machineoption".equalsIgnoreCase(config.getEntityName())) { if ("machineoption".equalsIgnoreCase(config.getEntityName())) {
// 先获取Entry列表（而不是MachineOption列表） // 先获取Entry列表（而不是MachineOption列表）
...@@ -375,43 +536,40 @@ public class ChromosomeDataService { ...@@ -375,43 +536,40 @@ public class ChromosomeDataService {
entryConfig.setEntityName("entry"); entryConfig.setEntityName("entry");
entryConfig.setDataSource(DataSourceType.FILE); entryConfig.setDataSource(DataSourceType.FILE);
entryConfig.setFieldName("allOperations"); entryConfig.setFieldName("allOperations");
Object entryData = queryFileData(sceneId, entryConfig); Object entryData = queryFileData(sceneId, entryConfig);
if (entryData instanceof List) { if (entryData instanceof List) {
List<?> entryList = (List<?>) entryData; List<?> entryList = (List<?>) entryData;
List<MachineOption> resultMachineOptions = new ArrayList<>(); List<Object> resultEntries = new ArrayList<>();
// 过滤Entry列表，只保留与场景ID匹配的Entry // 先将Entry对象转换为Object对象，方便后续处理
for (Object obj : entryList) { for (Object obj : entryList) {
if (obj instanceof Entry) { if (obj instanceof Entry) {
Entry entry = (Entry) obj; Entry entry = (Entry) obj;
// 检查Entry的SceneId是否匹配 // 检查Entry的SceneId是否匹配
if (entry.getSceneId() != null && !entry.getSceneId().equals(sceneId)) { if (entry.getSceneId() == null || entry.getSceneId().equals(sceneId)) {
continue; // 跳过不属于当前场景的Entry resultEntries.add(obj);
}
// 检查Entry是否满足其他条件
boolean matchesOtherConditions = true;
if (!CollectionUtils.isEmpty(paged.getConditions())) {
for (ConditionEntity condition : paged.getConditions()) {
if (condition != null && !"sceneId".equalsIgnoreCase(condition.getFieldName())) {
if (!matchesCondition(entry, condition.getFieldName(), condition.getFieldValue(),
ConditionEnum.getByName(condition.getConditionalType()))) {
matchesOtherConditions = false;
break;
}
}
}
} }
}
if (matchesOtherConditions && entry.getMachineOptions() != null) { }
// 如果Entry满足所有条件，添加其MachineOptions
// 应用条件过滤，支持AND/OR关系
if (!CollectionUtils.isEmpty(paged.getConditions())) {
resultEntries = filterDataByConditions(resultEntries, paged.getConditions(), paged.getAnd());
}
// 提取符合条件的Entry的MachineOptions
List<MachineOption> resultMachineOptions = new ArrayList<>();
for (Object obj : resultEntries) {
if (obj instanceof Entry) {
Entry entry = (Entry) obj;
if (entry.getMachineOptions() != null) {
resultMachineOptions.addAll(entry.getMachineOptions()); resultMachineOptions.addAll(entry.getMachineOptions());
} }
} }
} }
data = resultMachineOptions; data = resultMachineOptions;
} else { } else {
data = new ArrayList<MachineOption>(); data = new ArrayList<MachineOption>();
...@@ -419,52 +577,43 @@ public class ChromosomeDataService { ...@@ -419,52 +577,43 @@ public class ChromosomeDataService {
} else if ("order".equalsIgnoreCase(config.getEntityName())) { } else if ("order".equalsIgnoreCase(config.getEntityName())) {
// 特殊处理：当实体是Order时，使用orderId字段进行查询 // 特殊处理：当实体是Order时，使用orderId字段进行查询
Object orderData = queryFileData(sceneId, config); Object orderData = queryFileData(sceneId, config);
if (orderData instanceof List) { if (orderData instanceof List) {
List<?> orderList = (List<?>) orderData; List<?> orderList = (List<?>) orderData;
List<Order> resultOrders = new ArrayList<>(); List<Object> resultOrders = new ArrayList<>();
// 过滤Order列表，只保留满足条件的Order // 先将Order对象转换为Object对象，方便后续处理
for (Object obj : orderList) { for (Object obj : orderList) {
if (obj instanceof Order) { if (obj instanceof Order) {
Order order = (Order) obj; resultOrders.add(obj);
// 检查Order是否满足条件
boolean matchesOtherConditions = true;
if (!CollectionUtils.isEmpty(paged.getConditions())) {
for (ConditionEntity condition : paged.getConditions()) {
if (condition != null && !"sceneId".equalsIgnoreCase(condition.getFieldName())) {
if (!matchesCondition(order, condition.getFieldName(), condition.getFieldValue(),
ConditionEnum.getByName(condition.getConditionalType()))) {
matchesOtherConditions = false;
break;
}
}
}
}
if (matchesOtherConditions) {
resultOrders.add(order);
}
} }
} }
data = resultOrders; // 应用条件过滤，支持AND/OR关系
if (!CollectionUtils.isEmpty(paged.getConditions())) {
resultOrders = filterDataByConditions(resultOrders, paged.getConditions(), paged.getAnd());
}
// 应用排序
List<Object> sortedData = sortData(resultOrders, paged);
data = sortedData;
} else { } else {
data = new ArrayList<Order>(); data = new ArrayList<Order>();
} }
} else { } else {
data = queryFileData(sceneId, config); data = queryFileData(sceneId, config);
if (data instanceof List) { if (data instanceof List) {
List<?> dataList = (List<?>) data; List<?> dataList = (List<?>) data;
// 应用条件过滤 // 应用条件过滤
if (!CollectionUtils.isEmpty(paged.getConditions())) { if (!CollectionUtils.isEmpty(paged.getConditions())) {
dataList = filterDataByConditions(dataList, paged.getConditions()); dataList = filterDataByConditions(dataList, paged.getConditions(), paged.getAnd());
} }
data = dataList; // 应用排序
List<Object> sortedData = sortData(dataList, paged);
data = sortedData;
} }
} }
...@@ -507,9 +656,9 @@ public class ChromosomeDataService { ...@@ -507,9 +656,9 @@ public class ChromosomeDataService {
entryConfig.setEntityName("entry"); entryConfig.setEntityName("entry");
entryConfig.setDataSource(DataSourceType.FILE); entryConfig.setDataSource(DataSourceType.FILE);
entryConfig.setFieldName("allOperations"); entryConfig.setFieldName("allOperations");
Object result = queryFileData(sceneId, entryConfig); Object result = queryFileData(sceneId, entryConfig);
if (result instanceof List) { if (result instanceof List) {
List<?> entryList = (List<?>) result; List<?> entryList = (List<?>) result;
// 查找ID匹配的Entry // 查找ID匹配的Entry
...@@ -569,21 +718,17 @@ public class ChromosomeDataService { ...@@ -569,21 +718,17 @@ public class ChromosomeDataService {
* 忽略大小写获取字段 * 忽略大小写获取字段
*/ */
private Field getFieldIgnoreCase(Class<?> clazz, String fieldName) { private Field getFieldIgnoreCase(Class<?> clazz, String fieldName) {
try { // 遍历所有声明的字段，查找忽略大小写匹配的字段
return clazz.getDeclaredField(fieldName); for (Field field : clazz.getDeclaredFields()) {
} catch (NoSuchFieldException e) { if (field.getName().equalsIgnoreCase(fieldName)) {
// 尝试大写 return field;
try {
return clazz.getDeclaredField(fieldName.toUpperCase());
} catch (NoSuchFieldException e1) {
// 尝试小写
try {
return clazz.getDeclaredField(fieldName.toLowerCase());
} catch (NoSuchFieldException e2) {
return null;
}
} }
} }
// 如果当前类没有找到，递归查找父类
if (clazz.getSuperclass() != null && clazz.getSuperclass() != Object.class) {
return getFieldIgnoreCase(clazz.getSuperclass(), fieldName);
}
return null;
} }
/** /**
...@@ -592,15 +737,18 @@ public class ChromosomeDataService { ...@@ -592,15 +737,18 @@ public class ChromosomeDataService {
private List<Object> applyConditionsToList(Object data, Paged paged) { private List<Object> applyConditionsToList(Object data, Paged paged) {
// 检查是否是直接传入的EntityConfig（这种情况可能需要获取场景ID和实体类型） // 检查是否是直接传入的EntityConfig（这种情况可能需要获取场景ID和实体类型）
// 实际上这个方法是在queryChromosomeDataList中调用的，此时数据已经从文件中获取 // 实际上这个方法是在queryChromosomeDataList中调用的，此时数据已经从文件中获取
if (data instanceof List) { if (data instanceof List) {
List<Object> dataList = (List<Object>) data; List<Object> dataList = (List<Object>) data;
// 应用条件过滤 // 应用条件过滤
if (!CollectionUtils.isEmpty(paged.getConditions())) { if (!CollectionUtils.isEmpty(paged.getConditions())) {
dataList = filterDataByConditions(dataList, paged.getConditions()); dataList = filterDataByConditions(dataList, paged.getConditions(), paged.getAnd());
} }
// 应用排序
dataList = sortData(dataList, paged);
return dataList; return dataList;
} else { } else {
List<Object> resultList = new ArrayList<>(); List<Object> resultList = new ArrayList<>();
...@@ -612,44 +760,201 @@ public class ChromosomeDataService { ...@@ -612,44 +760,201 @@ public class ChromosomeDataService {
/** /**
* 根据条件过滤数据（文件数据使用）- 修复版本 * 根据条件过滤数据（文件数据使用）- 修复版本
*/ */
private List<Object> filterDataByConditions(List<?> dataList, List<ConditionEntity> conditions) { private List<Object> filterDataByConditions(List<?> dataList, List<ConditionEntity> conditions, Boolean and) {
if (CollectionUtils.isEmpty(conditions)) { if (CollectionUtils.isEmpty(conditions)) {
return new ArrayList<>(dataList); return new ArrayList<>(dataList);
} }
List<Object> filteredList = new ArrayList<>(dataList); // 分离sceneId条件和其他条件
List<ConditionEntity> sceneIdConditions = new ArrayList<>();
List<ConditionEntity> otherConditions = new ArrayList<>();
for (ConditionEntity condition : conditions) { for (ConditionEntity condition : conditions) {
if (condition == null || condition.getFieldName() == null || condition.getFieldValue() == null) { if (condition != null && condition.getFieldName() != null && condition.getFieldValue() != null) {
continue; if ("sceneId".equalsIgnoreCase(condition.getFieldName())) {
sceneIdConditions.add(condition);
} else {
otherConditions.add(condition);
}
} }
}
final String fieldName = condition.getFieldName(); // 如果只有sceneId条件，返回所有数据（因为sceneId已经在查询层面处理了）
final String fieldValue = condition.getFieldValue(); if (otherConditions.isEmpty()) {
ConditionEnum conditionType = ConditionEnum.getByName(condition.getConditionalType()); return new ArrayList<>(dataList);
if (conditionType == null) { }
conditionType = ConditionEnum.Equal;
}
final ConditionEnum finalConditionType = conditionType;
// 特殊处理：sceneId条件应该在查询层面处理，这里跳过 List<Object> filteredList = new ArrayList<>(dataList);
if ("sceneId".equalsIgnoreCase(fieldName)) { boolean isAnd = and != null && and;
continue;
} if (isAnd) {
// 与关系：逐个应用条件，只有满足所有条件的记录才会保留
for (ConditionEntity condition : otherConditions) {
final String fieldName = condition.getFieldName();
final String fieldValue = condition.getFieldValue();
ConditionEnum conditionType = ConditionEnum.getByName(condition.getConditionalType());
if (conditionType == null) {
conditionType = ConditionEnum.Equal;
}
final ConditionEnum finalConditionType = conditionType;
// 使用增强的for循环替代stream，避免lambda变量问题 List<Object> tempList = new ArrayList<>();
List<Object> tempList = new ArrayList<>(); for (Object item : filteredList) {
if (matchesCondition(item, fieldName, fieldValue, finalConditionType)) {
tempList.add(item);
}
}
filteredList = tempList;
}
} else {
// 或关系：只要满足一个条件的记录就会保留
List<Object> resultList = new ArrayList<>();
for (Object item : filteredList) { for (Object item : filteredList) {
if (matchesCondition(item, fieldName, fieldValue, finalConditionType)) { boolean matches = false;
tempList.add(item); for (ConditionEntity condition : otherConditions) {
final String fieldName = condition.getFieldName();
final String fieldValue = condition.getFieldValue();
ConditionEnum conditionType = ConditionEnum.getByName(condition.getConditionalType());
if (conditionType == null) {
conditionType = ConditionEnum.Equal;
}
if (matchesCondition(item, fieldName, fieldValue, conditionType)) {
matches = true;
break;
}
}
if (matches) {
resultList.add(item);
} }
} }
filteredList = tempList; filteredList = resultList;
} }
return filteredList; return filteredList;
} }
/**
* 根据排序规则对数据进行排序
*/
private List<Object> sortData(List<?> dataList, Paged paged) {
if (CollectionUtils.isEmpty(dataList)) {
return new ArrayList<>(dataList);
}
List<Object> sortedList = new ArrayList<>(dataList);
// 优先使用sortByList进行多字段排序
if (!CollectionUtils.isEmpty(paged.getSortByList())) {
// 构建Comparator链
Comparator<Object> comparator = null;
for (String sortBy : paged.getSortByList()) {
String[] parts = sortBy.trim().split("\\s+");
if (parts.length < 2) {
continue; // 跳过格式不正确的排序规则
}
String fieldName = parts[0];
boolean isAsc = !"desc".equalsIgnoreCase(parts[1]);
// 创建字段比较器
Comparator<Object> fieldComparator = (o1, o2) -> {
try {
Field field1 = getFieldIgnoreCase(o1.getClass(), fieldName);
Field field2 = getFieldIgnoreCase(o2.getClass(), fieldName);
if (field1 == null || field2 == null) {
return 0;
}
field1.setAccessible(true);
field2.setAccessible(true);
Object value1 = field1.get(o1);
Object value2 = field2.get(o2);
// 处理null值
if (value1 == null && value2 == null) {
return 0;
}
if (value1 == null) {
return isAsc ? -1 : 1;
}
if (value2 == null) {
return isAsc ? 1 : -1;
}
// 比较值
if (value1 instanceof Comparable && value2 instanceof Comparable) {
@SuppressWarnings("unchecked")
int compareResult = ((Comparable<Object>) value1).compareTo(value2);
return isAsc ? compareResult : -compareResult;
}
return 0;
} catch (Exception e) {
log.error("排序字段获取失败: " + fieldName, e);
return 0;
}
};
// 链式比较
comparator = comparator == null ? fieldComparator : comparator.thenComparing(fieldComparator);
}
if (comparator != null) {
sortedList.sort(comparator);
}
}
// 使用原有sortBy和desc字段进行单字段排序
else if (paged.getSortBy() != null && !paged.getSortBy().isEmpty()) {
String sortBy = paged.getSortBy();
boolean isDesc = paged.getDesc() != null && paged.getDesc();
sortedList.sort((o1, o2) -> {
try {
Field field1 = getFieldIgnoreCase(o1.getClass(), sortBy);
Field field2 = getFieldIgnoreCase(o2.getClass(), sortBy);
if (field1 == null || field2 == null) {
return 0;
}
field1.setAccessible(true);
field2.setAccessible(true);
Object value1 = field1.get(o1);
Object value2 = field2.get(o2);
// 处理null值
if (value1 == null && value2 == null) {
return 0;
}
if (value1 == null) {
return isDesc ? 1 : -1;
}
if (value2 == null) {
return isDesc ? -1 : 1;
}
// 比较值
if (value1 instanceof Comparable && value2 instanceof Comparable) {
@SuppressWarnings("unchecked")
int compareResult = ((Comparable<Object>) value1).compareTo(value2);
return isDesc ? -compareResult : compareResult;
}
return 0;
} catch (Exception e) {
log.error("排序字段获取失败: " + sortBy, e);
return 0;
}
});
}
return sortedList;
}
/** /**
* 判断单个对象是否匹配条件 * 判断单个对象是否匹配条件
*/ */
...@@ -665,9 +970,11 @@ public class ChromosomeDataService { ...@@ -665,9 +970,11 @@ public class ChromosomeDataService {
switch (conditionType) { switch (conditionType) {
case Equal: case Equal:
return actualValueStr.equals(fieldValue); // 使用compareValues方法比较，支持数字和字符串
return compareValues(actualValueStr, fieldValue) == 0;
case NoEqual: case NoEqual:
return !actualValueStr.equals(fieldValue); // 使用compareValues方法比较，支持数字和字符串
return compareValues(actualValueStr, fieldValue) != 0;
case Like: case Like:
return actualValueStr.contains(fieldValue); return actualValueStr.contains(fieldValue);
case GreaterThan: case GreaterThan:
...@@ -687,7 +994,7 @@ public class ChromosomeDataService { ...@@ -687,7 +994,7 @@ public class ChromosomeDataService {
case NotEmpty: case NotEmpty:
return !actualValueStr.isEmpty(); return !actualValueStr.isEmpty();
default: default:
return actualValueStr.equals(fieldValue); return compareValues(actualValueStr, fieldValue) == 0;
} }
} catch (Exception e) { } catch (Exception e) {
// 如果匹配过程中出错，保守起见返回true（不过滤掉数据） // 如果匹配过程中出错，保守起见返回true（不过滤掉数据）
...@@ -699,26 +1006,18 @@ public class ChromosomeDataService { ...@@ -699,26 +1006,18 @@ public class ChromosomeDataService {
* 安全获取字段值（支持多种字段名格式） * 安全获取字段值（支持多种字段名格式）
*/ */
private Object getFieldValue(Object item, String fieldName) { private Object getFieldValue(Object item, String fieldName) {
// 尝试多种可能的字段名 try {
String[] possibleNames = { // 使用getFieldIgnoreCase方法获取字段，支持忽略大小写和父类字段
fieldName, Field field = getFieldIgnoreCase(item.getClass(), fieldName);
fieldName.toLowerCase(), if (field != null) {
fieldName.toUpperCase(),
toCamelCase(fieldName),
toUnderScoreCase(fieldName)
};
for (String name : possibleNames) {
try {
Field field = item.getClass().getDeclaredField(name);
field.setAccessible(true); field.setAccessible(true);
Object value = field.get(item); // 对于基本数据类型，field.get(item)会返回对应的包装类型，不会返回null
if (value != null) { // 所以不需要检查value是否为null
return value; return field.get(item);
}
} catch (Exception e) {
// 继续尝试下一个名称
} }
} catch (Exception e) {
// 如果获取字段值时出错，返回null
log.error("获取字段值失败: {}", fieldName, e);
} }
return null; return null;
...@@ -779,7 +1078,7 @@ public class ChromosomeDataService { ...@@ -779,7 +1078,7 @@ public class ChromosomeDataService {
return updateDatabaseEntity(entityName, data); return updateDatabaseEntity(entityName, data);
} }
} }
/** /**
* 更新文件实体数据 * 更新文件实体数据
*/ */
...@@ -880,7 +1179,7 @@ public class ChromosomeDataService { ...@@ -880,7 +1179,7 @@ public class ChromosomeDataService {
// 更新其他传入的字段 // 更新其他传入的字段
updateObjectFields(originalEntry, data); updateObjectFields(originalEntry, data);
// 调用editOperation方法 // 调用editOperation方法
chromosome = planResultService.editOperation(chromosome, sceneId, originalEntry ); chromosome = planResultService.editOperation(chromosome, sceneId, originalEntry );
if (originalEntry.getDesignatedStartTime()== null){ if (originalEntry.getDesignatedStartTime()== null){
...@@ -894,7 +1193,7 @@ public class ChromosomeDataService { ...@@ -894,7 +1193,7 @@ public class ChromosomeDataService {
} }
} }
// 其他字段通过updateObjectFields更新 // 其他字段通过updateObjectFields更新
} }
...@@ -906,32 +1205,32 @@ public class ChromosomeDataService { ...@@ -906,32 +1205,32 @@ public class ChromosomeDataService {
throw new RuntimeException("访问Chromosome字段失败: " + e.getMessage(), e); throw new RuntimeException("访问Chromosome字段失败: " + e.getMessage(), e);
} }
} }
/** /**
* 更新数据库实体数据 * 更新数据库实体数据
*/ */
private boolean updateDatabaseEntity(String entityName, Map<String, Object> data) { private boolean updateDatabaseEntity(String entityName, Map<String, Object> data) {
EntityConfig config = getEntityConfig(entityName); EntityConfig config = getEntityConfig(entityName);
String tableName = config.getTableName(); String tableName = config.getTableName();
if (data == null || !data.containsKey("id")) { if (data == null || !data.containsKey("id")) {
throw new RuntimeException("更新数据库实体时必须提供id字段"); throw new RuntimeException("更新数据库实体时必须提供id字段");
} }
String id = data.get("id").toString(); String id = data.get("id").toString();
// 构建更新SQL // 构建更新SQL
StringBuilder sql = new StringBuilder(); StringBuilder sql = new StringBuilder();
sql.append("UPDATE ").append(tableName).append(" SET "); sql.append("UPDATE ").append(tableName).append(" SET ");
List<String> setParts = new ArrayList<>(); List<String> setParts = new ArrayList<>();
MapSqlParameterSource params = new MapSqlParameterSource(); MapSqlParameterSource params = new MapSqlParameterSource();
// 遍历要更新的字段，排除id字段 // 遍历要更新的字段，排除id字段
for (Map.Entry<String, Object> entry : data.entrySet()) { for (Map.Entry<String, Object> entry : data.entrySet()) {
String fieldName = entry.getKey(); String fieldName = entry.getKey();
Object fieldValue = entry.getValue(); Object fieldValue = entry.getValue();
if (!"id".equalsIgnoreCase(fieldName)) { if (!"id".equalsIgnoreCase(fieldName)) {
// 将驼峰命名转换为下划线大写格式 // 将驼峰命名转换为下划线大写格式
String dbFieldName = camelCaseToUnderScoreUpperCase(fieldName).toUpperCase(); String dbFieldName = camelCaseToUnderScoreUpperCase(fieldName).toUpperCase();
...@@ -939,17 +1238,17 @@ public class ChromosomeDataService { ...@@ -939,17 +1238,17 @@ public class ChromosomeDataService {
params.addValue(fieldName, fieldValue); params.addValue(fieldName, fieldValue);
} }
} }
if (setParts.isEmpty()) { if (setParts.isEmpty()) {
throw new RuntimeException("没有有效的字段用于更新"); throw new RuntimeException("没有有效的字段用于更新");
} }
sql.append(String.join(", ", setParts)); sql.append(String.join(", ", setParts));
// 添加WHERE条件 // 添加WHERE条件
sql.append(" WHERE ID = :idParam"); sql.append(" WHERE ID = :idParam");
params.addValue("idParam", id); params.addValue("idParam", id);
try { try {
int rowsAffected = namedParameterJdbcTemplate.update(sql.toString(), params); int rowsAffected = namedParameterJdbcTemplate.update(sql.toString(), params);
return rowsAffected > 0; return rowsAffected > 0;
...@@ -1146,7 +1445,7 @@ public class ChromosomeDataService { ...@@ -1146,7 +1445,7 @@ public class ChromosomeDataService {
} }
} }
} }
if (field != null) { if (field != null) {
field.setAccessible(true); field.setAccessible(true);
...@@ -1231,7 +1530,7 @@ public class ChromosomeDataService { ...@@ -1231,7 +1530,7 @@ public class ChromosomeDataService {
} }
} }
} }
/** /**
* 将Entry列表转换为ProdProcessExec列表 * 将Entry列表转换为ProdProcessExec列表
*/ */
...@@ -1239,7 +1538,7 @@ public class ChromosomeDataService { ...@@ -1239,7 +1538,7 @@ public class ChromosomeDataService {
if (data instanceof List) { if (data instanceof List) {
List<?> entryList = (List<?>) data; List<?> entryList = (List<?>) data;
List<ProdProcessExec> result = new ArrayList<>(); List<ProdProcessExec> result = new ArrayList<>();
for (Object obj : entryList) { for (Object obj : entryList) {
if (obj instanceof Entry) { if (obj instanceof Entry) {
Entry entry = (Entry) obj; Entry entry = (Entry) obj;
...@@ -1247,22 +1546,22 @@ public class ChromosomeDataService { ...@@ -1247,22 +1546,22 @@ public class ChromosomeDataService {
result.add(prodProcessExec); result.add(prodProcessExec);
} }
} }
return result; return result;
} else if (data instanceof Entry) { } else if (data instanceof Entry) {
Entry entry = (Entry) data; Entry entry = (Entry) data;
return convertEntryToProdProcessExecSingle(entry); return convertEntryToProdProcessExecSingle(entry);
} }
return data; // 如果不是Entry类型，直接返回原数据 return data; // 如果不是Entry类型，直接返回原数据
} }
/** /**
* 将单个Entry转换为ProdProcessExec * 将单个Entry转换为ProdProcessExec
*/ */
private ProdProcessExec convertEntryToProdProcessExecSingle(Entry entry) { private ProdProcessExec convertEntryToProdProcessExecSingle(Entry entry) {
ProdProcessExec prodProcessExec = new ProdProcessExec(); ProdProcessExec prodProcessExec = new ProdProcessExec();
// 基本字段映射 // 基本字段映射
prodProcessExec.setExecId(entry.ExecId); prodProcessExec.setExecId(entry.ExecId);
prodProcessExec.setSceneId(entry.SceneId); prodProcessExec.setSceneId(entry.SceneId);
...@@ -1279,17 +1578,17 @@ public class ChromosomeDataService { ...@@ -1279,17 +1578,17 @@ public class ChromosomeDataService {
prodProcessExec.setSingleOut(entry.getSingleOut()); prodProcessExec.setSingleOut(entry.getSingleOut());
prodProcessExec.setPlanQty(entry.getQuantity()); prodProcessExec.setPlanQty(entry.getQuantity());
prodProcessExec.setLogicalOrder((long) entry.getSequence()); prodProcessExec.setLogicalOrder((long) entry.getSequence());
// 设置ID字段 // 设置ID字段
prodProcessExec.setId(String.valueOf(entry.getId())); prodProcessExec.setId(String.valueOf(entry.getId()));
// 其他字段根据需要进行映射 // 其他字段根据需要进行映射
prodProcessExec.setCanInterrupt(entry.getIsInterrupt()); prodProcessExec.setCanInterrupt(entry.getIsInterrupt());
prodProcessExec.setRoutingId(entry.getRoutingId()); prodProcessExec.setRoutingId(entry.getRoutingId());
return prodProcessExec; return prodProcessExec;
} }
/** /**
* 从Entry列表中提取MachineOption列表 * 从Entry列表中提取MachineOption列表
*/ */
...@@ -1297,8 +1596,8 @@ public class ChromosomeDataService { ...@@ -1297,8 +1596,8 @@ public class ChromosomeDataService {
if (data instanceof List) { if (data instanceof List) {
List<?> entryList = (List<?>) data; List<?> entryList = (List<?>) data;
List<MachineOption> result = new ArrayList<>(); List<MachineOption> result = new ArrayList<>();
for (Object obj : entryList) { for (Object obj : entryList) {
if (obj instanceof Entry) { if (obj instanceof Entry) {
Entry entry = (Entry) obj; Entry entry = (Entry) obj;
...@@ -1309,13 +1608,13 @@ public class ChromosomeDataService { ...@@ -1309,13 +1608,13 @@ public class ChromosomeDataService {
} }
} }
} }
return result; return result;
} else if (data instanceof Entry) { } else if (data instanceof Entry) {
Entry entry = (Entry) data; Entry entry = (Entry) data;
return entry.getMachineOptions() != null ? entry.getMachineOptions() : new ArrayList<>(); return entry.getMachineOptions() != null ? entry.getMachineOptions() : new ArrayList<>();
} }
return new ArrayList<>(); // 如果不是Entry类型，返回空列表 return new ArrayList<>(); // 如果不是Entry类型，返回空列表
} }
......
src/main/java/com/aps/service/common/DatabaseQueryService.java
View file @ fa5b9c03
...@@ -35,13 +35,23 @@ public class DatabaseQueryService { ...@@ -35,13 +35,23 @@ public class DatabaseQueryService {
// 处理条件 // 处理条件
int paramIndex = 1; int paramIndex = 1;
if (paged.getConditions() != null && !paged.getConditions().isEmpty()) { if (paged.getConditions() != null && !paged.getConditions().isEmpty()) {
boolean isAnd = paged.getAnd() != null && paged.getAnd();
String logicalOperator = isAnd ? " AND " : " OR ";
// 构建条件列表
List<String> conditionSqlList = new ArrayList<>();
for (ConditionEntity condition : paged.getConditions()) { for (ConditionEntity condition : paged.getConditions()) {
String conditionSql = buildConditionSql(condition, params, paramIndex); String conditionSql = buildConditionSql(condition, params, paramIndex);
if (conditionSql != null) { if (conditionSql != null) {
whereClause.append(" AND ").append(conditionSql); conditionSqlList.add(conditionSql);
paramIndex++; paramIndex++;
} }
} }
// 如果有条件，使用指定的逻辑运算符连接
if (!conditionSqlList.isEmpty()) {
whereClause.append(" AND (").append(String.join(logicalOperator, conditionSqlList)).append(")");
}
} }
// 构建排序 // 构建排序
...@@ -110,13 +120,23 @@ public class DatabaseQueryService { ...@@ -110,13 +120,23 @@ public class DatabaseQueryService {
// 处理条件 // 处理条件
int paramIndex = 1; int paramIndex = 1;
if (paged.getConditions() != null && !paged.getConditions().isEmpty()) { if (paged.getConditions() != null && !paged.getConditions().isEmpty()) {
boolean isAnd = paged.getAnd() != null && paged.getAnd();
String logicalOperator = isAnd ? " AND " : " OR ";
// 构建条件列表
List<String> conditionSqlList = new ArrayList<>();
for (ConditionEntity condition : paged.getConditions()) { for (ConditionEntity condition : paged.getConditions()) {
String conditionSql = buildConditionSql(condition, params, paramIndex); String conditionSql = buildConditionSql(condition, params, paramIndex);
if (conditionSql != null) { if (conditionSql != null) {
whereClause.append(" AND ").append(conditionSql); conditionSqlList.add(conditionSql);
paramIndex++; paramIndex++;
} }
} }
// 如果有条件，使用指定的逻辑运算符连接
if (!conditionSqlList.isEmpty()) {
whereClause.append(" AND (").append(String.join(logicalOperator, conditionSqlList)).append(")");
}
} }
// 构建排序 // 构建排序
...@@ -188,11 +208,48 @@ public class DatabaseQueryService { ...@@ -188,11 +208,48 @@ public class DatabaseQueryService {
* 构建排序子句 * 构建排序子句
*/ */
private String buildOrderBy(Paged paged) { private String buildOrderBy(Paged paged) {
// 优先使用sortByList进行多字段排序
if (paged.getSortByList() != null && !paged.getSortByList().isEmpty()) {
StringBuilder orderBy = new StringBuilder(" ORDER BY ");
boolean first = true;
for (String sortBy : paged.getSortByList()) {
if (!first) {
orderBy.append(", ");
}
first = false;
// 解析排序规则，格式如"field asc"或"field desc"
String[] parts = sortBy.trim().split("\\s+");
if (parts.length < 2) {
continue; // 跳过格式不正确的排序规则
}
String fieldName = parts[0];
String direction = "DESC".equalsIgnoreCase(parts[1]) ? "DESC" : "ASC";
// 处理字段名大小写问题：将驼峰命名转换为下划线大写（数据库字段格式）
fieldName = camelCaseToUnderScoreUpperCase(fieldName).toUpperCase();
orderBy.append(fieldName).append(" ").append(direction);
}
// 如果有有效的排序规则，返回构建的ORDER BY子句
if (!first) {
return orderBy.toString();
}
}
// 使用原有sortBy和desc字段进行单字段排序
if (paged.getSortBy() != null && !paged.getSortBy().isEmpty()) { if (paged.getSortBy() != null && !paged.getSortBy().isEmpty()) {
String direction = Boolean.TRUE.equals(paged.getDesc()) ? "DESC" : "ASC"; String direction = Boolean.TRUE.equals(paged.getDesc()) ? "DESC" : "ASC";
return " ORDER BY " + paged.getSortBy() + " " + direction; // 处理字段名大小写问题：将驼峰命名转换为下划线大写（数据库字段格式）
String fieldName = camelCaseToUnderScoreUpperCase(paged.getSortBy()).toUpperCase();
return " ORDER BY " + fieldName + " " + direction;
} }
return " ORDER BY ID DESC"; // 默认按ID降序
// 默认按ID降序
return " ORDER BY ID DESC";
} }
/** /**
...@@ -262,7 +319,7 @@ public class DatabaseQueryService { ...@@ -262,7 +319,7 @@ public class DatabaseQueryService {
return fieldName + " = :" + paramName; return fieldName + " = :" + paramName;
} }
} }
/** /**
* 驼峰命名转下划线大写：prodProduct -> PROD_PRODUCT * 驼峰命名转下划线大写：prodProduct -> PROD_PRODUCT
*/ */
......
src/main/java/com/aps/service/impl/DiscreteParameterDurationServiceImpl.java
View file @ fa5b9c03
package com.aps.service.impl; package com.aps.service.impl;
import com.aps.entity.Algorithm.GAScheduleResult; import com.aps.entity.Algorithm.GAScheduleResult;
import com.aps.entity.DiscreteParameterConfigType;
import com.aps.entity.DiscreteParameterDuration; import com.aps.entity.DiscreteParameterDuration;
import com.aps.entity.basic.Entry; import com.aps.entity.basic.Entry;
import com.aps.entity.basic.Machine; import com.aps.entity.basic.Machine;
...@@ -22,24 +23,23 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa ...@@ -22,24 +23,23 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa
* 计算当前工序需要的换型时间 * 计算当前工序需要的换型时间
*/ */
@Override @Override
public double calculateChangeoverTime(List<GAScheduleResult> existingGenes, public double calculateChangeoverTime(Entry lastEntry,
Entry operation, Entry entry,
Machine machine, Machine machine,
List<Entry> allOperations, List<Entry> allOperations,int startTime,List<GAScheduleResult> machineTasks) {
int startTime) {
if (existingGenes.isEmpty()) { if ( machineTasks.isEmpty()) {
return 0.0; return 0.0;
} }
// 获取当前工序的所有参数 // 获取当前工序的所有参数
List<ParameterPair> currentParams = getOperationParameters(operation); List<ParameterPair> currentParams = getOperationParameters(entry);
if (currentParams.isEmpty()) { if (currentParams.isEmpty()) {
return 0.0; return 0.0;
} }
// 获取设备上最后一个任务 // 获取设备上最后一个任务
GAScheduleResult lastGene = existingGenes.stream() GAScheduleResult lastGene = machineTasks.stream()
.filter(g -> g.getMachineId() == machine.getId()) .filter(g -> g.getMachineId() == machine.getId())
.max(Comparator.comparingInt(GAScheduleResult::getEndTime)) .max(Comparator.comparingInt(GAScheduleResult::getEndTime))
.orElse(null); .orElse(null);
...@@ -48,27 +48,18 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa ...@@ -48,27 +48,18 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa
return 0.0; return 0.0;
} }
if (operation.getOrderId()=="a0e61488-0647-4f8e-a27c-cfed9cbbba52"){
System.out.println("lastGene"+lastGene.getExecId());
}
// 找到最后一个任务对应的Entry
Entry prev = allOperations.stream()
.filter(t -> t.getExecId().equals(lastGene.getExecId()))
.findFirst().orElse(null);
if (prev == null) { if (lastEntry == null) {
return 0.0; return 0.0;
} }
List<ParameterPair> lastParams = getOperationParameters(prev); List<ParameterPair> lastParams = getOperationParameters(lastEntry);
List<DiscreteParameterDuration> parameterDurations = this.lambdaQuery().list(); List<DiscreteParameterDuration> parameterDurations = this.lambdaQuery().list();
// 获取该设备上的所有任务（按开始时间排序） // 获取该设备上的所有任务（按开始时间排序）
List<GAScheduleResult> machineGenes = existingGenes.stream() List<GAScheduleResult> machineGenes = machineTasks.stream()
.filter(g -> g.getMachineId() == machine.getId()) .filter(g -> g.getMachineId() == machine.getId())
.sorted(Comparator.comparingInt(GAScheduleResult::getStartTime)) .sorted(Comparator.comparingInt(GAScheduleResult::getStartTime))
.collect(Collectors.toList()); .collect(Collectors.toList());
...@@ -122,7 +113,7 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa ...@@ -122,7 +113,7 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa
List<DiscreteParameterDuration> parameterDurations, List<DiscreteParameterDuration> parameterDurations,
List<Entry> allOperations) { List<Entry> allOperations) {
DiscreteParameterDuration config = findParameterConfig(currentParam, "WorkingDuration", parameterDurations); DiscreteParameterDuration config = findParameterConfig(currentParam, DiscreteParameterConfigType.WORKING_DURATION, parameterDurations);
if (config == null) { if (config == null) {
return 0.0; return 0.0;
} }
...@@ -161,7 +152,7 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa ...@@ -161,7 +152,7 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa
List<DiscreteParameterDuration> parameterDurations, List<DiscreteParameterDuration> parameterDurations,
int startTime, List<Entry> allOperations) { int startTime, List<Entry> allOperations) {
DiscreteParameterDuration config = findParameterConfig(currentParam, "AbsoluteDuration", parameterDurations); DiscreteParameterDuration config = findParameterConfig(currentParam, DiscreteParameterConfigType.ABSOLUTE_DURATION, parameterDurations);
if (config == null) { if (config == null) {
return 0.0; return 0.0;
} }
...@@ -197,7 +188,7 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa ...@@ -197,7 +188,7 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa
List<DiscreteParameterDuration> parameterDurations, List<DiscreteParameterDuration> parameterDurations,
int startTime, List<Entry> allOperations) { int startTime, List<Entry> allOperations) {
DiscreteParameterDuration config = findParameterConfig(currentParam, "MaxInterval", parameterDurations); DiscreteParameterDuration config = findParameterConfig(currentParam, DiscreteParameterConfigType.MAX_INTERVAL, parameterDurations);
if (config == null) { if (config == null) {
return 0.0; return 0.0;
} }
...@@ -231,7 +222,7 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa ...@@ -231,7 +222,7 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa
List<DiscreteParameterDuration> parameterDurations, List<DiscreteParameterDuration> parameterDurations,
List<Entry> allOperations) { List<Entry> allOperations) {
DiscreteParameterDuration config = findParameterConfig(currentParam, "OrderCount", parameterDurations); DiscreteParameterDuration config = findParameterConfig(currentParam, DiscreteParameterConfigType.ORDER_COUNT, parameterDurations);
if (config == null) { if (config == null) {
return 0.0; return 0.0;
} }
...@@ -409,12 +400,12 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa ...@@ -409,12 +400,12 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa
.collect(Collectors.toList()); .collect(Collectors.toList());
} }
private DiscreteParameterDuration findParameterConfig(ParameterPair param, String configType, private DiscreteParameterDuration findParameterConfig(ParameterPair param, DiscreteParameterConfigType configType,
List<DiscreteParameterDuration> parameterDurations) { List<DiscreteParameterDuration> parameterDurations) {
return parameterDurations.stream() return parameterDurations.stream()
.filter(pd -> param.getGroupId().equals(pd.getGroupid()) && .filter(pd -> param.getGroupId().equals(pd.getGroupid()) &&
param.getParameterId().equals(pd.getParameterid()) && param.getParameterId().equals(pd.getParameterid()) &&
configType.equals(pd.getExp1())) configType.getValue()==pd.getMeasureparameterid())
.findFirst() .findFirst()
.orElse(null); .orElse(null);
} }
...@@ -443,7 +434,7 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa ...@@ -443,7 +434,7 @@ public class DiscreteParameterDurationServiceImpl extends ServiceImpl<DiscretePa
List<DiscreteParameterDuration> parameterDurations, List<DiscreteParameterDuration> parameterDurations,
List<Entry> allOperations) { List<Entry> allOperations) {
DiscreteParameterDuration config = findParameterConfig(currentParam, "AccumulatedQuantity", parameterDurations); DiscreteParameterDuration config = findParameterConfig(currentParam, DiscreteParameterConfigType.WORKING_QUANTITY, parameterDurations);
if (config == null) { if (config == null) {
return 0.0; return 0.0;
} }
......
src/main/java/com/aps/service/impl/DiscreteParameterMatrixServiceImpl.java
View file @ fa5b9c03
...@@ -35,6 +35,8 @@ public class DiscreteParameterMatrixServiceImpl extends ServiceImpl<DiscretePara ...@@ -35,6 +35,8 @@ public class DiscreteParameterMatrixServiceImpl extends ServiceImpl<DiscretePara
@Override @Override
public double getDiscreteParameterMatrixValue(Entry entry, Entry lastEntry) { public double getDiscreteParameterMatrixValue(Entry entry, Entry lastEntry) {
// 参数校验 // 参数校验
cleanCache(resultCache, MAX_RESULT_CACHE_SIZE);
if (entry == null || lastEntry == null) { if (entry == null || lastEntry == null) {
return 0.0; return 0.0;
......
src/main/java/com/aps/service/impl/LanuchServiceImpl.java
View file @ fa5b9c03
...@@ -27,6 +27,7 @@ import java.time.LocalDate; ...@@ -27,6 +27,7 @@ import java.time.LocalDate;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.time.LocalTime; import java.time.LocalTime;
import java.util.*; import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import static org.springframework.beans.BeanUtils.copyProperties; import static org.springframework.beans.BeanUtils.copyProperties;
...@@ -42,55 +43,25 @@ import static org.springframework.beans.BeanUtils.copyProperties; ...@@ -42,55 +43,25 @@ import static org.springframework.beans.BeanUtils.copyProperties;
@RequiredArgsConstructor @RequiredArgsConstructor
public class LanuchServiceImpl implements LanuchService { public class LanuchServiceImpl implements LanuchService {
@Autowired private final ProdEquipSpecialCalService prodEquipSpecialCalService;
private ProdEquipSpecialCalService prodEquipSpecialCalService; private final ApsOrderService apsOrderService;
@Autowired private final ProdLaunchOrderService prodLaunchOrderService;
private ApsOrderService apsOrderService; private final RoutingDetailMapper routingDetailMapper;
private final ProdProcessExecService prodProcessExecService;
@Autowired private final RoutingDetailConnectService routingDetailConnectService;
private RoutingHeaderService routingHeaderService; private final ProdOrderProcessService prodOrderProcessService;
@Autowired private final RoutingHeaderMapper routingHeaderMapper;
private ProdLaunchOrderService prodLaunchOrderService; private final ProdSceneConfigService prodSceneConfigService;
@Autowired private final ProdEquipmentService prodEquipmentService;
private RoutingDetailMapper routingDetailMapper; private final RoutingDetailEquipService routingDetailEquipService;
@Autowired private final SceneService sceneService;
private ProdProcessExecService prodProcessExecService; private final MesOrderService mesOrderService;
private final DispatchService dispatchService;
@Autowired private final MesScheduleService mesScheduleService;
private RoutingDetailConnectService routingDetailConnectService; private final Equiptype1Service equiptype1Service;
@Autowired private final PlanResourceService planResourceService;
private ProdOrderProcessService prodOrderProcessService; private final OrderMaterialRequirementService orderMaterialRequirementService;
private final EquipinfoService equipinfoService;
@Autowired
private RoutingHeaderMapper routingHeaderMapper;
@Autowired
private ProdSceneConfigService prodSceneConfigService;
@Autowired
private ProdEquipmentService prodEquipmentService;
@Autowired
private RoutingDetailEquipService routingDetailEquipService;
@Autowired
private SceneService sceneService;
@Autowired
private MesOrderService mesOrderService;
@Autowired
private DispatchService dispatchService;
@Autowired
private RoutingDiscreteParamService routingDiscreteParamService;
@Autowired
private MesScheduleService mesScheduleService;
@Autowired
private Equiptype1Service equiptype1Service;
@Autowired
private PlanResourceService planResourceService;
@Autowired
private OrderMaterialRequirementService orderMaterialRequirementService;
@Autowired
private EquipinfoService equipinfoService;
/** /**
* 生成场景数据 * 生成场景数据
* *
...@@ -113,14 +84,14 @@ public class LanuchServiceImpl implements LanuchService { ...@@ -113,14 +84,14 @@ public class LanuchServiceImpl implements LanuchService {
String sceneId = null; String sceneId = null;
// 1. 创建场景 // 1. 创建场景
ProdSceneConfig sceneConfig = createScene(sceneName, username); ProdSceneConfig sceneConfig = createScene(sceneName, username);
if (sceneConfig == null) { if (sceneConfig == null) {
throw new RuntimeException("场景名称已存在"); throw new RuntimeException("场景名称已存在");
} }
sceneId = sceneConfig.getSceneId(); sceneId = sceneConfig.getSceneId();
prodEquipSpecialCalService.copyFromEquipCapacityDef(sceneId); prodEquipSpecialCalService.copyFromEquipCapacityDef(sceneId);
List<MesSchedule> mesSchedules = mesScheduleService.lambdaQuery() List<MesSchedule> mesSchedules = mesScheduleService.lambdaQuery()
...@@ -130,38 +101,38 @@ public class LanuchServiceImpl implements LanuchService { ...@@ -130,38 +101,38 @@ public class LanuchServiceImpl implements LanuchService {
// 2. 获取工单列表 // 2. 获取工单列表
List<String> apsOrderIds = mesSchedules.stream() List<String> apsOrderIds = mesSchedules.stream()
.map(MesSchedule::getApsOrderId) .map(MesSchedule::getApsOrderId)
.filter(Objects::nonNull) .filter(Objects::nonNull)
.collect(Collectors.toList()); .collect(Collectors.toList());
List<ApsOrder> apsOrders; List<ApsOrder> apsOrders;
if (apsOrderIds.isEmpty()) { if (apsOrderIds.isEmpty()) {
apsOrders = new ArrayList<>(); apsOrders = new ArrayList<>();
} else { } else {
apsOrders = apsOrderService.lambdaQuery() apsOrders = apsOrderService.lambdaQuery()
.eq(ApsOrder::getIsdeleted, 0) .eq(ApsOrder::getIsdeleted, 0)
.eq(ApsOrder::getStatus, 4) .eq(ApsOrder::getStatus, 4)
// .eq(ApsOrder::getCreatoruserid, username) // .eq(ApsOrder::getCreatoruserid, username)
.in(ApsOrder::getId, apsOrderIds) .in(ApsOrder::getId, apsOrderIds)
.list(); .list();
} }
if (CollectionUtils.isEmpty(apsOrders)) { if (CollectionUtils.isEmpty(apsOrders)) {
throw new SceneGenerationException("工单列表不能为空"); throw new SceneGenerationException("工单列表不能为空");
} }
// 4. 处理工单数据转换 // 4. 处理工单数据转换
List<ProdLaunchOrder> prodLaunchOrders = processOrderData(sceneId, apsOrders); List<ProdLaunchOrder> prodLaunchOrders = processOrderData(sceneId, apsOrders);
// 5. 转换工单于工序执行表 // 5. 转换工单于工序执行表
convertToProcessExecBatch(prodLaunchOrders, sceneId); convertToProcessExecBatch(prodLaunchOrders, sceneId);
// 6. 生成工序关联关系 // 6. 生成工序关联关系
generateProcessRelationsBatch(prodLaunchOrders, sceneId); generateProcessRelationsBatch(prodLaunchOrders, sceneId);
log.info("场景数据生成完成，场景ID：{}", sceneId); log.info("场景数据生成完成，场景ID：{}", sceneId);
return R.ok(sceneConfig); return R.ok(sceneConfig);
} }
...@@ -304,7 +275,7 @@ public class LanuchServiceImpl implements LanuchService { ...@@ -304,7 +275,7 @@ public class LanuchServiceImpl implements LanuchService {
// 先删除表中所有数据 // 先删除表中所有数据
orderMaterialRequirementService.remove(new LambdaQueryWrapper<>()); orderMaterialRequirementService.remove(new LambdaQueryWrapper<>());
// 再批量插入新数据 // 再批量插入新数据
orderMaterialRequirementService.saveBatch(orderMaterials); orderMaterialRequirementService.saveBatch(orderMaterials);
...@@ -735,11 +706,11 @@ public class LanuchServiceImpl implements LanuchService { ...@@ -735,11 +706,11 @@ public class LanuchServiceImpl implements LanuchService {
{ {
Equiptype1 equipType = equiptype1Service.lambdaQuery().eq(Equiptype1::getId, detail.getEquipTypeId()).one(); Equiptype1 equipType = equiptype1Service.lambdaQuery().eq(Equiptype1::getId, detail.getEquipTypeId()).one();
if (equipType != null) { if (equipType != null) {
prodProcessExec.setEquipTypeName(equipType.getEquipTypeName()); prodProcessExec.setEquipTypeName(equipType.getEquipTypeName());
prodProcessExec.setEquipTypeCode(equipType.getEquipTypeId()); prodProcessExec.setEquipTypeCode(equipType.getEquipTypeId());
}
} }
}
prodProcessExec.setPlanQty(prodOrderMain.getQuantity()); prodProcessExec.setPlanQty(prodOrderMain.getQuantity());
prodProcessExec.setTargetStartDate(prodOrderMain.getStartDate()); prodProcessExec.setTargetStartDate(prodOrderMain.getStartDate());
prodProcessExec.setTargetEndDate(prodOrderMain.getEndDate()); prodProcessExec.setTargetEndDate(prodOrderMain.getEndDate());
...@@ -904,29 +875,29 @@ public class LanuchServiceImpl implements LanuchService { ...@@ -904,29 +875,29 @@ public class LanuchServiceImpl implements LanuchService {
String execId = routingDetailIdToExecIdMap.get(connection.getSourceoperationid() + "_" + prodOrderMain.getOrderId()); String execId = routingDetailIdToExecIdMap.get(connection.getSourceoperationid() + "_" + prodOrderMain.getOrderId());
String targetExecId = routingDetailIdToExecIdMap.get(connection.getDestoperationid() + "_" + prodOrderMain.getOrderId()); String targetExecId = routingDetailIdToExecIdMap.get(connection.getDestoperationid() + "_" + prodOrderMain.getOrderId());
if (connection.getDestoperationid() !=null && connection.getSourceoperationid() != null && execId != null && targetExecId != null) { if (connection.getDestoperationid() !=null && connection.getSourceoperationid() != null && execId != null && targetExecId != null) {
prodOrderProcess.setTaskSeq(getTaskSeqFromRoutingDetail(connection.getSourceoperationid(), connection.getSourceoperation())); prodOrderProcess.setTaskSeq(getTaskSeqFromRoutingDetail(connection.getSourceoperationid(), connection.getSourceoperation()));
prodOrderProcess.setTargetTaskSeq(getTaskSeqFromRoutingDetail(connection.getDestoperationid(), connection.getDestoperation())); prodOrderProcess.setTargetTaskSeq(getTaskSeqFromRoutingDetail(connection.getDestoperationid(), connection.getDestoperation()));
prodOrderProcess.setSceneId(sceneId); prodOrderProcess.setSceneId(sceneId);
prodOrderProcess.setOrderId(prodOrderMain.getOrderId()); prodOrderProcess.setOrderId(prodOrderMain.getOrderId());
// prodOrderProcess.setTaskSeq(connection.getSourceoperation()); // prodOrderProcess.setTaskSeq(connection.getSourceoperation());
prodOrderProcess.setTargetOrderId(prodOrderMain.getOrderId()); prodOrderProcess.setTargetOrderId(prodOrderMain.getOrderId());
// prodOrderProcess.setTargetTaskSeq(connection.getDestoperation()); // prodOrderProcess.setTargetTaskSeq(connection.getDestoperation());
prodOrderProcess.setId(String.valueOf(SnowFlackIdWorker.getId())); prodOrderProcess.setId(String.valueOf(SnowFlackIdWorker.getId()));
if (execId != null) { if (execId != null) {
prodOrderProcess.setExecId(execId); prodOrderProcess.setExecId(execId);
} }
if (targetExecId != null) { if (targetExecId != null) {
prodOrderProcess.setTargetExecId(targetExecId); prodOrderProcess.setTargetExecId(targetExecId);
} }
} }
return prodOrderProcess; return prodOrderProcess;
} }
...@@ -993,86 +964,169 @@ if (connection.getDestoperationid() !=null && connection.getSourceoperationid() ...@@ -993,86 +964,169 @@ if (connection.getDestoperationid() !=null && connection.getSourceoperationid()
// log.warn("工艺设备列表为空，跳过设备对照表生成"); // log.warn("工艺设备列表为空，跳过设备对照表生成");
// return null; // return null;
// } // }
// 预加载数据并转换为Map以提高查询效率
List<Equiptype1> equipTypes = equiptype1Service.lambdaQuery().eq(Equiptype1::getIsdeleted, 0).list(); List<Equiptype1> equipTypes = equiptype1Service.lambdaQuery().eq(Equiptype1::getIsdeleted, 0).list();
Map<Long, Equiptype1> equipTypeMap = equipTypes.stream()
.collect(Collectors.toMap(Equiptype1::getId, Function.identity()));
List<PlanResource> list = planResourceService.lambdaQuery() List<PlanResource> list = planResourceService.lambdaQuery()
.eq(PlanResource::getIsdeleted, 0) .eq(PlanResource::getIsdeleted, 0)
.list(); .list();
Map<Integer, PlanResource> planResourceMap = list.stream()
.collect(Collectors.toMap(PlanResource::getId, Function.identity()));
Map<Integer, PlanResource> planResourceByReferenceIdMap = list.stream()
.filter(pr -> pr.getReferenceId() != null)
.collect(Collectors.toMap(PlanResource::getReferenceId, Function.identity()));
// 转换equipinfo为Map
Map<Integer, Equipinfo> equipinfoMap = equipinfo.stream()
.collect(Collectors.toMap(Equipinfo::getId, Function.identity()));
Map<Integer, List<Equipinfo>> equipinfoByEquipTypeMap = equipinfo.stream()
.filter(e -> e.getEquipType() != null)
.collect(Collectors.groupingBy(Equipinfo::getEquipType));
// 创建ProdEquipment列表 // 创建ProdEquipment列表
List<ProdEquipment> prodEquipments = new java.util.ArrayList<>(); List<ProdEquipment> prodEquipments = new ArrayList<>();
if (routingDetailEquips != null && routingDetailEquips.size() > 0) { if (routingDetailEquips != null && !routingDetailEquips.isEmpty()) {
// 遍历RoutingDetailEquip列表，转换为ProdEquipment对象 // 遍历RoutingDetailEquip列表，转换为ProdEquipment对象
for (RoutingDetailEquip routingDetailEquip : routingDetailEquips) { for (RoutingDetailEquip routingDetailEquip : routingDetailEquips) {
ProdEquipment prodEquipment = new ProdEquipment(); try {
prodEquipment.setSceneId(sceneId); ProdEquipment prodEquipment = new ProdEquipment();
prodEquipment.setEquipId(routingDetailEquip.getEquipId().longValue()); prodEquipment.setSceneId(sceneId);
prodEquipment.setEquipId(routingDetailEquip.getEquipId().longValue());
Integer i = list.stream().filter(equip -> equip.getId().equals(routingDetailEquip.getEquipId().intValue())).findFirst().map(PlanResource::getReferenceId).orElse(null);
// 使用Map快速查询，替代多次stream操作
Equipinfo equipinfo1 = equipinfo.stream().filter(equip -> equip.getId().equals(i)).findFirst().orElse(null); PlanResource planResource = planResourceMap.get(routingDetailEquip.getEquipId().intValue());
if (planResource != null && planResource.getReferenceId() != null) {
Equipinfo equipinfo1 = equipinfoMap.get(planResource.getReferenceId());
if (equipinfo1 != null) {
prodEquipment.setEquipCode(equipinfo1.getEquipId());
prodEquipment.setEquipName(equipinfo1.getEquipName());
} else {
log.warn("未找到referenceId={}对应的设备信息", planResource.getReferenceId());
continue;
}
} else {
log.warn("未找到equipId={}对应的PlanResource信息", routingDetailEquip.getEquipId());
continue;
}
prodEquipment.setEquipCode(equipinfo1.getEquipId()); // 使用Map快速查询
prodEquipment.setEquipName(equipinfo1.getEquipName()); Long resourceId = routingDetailEquip.getType1();
prodEquipment.setResourceId(resourceId);
Equiptype1 equiptype1 = equipTypeMap.get(resourceId);
if (equiptype1 != null) {
prodEquipment.setResourceCode(equiptype1.getEquipTypeId());
}
prodEquipment.setResourceId(routingDetailEquip.getType1()); prodEquipment.setEfficiencyValue(routingDetailEquip.getEfficiencyValue());
prodEquipment.setSetupTime(routingDetailEquip.getSetupTime());
prodEquipment.setId(String.valueOf(SnowFlackIdWorker.getId()));
prodEquipment.setRuntime(routingDetailEquip.getDuration());
prodEquipment.setSingleOut(routingDetailEquip.getOutputQuantity());
// 计算speed
prodEquipment.setSpeed(
Optional.ofNullable(routingDetailEquip.getDuration())
.filter(out -> routingDetailEquip.getOutputQuantity() != null)
.filter(out -> routingDetailEquip.getOutputQuantity().compareTo(BigDecimal.ZERO) != 0)
.map(out -> out.divide(routingDetailEquip.getOutputQuantity(), 6, RoundingMode.HALF_UP))
.map(BigDecimal::doubleValue)
.orElse(0.0)
);
// 查找execId
Long routingDetailId = routingDetailEquip.getRoutingDetailId();
String execId = null;
if (routingDetailId != null) {
execId = processExecList.stream()
.filter(exec -> routingDetailId.equals(exec.getRoutingDetailId()))
.findFirst()
.map(ProdProcessExec::getExecId)
.orElse(null);
}
if (execId != null) {
prodEquipment.setExecId(execId);
} else {
log.warn("未找到routingDetailId={}对应的execId", routingDetailEquip.getRoutingDetailId());
}
Equiptype1 equiptype1 = equipTypes.stream().filter(equip -> equip.getId().equals(routingDetailEquip.getType1())) prodEquipments.add(prodEquipment);
.findFirst() } catch (Exception e) {
.orElse(null); log.error("处理设备信息失败，routingDetailEquipId={}", routingDetailEquip.getId(), e);
}
}
} else {
// 当routingDetailEquips为null时，遍历processExecList，根据machineId去equipinfo里面找设备然后创建prodEquipMent
if (processExecList != null && !processExecList.isEmpty()) {
for (ProdProcessExec exec : processExecList) {
try {
// 获取machineId
Long machineId = exec.getMachineId();
if (machineId == null) {
continue;
}
// 使用Map快速查询设备列表
List<Equipinfo> matchedEquipments = equipinfoByEquipTypeMap.get(machineId.intValue());
if (matchedEquipments == null || matchedEquipments.isEmpty()) {
log.warn("未找到machineId={}对应的设备信息", machineId);
continue;
}
// 遍历所有匹配的设备，创建ProdEquipment对象
for (Equipinfo equipinfo1 : matchedEquipments) {
ProdEquipment prodEquipment = new ProdEquipment();
prodEquipment.setSceneId(sceneId);
// 使用Map快速查询，替代stream操作
PlanResource planResource = planResourceByReferenceIdMap.get(equipinfo1.getId());
if (planResource != null) {
prodEquipment.setEquipId(planResource.getId().longValue());
} else {
log.warn("未找到equipinfoId={}对应的planResource信息", equipinfo1.getId());
continue;
}
prodEquipment.setEquipCode(equipinfo1.getEquipId());
prodEquipment.setEquipName(equipinfo1.getEquipName());
if (equiptype1 != null) { // 使用Map快速查询
prodEquipment.setResourceCode(equiptype1.getEquipTypeId()); prodEquipment.setResourceId(machineId);
} Equiptype1 equiptype1 = equipTypeMap.get(machineId);
prodEquipment.setEfficiencyValue(routingDetailEquip.getEfficiencyValue()); if (equiptype1 != null) {
prodEquipment.setSetupTime(routingDetailEquip.getSetupTime()); prodEquipment.setResourceCode(equiptype1.getEquipTypeId());
prodEquipment.setId(String.valueOf(SnowFlackIdWorker.getId()));
prodEquipment.setRuntime(routingDetailEquip.getDuration());
prodEquipment.setSingleOut(routingDetailEquip.getOutputQuantity());
prodEquipment.setSpeed(
Optional.ofNullable(routingDetailEquip.getDuration())
.filter(out -> routingDetailEquip.getOutputQuantity() != null)
.filter(out -> routingDetailEquip.getOutputQuantity().compareTo(BigDecimal.ZERO) != 0)
.map(out -> out.divide(routingDetailEquip.getOutputQuantity(), 6, RoundingMode.HALF_UP))
.map(BigDecimal::doubleValue) // 关键转换
.orElse(0.0)
);
String execId = processExecList.stream()
.filter(exec -> {
Long execRoutingDetailId = exec.getRoutingDetailId();
Long equipRoutingDetailId = routingDetailEquip.getRoutingDetailId();
// 处理null值
if (execRoutingDetailId == null || equipRoutingDetailId == null) {
return false;
} }
// 使用equals比较 // 设置其他属性
return execRoutingDetailId.equals(equipRoutingDetailId); prodEquipment.setEfficiencyValue(1.0); // 默认效率值
}) prodEquipment.setSetupTime(0); // 默认准备时间
.findFirst() prodEquipment.setId(String.valueOf(SnowFlackIdWorker.getId()));
.map(ProdProcessExec::getExecId) prodEquipment.setRuntime(exec.getRuntime());
.orElse(null); prodEquipment.setSingleOut(exec.getSingleOut());
if (execId != null) {
prodEquipment.setExecId(execId); // 计算speed
} else { prodEquipment.setSpeed(
log.warn("未找到routingDetailId={}对应的execId", routingDetailEquip.getRoutingDetailId()); Optional.ofNullable(exec.getRuntime())
.filter(out -> exec.getSingleOut() != null)
.filter(out -> exec.getSingleOut().compareTo(BigDecimal.ZERO) != 0)
.map(out -> out.divide(exec.getSingleOut(), 6, RoundingMode.HALF_UP))
.map(BigDecimal::doubleValue)
.orElse(0.0)
);
// 设置execId
prodEquipment.setExecId(exec.getExecId());
prodEquipments.add(prodEquipment);
}
} catch (Exception e) {
log.error("处理工序执行设备信息失败，execId={}", exec.getExecId(), e);
}
} }
prodEquipments.add(prodEquipment);
} }
}else {
} }
// 批量保存 // 批量保存
if (!prodEquipments.isEmpty()&&isSave) { if (!prodEquipments.isEmpty()&&isSave) {
......
src/main/java/com/aps/service/plan/PlanResultService.java
View file @ fa5b9c03
...@@ -1095,7 +1095,7 @@ private GlobalParam InitGlobalParam() ...@@ -1095,7 +1095,7 @@ private GlobalParam InitGlobalParam()
{ {
globalParam.setIsUseCalendar(c.isValue()); globalParam.setIsUseCalendar(c.isValue());
} }
else if(c.getTitle().contains("设置时间")) else if(c.getTitle().equals("设置时间"))
{ {
//是否考虑换型时间 //是否考虑换型时间
globalParam.set_smoothChangeOver(c.isValue()); globalParam.set_smoothChangeOver(c.isValue());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment