Commit e4268f8b authored by litengwei's avatar litengwei

稳压泵统计问题修改

parent e47aa31e
...@@ -71,19 +71,22 @@ public class PluginInterceptor implements Interceptor { ...@@ -71,19 +71,22 @@ public class PluginInterceptor implements Interceptor {
par = (HashMap) ((HashMap<?, ?>) parameter).get("map"); par = (HashMap) ((HashMap<?, ?>) parameter).get("map");
} }
LinkedHashMap<String, String> fieldsValue = (LinkedHashMap<String, String>) par.get("fieldsValue"); try {
Iterator<String> iterator = fieldsValue.keySet().stream().iterator(); LinkedHashMap<String, String> fieldsValue = (LinkedHashMap<String, String>) par.get("fieldsValue");
Iterator<String> iterator = fieldsValue.keySet().stream().iterator();
while (iterator.hasNext()) {
String next = iterator.next(); while (iterator.hasNext()) {
sql = sql.replaceFirst("item", next).replaceFirst("ietmValue", new StringBuffer().append("'").append(fieldsValue.get(next)).append("'").toString()); String next = iterator.next();
sql = sql.replaceFirst("item", next).replaceFirst("ietmValue", new StringBuffer().append("'").append(fieldsValue.get(next)).append("'").toString());
}
//通过反射修改sql语句
Field field = boundSql.getClass().getDeclaredField("sql");
ReflectionUtils.makeAccessible(field);
field.set(boundSql, sql);
return executor.query(mappedStatement, parameter, rowBounds, resultHandler, cacheKey, boundSql);
} catch (Exception e) {
return executor.query(mappedStatement, parameter, rowBounds, resultHandler, cacheKey, boundSql);
} }
//通过反射修改sql语句
Field field = boundSql.getClass().getDeclaredField("sql");
ReflectionUtils.makeAccessible(field);
field.set(boundSql, sql);
return executor.query(mappedStatement, parameter, rowBounds, resultHandler, cacheKey, boundSql);
} else if ("com.yeejoin.amos.boot.module.common.api.mapper.DynamicFormInstanceMapper.listAll".equals(id) || } else if ("com.yeejoin.amos.boot.module.common.api.mapper.DynamicFormInstanceMapper.listAll".equals(id) ||
"com.yeejoin.amos.boot.module.common.api.mapper.DynamicFormInstanceMapper.listOneDayDutyPerson".equals(id) || "com.yeejoin.amos.boot.module.common.api.mapper.DynamicFormInstanceMapper.listOneDayDutyPerson".equals(id) ||
"com.yeejoin.amos.boot.module.common.api.mapper.DynamicFormInstanceMapper.pageList".equals(id)) { "com.yeejoin.amos.boot.module.common.api.mapper.DynamicFormInstanceMapper.pageList".equals(id)) {
......
...@@ -142,7 +142,7 @@ public class PressurePumpServiceImpl implements IPressurePumpService { ...@@ -142,7 +142,7 @@ public class PressurePumpServiceImpl implements IPressurePumpService {
try { try {
Date date = DateUtils.convertStrToDate(time, DateUtils.DATE_PATTERN); Date date = DateUtils.convertStrToDate(time, DateUtils.DATE_PATTERN);
// 结束日期不包含今天,获取3天前数据 // 结束日期不包含今天,获取3天前数据
if (DateUtils.dateCompare(date, startDate) >= 0 && DateUtils.dateCompare(endDate, date) > 0) { if (DateUtils.dateCompare(date, startDate) >= 0 && DateUtils.dateCompare(endDate, date) >= 0) {
list.add(JSON.parseObject(redisUtils.get(x).toString(), PressurePumpCountVo.class)); list.add(JSON.parseObject(redisUtils.get(x).toString(), PressurePumpCountVo.class));
} }
} catch (ParseException e) { } catch (ParseException e) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment