加入律师通知接口

alien-lawyer/src/main/java/shop/alien/lawyer/controller/LawyerNoticeController.java

@@ -0,0 +1,74 @@
+package shop.alien.lawyer.controller;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import io.swagger.annotations.*;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.web.bind.annotation.*;
+import shop.alien.entity.result.R;
+import shop.alien.entity.store.vo.LifeNoticeVo;
+import shop.alien.lawyer.service.LawyerNoticeService;
+
+/**
+ * 律师通知控制器
+ *
+ * @author system
+ */
+@Api(tags = {"律师模块-通知"})
+@Slf4j
+@RestController
+@CrossOrigin
+@RequestMapping("/lawyerNotice")
+@RequiredArgsConstructor
+public class LawyerNoticeController {
+
+    private final LawyerNoticeService lawyerNoticeService;
+
+    /**
+     * 获取律师通知列表
+     *
+     * @param pageNum    页码，从1开始
+     * @param pageSize   每页大小
+     * @param receiverId 接收人ID
+     * @param noticeType 通知类型：0-系统通知和订单提醒之外的类型，1-系统通知，2-订单提醒
+     * @return 分页通知列表
+     */
+    @GetMapping("/list")
+    @ApiOperation("律师通知列表")
+    @ApiOperationSupport(order = 1)
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "pageNum", value = "页码", dataType = "Integer", paramType = "query", required = true, example = "1"),
+            @ApiImplicitParam(name = "pageSize", value = "每页大小", dataType = "Integer", paramType = "query", required = true, example = "10"),
+            @ApiImplicitParam(name = "receiverId", value = "接收人ID", dataType = "String", paramType = "query", required = true),
+            @ApiImplicitParam(name = "noticeType", value = "通知类型：0-系统通知和订单提醒之外的类型，1-系统通知，2-订单提醒", dataType = "Integer", paramType = "query", example = "0")})
+    public R<IPage<LifeNoticeVo>> getLawyerNoticeList(
+            @RequestParam Integer pageNum,
+            @RequestParam Integer pageSize,
+            @RequestParam String receiverId,
+            @RequestParam(defaultValue = "0") Integer noticeType) {
+        log.info("LawyerNoticeController.getLawyerNoticeList, pageNum={}, pageSize={}, receiverId={}, noticeType={}", 
+                pageNum, pageSize, receiverId, noticeType);
+        
+        // 参数校验
+        if (pageNum == null || pageNum < 1) {
+            log.warn("分页参数无效，pageNum={}", pageNum);
+            return R.fail("页码必须大于0");
+        }
+        if (pageSize == null || pageSize < 1) {
+            log.warn("分页参数无效，pageSize={}", pageSize);
+            return R.fail("每页大小必须大于0");
+        }
+        if (StringUtils.isBlank(receiverId)) {
+            log.warn("接收人ID为空");
+            return R.fail("接收人ID不能为空");
+        }
+        if (noticeType == null || noticeType < 0) {
+            log.warn("通知类型参数无效，noticeType={}", noticeType);
+            return R.fail("通知类型参数无效");
+        }
+        
+        return lawyerNoticeService.getLawyerNoticeList(pageNum, pageSize, receiverId, noticeType);
+    }
+
+}

alien-lawyer/src/main/java/shop/alien/lawyer/service/LawyerNoticeService.java

@@ -0,0 +1,27 @@
+package shop.alien.lawyer.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.IService;
+import shop.alien.entity.result.R;
+import shop.alien.entity.store.LifeNotice;
+import shop.alien.entity.store.vo.LifeNoticeVo;
+
+/**
+ * 律师通知服务接口
+ *
+ * @author system
+ */
+public interface LawyerNoticeService extends IService<LifeNotice> {
+
+    /**
+     * 获取律师通知列表
+     *
+     * @param pageNum    页码，从1开始
+     * @param pageSize   每页大小
+     * @param receiverId 接收人ID
+     * @param noticeType 通知类型：0-系统通知和订单提醒之外的类型，1-系统通知，2-订单提醒
+     * @return 分页通知列表
+     */
+    R<IPage<LifeNoticeVo>> getLawyerNoticeList(Integer pageNum, Integer pageSize, String receiverId, Integer noticeType);
+
+}

alien-lawyer/src/main/java/shop/alien/lawyer/service/impl/LawyerNoticeServiceImpl.java

@@ -0,0 +1,322 @@
+package shop.alien.lawyer.service.impl;
+
+import cn.hutool.core.collection.CollectionUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+import shop.alien.entity.result.R;
+import shop.alien.entity.store.LawyerUserViolation;
+import shop.alien.entity.store.LifeNotice;
+import shop.alien.entity.store.LifeUserViolation;
+import shop.alien.entity.store.vo.LifeMessageVo;
+import shop.alien.entity.store.vo.LifeNoticeVo;
+import shop.alien.lawyer.service.LawyerNoticeService;
+import shop.alien.mapper.LawyerUserViolationMapper;
+import shop.alien.mapper.LifeMessageMapper;
+import shop.alien.mapper.LifeNoticeMapper;
+import shop.alien.mapper.LifeUserViolationMapper;
+
+import java.util.*;
+import java.util.stream.Collectors;
+
+/**
+ * 律师通知服务实现类
+ *
+ * @author system
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class LawyerNoticeServiceImpl extends ServiceImpl<LifeNoticeMapper, LifeNotice> implements LawyerNoticeService {
+
+    /**
+     * 系统发送者标识
+     */
+    private static final String SYSTEM_SENDER = "system";
+
+    /**
+     * 平台类型：1-平台
+     */
+    private static final String PLATFORM_TYPE_ONE = "1";
+
+    /**
+     * 店铺审核通知标题
+     */
+    private static final String STORE_AUDIT_NOTICE_TITLE = "店铺审核通知";
+
+    /**
+     * 删除标识：0-未删除
+     */
+    private static final Integer DELETE_FLAG_NOT_DELETED = 0;
+
+    /**
+     * 发送者ID分隔符
+     */
+    private static final String SENDER_ID_SEPARATOR = "_";
+
+    /**
+     * 店铺类型标识
+     */
+    private static final String STORE_TYPE = "store";
+
+    /**
+     * 用户类型标识
+     */
+    private static final String USER_TYPE = "user";
+
+    /**
+     * 报告上下文类型范围
+     */
+    private static final String REPORT_CONTEXT_TYPE_RANGE = "1,2,3,6";
+
+    private final LifeNoticeMapper lifeNoticeMapper;
+
+    private final LifeMessageMapper lifeMessageMapper;
+
+    private final LawyerUserViolationMapper lawyerUserViolationMapper;
+
+    @Override
+    public R<IPage<LifeNoticeVo>> getLawyerNoticeList(Integer pageNum, Integer pageSize, String receiverId, Integer noticeType) {
+        // 构建查询条件
+        LambdaQueryWrapper<LifeNotice> queryWrapper = buildQueryWrapper(receiverId, noticeType);
+        
+        // 使用分页查询，避免查询全部数据
+        IPage<LifeNotice> noticePage = new Page<>(pageNum, pageSize);
+        IPage<LifeNotice> noticeResult = lifeNoticeMapper.selectPage(noticePage, queryWrapper);
+        
+        List<LifeNotice> lifeNoticeList = noticeResult.getRecords();
+        if (CollectionUtil.isEmpty(lifeNoticeList)) {
+            return R.data(createEmptyPageResult(pageNum, pageSize));
+        }
+
+        // 提取业务ID列表
+        List<Integer> businessIdList = extractBusinessIdList(lifeNoticeList);
+        
+        // 获取违规信息映射
+        Map<Integer, String> lawyerUserViolationMap = getLifeUserViolationMap(businessIdList);
+        
+        // 提取发送者ID并按类型分组
+        Map<String, List<String>> senderIdGroupMap = extractSenderIdGroupMap(lifeNoticeList);
+        
+        // 获取用户信息列表
+        List<LifeMessageVo> userList = getUserList(senderIdGroupMap);
+        
+        // 转换为VO列表
+        List<LifeNoticeVo> noticeVoList = convertToNoticeVoList(lifeNoticeList, userList);
+        
+        // 设置平台类型
+        setPlatformType(noticeVoList, lawyerUserViolationMap);
+        
+        // 构建分页结果
+        IPage<LifeNoticeVo> result = new Page<>(pageNum, pageSize);
+        result.setRecords(noticeVoList);
+        result.setTotal(noticeResult.getTotal());
+        result.setPages(noticeResult.getPages());
+        result.setCurrent(noticeResult.getCurrent());
+        result.setSize(noticeResult.getSize());
+        
+        return R.data(result);
+    }
+
+    /**
+     * 构建查询条件
+     *
+     * @param receiverId 接收人ID
+     * @param noticeType 通知类型
+     * @return 查询条件包装器
+     */
+    private LambdaQueryWrapper<LifeNotice> buildQueryWrapper(String receiverId, Integer noticeType) {
+        LambdaQueryWrapper<LifeNotice> queryWrapper = new LambdaQueryWrapper<>();
+        queryWrapper.eq(LifeNotice::getReceiverId, receiverId)
+                .eq(LifeNotice::getNoticeType, noticeType)
+                .eq(LifeNotice::getDeleteFlag, DELETE_FLAG_NOT_DELETED)
+                .orderByDesc(LifeNotice::getCreatedTime);
+        return queryWrapper;
+    }
+
+    /**
+     * 创建空的分页结果
+     *
+     * @param pageNum  页码
+     * @param pageSize 每页大小
+     * @return 空的分页结果
+     */
+    private IPage<LifeNoticeVo> createEmptyPageResult(Integer pageNum, Integer pageSize) {
+        IPage<LifeNoticeVo> result = new Page<>(pageNum, pageSize);
+        result.setRecords(Collections.emptyList());
+        result.setTotal(0L);
+        result.setPages(0);
+        return result;
+    }
+
+    /**
+     * 提取业务ID列表
+     *
+     * @param lifeNoticeList 通知列表
+     * @return 业务ID列表
+     */
+    private List<Integer> extractBusinessIdList(List<LifeNotice> lifeNoticeList) {
+        return lifeNoticeList.stream()
+                .map(LifeNotice::getBusinessId)
+                .filter(Objects::nonNull)
+                .distinct()
+                .collect(Collectors.toList());
+    }
+
+    /**
+     * 获取违规信息映射
+     *
+     * @param businessIdList 业务ID列表
+     * @return 违规信息映射，key为业务ID，value为报告上下文类型
+     */
+    private Map<Integer, String> getLifeUserViolationMap(List<Integer> businessIdList) {
+        if (CollectionUtil.isEmpty(businessIdList)) {
+            return Collections.emptyMap();
+        }
+        
+        List<LawyerUserViolation> lawyerUserViolationList = lawyerUserViolationMapper.selectBatchIds(businessIdList);
+        if (CollectionUtil.isEmpty(lawyerUserViolationList)) {
+            return Collections.emptyMap();
+        }
+        
+        return lawyerUserViolationList.stream()
+                .filter(violation -> violation != null && violation.getId() != null)
+                .collect(Collectors.toMap(
+                        LawyerUserViolation::getId,
+                        violation -> StringUtils.defaultString(violation.getReportContextType(), ""),
+                        (existing, replacement) -> existing
+                ));
+    }
+
+    /**
+     * 提取发送者ID并按类型分组
+     *
+     * @param lifeNoticeList 通知列表
+     * @return 发送者ID分组映射，key为类型（store/user），value为ID列表
+     */
+    private Map<String, List<String>> extractSenderIdGroupMap(List<LifeNotice> lifeNoticeList) {
+        return lifeNoticeList.stream()
+                .map(LifeNotice::getSenderId)
+                .filter(senderId -> StringUtils.isNotBlank(senderId) 
+                        && !SYSTEM_SENDER.equals(senderId) 
+                        && senderId.contains(SENDER_ID_SEPARATOR))
+                .collect(Collectors.groupingBy(
+                        senderId -> senderId.split(SENDER_ID_SEPARATOR)[0],
+                        Collectors.mapping(
+                                senderId -> senderId.split(SENDER_ID_SEPARATOR)[1],
+                                Collectors.toList()
+                        )
+                ));
+    }
+
+    /**
+     * 获取用户信息列表
+     *
+     * @param senderIdGroupMap 发送者ID分组映射
+     * @return 用户信息列表
+     */
+    private List<LifeMessageVo> getUserList(Map<String, List<String>> senderIdGroupMap) {
+        String storePhones = buildPhoneString(senderIdGroupMap.get(STORE_TYPE));
+        String userPhones = buildPhoneString(senderIdGroupMap.get(USER_TYPE));
+        return lifeMessageMapper.getLifeUserAndStoreUserByPhone(storePhones, userPhones);
+    }
+
+    /**
+     * 构建手机号字符串
+     *
+     * @param phoneList 手机号列表
+     * @return 手机号字符串，格式：'phone1','phone2'
+     */
+    private String buildPhoneString(List<String> phoneList) {
+        if (CollectionUtil.isEmpty(phoneList)) {
+            return "''";
+        }
+        return "'" + String.join("','", phoneList) + "'";
+    }
+
+    /**
+     * 转换为通知VO列表
+     *
+     * @param lifeNoticeList 通知列表
+     * @param userList       用户信息列表
+     * @return 通知VO列表
+     */
+    private List<LifeNoticeVo> convertToNoticeVoList(List<LifeNotice> lifeNoticeList, List<LifeMessageVo> userList) {
+        if (CollectionUtil.isEmpty(userList)) {
+            return lifeNoticeList.stream()
+                    .map(this::convertToNoticeVo)
+                    .collect(Collectors.toList());
+        }
+        
+        Map<String, LifeMessageVo> userMap = userList.stream()
+                .filter(user -> user != null && StringUtils.isNotBlank(user.getPhoneId()))
+                .collect(Collectors.toMap(
+                        LifeMessageVo::getPhoneId,
+                        user -> user,
+                        (existing, replacement) -> existing
+                ));
+        
+        return lifeNoticeList.stream()
+                .map(notice -> {
+                    LifeNoticeVo noticeVo = convertToNoticeVo(notice);
+                    LifeMessageVo userInfo = userMap.get(notice.getSenderId());
+                    if (userInfo != null && !SYSTEM_SENDER.equals(noticeVo.getSenderId())) {
+                        noticeVo.setUserName(userInfo.getUserName());
+                        noticeVo.setUserImage(userInfo.getUserImage());
+                    }
+                    return noticeVo;
+                })
+                .collect(Collectors.toList());
+    }
+
+    /**
+     * 转换为通知VO
+     *
+     * @param notice 通知实体
+     * @return 通知VO
+     */
+    private LifeNoticeVo convertToNoticeVo(LifeNotice notice) {
+        LifeNoticeVo noticeVo = new LifeNoticeVo();
+        BeanUtils.copyProperties(notice, noticeVo);
+        return noticeVo;
+    }
+
+    /**
+     * 设置平台类型
+     *
+     * @param noticeVoList           通知VO列表
+     * @param lawyerUserViolationMap   违规信息映射
+     */
+    private void setPlatformType(List<LifeNoticeVo> noticeVoList, Map<Integer, String> lawyerUserViolationMap) {
+        for (LifeNoticeVo noticeVo : noticeVoList) {
+            if (noticeVo == null) {
+                continue;
+            }
+            
+            // 业务ID为空时设置为平台类型
+            if (noticeVo.getBusinessId() == null) {
+                noticeVo.setPlatformType(PLATFORM_TYPE_ONE);
+                continue;
+            }
+            
+            // 店铺审核通知设置为平台类型
+            if (STORE_AUDIT_NOTICE_TITLE.equals(noticeVo.getTitle())) {
+                noticeVo.setPlatformType(PLATFORM_TYPE_ONE);
+                continue;
+            }
+            
+            // 根据违规信息设置平台类型
+            String reportContextType = lawyerUserViolationMap.get(noticeVo.getBusinessId());
+            if (StringUtils.isNotBlank(reportContextType) 
+                    && REPORT_CONTEXT_TYPE_RANGE.contains(reportContextType)) {
+                noticeVo.setPlatformType(PLATFORM_TYPE_ONE);
+            }
+        }
+    }
+}