Compare commits

..

No commits in common. "af54377bb263880b4b1dfc74b55e77c24bbe3e82" and "08bbd247a4e16d3c82e958d00a613ea8fff69be3" have entirely different histories.

2 changed files with 35 additions and 68 deletions

View File

@ -6,7 +6,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication @SpringBootApplication
public class QQBotApplication { public class QQBotApplication {
public static final String version="QQBot v.1.3.2"; public static final String version="QQBot v.1.3.1";
public static void main(String[] args) { public static void main(String[] args) {
System.out.println("version = " + version); System.out.println("version = " + version);
SpringApplication.run(QQBotApplication.class, args); SpringApplication.run(QQBotApplication.class, args);

View File

@ -14,7 +14,6 @@ import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.io.InputStreamReader; import java.io.InputStreamReader;
import java.util.HashSet; import java.util.HashSet;
import java.util.Map;
import java.util.Properties; import java.util.Properties;
import java.util.Set; import java.util.Set;
@ -25,7 +24,7 @@ public class RedisTools {
private static String host; private static String host;
private static int port; private static int port;
public static int TOKEN_TIMEOUT_DEFAULT = 360; public static int TOKEN_TIMEOUT_DEFAULT = 360;
public final static int DATABASES_ALI_OSS = 4; public final static int DATABASES_ALI_OSS=4;
private RedisTools() { private RedisTools() {
@ -58,13 +57,13 @@ public class RedisTools {
return true; return true;
} }
public static boolean set(String key, String value, long timeout, int db) { public static boolean set (String key,String value, long timeout,int db){
try { try {
if (isNotInstallRedis) { if (isNotInstallRedis) {
return false; return false;
} }
Jedis jedis = getRedis(); Jedis jedis = getRedis();
if (db > -1) { if(db>-1){
jedis.select(db); jedis.select(db);
} }
if (timeout == -1) { if (timeout == -1) {
@ -82,11 +81,11 @@ public class RedisTools {
} }
public static boolean set(Object key, String value) { public static boolean set(Object key, String value) {
return set(QQBOT_USER, key + "", value); return set(QQBOT_USER, key+"", value);
} }
public static boolean set(String key, String value, long timeout) { public static boolean set(String key, String value, long timeout) {
return set(key, value, timeout, QQBOT_USER); return set(key, value, timeout,QQBOT_USER);
} }
public static String get(String key, int dbIndex) { public static String get(String key, int dbIndex) {
@ -106,19 +105,19 @@ public class RedisTools {
} }
public static String get(Object key) { public static String get(Object key) {
return get(key + "", QQBOT_USER); return get(key+"", QQBOT_USER);
} }
public static String get(Object key, String defValue) { public static String get(Object key,String defValue){
String ret = get(key); String ret=get(key);
if (StringUtils.isEmpty(ret)) { if(StringUtils.isEmpty(ret)){
return defValue; return defValue;
} }
return ret; return ret;
} }
public static boolean remove(String key) { public static boolean remove(String key) {
return remove(key, QQBOT_USER); return remove(key,QQBOT_USER);
} }
public static void removeLoginState(String uid) { public static void removeLoginState(String uid) {
@ -138,22 +137,20 @@ public class RedisTools {
jedis.close(); jedis.close();
return tmp; return tmp;
} }
public static boolean exists(Object key,String value){
public static boolean exists(Object key, String value) { return exists(QQBOT_USER,key,value);
return exists(QQBOT_USER, key, value);
} }
public static boolean exists(int db,Object key, String value) {
public static boolean exists(int db, Object key, String value) {
if (isNotInstallRedis) { if (isNotInstallRedis) {
return false; return false;
} }
Jedis jedis = getRedis(); Jedis jedis = getRedis();
jedis.select(db); jedis.select(db);
boolean flag = false; boolean flag=false;
if (value == null) { if(value==null){
flag = jedis.exists(key + ""); flag= jedis.exists(key+"");
} else { }else {
flag = value.equals(jedis.get(key + "")); flag = value.equals(jedis.get(key+""));
} }
jedis.close(); jedis.close();
return flag; return flag;
@ -188,45 +185,13 @@ public class RedisTools {
public static boolean list_isExist(String listName, String value) { public static boolean list_isExist(String listName, String value) {
Jedis jedis = getRedis(); Jedis jedis = getRedis();
jedis.select(QQBOT_USER);
boolean flag = jedis.sismember(listName, value); boolean flag = jedis.sismember(listName, value);
jedis.close(); jedis.close();
return flag; return flag;
} }
public static String getHashMap(String hashKey, String key) {
Jedis jedis = getRedis();
return jedis.hget(hashKey, key);
}
public static Map<String, String> getHashMap(String hashKey) {
return getRedis().hgetAll(hashKey);
}
public static boolean setHashMap(String hashKey, String key, String value) {
Jedis jedis = getRedis();
long l = jedis.hsetnx(hashKey, key, value);
jedis.close();
return l > 0;
}
public static boolean removeHashMap(String hashKey, String key) {
Jedis jedis = getRedis();
long l = jedis.hdel(hashKey, key);
jedis.close();
return l > 0;
}
public static boolean removeHashMap(String hashKey) {
Jedis jedis = getRedis();
long del = jedis.del(hashKey);
return del > 0;
}
public static Jedis getRedis() { public static Jedis getRedis() {
Jedis jedis = new Jedis(host, port); return new Jedis(host, port);
jedis.select(QQBOT_USER);
return jedis;
} }
public static boolean remove(String key, int index) { public static boolean remove(String key, int index) {
@ -235,9 +200,13 @@ public class RedisTools {
} }
Jedis jedis = getRedis(); Jedis jedis = getRedis();
jedis.select(index); jedis.select(index);
long i = jedis.del(key); Long i = jedis.del(key);
jedis.close(); jedis.close();
return i > 0; if (i > 0) {
return true;
} else {
return false;
}
} }
private static class PropertyUtil { private static class PropertyUtil {
@ -318,7 +287,7 @@ public class RedisTools {
system("cmd", message); system("cmd", message);
break; break;
case "msg": case "msg":
AppTools.sendServer("来自服务姬的通知~", message); AppTools.sendServer("来自服务姬的通知~",message);
break; break;
} }
} }
@ -355,6 +324,7 @@ public class RedisTools {
} }
public static void bot(String value) { public static void bot(String value) {
switch (value) { switch (value) {
case "getip": case "getip":
@ -365,12 +335,10 @@ public class RedisTools {
} }
} }
} }
public static void processOut(InputStream inputStream) { public static void processOut(InputStream inputStream) {
processOut(inputStream, null, true); processOut(inputStream,null,true);
} }
public static void processOut(InputStream inputStream, ObjectInterface objectInterface, boolean isOutQQBot){
public static void processOut(InputStream inputStream, ObjectInterface objectInterface, boolean isOutQQBot) {
String tmp; String tmp;
StringBuilder str = new StringBuilder(); StringBuilder str = new StringBuilder();
try { try {
@ -383,15 +351,14 @@ public class RedisTools {
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} }
if (objectInterface != null) { if(objectInterface!=null){
objectInterface.out(str.toString()); objectInterface.out(str.toString());
} }
// Log.i("cmd > " + str); // Log.i("cmd > " + str);
if (isOutQQBot) { if(isOutQQBot) {
QQBotManager.getInstance().sendMessage(str.toString()); QQBotManager.getInstance().sendMessage(str.toString());
} }
} }
public static void main(String[] args) { public static void main(String[] args) {
RedisTools.pullMsg("msg", "abc"); RedisTools.pullMsg("msg", "abc");
} }