From e8ed1a91c77ab62a924f12acd55777f227bacd7e Mon Sep 17 00:00:00 2001
From: yangys <y_ys79@sina.com>
Date: 星期五, 21 十一月 2025 17:15:17 +0800
Subject: [PATCH] 工位组删除后，其下工位移动到默认组
---
smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/ProcessParameterServiceImpl.java | 199 +++++++++++++++++++++++++++----------------------
1 files changed, 110 insertions(+), 89 deletions(-)
diff --git a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/ProcessParameterServiceImpl.java b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/ProcessParameterServiceImpl.java
index 59262ad..d832ade 100644
--- a/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/ProcessParameterServiceImpl.java
+++ b/smart-man-boot/src/main/java/com/qianwen/smartman/modules/mdc/service/impl/ProcessParameterServiceImpl.java
@@ -1,20 +1,7 @@
package com.qianwen.smartman.modules.mdc.service.impl;
-import cn.hutool.core.lang.Tuple;
-import cn.hutool.core.util.ObjectUtil;
-
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
-import com.baomidou.dynamic.datasource.annotation.DS;
-import com.baomidou.mybatisplus.core.metadata.IPage;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.google.common.collect.Lists;
-import com.google.common.collect.Maps;
-import com.google.common.collect.Sets;
-
import java.sql.ResultSet;
import java.sql.SQLException;
-import java.sql.Timestamp;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
@@ -28,8 +15,29 @@
import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
+import org.springframework.stereotype.Service;
+import org.springframework.web.multipart.MultipartFile;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
+import com.google.common.collect.Sets;
+import com.qianwen.core.log.exception.ServiceException;
+import com.qianwen.core.mp.support.Query;
+import com.qianwen.core.oss.model.BladeFile;
+import com.qianwen.core.tool.jackson.JsonUtil;
+import com.qianwen.core.tool.utils.DateUtil;
+import com.qianwen.core.tool.utils.Func;
import com.qianwen.smartman.common.cache.cps.TimeSliceCache;
import com.qianwen.smartman.common.cache.cps.WorkstationCache;
import com.qianwen.smartman.common.constant.DateConstant;
@@ -38,23 +46,18 @@
import com.qianwen.smartman.common.enums.WcsDataTypeEnums;
import com.qianwen.smartman.common.utils.ListUtils;
import com.qianwen.smartman.common.utils.MessageUtils;
-import com.qianwen.core.log.exception.ServiceException;
-import com.qianwen.core.mp.support.Query;
-import com.qianwen.core.oss.model.BladeFile;
-import com.qianwen.core.tool.jackson.JsonUtil;
-import com.qianwen.core.tool.utils.DateUtil;
-import com.qianwen.core.tool.utils.Func;
-import com.qianwen.smartman.modules.cps.dto.CalendarShiftDTO;
-import com.qianwen.smartman.modules.cps.dto.CalendarShiftTimeSlicesDTO;
-import com.qianwen.smartman.modules.cps.dto.WorkstationWcsDmpDTO;
-import com.qianwen.smartman.modules.cps.entity.GlobalWcs;
-import com.qianwen.smartman.modules.cps.entity.Workstation;
-import com.qianwen.smartman.modules.cps.service.ICalendarService;
-import com.qianwen.smartman.modules.cps.service.IWorkstationService;
-import com.qianwen.smartman.modules.cps.service.WorkstationDatapointsService;
-import com.qianwen.smartman.modules.cps.utils.ThrowFun;
-import com.qianwen.smartman.modules.cps.vo.ShiftTimeDetailVO;
-import com.qianwen.smartman.modules.cps.vo.WorkstationDatapointsVO;
+import com.qianwen.smartman.modules.smis.dto.CalendarShiftDTO;
+import com.qianwen.smartman.modules.smis.dto.CalendarShiftTimeSlicesDTO;
+import com.qianwen.smartman.modules.smis.dto.WorkstationWcsDmpDTO;
+import com.qianwen.smartman.modules.smis.entity.GlobalWcs;
+import com.qianwen.smartman.modules.smis.entity.Workstation;
+import com.qianwen.smartman.modules.smis.service.ICalendarService;
+import com.qianwen.smartman.modules.smis.service.IWorkstationService;
+import com.qianwen.smartman.modules.smis.service.WorkstationDatapointsService;
+import com.qianwen.smartman.modules.smis.utils.ThrowFun;
+import com.qianwen.smartman.modules.smis.vo.ShiftTimeDetailVO;
+import com.qianwen.smartman.modules.smis.vo.WorkstationDatapointsVO;
+import com.qianwen.smartman.modules.mdc.dto.DatapointDTO;
import com.qianwen.smartman.modules.mdc.dto.GroupWorkDTO;
import com.qianwen.smartman.modules.mdc.dto.NewParamDTO;
import com.qianwen.smartman.modules.mdc.dto.ParamDTO;
@@ -63,10 +66,9 @@
import com.qianwen.smartman.modules.mdc.dto.ProcessParameterVO;
import com.qianwen.smartman.modules.mdc.dto.ProcessWcsDTO;
import com.qianwen.smartman.modules.mdc.dto.StatusDTO;
-import com.qianwen.smartman.modules.mdc.entity.LastProcessParam;
import com.qianwen.smartman.modules.mdc.entity.WorkstationCollectData;
import com.qianwen.smartman.modules.mdc.enums.ProcessParamEnum;
-import com.qianwen.smartman.modules.mdc.mapper.SuperCollectJsonMapper;
+//import com.qianwen.smartman.modules.mdc.mapper.SuperCollectJsonMapper;
import com.qianwen.smartman.modules.mdc.mapper.SuperProcessParameterMapper;
import com.qianwen.smartman.modules.mdc.service.IProcessParameterService;
import com.qianwen.smartman.modules.mdc.service.ProcessParameterHelperService;
@@ -83,17 +85,14 @@
import com.qianwen.smartman.modules.mdc.vo.excel.ProcessParamExcelVO;
import com.qianwen.smartman.modules.resource.builder.oss.OssBuilder;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.jdbc.core.JdbcTemplate;
-import org.springframework.jdbc.core.RowMapper;
-import org.springframework.stereotype.Service;
-import org.springframework.web.multipart.MultipartFile;
+import cn.hutool.core.lang.Tuple;
+import cn.hutool.core.util.ObjectUtil;
@Service
public class ProcessParameterServiceImpl implements IProcessParameterService {
private static final Logger log = LoggerFactory.getLogger(ProcessParameterServiceImpl.class);
- @Autowired
- private SuperCollectJsonMapper collectJsonMapper;
+ //@Autowired
+ //private SuperCollectJsonMapper collectJsonMapper;
@Autowired
private IWorkstationService workstationService;
@Autowired
@@ -109,15 +108,7 @@
@Autowired
private ProcessParameterHelperService helperService;
- /*
- public ProcessParameterServiceImpl(final SuperCollectJsonMapper collectJsonMapper, final IWorkstationService workstationService, final OssBuilder ossBuilder, final SuperProcessParameterMapper parameterMapper, final ICalendarService calendarService) {
- this.collectJsonMapper = collectJsonMapper;
- this.workstationService = workstationService;
- this.ossBuilder = ossBuilder;
- this.parameterMapper = parameterMapper;
- this.calendarService = calendarService;
- }*/
-
+
@Override
public ProcessParameterResVO queryProcessParameterChart(ProcessParameterSearchVO vo) {
ProcessParamEnum methodEnum = vo.getMethodEnum();
@@ -142,6 +133,7 @@
int current = query.getCurrent().intValue();
long startTime = vo.getStartTime().getTime();
long endTime = vo.getEndTime().getTime();
+
String workstationId = vo.getWorkstationId();
Integer flag = vo.getFlag();
String item = vo.getItem();
@@ -150,7 +142,8 @@
if (total == 0) {
return page;
}
- List<ProcessParameterVO> res = this.parameterMapper.pageProcessParameter(Integer.valueOf(size), Integer.valueOf((current - 1) * size), Long.valueOf(startTime), Long.valueOf(endTime), item, workstationId);
+
+ List<ProcessParameterVO> res = this.parameterMapper.pageProcessParameter(size,(current - 1) * size, startTime, endTime, item, workstationId);
Map<String, String> map = getWcsMap();
List<ProcessParameterRealVO> collect = res.stream().map(c -> {
String value;
@@ -164,17 +157,10 @@
page.setRecords(collect);
return page;
}
-
+ /*
@Override
public List<WorkstationWcsDmpDTO> processParam(String workstationId) {
- /*
- List<WorkstationWcsDmpDTO> vos =WorkstationCache.getWorkstationWcsList(workstationId).stream().filter((v0) -> {
- return v0.getProcessParameter();
- }).collect(Collectors.toList());
- if (Func.isEmpty(vos)) {
- return Lists.newArrayList();
- }
- return vos;*/
+
//鑾峰彇灞曠ず鍦ㄨ繃绋嬪弬鏁颁腑鐨勫彉閲�
List<WorkstationWcsDmpDTO> dps = new ArrayList<>();
@@ -217,7 +203,25 @@
}
return dps;
}
-
+ */
+ @Override
+ public List<DatapointDTO> processParams(String workstationId) {
+ //鑾峰彇灞曠ず鍦ㄨ繃绋嬪弬鏁颁腑鐨勫彉閲�
+ if(ObjectUtil.isEmpty(workstationId)) {
+ return Collections.emptyList();
+ }
+ WorkstationDatapointsVO dpVo = dpService.getDatapoints(Long.parseLong(workstationId));
+ if(ObjectUtil.isEmpty(dpVo.getDpConfig())) {
+ return Collections.emptyList();
+ }
+
+ //JSONArray dpArrJson = JSONArray.parseArray(dpVo.getDpConfig());
+ List<DatapointDTO> list = JSONObject.parseArray(dpVo.getDpConfig(),DatapointDTO.class);
+
+ return list.stream().filter(dp -> dp.getIsProcessParam()!=null && dp.getIsProcessParam()).collect(Collectors.toList());
+
+ }
+ /*
@Override
public ProParamSheetVO queryProcessParameterSheet(ProcessParameterSearchVO vo, Boolean isFilterProcessParameter) {
ProcessParamEnum methodEnum = vo.getMethodEnum();
@@ -229,8 +233,8 @@
default:
return new ProParamSheetVO();
}
- }
-
+ }*/
+ /*
@Override
public BladeFile exportProcessParam(ProcessParamExcelVO vo) {
try {
@@ -240,7 +244,7 @@
throw new RuntimeException(e);
}
}
-
+ */
@Override
public ShiftTimeVO getShiftTime(ProcessParameterSearchVO vo) {
String workstationId = vo.getWorkstationId();
@@ -266,16 +270,16 @@
if (startTime.after(now)) {
return new CollectParamResVO<>();
}
- //String workstationId = vo.getWorkstationId();
+
Long workstationId = Long.parseLong(vo.getWorkstationId());
- List<ProcessParameterVO> processParameterList = getProcessParameterList(startTime, endTime, workstationId, vo.getDmpDTO());
- return getCollectParamResVO(vo.getDmpDTO(), processParameterList);
+ List<ProcessParameterVO> processParameterList = getProcessParameterList(startTime, endTime, workstationId, vo.getDpDTO());
+ return getCollectParamResVO(vo.getDpDTO(), processParameterList);
}
- private CollectParamResVO<?> getCollectParamResVO(WorkstationWcsDmpDTO dmpDTO, List<ProcessParameterVO> processParameterList) {
+ private CollectParamResVO<?> getCollectParamResVO(DatapointDTO dpDTO, List<ProcessParameterVO> processParameterList) {//WorkstationWcsDmpDTO dmpDTO
//鐘舵�佺壒娈婂鐞嗭紵
//if (WcsDataTypeEnums.WcsDataType.STATE.getCode().equals(dmpDTO.getWcsDataType())) {//yys
- if (WcsDataTypeEnums.WcsDataType.STATE.getCode().equals(dmpDTO.getWcsDataType())) {
+ if ("DeviceStatus".equals(dpDTO.getDpName())) {//鐘舵�侊紝闇�瑕佺壒娈婂鐞�
Map<String, String> colorMap = Maps.newHashMap();
Map<String, String> nameMap = Maps.newHashMap();
Set<String> codes = Sets.newHashSet();
@@ -288,25 +292,26 @@
return StatusDTO.builder().time(DateUtil.formatDateTime(DateUtil.fromMilliseconds(param.getRealTime().longValue()))).name((String) nameMap.get(param.getValue())).color((String) colorMap.get(param.getValue())).value(param.getValue()).build();
}).collect(Collectors.toList());*/
return CollectParamResVO.<StatusDTO>builder()
- .collectItem(dmpDTO.getDescription())
- .collectRealItem(dmpDTO.getName())
+ .collectItem(dpDTO.getDpLabel())
+ .collectRealItem(dpDTO.getDpName())
.data(list)
.build();
//return CollectParamResVO.builder().collectItem(dmpDTO.getDescription()).collectRealItem(dmpDTO.getName()).data(list).build();
}
//绌烘寚閽�
List<ParamDTO> collect = processParameterList.stream().map(param -> ParamDTO.builder().time(DateUtil.formatDateTime(DateUtil.fromMilliseconds(param.getRealTime().longValue()))).value(param.getValue()).build()).collect(Collectors.toList());
+ /*
return CollectParamResVO.<ParamDTO>builder()
.collectItem(dmpDTO.getDescription())
.collectRealItem(dmpDTO.getName())
.data(collect)
.build();
- /*
- List<ParamDTO> collect2 = (List) processParameterList.stream().map(param2 -> {
- return ParamDTO.builder().time(DateUtil.formatDateTime(DateUtil.fromMilliseconds(param2.getRealTime().longValue()))).value(param2.getValue()).build();
- }).collect(Collectors.toList());
- return CollectParamResVO.builder().collectItem(dmpDTO.getDescription()).collectRealItem(dmpDTO.getName()).data(collect2).build();
- */
+ */
+ return CollectParamResVO.<ParamDTO>builder()
+ .collectItem(dpDTO.getDpLabel())
+ .collectRealItem(dpDTO.getDpName())
+ .data(collect)
+ .build();
}
private void buildWcsMap(Map<String, String> colorMap, Map<String, String> nameMap, Set<String> codes) {
@@ -326,13 +331,13 @@
* @param dmpDTO
* @return
*/
- private List<ProcessParameterVO> getProcessParameterList(Date startTime, Date endTime, Long workstationId, WorkstationWcsDmpDTO dmpDTO) {
- ProcessParameterVO firstStatue = oldFirstStatue(startTime, dmpDTO.getName(), workstationId);
- ProcessParameterVO endStatue = oldLastStatue(endTime, dmpDTO.getName(), workstationId);
+ private List<ProcessParameterVO> getProcessParameterList(Date startTime, Date endTime, Long workstationId, DatapointDTO dpDTO) {//WorkstationWcsDmpDTO dmpDTO
+ ProcessParameterVO firstStatue = oldFirstStatue(startTime, dpDTO.getDpName(), workstationId);
+ ProcessParameterVO endStatue = oldLastStatue(endTime, dpDTO.getDpName(), workstationId);
- List<ProcessParameterVO> processParameterList = oldOneCollectList(startTime, endTime, dmpDTO.getName(), workstationId);
+ List<ProcessParameterVO> processParameterList = oldOneCollectList(startTime, endTime, dpDTO.getDpName(), workstationId);
if (Func.isNotEmpty(processParameterList)) {
- if (Func.notNull(firstStatue) && !firstStatue.getRealTime().equals(Long.valueOf(startTime.getTime()))) {
+ if (Func.notNull(firstStatue) && !firstStatue.getRealTime().equals(startTime.getTime())) {
firstStatue.setRealTime(startTime.getTime());
processParameterList.add(0, firstStatue);
}
@@ -451,7 +456,7 @@
return entityVO(parameterList, wcs, collectItemMap);
}).orElse(new ProcessParameterResVO());
}
-
+ /*
private ProParamSheetVO buildProcessHourSheet(ProcessParameterSearchVO vo, Boolean isFilterProcessParameter) {
Date startTime = vo.getStartTime();
Date endTime = vo.getEndTime();
@@ -478,8 +483,8 @@
return new ProParamSheetVO();
}
return buildSheetVO(vos, dtoList, wcs, getWcsMap());
- }
-
+ }*/
+ /*
private ProParamSheetVO buildProcessShiftSheet(ProcessParameterSearchVO vo, Boolean isFilterProcessParameter) {
Integer shift = vo.getShift();
LocalDate queryTime = vo.getQueryTime();
@@ -505,8 +510,8 @@
return new ProParamSheetVO();
}
return buildSheetVO(vos, dtoList, wcs, getWcsMap());
- }
-
+ }*/
+ /*
private BladeFile exportByHour(ProcessParamExcelVO vo) throws Exception {
Date startTime = vo.getStartTime();
Date endTime = vo.getEndTime();
@@ -519,7 +524,8 @@
MultipartFile multipartFile = ExcelStrategyUtil.customerStyleExport(fileName, ExcelConstant.SHEET, head, content);
return this.ossBuilder.tempTemplate().putFile(multipartFile.getOriginalFilename(), multipartFile);
}
-
+ */
+ /*
private List<List<Object>> buildExcelContentByHour(Long workstationId, List<WorkstationWcsDmpDTO> collectItem, Date startTime, Date endTime) {
Workstation workstation = (Workstation) this.workstationService.getById(workstationId);
Map<Long, GroupWorkDTO> groupWorkMap = this.workstationService.queryGroupWorkStation(Lists.newArrayList(new Long[]{workstation.getId()}));
@@ -534,7 +540,7 @@
return Lists.newArrayList();
}
return buildExcelContentByHour(collectItem, parameterList, wcs, workstation, groupName, timeShiftAll);
- }
+ }*/
private List<List<Object>> buildExcelContentByHour(List<WorkstationWcsDmpDTO> collectItem, List<NewParamDTO> parameterList, WorkstationWcsDmpDTO wcs, Workstation workstation, String groupName, List<CalendarShiftDTO> timeShiftAll) {
List<Tuple> times = timeShiftAll.stream().map(calendarShiftDTO -> {
@@ -578,11 +584,11 @@
}
return head;
}
-
+ /*
private List<NewParamDTO> processParameterList(Date startTime, Date endTime, String workstationId) {
return this.collectJsonMapper.queryProcessParameter(workstationId, Long.valueOf(startTime.getTime()), Long.valueOf(endTime.getTime()));
}
-
+ */
private List<ProcessParameterVO> oldProcessParameterList(Date startTime, Date endTime, List<String> collectItems, String workstationId) {
return this.parameterMapper.queryProcessParameter(workstationId, collectItems, Long.valueOf(startTime.getTime()), Long.valueOf(endTime.getTime()));
}
@@ -596,6 +602,13 @@
return vo;
}
+ /**
+ *
+ * @param endTime
+ * @param item 鏁版嵁鐐瑰悕绉�,濡侽utput
+ * @param workstationId
+ * @return
+ */
private ProcessParameterVO oldLastStatue(Date endTime, String item, Long workstationId) {
//ProcessParameterVO vo = this.parameterMapper.oldLastStatue(workstationId, item, Long.valueOf(endTime.getTime()));
ProcessParameterVO vo = helperService.getLastParameterGreaterThenTime(workstationId, item, endTime.getTime());
@@ -605,6 +618,14 @@
return vo;
}
+ /**
+ *
+ * @param startTime
+ * @param endTime
+ * @param item 鏁版嵁鐐瑰悕绉帮紝濡侽utput
+ * @param workstationId
+ * @return
+ */
private List<ProcessParameterVO> oldOneCollectList(Date startTime, Date endTime, String item, Long workstationId) {
List<ProcessParameterVO> list = this.parameterMapper.oldOneCollectList(workstationId, item, startTime.getTime(), endTime.getTime());
list.forEach(p -> {p.setRealTime(p.getTime().getTime());});
--
Gitblit v1.9.3