社区管理推送

epdc-cloud-client-yushan

@@ -1 +1 @@
-Subproject commit 9a2f70c6215d14eec99c7a9811376550f2bef0d9
+Subproject commit 48965c0cc93cfb5dbaf3f6f649f11ac9856ee8e4

epdc-cloud-commons-yushan

@@ -1 +1 @@
-Subproject commit 128c6a4bfb8087999b492a6febfdde984623fe3a
+Subproject commit f49128405cd591b9aab7f129df01518c5aea143e

epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/AdminFeignClient.java

@@ -0,0 +1,26 @@
+package com.elink.esua.epdc.feign;
+
+import com.elink.esua.epdc.commons.tools.constant.ServiceConstant;
+import com.elink.esua.epdc.commons.tools.utils.Result;
+import com.elink.esua.epdc.feign.fallback.AdminFeignClientFallback;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+
+/**
+ *
+ *
+ * @author zhy
+ * @date 2022/12/9 10:22
+ */
+@FeignClient(name = ServiceConstant.EPDC_ADMIN_SERVER, fallback = AdminFeignClientFallback.class)
+public interface AdminFeignClient {
+
+    /**
+     * 获取当日排行榜
+     *
+     * @return
+     */
+    @GetMapping("sys/dept/manage/sendManageDept")
+    Result sendManageDept();
+
+}

epdc-cloud-job/src/main/java/com/elink/esua/epdc/feign/fallback/AdminFeignClientFallback.java

@@ -0,0 +1,23 @@
+package com.elink.esua.epdc.feign.fallback;
+
+import com.elink.esua.epdc.commons.tools.constant.ServiceConstant;
+import com.elink.esua.epdc.commons.tools.utils.ModuleUtils;
+import com.elink.esua.epdc.commons.tools.utils.Result;
+import com.elink.esua.epdc.feign.AdminFeignClient;
+import org.springframework.stereotype.Component;
+
+/**
+ *
+ *
+ * @author zhy
+ * @date 2022/12/9 10:22
+ */    
+@Component
+public class AdminFeignClientFallback implements AdminFeignClient {
+
+    @Override
+    public Result sendManageDept() {
+        return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "sendCommunityManageDept");
+    }
+
+}

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/admin/CommunityManageTask.java

@@ -0,0 +1,20 @@
+package com.elink.esua.epdc.task.admin;
+
+/**
+ *
+ *
+ * @author zhy
+ * @date 2022/12/9 10:17
+ */
+public interface CommunityManageTask {
+
+    /**
+     * 社区管理推送
+     *
+     * @param param
+     * @return void
+     * @author zhy
+     * @date 2022/12/9 10:17
+     */
+    void run(String param);
+}

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/admin/impl/CommunityManageTaskImpl.java

@@ -0,0 +1,29 @@
+package com.elink.esua.epdc.task.admin.impl;
+
+import com.elink.esua.epdc.feign.AdminFeignClient;
+import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import com.elink.esua.epdc.feign.UserFeignClient;
+import com.elink.esua.epdc.task.admin.CommunityManageTask;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ *
+ *
+ * @author zhy
+ * @date 2022/12/9 10:17
+ */
+@Component("communityManageTask")
+public class CommunityManageTaskImpl implements CommunityManageTask {
+
+    @Autowired
+    private AdminFeignClient adminFeignClient;
+
+    @Autowired
+    private UserFeignClient userFeignClient;
+
+    @Override
+    public void run(String param) {
+        adminFeignClient.sendManageDept();
+    }
+}

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/analysis/CategoryDailyReportTaskImpl.java → epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/analysis/impl/CategoryDailyReportTaskImpl.java

@@ -1,6 +1,7 @@
-package com.elink.esua.epdc.task.analysis;
+package com.elink.esua.epdc.task.analysis.impl;
 
 import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import com.elink.esua.epdc.task.analysis.CategoryDailyReportTask;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/analysis/GridOpeningTaskImpl.java → epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/analysis/impl/GridOpeningTaskImpl.java

@@ -1,6 +1,7 @@
-package com.elink.esua.epdc.task.analysis;
+package com.elink.esua.epdc.task.analysis.impl;
 
 import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import com.elink.esua.epdc.task.analysis.GridOpeningTask;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/EpdcScreenJobTaskImpl.java → epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/impl/EpdcScreenJobTaskImpl.java

@@ -1,6 +1,7 @@
-package com.elink.esua.epdc.task.screen;
+package com.elink.esua.epdc.task.screen.impl;
 
 import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import com.elink.esua.epdc.task.screen.EpdcScreenJobTask;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/ScreenBaseReportPushTaskImpl.java → epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/impl/ScreenBaseReportPushTaskImpl.java

@@ -1,10 +1,11 @@
-package com.elink.esua.epdc.task.screen;
+package com.elink.esua.epdc.task.screen.impl;
 
 import com.alibaba.fastjson.JSONObject;
 import com.elink.esua.epdc.dto.ScreenBaseReportParamDTO;
 import com.elink.esua.epdc.dto.analysis.pc.screen.form.ItemCountParamDTO;
 import com.elink.esua.epdc.dto.analysis.pc.screen.form.ScreenJobFormDTO;
 import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import com.elink.esua.epdc.task.screen.ScreenBaseReportPushTask;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/ScreenGovernancePushTaskImpl.java → epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/impl/ScreenGovernancePushTaskImpl.java

@@ -1,9 +1,10 @@
-package com.elink.esua.epdc.task.screen;
+package com.elink.esua.epdc.task.screen.impl;
 
 import com.alibaba.fastjson.JSONObject;
 import com.elink.esua.epdc.dto.ScreenGovernanceParamDTO;
 import com.elink.esua.epdc.dto.analysis.pc.screen.form.ScreenJobFormDTO;
 import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import com.elink.esua.epdc.task.screen.ScreenGovernancePushTask;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/ScreenGridManagerDataTaskImpl.java → epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/impl/ScreenGridManagerDataTaskImpl.java

@@ -1,8 +1,9 @@
-package com.elink.esua.epdc.task.screen;
+package com.elink.esua.epdc.task.screen.impl;
 
 import com.alibaba.fastjson.JSONObject;
 import com.elink.esua.epdc.dto.analysis.pc.screen.form.GmUploaddataParamDTO;
 import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import com.elink.esua.epdc.task.screen.ScreenIndexDataPushTask;
 import org.apache.commons.lang.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/ScreenGridManagerEventsTaskImpl.java → epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/impl/ScreenGridManagerEventsTaskImpl.java

@@ -1,9 +1,10 @@
-package com.elink.esua.epdc.task.screen;
+package com.elink.esua.epdc.task.screen.impl;
 
 import com.alibaba.fastjson.JSONObject;
 import com.elink.esua.epdc.dto.ScreenGridManagerParamDTO;
 import com.elink.esua.epdc.dto.analysis.pc.screen.form.ScreenJobFormDTO;
 import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import com.elink.esua.epdc.task.screen.ScreenIndexDataPushTask;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/ScreenIndexDataPushTaskImpl.java → epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/impl/ScreenIndexDataPushTaskImpl.java

@@ -1,9 +1,10 @@
-package com.elink.esua.epdc.task.screen;
+package com.elink.esua.epdc.task.screen.impl;
 
 import com.alibaba.fastjson.JSONObject;
 import com.elink.esua.epdc.dto.ScreenIndexBasicDataParamDTO;
 import com.elink.esua.epdc.dto.analysis.pc.screen.form.ScreenJobFormDTO;
 import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import com.elink.esua.epdc.task.screen.ScreenIndexDataPushTask;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/ScreenPublicDataPushTaskImpl.java → epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/impl/ScreenPublicDataPushTaskImpl.java

@@ -1,8 +1,9 @@
-package com.elink.esua.epdc.task.screen;
+package com.elink.esua.epdc.task.screen.impl;
 
 import com.alibaba.fastjson.JSONObject;
 import com.elink.esua.epdc.dto.ScreenJobBasicDataParamDTO;
 import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import com.elink.esua.epdc.task.screen.ScreenPublicDataPushTask;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/WorkLogTaskImpl.java → epdc-cloud-job/src/main/java/com/elink/esua/epdc/task/screen/impl/WorkLogTaskImpl.java

@@ -1,6 +1,7 @@
-package com.elink.esua.epdc.task.screen;
+package com.elink.esua.epdc.task.screen.impl;
 
 import com.elink.esua.epdc.feign.AnalysisFeignClient;
+import com.elink.esua.epdc.task.screen.WorkLogTask;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 

epdc-cloud-parent-yushan

@@ -1 +1 @@
-Subproject commit 6c53fd985cbaae46046a44a2d84f1eb9bff86a9d
+Subproject commit 7d5b8709e3fa8224b3463e120f7b79af1feea28c