lutong il y a 16 heures
Parent
commit
4ff01cb9e3

+ 28 - 24
alien-store-platform/src/main/java/shop/alien/storeplatform/service/impl/LicenseServiceImpl.java

@@ -35,10 +35,14 @@ import java.util.*;
 @RequiredArgsConstructor
 public class LicenseServiceImpl implements LicenseService {
 
-    /** 商户图片数据访问对象 */
+    /**
+     * 商户图片数据访问对象
+     */
     private final StoreImgMapper storeImgMapper;
 
-    /** 商户证照历史记录数据访问对象 */
+    /**
+     * 商户证照历史记录数据访问对象
+     */
     private final StoreLicenseHistoryMapper licenseHistoryMapper;
 
     private final StoreInfoMapper storeInfoMapper;
@@ -46,7 +50,7 @@ public class LicenseServiceImpl implements LicenseService {
 
     @Override
     public int uploadfoodLicence(StoreImg storeImg) {
-        storeImgMapper.delete(new LambdaQueryWrapper<StoreImg>().eq(StoreImg::getImgType,24).eq(StoreImg::getStoreId,storeImg.getStoreId()));
+        storeImgMapper.delete(new LambdaQueryWrapper<StoreImg>().eq(StoreImg::getImgType, 24).eq(StoreImg::getStoreId, storeImg.getStoreId()));
         storeImg.setImgType(24);
         storeImg.setImgDescription("经营许可证审核通过前图片");
         storeImgMapper.insert(storeImg);
@@ -78,7 +82,7 @@ public class LicenseServiceImpl implements LicenseService {
      * @return 营业执照图片列表
      */
     @Override
-    public List<StoreImg> getbusinessLicenseList (Integer id) {
+    public List<StoreImg> getbusinessLicenseList(Integer id) {
         // 查询图片类型为14(营业执照)的图片列表
         return storeImgMapper.selectList(new LambdaQueryWrapper<StoreImg>()
                 .eq(StoreImg::getImgType, 14)
@@ -95,11 +99,11 @@ public class LicenseServiceImpl implements LicenseService {
      * @return 合同图片列表
      */
     @Override
-    public List<StoreImgDTO> getContractList (Integer id) {
+    public List<StoreImgDTO> getContractList(Integer id) {
 
 
         StoreInfo storeInfo = storeInfoMapper.selectOne(new LambdaQueryWrapper<StoreInfo>().eq(StoreInfo::getId, id));
-        
+
 
         log.info("getEntertainmentLicenseList - 查询商户ID为 {} 的娱乐经营许可证图片列表", id);
         List<StoreImg> storeImgList = storeImgMapper.selectList(new LambdaQueryWrapper<StoreImg>()
@@ -130,11 +134,11 @@ public class LicenseServiceImpl implements LicenseService {
      * @return 食品经营许可证图片列表
      */
     @Override
-    public List<StoreImgDTO> getFoodLicenceList (Integer id) {
-         log.info("getEntertainmentLicenseList - 查询商户ID为 {} 的娱乐经营许可证图片列表", id);
-        
+    public List<StoreImgDTO> getFoodLicenceList(Integer id) {
+        log.info("getEntertainmentLicenseList - 查询商户ID为 {} 的娱乐经营许可证图片列表", id);
+
         StoreInfo storeInfo = storeInfoMapper.selectOne(new LambdaQueryWrapper<StoreInfo>().eq(StoreInfo::getId, id));
-        
+
         // 查询图片类型为25(食品经营许可证)的图片列表
         List<StoreImg> storeImgList = storeImgMapper.selectList(new LambdaQueryWrapper<StoreImg>()
                 .eq(StoreImg::getImgType, 25)
@@ -165,7 +169,7 @@ public class LicenseServiceImpl implements LicenseService {
      * @return 证照历史记录VO列表
      */
     @Override
-    public List<StoreLicenseHistoryDto> queryLicenceByStatusList (Integer storeId) {
+    public List<StoreLicenseHistoryDto> queryLicenceByStatusList(Integer storeId) {
 
         List<StoreLicenseHistory> licenseList = licenseHistoryMapper.queryLicenceByStatusList(storeId, 2, 1);
 
@@ -222,7 +226,7 @@ public class LicenseServiceImpl implements LicenseService {
 
         Date date = new Date();
         //先清除数据
-        storeImgMapper.delete(new LambdaQueryWrapper<StoreImg>().eq(StoreImg::getImgType,22).eq(StoreImg::getStoreId,value));
+        storeImgMapper.delete(new LambdaQueryWrapper<StoreImg>().eq(StoreImg::getImgType, 22).eq(StoreImg::getStoreId, value));
         for (StoreImg renewContract : storeImgList) {
             StoreImg storeImg = new StoreImg();
             storeImg.setStoreId(renewContract.getStoreId());
@@ -320,7 +324,7 @@ public class LicenseServiceImpl implements LicenseService {
      * @return 按时间分组的证照历史记录列表
      */
     @Override
-    public List<StoreLicenseHistoryDto> queryContractByStatusList (Integer storeId) {
+    public List<StoreLicenseHistoryDto> queryContractByStatusList(Integer storeId) {
 
         // 查询证照类型为1(合同管理)的记录
         List<StoreLicenseHistory> licenseList = licenseHistoryMapper.queryLicenceByStatusList(storeId, 1, 1);
@@ -392,29 +396,29 @@ public class LicenseServiceImpl implements LicenseService {
         // 第三步:将分组后的数据转换为列表结构
         // 每个时间节点创建一个父对象,将该时间的所有记录存储到 licenseList 中
         List<StoreLicenseHistoryDto> resultList = new ArrayList<>();
-        
+
         for (Map.Entry<String, List<StoreLicenseHistoryDto>> entry : timeGroupMap.entrySet()) {
             String timeKey = entry.getKey();
             List<StoreLicenseHistoryDto> sameTimeList = entry.getValue();
-            
+
             // 创建一个父对象,代表这个时间节点
             StoreLicenseHistoryDto parentVo = new StoreLicenseHistoryDto();
-            
+
             // 使用第一条记录的基本信息作为父对象的信息(ID最小的那条)
             if (!sameTimeList.isEmpty()) {
                 StoreLicenseHistoryDto firstItem = sameTimeList.get(0);
                 BeanUtils.copyProperties(firstItem, parentVo);
-                
+
                 // 将相同时间的所有记录存储到 licenseList 中(已按ID升序排列)
                 parentVo.setLicenseList(sameTimeList);
                 parentVo.setCreatedDateFormat(timeKey);
-                
+
                 resultList.add(parentVo);
             }
         }
 
-        log.info("queryContractByStatusList - 共查询到 {} 条记录,按时间分组后 {} 个时间节点", 
-                 licenseList.size(), resultList.size());
+        log.info("queryContractByStatusList - 共查询到 {} 条记录,按时间分组后 {} 个时间节点",
+                licenseList.size(), resultList.size());
 
         return resultList;
     }
@@ -429,10 +433,10 @@ public class LicenseServiceImpl implements LicenseService {
      * @return 营业执照图片列表
      */
     @Override
-    public List<StoreImgDTO> getEntertainmentLicenseList (Integer id) {
+    public List<StoreImgDTO> getEntertainmentLicenseList(Integer id) {
 
         StoreInfo storeInfo = storeInfoMapper.selectOne(new LambdaQueryWrapper<StoreInfo>().eq(StoreInfo::getId, id));
-        
+
         log.info("getEntertainmentLicenseList - 查询商户ID为 {} 的娱乐经营许可证图片列表", id);
         List<StoreImg> storeImgList = storeImgMapper.selectList(new LambdaQueryWrapper<StoreImg>()
                 .eq(StoreImg::getImgType, 31)
@@ -452,7 +456,7 @@ public class LicenseServiceImpl implements LicenseService {
 
     @Override
     public int uploadEntertainmentLicence(StoreImg storeImg) {
-        storeImgMapper.delete(new LambdaQueryWrapper<StoreImg>().eq(StoreImg::getImgType,32).eq(StoreImg::getStoreId,storeImg.getStoreId()));
+        storeImgMapper.delete(new LambdaQueryWrapper<StoreImg>().eq(StoreImg::getImgType, 32).eq(StoreImg::getStoreId, storeImg.getStoreId()));
         storeImg.setImgType(32);
         storeImg.setImgDescription("经营许可证审核通过前图片");
         storeImgMapper.insert(storeImg);
@@ -486,7 +490,7 @@ public class LicenseServiceImpl implements LicenseService {
      * @return 证照历史记录VO列表
      */
     @Override
-    public List<StoreLicenseHistoryDto> queryEntertainmentByStatusList (Integer storeId) {
+    public List<StoreLicenseHistoryDto> queryEntertainmentByStatusList(Integer storeId) {
 
         List<StoreLicenseHistory> licenseList = licenseHistoryMapper.queryLicenceByStatusList(storeId, 3, 1);
 

+ 20 - 19
alien-store/src/main/java/shop/alien/store/service/LifeUserService.java

@@ -19,22 +19,13 @@ import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 import shop.alien.config.properties.RiskControlProperties;
-import shop.alien.entity.result.R;
 import shop.alien.entity.second.LifeUserLog;
 import shop.alien.entity.second.SecondRiskControlRecord;
-import shop.alien.entity.store.LifeFans;
-import shop.alien.entity.store.LifeNotice;
-import shop.alien.entity.store.LifeUser;
-import shop.alien.entity.store.PushDeviceOwnerType;
-import shop.alien.entity.store.StoreUser;
+import shop.alien.entity.store.*;
 import shop.alien.entity.store.vo.LifeMessageVo;
 import shop.alien.entity.store.vo.LifeUserVo;
 import shop.alien.entity.store.vo.WebSocketVo;
-import shop.alien.mapper.LifeFansMapper;
-import shop.alien.mapper.LifeMessageMapper;
-import shop.alien.mapper.LifeNoticeMapper;
-import shop.alien.mapper.LifeUserMapper;
-import shop.alien.mapper.StoreUserMapper;
+import shop.alien.mapper.*;
 import shop.alien.mapper.second.LifeUserLogMapper;
 import shop.alien.mapper.second.SecondRiskControlRecordMapper;
 import shop.alien.mapper.second.SecondUserCreditMapper;
@@ -57,7 +48,9 @@ import java.util.stream.Collectors;
 @RequiredArgsConstructor
 public class LifeUserService extends ServiceImpl<LifeUserMapper, LifeUser> {
 
-    /** App 点击推送后跳转页面(与动态点赞通知一致) */
+    /**
+     * App 点击推送后跳转页面(与动态点赞通知一致)
+     */
     private static final String FOLLOW_APP_PUSH_OPEN_PATH =
             "pages/secondHandTransactions/pages/message/noticesAndMessage";
 
@@ -127,7 +120,15 @@ public class LifeUserService extends ServiceImpl<LifeUserMapper, LifeUser> {
 
     public int addFans(LifeFans fans) {
         fans.setCreatedTime(new Date());
-        int num = lifeFansMapper.insert(fans);
+        LambdaQueryWrapper<LifeFans> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.eq(LifeFans::getFollowedId, fans.getFollowedId())
+                .eq(LifeFans::getFansId, fans.getFansId())
+                .eq(LifeFans::getDeleteFlag, 0);
+        int num = lifeFansMapper.selectCount(lambdaQueryWrapper);
+        if (num != 0) {
+            return 1;
+        }
+        lifeFansMapper.insert(fans);
 
         if (num == 1) {
             LifeNotice notice = new LifeNotice();
@@ -156,7 +157,7 @@ public class LifeUserService extends ServiceImpl<LifeUserMapper, LifeUser> {
                 lifeNoticeMapper.insert(notice);
 
                 // 发送系统通知开关
-                if(uniPushOn) {
+                if (uniPushOn) {
                     try {
                         sendFollowRelationAppPush(fans.getFollowedId());
                     } catch (Exception e) {
@@ -248,11 +249,11 @@ public class LifeUserService extends ServiceImpl<LifeUserMapper, LifeUser> {
         QueryWrapper<LifeUserVo> queryWrapper = new QueryWrapper<>();
         if (StringUtils.isNotEmpty(vo.getSearchName())) {
             queryWrapper.and(wrapper -> wrapper
-                .like("a.storeUserName", vo.getSearchName())
-                .or()
-                .like("a.phoneId", vo.getSearchName())
-                .or()
-                .like("a.accountName", vo.getSearchName())
+                    .like("a.storeUserName", vo.getSearchName())
+                    .or()
+                    .like("a.phoneId", vo.getSearchName())
+                    .or()
+                    .like("a.accountName", vo.getSearchName())
             );
         }
         IPage<LifeUserVo> voList = lifeUserMapper.getStoreAndUserByName(new Page<>(vo.getPage(), vo.getSize()), queryWrapper);