From b6949a31464f2ca4e790affd467dcfc511223ba2 Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: 星期三, 05 四月 2023 23:56:00 +0800
Subject: [PATCH] 优化交费 -- 加入收银员功能
---
java110-db/src/main/java/com/java110/db/Java110MybatisInterceptor.java | 432 +++++++++++++++++++++++++++++++++++++++++++----------
1 files changed, 350 insertions(+), 82 deletions(-)
diff --git a/java110-db/src/main/java/com/java110/db/Java110MybatisInterceptor.java b/java110-db/src/main/java/com/java110/db/Java110MybatisInterceptor.java
old mode 100644
new mode 100755
index 9c9a549..c32f4f0
--- a/java110-db/src/main/java/com/java110/db/Java110MybatisInterceptor.java
+++ b/java110-db/src/main/java/com/java110/db/Java110MybatisInterceptor.java
@@ -1,82 +1,274 @@
package com.java110.db;
-import org.apache.commons.collections4.CollectionUtils;
-import org.apache.ibatis.executor.statement.StatementHandler;
-import org.apache.ibatis.mapping.MappedStatement;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.client.RestTemplate;
+import com.java110.core.context.Environment;
+import com.java110.core.factory.Java110TransactionalFactory;
+import com.java110.db.dao.IQueryServiceDAO;
+import com.java110.dto.order.OrderItemDto;
+import com.java110.utils.constant.ServiceConstant;
+import com.java110.utils.factory.ApplicationContextFactory;
+import com.java110.utils.util.DateUtil;
+import com.java110.utils.util.StringUtil;
+import org.apache.ibatis.executor.Executor;
+import org.apache.ibatis.mapping.*;
import org.apache.ibatis.plugin.*;
import org.apache.ibatis.reflection.MetaObject;
-import org.apache.ibatis.reflection.SystemMetaObject;
+import org.apache.ibatis.session.Configuration;
+import org.apache.ibatis.type.TypeHandlerRegistry;
import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.stereotype.Component;
+import com.java110.core.log.LoggerFactory;
+import org.springframework.http.*;
-import java.beans.Statement;
-import java.lang.reflect.Proxy;
+import java.sql.Timestamp;
+import java.text.DateFormat;
import java.util.*;
@Intercepts({
- @Signature(type = StatementHandler.class, method = "update", args = {Statement.class}),
- @Signature(type = StatementHandler.class, method = "query", args = {Statement.class}),
- @Signature(type = StatementHandler.class, method = "batch", args = {Statement.class})
+ @Signature(type = Executor.class, method = "update", args = {MappedStatement.class,
+ Object.class})
})
-
public class Java110MybatisInterceptor implements Interceptor {
private static Logger logger = LoggerFactory.getLogger(Java110MybatisInterceptor.class);
+ IQueryServiceDAO queryServiceDAOImpl;
+ RestTemplate restTemplate;
+
@Override
public Object intercept(Invocation invocation) throws Throwable {
- Statement statement;
- //鑾峰彇鏂规硶鍙傛暟
- Object firstArg = invocation.getArgs()[0];
- if (Proxy.isProxyClass(firstArg.getClass())) {
- statement = (Statement) SystemMetaObject.forObject(firstArg).getValue("h.statement");
- } else {
- statement = (Statement) firstArg;
+ if (StringUtil.isEmpty(Java110TransactionalFactory.getOId())) { //鏈紑鍚簨鍔�
+ return invocation.proceed();
}
- MetaObject stmtMetaObj = SystemMetaObject.forObject(statement);
- //鑾峰彇Statement瀵硅薄锛坰ql璇硶宸茬粡鏋勫缓瀹屾瘯锛�
- statement = (Statement) stmtMetaObj.getValue("stmt.statement");
+ MappedStatement mappedStatement = (MappedStatement) invocation.getArgs()[0];
+ SqlCommandType sqlCommandType = mappedStatement.getSqlCommandType();
+ Object parameter = null;
+ if (invocation.getArgs().length > 1) {
+ parameter = invocation.getArgs()[1];
+ }
+
+ BoundSql boundSql = mappedStatement.getBoundSql(parameter);
+ Configuration configuration = mappedStatement.getConfiguration();
+ Map<String, Object> sqlValue = new HashMap<>();
//鑾峰彇sql璇彞
- String originalSql = statement.toString();
+ String sql = showSql(configuration, boundSql, sqlValue, sqlCommandType);
+ if(Environment.isStartBootWay()){
+ restTemplate = ApplicationContextFactory.getBean("outRestTemplate", RestTemplate.class);
+ }else {
+ restTemplate = ApplicationContextFactory.getBean("restTemplate", RestTemplate.class);
+ }
+ switch (sqlCommandType) {
+ case INSERT:
+ dealInsertSql(mappedStatement, parameter, sql, sqlValue);
+ break;
+ case UPDATE:
+ dealUpdateSql(mappedStatement, parameter, sql, sqlValue);
+ break;
+ case DELETE:
+ dealDeleteSql(mappedStatement, parameter, sql, sqlValue);
+ break;
+ }
+ return invocation.proceed();
+ }
- //灏嗗師濮媠ql涓殑绌虹櫧瀛楃锛圽s鍖呮嫭鎹㈣绗︼紝鍒惰〃绗︼紝绌烘牸绗︼級鏇挎崲涓�" "
- originalSql = originalSql.replaceAll("[\\s]+", " ");
+ /**
+ * 澶勭悊鍒犻櫎sql
+ *
+ * @param mappedStatement
+ * @param parameter
+ */
+ private void dealDeleteSql(MappedStatement mappedStatement, Object parameter, String sql, Map<String, Object> sqlValue) {
- //鍙幏鍙杝ql鐨剆elect/update/insert/delete寮�澶寸殑sql
- int index = indexOfSqlStart(originalSql);
- if (index > 0) {
- originalSql = originalSql.substring(index);
+ String tmpTable = sql.substring(sql.indexOf("from") + 4, sql.indexOf("where")).trim();
+ String tmpTableHasT = tmpTable;
+ if(tmpTable.indexOf(" ") > 0){
+ tmpTable = tmpTable.substring(0,tmpTable.indexOf(" "));
+ }
+ String tmpWhere = sql.substring(sql.indexOf("where"));
+ //鎻掑叆鎿嶄綔鏃朵箣鍓嶇殑 娌℃湁鏁版嵁 鎵�浠� preValue 涓虹┖瀵硅薄
+ JSONArray preValues = new JSONArray();
+
+ String execSql = "select * from " + tmpTableHasT + " " + tmpWhere;
+
+ queryServiceDAOImpl = ApplicationContextFactory.getBean("queryServiceDAOImpl", IQueryServiceDAO.class);
+ List<Map<String, Object>> deleteDatas = queryServiceDAOImpl.executeSql(execSql, null);
+
+ if (deleteDatas != null && deleteDatas.size() > 0) {
+ for (Map<String, Object> map : deleteDatas) {
+ dealReturnMap(map);
+ preValues.add(map);
+ }
}
- // 璁＄畻鎵ц SQL 鑰楁椂
- long start = System.currentTimeMillis();
- Object result = invocation.proceed();
- long timing = System.currentTimeMillis() - start;
+ JSONArray afterValues = new JSONArray();
- //鑾峰彇MapperStatement瀵硅薄锛岃幏鍙栧埌sql鐨勮缁嗕俊鎭�
- Object realTarget = realTarget(invocation.getTarget());
- //鑾峰彇metaObject瀵硅薄
- MetaObject metaObject = SystemMetaObject.forObject(realTarget);
- //鑾峰彇MappedStatement瀵硅薄
- MappedStatement ms = (MappedStatement) metaObject.getValue("delegate.mappedStatement");
- StringBuilder formatSql = new StringBuilder()
- .append(" Time锛�").append(timing)
- //鑾峰彇Mapper淇℃伅鍜屾柟娉曚俊鎭�
- .append(" ms - ID锛�").append(ms.getId())
- .append("Execute SQL锛�")
- .append(originalSql);
- //鎵撳嵃sql淇℃伅
- logger.debug(formatSql.toString());
- return result;
+ JSONObject logText = new JSONObject();
+ logText.put("preValue", preValues);
+ logText.put("afterValue", afterValues);
+
+ OrderItemDto orderItemDto = new OrderItemDto();
+ orderItemDto.setbId("-1");
+ orderItemDto.setAction("DEL");
+ orderItemDto.setActionObj(tmpTable.trim());
+ orderItemDto.setLogText(logText.toJSONString());
+ orderItemDto.setServiceName(ApplicationContextFactory.getApplicationName());
+ orderItemDto.setoId(Java110TransactionalFactory.getOId());
+
+ String url = ServiceConstant.SERVICE_ORDER_URL + "/order/oIdApi/createOrderItem";
+ HttpHeaders httpHeaders = new HttpHeaders();
+ HttpEntity httpEntity = new HttpEntity(orderItemDto.toString(), httpHeaders);
+ if(Environment.isStartBootWay()){
+ url = ServiceConstant.BOOT_SERVICE_ORDER_URL + "/order/oIdApi/createOrderItem";
+ }
+ ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
+
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ throw new IllegalArgumentException("娉ㄥ唽浜嬪姟鍥炴粴鏃ュ織澶辫触" + responseEntity);
+ }
}
+
+ /**
+ * 澶勭悊淇敼 sql
+ *
+ * @param mappedStatement
+ * @param parameter
+ */
+ private void dealUpdateSql(MappedStatement mappedStatement, Object parameter, String sql, Map<String, Object> sqlValue) {
+ //RestTemplate restTemplate = ApplicationContextFactory.getBean("restTemplate", RestTemplate.class);
+
+ String tmpTable = sql.substring(sql.indexOf("update") + 6, sql.indexOf("set ")).trim();
+
+ String tmpTableHasT = tmpTable;
+
+ if(tmpTable.indexOf(" ") > 0){
+ tmpTable = tmpTable.substring(0,tmpTable.indexOf(" "));
+ }
+ String tmpWhere = sql.substring(sql.indexOf("where"));
+
+ //鎻掑叆鎿嶄綔鏃朵箣鍓嶇殑 娌℃湁鏁版嵁 鎵�浠� preValue 涓虹┖瀵硅薄
+ JSONArray preValues = new JSONArray();
+ JSONArray afterValues = new JSONArray();
+ JSONObject afterVaule = null;
+ String execSql = "select * from " + tmpTableHasT + " " + tmpWhere;
+ queryServiceDAOImpl = ApplicationContextFactory.getBean("queryServiceDAOImpl", IQueryServiceDAO.class);
+ List<Map<String, Object>> deleteDatas = queryServiceDAOImpl.executeSql(execSql, null);
+
+ if (deleteDatas != null && deleteDatas.size() > 0) {
+ for (Map<String, Object> map : deleteDatas) {
+ dealReturnMap(map);
+ preValues.add(map);
+ afterVaule = new JSONObject();
+ afterVaule.putAll(map);
+ afterVaule.putAll(sqlValue);
+ afterValues.add(afterVaule);
+ }
+ }
+
+ JSONObject logText = new JSONObject();
+ logText.put("preValue", preValues);
+ logText.put("afterValue", afterValues);
+
+ OrderItemDto orderItemDto = new OrderItemDto();
+ orderItemDto.setbId("-1");
+ orderItemDto.setAction("MOD");
+ orderItemDto.setActionObj(tmpTable.trim());
+ orderItemDto.setLogText(logText.toJSONString());
+ orderItemDto.setServiceName(ApplicationContextFactory.getApplicationName());
+ orderItemDto.setoId(Java110TransactionalFactory.getOId());
+
+ String url = ServiceConstant.SERVICE_ORDER_URL + "/order/oIdApi/createOrderItem";
+ HttpHeaders httpHeaders = new HttpHeaders();
+ HttpEntity httpEntity = new HttpEntity(orderItemDto.toString(), httpHeaders);
+ ResponseEntity<String> responseEntity = null;
+ if(Environment.isStartBootWay()){
+ url = ServiceConstant.BOOT_SERVICE_ORDER_URL + "/order/oIdApi/createOrderItem";
+ }
+ responseEntity = restTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
+
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ throw new IllegalArgumentException("娉ㄥ唽浜嬪姟鍥炴粴鏃ュ織澶辫触" + responseEntity);
+ }
+ }
+
+ private void dealReturnMap(Map<String, Object> map) {
+ for (String key : map.keySet()) {
+ Object value = map.get(key);
+ if (value instanceof String) {
+ map.put(key, "'" + map.get(key) + "'");
+ } else if (value instanceof Date) {
+ String tmpValue = DateUtil.getFormatTimeString((Date) value, DateUtil.DATE_FORMATE_STRING_A);
+ map.put(key, "'" + tmpValue + "'");
+ } else if (value instanceof Timestamp) {
+ Date date = new Date(((Timestamp) value).getTime());
+ String tmpValue = DateUtil.getFormatTimeString(date, DateUtil.DATE_FORMATE_STRING_A);
+ map.put(key, "'" + tmpValue + "'");
+ } else if (value instanceof Double) {
+ map.put(key, "'" + map.get(key) + "'");
+ } else {
+ if (value != null) {
+ map.put(key, "'" + value.toString() + "'");
+ } else {
+ map.put(key, "''");
+ }
+ }
+ }
+ }
+
+ /**
+ * 澶勭悊insert 璇彞
+ *
+ * @param mappedStatement
+ * @param parameter
+ */
+ private void dealInsertSql(MappedStatement mappedStatement, Object parameter, String sql, Map<String, Object> sqlValue) {
+
+ // RestTemplate restTemplate = ApplicationContextFactory.getBean("restTemplate", RestTemplate.class);
+
+ //鎻掑叆鎿嶄綔鏃朵箣鍓嶇殑 娌℃湁鏁版嵁 鎵�浠� preValue 涓虹┖瀵硅薄
+ JSONArray preValues = new JSONArray();
+
+ JSONArray afterValues = new JSONArray();
+
+ String tmpTable = sql.substring(sql.toLowerCase().indexOf("into") + 4, sql.indexOf("(")).trim();
+
+ if(tmpTable.indexOf(" ") > 0){
+ tmpTable = tmpTable.substring(0,tmpTable.indexOf(" "));
+ }
+
+ afterValues.add(sqlValue);
+
+ JSONObject logText = new JSONObject();
+ logText.put("preValue", preValues);
+ logText.put("afterValue", afterValues);
+
+ OrderItemDto orderItemDto = new OrderItemDto();
+ orderItemDto.setbId("-1");
+ orderItemDto.setAction("ADD");
+ orderItemDto.setActionObj(tmpTable.trim());
+ orderItemDto.setLogText(logText.toJSONString());
+ orderItemDto.setServiceName(ApplicationContextFactory.getApplicationName());
+ orderItemDto.setoId(Java110TransactionalFactory.getOId());
+
+ String url = ServiceConstant.SERVICE_ORDER_URL + "/order/oIdApi/createOrderItem";
+ HttpHeaders httpHeaders = new HttpHeaders();
+ HttpEntity httpEntity = new HttpEntity(orderItemDto.toString(), httpHeaders);
+ if(Environment.isStartBootWay()){
+ url = ServiceConstant.BOOT_SERVICE_ORDER_URL + "/order/oIdApi/createOrderItem";
+ }
+ ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
+
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ throw new IllegalArgumentException("娉ㄥ唽浜嬪姟鍥炴粴鏃ュ織澶辫触" + responseEntity);
+ }
+
+ }
+
@Override
public Object plugin(Object target) {
- if (target instanceof StatementHandler) {
- return Plugin.wrap(target, this);
- }
- return target;
+ return Plugin.wrap(target, this);
+
}
@Override
@@ -84,39 +276,115 @@
}
- /**
- * 鑾峰彇sql璇彞寮�澶撮儴鍒�
- *
- * @param sql
- * @return
- */
- private int indexOfSqlStart(String sql) {
- String upperCaseSql = sql.toUpperCase();
- Set<Integer> set = new HashSet<>();
- set.add(upperCaseSql.indexOf("SELECT "));
- set.add(upperCaseSql.indexOf("UPDATE "));
- set.add(upperCaseSql.indexOf("INSERT "));
- set.add(upperCaseSql.indexOf("DELETE "));
- set.remove(-1);
- if (CollectionUtils.isEmpty(set)) {
- return -1;
+ public String showSql(Configuration configuration, BoundSql boundSql, Map<String, Object> sqlValue, SqlCommandType sqlCommandType) {
+ Object parameterObject = boundSql.getParameterObject();
+ List<ParameterMapping> parameterMappings = boundSql.getParameterMappings();
+ String sql = boundSql.getSql().replaceAll("[\\s]+", " ").toLowerCase();
+ String orgSql = sql;// 鍘熷sql
+
+ List<String> values = new ArrayList<>();
+ if (parameterMappings.size() > 0 && parameterObject != null) {
+ TypeHandlerRegistry typeHandlerRegistry = configuration.getTypeHandlerRegistry();
+ if (typeHandlerRegistry.hasTypeHandler(parameterObject.getClass())) {
+ sql = sql.replaceFirst("\\?", getParameterValue(parameterObject));
+ values.add(getParameterValue(parameterObject));
+ } else {
+ MetaObject metaObject = configuration.newMetaObject(parameterObject);
+ for (ParameterMapping parameterMapping : parameterMappings) {
+ String propertyName = parameterMapping.getProperty();
+ if (metaObject.hasGetter(propertyName)) {
+ Object obj = metaObject.getValue(propertyName);
+ String value = getParameterValue(obj);
+ if(value.contains("${")){
+ value = value.replace("${","\\${");
+ }
+ sql = sql.replaceFirst("\\?", value);
+ values.add(getParameterValue(obj));
+ } else if (boundSql.hasAdditionalParameter(propertyName)) {
+ Object obj = boundSql.getAdditionalParameter(propertyName);
+ sql = sql.replaceFirst("\\?", getParameterValue(obj));
+ values.add(getParameterValue(obj));
+ }
+ }
+ }
}
- List<Integer> list = new ArrayList<>(set);
- list.sort(Comparator.naturalOrder());
- return list.get(0);
+
+ if (sqlCommandType == SqlCommandType.INSERT) {
+ String tmpKey = orgSql.substring(orgSql.indexOf("(") + 1, orgSql.indexOf(")"));
+ String[] tmpKeys = tmpKey.split(",");
+
+// if (values.size() < tmpKeys.length) {
+// throw new IllegalArgumentException("sql 閿欒 key P鍜寁alue 涓暟涓嶇瓑" + sql);
+// }
+ for (int keyIndex = 0; keyIndex < tmpKeys.length; keyIndex++) {
+ String key = tmpKeys[keyIndex].trim();
+ String value = "";
+ if (values.size() - 1 < keyIndex) {
+ continue;
+ }
+ value = values.get(keyIndex);
+ if ("''".equals(value)) {
+ continue;
+ }
+ sqlValue.put(key, value);
+ }
+ } else if (sqlCommandType == SqlCommandType.UPDATE) {
+ String tmpKey = orgSql.substring(sql.indexOf("set") + 3, orgSql.indexOf("where"));
+ String[] tmpKeys = tmpKey.split(",");
+// if (values.size() < tmpKeys.length) {
+// throw new IllegalArgumentException("sql 閿欒 key 鍜寁alue 涓暟涓嶇瓑" + sql);
+// }
+ for (int keyIndex = 0; keyIndex < tmpKeys.length; keyIndex++) {
+ String tmpSetKey = tmpKeys[keyIndex];
+ String[] keyValues = tmpSetKey.split("=");
+ String key = "";
+ if (keyValues.length != 2) {
+ throw new IllegalArgumentException("update 璇彞鍙兘鏈夐棶棰橈紝娌℃湁 set 涓嚭閿� " + sql);
+ }
+ if (keyValues[0].contains(".")) {
+ key = keyValues[0].substring(keyValues[0].indexOf(".") + 1).trim();
+ } else {
+ key = keyValues[0].trim();
+ }
+ String value = "";
+ if (values.size() - 1 < keyIndex) {
+ continue;
+ }
+ value = values.get(keyIndex);
+ if ("''".equals(value)) {
+ continue;
+ }
+ sqlValue.put(key, value);
+ }
+
+ } else if (sqlCommandType == SqlCommandType.DELETE) {
+
+ }
+
+
+ return sql;
}
- /**
- * <p>
- * 鑾峰緱鐪熸鐨勫鐞嗗璞�,鍙兘澶氬眰浠ｇ悊.
- * </p>
- */
- @SuppressWarnings("unchecked")
- public static <T> T realTarget(Object target) {
- if (Proxy.isProxyClass(target.getClass())) {
- MetaObject metaObject = SystemMetaObject.forObject(target);
- return realTarget(metaObject.getValue("h.target"));
+
+ private String getParameterValue(Object obj) {
+ String value = null;
+ if (obj instanceof String) {
+ value = "'" + obj.toString() + "'";
+ } else if (obj instanceof Date) {
+ DateFormat formatter = DateFormat.getDateTimeInstance(DateFormat.DEFAULT, DateFormat.DEFAULT, Locale.CHINA);
+ value = "'" + formatter.format(obj) + "'";
+// System.out.println(value);
+ } else {
+ if (obj != null) {
+ value = obj.toString();
+ } else {
+ value = "''";
+ }
+
}
- return (T) target;
+ return value;
}
+
+
+
}
--
Gitblit v1.8.0