From bae42356684138720f1613b8d887034bf4d62cc0 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 24 Oct 2023 14:15:14 +0800
Subject: [PATCH] 版本管理
---
src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java | 128 ++++++++++++++++++++++++++++++------------
1 files changed, 92 insertions(+), 36 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java b/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java
index 457810f..1ccbe27 100644
--- a/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java
+++ b/src/main/java/cc/mrbird/febs/mall/quartz/ProfitJob.java
@@ -3,28 +3,37 @@
import cc.mrbird.febs.common.enumerates.AgentLevelEnum;
import cc.mrbird.febs.common.enumerates.MoneyFlowTypeEnum;
import cc.mrbird.febs.common.utils.MallUtils;
+import cc.mrbird.febs.mall.entity.ChatGroup;
+import cc.mrbird.febs.mall.entity.ChatUser;
import cc.mrbird.febs.mall.entity.MallMember;
import cc.mrbird.febs.mall.entity.MallMoneyFlow;
+import cc.mrbird.febs.mall.mapper.ChatGroupMapper;
+import cc.mrbird.febs.mall.mapper.ChatUserMapper;
import cc.mrbird.febs.mall.mapper.MallMemberMapper;
import cc.mrbird.febs.mall.mapper.MallMoneyFlowMapper;
import cc.mrbird.febs.mall.service.IApiMallMemberService;
import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;
import cc.mrbird.febs.mall.service.IMemberProfitService;
import cc.mrbird.febs.mall.service.impl.CommonService;
+import cc.mrbird.febs.rabbit.producter.AgentProducer;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.RandomUtil;
import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
+import javax.annotation.Resource;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.Date;
import java.util.List;
+import java.util.Random;
/**
* @author wzy
@@ -34,53 +43,100 @@
@Component
public class ProfitJob {
- @Autowired
- private IMemberProfitService memberProfitService;
+ @Resource
+ private ChatUserMapper chatUserMapper;
+
+ @Resource
+ private ChatGroupMapper chatGroupMapper;
+
+ @Resource
+ private AgentProducer agentProducer;
/**
* 代理分红
*/
- @Scheduled(cron = "0 30 0 * * ?")
+// @Scheduled(cron = "0 0/1 * * * ? ")
+ @Scheduled(cron = "0/2 * * * * ? ")
+// @Scheduled(cron = "0/30 * * * * ? ")
public void profitJob() {
- memberProfitService.agentProfit(null);
+ QueryWrapper<ChatGroup> objectQueryWrapper = new QueryWrapper<>();
+ objectQueryWrapper.eq("auto_send", 1);
+ List<ChatGroup> chatGroups = chatGroupMapper.selectList(objectQueryWrapper);
+ if(CollUtil.isNotEmpty(chatGroups)){
+ for(ChatGroup chatGroup : chatGroups){
+ agentProducer.sendAutoSendMsg(chatGroup.getId());
+ }
+ }
}
- @Scheduled(cron = "0 30 1 * * ?")
- public void storeAndDirectorJob() {
- memberProfitService.storeAndDirectorProfit(null);
+// @Scheduled(cron = "0/2 * * * * ? ")
+ @Scheduled(cron = "0 0 0/1 * * ? ")
+ public void robotNickNameJob() {
+ List<ChatUser> chatUsers = chatUserMapper.selectListByIsRobot(1);
+ if(CollUtil.isNotEmpty(chatUsers)){
+ for(ChatUser chatUser : chatUsers){
+ chatUserMapper.updateNicknameById(chatUser.getUserId(),randomName(RandomUtil.randomInt(1, 5)));
+ }
+ }
}
- /**
- * 感恩奖
- */
- @Scheduled(cron = "0 0 1 * * ?")
- public void thankfulJob() {
- memberProfitService.thankfulProfit(null);
- }
+ public static String randomName(Integer len){
+ len=len<2? 2:len;
+ StringBuilder name = new StringBuilder();
+
+ String na = "赵钱孙李周吴郑王冯陈褚卫蒋沈韩杨朱秦尤许何吕施张孔曹严华金魏陶姜戚谢邹喻柏水窦" +
+ "章云苏潘葛奚范彭郎鲁韦昌马苗凤花方俞袁柳鲍史唐费廉岑薛雷贺倪汤滕殷罗毕郝安常于傅" +
+ "齐康伍余元顾孟黄穆萧尹姚邵湛汪祁毛禹狄米明计成戴宋茅庞熊纪舒屈项祝董梁杜" +
+ "阮蓝闵席季贾路娄危江童颜郭梅林钟徐邱骆高夏蔡田樊胡";
+ Random random=new Random();
+ int nextInt = random.nextInt(na.length() - 1);
+ name.append(na.charAt(nextInt));
- /**
- * 静态分红
- */
-// @Scheduled(cron = "0 0 0 * * ?")
-// public void staticProfitJob() {
-// memberProfitService.staticProfit(null);
-// }
+// String me = "承月施韵浦镜强辉伟晴世彦圆鉴凯运吉峰傲轩拂勋健净励柏福晋年常文悠颜建帆丰锦毅睿迪厉昌炎俊豫泉展冠飞雪传忠力平幽阳融材实刚理光浅商星奋照侠满厚宁广明勇潭雄壮鼎贵煊闻仕荣永易馨琢卡遥霄彬何均湛群东飘怀安城观翱石敬织豪杉朴保捷军" +
+// "笑柔秋嫣灵儿悠润怜听睿莉忆蓉醉桐海含怀卿娅明芸佑玫歆茵雨珊花如娇江幼薇凤沛柳霜晓黛絮沁媛洁冰奇佳兔芙菊慧裳蓝映夜可盈又瑾微婉迪婷琳真雪鸣影琴烟月杏妹娜倚辰舒柯芝任傲悦梦楠岚彩虞菱雅以竹艺蕾嫦孤丽林优迎琼" +
+// "骏宇玄璀紫子全超益莉信美奎琪豪浩槐文巧治瑜雯诗涵曦嵘天誉喜伟嘉欣卿钰勇寅天宸兵祥运昊泽仁淳轩子泳瑶源杰正驿豪财熙海辉辉天华峻龙嘉诚嘉运财喜伟天俊熙熙利君帝云海伟熙霞艳宗书文国熙林天录熙明俊敬贵艺心艾悦思甜帅梅莲婷伯沁苹苗龙尔" +
+// "仕墨驿森桥丹东墨满阳骏鹏毓昆金宇宇木金豪天洋宇捷治智浩泽搏朗桐喜伊萱彤正裕馨湘锦湘玉元坤子侦山水茂阳海乐晨杰高启夫玉舟凌璇雨扬晨亭艳昊洋晴雨雨晨雨辰骞娴颖晞朝晓小蕾雯悦月秋绮书彤诗韬羿程惠忻";
+//
+// for (int i = 0; i < len-1; i++) {
+// int anInt = random.nextInt(me.length()-1);
+// name.append(me.charAt(anInt));
+// }
+ char[] chars = {'张', '王', '李', '赵', '刘', '陈', '杨', '黄', '吴',
+ '周', '徐', '孙', '马', '朱', '胡', '郭', '何', '高', '林',
+ '罗', '郑', '梁', '谢', '宋', '唐', '许', '邓', '冯', '韩',
+ '曹', '曾', '彭', '萧', '蔡', '潘', '田', '董', '袁', '于',
+ '余', '叶', '蒋', '杜', '苏', '魏', '程', '吕', '丁', '沈',
+ '任', '姚', '卢', '姜', '崔', '钟', '谭', '陆', '汪', '范',
+ '金', '石', '廖', '贾', '夏', '韦', '付', '方', '白', '邹',
+ '孟', '熊', '秦', '邱', '江', '尹', '薛', '闫', '段', '雷',
+ '侯', '龙', '史', '陶', '黎', '贺', '顾', '毛', '郝', '龚',
+ '邵', '万', '钱', '严', '覃', '武', '戴', '莫', '孔', '向',
+ '汤', '安', '祝', '福', '柯', '柴', '翟', '宁', '房', '滕',
+ '屈', '饶', '解', '牛', '艾', '尤', '丰', '阳', '时', '穆',
+ '冉', '牟', '殷', '毕', '邬', '安', '常', '乐', '于', '时',
+ '傅', '皮', '卫', '齐', '康', '伍', '余', '元', '卜', '顾',
+ '孟', '平', '黄', '和', '穆', '萧', '尹', '姚', '邵', '湛',
+ '汪', '祁', '毛', '禹', '狄', '米', '贝', '明', '藏', '计',
+ '伏', '成', '戴', '谈', '宋', '茅', '庞', '熊', '纪', '舒',
+ '屈', '项', '祝', '董', '梁', '杜', '阮', '蓝', '闵', '席',
+ '季', '麻', '强', '贾', '路', '娄', '危', '江', '童', '颜',
+ '郁', '胥', '柳', '鲍', '史', '唐', '费', '岑', '薛', '雷',
+ '贺', '倪', '汤', '滕', '殷', '罗', '毕', '郝', '邬', '安',
+ '常', '乐', '于', '时', '傅', '皮', '卫', '齐', '康', '伍',
+ '余', '元', '卜', '顾', '孟', '平', '黄', '和', '穆', '萧',
+ '尹', '姚', '邵', '湛', '汪', '祁', '毛', '禹', '狄', '米',
+ '贝', '明', '藏', '计', '伏', '成', '戴', '谈', '宋', '茅',
+ '庞', '熊', '纪', '舒', '屈', '项', '祝', '董', '梁', '杜',
+ '阮', '蓝', '闵', '席', '季', '麻', '强', '贾', '路', '娄',
+ '危', '江', '童', '颜', '郁', '胥', '柳', '鲍', '史', '唐',
+ '费', '岑', '薛', '雷', '贺', '倪', '汤', '滕', '殷', '罗', '毕', '郝', '邬', '安', '常', '乐', '于', '时', '傅', '皮', '卫', '齐', '康', '伍', '余', '元', '卜', '顾', '孟', '平', '黄', '和', '穆', '萧', '尹', '姚', '邵', '湛', '汪', '祁', '毛', '禹', '狄', '米', '贝', '明', '藏', '计', '伏', '成', '戴', '谈', '宋', '茅', '庞', '熊', '纪', '舒', '屈', '项', '祝', '董', '梁', '杜', '阮', '蓝', '闵', '席', '季', '麻', '强', '贾', '路', '娄', '危', '江', '童', '颜', '郁', '胥', '柳', '鲍', '史', '唐', '费', '岑', '薛', '雷', '贺', '倪', '汤', '滕', '殷', '罗', '毕', '郝', '邬', '安', '常', '乐', '于', '时', '傅', '皮', '卫', '齐', '康', '伍', '余', '元', '卜', '顾', '孟', '平', '黄', '和', '穆', '萧', '尹', '姚', '邵', '湛', '汪', '祁', '毛', '禹', '狄', '米', '贝', '明', '藏', '计', '伏', '成', '戴', '谈', '宋', '茅', '庞', '熊', '纪', '舒', '屈', '项', '祝', '董', '梁', '杜', '阮', '蓝', '闵', '席', '季', '麻', '强', '贾', '路', '娄', '危', '江', '童', '颜', '郁', '胥', '柳', '鲍', '史', '唐', '费', '岑', '薛', '雷', '贺', '倪', '汤', '滕', '殷', '罗', '毕', '郝', '邬', '安', '常', '乐', '于', '时', '傅', '皮', '卫', '齐', '康', '伍', '余', '元', '卜', '顾', '孟', '平', '黄', '和', '穆', '萧', '尹', '姚', '邵', '湛', '汪', '祁', '毛', '禹', '狄', '米', '贝', '明', '藏', '计', '伏', '成', '戴', '谈', '宋', '茅', '庞', '熊', '纪', '舒', '屈', '项', '祝', '董', '梁', '杜', '阮', '蓝', '闵', '席', '季', '麻', '强', '贾', '路', '娄', '危', '江', '童', '颜', '郁', '胥', '柳', '鲍', '史', '唐', '费', '岑', '薛', '雷', '贺', '倪', '汤', '滕', '殷', '罗', '毕', '郝', '邬', '安', '常', '乐', '于', '时', '傅', '皮', '卫', '齐', '康', '伍', '余', '元', '卜', '顾', '孟', '平', '黄', '和', '穆', '萧', '尹', '姚', '邵', '湛', '汪', '祁', '毛', '禹', '狄', '米', '贝', '明', '藏', '计', '伏', '成', '戴', '谈', '宋', '茅', '庞', '熊', '纪', '舒', '屈', '项', '祝', '董', '梁', '杜', '阮', '蓝', '闵', '席', '季', '麻', '强', '贾', '路', '娄', '危', '江', '童', '颜', '郁', '胥', '柳', '鲍', '史', '唐', '费', '岑', '薛', '雷', '贺', '倪', '汤', '滕', '殷', '罗', '毕', '郝', '邬', '安', '常', '乐', '于', '时', '傅', '皮', '卫', '齐', '康', '伍', '余', '元', '卜', '顾', '孟', '平', '黄', '和', '穆', '萧', '尹', '姚', '邵', '湛', '汪', '祁', '毛', '禹', '狄', '米', '贝', '明', '藏', '计', '伏', '成', '戴', '谈', '宋', '茅', '庞', '熊', '纪', '舒', '屈', '项', '祝', '董', '梁', '杜', '阮', '蓝', '闵', '席', '季', '麻', '强', '贾', '路', '娄', '危', '江', '童', '颜', '郁', '胥', '柳', '鲍', '史', '唐', '费', '岑', '薛', '雷', '贺', '倪', '汤', '滕', '殷', '罗', '毕', '郝', '邬', '安', '常', '乐', '于', '时', '傅', '皮', '卫', '齐', '康', '伍', '余', '元', '卜', '顾', '孟', '平', '黄', '和', '穆', '萧', '尹', '姚', '邵', '湛', '汪', '祁', '毛', '禹', '狄', '米', '贝', '明', '藏', '计', '伏', '成', '戴', '谈', '宋', '茅', '庞', '熊', '纪', '舒', '屈', '项', '祝', '董', '梁', '杜', '阮', '蓝', '闵', '席', '季', '麻', '强', '贾', '路', '娄', '危', '江', '童', '颜', '郁', '胥', '柳', '鲍', '史', '唐', '费', '岑', '薛', '雷', '贺', '倪', '汤', '滕', '殷', '罗', '毕', '郝', '邬', '安', '常', '乐', '于', '时', '傅', '皮', '卫', '齐', '康', '伍', '余', '元', '卜', '顾', '孟', '平', '黄', '和', '穆', '萧', '尹', '姚', '邵', '湛', '汪', '祁', '毛', '禹', '狄', '米', '贝', '明', '藏', '计', '伏', '成', '戴', '谈', '宋', '茅', '庞', '熊', '纪', '舒', '屈', '项', '祝', '董', '梁', '杜', '阮', '蓝', '闵', '席', '季', '麻', '强', '贾', '路', '娄', '危', '江', '童', '颜', '郁', '胥', '柳', '鲍', '史', '唐', '费', '岑', '薛', '雷', '贺', '倪', '汤', '滕', '殷', '罗', '毕', '郝', '邬', '安', '常', '乐', '于', '时', '傅', '皮', '卫', '齐', '康', '伍', '余', '元', '卜', '顾', '孟', '平', '黄', '和', '穆', '萧', '尹', '姚', '邵', '湛', '汪', '祁', '毛', '禹', '狄', '米', '贝', '明', '藏', '计', '伏', '成', '戴', '谈', '宋', '茅', '庞', '熊', '纪', '舒', '屈', '项', '祝', '董', '梁', '杜', '阮', '蓝', '闵', '席', '季', '麻', '强', '贾', '路', '娄', '危', '江', '童', '颜', '郁', '胥', '柳', '鲍', '史', '唐', '费', '岑', '薛', '雷', '贺', '倪', '汤', '滕', '殷', '罗', '毕', '郝', '邬', '安', '常', '乐', '于', '时', '傅', '皮', '卫', '齐', '康', '伍', '余', '元',
+ '卜', '顾', '孟', '平', '黄', '和', '穆', '萧', '尹'};
+ for (int i = 0; i < len-1; i++) {
+ int anInt = random.nextInt(chars.length);
+ name.append(chars[anInt]);
+ }
- /**
- * 排名奖 每月1号
- */
- @Scheduled(cron = "0 30 0 1 * ?")
- public void rankJob() {
- memberProfitService.rankProfit();
- }
-
- /**
- * 积分池，所有消费拿出10%放到积分池，然后按1%每天释放加权平分
- */
-// @Scheduled(cron = "0 0 2 * * ?")
- @Scheduled(cron = "0 0/5 * * * ? ")
- public void scorePool() {
- memberProfitService.scorePool();
+ return name.toString();
}
}
--
Gitblit v1.9.1