# WeeklyMonthlyRevenueEmailConfigController.java

    package cloud.wconnect.rateshop.controller.weeklymonthlyrevenue;

    import cloud.wconnect.commonlib.annotation.ApiId;
    import cloud.wconnect.commonlib.component.SessionContext;
    import cloud.wconnect.commonlib.cons.BaseErrorCodeEnum;
    import cloud.wconnect.commonlib.cons.CommonErrorI18nConstant;
    import cloud.wconnect.commonlib.cons.EmailConfigCons;
    import cloud.wconnect.commonlib.cons.SystemPlatformEnum;
    import cloud.wconnect.commonlib.exception.BadRequestException;
    import cloud.wconnect.commonlib.pojo.dto.PropertyDTO;
    import cloud.wconnect.commonlib.pojo.dto.UserDTO;
    import cloud.wconnect.commonlib.pojo.dto.UsergroupDTO;
    import cloud.wconnect.commonlib.redis.PropertyI18nRedisService;
    import cloud.wconnect.commonlib.service.UserInternalService;
    import cloud.wconnect.commonlib.service.UsergroupInternalService;
    import cloud.wconnect.commonlib.util.I18nMessageUtils;
    import cloud.wconnect.rateshop.cons.weeklymonthlyrevenue.MonthlyRevenueCons;
    import cloud.wconnect.rateshop.pojo.dto.weeklymonthlyrevenue.WeeklyMonthlyRevenueEmailConfigDTO;
    import cloud.wconnect.rateshop.pojo.dto.weeklymonthlyrevenue.WeeklyMonthlyRevenueEmailTargetDTO;
    import cloud.wconnect.rateshop.service.weeklymonthlyrevenue.IWeeklyMonthlyRevenueEmailConfigService;
    import com.google.common.collect.ImmutableMap;
    import com.google.common.collect.Lists;
    import com.google.common.collect.Sets;
    import jakarta.annotation.Resource;
    import jakarta.validation.Valid;
    import org.apache.commons.collections.CollectionUtils;
    import org.springframework.web.bind.annotation.*;

    import java.text.MessageFormat;
    import java.util.Collections;
    import java.util.List;
    import java.util.Map;
    import java.util.stream.Collectors;

    /**
     * <p>
     * Weekly Monthly Revenue email config 前端控制器
     * </p>
     *
     * @author zc
     * @since 2024-05-13
     */
    @RestController
    @RequestMapping("/weekly-monthly-revenue/email-config")
    public class WeeklyMonthlyRevenueEmailConfigController {
        @Resource
        private IWeeklyMonthlyRevenueEmailConfigService emailConfigService;
        @Resource
        private UsergroupInternalService usergroupInternalService;
        @Resource
        private UserInternalService userInternalService;
        @Resource
        private PropertyI18nRedisService propertyI18nRedisService;
        @Resource
        private SessionContext sessionContext;
        @Resource
        private I18nMessageUtils i18nMessageUtils;

        /**
         * 获取邮件配置
         *
         * @param property 资产标识
         * @param type     邮件类型
         * @return 邮件配置
         * @author zc
         * @date 2024/11/15
         */
        @ApiId(1167)
        @GetMapping
        public WeeklyMonthlyRevenueEmailConfigDTO get(@RequestParam String property, @RequestParam int type) {
            int propertyId = sessionContext.getPropertyId(property);
            PropertyDTO propertyDTO = propertyI18nRedisService.get(propertyId);
            // 校验通知类型参数
            checkNotifyTypeParams(propertyDTO.getPmsType(), type);
            return emailConfigService.getEmailConfigDTO(propertyDTO, type);
        }

        /**
         * 保存邮件配置
         *
         * @param property       资产标识
         * @param emailConfigDTO 邮件配置信息
         * @return 邮件配置 id
         * @author zc
         * @date 2024/11/15
         */
        @ApiId(1168)
        @PostMapping
        public Map<String, Integer> save(@RequestParam String property, @RequestBody @Valid WeeklyMonthlyRevenueEmailConfigDTO emailConfigDTO) {
            int propertyId = sessionContext.getPropertyId(property);
            PropertyDTO propertyDTO = propertyI18nRedisService.get(propertyId);
            // 校验通知类型参数
            checkNotifyTypeParams(propertyDTO.getPmsType(), emailConfigDTO.getType());
            // 校验通知对象有效性
            checkEmailTarget(propertyDTO.getTenantId(), propertyDTO.getId(), emailConfigDTO);
            return ImmutableMap.of("id", emailConfigService.save(propertyDTO.getId(), sessionContext.getLoginUserId(), emailConfigDTO));
        }

        /**
         * 校验通知对象有效性
         *
         * @param tenantId       租户 id
         * @param propertyId     资产 id
         * @param emailConfigDTO 邮件配置DTO
         * @author zc
         * @date 2024/11/12
         */
        private void checkEmailTarget(int tenantId, int propertyId, WeeklyMonthlyRevenueEmailConfigDTO emailConfigDTO) {
            List<WeeklyMonthlyRevenueEmailTargetDTO> allNotifyList = Lists.newArrayList();
            if (CollectionUtils.isNotEmpty(emailConfigDTO.getToList())) {
                allNotifyList.addAll(emailConfigDTO.getToList());
            }
            if (CollectionUtils.isNotEmpty(emailConfigDTO.getCcList())) {
                allNotifyList.addAll(emailConfigDTO.getCcList());
            }
            if (CollectionUtils.isEmpty(allNotifyList)) {
                return;
            }

            // 按照用户来源分组
            Map<Integer, List<Integer>> source2IdentityIdList = allNotifyList.stream()
                    .collect(Collectors.groupingBy(WeeklyMonthlyRevenueEmailTargetDTO::getSource,
                            Collectors.mapping(WeeklyMonthlyRevenueEmailTargetDTO::getIdentityId, Collectors.toList())));

            // 校验是否重复
            List<Integer> userIds = source2IdentityIdList.getOrDefault(EmailConfigCons.SOURCE_USER, Collections.emptyList());
            if (userIds.size() != Sets.newHashSet(userIds).size()) {
                throw new BadRequestException(CommonErrorI18nConstant.DATA_CANNOT_REPEAT,
                        i18nMessageUtils.getErrorParamMapNotNeedTranslate("userIds"),
                        BaseErrorCodeEnum.DATA_VALIDATION_ERROR.getCode(),
                        "The user cannot repeat");
            }
            List<Integer> userGroupIds = source2IdentityIdList.getOrDefault(EmailConfigCons.SOURCE_USERGROUP, Collections.emptyList());
            if (userGroupIds.size() != Sets.newHashSet(userGroupIds).size()) {
                throw new BadRequestException(CommonErrorI18nConstant.DATA_CANNOT_REPEAT,
                        i18nMessageUtils.getErrorParamMapNotNeedTranslate("userGroupIds"),
                        BaseErrorCodeEnum.DATA_VALIDATION_ERROR.getCode(),
                        "The user group cannot repeat");
            }
            List<String> manualEmails = allNotifyList.stream().filter(item -> item.getSource() == EmailConfigCons.SOURCE_MANUAL)
                    .map(WeeklyMonthlyRevenueEmailTargetDTO::getEmail).collect(Collectors.toList());
            if (manualEmails.size() != Sets.newHashSet(manualEmails).size()) {
                throw new BadRequestException(CommonErrorI18nConstant.DATA_CANNOT_REPEAT,
                        i18nMessageUtils.getErrorParamMapNotNeedTranslate("manualEmails"),
                        BaseErrorCodeEnum.DATA_VALIDATION_ERROR.getCode(),
                        "The manual email cannot repeat");
            }
            // 用户集合
            if (CollectionUtils.isNotEmpty(userIds)) {
                List<UserDTO> allUsers = userInternalService.getUsers(tenantId, userIds);
                if (userIds.size() != allUsers.size()) {
                    throw new BadRequestException(CommonErrorI18nConstant.DATA_NOT_EXIST,
                            i18nMessageUtils.getErrorParamMapNotNeedTranslate("userId"),
                            BaseErrorCodeEnum.DATA_VALIDATION_ERROR.getCode(),
                            "The user not exist");
                }
            }
            // 校验用户组是否存在
            if (CollectionUtils.isNotEmpty(userGroupIds)) {
                List<UsergroupDTO> userGroups = usergroupInternalService.getUsergroups(tenantId, propertyId, userGroupIds);
                if (userGroupIds.size() != userGroups.size()) {
                    throw new BadRequestException(CommonErrorI18nConstant.DATA_NOT_EXIST,
                            i18nMessageUtils.getErrorParamMapNotNeedTranslate("userGroupId"),
                            BaseErrorCodeEnum.DATA_VALIDATION_ERROR.getCode(),
                            "The user group not exist");
                }
            }
        }

        /**
         * 校验通知类型参数
         *
         * @param propertyPmsType 属性PMS类型
         * @param notifyType      报告类型
         * @author zc
         * @date 2025/7/5
         */
        private void checkNotifyTypeParams(String propertyPmsType, int notifyType) {
            List<Integer> effectNotifyTypeList;
            if (SystemPlatformEnum.OPERA.getDesc().equals(propertyPmsType)) {
                effectNotifyTypeList = MonthlyRevenueCons.OPERA_PMS_NOTIFY_TYPE_LIST;
            } else if (SystemPlatformEnum.SHI_JI.getDesc().equals(propertyPmsType)) {
                effectNotifyTypeList = MonthlyRevenueCons.SHIJI_PMS_NOTIFY_TYPE_LIST;
            } else {
                effectNotifyTypeList = MonthlyRevenueCons.PEP_PMS_NOTIFY_TYPE_LIST;
            }
            if (!effectNotifyTypeList.contains(notifyType)) {
                throw new BadRequestException(CommonErrorI18nConstant.NOTIFY_TYPE_NOT_SUPPORTED,
                        BaseErrorCodeEnum.DATA_VALIDATION_ERROR.getCode(),
                        MessageFormat.format("The currently selected notify type is not supported, " +
                                "notifyType must be in {0}", effectNotifyTypeList));
            }
        }
    }