sc-11111111111

package com.zkj.wecom.marketing.customer.server.service.impl; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.toolkit.CollectionUtils; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.google.common.base.Preconditions; import com.google.common.collect.Maps; import com.google.common.primitives.Ints; import com.zkj.wecom.marketing.base.service.*; import com.zkj.wecom.marketing.common.constant.BaseSettingConstant; import com.zkj.wecom.marketing.common.enums.DeleteFlagEnum; import com.zkj.wecom.marketing.common.result.JsonResult; import com.zkj.wecom.marketing.common.util.RedisUtil; import com.zkj.wecom.marketing.customer.core.service.pullnew.CustomerPullNewCustomerService; import com.zkj.wecom.marketing.customer.core.service.pullnew.CustomerPullNewGroupService; import com.zkj.wecom.marketing.customer.core.service.pullnew.CustomerPullNewService; import com.zkj.wecom.marketing.customer.core.service.pullnew.CustomerPullNewStaffService; import com.zkj.wecom.marketing.customer.model.domain.entity.pullnew.CustomerPullNewCustomerEntity; import com.zkj.wecom.marketing.customer.model.domain.entity.pullnew.CustomerPullNewEntity; import com.zkj.wecom.marketing.customer.model.domain.entity.pullnew.CustomerPullNewGroupEntity; import com.zkj.wecom.marketing.customer.model.domain.entity.pullnew.CustomerPullNewStaffEntity; import com.zkj.wecom.marketing.customer.model.domain.req.pullnew.*; import com.zkj.wecom.marketing.customer.model.domain.vo.CustomerCountVO; import com.zkj.wecom.marketing.customer.model.domain.vo.pullnew.*; import com.zkj.wecom.marketing.customer.model.enums.WeComCustomerHandleTypeEnum; import com.zkj.wecom.marketing.customer.server.handle.config.CompanyConfigHandle; import com.zkj.wecom.marketing.customer.server.service.CloudCustomerPullNewService; import com.zkj.wecom.marketing.system.core.service.SysCompanyConfigService; import com.zkj.wecom.marketing.system.model.domain.entity.base.*; import com.zkj.wecom.marketing.system.model.domain.entity.tenant.SysCompanyConfig; import com.zkj.wecom.marketing.wechat.api.feign.WeChatAppMessageFeign; import com.zkj.wecom.marketing.wechat.model.app.MessageSendRequest; import com.zkj.wecom.marketing.wechat.model.app.MessageSendResponse; import lombok.Data; import lombok.extern.slf4j.Slf4j; import org.apache.commons.compress.utils.Lists; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.BeanUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.interceptor.TransactionAspectSupport; import javax.annotation.Resource; import java.time.*; import java.time.format.DateTimeFormatter; import java.util.*; import java.util.concurrent.TimeUnit; import java.util.function.Function; import java.util.stream.Collectors; @Slf4j @Service public class CloudCustomerPullNewServiceImpl implements CloudCustomerPullNewService { @Resource private BaseMemberService baseMemberService; @Resource private BaseCustomerService baseCustomerService; @Resource private BaseCustomerGroupService baseCustomerGroupService; @Resource private BaseDepartmentService baseDepartmentService; @Resource private BaseCustomerFollowService baseCustomerFollowService; @Resource private CustomerPullNewService pullNewService; @Resource private CustomerPullNewStaffService pullNewStaffService; @Resource private CustomerPullNewGroupService pullNewGroupService; @Resource private CustomerPullNewCustomerService pullNewCustomerService; @Resource private SysCompanyConfigService sysCompanyConfigService; @Resource private WeChatAppMessageFeign weChatAppMessageFeign; @Resource private CompanyConfigHandle configHandle; @Resource private RedisUtil redisUtil; /** * 定时更新拉新排行活动状态redisKey */ private String redisSyncLock = "cover:pullnew:schedule"; /** * 拉新排行活动 - h5详情页 */ public static String PULL_NEW_H5_DETAIL = "/pages/operational_tools/staff_rank_detail"; /** * 活动开始消息内容 */ public static String PULL_NEW_START_MESSAGE = "【排行榜活动开始提醒】\n新的排行榜活动开始啦，快去看看吧~\n活动名称∶ %s\n排行指标∶ %s\n结束时间∶ %s\n上榜名次∶ %s\n<a href=%s>点击查看此排行榜活动</a>"; /** * 活动结束消息内容 */ public static String PULL_NEW_END_MESSAGE = "【排行榜活动结束提醒】\n您参加的排行榜活动结束啦，快去看看活动的最终排名吧~\n活动名称∶ %s\n排行指标∶ %s\n结束时间∶ %s\n上榜名次∶ %s\n您的最终排名∶ %s\n<a href=%s>点击查看此排行榜活动</a>"; /** * 每日播报消息内容 */ public static String PULL_NEW_DAY_MESSAGE = "【排行榜活动每日播报】\n您的今日排名为第%s名\n距上一名∶ 差%s位客户\n活动名称∶ %s\n排行指标∶ %s\n结束时间∶ %s\n上榜名次∶ %s\n<a href=%s>点击查看此排行榜活动</a>"; /** * 上榜消息内容 */ public static String PULL_NEW_UP_MESSAGE = "【排行榜上榜提醒】\n恭喜您上榜啦，距上一名差∶%s位客户，请乘势而上，再创新高哦~\n活动名称∶ %s\n排行指标∶ %s\n结束时间∶ %s\n上榜名次∶ %s\n您的当前排名∶ %s\n<a href=%s>点击查看此排行榜活动</a>"; /** * 落榜消息内容 */ public static String PULL_NEW_DOWN_MESSAGE = "【排行榜落榜提醒】\n您已经落榜啦，距上榜差∶%s位客户，请不要气馁，继续加油哦~\n活动名称∶ %s\n排行指标∶ %s\n结束时间∶ %s\n上榜名次∶ %s\n您的当前排名∶ %s\n<a href=%s>点击查看此排行榜活动</a>"; /** * 即将上榜消息内容 */ public static String PULL_NEW_RANKING_MESSAGE = "【排行榜提醒】排行榜日报来啦\n活动名称∶ %s\n排行指标∶ %s\n结束时间∶ %s\n上榜名次∶ %s\n今日排名∶ %s\n距上一名∶ 差%s位客户\n继续加油哦\n<a href=%s>点击查看此排行榜活动</a>"; /** * 拉新排行类型 */ public static final Map<Integer, String> PULL_NEW_TYPE_MAP = new HashMap(); /** * status标识 */ public static final Map<Integer, String> STATUS_MAP = new HashMap(); /** * flag标识 */ public static final Map<Integer, String> FLAG_MAP = new HashMap(); static { /** 拉新排行类型 **/ PULL_NEW_TYPE_MAP.put(0, "邀请成为企微客户"); PULL_NEW_TYPE_MAP.put(1, "邀请加入群聊"); /** status标识 **/ STATUS_MAP.put(0, "未开始"); STATUS_MAP.put(1, "进行中"); STATUS_MAP.put(2, "已结束"); /** flag标识 **/ FLAG_MAP.put(0, "否"); FLAG_MAP.put(1, "是"); } @Override @Transactional public JsonResult add(Integer tenantId, Integer currentMemberId, PullNewAddReq req) { log.info("add.tenantId:{}, currentMemberId:{}, req:{}", tenantId, currentMemberId, req); try { //参数校验 this.checkAddParams(req); //拉新排行榜保存 CustomerPullNewEntity pullNewEntity = new CustomerPullNewEntity(); BeanUtils.copyProperties(req, pullNewEntity); pullNewEntity.setTenantId(tenantId); pullNewEntity.setStartTime(req.getStartTimeInt()); pullNewEntity.setEndTime(req.getEndTimeInt()); pullNewEntity.setCreateBy(String.valueOf(curren