|
@@ -215,18 +215,21 @@ public class AgricultureBigDataServiceImpl extends BaseServiceImpl implements IA
|
|
|
* @return
|
|
|
*/
|
|
|
private List<Map<String, Object>> getMaps(AgricultureBigDataBO agricultureBigDataBO, List<Map<String, Object>> list) {
|
|
|
- if (list == null || list.isEmpty()) {
|
|
|
- HashMap<String, Object> objectObjectHashMap = new HashMap<>();
|
|
|
- objectObjectHashMap.put("ancestors", 0);
|
|
|
- objectObjectHashMap.put("deptId", 0);
|
|
|
- objectObjectHashMap.put("salesVolumeNum", 0);
|
|
|
- objectObjectHashMap.put("stockNum", 0);
|
|
|
- list.add(objectObjectHashMap);
|
|
|
- }
|
|
|
+ //if (list == null || list.isEmpty()) {
|
|
|
+ // HashMap<String, Object> objectObjectHashMap = new HashMap<>();
|
|
|
+ // objectObjectHashMap.put("ancestors", 0);
|
|
|
+ // objectObjectHashMap.put("deptId", 0);
|
|
|
+ // objectObjectHashMap.put("salesVolumeNum", 0);
|
|
|
+ // objectObjectHashMap.put("stockNum", 0);
|
|
|
+ // list.add(objectObjectHashMap);
|
|
|
+ //}
|
|
|
+ List<String> addKeys = new ArrayList<>();
|
|
|
+ addKeys.add("salesVolumeNum");
|
|
|
+ addKeys.add("stockNum");
|
|
|
if (StringUtils.isNull(agricultureBigDataBO.getDeptId())){
|
|
|
agricultureBigDataBO.setDeptId(SecurityUtils.getLoginUser().getSysUser().getDeptId());
|
|
|
}
|
|
|
- return deptLevelUtil.getDeptLevel(list,String.valueOf(agricultureBigDataBO.getDeptId()));
|
|
|
+ return deptLevelUtil.getDeptLevel(agricultureBigDataBO.getDeptId().toString(), list, addKeys);
|
|
|
}
|
|
|
|
|
|
|
|
@@ -252,17 +255,21 @@ public class AgricultureBigDataServiceImpl extends BaseServiceImpl implements IA
|
|
|
if (StringUtils.isNull(agricultureBigDataBO.getDeptId())){
|
|
|
agricultureBigDataBO.setDeptId(SecurityUtils.getLoginUser().getSysUser().getDeptId());
|
|
|
}
|
|
|
- List<Map<String, Object>> deptLevel = deptLevelUtil.getDeptLevel(currentYearStatistics,String.valueOf(agricultureBigDataBO.getDeptId()));
|
|
|
+ List<String> addKeys = new ArrayList<>();
|
|
|
+ addKeys.add("landAreaNum");
|
|
|
+ addKeys.add("estimatedProductionNum");
|
|
|
+ addKeys.add("actualOutputNum");
|
|
|
+ List<Map<String, Object>> deptLevel = deptLevelUtil.getDeptLevel(agricultureBigDataBO.getDeptId().toString(),currentYearStatistics,addKeys);
|
|
|
// 获取过去五年的数据
|
|
|
for (int i = currentYear - 1; i >= currentYear - 4; i--) {
|
|
|
List<Map<String, Object>> statisticsByYear = getStatisticsByYear(agricultureBigDataBO, String.valueOf(i));
|
|
|
if (StringUtils.isNull(agricultureBigDataBO.getDeptId())){
|
|
|
agricultureBigDataBO.setDeptId(SecurityUtils.getLoginUser().getSysUser().getDeptId());
|
|
|
}
|
|
|
- deptLevel.addAll(deptLevelUtil.getDeptLevel(statisticsByYear,String.valueOf(agricultureBigDataBO.getDeptId())));
|
|
|
+ deptLevel.addAll(deptLevelUtil.getDeptLevel(agricultureBigDataBO.getDeptId().toString(),statisticsByYear,addKeys));
|
|
|
}
|
|
|
// 根据name(年份)进行分组
|
|
|
- return deptLevel.stream().collect(Collectors.groupingBy(map -> (String) map.get("name")));
|
|
|
+ return deptLevel.stream().collect(Collectors.groupingBy(map -> map.get("name").toString()));
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -273,12 +280,7 @@ public class AgricultureBigDataServiceImpl extends BaseServiceImpl implements IA
|
|
|
List<Map<String, Object>> statisticsByYear = agricultureBigDataMapper.getCultivationStatisticsByYear(agricultureBigDataBO, year);
|
|
|
if (statisticsByYear == null || statisticsByYear.isEmpty()) {
|
|
|
Map<String, Object> objectObjectHashMap = new HashMap<>();
|
|
|
- objectObjectHashMap.put("ancestors", 0);
|
|
|
- objectObjectHashMap.put("deptId", 0);
|
|
|
objectObjectHashMap.put("name", year);
|
|
|
- objectObjectHashMap.put("landAreaNum", 0);
|
|
|
- objectObjectHashMap.put("estimatedProductionNum", 0);
|
|
|
- objectObjectHashMap.put("actualOutputNum", 0);
|
|
|
statisticsByYear.add(objectObjectHashMap);
|
|
|
}
|
|
|
return statisticsByYear;
|
|
@@ -295,19 +297,14 @@ public class AgricultureBigDataServiceImpl extends BaseServiceImpl implements IA
|
|
|
public List<Map<String, Object>> getAgriculturalSubsidy(AgricultureBigDataBO agricultureBigDataBO) {
|
|
|
setSookaDataBase(agricultureBigDataBO);
|
|
|
List<Map<String, Object>> agriculturalSubsidy = agricultureBigDataMapper.getAgriculturalSubsidy(agricultureBigDataBO);
|
|
|
- if (agriculturalSubsidy == null || agriculturalSubsidy.isEmpty()) {
|
|
|
- Map<String, Object> objectObjectHashMap = new HashMap<>();
|
|
|
- objectObjectHashMap.put("ancestors", 0);
|
|
|
- objectObjectHashMap.put("deptId", 0);
|
|
|
- objectObjectHashMap.put("subsidyMoneyNum", 0);
|
|
|
- objectObjectHashMap.put("farmMacMoneyNum", 0);
|
|
|
- objectObjectHashMap.put("breedMoneyNum", 0);
|
|
|
- agriculturalSubsidy.add(objectObjectHashMap);
|
|
|
- }
|
|
|
+ List<String> addKeys = new ArrayList<>();
|
|
|
+ addKeys.add("subsidyMoneyNum");
|
|
|
+ addKeys.add("farmMacMoneyNum");
|
|
|
+ addKeys.add("breedMoneyNum");
|
|
|
if (StringUtils.isNull(agricultureBigDataBO.getDeptId())){
|
|
|
agricultureBigDataBO.setDeptId(SecurityUtils.getLoginUser().getSysUser().getDeptId());
|
|
|
}
|
|
|
- return deptLevelUtil.getDeptLevel(agriculturalSubsidy,String.valueOf(agricultureBigDataBO.getDeptId()));
|
|
|
+ return deptLevelUtil.getDeptLevel(agricultureBigDataBO.getDeptId().toString(),agriculturalSubsidy,addKeys);
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -396,12 +393,13 @@ public class AgricultureBigDataServiceImpl extends BaseServiceImpl implements IA
|
|
|
public List<Map<String, Object>> getFarmlandStatistics(AgricultureBigDataBO agricultureBigDataBO) {
|
|
|
setSookaDataBase(agricultureBigDataBO);
|
|
|
Map<String, Object> map = new HashMap<>();
|
|
|
+ List<SysDictData> dictKeys = DictUtils.getDictCache("farm_field_attribute");
|
|
|
map.put("agricultureBigDataBO",agricultureBigDataBO);
|
|
|
- map.put("dictList", DictUtils.getDictCache("farm_field_attribute"));
|
|
|
+ map.put("dictList", dictKeys);
|
|
|
if (StringUtils.isNull(agricultureBigDataBO.getDeptId())){
|
|
|
agricultureBigDataBO.setDeptId(SecurityUtils.getLoginUser().getSysUser().getDeptId());
|
|
|
}
|
|
|
- return deptLevelUtil.getDeptLevel(agricultureBigDataMapper.getFarmlandStatistics(map),String.valueOf(agricultureBigDataBO.getDeptId()));
|
|
|
+ return deptLevelUtil.getDeptLevel(dictKeys,agricultureBigDataMapper.getFarmlandStatistics(map),agricultureBigDataBO.getDeptId().toString());
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -415,39 +413,40 @@ public class AgricultureBigDataServiceImpl extends BaseServiceImpl implements IA
|
|
|
public Map<String,List<Map<String, Object>>> getCooperativesStatistics(AgricultureBigDataBO agricultureBigDataBO) {
|
|
|
setSookaDataBase(agricultureBigDataBO);
|
|
|
Map<String,List<Map<String, Object>>> hashMap = new HashMap<>();
|
|
|
+
|
|
|
// 合作社数量
|
|
|
List<Map<String, Object>> cooperativesStatisticsByCooperatives = agricultureBigDataMapper.getCooperativesStatisticsByCooperatives(agricultureBigDataBO);
|
|
|
if (StringUtils.isNull(agricultureBigDataBO.getDeptId())){
|
|
|
agricultureBigDataBO.setDeptId(SecurityUtils.getLoginUser().getSysUser().getDeptId());
|
|
|
}
|
|
|
- List<Map<String, Object>> cooperativesStatistics = new ArrayList<>(deptLevelUtil.getDeptLevel(cooperativesStatisticsByCooperatives,String.valueOf(agricultureBigDataBO.getDeptId())));
|
|
|
+ List<Map<String, Object>> cooperativesStatistics = new ArrayList<>(deptLevelUtil.getDeptLevel(String.valueOf(agricultureBigDataBO.getDeptId()),cooperativesStatisticsByCooperatives,"num"));
|
|
|
// 示范级别
|
|
|
List<Map<String, Object>> statisticsByLeaseTerm = agricultureBigDataMapper.getCooperativesStatisticsByLeaseTerm(agricultureBigDataBO);
|
|
|
if (StringUtils.isNull(agricultureBigDataBO.getDeptId())){
|
|
|
agricultureBigDataBO.setDeptId(SecurityUtils.getLoginUser().getSysUser().getDeptId());
|
|
|
}
|
|
|
- List<Map<String, Object>> statisticsByLeaseTermList = deptLevelUtil.getDeptLevel(statisticsByLeaseTerm, String.valueOf(agricultureBigDataBO.getDeptId()));
|
|
|
+ List<Map<String, Object>> statisticsByLeaseTermList = deptLevelUtil.getDeptLevel(String.valueOf(agricultureBigDataBO.getDeptId()),statisticsByLeaseTerm,"num");
|
|
|
// 成员出资额
|
|
|
List<Map<String, Object>> statisticsByRegisterCapital = agricultureBigDataMapper.getCooperativesStatisticsByRegisterCapital(agricultureBigDataBO);
|
|
|
int registerCapitalSum = getStatisticsSum(statisticsByRegisterCapital);
|
|
|
if (StringUtils.isNull(agricultureBigDataBO.getDeptId())){
|
|
|
agricultureBigDataBO.setDeptId(SecurityUtils.getLoginUser().getSysUser().getDeptId());
|
|
|
}
|
|
|
- List<Map<String, Object>> statisticsByRegisterCapitalList = deptLevelUtil.getDeptLevel(statisticsByRegisterCapital, String.valueOf(agricultureBigDataBO.getDeptId()));
|
|
|
+ List<Map<String, Object>> statisticsByRegisterCapitalList = deptLevelUtil.getDeptLevel(String.valueOf(agricultureBigDataBO.getDeptId()),statisticsByRegisterCapital,"num");
|
|
|
// 入社人员
|
|
|
List<Map<String, Object>> statisticsByMembersNum = agricultureBigDataMapper.getCooperativesStatisticsByMembersNum(agricultureBigDataBO);
|
|
|
int membersNumSum = getStatisticsSum(statisticsByMembersNum);
|
|
|
if (StringUtils.isNull(agricultureBigDataBO.getDeptId())){
|
|
|
agricultureBigDataBO.setDeptId(SecurityUtils.getLoginUser().getSysUser().getDeptId());
|
|
|
}
|
|
|
- List<Map<String, Object>> statisticsByMembersNumList = deptLevelUtil.getDeptLevel(statisticsByMembersNum, String.valueOf(agricultureBigDataBO.getDeptId()));
|
|
|
+ List<Map<String, Object>> statisticsByMembersNumList = deptLevelUtil.getDeptLevel(String.valueOf(agricultureBigDataBO.getDeptId()),statisticsByMembersNum,"num");
|
|
|
// 带动农户
|
|
|
List<Map<String, Object>> statisticsByDrivenFarmersNum = agricultureBigDataMapper.getCooperativesStatisticsByDrivenFarmersNum(agricultureBigDataBO);
|
|
|
int drivenFarmersNumSum = getStatisticsSum(statisticsByDrivenFarmersNum);
|
|
|
if (StringUtils.isNull(agricultureBigDataBO.getDeptId())){
|
|
|
agricultureBigDataBO.setDeptId(SecurityUtils.getLoginUser().getSysUser().getDeptId());
|
|
|
}
|
|
|
- List<Map<String, Object>> statisticsByDrivenFarmersNumList = deptLevelUtil.getDeptLevel(statisticsByDrivenFarmersNum, String.valueOf(agricultureBigDataBO.getDeptId()));
|
|
|
+ List<Map<String, Object>> statisticsByDrivenFarmersNumList = deptLevelUtil.getDeptLevel(String.valueOf(agricultureBigDataBO.getDeptId()),statisticsByDrivenFarmersNum, "num");
|
|
|
|
|
|
// 数据分组
|
|
|
for (int i = 0; i <cooperativesStatistics.size();i++){
|
|
@@ -533,16 +532,9 @@ public class AgricultureBigDataServiceImpl extends BaseServiceImpl implements IA
|
|
|
public List<Map<String, Object>> getStrawTurnover(AgricultureBigDataBO agricultureBigDataBO) {
|
|
|
setSookaDataBase(agricultureBigDataBO);
|
|
|
List<Map<String, Object>> strawTurnover = agricultureBigDataMapper.getStrawTurnover(agricultureBigDataBO);
|
|
|
- if (strawTurnover == null || strawTurnover.isEmpty()) {
|
|
|
- Map<String, Object> objectObjectHashMap = new HashMap<>();
|
|
|
- objectObjectHashMap.put("ancestors", 0);
|
|
|
- objectObjectHashMap.put("deptId", 0);
|
|
|
- objectObjectHashMap.put("stillAreaNum", 0);
|
|
|
- strawTurnover.add(objectObjectHashMap);
|
|
|
- }
|
|
|
if (StringUtils.isNull(agricultureBigDataBO.getDeptId())){
|
|
|
agricultureBigDataBO.setDeptId(SecurityUtils.getLoginUser().getSysUser().getDeptId());
|
|
|
}
|
|
|
- return deptLevelUtil.getDeptLevel(strawTurnover,String.valueOf(agricultureBigDataBO.getDeptId()));
|
|
|
+ return deptLevelUtil.getDeptLevel(String.valueOf(agricultureBigDataBO.getDeptId()),strawTurnover,"stillAreaNum");
|
|
|
}
|
|
|
}
|