Lianxun_Java.git

			@@ -3,6 +3,7 @@
			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;
			@@ -11,16 +12,13 @@
			import com.java110.utils.util.DateUtil;
			import com.java110.utils.util.StringUtil;
			import org.apache.ibatis.executor.Executor;
			import org.apache.ibatis.mapping.BoundSql;
			import org.apache.ibatis.mapping.MappedStatement;
			import org.apache.ibatis.mapping.ParameterMapping;
			import org.apache.ibatis.mapping.SqlCommandType;
			import org.apache.ibatis.mapping.*;
			import org.apache.ibatis.plugin.*;
			import org.apache.ibatis.reflection.MetaObject;
			import org.apache.ibatis.session.Configuration;
			import org.apache.ibatis.type.TypeHandlerRegistry;
			import org.slf4j.Logger;
			import org.slf4j.LoggerFactory;
			import com.java110.core.log.LoggerFactory;
			import org.springframework.http.*;

			import java.sql.Timestamp;
			@@ -54,7 +52,11 @@
			Map<String, Object> sqlValue = new HashMap<>();
			//获取sql语句
			String sql = showSql(configuration, boundSql, sqlValue, sqlCommandType);
			restTemplate = ApplicationContextFactory.getBean("restTemplate", RestTemplate.class);
			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);
			@@ -77,7 +79,7 @@
			*/
			private void dealDeleteSql(MappedStatement mappedStatement, Object parameter, String sql, Map<String, Object> sqlValue) {

			String tmpTable = sql.substring(sql.indexOf("into") + 4, sql.indexOf("(")).trim();
			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(" "));
			@@ -115,6 +117,9 @@
			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) {
			@@ -131,7 +136,7 @@
			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 tmpTable = sql.substring(sql.indexOf("update") + 6, sql.indexOf("set ")).trim();

			String tmpTableHasT = tmpTable;

			@@ -174,7 +179,11 @@
			String url = ServiceConstant.SERVICE_ORDER_URL + "/order/oIdApi/createOrderItem";
			HttpHeaders httpHeaders = new HttpHeaders();
			HttpEntity httpEntity = new HttpEntity(orderItemDto.toString(), httpHeaders);
			ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.POST, httpEntity, String.class);
			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);
			@@ -243,6 +252,9 @@
			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) {
			@@ -282,7 +294,11 @@
			String propertyName = parameterMapping.getProperty();
			if (metaObject.hasGetter(propertyName)) {
			Object obj = metaObject.getValue(propertyName);
			sql = sql.replaceFirst("\\?", getParameterValue(obj));
			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);
			@@ -298,7 +314,7 @@
			String[] tmpKeys = tmpKey.split(",");

			// if (values.size() < tmpKeys.length) {
			// throw new IllegalArgumentException("sql 错误 key 和value 个数不等" + sql);
			// throw new IllegalArgumentException("sql 错误 key P和value 个数不等" + sql);
			// }
			for (int keyIndex = 0; keyIndex < tmpKeys.length; keyIndex++) {
			String key = tmpKeys[keyIndex].trim();
			@@ -370,13 +386,5 @@
			}


			public static void main(String[] args) {
			String tmpTable = "" +
			" id_card,open_id,link,remark,user_id,app_type,app_user_name,nickname,headimgurl,community_name,state,app_user_id,community_id,app_type_cd,member_id\n" +
			" ";
			String[] a = tmpTable.split(",");
			for(String a1:a){
			System.out.println(a1);
			}
			}

			}