Public/cf_imes_server
6
0
Fork 0
mirror of http://192.168.1.205:9980/cf_devdept2/cf_imes_server.git synced 2026-08-12 21:02:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

获取生产单源数据-优化时的数据新增随机ID

Browse Source
This commit is contained in:
liuzhaotian
2024-05-22 14:11:59 +08:00
parent 5fb2084f28
commit 0873a73196
2 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/controller/admin/plan/vo/OptimizePlateDetialRespVO.java
+3
View File
@@ -8,6 +8,9 @@ import lombok.Data;
@Data
public class OptimizePlateDetialRespVO {
@Schema(description = "id", requiredMode = Schema.RequiredMode.REQUIRED)
private Long id;
@Schema(description = "大板名称", requiredMode = Schema.RequiredMode.REQUIRED)
private String plateName;
cf-module-prod-executor/cf-module-prod-executor-biz/src/main/java/com/cf/imes/module/executor/service/optimizeplan/OptimizePlanServiceImpl.java
+11 -1
View File
@@ -1,6 +1,8 @@
package com.cf.imes.module.executor.service.optimizeplan;
import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.StrUtil;
import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.elasticsearch._types.FieldValue;
@@ -90,7 +92,7 @@ public class OptimizePlanServiceImpl implements OptimizePlanService {
@Resource
private ElasticsearchClient elasticsearchClient;
//public static final String ORDER_PLATE_MODEL = "imes_order_plate_model";
private Snowflake snowflake = IdUtil.getSnowflake();
@Resource
private MachineApi machineApi;
@@ -302,6 +304,10 @@ public class OptimizePlanServiceImpl implements OptimizePlanService {
OrderSource orderSource = new OrderSource();
List<OptimizePlateDetialRespVO> optimizePlateDetialRespVO = plateMapper.selectPlate(orderId);
// 赋值随机ID
for (OptimizePlateDetialRespVO plateDetialRespVO : optimizePlateDetialRespVO) {
plateDetialRespVO.setId(snowflake.nextId());
}
List<GoodsDO> goodsDOS = goodsMapper.selectList(new LambdaQueryWrapperX<GoodsDO>()
.eq(GoodsDO::getOrderId, orderId)
@@ -340,6 +346,10 @@ public class OptimizePlanServiceImpl implements OptimizePlanService {
List<Long> orderIds = orderItemDOS.stream().map(OrderItemDO::getOrderId).collect(Collectors.toList());
List<OptimizePlateDetialRespVO> optimizePlateDetialRespVOS = plateMapper.selectPlateListByOrderIds(orderIds);
// 赋值随机ID
for (OptimizePlateDetialRespVO plateDetialRespVO : optimizePlateDetialRespVOS) {
plateDetialRespVO.setId(snowflake.nextId());
}
List<OrderDO> orderDOS = orderMapper.selectBatchIds(orderIds);