From 11b9970b5f1f99e718c8258cef4b0eadc0c00630 Mon Sep 17 00:00:00 2001 From: HAHA Date: Tue, 7 Jun 2022 09:42:54 +0800 Subject: [PATCH] =?UTF-8?q?=E9=85=8D=E7=BD=AE=E5=AE=9A=E6=97=B6=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../epmet-job/epmet-job-server/pom.xml | 6 +++ .../epmet/task/GuardarDatosLouDongTask.java | 41 +++++++++++++++++++ .../epmet/task/GuardarDatosPingFangTask.java | 41 +++++++++++++++++++ .../epmet/task/GuardarDatosRentalTask.java | 40 ++++++++++++++++++ .../epmet/task/GuardarDatosResidentTask.java | 41 +++++++++++++++++++ .../epmet/task/GuardarDatosRotatorsTask.java | 40 ++++++++++++++++++ .../feign/GuardarDatosFeignClient.java | 26 ++++++++++++ .../impl/GuardarDatosFeignClientFallBack.java | 37 +++++++++++++++++ 8 files changed, 272 insertions(+) create mode 100644 epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosLouDongTask.java create mode 100644 epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosPingFangTask.java create mode 100644 epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosRentalTask.java create mode 100644 epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosResidentTask.java create mode 100644 epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosRotatorsTask.java create mode 100644 epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/feign/GuardarDatosFeignClient.java create mode 100644 epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/feign/impl/GuardarDatosFeignClientFallBack.java diff --git a/epmet-module/epmet-job/epmet-job-server/pom.xml b/epmet-module/epmet-job/epmet-job-server/pom.xml index b0a4d6f1e5..30bdb6016d 100644 --- a/epmet-module/epmet-job/epmet-job-server/pom.xml +++ b/epmet-module/epmet-job/epmet-job-server/pom.xml @@ -114,6 +114,12 @@ 2.0.0 compile + + com.epmet + open-data-worker-server + 0.3.31 + compile + diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosLouDongTask.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosLouDongTask.java new file mode 100644 index 0000000000..03ec5b5ad2 --- /dev/null +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosLouDongTask.java @@ -0,0 +1,41 @@ +package com.epmet.task; + +import com.alibaba.fastjson.JSON; +import com.epmet.commons.tools.utils.Result; +import com.epmet.opendata.dto.form.PreserVationFormDTO; +import com.epmet.opendata.feign.GuardarDatosFeignClient; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * 获取楼栋的数据存入ca_开头的表 + * + * @param + * @return + * @author LZN + * @date 2022/6/6 14:37 + */ +@Slf4j +@Component("getPreserLouDongVation") +public class GuardarDatosLouDongTask implements ITask { + + @Autowired + private GuardarDatosFeignClient guardarDatosFeignClient; + + @Override + public void run(String params) { + log.info("LouDong定时任务执行，参数为：" + params); + PreserVationFormDTO formDTO = new PreserVationFormDTO(); + if (StringUtils.isNotBlank(params)) { + formDTO = JSON.parseObject(params, PreserVationFormDTO.class); + } + Result result = guardarDatosFeignClient.getPreserLouDongVation(formDTO); + if (result.success()){ + log.debug("LouDong执行成功"); + }else{ + log.debug("LouDong执行失败" + result.getMsg()); + } + } +} diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosPingFangTask.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosPingFangTask.java new file mode 100644 index 0000000000..6f56f8e7ad --- /dev/null +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosPingFangTask.java @@ -0,0 +1,41 @@ +package com.epmet.task; + +import com.alibaba.fastjson.JSON; +import com.epmet.commons.tools.utils.Result; +import com.epmet.opendata.dto.form.PreserVationFormDTO; +import com.epmet.opendata.feign.GuardarDatosFeignClient; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; + +/** + * 获取平房的数据存入ca_开头的表 + * + * @param + * @return + * @author LZN + * @date 2022/6/6 14:37 + */ +@Component("getPreserPingFangVation") +@Slf4j +public class GuardarDatosPingFangTask implements ITask { + + @Resource + private GuardarDatosFeignClient feignClient; + + @Override + public void run(String params) { + PreserVationFormDTO formDTO = new PreserVationFormDTO(); + if (StringUtils.isNotBlank(params)) { + formDTO = JSON.parseObject(params, PreserVationFormDTO.class); + } + Result result = feignClient.getPreserPingFangVation(formDTO); + if (result.success()) { + log.debug("pingfang执行成功"); + } else { + log.debug("pingfang执行失败" + result.getMsg()); + } + } +} diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosRentalTask.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosRentalTask.java new file mode 100644 index 0000000000..efed6268e3 --- /dev/null +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosRentalTask.java @@ -0,0 +1,40 @@ +package com.epmet.task; + +import com.alibaba.fastjson.JSON; +import com.epmet.commons.tools.utils.Result; +import com.epmet.opendata.dto.form.PreserVationFormDTO; +import com.epmet.opendata.feign.GuardarDatosFeignClient; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * 获取出租房的数据存入ca_开头的表 + * + * @param + * @return + * @author LZN + * @date 2022/6/6 14:38 + */ +@Component("getPreserRentalVation") +@Slf4j +public class GuardarDatosRentalTask implements ITask { + + @Autowired + private GuardarDatosFeignClient feignClient; + + @Override + public void run(String params) { + PreserVationFormDTO formDTO = new PreserVationFormDTO(); + if (StringUtils.isNotBlank(params)) { + formDTO = JSON.parseObject(params, PreserVationFormDTO.class); + } + Result result = feignClient.getPreserRentalVation(formDTO); + if (result.success()) { + log.debug("Rental执行成功"); + }else{ + log.debug("Rental执行失败" + result.getMsg()); + } + } +} diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosResidentTask.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosResidentTask.java new file mode 100644 index 0000000000..b52aff94f6 --- /dev/null +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosResidentTask.java @@ -0,0 +1,41 @@ +package com.epmet.task; + +import com.alibaba.fastjson.JSON; +import com.epmet.commons.tools.utils.Result; +import com.epmet.opendata.dto.form.PreserVationFormDTO; +import com.epmet.opendata.feign.GuardarDatosFeignClient; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; + +/** + * 获取人口的数据存入ca_开头的表 + * + * @param + * @return + * @author LZN + * @date 2022/6/6 14:39 + */ +@Component("getPreserResidentVation") +@Slf4j +public class GuardarDatosResidentTask implements ITask { + + @Resource + private GuardarDatosFeignClient feignClient; + + @Override + public void run(String params) { + PreserVationFormDTO formDTO = new PreserVationFormDTO(); + if (StringUtils.isNotBlank(params)) { + formDTO = JSON.parseObject(params, PreserVationFormDTO.class); + } + Result result = feignClient.getPreserResidentVation(formDTO); + if (result.success()) { + log.debug("Resident执行成功"); + } else { + log.debug("Resident执行失败" + result.getMsg()); + } + } +} diff --git a/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosRotatorsTask.java b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosRotatorsTask.java new file mode 100644 index 0000000000..b8414eaa56 --- /dev/null +++ b/epmet-module/epmet-job/epmet-job-server/src/main/java/com/epmet/task/GuardarDatosRotatorsTask.java @@ -0,0 +1,40 @@ +package com.epmet.task; + +import com.alibaba.fastjson.JSON; +import com.epmet.commons.tools.utils.Result; +import com.epmet.opendata.dto.form.PreserVationFormDTO; +import com.epmet.opendata.feign.GuardarDatosFeignClient; +import lombok.extern.slf4j.Slf4j; +import org.apache.commons.lang3.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * 获取流动人口的数据存入ca_开头的表 + * + * @param + * @return + * @author LZN + * @date 2022/6/6 14:39 + */ +@Component("getPreserRotatorsVation") +@Slf4j +public class GuardarDatosRotatorsTask implements ITask { + + @Autowired + private GuardarDatosFeignClient guardarDatosFeignClient; + + @Override + public void run(String params) { + PreserVationFormDTO formDTO = new PreserVationFormDTO(); + if (StringUtils.isNotBlank(params)) { + formDTO = JSON.parseObject(params, PreserVationFormDTO.class); + } + Result result = guardarDatosFeignClient.getPreserRotatorsVation(formDTO); + if (result.success()) { + log.debug("Rotators执行成功"); + } else { + log.debug("Rotators执行失败" + result.getMsg()); + } + } +} diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/feign/GuardarDatosFeignClient.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/feign/GuardarDatosFeignClient.java new file mode 100644 index 0000000000..cc884d2a12 --- /dev/null +++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/feign/GuardarDatosFeignClient.java @@ -0,0 +1,26 @@ +package com.epmet.opendata.feign; + +import com.epmet.commons.tools.utils.Result; +import com.epmet.opendata.dto.form.PreserVationFormDTO; +import com.epmet.opendata.feign.impl.GuardarDatosFeignClientFallBack; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.web.bind.annotation.PostMapping; + +@FeignClient(name = "open-data-worker-server",fallback = GuardarDatosFeignClientFallBack.class) +public interface GuardarDatosFeignClient { + + @PostMapping(value = "/opendata/caLoudong/preserLouDongVation") + Result getPreserLouDongVation(PreserVationFormDTO dto); + + @PostMapping(value = "/opendata/caPingfang/preserPingFangVation") + Result getPreserPingFangVation(PreserVationFormDTO dto); + + @PostMapping("/opendata/caRental/preserRentalVation") + Result getPreserRentalVation(PreserVationFormDTO dto); + + @PostMapping("/opendata/caResident/preserResidentVation") + Result getPreserResidentVation(PreserVationFormDTO dto); + + @PostMapping("/opendata/caRotators/preserRotatorsVation") + Result getPreserRotatorsVation(PreserVationFormDTO dto); +} diff --git a/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/feign/impl/GuardarDatosFeignClientFallBack.java b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/feign/impl/GuardarDatosFeignClientFallBack.java new file mode 100644 index 0000000000..9dc6f57393 --- /dev/null +++ b/epmet-module/open-data-worker/open-data-worker-server/src/main/java/com/epmet/opendata/feign/impl/GuardarDatosFeignClientFallBack.java @@ -0,0 +1,37 @@ +package com.epmet.opendata.feign.impl; + +import com.epmet.commons.tools.constant.ServiceConstant; +import com.epmet.commons.tools.utils.ModuleUtils; +import com.epmet.commons.tools.utils.Result; +import com.epmet.opendata.dto.form.PreserVationFormDTO; +import com.epmet.opendata.feign.GuardarDatosFeignClient; +import org.springframework.stereotype.Component; + +@Component +public class GuardarDatosFeignClientFallBack implements GuardarDatosFeignClient { + + @Override + public Result getPreserLouDongVation(PreserVationFormDTO dto) { + return ModuleUtils.feignConError("open-data-worker", "getPreserLouDongVation", dto); + } + + @Override + public Result getPreserPingFangVation(PreserVationFormDTO dto) { + return ModuleUtils.feignConError("open-data-worker", "getPreserPingFangVation", dto); + } + + @Override + public Result getPreserRentalVation(PreserVationFormDTO dto) { + return ModuleUtils.feignConError("open-data-worker", "getPreserRentalVation", dto); + } + + @Override + public Result getPreserResidentVation(PreserVationFormDTO dto) { + return ModuleUtils.feignConError("open-data-worker", "getPreserResidentVation", dto); + } + + @Override + public Result getPreserRotatorsVation(PreserVationFormDTO dto) { + return ModuleUtils.feignConError("open-data-worker", "getPreserRotatorsVation", dto); + } +}