From b10e7928d4517eb350b85075065023bed4139598 Mon Sep 17 00:00:00 2001 From: chengqf <584883665@139.com> Date: Sat, 15 Apr 2023 15:29:30 +0800 Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=88=A0=E9=99=A4=E5=90=8C?= =?UTF-8?q?=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../glxp/api/idc/service/DeleteService.java | 1 - .../idc/service/impl/DeleteServiceImpl.java | 23 ++----------------- 2 files changed, 2 insertions(+), 22 deletions(-) diff --git a/src/main/java/com/glxp/api/idc/service/DeleteService.java b/src/main/java/com/glxp/api/idc/service/DeleteService.java index 4f5bf20c0..d8cfa8784 100644 --- a/src/main/java/com/glxp/api/idc/service/DeleteService.java +++ b/src/main/java/com/glxp/api/idc/service/DeleteService.java @@ -6,6 +6,5 @@ import java.util.Map; public interface DeleteService { boolean syncDelete(String tableName,String uniqueValue); - boolean syncDelete(String tableName,String uniqueColumn,String uniqueValue); boolean syncDelete(Map params); } diff --git a/src/main/java/com/glxp/api/idc/service/impl/DeleteServiceImpl.java b/src/main/java/com/glxp/api/idc/service/impl/DeleteServiceImpl.java index a52910057..0372f0982 100644 --- a/src/main/java/com/glxp/api/idc/service/impl/DeleteServiceImpl.java +++ b/src/main/java/com/glxp/api/idc/service/impl/DeleteServiceImpl.java @@ -5,7 +5,6 @@ import java.util.Map; import javax.annotation.Resource; -import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.jdbc.core.JdbcTemplate; @@ -13,7 +12,6 @@ import org.springframework.stereotype.Service; import com.glxp.api.dao.idc.DbDao; import com.glxp.api.idc.service.DeleteService; -import com.glxp.api.idc.utils.TableUtils; import com.glxp.api.util.CustomUtil; @@ -27,32 +25,15 @@ public class DeleteServiceImpl implements DeleteService { @Override public boolean syncDelete(String tableName,String uniqueValue) { - return syncDelete(tableName,"",uniqueValue); - } - @Override - public boolean syncDelete(String tableName,String uniqueColumn,String uniqueValue) { Map map = new HashMap<>(); map.put("tableName", tableName); - map.put("uniqueColumn", uniqueColumn); map.put("uniqueValue", uniqueValue); return syncDelete(map); } @Override public boolean syncDelete(Map params) { createTable(); - String tableName = params.get("tableName").toString(); - String uniqueColumn = params.get("uniqueColumn")!=null ? params.get("uniqueColumn").toString() : ""; - if(StringUtils.isEmpty(uniqueColumn)) { - String[] syncTables = TableUtils.syncTables(); - for(String str:syncTables) { - String[] tnames = str.split("/"); - if(tnames[3].toLowerCase().equals(tableName.toLowerCase())) { - uniqueColumn = tnames[4]; - break; - } - } - } - String sql = "insert into idc_delete (id,tableName,uniqueColumn,updateTime,uniqueValue) values ('"+CustomUtil.getId()+"','"+params.get("tableName").toString().toLowerCase()+"','"+uniqueColumn+"',now(),'"+params.get("uniqueValue")+"')"; + String sql = "insert into idc_delete (id,tableName,updateTime,uniqueValue) values ('"+CustomUtil.getId()+"','"+params.get("tableName").toString().toLowerCase()+"',now(),'"+params.get("uniqueValue")+"')"; if(dbDao.save(sql)>0) return true; @@ -61,7 +42,7 @@ public class DeleteServiceImpl implements DeleteService { private void createTable() { try { - jdbcTemplate.execute("create table idc_delete (id varchar(36),tableName varchar(100),uniqueColumn varchar(60),uniqueValue varchar(600),updateTime datetime,PRIMARY KEY (id))"); + jdbcTemplate.execute("create table idc_delete (id varchar(36),tableName varchar(100),uniqueValue varchar(600),updateTime datetime,PRIMARY KEY (id))"); } catch (Exception e) {