From 5154d1820600ebc331289f7fe599dc89ecbadb68 Mon Sep 17 00:00:00 2001
From: chengqf <584883665@139.com>
Date: Sat, 15 Apr 2023 11:16:22 +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=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../api/idc/controller/DeleteController.java  | 37 +++++++++++++
 .../glxp/api/idc/service/DeleteService.java   | 10 ++++
 .../idc/service/impl/DeleteServiceImpl.java   | 52 +++++++++++++++++++
 3 files changed, 99 insertions(+)
 create mode 100644 src/main/java/com/glxp/api/idc/controller/DeleteController.java
 create mode 100644 src/main/java/com/glxp/api/idc/service/DeleteService.java
 create mode 100644 src/main/java/com/glxp/api/idc/service/impl/DeleteServiceImpl.java

diff --git a/src/main/java/com/glxp/api/idc/controller/DeleteController.java b/src/main/java/com/glxp/api/idc/controller/DeleteController.java
new file mode 100644
index 00000000..913487f8
--- /dev/null
+++ b/src/main/java/com/glxp/api/idc/controller/DeleteController.java
@@ -0,0 +1,37 @@
+package com.glxp.api.idc.controller;
+
+import java.util.Map;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.glxp.api.common.res.BaseResponse;
+import com.glxp.api.common.util.ResultVOUtils;
+import com.glxp.api.idc.service.DeleteService;
+
+
+
+
+/**
+ * 中继服务接口
+ */
+
+@RestController
+public class DeleteController {
+    @Resource
+    DeleteService deleteService;
+
+    @RequestMapping(value = "/spssync/common/delete")
+    @ResponseBody
+    public BaseResponse delete(HttpServletRequest request, @RequestBody Map<String, Object> params) {
+        if(deleteService.syncDelete(params))
+            return ResultVOUtils.success();
+        return ResultVOUtils.error(9999, "失败");
+    }
+
+}
diff --git a/src/main/java/com/glxp/api/idc/service/DeleteService.java b/src/main/java/com/glxp/api/idc/service/DeleteService.java
new file mode 100644
index 00000000..2c02d5da
--- /dev/null
+++ b/src/main/java/com/glxp/api/idc/service/DeleteService.java
@@ -0,0 +1,10 @@
+package com.glxp.api.idc.service;
+
+import java.util.Map;
+
+/*数据中继删除数据处理*/
+public interface DeleteService {
+
+	boolean syncDelete(String tableName,String uniqueColumn,String value);
+	boolean syncDelete(Map<String,Object> 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
new file mode 100644
index 00000000..afdf38ec
--- /dev/null
+++ b/src/main/java/com/glxp/api/idc/service/impl/DeleteServiceImpl.java
@@ -0,0 +1,52 @@
+package com.glxp.api.idc.service.impl;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.annotation.Resource;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Service;
+
+import com.glxp.api.dao.idc.DbDao;
+import com.glxp.api.idc.service.DeleteService;
+import com.glxp.api.util.CustomUtil;
+
+
+/*连通检测*/
+@Service
+public class DeleteServiceImpl implements DeleteService {
+    private static final Logger logger = LoggerFactory.getLogger(DeleteServiceImpl.class);
+    @Resource
+    private JdbcTemplate jdbcTemplate;
+    @Resource
+    private DbDao dbDao;
+    
+    @Override
+    public boolean syncDelete(String tableName,String uniqueColumn,String uniqueValue) {
+        Map<String,Object> map = new HashMap<>();
+        map.put("tableName", tableName);
+        map.put("uniqueColumn", uniqueColumn);
+        map.put("uniqueValue", uniqueValue);
+        return syncDelete(map);
+    }
+    @Override
+    public boolean syncDelete(Map<String,Object> params) {
+        createTable();
+        String sql = "insert into idc_delete (id,tableName,uniqueColumn,uniqueValue,updateTime) values ('"+CustomUtil.getId()+"','"+params.get("tableName")+"','"+params.get("uniqueColumn")+"','"+params.get("uniqueValue")+"',now())";
+        if(dbDao.save(sql)>0)
+            return true;
+        return false;
+    }
+    
+    private void createTable() {
+        try {
+            jdbcTemplate.execute("create table idc_delete (id varchar(36),tableName varchar(100),uniqueColumn varchar(60),uniqueValue varchar(200),updateTime datetime,PRIMARY KEY (id))");
+
+        } catch (Exception e) {
+
+        }
+     }
+}
\ No newline at end of file