主客态判断接口

ch-wx-api/src/main/java/com/wwdz/ch/wx/entity/request/SelfPageRequestDto.java

@@ -7,4 +7,6 @@ import lombok.Data;
 public class SelfPageRequestDto implements Entity {
 
     private Long userId;
+
+    private String shareRecordId;
 }

ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/distribution/SelfPageServiceImpl.java

 package com.wwdz.ch.wx.impl.distribution;
 
+import com.wwdz.ch.core.consts.CommConsts;
 import com.wwdz.ch.core.consts.DistributionEnum;
 import com.wwdz.ch.core.type.Result;
 import com.wwdz.ch.core.util.CacheUtil;
@@ -9,11 +10,13 @@ import com.wwdz.ch.db.bean.DistributionOrderNum;
 import com.wwdz.ch.db.dao.distribution.*;
 import com.wwdz.ch.db.domain.distribution.AuctionConfig;
 import com.wwdz.ch.db.domain.distribution.AuctionRecord;
+import com.wwdz.ch.db.domain.distribution.CollectionShareRecord;
 import com.wwdz.ch.wx.entity.request.SelfPageRequestDto;
 import com.wwdz.ch.wx.entity.vo.distribution.SelfPageInfoVo;
 import com.wwdz.ch.wx.service.distribution.SelfPageService;
 import com.wwdz.ch.wx.util.RedisUtil;
 import com.wwdz.user.api.service.user.UserReadService;
+import com.xxdxxs.utils.StringUtils;
 import org.apache.dubbo.config.annotation.Reference;
 import org.redisson.Redisson;
 import org.redisson.api.RLock;
@@ -27,7 +30,9 @@ import org.springframework.util.CollectionUtils;
 import java.time.Duration;
 import java.time.Instant;
 import java.util.Date;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
@@ -52,6 +57,9 @@ public class SelfPageServiceImpl implements SelfPageService {
     @Autowired
     CacheUtil cacheUtil;
 
+    @Autowired
+    CollectionShareRecordDao collectionShareRecordDao;
+
 
 
     @Override
@@ -137,4 +145,25 @@ public class SelfPageServiceImpl implements SelfPageService {
         }
         return Result.failed();
     }
+
+
+    @Override
+    public Result checkIsMine(SelfPageRequestDto dto) {
+        try {
+            Map<String, Object> map = new HashMap<>();
+            CollectionShareRecord collectionShareRecord = collectionShareRecordDao.findById(dto.getShareRecordId());
+            long itemUserId = collectionShareRecord.getItemUserId();
+            if (itemUserId != dto.getUserId()) {
+                map.put("isMine", false);
+            } else {
+                map.put("isMine", true);
+            }
+            String avatar = cacheUtil.getAppletUserById(itemUserId).getAvatar();
+            map.put("avatar", StringUtils.isEmpty(avatar) ? CommConsts.DEFAULT_AVATAR_URL : avatar);
+            return Result.success(map);
+        } catch (Exception e) {
+            logger.error("判断主客态 error : {}", e);
+        }
+        return Result.failed();
+    }
 }

ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/distribution/SupplierItemServiceImpl.java

@@ -808,11 +808,9 @@ public class SupplierItemServiceImpl implements SupplierItemService {
                             }
                         }
                     } else {
-                        if (supplierItemVo != null) {
-                            if (lastedRecord.getUserId().longValue() == dto.getUserId().longValue()) {
-                                supplierItemVo.setUserState(DistributionEnum.AuctionUserStateEnum.LEAD.getCode());
-                                supplierItemVo.setUserStateName(DistributionEnum.AuctionUserStateEnum.LEAD.getDes());
-                            }
+                        if (lastedRecord.getUserId().longValue() == dto.getUserId().longValue()) {
+                            supplierItemVo.setUserState(DistributionEnum.AuctionUserStateEnum.LEAD.getCode());
+                            supplierItemVo.setUserStateName(DistributionEnum.AuctionUserStateEnum.LEAD.getDes());
                         }
                         supplierItemVo.setState(DistributionEnum.AuctionStateEnum.IN_AUCTION.getCode());
                         supplierItemVo.setStateName(DistributionEnum.AuctionStateEnum.IN_AUCTION.getDes());

ch-wx-api/src/main/java/com/wwdz/ch/wx/service/distribution/SelfPageService.java

@@ -31,4 +31,12 @@ public interface SelfPageService {
     Result getMyOrders(SelfPageRequestDto dto);
 
 
+    /**
+     * 检查是否是主态
+     * @param dto
+     * @return
+     */
+    Result checkIsMine(SelfPageRequestDto dto);
+
+
 }

ch-wx-api/src/main/java/com/wwdz/ch/wx/web/distribution/SelfPageController.java

@@ -70,4 +70,19 @@ public class SelfPageController {
         return selfPageService.getMyOrders(dto);
     }
 
+
+    @ApiOperation(value = "检查是否是主态")
+    @PostMapping("/checkIsMine")
+    public Result checkIsMine(@RequestBody SelfPageRequestDto dto) {
+        logger.info("分销商查询自己购买的订单信息,请求参数:{}", JSON.toJSONString(dto));
+        Validator validator = new Validator(FormHandler.ofEntity(dto));
+        validator.set("userId", "用户id").must().number()
+                .set("shareRecordId", "分享记录id").must().string()
+                .end();
+        if (!validator.isValid()) {
+            return Result.failed(validator.getErrorInfo());
+        }
+        return selfPageService.checkIsMine(dto);
+    }
+
 }