|
|
@@ -1,552 +1,552 @@
|
|
|
-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.mapper.market.task.UserBindDetailMapper;
|
|
|
-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.scheduler.SchedulerService;
|
|
|
-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 GoodsDonSkuMapper skuMapper;
|
|
|
-
|
|
|
- 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;
|
|
|
-
|
|
|
- private final SchedulerService schedulerService;
|
|
|
-
|
|
|
- private final UserBindDetailMapper userBindDetailMapper;
|
|
|
-
|
|
|
- private final static List<Long> filter_skuIds = List.of(177l);
|
|
|
-
|
|
|
- /**
|
|
|
- * 每5分钟清理过期账号
|
|
|
- */
|
|
|
- @Scheduled(cron = "0 0/5 * * * ?")
|
|
|
- public void clearExpiry() {
|
|
|
- DateTime now = new DateTime();
|
|
|
- //List<GroupsRelation> expiryList = groupsRelationMapper.selectList(Wrappers.lambdaQuery(GroupsRelation.class).le(GroupsRelation::getExpiryTime, now));
|
|
|
- List<GroupsRelation> expiryList = groupsRelationMapper.selectExpiredRelationByCondition(now, filter_skuIds);
|
|
|
- log.info("定时清理过期账号start ===> 数量:{}", expiryList.size());
|
|
|
- //过期账号清楚有效期
|
|
|
- expiryList.forEach(relation -> groupRelationClearService.clearTicket(relation, UserTicketClearedRecord.Source.self));
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 每天凌晨清除当天过期的ChatGPT PLUS车票
|
|
|
- */
|
|
|
- @Scheduled(cron = "0 1 0 * * ?")
|
|
|
- public void clearChatGPTPlusTicket() {
|
|
|
- DateTime now = new DateTime();
|
|
|
- DateTime nextBeginDay = DateUtil.offsetDay(DateUtil.beginOfDay(now), 1);
|
|
|
- List<Long> gptSkuIds = skuMapper.selectList(Wrappers.lambdaQuery(GoodsDonSku.class)
|
|
|
- .eq(GoodsDonSku::getGoodsId, 18)).stream().filter((sku) -> !filter_skuIds.contains(sku.getId())).map(GoodsDonSku::getId).collect(Collectors.toList());
|
|
|
- List<GroupsRelation> expiryGPTListToday = groupsRelationMapper.selectExpiredChatGPTRelation(nextBeginDay, gptSkuIds);
|
|
|
- log.info("每日凌晨清除当日过期GPT账号start ===> 数量:{}", expiryGPTListToday.size());
|
|
|
- //过期账号清楚有效期
|
|
|
- expiryGPTListToday.forEach(relation -> groupRelationClearService.clearTicket(relation, UserTicketClearedRecord.Source.self));
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 每日过期主账号 迁移该账号对应车队的未过期用户车票
|
|
|
- */
|
|
|
- @Scheduled(cron = "0 30 0 * * ?")
|
|
|
- public void expiryAccountTrans() {
|
|
|
- schedulerService.transExpiryAccountValidRelation();
|
|
|
- }
|
|
|
-
|
|
|
- @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));
|
|
|
+//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.mapper.market.task.UserBindDetailMapper;
|
|
|
+//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.scheduler.SchedulerService;
|
|
|
+//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 GoodsDonSkuMapper skuMapper;
|
|
|
+//
|
|
|
+// 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;
|
|
|
+//
|
|
|
+// private final SchedulerService schedulerService;
|
|
|
+//
|
|
|
+// private final UserBindDetailMapper userBindDetailMapper;
|
|
|
+//
|
|
|
+// private final static List<Long> filter_skuIds = List.of(177l);
|
|
|
+//
|
|
|
+// /**
|
|
|
+// * 每5分钟清理过期账号
|
|
|
+// */
|
|
|
+// @Scheduled(cron = "0 0/5 * * * ?")
|
|
|
+// public void clearExpiry() {
|
|
|
+// DateTime now = new DateTime();
|
|
|
+// //List<GroupsRelation> expiryList = groupsRelationMapper.selectList(Wrappers.lambdaQuery(GroupsRelation.class).le(GroupsRelation::getExpiryTime, now));
|
|
|
+// List<GroupsRelation> expiryList = groupsRelationMapper.selectExpiredRelationByCondition(now, filter_skuIds);
|
|
|
+// log.info("定时清理过期账号start ===> 数量:{}", expiryList.size());
|
|
|
+// //过期账号清楚有效期
|
|
|
+// expiryList.forEach(relation -> groupRelationClearService.clearTicket(relation, UserTicketClearedRecord.Source.self));
|
|
|
+// }
|
|
|
+//
|
|
|
+// /**
|
|
|
+// * 每天凌晨清除当天过期的ChatGPT PLUS车票
|
|
|
+// */
|
|
|
+// @Scheduled(cron = "0 1 0 * * ?")
|
|
|
+// public void clearChatGPTPlusTicket() {
|
|
|
+// DateTime now = new DateTime();
|
|
|
+// DateTime nextBeginDay = DateUtil.offsetDay(DateUtil.beginOfDay(now), 1);
|
|
|
+// List<Long> gptSkuIds = skuMapper.selectList(Wrappers.lambdaQuery(GoodsDonSku.class)
|
|
|
+// .eq(GoodsDonSku::getGoodsId, 18)).stream().filter((sku) -> !filter_skuIds.contains(sku.getId())).map(GoodsDonSku::getId).collect(Collectors.toList());
|
|
|
+// List<GroupsRelation> expiryGPTListToday = groupsRelationMapper.selectExpiredChatGPTRelation(nextBeginDay, gptSkuIds);
|
|
|
+// log.info("每日凌晨清除当日过期GPT账号start ===> 数量:{}", expiryGPTListToday.size());
|
|
|
+// //过期账号清楚有效期
|
|
|
+// expiryGPTListToday.forEach(relation -> groupRelationClearService.clearTicket(relation, UserTicketClearedRecord.Source.self));
|
|
|
+// }
|
|
|
+//
|
|
|
+// /**
|
|
|
+// * 每日过期主账号 迁移该账号对应车队的未过期用户车票
|
|
|
+// */
|
|
|
+// @Scheduled(cron = "0 30 0 * * ?")
|
|
|
+// public void expiryAccountTrans() {
|
|
|
+// schedulerService.transExpiryAccountValidRelation();
|
|
|
+// }
|
|
|
+//
|
|
|
+// @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)
|
|
|
+// .eq(DistributeWaitingSendPoints::getIsDelivery, true)
|
|
|
+// .le(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());
|
|
|
// }
|
|
|
-
|
|
|
-// 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));
|
|
|
+// });
|
|
|
+// }
|
|
|
+//
|
|
|
+// /**
|
|
|
+// * 定时更新未支付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(ur.id) from user_ticket_cleared_record ur where ur.account_id = a.id and deleted is true and source = 'self' %s)>=4,true,false)) = 1", yesTimeSql);
|
|
|
+// List<AccountView> accountViews = beanSearcher.searchAll(AccountView.class, MapUtils.builder()
|
|
|
+// .put("extra_sql", extra_sql)
|
|
|
+// .field(AccountView::getCustomerServiceId, 0)
|
|
|
+// .field(AccountView::getGoodsSecondType, 2)
|
|
|
+// .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;
|
|
|
// }
|
|
|
- //短信通知过期账号 用户
|
|
|
- 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)
|
|
|
- .eq(DistributeWaitingSendPoints::getIsDelivery, true)
|
|
|
- .le(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(ur.id) from user_ticket_cleared_record ur where ur.account_id = a.id and deleted is true and source = 'self' %s)>=4,true,false)) = 1", yesTimeSql);
|
|
|
- List<AccountView> accountViews = beanSearcher.searchAll(AccountView.class, MapUtils.builder()
|
|
|
- .put("extra_sql", extra_sql)
|
|
|
- .field(AccountView::getCustomerServiceId, 0)
|
|
|
- .field(AccountView::getGoodsSecondType, 2)
|
|
|
- .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();
|
|
|
- Constant.AI_goodsIds.forEach(goodsId -> {
|
|
|
- //ChatGPT 10天提前下架
|
|
|
- //midJourney 提前3天
|
|
|
- Integer day = 3;
|
|
|
- if (goodsId == 18) {
|
|
|
- day = 10;
|
|
|
- }
|
|
|
- DateTime nextDay = DateUtil.offsetDay(DateUtil.beginOfDay(now), day);
|
|
|
- List<CloseGroupsTripsView> closeGroupsTripsViews = Optional.ofNullable(beanSearcher.searchAll(CloseGroupsTripsView.class, MapUtils.builder()
|
|
|
- .field(CloseGroupsTripsView::getExpiryTime, nextDay).op(Operator.LessEqual)
|
|
|
- .field(CloseGroupsTripsView::getGoodsId, goodsId)
|
|
|
- .field(CloseGroupsTripsView::getGroupsId).op(Operator.NotNull)
|
|
|
- .field(CloseGroupsTripsView::getGroupsStatus, GroupsTrips.Status.down.name()).op(Operator.NotEqual)
|
|
|
- .build())).orElse(new ArrayList<>());
|
|
|
-
|
|
|
- log.info("下架goodsId:{}过期账号数量:{}", goodsId, 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());
|
|
|
- }
|
|
|
- });
|
|
|
- });
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 1w条短信 每小时
|
|
|
- */
|
|
|
- //@Scheduled(cron = "0 0 12,15,17,18 * * ?")
|
|
|
- public void marketingMsg() {
|
|
|
- //获取最大条件
|
|
|
- String key = RedisService.key.MAKERTING_MSG_KEY.getName();
|
|
|
- Object value = redisService.get(key);
|
|
|
- Integer max_filter = 0;
|
|
|
- if (value != null) {
|
|
|
- max_filter = Integer.parseInt(value.toString());
|
|
|
- log.info("过滤条数:{}", max_filter);
|
|
|
- }
|
|
|
- //获取手机号 每次获取3000次
|
|
|
- List<String> phones = userBindDetailMapper.selectPhones(max_filter);
|
|
|
- if (phones.isEmpty()) {
|
|
|
- log.info("营销短信已发完");
|
|
|
- return;
|
|
|
- }
|
|
|
- log.info("营销短信手机号数量大小:{}", phones.size());
|
|
|
- try {
|
|
|
- Boolean isSuccess = SmsUtil.batchSendLuoKey2Msg(phones, "618大促流媒体、Ai会员全场9折续费可用!电视看奈飞方案最多减100!登录https://nf.video下单【银河录像局】");
|
|
|
- if (isSuccess) {
|
|
|
- if (value != null) {
|
|
|
- redisService.incr(key, 10000l);
|
|
|
- return;
|
|
|
- }
|
|
|
- redisService.set(key, 10000, RedisService.key.MAKERTING_MSG_KEY.getTimeout());
|
|
|
- }
|
|
|
- } catch (Exception e) {
|
|
|
-
|
|
|
- }
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
+// //分配过期账号
|
|
|
+// 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();
|
|
|
+// Constant.AI_goodsIds.forEach(goodsId -> {
|
|
|
+// //ChatGPT 10天提前下架
|
|
|
+// //midJourney 提前3天
|
|
|
+// Integer day = 3;
|
|
|
+// if (goodsId == 18) {
|
|
|
+// day = 10;
|
|
|
+// }
|
|
|
+// DateTime nextDay = DateUtil.offsetDay(DateUtil.beginOfDay(now), day);
|
|
|
+// List<CloseGroupsTripsView> closeGroupsTripsViews = Optional.ofNullable(beanSearcher.searchAll(CloseGroupsTripsView.class, MapUtils.builder()
|
|
|
+// .field(CloseGroupsTripsView::getExpiryTime, nextDay).op(Operator.LessEqual)
|
|
|
+// .field(CloseGroupsTripsView::getGoodsId, goodsId)
|
|
|
+// .field(CloseGroupsTripsView::getGroupsId).op(Operator.NotNull)
|
|
|
+// .field(CloseGroupsTripsView::getGroupsStatus, GroupsTrips.Status.down.name()).op(Operator.NotEqual)
|
|
|
+// .build())).orElse(new ArrayList<>());
|
|
|
+//
|
|
|
+// log.info("下架goodsId:{}过期账号数量:{}", goodsId, 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());
|
|
|
+// }
|
|
|
+// });
|
|
|
+// });
|
|
|
+// }
|
|
|
+//
|
|
|
+// /**
|
|
|
+// * 1w条短信 每小时
|
|
|
+// */
|
|
|
+// //@Scheduled(cron = "0 0 12,15,17,18 * * ?")
|
|
|
+// public void marketingMsg() {
|
|
|
+// //获取最大条件
|
|
|
+// String key = RedisService.key.MAKERTING_MSG_KEY.getName();
|
|
|
+// Object value = redisService.get(key);
|
|
|
+// Integer max_filter = 0;
|
|
|
+// if (value != null) {
|
|
|
+// max_filter = Integer.parseInt(value.toString());
|
|
|
+// log.info("过滤条数:{}", max_filter);
|
|
|
+// }
|
|
|
+// //获取手机号 每次获取3000次
|
|
|
+// List<String> phones = userBindDetailMapper.selectPhones(max_filter);
|
|
|
+// if (phones.isEmpty()) {
|
|
|
+// log.info("营销短信已发完");
|
|
|
+// return;
|
|
|
+// }
|
|
|
+// log.info("营销短信手机号数量大小:{}", phones.size());
|
|
|
+// try {
|
|
|
+// Boolean isSuccess = SmsUtil.batchSendLuoKey2Msg(phones, "618大促流媒体、Ai会员全场9折续费可用!电视看奈飞方案最多减100!登录https://nf.video下单【银河录像局】");
|
|
|
+// if (isSuccess) {
|
|
|
+// if (value != null) {
|
|
|
+// redisService.incr(key, 10000l);
|
|
|
+// return;
|
|
|
+// }
|
|
|
+// redisService.set(key, 10000, RedisService.key.MAKERTING_MSG_KEY.getTimeout());
|
|
|
+// }
|
|
|
+// } catch (Exception e) {
|
|
|
+//
|
|
|
+// }
|
|
|
+// }
|
|
|
+//}
|
|
|
+//
|