| | |
| | | package com.qianwen.smartman.modules.fms.service.impl; |
| | | |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.google.common.base.Joiner; |
| | | import java.lang.invoke.SerializedLambda; |
| | | import java.util.Arrays; |
| | | import java.util.List; |
| | | |
| | | import org.apache.commons.compress.utils.Lists; |
| | | import com.qianwen.smartman.common.utils.ExtraLambdaQueryWrapper; |
| | | import com.qianwen.smartman.common.utils.Lambda; |
| | | import com.qianwen.smartman.common.websocket.fms.FmsVisualDataRequestMessage; |
| | | import com.qianwen.smartman.common.websocket.fms.FmsVisualDataResponseMessage; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | import com.baomidou.mybatisplus.core.metadata.IPage; |
| | | import com.google.common.base.Joiner; |
| | | import com.qianwen.core.mp.base.BaseServiceImpl; |
| | | import com.qianwen.core.mp.support.Query; |
| | | import com.qianwen.core.tool.utils.Func; |
| | | import com.qianwen.smartman.common.utils.Lambda; |
| | | import com.qianwen.smartman.common.websocket.fms.FmsVisualDataRequestMessage; |
| | | import com.qianwen.smartman.common.websocket.fms.FmsVisualDataResponseMessage; |
| | | import com.qianwen.smartman.modules.fms.convert.FmsAbnormalConvert; |
| | | import com.qianwen.smartman.modules.fms.convert.FmsInstructionRecordConvert; |
| | | import com.qianwen.smartman.modules.fms.entity.FmsAbnormal; |
| | |
| | | import com.qianwen.smartman.modules.fms.vo.FmsOrderQueryVO; |
| | | import com.qianwen.smartman.modules.fms.vo.FmsOrderVO; |
| | | import com.qianwen.smartman.modules.fms.vo.FmsVO; |
| | | import org.springframework.stereotype.Service; |
| | | |
| | | @Service |
| | | /* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/fms/service/impl/FmsAbnormalServiceImpl.class */ |
| | | public class FmsAbnormalServiceImpl extends BaseServiceImpl<FmsAbnormalMapper, FmsAbnormal> implements IFmsAbnormalService { |
| | | private final IFmsOrderService fmsOrderService; |
| | | private final IFmsInstructionRecordService fmsInstructionRecordService; |
| | | |
| | | private static /* synthetic */ Object $deserializeLambda$(SerializedLambda lambda) { |
| | | String implMethodName = lambda.getImplMethodName(); |
| | | boolean z = true; |
| | | switch (implMethodName.hashCode()) { |
| | | case 1071464927: |
| | | if (implMethodName.equals("getCreateTime")) { |
| | | z = false; |
| | | break; |
| | | } |
| | | break; |
| | | } |
| | | switch (z) { |
| | | case false: |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/util/Date;")) { |
| | | return (v0) -> { |
| | | return v0.getCreateTime(); |
| | | }; |
| | | } |
| | | if (lambda.getImplMethodKind() == 5 && lambda.getFunctionalInterfaceClass().equals("com/baomidou/mybatisplus/core/toolkit/support/SFunction") && lambda.getFunctionalInterfaceMethodName().equals("apply") && lambda.getFunctionalInterfaceMethodSignature().equals("(Ljava/lang/Object;)Ljava/lang/Object;") && lambda.getImplClass().equals("org/springblade/core/mp/base/BaseEntity") && lambda.getImplMethodSignature().equals("()Ljava/util/Date;")) { |
| | | return (v0) -> { |
| | | return v0.getCreateTime(); |
| | | }; |
| | | } |
| | | break; |
| | | } |
| | | throw new IllegalArgumentException("Invalid lambda deserialization"); |
| | | } |
| | | |
| | | public FmsAbnormalServiceImpl(final IFmsOrderService fmsOrderService, final IFmsInstructionRecordService fmsInstructionRecordService) { |
| | | this.fmsOrderService = fmsOrderService; |
| | |
| | | if (Func.isNotEmpty(records)) { |
| | | fmsVO.setFmsOrderVOList(records); |
| | | } |
| | | List<FmsAbnormal> fmsAbnormalList = list(Lambda.<FmsAbnormal>create().orderByDesc(FmsAbnormal::getCreateTime).limit(10)); |
| | | /* |
| | | List<FmsAbnormal> fmsAbnormalList = list(((ExtraLambdaQueryWrapper) Lambda.create().orderByDesc((v0) -> { |
| | | return v0.getCreateTime(); |
| | | })).limit(10)); |
| | | })).limit(10));*/ |
| | | fmsVO.setAbnormalList(FmsAbnormalConvert.INSTANCE.convert(fmsAbnormalList)); |
| | | List<FmsInstructionRecord> instructionRecordList = this.fmsInstructionRecordService.list(Lambda.<FmsInstructionRecord>create().orderByDesc(FmsInstructionRecord::getCreateTime).limit(10)); |
| | | /* |
| | | List<FmsInstructionRecord> instructionRecordList = this.fmsInstructionRecordService.list(((ExtraLambdaQueryWrapper) Lambda.create().orderByDesc((v0) -> { |
| | | return v0.getCreateTime(); |
| | | })).limit(10)); |
| | | })).limit(10));*/ |
| | | instructionRecordList.forEach(x -> { |
| | | FmsInstructionRecordVO fmsInstructionRecordVO = FmsInstructionRecordConvert.INSTANCE.convert(x); |
| | | fmsInstructionRecordVO.setStateName(InstructionEnum.of(x.getState()).getDesc()); |