增加魔女抽奖cd功能,防止刷屏

README.md

@@ -8,7 +8,11 @@
 
 前台监听地址 host: 127.0.0.1  port: 5700
 
-视频搭建流程 https://www.bilibili.com/video/BV14R4y1G7sM
+# 视频搭建流程：
+
+Linux服务器搭建：https://www.bilibili.com/video/BV14R4y1G7sM
+
+windows服务器搭建：https://www.bilibili.com/video/BV1pW4y1r7JS
 
 ## 静态资源 
 

build.gradle

@@ -19,6 +19,7 @@ dependencies {
 	implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
 	implementation 'org.springframework.boot:spring-boot-starter-web'
 	implementation('org.springframework.boot:spring-boot-starter-thymeleaf')
+	implementation('com.squareup.okhttp3:okhttp:5.0.0-alpha.2')
 	runtimeOnly('com.h2database:h2')
  	runtimeOnly 'mysql:mysql-connector-java'
 	testImplementation('org.springframework.boot:spring-boot-starter-test')

pom.xml

@@ -2,10 +2,16 @@
 <project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
   <modelVersion>4.0.0</modelVersion>
+  <parent>
+    <groupId>org.springframework.boot</groupId>
+    <artifactId>spring-boot-starter-parent</artifactId>
+    <version>2.4.0</version>
+  </parent>
   <groupId>com.badeling</groupId>
   <artifactId>msbot</artifactId>
   <version>0.0.1-SNAPSHOT</version>
   <inceptionYear>2014</inceptionYear>
+
   <licenses>
     <license>
       <name>The Apache Software License, Version 2.0</name>

src/main/java/com/badeling/msbot/MsbotApplication.java

@@ -6,12 +6,13 @@
 
 import com.badeling.msbot.domain.ReRead;
 
+import java.util.TimeZone;
 
 @SpringBootApplication
 @EnableConfigurationProperties({ReRead.class})
 public class MsbotApplication {
-
 	public static void main(String[] args) {
+		TimeZone.setDefault(TimeZone.getTimeZone("Asia/Shanghai"));
 		SpringApplication.run(MsbotApplication.class, args);
 	}
 

src/main/java/com/badeling/msbot/config/MsbotConst.java

@@ -1,14 +1,16 @@
 package com.badeling.msbot.config;
 
 public class MsbotConst {
-	
+
 	//go cqhttp本体
 	public static final String miraiUrl = "D:/go-cqhttp";
 	//go-cqhttp图片目录
 	public static final String imageUrl = miraiUrl + "/data/images/";
+	//go-cqhttp音频目录
+	public static final String voiceUrl = miraiUrl + "/data/voices/";
 	//机器人昵称
 	public static final String botName = "蠢猫";
-	//自己的昵称 
+	//自己的昵称
 	public static final String masterName = "BadeLing";
 	//机器人qq号
 	public static final String botId = "123456";
@@ -18,21 +20,24 @@ public class MsbotConst {
 	public static final String[] managerId = {"123","223"};
 	//拉黑的qq号
 	public static final String[] blackList = {"323","423"};
-
+
+	//魔女cd 单位秒
+	public static final int monv_cd = 120;
+
 	//第三方机器人 也就是上面登录的账号 允许发言的频道 QQ频道发一句话 然后后台查看频道id
 	//"channel_id":"1609899"
 	public static final String[] botChannel = {"1609899"};
-	
+
 	//茉莉机器人key
 	public static final String moliKey = "";
 	//茉莉机器人Secret
 	public static final String moliSecret = "";
-	
+
 	//茉莉机器人key 可以和上面填一样 一个是官方频道机器人用的 一个是上面登录的第三方机器人用的
 	public static final String moliKey2 = "";
 	//茉莉机器人Secret
 	public static final String moliSecret2 = "";
-	
+
 	//百度云识图Key 可不填 只影响 识图和起源39自动识别功能 原本的气象功能已废弃
 	//百度云识图 普通模式每天免费5w次 高精度模式每天免费500次
 	public static final String baiduKey = "";
@@ -43,7 +48,7 @@ public class MsbotConst {
 	//百度翻译key
 	public static final String securityKey="";
 
-	
+
 	//腾讯云key 这个可以不填 是为官方机器人用的 这个以后有条件再教
 	public static final String tencentSecretId = "";
 	//腾讯云Secret
@@ -52,10 +57,10 @@ public class MsbotConst {
 	public static final String bucketName = "image";
 	//存储桶地址
 	public static final String bucketRegion = "ap-chengdu";
-	
+
 	//QQ频道官方机器人
 	public static final String channelBotId = "123456";
 	//QQ频道官方机器人 昵称
 	public static final String channelBotName = "拉拉";
-	
-}
+
+}

src/main/java/com/badeling/msbot/controller/ApplicationRunnerImpl.java

@@ -1,22 +1,170 @@
 package com.badeling.msbot.controller;
 
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
 import java.util.TreeSet;
 
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
 import org.springframework.stereotype.Component;
 
 import com.badeling.msbot.domain.GlobalVariable;
+import com.badeling.msbot.domain.GroupMsg;
+import com.badeling.msbot.domain.Result;
+import com.badeling.msbot.entity.GroupInfo;
+import com.badeling.msbot.entity.GroupMember;
+import com.badeling.msbot.repository.GroupInfoRepository;
+import com.badeling.msbot.repository.GroupMemberRepository;
+import com.badeling.msbot.service.GroupMsgService;
 
 @Component
 public class ApplicationRunnerImpl implements ApplicationRunner{
 //public class ApplicationRunnerImpl{
-
+
+	@Autowired
+	GroupMsgService groupMsgService;
+
+	@Autowired
+	GroupInfoRepository groupInfoRepository;
+
+	@Autowired
+	GroupMemberRepository groupMemberRepository;
+
 	@Override
 	public void run(ApplicationArguments args) throws Exception {
 		TreeSet<String> msgList = new TreeSet<>();
 		GlobalVariable.setMsgList(msgList);
+		Map<String,Long> newFriendsList = new HashMap<>();
+		GlobalVariable.setNewFriendsMap(newFriendsList);
+		Map<String,Long> witchForestMap = new HashMap<>();
+		GlobalVariable.setWitchForestMap(witchForestMap);
+
+
 		System.out.println("初始程序执行完毕");
+
+		List<String> list = new ArrayList<String>();
+		//获取群列表
+		try {
+			Result<?> groupList = groupMsgService.getGroupList();
+
+			if(groupList.getStatus().equals("ok")) {
+				@SuppressWarnings("unchecked")
+				List<Map<String,Object>> data = (List<Map<String, Object>>) groupList.getData();
+				int countGroup = 0;
+				int addGroup = 0;
+				for(Map<String,Object> mapElement : data) {
+					GroupInfo groupInfo = new GroupInfo();
+					list.add(""+mapElement.get("group_id"));
+					String group_id = ""+mapElement.get("group_id");
+					String group_name = ""+mapElement.get("group_name");
+					String group_memo = ""+mapElement.get("group_memo");
+					GroupInfo findByGroupId = groupInfoRepository.findByGroupId(group_id);
+					if(findByGroupId==null) {
+						groupInfo.setGroup_id(group_id);
+						groupInfo.setGroup_name(group_name);
+						groupInfo.setGroup_memo(group_memo);
+						groupInfoRepository.save(groupInfo);
+						addGroup++;
+					}
+					countGroup++;
+				}
+				System.out.println("共获取"+countGroup+"个群，新增群聊"+addGroup+"个");
+			}
+		} catch (Exception e) {
+			// 获取群列表失败
+			e.printStackTrace();
+			System.out.println("获取群列表失败");
+		}
+
+
+		try {
+			//更新群成员信息
+			SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
+			int countAdd = 0;
+			int countModify = 0;
+			int countLeave = 0;
+			int countSame = 0;
+			Long startTime = System.currentTimeMillis();
+			List<GroupMember> addList = new ArrayList<GroupMember>();
+			for(String group_id : list) {
+				GroupMsg groupMsg = new GroupMsg();
+				groupMsg.setGroup_id(Long.parseLong(group_id));
+				Result<?> groupMemberList = groupMsgService.getGroupMember(groupMsg);
+				List<GroupMember> findGroupMemberList = groupMemberRepository.findGroupMemberByGroup(group_id);
+				Map<String,GroupMember> groupMemberMap = new HashMap<String, GroupMember>();
+				for(GroupMember groupMember : findGroupMemberList) {
+					groupMemberMap.put(groupMember.getUser_id(), groupMember);
+				}
+
+				@SuppressWarnings("unchecked")
+				List<Map<String,Object>> data = (List<Map<String, Object>>) groupMemberList.getData();
+				for(Map<String,Object> map : data) {
+					String user_id = String.valueOf(map.get("user_id"));
+					if(groupMemberMap.containsKey(user_id)) {
+						GroupMember groupMember = groupMemberMap.get(user_id);
+						groupMemberMap.remove(user_id);
+						String leave_time = groupMember.getLeave_time();
+						if(leave_time!=null&&!leave_time.isEmpty()) {
+							groupMemberRepository.modifyMemberLeaveTime(groupMember.getId(),"");
+						}
+						if(groupMember.getCard().equals(String.valueOf(map.get("card")))&&groupMember.getNickname().equals(String.valueOf(map.get("nickname")))) {
+							countSame++;
+							continue;
+						}else {
+							countModify++;
+							groupMemberRepository.modifyMemberInfo(groupMember.getId(), String.valueOf(map.get("nickname")), String.valueOf(map.get("card")), sdf.format(Long.parseLong(map.get("join_time")+"000")));
+						}
+					}else {
+						String time = sdf.format(Long.parseLong(map.get("join_time")+"000"));
+						GroupMember groupMember = new GroupMember();
+						groupMember.setCard(String.valueOf(map.get("card")));
+						groupMember.setGroup_id(group_id);
+						groupMember.setJoin_time(time);
+						groupMember.setLeave_time(null);
+						groupMember.setNickname(String.valueOf(map.get("nickname")));
+						groupMember.setUser_id(user_id);
+						addList.add(groupMember);
+						countAdd++;
+					}
+				}
+
+				if(!groupMemberMap.isEmpty()) {
+					String time = sdf.format(System.currentTimeMillis());
+					for(String temp : groupMemberMap.keySet()) {
+						GroupMember groupMember = groupMemberMap.get(temp);
+						if(groupMember.getLeave_time()==null||groupMember.getLeave_time().isEmpty()) {
+							groupMemberRepository.modifyMemberLeaveTime(groupMember.getId(), time);
+							countLeave++;
+							continue;
+						}
+						try {
+							if(Integer.parseInt(groupMember.getJoin_time())>Integer.parseInt(groupMember.getLeave_time())) {
+								groupMemberRepository.modifyMemberLeaveTime(groupMember.getId(), time);
+								countLeave++;
+								continue;
+							}
+						} catch (Exception e) {
+							System.out.println("统计减少人数时出错:"+groupMember.toString());
+						}
+					}
+				}
+
+				if(addList.size()>0) {
+					groupMemberRepository.saveAll(addList);
+				}
+			}
+			System.out.println("更新群成员信息成功:新增"+countAdd+"人，更新"+countModify+"人，离开"+countLeave+"人，保持"+countSame+"人，耗时"+((startTime-System.currentTimeMillis())/1000)+"ms");
+		} catch (Exception e) {
+			e.printStackTrace();
+			System.out.println("更新群成员信息失败");
+		}
+
+
+
 	}
 
-}
+}