You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
94 lines
3.4 KiB
94 lines
3.4 KiB
package com.fr.plugin.db.redis.util; |
|
|
|
import com.eclipsesource.v8.V8Object; |
|
import com.fanruan.api.cal.ParameterKit; |
|
import com.fanruan.api.util.ArrayKit; |
|
import com.fanruan.api.util.GeneralKit; |
|
import com.fanruan.api.util.RenderKit; |
|
import com.fanruan.api.util.StringKit; |
|
import com.fr.json.JSONArray; |
|
import com.fr.plugin.db.redis.core.order.OrderValue; |
|
import com.fr.plugin.db.redis.help.ScriptBridge; |
|
import com.fr.stable.ParameterProvider; |
|
import redis.clients.jedis.Jedis; |
|
|
|
import java.lang.reflect.InvocationTargetException; |
|
import java.lang.reflect.Method; |
|
import java.util.HashMap; |
|
import java.util.Map; |
|
|
|
/** |
|
* @author richie |
|
* @version 10.0 |
|
* Created by richie on 2019-03-18 |
|
*/ |
|
public class RedisUtils { |
|
|
|
/** |
|
* 关闭redis客户端 |
|
* |
|
* @param jedis redis客户端对象 |
|
*/ |
|
public static void close(Jedis jedis) { |
|
jedis.close(); |
|
} |
|
|
|
public static String calculateQuery(String query, ParameterProvider[] ps) { |
|
if (ArrayKit.isEmpty(ps)) { |
|
return query; |
|
} |
|
Map<String, Object> map = new HashMap<String, Object>(); |
|
for (ParameterProvider p : ps) { |
|
map.put(p.getName(), p.getValue()); |
|
} |
|
try { |
|
return RenderKit.renderParameter4Tpl(query, map); |
|
} catch (Exception e) { |
|
return query; |
|
} |
|
} |
|
|
|
public static void registerJavaMethods(V8Object v8Object, Object target) { |
|
Method[] methods = target.getClass().getMethods(); |
|
for (Method m : methods) { |
|
if (m.getAnnotation(ScriptBridge.class) != null) { |
|
v8Object.registerJavaMethod(target, m.getName(), m.getName(), m.getParameterTypes()); |
|
} |
|
} |
|
} |
|
|
|
public static String getName(Object target) { |
|
if (target == null) { |
|
return StringKit.EMPTY; |
|
} |
|
try { |
|
Method method = target.getClass().getMethod("getName"); |
|
return GeneralKit.objectToString(method.invoke(target)); |
|
} catch (NoSuchMethodException e) { |
|
return StringKit.EMPTY; |
|
} catch (IllegalAccessException e) { |
|
return StringKit.EMPTY; |
|
} catch (InvocationTargetException e) { |
|
return StringKit.EMPTY; |
|
} |
|
} |
|
|
|
public static ParameterProvider[] analyzeParameter(JSONArray existParameters, OrderValue orderValue, String... parameterTexts) { |
|
ParameterProvider[] oldParameters = new ParameterProvider[existParameters.size()]; |
|
for (int i = 0; i < existParameters.size(); i++) { |
|
oldParameters[i] = ParameterKit.json2Parameter(existParameters.getJSONObject(i)); |
|
} |
|
ParameterProvider[] newParameters = ParameterKit.analyzeAndUnionSameParameters(parameterTexts, oldParameters); |
|
ParameterProvider[] newOrderParameters = orderValue.analyze4Parameters(); |
|
Map<String, ParameterProvider> parameterProviderMap = new HashMap<String, ParameterProvider>(); |
|
for (ParameterProvider parameterProvider : oldParameters) { |
|
parameterProviderMap.put(parameterProvider.getName(), parameterProvider); |
|
} |
|
for (ParameterProvider parameterProvider : newOrderParameters) { |
|
if (parameterProviderMap.containsKey(parameterProvider.getName())) { |
|
parameterProvider.setValue(parameterProviderMap.get(parameterProvider.getName()).getValue()); |
|
} |
|
} |
|
return ArrayKit.addAll(newParameters, newOrderParameters); |
|
} |
|
}
|
|
|