yhlxj/netflix-service/src/main/java/com/cyksj/task/Scheduler.java

package com.cyksj.task;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.BetweenFormater;
import cn.hutool.core.date.DateField;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.cyksj.common.EnvCommonService;
import com.cyksj.common.constant.Constant;
import com.cyksj.common.util.SmsUtil;
import com.cyksj.common.util.StringUtil;
import com.cyksj.dto.RedisKey;
import com.cyksj.mapper.*;
import com.cyksj.mapper.manage.cms.CmsUserMapper;
import com.cyksj.mapper.manage.distribute.DistributeWaitingSendPointsMapper;
import com.cyksj.mapper.manage.sys.WorkOrderMapper;
import com.cyksj.model.entity.*;
import com.cyksj.model.manage.views.AccountView;
import com.cyksj.model.manage.views.GroupsRelationView;
import com.cyksj.model.views.CloseGroupsTripsView;
import com.cyksj.model.views.CmsUserVO;
import com.cyksj.model.views.UserDistributeViews;
import com.cyksj.redis.RedisService;
import com.cyksj.service.mange.CmsAccountService;
import com.cyksj.service.order.OrderDonService;
import com.cyksj.service.register.RegisterOrderDonService;
import com.cyksj.service.register.SpotifyService;
import com.cyksj.service.relation.GroupRelationClearService;
import com.cyksj.service.sms.SmsService;
import com.cyksj.service.user.UserBenefitsService;
import com.ejlchina.searcher.BeanSearcher;
import com.ejlchina.searcher.param.Operator;
import com.ejlchina.searcher.util.MapUtils;
import com.google.common.collect.Lists;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import java.util.stream.Collectors;

@Component
@Slf4j
@RequiredArgsConstructor
public class Scheduler {

        private final GoodsDonMapper donMapper;

        private final GroupsMapper groupsMapper;

        private final OrderDonService orderDonService;

        private final GroupsRelationMapper groupsRelationMapper;

        private final UserMapper userMapper;

        private final BeanSearcher beanSearcher;

        private final SpotifyService spotifyService;

        private final RegisterOrderDonMapper registerOrderDonMapper;

        private final RedisService redisService;

        private final SysConfigMapper sysConfigMapper;

        private final DistributeWaitingSendPointsMapper distributeWaitingSendPointsMapper;

        private final RegisterOrderDonService registerOrderDonService;

        private final AppleAutoRegisterDataMapper appleAutoRegisterDataMapper;

        private final RealGoodsInterestUserMapper realGoodsInterestUserMapper;

        private final GroupRelationClearService groupRelationClearService;

        private final CmsAccountService cmsAccountService;

        private final EnvCommonService envCommonService;

        private final WorkOrderMapper workOrderMapper;

        private final SmsService smsService;

        private final CmsUserMapper cmsUserMapper;

	    private final AccountDoubleVerifyRecordMapper doubleVerifyRecordMapper;

	    private final UserBenefitsService userBenefitsService;


    /**
     * 每5分钟清理过期账号
     */
    @Scheduled(cron = "0 0/5 * * * ?")
    @Transactional(rollbackFor = Throwable.class)
    public void clearExpiry() {
        DateTime now = new DateTime();
        List<GroupsRelation> expiryList = groupsRelationMapper.selectList(Wrappers.lambdaQuery(GroupsRelation.class).le(GroupsRelation::getExpiryTime, now));
        log.info("定时清理过期账号start ===> 数量:{}", expiryList.size());
        //过期账号清楚有效期
        expiryList.forEach(relation -> groupRelationClearService.clearTicket(relation, UserTicketClearedRecord.Source.self));
    }

	@Scheduled(cron = "0 0 9 * * ?")
	public void expiryWxMsg() throws Exception {
		if (envCommonService.isPrdEnv()) {
			DateTime now = new DateTime();
			DateTime zero = DateUtil.offset(now, DateField.HOUR, -9);
			DateTime time = DateUtil.offset(zero, DateField.DAY_OF_MONTH, 1);
			List<GroupsRelationView> groupsRelations = beanSearcher.searchAll(GroupsRelationView.class, MapUtils.builder().field(GroupsRelationView::getExpiryTime, time).op(Operator.LessEqual).build());
			//String url = String.format("%sauth/weChat?url=%syinhe/web/ticket", envCommonService.getHost(), envCommonService.getDomain());
			for (GroupsRelationView relation : groupsRelations) {
//            User user = userMapper.selectById(relation.getUserId());
//            if (user != null && StrUtil.isNotBlank(user.getOpenId())) {
//                String openId = user.getOpenId();
//                WxAppTemplateView wxAppTemplateView = templateCommonService.getWxAppByUserId(openId, TemplateEnum.EXPIRY_TEMPLATE.getDesc());
//                if (wxAppTemplateView != null) {
//                    WxMpTemplateMessage templateMessage = new WxMpTemplateMessage()
//                            .setToUser(openId)
//                            .setTemplateId(wxAppTemplateView.getTemplateId())
//                            .setUrl(url);
//
//                    /**
//                     * 您的账号即将到期
//                     * 账号名称：Netflix账号
//                     * 平台：Netflix
//                     * 失效日期：3天后
//                     * 异常原因：账号即将到期
//                     * 请尽快续费，以免影响使用
//                     */
//                    GroupsTrips groupsTrips = groupsMapper.selectById(relation.getGroupsId());
//                    GoodsDonSku donSku = skuMapper.selectById(groupsTrips.getSkuId());
//                    GoodsDon goodsDon = donMapper.selectById(donSku.getGoodsId());
//                    WxMpTemplateMessage.TemplateData data = templateMessage.getData();
//                    data.setFirst(new WxMpTemplateData("您的账号即将到期"));
//                    data.setKeyword1(new WxMpTemplateData(goodsDon.getTitle()));
//                    data.setKeyword2(new WxMpTemplateData(DateUtil.format(relation.getExpiryTime(), "yyyy-MM-dd HH:mm:ss")));
//                    data.setRemark(new WxMpTemplateData("请尽快续费，以免影响使用"));
//                    log.info("发送账号即将到期消息至用户:{}", user.getId());
//                    weChatService.sendTemplateMessage(weChatService.getAccessToken(wxAppTemplateView.getAppId()), Jsons.toJson(templateMessage));
//            }

//                List<Account> accounts = accountMapper.selectList(Wrappers.lambdaQuery(Account.class).le(Account::getExpiryTime, time));
//                List<CustomerService> customerServices = customerServiceMapper.selectList(null);
//                if(!accounts.isEmpty()){
//                    for (CustomerService customerService : customerServices) {
//                        openId = customerService.getOpenId();
//                        WxMpTemplateMessage manageMessage = new WxMpTemplateMessage()
//                                .setToUser(openId)
//                                .setTemplateId(wxAppTemplateView.getTemplateId())
//                                .setUrl(" ");
//                        WxMpTemplateMessage.TemplateData data2 = manageMessage.getData();
//                        data2.setFirst(new WxMpTemplateData("您有" + accounts.size() + "个主账号即将到期"));
//                        data2.setKeyword1(new WxMpTemplateData("车队主账号"));
//                        data2.setKeyword2(new WxMpTemplateData("车队主账号"));
//                        data2.setKeyword3(new WxMpTemplateData("5天后"));
//                        data2.setKeyword4(new WxMpTemplateData("账号即将到期"));
//                        data2.setRemark(new WxMpTemplateData("请尽快登录后台-在账号管理中查看"));
//                        log.info("发送账号即将到期消息至客服:{}", customerService.getNickName());
//                        weChatService.sendTemplateMessage(weChatService.getAccessToken(),Jsons.toJson(manageMessage));
//                    }
//                }
//            }
				//短信通知过期账号 用户
				try {
					String day = DateUtil.formatBetween(zero, relation.getExpiryTime(), BetweenFormater.Level.DAY);
					if ("0".equals(day)) day = "今";
					smsService.sendSmsToRelationUser(relation.getUserId(), String.format(Constant.ACCOUNT_EXPIRY_MSG_TEMPLATE, relation.getTitle(), day));
				} catch (Exception e) {
					log.error("过期账号用户:{}发送短信错误:{}", relation.getUserId(), StringUtil.getErrorText(e));
				}
			}
		}
	}

    /**
     * 定时关闭订单
     */
    @Scheduled(cron = "0 0/5 * * * ?")
    public void closeOrder() {
        //获取为支付订单
        DateTime now = new DateTime();
        Date newDate = DateUtil.offset(now, DateField.MINUTE, -5);
        List<OrderDon> list = orderDonService.list(Wrappers.lambdaQuery(OrderDon.class).eq(OrderDon::getStatus, OrderDon.Status.noPayment).le(OrderDon::getCreatedTime,newDate));
        log.info("定时任务 关闭 订单数：{}",list.size());
        list.forEach((orderDon)->{
            orderDonService.closeOrder(orderDon.getId());
        });
    }

    /**
     * spotify 注册
     */
    @Scheduled(cron = "0 0/15 * * * ?")
    public void spotify() {
        List<RegisterOrderDon> spotify = registerOrderDonMapper.selectList(Wrappers.lambdaQuery(RegisterOrderDon.class)
                .select(RegisterOrderDon::getId)
                .eq(RegisterOrderDon::getPlatform, "spotify")
                .eq(RegisterOrderDon::getStatus, RegisterOrderDon.Status.hasPayment));
        for (RegisterOrderDon orderDon : spotify) {
            spotifyService.register(orderDon.getId());
        }
    }

    /**
     * 每日免单重置
     */
    @Scheduled(cron = "0 0 0 * * ?")
    public void freeReset() {
        log.info("每日重置 spotify 免单账户数 [start]");
        SysConfig register_free_num = sysConfigMapper.selectOne(Wrappers.lambdaQuery(SysConfig.class).eq(SysConfig::getSysKey, "register_free_num"));
        redisService.set(RedisKey.SPOTIFY_FREE_NUM, Long.parseLong(register_free_num.getSysValue()));
        log.info("每日重置 spotify 免单账户数 [end] 数量:{}",register_free_num.getSysValue());
    }

    /**
     * 分销订单积分奖励分发
     */
    @Scheduled(cron = "0 0 0/2 * * ?")
    @Transactional(rollbackFor = Throwable.class)
    public void distributeOrdersSendPoints() {
        List<DistributeWaitingSendPoints> waitingSendPoints = Optional.ofNullable(distributeWaitingSendPointsMapper.selectList(Wrappers.lambdaQuery(DistributeWaitingSendPoints.class)
                .eq(DistributeWaitingSendPoints::getSendStatus, DistributeWaitingSendPoints.Status.waiting)
                .lt(DistributeWaitingSendPoints::getSendTime, DateTime.now())
                .select(DistributeWaitingSendPoints::getId,
                        DistributeWaitingSendPoints::getOrderId,
                        DistributeWaitingSendPoints::getPoints,
                        DistributeWaitingSendPoints::getUserId,
                        DistributeWaitingSendPoints::getSharedId,
                        DistributeWaitingSendPoints::getSendTime))).orElse(new ArrayList<>());
        log.info("查询分销订单积分分发记录开始,条数:{}=======》", waitingSendPoints.size());
        waitingSendPoints.forEach(wait -> {
            //积分待发人
            Long sharedId = wait.getSharedId();
            User user = userMapper.selectById(sharedId);
            if (user == null) {
                wait.setSendStatus(DistributeWaitingSendPoints.Status.not_exist);
                log.info("分销订单,发送积分用户不存在");
                distributeWaitingSendPointsMapper.updateById(wait);
            } else {
                wait.setSendStatus(DistributeWaitingSendPoints.Status.success);
                log.info("更新用户积分开始=====>");
	            userBenefitsService.addDistributePoints(sharedId, wait.getPoints());
	            distributeWaitingSendPointsMapper.updateById(wait);
	            log.info("分销积分表订单id:{}发放积分success", wait.getOrderId());
            }
        });
    }

    /**
     * 定时更新未支付AppleID自动注册订单
     */
    @Scheduled(cron = "0 0/5 * * * ?")
    public void updateAppleAutoStatus() {
        //获取为支付订单
        DateTime now = new DateTime();
        Date newDate = DateUtil.offset(now, DateField.MINUTE, -5);
        List<Long> orderDons = appleAutoRegisterDataMapper.getAllNoPayOrders(newDate);
        log.info("定时更新未支付AppleID自动注册订单 订单数：{}",orderDons.size());
        orderDons.forEach((orderId)->{
            registerOrderDonService.updateAppleAutoStatus(orderId);
        });
    }

    /**
     * 实物订单意愿数据
     */
    @Scheduled(cron = "0 0/5 * * * ?")
    public void realGoodsInterestUser() {
        Optional.ofNullable(orderDonService.selectNoPaymentRealGoods()).ifPresent(list -> {
                    if (list.size() > 0) {
                        Map<String, List<RealGoodsInterestUser>> collect = list.stream().collect(Collectors.groupingBy(RealGoodsInterestUser::getGroupBy));
                        log.info("实物订单意愿数据同步开始");
                        collect.forEach((k, data) -> {
                            RealGoodsInterestUser realGoodsInterestUser = null;
                            if (data.size() == 0) {
                                realGoodsInterestUser = data.get(0);
                            } else {
                                List<RealGoodsInterestUser> high = data.stream().sorted(Comparator.comparing(RealGoodsInterestUser::getMoney).thenComparing(RealGoodsInterestUser::getOrderCreatedTime).reversed()).collect(Collectors.toList());
                                realGoodsInterestUser = high.get(0);
                            }
                            try {
                                realGoodsInterestUserMapper.insert(realGoodsInterestUser);
                            } catch (DuplicateKeyException e) {
                                log.info("重复插入用户相同实物商品记录");
                            }
                        });
                        log.info("实物订单意愿数据同步结束");
                    }
                }
        );
        Integer update = orderDonService.updateHasPaymentInterestRealGoods();
        orderDonService.updateHasPaymentInterestRealGoodsPayTime();
        if (update > 0) {
            log.info("更新用户记录:{}已购买实物意愿商品状态成功", update);
        }
    }

    /**
     * 统计昨日过期账号 分配给客服
     */
    @Scheduled(cron = "0 30 8 * * ?")
    public void assignNeedUpdateExpiredAccount() {
        DateTime beginOfDay = DateUtil.beginOfDay(DateTime.now());
	    String yesTimeSql = String.format("and ur.created_time < '%s'", beginOfDay);
	    String extra_sql = String.format("(if((select count(distinct relation_id) from user_ticket_cleared_record ur where ur.account_id = a.id and deleted is true and source = 'self' %s)>=5,true,false)) = 1", yesTimeSql);
        List<AccountView> accountViews = beanSearcher.searchAll(AccountView.class, MapUtils.builder()
                .put("extra_sql", extra_sql)
                .field(AccountView::getCustomerServiceId, 0)
                .build());
        if (accountViews.size() > 0) {
            int accountSize = accountViews.size();
            log.info("开始给客服分配过期账号,过期账号数量:{}", accountSize);
            List<CmsUserVO> customers = beanSearcher.searchAll(CmsUserVO.class, MapUtils.builder().field(CmsUserVO::getRoleNames, "客服").op(Operator.Contain).build());
            if (customers.isEmpty()) {
                log.info("暂无客服");
                return;
            }
            //分配过期账号
            cmsAccountService.assignCustomerAccount(customers, accountViews);
        }

    }

    /**
     * 2天前的工单未关闭 直接关闭
     */
    @Scheduled(cron = "0 10 0 * * ?")
    public void closeWorkOrderBeforeTowDays() {
        DateTime twoBefore = DateUtil.offsetDay(DateTime.now(), -2);
        List<WorkOrder> workOrders = beanSearcher.searchAll(WorkOrder.class, MapUtils.builder()
                .field(WorkOrder::getStatus, WorkOrder.Status.waiting.name())
                .field(WorkOrder::getCreatedTime, twoBefore).op(Operator.LessEqual)
                .onlySelect(WorkOrder::getId)
                .build());
        if (CollUtil.isNotEmpty(workOrders)) {
            List<Long> collect = workOrders.stream().map(WorkOrder::getId).collect(Collectors.toList());
            List<List<Long>> lists = Lists.partition(collect, 1000);
            log.info("关闭2天前未关闭的工单");
            lists.forEach(ids -> {
                workOrderMapper.update(null, Wrappers.lambdaUpdate(WorkOrder.class)
                        .set(WorkOrder::getStatus, WorkOrder.Status.close)
                        .in(WorkOrder::getId, ids));
            });
        }
    }

    /**
     * 推广者渠道昨天订单金额是否小于过去7天平均订单金额的一半
     * 若小于 则发送短信到对应商务
     */
    @Scheduled(cron = "0 30 8 * * ?")
    public void distributeOrderDetailAndSendMsgToBusiness() {
	    Integer daysRule = 7;
	    DateTime thisZero = DateUtil.beginOfDay(DateTime.now());

	    DateTime yesZero = DateUtil.offsetDay(thisZero, -1);
	    DateTime thePast7dZero = DateUtil.offsetDay(yesZero, -daysRule);

	    DateTime twoYesZero = DateUtil.offsetDay(thisZero, -2);
	    DateTime theTwoPast7dZero = DateUtil.offsetDay(twoYesZero, -daysRule);
	    //总销量小于1000的 不算、建立天数低于7天的不算、 连续2天销量低于7天平均值的50%的 提醒
	    List<UserDistributeViews> userDistributeViews = beanSearcher.searchAll(UserDistributeViews.class, MapUtils.builder()
			    .field(UserDistributeViews::getCreatedTime, thePast7dZero).op(Operator.LessEqual)
			    .field(UserDistribute::getBusinessId, 0).op(Operator.GreaterThan)
			    .put("time", String.format("and od.created_time < '%s'", thisZero))
			    .field(UserDistributeViews::getDistributeOrdersMoney, BigDecimal.valueOf(100000)).op(Operator.GreaterEqual)
			    .build());
	    String thePast7dTimeSql = String.format("and od.created_time >= '%s' and od.created_time < '%s'", thePast7dZero, yesZero);
	    String yesTimeSql = String.format("and od.created_time >= '%s' and od.created_time < '%s'", yesZero, thisZero);

	    String theTwoPast7dTimeSql = String.format("and od.created_time >= '%s' and od.created_time < '%s'", theTwoPast7dZero, twoYesZero);
	    String twoYesTimeSql = String.format("and od.created_time >= '%s' and od.created_time < '%s'", twoYesZero, yesZero);

	    Map<Long, String> phoneMap = new ConcurrentHashMap<>();
	    userDistributeViews.forEach(data -> {
		    //昨天过去7天总订单金额
		    Number yesPastFtMoneySum = beanSearcher.searchSum(UserDistributeViews.class, MapUtils.builder()
				    .field(UserDistributeViews::getUserId, data.getUserId())
				    .put("time", thePast7dTimeSql).build(), "distributeOrdersMoney");
		    //前天过去7天总订单金额
		    Number towYesPastMoneySum = beanSearcher.searchSum(UserDistributeViews.class, MapUtils.builder()
				    .field(UserDistributeViews::getUserId, data.getUserId())
				    .put("time", theTwoPast7dTimeSql).build(), "distributeOrdersMoney");

		    int theYes7dPastMoney = yesPastFtMoneySum.intValue();

		    int theTwoYes7dPastMoney = towYesPastMoneySum.intValue();
		    UserDistributeViews yesDistribute = beanSearcher.searchFirst(UserDistributeViews.class, MapUtils.builder()
				    .field(UserDistributeViews::getUserId, data.getUserId())
				    .put("time", yesTimeSql).build());

		    UserDistributeViews twoYesDistribute = beanSearcher.searchFirst(UserDistributeViews.class, MapUtils.builder()
				    .field(UserDistributeViews::getUserId, data.getUserId())
				    .put("time", twoYesTimeSql).build());
		    BigDecimal yesDistributeOrdersMoney = yesDistribute.getDistributeOrdersMoney();
		    BigDecimal twoYesDistributeOrdersMoney = twoYesDistribute.getDistributeOrdersMoney();

		    BigDecimal thePast7dAverage = BigDecimal.valueOf(theYes7dPastMoney).divide(BigDecimal.valueOf(daysRule).multiply(BigDecimal.valueOf(2)), 2, RoundingMode.HALF_DOWN);
		    BigDecimal theTwoPast7dAverage = BigDecimal.valueOf(theTwoYes7dPastMoney).divide(BigDecimal.valueOf(daysRule).multiply(BigDecimal.valueOf(2)), 2, RoundingMode.HALF_DOWN);
		    if (yesDistributeOrdersMoney.compareTo(thePast7dAverage) < 0 && twoYesDistributeOrdersMoney.compareTo(theTwoPast7dAverage) < 0) {
			    User user = userMapper.selectById(data.getUserId());
			    String msg = String.format(Constant.BUSINESS_CHANNEL_MSG, (user == null ? "用户" : user.getNickname()), data.getUserId());
			    String phone = phoneMap.get(data.getUserId());
			    if (StrUtil.isBlank(phone)) {
				    CmsUser cmsUser = cmsUserMapper.selectById(data.getBusinessId());
				    if (cmsUser != null) {
					    phone = cmsUser.getPhone();
					    phoneMap.putIfAbsent(data.getBusinessId(), phone);
				    }
			    }
			    if (StrUtil.isNotBlank(phone)) {
				    log.info("商务businessId:{}所下渠道用户id:{}分销数据已低于7天平均值的50%%", data.getBusinessId(), data.getUserId());
				    //发短信
				    SmsUtil.sendLuoKey2Msg(phone, msg);
			    }
			    return;
		    }
	    });
    }

	@Scheduled(cron = "0 0 0/3 * * ?")
	public void accountDoubleVerify() {
    	//chatGPT PLUS
		Long goodsId = 18l;
		List<AccountDoubleVerifyRecord> doubleVerifyRecords = groupsMapper.selectGPTDoubleVerifyTrips(goodsId);
		doubleVerifyRecords.forEach(data -> {
			AccountDoubleVerifyRecord exist = doubleVerifyRecordMapper.selectOne(Wrappers.lambdaQuery(AccountDoubleVerifyRecord.class)
					.eq(AccountDoubleVerifyRecord::getAccountId, data.getAccountId())
					.eq(AccountDoubleVerifyRecord::getDeleted, true).last("limit 1"));
			if (exist == null) {
				if (redisService.setNx(String.format("%s-%s", data.getAccountId(), data.getId()), data.getId(), 60l)) {
					log.info("插入待开启双重验证号账号:{}", data.getAccount());
					data.setRemark("车队满员后三天后自动移入");
					doubleVerifyRecordMapper.insert(data);
				}
			}
		});
	}

	/**
	 * 每日凌晨下架今日过期车队账号
	 */
	@Scheduled(cron = "0 0 0 * * ?")
	public void closeGroupsTrips() {
		DateTime now = DateTime.now();
		DateTime nextDay = DateUtil.offsetDay(DateUtil.beginOfDay(now), 3);
		List<CloseGroupsTripsView> closeGroupsTripsViews = Optional.ofNullable(beanSearcher.searchAll(CloseGroupsTripsView.class, MapUtils.builder()
				.field(CloseGroupsTripsView::getExpiryTime, nextDay).op(Operator.LessThan)
				.field(CloseGroupsTripsView::getGoodsId, List.of(18, 26)).op(Operator.InList)
				.field(CloseGroupsTripsView::getGroupsId).op(Operator.NotNull)
				.field(CloseGroupsTripsView::getGroupsStatus, GroupsTrips.Status.down.name()).op(Operator.NotEqual)
				.build())).orElse(new ArrayList<>());
		log.info("下架过期账号数量:{}", closeGroupsTripsViews.size());
		closeGroupsTripsViews.forEach(account -> {
			int update = groupsMapper.update(null, Wrappers.lambdaUpdate(GroupsTrips.class)
					.set(GroupsTrips::getStatus, GroupsTrips.Status.down)
					.ne(GroupsTrips::getStatus, GroupsTrips.Status.down)
					.eq(GroupsTrips::getId, account.getGroupsId()));
			if (update == 1) {
				log.info("将过期账号:{}车队:{}下架", account.getId(), account.getGroupsId());
			}
		});
	}
}