| | |
| | | import com.qianwen.smartman.common.enums.GlobalWcsTypeEnum; |
| | | import com.qianwen.smartman.common.enums.WcsDataTypeEnums; |
| | | import com.qianwen.smartman.common.utils.CommonUtil; |
| | | import com.qianwen.smartman.modules.cps.convert.WorkstationConvert; |
| | | import com.qianwen.smartman.modules.cps.dto.WorkstationDTO; |
| | | import com.qianwen.smartman.modules.cps.dto.WorkstationParamTypeDTO; |
| | | import com.qianwen.smartman.modules.cps.dto.WorkstationWcsDTO; |
| | | 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.message.dto.TelemetryDataResponseDTO; |
| | | import com.qianwen.smartman.modules.cps.service.IGlobalWcsService; |
| | | import com.qianwen.smartman.modules.cps.service.IMachineService; |
| | | import com.qianwen.smartman.modules.cps.service.IWorkstationService; |
| | | import com.qianwen.smartman.modules.cps.service.IWorkstationWcsService; |
| | | import com.qianwen.smartman.modules.cps.vo.WorkstationInGroupVO; |
| | | import com.qianwen.smartman.modules.smis.convert.WorkstationConvert; |
| | | import com.qianwen.smartman.modules.smis.dto.WorkstationDTO; |
| | | import com.qianwen.smartman.modules.smis.dto.WorkstationParamTypeDTO; |
| | | import com.qianwen.smartman.modules.smis.dto.WorkstationWcsDTO; |
| | | 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.message.dto.TelemetryDataResponseDTO; |
| | | import com.qianwen.smartman.modules.smis.service.IGlobalWcsService; |
| | | import com.qianwen.smartman.modules.smis.service.IMachineService; |
| | | import com.qianwen.smartman.modules.smis.service.IWorkstationService; |
| | | import com.qianwen.smartman.modules.smis.service.IWorkstationWcsService; |
| | | import com.qianwen.smartman.modules.smis.vo.WorkstationInGroupVO; |
| | | import com.qianwen.smartman.modules.mdc.dto.WorkstationDmpDTO; |
| | | import com.qianwen.smartman.modules.mdc.entity.WorkstationCollectData; |
| | | import com.qianwen.smartman.modules.mdc.mapper.SuperProcessParameterMapper; |
| | | import com.qianwen.smartman.modules.mdc.service.IProcessParameterService; |
| | | |
| | | public class WorkstationCache { |
| | | public static final String CRC = "crc:"; |
| | |
| | | private static final IGlobalWcsService WCS_SERVICE = (IGlobalWcsService) SpringUtil.getBean(IGlobalWcsService.class); |
| | | private static final IWorkstationWcsService WORKSTATION_WCS_SERVICE = (IWorkstationWcsService) SpringUtil.getBean(IWorkstationWcsService.class); |
| | | private static final SuperProcessParameterMapper superProcessParameterMapper = (SuperProcessParameterMapper) SpringUtil.getBean(SuperProcessParameterMapper.class); |
| | | |
| | | private static final IProcessParameterService processParameterService = SpringUtil.getBean(IProcessParameterService.class); |
| | | |
| | | public static List<WorkstationWcsDmpDTO> getWorkstationWcsList(String workstationId) { |
| | | String redisKey = CommonUtil.getReallyCacheName(ExtCacheConstant.CPS_CACHE, WORKSTATION_WCS, "", workstationId); |
| | | SetOperations<String, Object> setOps = BLADE_REDIS.getSetOps(); |
| | |
| | | String cacheName = CommonUtil.getReallyCacheName(ExtCacheConstant.CPS_CACHE, WORKSTATION_REAL_TIME, "", workstationId); |
| | | Map<String, Object> resultMapping = BLADE_REDIS.hGetAll(cacheName); |
| | | if (Func.isEmpty(resultMapping)) { |
| | | List<WorkstationCollectData> workstationCollectData = superProcessParameterMapper.queryLastParameter(workstationId); |
| | | // |
| | | //List<WorkstationCollectData> workstationCollectData = superProcessParameterMapper.queryLastParameter(workstationId); |
| | | Long wid = Long.parseLong(workstationId); |
| | | List<WorkstationCollectData> workstationCollectData = processParameterService.queryLastParameter(wid); |
| | | if (Func.isNotEmpty(workstationCollectData)) { |
| | | resultMapping = workstationCollectData.stream().collect(Collectors.toMap((v0) -> { |
| | | return v0.getN(); |
| | |
| | | return result; |
| | | })); |
| | | } |
| | | |
| | | } |
| | | return resultMapping; |
| | | } |