diff --git a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/controller/SysDeptController.java b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/controller/SysDeptController.java index 9f58c56fe..f300273f7 100644 --- a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/controller/SysDeptController.java +++ b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/controller/SysDeptController.java @@ -133,6 +133,7 @@ public class SysDeptController { public Result getCompleteDept(@PathVariable("gridId") String gridId) { return sysDeptService.getCompleteDept(gridId); } + /** * 通过网格ID获取该网格所有上级机构 * @@ -207,8 +208,24 @@ public class SysDeptController { * @date 2019/12/12 17:26 */ @GetMapping("listAllGridId") - @ApiOperation("获取所有下属网格ID集合") public Result listAllGridId() { return sysDeptService.listAllGridId(); } + + /** + * 按部门类型,分页查询部门列表 + * + * @param typeKey 部门类型 + * @param pageSize 页容量 + * @param pageIndex 页码 + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @author work@yujt.net.cn + * @date 2019/12/17 16:03 + */ + @GetMapping("pageDeptIdByTypeKey/{typeKey}/{pageSize}/{pageIndex}") + public Result> pageDeptIdByTypeKey(@PathVariable("typeKey") String typeKey, + @PathVariable("pageSize") Integer pageSize, + @PathVariable("pageIndex") Integer pageIndex) { + return sysDeptService.pageDeptIdByTypeKey(typeKey, pageSize, pageIndex); + } } diff --git a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/dao/SysDeptDao.java b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/dao/SysDeptDao.java index a89edac59..3d20bfc07 100644 --- a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/dao/SysDeptDao.java +++ b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/dao/SysDeptDao.java @@ -136,16 +136,29 @@ public interface SysDeptDao extends BaseDao { * @Description * @Date 2019/12/4 20:22 **/ - List selectListUserSysDeptInfo(UserSysDeptInfoFormDTO formDTO); + List selectListUserSysDeptInfo(UserSysDeptInfoFormDTO formDTO); - - /*** - * 查询所有网格 - * @param - * @return java.util.List - * @author qushutong - * @date 2019/12/12 18:12 - */ + /*** + * 查询所有网格 + * @param + * @return java.util.List + * @author qushutong + * @date 2019/12/12 18:12 + */ List selectListAllGridId(); + + /** + * 按部门类型,分页查询部门列表 + * + * @param typeKey 部门类型 + * @param pageSize 页容量 + * @param pageIndex 页码 + * @return java.util.List + * @author work@yujt.net.cn + * @date 2019/12/17 16:11 + */ + List pageDeptIdByTypeKey(@Param("typeKey") String typeKey, + @Param("pageSize") Integer pageSize, + @Param("pageIndex") Integer pageIndex); } diff --git a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/SysDeptService.java b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/SysDeptService.java index a95a808fb..cb2aaca7f 100644 --- a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/SysDeptService.java +++ b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/SysDeptService.java @@ -174,12 +174,21 @@ public interface SysDeptService extends BaseService { /*** * 获取所有网格 * @param - * @return com.elink.esua.epdc.commons.tools.utils.Result> + * @return com.elink.esua.epdc.commons.tools.utils.Result> * @author qushutong * @date 2019/12/12 17:29 */ Result listAllGridId(); - - + /** + * 按部门类型,分页查询部门列表 + * + * @param typeKey 部门类型 + * @param pageSize 页容量 + * @param pageIndex 页码 + * @return com.elink.esua.epdc.commons.tools.utils.Result> + * @author work@yujt.net.cn + * @date 2019/12/17 16:05 + */ + Result> pageDeptIdByTypeKey(String typeKey, Integer pageSize, Integer pageIndex); } diff --git a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/impl/SysDeptServiceImpl.java b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/impl/SysDeptServiceImpl.java index 152d71908..84214e7e5 100644 --- a/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/impl/SysDeptServiceImpl.java +++ b/esua-epdc/epdc-admin/epdc-admin-server/src/main/java/com/elink/esua/epdc/service/impl/SysDeptServiceImpl.java @@ -15,6 +15,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.elink.esua.epdc.commons.mybatis.service.impl.BaseServiceImpl; import com.elink.esua.epdc.commons.tools.constant.Constant; import com.elink.esua.epdc.commons.tools.constant.FieldConstant; +import com.elink.esua.epdc.commons.tools.constant.NumConstant; import com.elink.esua.epdc.commons.tools.constant.OrganizationTypeConstant; import com.elink.esua.epdc.commons.tools.enums.SuperAdminEnum; import com.elink.esua.epdc.commons.tools.exception.ErrorCode; @@ -511,4 +512,14 @@ public class SysDeptServiceImpl extends BaseServiceImpl> pageDeptIdByTypeKey(String typeKey, Integer pageSize, Integer pageIndex) { + if (null == pageSize || null == pageIndex || pageSize < NumConstant.ONE || pageIndex < NumConstant.ONE) { + return new Result().error("参数错误"); + } + pageIndex = pageIndex - NumConstant.ONE; + List deptIdList = baseDao.pageDeptIdByTypeKey(typeKey, pageSize, pageIndex); + return new Result().ok(deptIdList); + } } diff --git a/esua-epdc/epdc-admin/epdc-admin-server/src/main/resources/mapper/SysDeptDao.xml b/esua-epdc/epdc-admin/epdc-admin-server/src/main/resources/mapper/SysDeptDao.xml index 54100f933..865c23ce1 100644 --- a/esua-epdc/epdc-admin/epdc-admin-server/src/main/resources/mapper/SysDeptDao.xml +++ b/esua-epdc/epdc-admin/epdc-admin-server/src/main/resources/mapper/SysDeptDao.xml @@ -203,4 +203,11 @@ WHERE sd.type_key = 'grid_party' + + diff --git a/esua-epdc/epdc-gateway/pom.xml b/esua-epdc/epdc-gateway/pom.xml index 93de64088..a6980a704 100644 --- a/esua-epdc/epdc-gateway/pom.xml +++ b/esua-epdc/epdc-gateway/pom.xml @@ -99,12 +99,12 @@ lb://epdc-auth-server - - http://127.0.0.1:9092 + lb://epdc-admin-server + lb://epdc-activiti-server - http://127.0.0.1:9040 + http://127.0.0.1:9040 lb://epdc-app-server lb://epdc-heart-server @@ -126,8 +126,10 @@ lb://epdc-demo-server http://127.0.0.1:9063 - lb://epdc-websocket-server - lb://epdc-kpi-server + lb://epdc-websocket-server + + + http://127.0.0.1:9069 false 47.104.224.45:8848 @@ -165,7 +167,8 @@ lb://epdc-user-server lb://epdc-demo-server lb://epdc-group-server - lb://epdc-websocket-server + lb://epdc-websocket-server + lb://epdc-kpi-server @@ -200,7 +203,8 @@ lb://epdc-user-server lb://epdc-demo-server lb://epdc-group-server - lb://epdc-websocket-server + lb://epdc-websocket-server + lb://epdc-kpi-server diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/ScheduleJobKpiService.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/ScheduleJobKpiService.java index 59000c295..dbd37675f 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/ScheduleJobKpiService.java +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/ScheduleJobKpiService.java @@ -1,9 +1,9 @@ package com.elink.esua.epdc.service; /** - * @author: qushutong - * @Date: 2019/12/12 16:52 - * @Description: kpi 模块查原始数据 + * @author: qushutong + * @Date: 2019/12/12 16:52 + * @Description: kpi 模块查原始数据 */ public interface ScheduleJobKpiService { @@ -15,4 +15,14 @@ public interface ScheduleJobKpiService { * @date 2019/12/12 16:56 */ void statKpiMetaData(); + + /** + * 启动与规则编码匹配的相关任务 + * + * @param ruleCode + * @return void + * @author work@yujt.net.cn + * @date 2019/12/17 14:43 + */ + void startTaskByRuleCode(String ruleCode); } diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/impl/ScheduleJobKpiServiceImpl.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/impl/ScheduleJobKpiServiceImpl.java index 6afd4e788..e445edae2 100644 --- a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/impl/ScheduleJobKpiServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/service/impl/ScheduleJobKpiServiceImpl.java @@ -18,4 +18,9 @@ public class ScheduleJobKpiServiceImpl implements ScheduleJobKpiService { public void statKpiMetaData() { kpiFeignClient.runKpiMateData(); } + + @Override + public void startTaskByRuleCode(String ruleCode) { + + } } diff --git a/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/KpiRuleTask.java b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/KpiRuleTask.java new file mode 100644 index 000000000..6c5edf27a --- /dev/null +++ b/esua-epdc/epdc-module/epdc-job/epdc-job-server/src/main/java/com/elink/esua/epdc/task/KpiRuleTask.java @@ -0,0 +1,34 @@ +package com.elink.esua.epdc.task; + +import com.elink.esua.epdc.service.ScheduleJobKpiService; +import org.apache.commons.lang3.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +/** + * 绩效考核规则的相关任务 + * + * @author work@yujt.net.cn + * @date 2019/12/17 14:40 + */ +@Component("kpiRuleTask") +public class KpiRuleTask implements ITask { + + @Autowired + private ScheduleJobKpiService kpiService; + + /** + * 根据规则编码执行计划任务 + * + * @param ruleCode + * @return void + * @author work@yujt.net.cn + * @date 2019/12/17 14:42 + */ + @Override + public void run(String ruleCode) { + if (StringUtils.isNotBlank(ruleCode)) { + kpiService.startTaskByRuleCode(ruleCode); + } + } +} diff --git a/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/pom.xml b/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/pom.xml index bae63c87b..1e7bad124 100644 --- a/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/pom.xml +++ b/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/pom.xml @@ -115,7 +115,7 @@ dev - 9987 + 9069 2 47.104.224.45 @@ -138,7 +138,7 @@ test - 9987 + 9069 2 47.104.224.45 @@ -162,7 +162,7 @@ prod prod - 9987 + 9069 0 10.5.34.164 diff --git a/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/controller/KpiMetaDataController.java b/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/controller/KpiMetaDataController.java index 034c42f60..b112a4336 100644 --- a/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/controller/KpiMetaDataController.java +++ b/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/controller/KpiMetaDataController.java @@ -45,24 +45,24 @@ import java.util.Map; @RestController @RequestMapping("kpimetadata") public class KpiMetaDataController { - + @Autowired private KpiMetaDataService kpiMetaDataService; @GetMapping("page") - public Result> page(@RequestParam Map params){ + public Result> page(@RequestParam Map params) { PageData page = kpiMetaDataService.page(params); return new Result>().ok(page); } @GetMapping("{id}") - public Result get(@PathVariable("id") String id){ + public Result get(@PathVariable("id") String id) { KpiMetaDataDTO data = kpiMetaDataService.get(id); return new Result().ok(data); } @PostMapping - public Result save(@RequestBody KpiMetaDataDTO dto){ + public Result save(@RequestBody KpiMetaDataDTO dto) { //效验数据 ValidatorUtils.validateEntity(dto, AddGroup.class, DefaultGroup.class); kpiMetaDataService.save(dto); @@ -70,7 +70,7 @@ public class KpiMetaDataController { } @PutMapping - public Result update(@RequestBody KpiMetaDataDTO dto){ + public Result update(@RequestBody KpiMetaDataDTO dto) { //效验数据 ValidatorUtils.validateEntity(dto, UpdateGroup.class, DefaultGroup.class); kpiMetaDataService.update(dto); @@ -78,7 +78,7 @@ public class KpiMetaDataController { } @DeleteMapping - public Result delete(@RequestBody String[] ids){ + public Result delete(@RequestBody String[] ids) { //效验数据 AssertUtils.isArrayEmpty(ids, "id"); kpiMetaDataService.delete(ids); @@ -99,7 +99,7 @@ public class KpiMetaDataController { * @date 2019/12/16 10:17 */ @GetMapping("buildMetaData") - public void buildMetaData(){ + public void buildMetaData() { } diff --git a/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/feign/AdminFeignClient.java b/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/feign/AdminFeignClient.java index 8642a823d..bd4f5e5c6 100644 --- a/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/feign/AdminFeignClient.java +++ b/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/feign/AdminFeignClient.java @@ -28,7 +28,7 @@ public interface AdminFeignClient { /** * @param userSysDeptInfoFormDTO - * @return com.elink.esua.epdc.commons.tools.utils.Result> + * @return com.elink.esua.epdc.commons.tools.utils.Result> * @Author yinzuomei * @Description 获取用户数据权限下各部门基本信息 * @Date 2019/12/6 19:40 @@ -66,4 +66,19 @@ public interface AdminFeignClient { */ @GetMapping("/sys/dept/listAllGridId") Result> listAllGridId(); + + /** + * 按部门类型,分页查询部门列表 + * + * @param typeKey 部门类型 + * @param pageSize 页容量 + * @param pageIndex 页码 + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @author work@yujt.net.cn + * @date 2019/12/17 16:03 + */ + @GetMapping("/sys/dept/pageDeptIdByTypeKey/{typeKey}/{pageSize}/{pageIndex}") + Result> pageDeptIdByTypeKey(@PathVariable("typeKey") String typeKey, + @PathVariable("pageSize") Integer pageSize, + @PathVariable("pageIndex") Integer pageIndex); } diff --git a/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/feign/fallback/AdminFeignClientFallback.java b/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/feign/fallback/AdminFeignClientFallback.java index a9be3bfcf..a62df24c6 100644 --- a/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/feign/fallback/AdminFeignClientFallback.java +++ b/esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/feign/fallback/AdminFeignClientFallback.java @@ -19,52 +19,56 @@ import java.util.List; */ @Component public class AdminFeignClientFallback implements AdminFeignClient { - /** - * @param userSysDeptInfoFormDTO - * @return com.elink.esua.epdc.commons.tools.utils.Result> - * @Author yinzuomei - * @Description - * @Date 2019/12/6 20:15 - **/ - @Override - public Result> queryUserSysDeptInfo(UserSysDeptInfoFormDTO userSysDeptInfoFormDTO) { - return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "queryUserSysDeptInfo", userSysDeptInfoFormDTO); - } + /** + * @param userSysDeptInfoFormDTO + * @return com.elink.esua.epdc.commons.tools.utils.Result> + * @Author yinzuomei + * @Description + * @Date 2019/12/6 20:15 + **/ + @Override + public Result> queryUserSysDeptInfo(UserSysDeptInfoFormDTO userSysDeptInfoFormDTO) { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "queryUserSysDeptInfo", userSysDeptInfoFormDTO); + } - /** - * @param deptId - * @return com.elink.esua.epdc.commons.tools.utils.Result - * @Author yinzuomei - * @Description 根据部门ID获取上级所有部门信息 - * @Date 2019/12/6 19:49 - **/ - @Override - public Result getParentAndAllDept(String deptId) { - return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "getParentAndAllDept", deptId); - } + /** + * @param deptId + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @Author yinzuomei + * @Description 根据部门ID获取上级所有部门信息 + * @Date 2019/12/6 19:49 + **/ + @Override + public Result getParentAndAllDept(String deptId) { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "getParentAndAllDept", deptId); + } - /** - * @param id - * @return com.elink.esua.epdc.commons.tools.utils.Result - * @Author yinzuomei - * @Description 根据部门id获取部门信息 - * @Date 2019/12/6 20:22 - **/ - @Override - public Result getSysDeptDTO(Long id) { - return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "getSysDeptDTO", id); - } + /** + * @param id + * @return com.elink.esua.epdc.commons.tools.utils.Result + * @Author yinzuomei + * @Description 根据部门id获取部门信息 + * @Date 2019/12/6 20:22 + **/ + @Override + public Result getSysDeptDTO(Long id) { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "getSysDeptDTO", id); + } - /*** - * 获取所有网格 - * @param - * @return com.elink.esua.epdc.commons.tools.utils.Result> - * @author qushutong - * @date 2019/12/12 19:03 - */ - @Override - public Result> listAllGridId() { - return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "listAllGridId","1"); - } + /*** + * 获取所有网格 + * @param + * @return com.elink.esua.epdc.commons.tools.utils.Result> + * @author qushutong + * @date 2019/12/12 19:03 + */ + @Override + public Result> listAllGridId() { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "listAllGridId", "1"); + } + @Override + public Result> pageDeptIdByTypeKey(String typeKey, Integer pageSize, Integer pageIndex) { + return ModuleUtils.feignConError(ServiceConstant.EPDC_ADMIN_SERVER, "pageDeptIdByTypeKey", typeKey, pageSize, pageIndex); + } }