Browse Source

指数采集 接口开发

dev_shibei_match
zhangyongzhangyong 5 years ago
parent
commit
57909e4ba3
  1. 136
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/FactIndexCollectController.java
  2. 30
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexGovrnAblityDeptMonthlyDao.java
  3. 31
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexGovrnAblityGridMonthlyDao.java
  4. 37
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexGovrnAblityOrgMonthlyDao.java
  5. 31
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexPartyAblityCpcMonthlyDao.java
  6. 31
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexPartyAblityGridMonthlyDao.java
  7. 38
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexPartyAblityOrgMonthlyDao.java
  8. 28
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexServiceAblityGridMonthlyDao.java
  9. 38
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexServiceAblityOrgMonthlyDao.java
  10. 98
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/indexcollect/FactIndexCollectService.java
  11. 132
      epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/indexcollect/impl/FactIndexCollectServiceImpl.java
  12. 55
      epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexGovrnAblityDeptMonthlyDao.xml
  13. 59
      epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexGovrnAblityGridMonthlyDao.xml
  14. 60
      epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexGovrnAblityOrgMonthlyDao.xml
  15. 67
      epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexPartyAblityCpcMonthlyDao.xml
  16. 70
      epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexPartyAblityGridMonthlyDao.xml
  17. 53
      epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexPartyAblityOrgMonthlyDao.xml
  18. 50
      epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexServiceAblityGridMonthlyDao.xml
  19. 52
      epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexServiceAblityOrgMonthlyDao.xml

136
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/controller/FactIndexCollectController.java

@ -1,10 +1,18 @@
package com.epmet.controller;
import com.epmet.commons.extappauth.annotation.ExternalAppRequestAuth;
import com.epmet.commons.extappauth.bean.ExternalAppRequestParam;
import com.epmet.commons.tools.utils.Result;
import com.epmet.dto.indexcollect.form.*;
import com.epmet.service.indexcollect.FactIndexCollectService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* 指标采集相关api
*
@ -17,4 +25,132 @@ public class FactIndexCollectController {
@Autowired
private FactIndexCollectService factIndexCollectService;
/**
* 1党建能力-党员相关指标上报(按照月份)
*
* @param externalAppRequestParam
* @param formDTO
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
@ExternalAppRequestAuth
@PostMapping("gridpartymemberdata")
public Result gridPartyMemberData(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<GridPartyMemberDataFormDTO> formDTO) {
factIndexCollectService.insertGridPartyMemberData(formDTO, externalAppRequestParam.getCustomerId());
return new Result();
}
/**
* 2党建能力-网格相关指标上报(按照月份)
*
* @param externalAppRequestParam
* @param formDTO
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
@ExternalAppRequestAuth
@PostMapping("gridpartyability")
public Result gridPartyAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<GridPartyAbilityFormDTO> formDTO) {
factIndexCollectService.insertGridPartyAbility(formDTO, externalAppRequestParam.getCustomerId());
return new Result();
}
/**
* 3党建能力-街道及社区相关指标
*
* @param externalAppRequestParam
* @param formDTO
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
@ExternalAppRequestAuth
@PostMapping("orgpartyability")
public Result orgPartyAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<OrgPartyAbilityFormDTO> formDTO) {
factIndexCollectService.insertOrgPartyAbility(formDTO, externalAppRequestParam.getCustomerId());
return new Result();
}
/**
* 4服务能力-网格相关指标
*
* @param externalAppRequestParam
* @param formDTO
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
@ExternalAppRequestAuth
@PostMapping("gridserviceability")
public Result gridServiceAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<GridServiceAbilityFormDTO> formDTO) {
factIndexCollectService.insertGridServiceAbility(formDTO, externalAppRequestParam.getCustomerId());
return new Result();
}
/**
* 5服务能力-组织街道|社区|全区相关指标
*
* @param externalAppRequestParam
* @param formDTO
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
@ExternalAppRequestAuth
@PostMapping("orgserviceability")
public Result orgServiceAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<OrgServiceAbilityFormDTO> formDTO) {
factIndexCollectService.insertOrgServiceAbility(formDTO, externalAppRequestParam.getCustomerId());
return new Result();
}
/**
* 6治理能力-网格相关指标
*
* @param externalAppRequestParam
* @param formDTO
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
@ExternalAppRequestAuth
@PostMapping("gridgovrnability")
public Result gridGovrnAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<GridGovrnAbilityFormDTO> formDTO) {
factIndexCollectService.insertGridGovrnAbility(formDTO, externalAppRequestParam.getCustomerId());
return new Result();
}
/**
* 7治理能力-街道及社区相关指标
*
* @param externalAppRequestParam
* @param formDTO
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
@ExternalAppRequestAuth
@PostMapping("orggovrnability")
public Result orgGovrnAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<OrgGovrnAbilityFormDTO> formDTO) {
factIndexCollectService.insertOrgGovrnAbility(formDTO, externalAppRequestParam.getCustomerId());
return new Result();
}
/**
* 8治理能力-部门相关指标
*
* @param externalAppRequestParam
* @param formDTO
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
@ExternalAppRequestAuth
@PostMapping("deptgovrnability")
public Result deptGovrnAbility(ExternalAppRequestParam externalAppRequestParam, @RequestBody List<DeptGovrnAbilityFormDTO> formDTO) {
factIndexCollectService.insertDeptGovrnAbility(formDTO, externalAppRequestParam.getCustomerId());
return new Result();
}
}

30
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexGovrnAblityDeptMonthlyDao.java

@ -17,16 +17,40 @@ package com.epmet.dao.indexcoll; /**
import com.epmet.commons.mybatis.dao.BaseDao;
import com.epmet.dto.indexcollect.form.DeptGovrnAbilityFormDTO;
import com.epmet.entity.indexcoll.FactIndexGovrnAblityDeptMonthlyEntity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 治理能力-部门相关数据
* 治理能力-部门相关数据
*
* @author generator generator@elink-cn.com
* @since v1.0.0 2020-08-20
*/
@Mapper
public interface FactIndexGovrnAblityDeptMonthlyDao extends BaseDao<FactIndexGovrnAblityDeptMonthlyEntity> {
}
/**
* 8治理能力-部门相关指标
* 据CUSTOMER_IDAGENCY_IDDEPT_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void deleteFactIndexGovrnAblityDeptMonthly(DeptGovrnAbilityFormDTO formDTO, @Param("customerId") String customerId);
/**
* 8治理能力-部门相关指标
* 2) 在批量新增
*
* @param list
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void batchInsertFactIndexGovrnAblityDeptMonthly(@Param("list") List<DeptGovrnAbilityFormDTO> list, @Param("customerId")String customerId);
}

31
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexGovrnAblityGridMonthlyDao.java

@ -18,16 +18,41 @@
package com.epmet.dao.indexcoll;
import com.epmet.commons.mybatis.dao.BaseDao;
import com.epmet.dto.indexcollect.form.GridGovrnAbilityFormDTO;
import com.epmet.entity.indexcoll.FactIndexGovrnAblityGridMonthlyEntity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 治理能力-网格相关事实表
* 治理能力-网格相关事实表
*
* @author generator generator@elink-cn.com
* @since v1.0.0 2020-08-20
*/
@Mapper
public interface FactIndexGovrnAblityGridMonthlyDao extends BaseDao<FactIndexGovrnAblityGridMonthlyEntity> {
}
/**
* 6治理能力-网格相关指标
* 根据CUSTOMER_IDAGENCY_IDGRID_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void deleteFactIndexGovrnAblityGridMonthly(GridGovrnAbilityFormDTO formDTO, @Param("customerId") String customerId);
/**
* 6治理能力-网格相关指标
* 2) 在批量新增
*
* @param list
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void batchInsertFactIndexGovrnAblityGridMonthly(@Param("list") List<GridGovrnAbilityFormDTO> list, @Param("customerId")String customerId);
}

37
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexGovrnAblityOrgMonthlyDao.java

@ -18,16 +18,47 @@
package com.epmet.dao.indexcoll;
import com.epmet.commons.mybatis.dao.BaseDao;
import com.epmet.dto.indexcollect.form.OrgGovrnAbilityFormDTO;
import com.epmet.entity.indexcoll.FactIndexGovrnAblityOrgMonthlyEntity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 治理能力-街道及社区相关数据
* 治理能力-街道及社区相关数据
*
* @author generator generator@elink-cn.com
* @since v1.0.0 2020-08-20
*/
@Mapper
public interface FactIndexGovrnAblityOrgMonthlyDao extends BaseDao<FactIndexGovrnAblityOrgMonthlyEntity> {
}
/**
* 7治理能力-街道及社区相关指标
* 据CUSTOMER_IDAGENCY_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param customerId
* @param yearId
* @param monthId
* @param quarterId
* @param agencyIds
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void deleteFactIndexGovrnAblityOrgMonthly(@Param("customerId") String customerId,
@Param("yearId") String yearId,
@Param("monthId") String monthId,
@Param("quarterId") String quarterId,
@Param("agencyIds") String[] agencyIds);
/**
* 7治理能力-街道及社区相关指标
* 2) 在批量新增
*
* @param list
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void batchInsertFactIndexGovrnAblityOrgMonthly(@Param("list") List<OrgGovrnAbilityFormDTO> list, @Param("customerId")String customerId);
}

31
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexPartyAblityCpcMonthlyDao.java

@ -18,16 +18,41 @@
package com.epmet.dao.indexcoll;
import com.epmet.commons.mybatis.dao.BaseDao;
import com.epmet.dto.indexcollect.form.GridPartyMemberDataFormDTO;
import com.epmet.entity.indexcoll.FactIndexPartyAblityCpcMonthlyEntity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 党建能力-党员相关的事实表
* 党建能力-党员相关的事实表
*
* @author generator generator@elink-cn.com
* @since v1.0.0 2020-08-20
*/
@Mapper
public interface FactIndexPartyAblityCpcMonthlyDao extends BaseDao<FactIndexPartyAblityCpcMonthlyEntity> {
}
/**
* 1党建能力-党员相关指标上报(按照月份)
* 1) 根据CUSTOMER_IDAGENCY_IDGRID_IDUSER_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void deleteFactIndexPartyAblityCpcMonthly(GridPartyMemberDataFormDTO formDTO, @Param("customerId") String customerId);
/**
* 1党建能力-党员相关指标上报(按照月份)
* 2) 在批量新增
*
* @param list
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void batchInsertFactIndexPartyAblityCpcMonthly(@Param("list") List<GridPartyMemberDataFormDTO> list, @Param("customerId")String customerId);
}

31
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexPartyAblityGridMonthlyDao.java

@ -18,16 +18,41 @@
package com.epmet.dao.indexcoll;
import com.epmet.commons.mybatis.dao.BaseDao;
import com.epmet.dto.indexcollect.form.GridPartyAbilityFormDTO;
import com.epmet.entity.indexcoll.FactIndexPartyAblityGridMonthlyEntity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 党建能力-网格相关事实表
* 党建能力-网格相关事实表
*
* @author generator generator@elink-cn.com
* @since v1.0.0 2020-08-20
*/
@Mapper
public interface FactIndexPartyAblityGridMonthlyDao extends BaseDao<FactIndexPartyAblityGridMonthlyEntity> {
}
/**
* 2党建能力-网格相关指标上报(按照月份)
* 1) 根据CUSTOMER_IDAGENCY_IDGRID_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void deleteFactIndexPartyAblityGridMonthly(GridPartyAbilityFormDTO formDTO, @Param("customerId") String customerId);
/**
* 2党建能力-网格相关指标上报(按照月份)
* 2) 在批量新增
*
* @param list
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void batchInsertFactIndexPartyAblityGridMonthly(@Param("list") List<GridPartyAbilityFormDTO> list, @Param("customerId")String customerId);
}

38
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexPartyAblityOrgMonthlyDao.java

@ -18,16 +18,48 @@
package com.epmet.dao.indexcoll;
import com.epmet.commons.mybatis.dao.BaseDao;
import com.epmet.dto.indexcollect.form.OrgPartyAbilityFormDTO;
import com.epmet.entity.indexcoll.FactIndexPartyAblityOrgMonthlyEntity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 党建能力-街道及社区相关事实表
* 党建能力-街道及社区相关事实表
*
* @author generator generator@elink-cn.com
* @since v1.0.0 2020-08-20
*/
@Mapper
public interface FactIndexPartyAblityOrgMonthlyDao extends BaseDao<FactIndexPartyAblityOrgMonthlyEntity> {
}
/**
* 3党建能力-街道及社区相关指标
* 根据CUSTOMER_IDAGENCY_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param customerId
* @param yearId
* @param monthId
* @param quarterId
* @param agencyIds
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void deleteFactIndexPartyAblityOrgMonthly(@Param("customerId") String customerId,
@Param("yearId") String yearId,
@Param("monthId") String monthId,
@Param("quarterId") String quarterId,
@Param("agencyIds") String[] agencyIds);
/**
* 3党建能力-街道及社区相关指标
* 2) 在批量新增
*
* @param list
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void batchInsertFactIndexPartyAblityOrgMonthly(@Param("list") List<OrgPartyAbilityFormDTO> list, @Param("customerId")String customerId);
}

28
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexServiceAblityGridMonthlyDao.java

@ -18,8 +18,12 @@
package com.epmet.dao.indexcoll;
import com.epmet.commons.mybatis.dao.BaseDao;
import com.epmet.dto.indexcollect.form.GridServiceAbilityFormDTO;
import com.epmet.entity.indexcoll.FactIndexServiceAblityGridMonthlyEntity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 服务能力-网格相关事实表
@ -29,5 +33,25 @@ import org.apache.ibatis.annotations.Mapper;
*/
@Mapper
public interface FactIndexServiceAblityGridMonthlyDao extends BaseDao<FactIndexServiceAblityGridMonthlyEntity> {
}
/**
* 4服务能力-网格相关指标
* 根据CUSTOMER_IDAGENCY_IDGRID_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void deleteFactIndexServiceAblityGridMonthly(GridServiceAbilityFormDTO formDTO, @Param("customerId") String customerId);
/**
* 4服务能力-网格相关指标
* 2) 在批量新增
*
* @param list
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void batchInsertFactIndexServiceAblityGridMonthly(@Param("list") List<GridServiceAbilityFormDTO> list, @Param("customerId")String customerId);
}

38
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/indexcoll/FactIndexServiceAblityOrgMonthlyDao.java

@ -18,16 +18,48 @@
package com.epmet.dao.indexcoll;
import com.epmet.commons.mybatis.dao.BaseDao;
import com.epmet.dto.indexcollect.form.OrgServiceAbilityFormDTO;
import com.epmet.entity.indexcoll.FactIndexServiceAblityOrgMonthlyEntity;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import java.util.List;
/**
* 服务能力-组织街道|社区|全区相关事实表
* 服务能力-组织街道|社区|全区相关事实表
*
* @author generator generator@elink-cn.com
* @since v1.0.0 2020-08-20
*/
@Mapper
public interface FactIndexServiceAblityOrgMonthlyDao extends BaseDao<FactIndexServiceAblityOrgMonthlyEntity> {
}
/**
* 5服务能力-组织街道|社区|全区相关指标
* 根据CUSTOMER_IDAGENCY_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param customerId
* @param yearId
* @param monthId
* @param quarterId
* @param agencyIds
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void deleteFactIndexServiceAblityOrgMonthly(@Param("customerId") String customerId,
@Param("yearId") String yearId,
@Param("monthId") String monthId,
@Param("quarterId") String quarterId,
@Param("agencyIds") String[] agencyIds);
/**
* 5服务能力-组织街道|社区|全区相关指标
* 2) 在批量新增
*
* @param list
* @param customerId
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void batchInsertFactIndexServiceAblityOrgMonthly(@Param("list") List<OrgServiceAbilityFormDTO> list, @Param("customerId")String customerId);
}

98
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/indexcollect/FactIndexCollectService.java

@ -1,5 +1,9 @@
package com.epmet.service.indexcollect;
import com.epmet.dto.indexcollect.form.*;
import java.util.List;
/**
* 大屏数据采集api
*
@ -8,5 +12,99 @@ package com.epmet.service.indexcollect;
*/
public interface FactIndexCollectService {
/**
* 1党建能力-党员相关指标上报(按照月份)
* 根据CUSTOMER_IDAGENCY_IDGRID_IDUSER_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void insertGridPartyMemberData(List<GridPartyMemberDataFormDTO> formDTO, String customerId);
/**
* 2党建能力-网格相关指标上报(按照月份)
* 根据CUSTOMER_IDAGENCY_IDGRID_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void insertGridPartyAbility(List<GridPartyAbilityFormDTO> formDTO, String customerId);
/**
* 3党建能力-街道及社区相关指标
* 根据CUSTOMER_IDAGENCY_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void insertOrgPartyAbility(List<OrgPartyAbilityFormDTO> formDTO, String customerId);
/**
* 4服务能力-网格相关指标
* 据CUSTOMER_IDAGENCY_IDGRID_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void insertGridServiceAbility(List<GridServiceAbilityFormDTO> formDTO, String customerId);
/**
* 5服务能力-组织街道|社区|全区相关指标
* 据CUSTOMER_IDAGENCY_IDGRID_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void insertOrgServiceAbility(List<OrgServiceAbilityFormDTO> formDTO, String customerId);
/**
* 6治理能力-网格相关指标
* 据CUSTOMER_IDAGENCY_IDGRID_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void insertGridGovrnAbility(List<GridGovrnAbilityFormDTO> formDTO, String customerId);
/**
* 7治理能力-街道及社区相关指标
* 据CUSTOMER_IDAGENCY_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void insertOrgGovrnAbility(List<OrgGovrnAbilityFormDTO> formDTO, String customerId);
/**
* 8治理能力-部门相关指标
* 据CUSTOMER_IDAGENCY_IDDEPT_IDYEAR_IDMONTH_IDQUARTER_ID进行查询如果有数据则先进行物理删除
*
* @param formDTO
* @param customerId
* @return com.epmet.commons.tools.utils.Result
* @Author zhangyong
* @Date 10:52 2020-08-20
**/
void insertDeptGovrnAbility(List<DeptGovrnAbilityFormDTO> formDTO, String customerId);
}

132
epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/indexcollect/impl/FactIndexCollectServiceImpl.java

@ -1,10 +1,142 @@
package com.epmet.service.indexcollect.impl;
import com.epmet.commons.tools.constant.NumConstant;
import com.epmet.dao.indexcoll.*;
import com.epmet.dto.indexcollect.form.*;
import com.epmet.service.indexcollect.FactIndexCollectService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
/**
* @Auther: zhangyong
* @Date: 2020-08-20 10:05
*/
@Service
public class FactIndexCollectServiceImpl implements FactIndexCollectService {
@Autowired
private FactIndexPartyAblityCpcMonthlyDao factIndexPartyAblityCpcMonthlyDao;
@Autowired
private FactIndexPartyAblityGridMonthlyDao factIndexPartyAblityGridMonthlyDao;
@Autowired
private FactIndexPartyAblityOrgMonthlyDao factIndexPartyAblityOrgMonthlyDao;
@Autowired
private FactIndexServiceAblityGridMonthlyDao factIndexServiceAblityGridMonthlyDao;
@Autowired
private FactIndexServiceAblityOrgMonthlyDao factIndexServiceAblityOrgMonthlyDao;
@Autowired
private FactIndexGovrnAblityGridMonthlyDao factIndexGovrnAblityGridMonthlyDao;
@Autowired
private FactIndexGovrnAblityOrgMonthlyDao factIndexGovrnAblityOrgMonthlyDao;
@Autowired
private FactIndexGovrnAblityDeptMonthlyDao factIndexGovrnAblityDeptMonthlyDao;
@Override
@Transactional(rollbackFor = Exception.class)
public void insertGridPartyMemberData(List<GridPartyMemberDataFormDTO> formDTO, String customerId) {
if (null != formDTO && formDTO.size() > NumConstant.ZERO){
for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
factIndexPartyAblityCpcMonthlyDao.deleteFactIndexPartyAblityCpcMonthly(formDTO.get(i), customerId);
}
factIndexPartyAblityCpcMonthlyDao.batchInsertFactIndexPartyAblityCpcMonthly(formDTO, customerId);
}
}
@Override
@Transactional(rollbackFor = Exception.class)
public void insertGridPartyAbility(List<GridPartyAbilityFormDTO> formDTO, String customerId) {
if (null != formDTO && formDTO.size() > NumConstant.ZERO){
for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
factIndexPartyAblityGridMonthlyDao.deleteFactIndexPartyAblityGridMonthly(formDTO.get(i), customerId);
}
factIndexPartyAblityGridMonthlyDao.batchInsertFactIndexPartyAblityGridMonthly(formDTO, customerId);
}
}
@Override
@Transactional(rollbackFor = Exception.class)
public void insertOrgPartyAbility(List<OrgPartyAbilityFormDTO> formDTO, String customerId) {
if (null != formDTO && formDTO.size() > NumConstant.ZERO){
String[] agencyIds = new String[formDTO.size()];
for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
agencyIds[i] = formDTO.get(i).getAgencyId();
}
factIndexPartyAblityOrgMonthlyDao.deleteFactIndexPartyAblityOrgMonthly(customerId,
formDTO.get(NumConstant.ZERO).getYearId(),
formDTO.get(NumConstant.ZERO).getMonthId(),
formDTO.get(NumConstant.ZERO).getQuarterId(),
agencyIds);
factIndexPartyAblityOrgMonthlyDao.batchInsertFactIndexPartyAblityOrgMonthly(formDTO, customerId);
}
}
@Override
@Transactional(rollbackFor = Exception.class)
public void insertGridServiceAbility(List<GridServiceAbilityFormDTO> formDTO, String customerId) {
if (null != formDTO && formDTO.size() > NumConstant.ZERO){
for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
factIndexServiceAblityGridMonthlyDao.deleteFactIndexServiceAblityGridMonthly(formDTO.get(i), customerId);
}
factIndexServiceAblityGridMonthlyDao.batchInsertFactIndexServiceAblityGridMonthly(formDTO, customerId);
}
}
@Override
@Transactional(rollbackFor = Exception.class)
public void insertOrgServiceAbility(List<OrgServiceAbilityFormDTO> formDTO, String customerId) {
if (null != formDTO && formDTO.size() > NumConstant.ZERO){
String[] agencyIds = new String[formDTO.size()];
for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
agencyIds[i] = formDTO.get(i).getAgencyId();
}
factIndexServiceAblityOrgMonthlyDao.deleteFactIndexServiceAblityOrgMonthly(customerId,
formDTO.get(NumConstant.ZERO).getYearId(),
formDTO.get(NumConstant.ZERO).getMonthId(),
formDTO.get(NumConstant.ZERO).getQuarterId(),
agencyIds);
factIndexServiceAblityOrgMonthlyDao.batchInsertFactIndexServiceAblityOrgMonthly(formDTO, customerId);
}
}
@Override
@Transactional(rollbackFor = Exception.class)
public void insertGridGovrnAbility(List<GridGovrnAbilityFormDTO> formDTO, String customerId) {
if (null != formDTO && formDTO.size() > NumConstant.ZERO){
for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
factIndexGovrnAblityGridMonthlyDao.deleteFactIndexGovrnAblityGridMonthly(formDTO.get(i), customerId);
}
factIndexGovrnAblityGridMonthlyDao.batchInsertFactIndexGovrnAblityGridMonthly(formDTO, customerId);
}
}
@Override
@Transactional(rollbackFor = Exception.class)
public void insertOrgGovrnAbility(List<OrgGovrnAbilityFormDTO> formDTO, String customerId) {
if (null != formDTO && formDTO.size() > NumConstant.ZERO){
String[] agencyIds = new String[formDTO.size()];
for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
agencyIds[i] = formDTO.get(i).getAgencyId();
}
factIndexGovrnAblityOrgMonthlyDao.deleteFactIndexGovrnAblityOrgMonthly(customerId,
formDTO.get(NumConstant.ZERO).getYearId(),
formDTO.get(NumConstant.ZERO).getMonthId(),
formDTO.get(NumConstant.ZERO).getQuarterId(),
agencyIds);
factIndexGovrnAblityOrgMonthlyDao.batchInsertFactIndexGovrnAblityOrgMonthly(formDTO, customerId);
}
}
@Override
@Transactional(rollbackFor = Exception.class)
public void insertDeptGovrnAbility(List<DeptGovrnAbilityFormDTO> formDTO, String customerId) {
if (null != formDTO && formDTO.size() > NumConstant.ZERO){
for (int i = NumConstant.ZERO; i < formDTO.size(); i++){
factIndexGovrnAblityDeptMonthlyDao.deleteFactIndexGovrnAblityDeptMonthly(formDTO.get(i), customerId);
}
factIndexGovrnAblityDeptMonthlyDao.batchInsertFactIndexGovrnAblityDeptMonthly(formDTO, customerId);
}
}
}

55
epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexGovrnAblityDeptMonthlyDao.xml

@ -25,5 +25,58 @@
<result property="updatedTime" column="UPDATED_TIME"/>
</resultMap>
<delete id="deleteFactIndexGovrnAblityDeptMonthly">
delete from fact_index_govrn_ablity_dept_monthly
where CUSTOMER_ID = #{customerId} AND AGENCY_ID = #{agencyId} AND DEPT_ID = #{deptId}
AND YEAR_ID = #{yearId} AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId}
</delete>
</mapper>
<insert id="batchInsertFactIndexGovrnAblityDeptMonthly" parameterType="map">
insert into fact_index_govrn_ablity_dept_monthly
(
ID,
CUSTOMER_ID,
AGENCY_ID,
DEPT_ID,
MONTH_ID,
QUARTER_ID,
YEAR_ID,
TRANSFERED_COUNT,
CLOSED_PROJECT_COUNT,
RESP_PROJECT_RATIO,
HANDLE_PROJECT_RATIO,
CLOSED_PROJECT_RATIO,
SATISFACTION_RATIO,
DEL_FLAG,
REVISION,
CREATED_BY,
CREATED_TIME,
UPDATED_BY,
UPDATED_TIME
) values
<foreach collection="list" item="item" index="index" separator=",">
(
(SELECT REPLACE(UUID(), '-', '') AS id),
#{customerId},
#{item.agencyId},
#{item.deptId},
#{item.monthId},
#{item.quarterId},
#{item.yearId},
#{item.transferedCount},
#{item.closedProjectCount},
#{item.respProjectRatio},
#{item.handleProjectRatio},
#{item.closedProjectRatio},
#{item.satisfactionRatio},
0,
0,
'APP_USER',
now(),
'APP_USER',
now()
)
</foreach>
</insert>
</mapper>

59
epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexGovrnAblityGridMonthlyDao.xml

@ -27,5 +27,62 @@
<result property="updatedTime" column="UPDATED_TIME"/>
</resultMap>
<delete id="deleteFactIndexGovrnAblityGridMonthly">
delete from fact_index_govrn_ablity_grid_monthly
where CUSTOMER_ID = #{customerId} AND AGENCY_ID = #{agencyId} AND GRID_ID = #{gridId} AND USER_ID = #{userId}
AND YEAR_ID = #{yearId} AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId}
</delete>
</mapper>
<insert id="batchInsertFactIndexGovrnAblityGridMonthly" parameterType="map">
insert into fact_index_govrn_ablity_grid_monthly
(
ID,
CUSTOMER_ID,
AGENCY_ID,
GRID_ID,
MONTH_ID,
QUARTER_ID,
YEAR_ID,
ISSUE_TOTAL,
AVG_ISSUE_COUNT,
AVG_SHIFT_PROJECT_RATIO,
PROJECT_TOTAL,
SELF_SOLVE_PROJECT_COUNT,
RESOLVE_PROJECT_COUNT,
TRANSFER_RIGHT_RATIO,
SATISFACTION_RATIO,
DEL_FLAG,
REVISION,
CREATED_BY,
CREATED_TIME,
UPDATED_BY,
UPDATED_TIME
) values
<foreach collection="list" item="item" index="index" separator=",">
(
(SELECT REPLACE(UUID(), '-', '') AS id),
#{customerId},
#{item.agencyId},
#{item.gridId},
#{item.monthId},
#{item.quarterId},
#{item.yearId},
#{item.issueTotal},
#{item.avgIssueCount},
#{item.avgShiftProjectRatio},
#{item.projectTotal},
#{item.selfSolveProjectCount},
#{item.resolveProjectCount},
#{item.transferRightRatio},
#{item.satisfactionRatio},
0,
0,
'APP_USER',
now(),
'APP_USER',
now()
)
</foreach>
</insert>
</mapper>

60
epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexGovrnAblityOrgMonthlyDao.xml

@ -26,5 +26,63 @@
<result property="updatedTime" column="UPDATED_TIME"/>
</resultMap>
<delete id="deleteFactIndexGovrnAblityOrgMonthly">
delete from fact_index_govrn_ablity_org_monthly
where CUSTOMER_ID = #{customerId}
AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId} AND YEAR_ID = #{yearId}
AND AGENCY_ID IN
<foreach item="item" collection="agencyIds" open="(" separator="," close=")">
#{item}
</foreach>
</delete>
</mapper>
<insert id="batchInsertFactIndexGovrnAblityOrgMonthly" parameterType="map">
insert into fact_index_govrn_ablity_org_monthly
(
ID,
CUSTOMER_ID,
AGENCY_ID,
PARENT_ID,
MONTH_ID,
QUARTER_ID,
YEAR_ID,
DATA_TYPE,
TRANSFERED_COUNT,
CLOSED_PROJECT_COUNT,
RESP_PROJECT_RATIO,
CLOSED_PROJECT_RATIO,
SATISFACTION_RATIO,
OVERDUE_PROJECT_RATIO,
DEL_FLAG,
REVISION,
CREATED_BY,
CREATED_TIME,
UPDATED_BY,
UPDATED_TIME
) values
<foreach collection="list" item="item" index="index" separator=",">
(
(SELECT REPLACE(UUID(), '-', '') AS id),
#{customerId},
#{item.agencyId},
#{item.parentId},
#{item.monthId},
#{item.quarterId},
#{item.yearId},
#{item.dataType},
#{item.transferedCount},
#{item.closedProjectCount},
#{item.respProjectRatio},
#{item.closedProjectRatio},
#{item.satisfactionRatio},
#{item.overdueProjectRatio},
0,
0,
'APP_USER',
now(),
'APP_USER',
now()
)
</foreach>
</insert>
</mapper>

67
epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexPartyAblityCpcMonthlyDao.xml

@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.epmet.dao.FactIndexPartyAblityCpcMonthlyDao">
<mapper namespace="com.epmet.dao.indexcoll.FactIndexPartyAblityCpcMonthlyDao">
<resultMap type="com.epmet.entity.indexcoll.FactIndexPartyAblityCpcMonthlyEntity" id="factIndexPartyAblityCpcMonthlyMap">
<result property="id" column="ID"/>
@ -30,5 +30,68 @@
<result property="updatedTime" column="UPDATED_TIME"/>
</resultMap>
<delete id="deleteFactIndexPartyAblityCpcMonthly">
delete from fact_index_party_ablity_cpc_monthly
where CUSTOMER_ID = #{customerId} AND AGENCY_ID = #{agencyId} AND GRID_ID = #{gridId} AND USER_ID = #{userId}
AND YEAR_ID = #{yearId} AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId}
</delete>
</mapper>
<insert id="batchInsertFactIndexPartyAblityCpcMonthly" parameterType="map">
insert into fact_index_party_ablity_cpc_monthly
(
ID,
CUSTOMER_ID,
AGENCY_ID,
PARENT_ID,
GRID_ID,
USER_ID,
MONTH_ID,
QUARTER_ID,
YEAR_ID,
CREATE_TOPIC_COUNT,
JOIN__TOPIC_COUNT,
SHIFT_ISSUE_COUNT,
SHIFT_PROJECT_COUNT,
JOIN_THREE_MEETS_COUNT,
GROUP_USER_COUNT,
GROUP_TOPIC_COUNT,
TOPIC_TO_ISSUE_RATIO,
ISSUE_TO_PROJECT_COUNT,
DEL_FLAG,
REVISION,
CREATED_BY,
CREATED_TIME,
UPDATED_BY,
UPDATED_TIME
) values
<foreach collection="list" item="item" index="index" separator=",">
(
(SELECT REPLACE(UUID(), '-', '') AS id),
#{customerId},
#{item.agencyId},
#{item.parentId},
#{item.gridId},
#{item.userId},
#{item.monthId},
#{item.quarterId},
#{item.yearId},
#{item.createTopicCount},
#{item.joinTopicCount},
#{item.shiftIssueCount},
#{item.shiftProjectCount},
#{item.joinThreeMeetsCount},
#{item.groupUserCount},
#{item.groupTopicCount},
#{item.topicToIssueRatio},
#{item.issueToProjectCount},
0,
0,
'APP_USER',
now(),
'APP_USER',
now()
)
</foreach>
</insert>
</mapper>

70
epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexPartyAblityGridMonthlyDao.xml

@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.epmet.dao.FactIndexPartyAblityGridMonthlyDao">
<mapper namespace="com.epmet.dao.indexcoll.FactIndexPartyAblityGridMonthlyDao">
<resultMap type="com.epmet.entity.indexcoll.FactIndexPartyAblityGridMonthlyEntity" id="factIndexPartyAblityGridMonthlyMap">
<result property="id" column="ID"/>
@ -32,5 +32,71 @@
<result property="updatedTime" column="UPDATED_TIME"/>
</resultMap>
<delete id="deleteFactIndexPartyAblityGridMonthly">
delete from fact_index_party_ablity_grid_monthly
where CUSTOMER_ID = #{customerId} AND AGENCY_ID = #{agencyId} AND GRID_ID = #{gridId}
AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId} AND YEAR_ID = #{yearId}
</delete>
</mapper>
<insert id="batchInsertFactIndexPartyAblityGridMonthly" parameterType="map">
insert into fact_index_party_ablity_grid_monthly
(
ID,
CUSTOMER_ID,
AGENCY_ID,
GRID_ID,
MONTH_ID,
QUARTER_ID,
YEAR_ID,
USER_COUNT,
PARTY_COUNT,
ACTIVE_USER_COUNT,
ACTIVE_PARTY_COUNT,
PARTY_AVG_TOPIC_COUNT,
USER_AVG_TOPIC_COUNT,
PARTY_AVG_SHIFT_PROJECT_COUNT,
USER_AVG_SHIFT_PROJECT_COUNT,
CREATE_GROUP_PARTY_COUNT,
PUBLISH_ARTICLE_COUNT,
ISSUE_TO_PROJECT_RATIO,
CREATE_THREE_MEETS_COUNT,
JOIN_THREE_MEETS_COUNT,
DEL_FLAG,
REVISION,
CREATED_BY,
CREATED_TIME,
UPDATED_BY,
UPDATED_TIME
) values
<foreach collection="list" item="item" index="index" separator=",">
(
(SELECT REPLACE(UUID(), '-', '') AS id),
#{customerId},
#{item.agencyId},
#{item.gridId},
#{item.monthId},
#{item.quarterId},
#{item.yearId},
#{item.userCount},
#{item.partyCount},
#{item.activeUserCount},
#{item.activePartyCount},
#{item.partyAvgTopicCount},
#{item.userAvgTopicCount},
#{item.partyAvgShiftProjectCount},
#{item.userAvgShiftProjectCount},
#{item.createGroupPartyCount},
#{item.publishArticleCount},
#{item.issueToProjectRatio},
#{item.createThreeMeetsCount},
#{item.joinThreeMeetsCount},
0,
0,
'APP_USER',
now(),
'APP_USER',
now()
)
</foreach>
</insert>
</mapper>

53
epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexPartyAblityOrgMonthlyDao.xml

@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.epmet.dao.FactIndexPartyAblityOrgMonthlyDao">
<mapper namespace="com.epmet.dao.indexcoll.FactIndexPartyAblityOrgMonthlyDao">
<resultMap type="com.epmet.entity.indexcoll.FactIndexPartyAblityOrgMonthlyEntity" id="factIndexPartyAblityOrgMonthlyMap">
<result property="id" column="ID"/>
@ -21,5 +21,54 @@
<result property="updatedTime" column="UPDATED_TIME"/>
</resultMap>
<delete id="deleteFactIndexPartyAblityOrgMonthly">
delete from fact_index_party_ablity_org_monthly
where CUSTOMER_ID = #{customerId}
AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId} AND YEAR_ID = #{yearId}
AND AGENCY_ID IN
<foreach item="item" collection="agencyIds" open="(" separator="," close=")">
#{item}
</foreach>
</delete>
</mapper>
<insert id="batchInsertFactIndexPartyAblityOrgMonthly" parameterType="map">
insert into fact_index_party_ablity_org_monthly
(
ID,
CUSTOMER_ID,
AGENCY_ID,
PARENT_ID,
MONTH_ID,
QUARTER_ID,
YEAR_ID,
PUBLISH_ARTICLE_COUNT,
DATA_TYPE,
DEL_FLAG,
REVISION,
CREATED_BY,
CREATED_TIME,
UPDATED_BY,
UPDATED_TIME
) values
<foreach collection="list" item="item" index="index" separator=",">
(
(SELECT REPLACE(UUID(), '-', '') AS id),
#{customerId},
#{item.agencyId},
#{item.parentId},
#{item.monthId},
#{item.quarterId},
#{item.yearId},
#{item.publishArticleCount},
#{item.dataType},
0,
0,
'APP_USER',
now(),
'APP_USER',
now()
)
</foreach>
</insert>
</mapper>

50
epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexServiceAblityGridMonthlyDao.xml

@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.epmet.dao.FactIndexServiceAblityGridMonthlyDao">
<mapper namespace="com.epmet.dao.indexcoll.FactIndexServiceAblityGridMonthlyDao">
<resultMap type="com.epmet.entity.indexcoll.FactIndexServiceAblityGridMonthlyEntity" id="factIndexServiceAblityGridMonthlyMap">
<result property="id" column="ID"/>
@ -22,5 +22,51 @@
<result property="updatedTime" column="UPDATED_TIME"/>
</resultMap>
<delete id="deleteFactIndexServiceAblityGridMonthly">
delete from fact_index_service_ablity_grid_monthly
where CUSTOMER_ID = #{customerId} AND AGENCY_ID = #{agencyId} AND GRID_ID = #{gridId}
AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId} AND YEAR_ID = #{yearId}
</delete>
</mapper>
<insert id="batchInsertFactIndexServiceAblityGridMonthly" parameterType="map">
insert into fact_index_service_ablity_grid_monthly
(
ID,
CUSTOMER_ID,
AGENCY_ID,
GRID_ID,
MONTH_ID,
QUARTER_ID,
YEAR_ID,
ACTIVITY_COUNT,
VOLUNTEER_RATIO,
PARTY_VOLUNTEER_RATIO,
DEL_FLAG,
REVISION,
CREATED_BY,
CREATED_TIME,
UPDATED_BY,
UPDATED_TIME
) values
<foreach collection="list" item="item" index="index" separator=",">
(
(SELECT REPLACE(UUID(), '-', '') AS id),
#{customerId},
#{item.agencyId},
#{item.gridId},
#{item.monthId},
#{item.quarterId},
#{item.yearId},
#{item.activityCount},
#{item.volunteerRatio},
#{item.partyVolunteerRatio},
0,
0,
'APP_USER',
now(),
'APP_USER',
now()
)
</foreach>
</insert>
</mapper>

52
epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/indexcoll/FactIndexServiceAblityOrgMonthlyDao.xml

@ -1,7 +1,7 @@
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.epmet.dao.FactIndexServiceAblityOrgMonthlyDao">
<mapper namespace="com.epmet.dao.indexcoll.FactIndexServiceAblityOrgMonthlyDao">
<resultMap type="com.epmet.entity.indexcoll.FactIndexServiceAblityOrgMonthlyEntity" id="factIndexServiceAblityOrgMonthlyMap">
<result property="id" column="ID"/>
@ -21,5 +21,53 @@
<result property="updatedTime" column="UPDATED_TIME"/>
</resultMap>
<delete id="deleteFactIndexServiceAblityOrgMonthly">
delete from fact_index_service_ablity_org_monthly
where CUSTOMER_ID = #{customerId}
AND MONTH_ID = #{monthId} AND QUARTER_ID = #{quarterId} AND YEAR_ID = #{yearId}
AND AGENCY_ID IN
<foreach item="item" collection="agencyIds" open="(" separator="," close=")">
#{item}
</foreach>
</delete>
</mapper>
<insert id="batchInsertFactIndexServiceAblityOrgMonthly" parameterType="map">
insert into fact_index_service_ablity_org_monthly
(
ID,
CUSTOMER_ID,
AGENCY_ID,
PARENT_ID,
MONTH_ID,
QUARTER_ID,
YEAR_ID,
ACTIVITY_COUNT,
DATA_TYPE,
DEL_FLAG,
REVISION,
CREATED_BY,
CREATED_TIME,
UPDATED_BY,
UPDATED_TIME
) values
<foreach collection="list" item="item" index="index" separator=",">
(
(SELECT REPLACE(UUID(), '-', '') AS id),
#{customerId},
#{item.agencyId},
#{item.parentId},
#{item.monthId},
#{item.quarterId},
#{item.yearId},
#{item.activityCount},
#{item.dataType},
0,
0,
'APP_USER',
now(),
'APP_USER',
now()
)
</foreach>
</insert>
</mapper>

Loading…
Cancel
Save