干燥机配套车间生产管理系统/云平台服务端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
bsw215583320
2024-11-22 ca75cf818e434f77ca71d78ac2c883ca41b18713 
 jeecg-module-dry/jeecg-module-dry-biz/src/main/java/org/jeecg/modules/dry/service/impl/DryEquipmentServiceImpl.java


@@ -1,17 +1,23 @@


package org.jeecg.modules.dry.service.impl;




import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import org.jeecg.common.config.TenantContext;


import org.jeecg.common.constant.CommonCacheConstant;


import org.jeecg.common.util.RedisUtil;


import org.jeecg.modules.dry.common.CacheConstants;


import org.jeecg.modules.dry.entity.DryEquipment;


import org.jeecg.modules.dry.mapper.DryEquipmentMapper;


import org.jeecg.modules.dry.service.IDryEquipmentService;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.cache.annotation.Cacheable;


import org.springframework.stereotype.Service;




import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;




import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.function.Function;


import java.util.stream.Collectors;




/**


 * @Description: 干燥机


@@ -24,6 +30,8 @@




    @Autowired


    private RedisUtil redisUtil;






    @Override


    public DryEquipment selectByTenantIdEquipmentId(String tenantId, String equipmentId) {


        DryEquipment dryEquipment = (DryEquipment) redisUtil.hget(CacheConstants.RedisKeyEnum.EQP_MAP.getCode(), tenantId + equipmentId);


@@ -39,4 +47,20 @@


        }


        return dryEquipment;


    }




    @Override


    @Cacheable(cacheNames = CommonCacheConstant.DRY_CACHE_TENANT_EQUS, key = "#tenantId" , unless = "#result == null " )


    public Map<String,DryEquipment> queryEquByTenantId(Integer tenantId) {


        TenantContext.setTenant(tenantId +"");


        QueryWrapper<DryEquipment> queryWrapper  = new QueryWrapper<>();


        queryWrapper.lambda().eq(DryEquipment::getTenantId,tenantId);


        List<DryEquipment> equipmentList = this.list(queryWrapper);


        Map<String, DryEquipment> userMap = equipmentList.stream()


                .collect(Collectors.toMap(


                        DryEquipment::getCode,


                        Function.identity(),


                        (existingValue, newValue) -> existingValue // 如果键冲突，保留旧值


                ));


        return userMap;


    }


}