fix:mq.sql.consumer;

liquidnet-bus-service/liquidnet-service-consumer/src/main/java/com/liquidnet/service/consumer/service/impl/BaseDao.java

@@ -62,13 +62,13 @@ public class BaseDao implements IBaseDao {
                         break;
                     }
                     if (!o.isEmpty()) {
-                        int[] ints = jdbcTemplate.batchUpdate(sql.get(i), o);
+                        jdbcTemplate.batchUpdate(sql.get(i), o);
 
-                        for (int c : ints) {
-                            if (c <= 0) {
-                                throw new LiquidnetServiceException("NON.SQL", sql.get(i));
-                            }
-                        }
+//                        for (int c : ints) {
+//                            if (c <= 0) {
+//                                throw new LiquidnetServiceException("NON.SQL", sql.get(i));
+//                            }
+//                        }
                     }
                     i++;
                 }
@@ -79,11 +79,11 @@ public class BaseDao implements IBaseDao {
             TransactionTemplate tt = new TransactionTemplate(transactionManager);
             return tt.execute(callback);
         } catch (Exception ex) {
-            if (ex instanceof LiquidnetServiceException) {
-                log.error("###Error.Code:{} - {}", ((LiquidnetServiceException) ex).getCode(), ex.getMessage());
-            } else {
-                log.error("###Error.Sqls:{}\nParameters:{}", JsonUtils.toJson(sql), JsonUtils.toJson(values), ex);
-            }
+//            if (ex instanceof LiquidnetServiceException) {
+//                log.error("###Error.Code:{} - {}", ((LiquidnetServiceException) ex).getCode(), ex.getMessage());
+//            } else {
+                log.error("###Error.Sqls:{}\nParameters:{},Ex:{}", JsonUtils.toJson(sql), JsonUtils.toJson(values), ex.getMessage());
+//            }
             return false;
         }
     }