重点工程删除项目信息

src/main/java/com/sooka/sponest/dataexchange/remoteapi/fallback/center/data/RemoteDataBaseServiceFallbackFactory.java

@@ -32,6 +32,11 @@ public class RemoteDataBaseServiceFallbackFactory implements FallbackFactory<Rem
             }
 
             @Override
+            public R<?> deleteProject(String[] projectIds) {
+                return null;
+            }
+
+            @Override
             public R<?> insertEnforceLawInfoByList(JSONArray jsonArray) {
                 return null;
             }

src/main/java/com/sooka/sponest/dataexchange/remoteapi/service/center/data/RemoteDataBaseService.java

@@ -9,6 +9,9 @@ import com.sooka.sponest.dataexchange.remoteapi.fallback.center.event.RemoteEven
 import com.sooka.sponest.dataexchange.remoteapi.service.ModulesServiceNameContants;
 import com.sooka.sponest.dataexchange.sendChange.domian.CenterdataTKeyProjects;
 import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.Mapping;
 import org.springframework.web.bind.annotation.PostMapping;
 
 import java.util.List;
@@ -23,13 +26,21 @@ import java.util.Map;
 public interface RemoteDataBaseService {
 
     /**
-     * 重点工程
+     * 重点工程接收项目信息
      * @param list
      * @return
      */
     @PostMapping("/projects/receivedMessage")
     public R<?> receivedMessage(List<CenterdataTKeyProjects> list);
 
+    /**
+     * 重点工程删除项目信息
+     * @param projectIds
+     * @return
+     */
+    @PostMapping("/projects/deleteProject")
+    public R<?> deleteProject(String[] projectIds);
+
     @PostMapping("/record/insertEnforceLawInfoByList")
     public R<?> insertEnforceLawInfoByList(JSONArray jsonArray);
 

src/main/java/com/sooka/sponest/dataexchange/sendChange/controller/EngineeringController.java

@@ -47,7 +47,7 @@ public class EngineeringController {
 
 
     /**
-     * 重点工程
+     * 重点工程推送项目信息
      * @param
      * @return
      */
@@ -111,6 +111,31 @@ public class EngineeringController {
         return R.ok(result,"接收成功");
     }
 
+
+    /**
+     * 重点工程删除项目信息
+     * @param
+     * @return
+     */
+    @PostMapping("/deleteEngineeringData")
+    @ResponseBody
+    @Log(title = "重点工程向数据中心推送删除事件", businessType = BusinessType.DELETE)
+    public R<?> deleteEngineeringData(@RequestBody String[] projectIds) {
+        if (StringUtils.isNotEmpty(SecurityUtils.getToken())) {
+            log.info("SecurityUtils.getToken():{}",SecurityUtils.getToken());
+            R<?> result = remoteDataBaseService.deleteProject(projectIds);
+            if (result.getCode() == 200) {
+                return R.ok(null,"删除成功");
+            } else {
+                return R.fail(result.getCode(),result.getMsg());
+            }
+        } else {
+            return R.fail(401,"登录状态已过期");
+        }
+    }
+
+
+
     /**
      * 重点区域
      * @param