jiangjiazhi / regional-platform

Commit f634674aa58423ba54c7769e7ed027304d2409b5

Authored by liquanyu over 7 years ago

Exists in master and in 6 other branches

同步

Showing 3 changed files with 26 additions and 65 deletions

platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MybatisSqlInterceptor.java
platform-operate-api/src/main/java/com/lyms/platform/operate/web/inteceptor/MysqlDataInterceptor.java
platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java

...	...	@@ -91,34 +91,19 @@
91	91	if (invocation.getArgs().length > 1) {
92	92	parameter = invocation.getArgs()[1];
93	93	}
94		- sqlId = mappedStatement.getId();
95		- BoundSql boundSql = mappedStatement.getBoundSql(parameter);
96		- Configuration configuration = mappedStatement.getConfiguration();
97		- sqlCommandType = mappedStatement.getSqlCommandType().name();
98		-// if ("update".equals(sqlCommandType.toLowerCase()) \|\| "delete".equals(sqlCommandType.toLowerCase()))
99		-// {
100		-// sql = getSql(configuration, boundSql, sqlId);
101		-// System.out.println("sql = "+sql);
102		-// if (isSyncTable(sql))
103		-// {
104		-//
105		-// System.out.println("delete or update sync sql = " + sql);
106		-// //发送要同步的sql
107		-// SendMysqlSyncDatUtil.addSqlToQueue(sql, sqlId);
108		-// sql = null;
109		-// System.out.println("time4=========" + (System.currentTimeMillis()-start));
110		-// }
111		-// }
112		-// else
113		- if ("insert".equals(sqlCommandType.toLowerCase()) )
	94	+ sqlId = mappedStatement.getId();
	95	+ BoundSql boundSql = mappedStatement.getBoundSql(parameter);
	96	+ Configuration configuration = mappedStatement.getConfiguration();
	97	+ sqlCommandType = mappedStatement.getSqlCommandType().name();
	98	+ if ("insert".equals(sqlCommandType.toLowerCase()) )
	99	+ {
	100	+ String tempSql = getSql(configuration, boundSql, sqlId);
	101	+ if (isSyncTable(tempSql))
114	102	{
115		- String tempSql = getSql(configuration, boundSql, sqlId);
116		- if (isSyncTable(tempSql))
117		- {
118		- sql = tempSql;
119		- }
	103	+ sql = tempSql;
120	104	}
121		- returnValue = invocation.proceed();
	105	+ }
	106	+ returnValue = invocation.proceed();
122	107	}
123	108	else
124	109	{

1	1	package com.lyms.platform.operate.web.inteceptor;
2	2
3	3
4		-import com.lyms.platform.biz.service.SyncDataService;
5	4	import com.lyms.platform.common.utils.ExceptionUtils;
6	5	import com.lyms.platform.operate.web.utils.SendMysqlSyncDatUtil;
7		-import org.apache.commons.collections.CollectionUtils;
8	6	import org.apache.commons.lang.StringUtils;
9	7	import org.apache.ibatis.executor.Executor;
10	8	import org.apache.ibatis.executor.resultset.ResultSetHandler;
...	...	@@ -15,7 +13,6 @@
15	13	import org.apache.ibatis.reflection.MetaObject;
16	14	import org.apache.ibatis.session.Configuration;
17	15	import org.apache.ibatis.type.TypeHandlerRegistry;
18		-import org.springframework.beans.factory.annotation.Autowired;
19	16	import org.springframework.context.annotation.Lazy;
20	17
21	18	import java.sql.Statement;
...	...	@@ -39,6 +36,7 @@
39	36	uses.add("baby_eye_check");
40	37	uses.add("baby_patient_extend_ear");
41	38	uses.add("baby_patient_extend_ear_birth");
	39	+ uses.add("baby_patient_extend_ear_baby");
42	40	uses.add("baby_patient_extend_ear_family");
43	41	uses.add("baby_patient_extend_ear_follow_up");
44	42	uses.add("baby_patient_extend_ear_hearing_diagnose");
...	...	@@ -46,14 +44,6 @@
46	44	uses.add("baby_patient_extend_ear_screen");
47	45	}
48	46
49		- private String sql;
50		-
51		- private Properties properties;
52		-
53		- private String sqlCommandType;
54		-
55		- private String sqlId;
56		-
57	47	public Object intercept(Invocation invocation) throws Throwable {
58	48	Object[] args = invocation.getArgs();
59	49	Object returnValue = null;
60	50
...	...	@@ -66,10 +56,11 @@
66	56	if (invocation.getArgs().length > 1) {
67	57	parameter = invocation.getArgs()[1];
68	58	}
69		- sqlId = mappedStatement.getId();
	59	+ String sqlId = mappedStatement.getId();
70	60	BoundSql boundSql = mappedStatement.getBoundSql(parameter);
71	61	Configuration configuration = mappedStatement.getConfiguration();
72		- sqlCommandType = mappedStatement.getSqlCommandType().name();
	62	+ String sqlCommandType = mappedStatement.getSqlCommandType().name();
	63	+ String sql = "";
73	64	if ("update".equals(sqlCommandType.toLowerCase()) \|\| "delete".equals(sqlCommandType.toLowerCase()))
74	65	{
75	66	sql = getSql(configuration, boundSql, sqlId);
76	67
77	68
78	69
79	70
...	...	@@ -77,37 +68,21 @@
77	68	{
78	69	System.out.println("delete or update sync sql = " + sql);
79	70	SendMysqlSyncDatUtil.addSqlToQueue1(sql,sqlId);
80		- sql = null;
81		-
82	71	}
83	72	}
84	73	else if ("insert".equals(sqlCommandType.toLowerCase()) )
85	74	{
86		- String tempSql = getSql(configuration, boundSql, sqlId);
87		- if (isSyncTable(tempSql))
	75	+ sql = getSql(configuration, boundSql, sqlId);
	76	+ if (isSyncTable(sql))
88	77	{
89		- sql = tempSql;
	78	+ System.out.println("add sync sql = " + sql);
	79	+ SendMysqlSyncDatUtil.addSqlToQueue1(sql,sqlId);
90	80	}
91	81	}
92		- returnValue = invocation.proceed();
93	82	}
94		- else
95		- {
96		- returnValue = invocation.proceed();
97		- if (StringUtils.isNotEmpty(sql) && sqlCommandType != null && "insert".equals(sqlCommandType.toLowerCase()))
98		- {
99		- if (returnValue != null && returnValue instanceof ArrayList)
100		- {
101		- List<Integer> list = (ArrayList)returnValue;
102		- if (CollectionUtils.isNotEmpty(list) && isSyncTable(sql)) {
103		- System.out.println("add sync sql = " + sql);
104		- SendMysqlSyncDatUtil.addSqlToQueue1(sql,sqlId);
105		- sql = null;
106		- }
107		- }
108		- }
109		- }
110		- }catch (Exception e)
	83	+ returnValue = invocation.proceed();
	84	+ }
	85	+ catch (Exception e)
111	86	{
112	87	ExceptionUtils.catchException(e," Mybatis Sql Interceptor exception");
113	88	}
...	...	@@ -191,8 +166,9 @@
191	166	return Plugin.wrap(target, this);
192	167	}
193	168
194		- public void setProperties(Properties properties0) {
195		- this.properties = properties0;
	169	+ @Override
	170	+ public void setProperties(Properties properties) {
	171	+
196	172	}
197	173	}

...	...	@@ -209,7 +209,7 @@
209	209	public static void main(String[] args)
210	210	{
211	211	try {
212		- String json = "aW5zZXJ0IGludG8gYmFieV9wYXRpZW50X2V4dGVuZF9lYXJfc2NyZWVuIChpZCxiYWJ5X2lkLHNjcmVlbl90eXBlLGNoZWNrX2hvc3BpdGFsX2lkLHNjcmVlbl9kYXRlLGhpZ2hfcmlza19jYXVzZSxvYWVfbGVmdCxvYWVfcmlnaHQsYWFicl9sZWZ0LGFhYnJfcmlnaHQsYWJyX2xlZnQsYWJyX3JpZ2h0LGdqYjJfZGVsXzM1LGdqYjJfZGVsXzE3NixnamIyX2RlbF8yMzUsZ2piMl9kZWxfMjk5LGdqYjNfc2xjMjZhNF81MzgsZ2piM19zbGMyNmE0XzIxNjgsZ2piM19zbGMyNmE0X2l2czcscnJuYV8xNDk0LHJybmFfMTU1NSxwcm9jZXNzX29wdGlvbl90eXBlLHByb2Nlc3Nfb3B0aW9uX2Rlc2MsZ3VpZF9vcGluaW9uLGNoZWNrX2RvY3Rvcl9pZCxyZWZlcnJhbF9kYXRlLGNyZWF0ZV9kYXRlLGNyZWF0ZV91c2VyX2lkLGNyZWF0ZV9ob3NwaXRhbF9pZCxuZXh0X2NoZWNrX3RpbWUsbGFzdF91cGRhdGVfZGF0ZSxsYXN0X3VwZGF0ZV91c2VyX2lkLGxhc3RfdXBkYXRlX2hvc3BpdGFsX2lkLHN0YXR1cyxzY3JfaXNwYXNzLHBpZCkgdmFsdWVzICgnZmRlMzc5OWY5NTZjNDg1Y2E4OTE0ZjczZjQ4YWVkZjMnLCc1YWE2ODNjMWE4NTI0MjhjOTI3ZTE3NjQnLDIsJzIxMDAwMDE3MDUnLCcyMDE4LTQtMTcgMjoyMjoyNycsbnVsbCxudWxsLG51bGwsbnVsbCxudWxsLG51bGwsbnVsbCxudWxsLG51bGwsMixudWxsLG51bGwsbnVsbCxudWxsLG51bGwsbnVsbCwyLCfH69PaM7j21MLE2r340NC9+NK7sr287LLp1e+2zycsJ7e0t7S4tLi0t7S3tLi0uLS3tLe0uLS4tLe0t7S4tLi0t7S3tLi0uLS3tLe0uLS4tLfvt8m3yScsJzIxMDAwMDI5OTAnLG51bGwsJzIwMTgtNC0xNyAyOjIyOjI3JywnMjEwMDAwMjk5MCcsJzIxMDAwMDE3MDUnLG51bGwsJzIwMTgtNC0xNyAyOjIyOjI3JywnMjEwMDAwMjk5MCcsJzIxMDAwMDE3MDUnLDAsMiwnNWFhNjgzYzFhODUyNDI4YzkyN2UxNzYyJyk=";
	212	+ String json = "aW5zZXJ0IGludG8gYmFieV9wYXRpZW50X2V4dGVuZF9lYXJfYmFieSAoaWQsbmFtZSxzZXgsY2FyZE5vLGJpcnRoLG1uYW1lLG1jZXJ0X3R5cGVfaWQsbWNlcnRfbm8sbXBob25lLHZjX2NhcmRfbm8sYnVpbGRfZG9jdG9yLGhvc3BpdGFsX2lkLGJ1aWxkX3R5cGUsZW5hYmxlLHluLGJ1aWxkX2RhdGUsYmFieV9wYXRpZW50X2lkLGJhYnlfZWFyX2lkLHBlcnNvbl9pZCkgdmFsdWVzICgnOTM2OTMwMTU0MjJlNDliNDg4Y2Y0ZTViMTcyNWI4NzQnLCfI+Mu5tcQnLDAsbnVsbCwnMjAxOC00LTE3IDM6NDY6MTInLCfL1bTyJywnNTdlMWRjZDNmMGYwMmU3Y2E1MTlkNmM2JywnMTY1NDg4Nzc3NzcnLCcxNjU0ODg3Nzc3NycsJzI0MzUyMzQ1MjM0NScsJzIxMDAwMDI5OTAnLCcyMTAwMDAxNzA1JywxLG51bGwsMSwnMjAxOC00LTE3IDM6NDY6MTInLCc1YWQ0ZmQzNGE4NTI5OGQyOTFhMDhjMGYnLCc0YTk3YWVhOGVkYjQ0MDg3OThhOTc0YWY0OThkMWM2ZicsJzVhZDRmZDMzYTg1Mjk4ZDI5MWEwOGMwNScp";
213	213	// json = org.apache.commons.codec.binary.Base64.encodeBase64String(json.getBytes());
214	214	// json = LymsEncodeUtil.aesEncrypt(json, "Lymsh@2016");
215	215