jiangjiazhi / regional-platform

Authored by liquanyu almost 7 years ago

Exists in master and in 6 other branches

Showing 3 changed files with 0 additions and 8 deletions

...	...	@@ -111,7 +111,6 @@
111	111	if (CollectionUtils.isNotEmpty(list)) {
112	112	sql = sql.replaceFirst("\\(", "(ID,");
113	113	sql = sql.substring(0, sql.lastIndexOf("(") + 1) + list.get(0) + "," + sql.substring(sql.lastIndexOf("(") + 1, sql.length());
114		- System.out.println("add sync sql = " + sql);
115	114	//发送要同步的sql
116	115	SendMysqlSyncDatUtil.addSqlToQueue(sql, sqlId);
117	116	sql = null;

...	...	@@ -67,7 +67,6 @@
67	67	sql = getSql(configuration, boundSql, sqlId);
68	68	if (isSyncTable(sql))
69	69	{
70		- System.out.println("delete or update sync sql = " + sql);
71	70	SendMysqlSyncDatUtil.addSqlToQueue1(sql,sqlId);
72	71	}
73	72	}
...	...	@@ -76,7 +75,6 @@
76	75	sql = getSql(configuration, boundSql, sqlId);
77	76	if (isSyncTable(sql))
78	77	{
79		- System.out.println("add sync sql = " + sql);
80	78	SendMysqlSyncDatUtil.addSqlToQueue1(sql,sqlId);
81	79	}
82	80	}

...	...	@@ -60,7 +60,6 @@
60	60	request.setSql(Base64.encodeBase64String(sql.getBytes("utf-8")));
61	61	request.setSqlId(sqlId);
62	62	syncSqlQueue.add(request);
63		- System.out.println("syncSqlQueue size = " + syncSqlQueue.size());
64	63	} catch (UnsupportedEncodingException e) {
65	64	e.printStackTrace();
66	65	}
...	...	@@ -74,7 +73,6 @@
74	73	request.setSql(sql);
75	74	request.setSqlId(sqlId);
76	75	syncSqlQueue1.add(request);
77		- System.out.println("syncSqlQueue1 size = " + syncSqlQueue.size());
78	76	}
79	77
80	78	/**
...	...	@@ -84,7 +82,6 @@
84	82	*/
85	83	@Override
86	84	public void afterPropertiesSet() throws Exception {
87		- System.out.println("init sync sql thread.........");
88	85	Thread thread = new HandleThread();
89	86	Thread thread1 = new HandleThread1();
90	87	thread.setName("syncMysqlThread");
...	...	@@ -107,7 +104,6 @@
107	104	try {
108	105	Thread.sleep(3000);
109	106	request = syncSqlQueue.take();
110		- System.out.println(request);
111	107	String json = JsonUtil.obj2Str(request);
112	108	if (CollectionUtils.isNotEmpty(urls))
113	109	{
...	...	@@ -116,7 +112,6 @@
116	112	for (int i = 0 ; i < 3 ; i++)
117	113	{
118	114	String result = HttpClientUtil.doPostSSL(url,json,"3d19960bf3e81e7d816c4f26051c49ba");
119		- System.out.println("sync mysql result = " + result+";url="+url);
120	115	if (result == null)
121	116	{
122	117	continue;