xdd 1 settimana fa
parent
commit
8ca314faa8

+ 2 - 1
fs-service-system/src/main/java/com/fs/company/cache/ICompanyTagCacheService.java

@@ -1,5 +1,6 @@
 package com.fs.company.cache;
 
+import com.fs.company.domain.CompanyTag;
 import com.fs.company.dto.CompanyIdAndUserDTO;
 
 import java.util.Map;
@@ -7,5 +8,5 @@ import java.util.Map;
 public interface ICompanyTagCacheService {
     String findUserTagByUserId(Long userId);
 
-    Map<Long, String> queryAllTagMap();
+    Map<Long, CompanyTag> queryAllTagMap();
 }

+ 3 - 2
fs-service-system/src/main/java/com/fs/company/cache/impl/CompanyTagCacheServiceImpl.java

@@ -1,6 +1,7 @@
 package com.fs.company.cache.impl;
 
 import com.fs.company.cache.ICompanyTagCacheService;
+import com.fs.company.domain.CompanyTag;
 import com.fs.company.service.ICompanyTagService;
 import com.github.benmanes.caffeine.cache.Cache;
 import com.github.benmanes.caffeine.cache.Caffeine;
@@ -20,7 +21,7 @@ public class CompanyTagCacheServiceImpl implements ICompanyTagCacheService {
             .expireAfterWrite(5, TimeUnit.MINUTES)
             .build();
 
-    private static final Cache<Long,Map<Long, String>> COMPANY_USER_TAG_CACHE = Caffeine.newBuilder()
+    private static final Cache<Long,Map<Long, CompanyTag>> COMPANY_USER_TAG_CACHE = Caffeine.newBuilder()
             .maximumSize(1000)
             .expireAfterWrite(5, TimeUnit.MINUTES)
             .build();
@@ -30,7 +31,7 @@ public class CompanyTagCacheServiceImpl implements ICompanyTagCacheService {
     }
 
     @Override
-    public Map<Long, String> queryAllTagMap() {
+    public Map<Long, CompanyTag> queryAllTagMap() {
         return COMPANY_USER_TAG_CACHE.get(0L, e-> companyTagService.queryAllTagMap());
     }
 }

+ 1 - 1
fs-service-system/src/main/java/com/fs/company/mapper/CompanyTagMapper.java

@@ -80,5 +80,5 @@ public interface CompanyTagMapper
 
     String findUserTagByUserId(@Param("userId") Long userId);
     @MapKey("tag_id")
-    Map<Long,String> queryAllTagMap();
+    Map<Long,CompanyTag> queryAllTagMap();
 }

+ 1 - 1
fs-service-system/src/main/java/com/fs/company/service/ICompanyTagService.java

@@ -76,7 +76,7 @@ public interface ICompanyTagService
      */
     List<CompanyTag> selectCompanyTagListByMap(Map<String, Object> params);
 
-    Map<Long,String> queryAllTagMap();
+    Map<Long,CompanyTag> queryAllTagMap();
 
     String findUserTagByUserId(Long key);
 }

+ 1 - 1
fs-service-system/src/main/java/com/fs/company/service/impl/CompanyTagServiceImpl.java

@@ -120,7 +120,7 @@ public class CompanyTagServiceImpl implements ICompanyTagService
     }
 
     @Override
-    public Map<Long, String> queryAllTagMap() {
+    public Map<Long, CompanyTag> queryAllTagMap() {
         return companyTagMapper.queryAllTagMap();
     }
 

+ 5 - 3
fs-service-system/src/main/java/com/fs/store/service/impl/FsUserServiceImpl.java

@@ -526,13 +526,15 @@ public class FsUserServiceImpl implements IFsUserService
                 String userTagByUserId = companyTagCacheService.findUserTagByUserId(item.getUserId());
                 if(StringUtils.isNotEmpty(userTagByUserId)) {
                     String[] split = userTagByUserId.split(",");
-                    Map<Long, String> tagMap = companyTagCacheService.queryAllTagMap();
+                    Map<Long, CompanyTag> tagMap = companyTagCacheService.queryAllTagMap();
                     Set<String> tagNames = new HashSet<>();
                     for (String tag : split) {
                         if(tag != null) {
                             Long tagL = Long.parseLong(tag);
-                            String tagName = tagMap.get(tagL);
-                            tagNames.add(tagName);
+                            CompanyTag companyTag = tagMap.get(tagL);
+                            if(companyTag != null) {
+                                tagNames.add(companyTag.getTag());
+                            }
                         }
                     }
                     item.setTagIds(userTagByUserId);