From db1df079779c4a560e8c4de7ca9b7c96ff9c4428 Mon Sep 17 00:00:00 2001
From: lidongdong <1459917685@qq.com>
Date: 星期二, 16 七月 2024 16:00:29 +0800
Subject: [PATCH] 花城 报道单位统计】这里报错500
---
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java | 174 ++++++++++++++++++++++++++++++++++++++++++++++++---------
1 files changed, 145 insertions(+), 29 deletions(-)
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
index ca3aaf0..58e9eb3 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActNeighborCircleServiceImpl.java
@@ -1145,7 +1145,7 @@
serviceStaticDTO.getYear(), serviceStaticDTO.getServiceType());
- if(serviceStaticDTO.getServiceType()==1 || serviceStaticDTO.getServiceType()==null)
+ if(serviceStaticDTO.getServiceType()==null || serviceStaticDTO.getServiceType()==1)
{
List<NewFightNeedProblemClaim> list=baseMapper.getNewServiceNum("",serviceStaticDTO.getCheckUnitId()+"");
if(list.size()>0)
@@ -1163,21 +1163,23 @@
String Ltime=item.getServiceTime();
if(!StringUtils.isEmpty(Ltime))
{
- double time=(double)(Long.valueOf(Ltime)/3600000);
- hours=hours+(time);
-
- DecimalFormat df = new DecimalFormat("#.00");
+ double time=(Double.valueOf(Ltime)/3600000);
+ DecimalFormat df = new DecimalFormat("#.##");
String formattedNumber = df.format(time);
double result = Double.parseDouble(formattedNumber);
+
+ hours=hours+result;
+
newItem.setServiceTime(result);
item.setServiceTime(result+"");
}
+ newItem.setIsNew("2");
newItem.setServiceId(Long.valueOf(item.getTaskId()));
newItem.setServiceType(1);
newItem.setServiceAt(item.getCreationTime());
serviceDetailStaticsVOList.add(newItem);
}
- DecimalFormat df = new DecimalFormat("#.00");
+ DecimalFormat df = new DecimalFormat("#.##");
String formattedNumber = df.format(hours);
double result = Double.parseDouble(formattedNumber);
serviceStaticsVO.setHours(result);
@@ -1200,8 +1202,7 @@
List<ServiceDetailStaticsVO> serviceDetailStaticsVOList=this.baseMapper.selectServiceDetailListForPersonal(checkUnitId, serviceStaticDTO.getPhone(),
serviceStaticDTO.getYear(), serviceStaticDTO.getServiceType());
-
- if(serviceStaticDTO.getServiceType()==1 || serviceStaticDTO.getServiceType()==null)
+ if(serviceStaticDTO.getServiceType()==null || serviceStaticDTO.getServiceType()==1)
{
//获取新需求服务列表
List<NewFightNeedProblemClaim> list=baseMapper.getNewServiceNum(serviceStaticDTO.getPhone(),"");
@@ -1220,22 +1221,24 @@
String Ltime=item.getServiceTime();
if(!StringUtils.isEmpty(Ltime))
{
- double time=(double)(Long.valueOf(Ltime)/3600000);
-
- hours=hours+(time);
- DecimalFormat df = new DecimalFormat("#.00");
+ double time=(Double.valueOf(Ltime)/3600000);
+ DecimalFormat df = new DecimalFormat("#.##");
String formattedNumber = df.format(time);
double result = Double.parseDouble(formattedNumber);
+
+ hours=hours+result;
+
newItem.setServiceTime(result);
item.setServiceTime(result+"");
}
+ newItem.setIsNew("2");
newItem.setServiceId(Long.valueOf(item.getTaskId()));
newItem.setServiceType(1);
newItem.setServiceAt(item.getCreationTime());
serviceDetailStaticsVOList.add(newItem);
}
- DecimalFormat df = new DecimalFormat("#.00");
+ DecimalFormat df = new DecimalFormat("#.##");
String formattedNumber = df.format(hours);
double result = Double.parseDouble(formattedNumber);
serviceStaticsVO.setHours(result);
@@ -1265,6 +1268,9 @@
List<UnitActivityAnalysisVO> unitActivityAnalysisVOS = comActNeighborCircleDAO.institutionalUnitServiceAnalysis(beginTime, endTime, belongTo,communityId);
//获取单位活动统计数据（活动）
List<UnitActivityAnalysisVO> unitActivityAnalysisVOS1 = comActNeighborCircleDAO.institutionalUnitActivityAnalysis(beginTime, endTime, belongTo,communityId);
+ //获取新双挣双评清单任务
+ List<UnitActivityAnalysisVO> newTaskList=comActNeighborCircleDAO.getNewTaskList(beginTime, endTime, belongTo,communityId);
+
if (unitActivityAnalysisVOS.size()>0){
for (UnitActivityAnalysisVO unitActivityAnalysisVO : unitActivityAnalysisVOS){
if (ObjectUtils.isNotEmpty(unitActivityAnalysisVO)){
@@ -1279,6 +1285,28 @@
}
}
}
+
+ if (newTaskList.size()>0){
+ for (UnitActivityAnalysisVO item : newTaskList){
+ if (ObjectUtils.isNotEmpty(item)){
+ if (ObjectUtils.isNotEmpty(item.getUnitId())){
+ //设置单位名称
+ item.setUnitName(comActDAO.selectUnitName(item.getUnitId()));
+ //统计活动表中的活动信息
+ }
+ if (ObjectUtils.isNotEmpty(item.getCommunityId())){
+ item.setCommunityName(comActDAO.selectById(item.getCommunityId()).getName());
+ }
+
+ Double time=(item.getServiceTime()/3600000);
+ DecimalFormat df = new DecimalFormat("#.##");
+ String formattedNumber = df.format(time);
+ Double result = Double.parseDouble(formattedNumber);
+ item.setServiceTime(result);
+ }
+ }
+ }
+
//活动表数据处理
if (unitActivityAnalysisVOS1.size()>0){
for (UnitActivityAnalysisVO vo : unitActivityAnalysisVOS1) {
@@ -1288,7 +1316,7 @@
Map<String, Integer> param = alreadyAnalysis(vo.getUnitId(), unitActivityAnalysisVOS);
if (param.get("flag")==1){
//已有数据，将时长,次数相加
- Integer serviceTime = vo.getServiceTime();
+ Double serviceTime = vo.getServiceTime();
Integer serviceTimes = vo.getServiceTimes();
unitActivityAnalysisVOS.get(param.get("index")).setServiceTime(unitActivityAnalysisVOS.get(param.get("index")).getServiceTime()+serviceTime);
unitActivityAnalysisVOS.get(param.get("index")).setServiceTimes(unitActivityAnalysisVOS.get(param.get("index")).getServiceTimes()+serviceTimes);
@@ -1309,16 +1337,59 @@
}
}
}
+
+ if (newTaskList.size()>0){
+ for (UnitActivityAnalysisVO item : newTaskList){
+ if (ObjectUtils.isNotEmpty(item)){
+
+ if (ObjectUtils.isNotEmpty(item.getUnitId())){
+ //判断邻里圈统计中是否已有该单位数据
+ Map<String, Integer> param = alreadyAnalysis(item.getUnitId(), unitActivityAnalysisVOS);
+ if (param.get("flag")==1){
+ //已有数据，将时长,次数相加
+ Double serviceTime = unitActivityAnalysisVOS.get(param.get("index")).getServiceTime()+item.getServiceTime();
+ Integer serviceTimes = item.getServiceTimes();
+
+ DecimalFormat df2 = new DecimalFormat("#.##");
+ String formattedNumber2 = df2.format(serviceTimes);
+ Double result2 = Double.parseDouble(formattedNumber2);
+
+ unitActivityAnalysisVOS.get(param.get("index")).setServiceTime(result2);
+ unitActivityAnalysisVOS.get(param.get("index")).setServiceTimes(unitActivityAnalysisVOS.get(param.get("index")).getServiceTimes()+serviceTimes);
+ }else {
+ //新数据，获取单位，社区名
+ item.setUnitName(comActDAO.selectUnitName(item.getUnitId()));
+ if (ObjectUtils.isNotEmpty(item.getCommunityId()))
+ {
+ ComActDO actDO=comActDAO.selectById(item.getCommunityId());
+ if(actDO!=null && !StringUtils.isEmpty(actDO.getName()))
+ {
+ item.setCommunityName(actDO.getName());
+ }
+ }
+
+ unitActivityAnalysisVOS.add(item);
+ }
+ }
+
+ }
+ }
+ }
+
+
+
//获取党员活动统计数据
List<PartyMemberAnalysisVO> partyMemberAnalysisVOS = comActNeighborCircleDAO.institutionalPartyMemberServiceAnalysis(beginTime, endTime, belongTo,communityId,unitId,searchContent);
List<PartyMemberAnalysisVO> partyMemberAnalysisVOS1 = comActNeighborCircleDAO.institutionalPartyMemberActAnalysis(beginTime, endTime, belongTo,communityId,unitId,searchContent);
+ //获取新双挣双评清单任务
+ List<PartyMemberAnalysisVO> newPartyMemberList = comActNeighborCircleDAO.getNewPartyMemberTaskList(beginTime, endTime, belongTo,communityId,unitId,searchContent);
if (partyMemberAnalysisVOS1.size()>0){
for (PartyMemberAnalysisVO vo : partyMemberAnalysisVOS1) {
if (ObjectUtils.isNotEmpty(vo)){
if (ObjectUtils.isNotEmpty(vo.getMemberId())){
Map<String, Integer> param = memberAlreadyAnalysis(vo.getMemberId(), partyMemberAnalysisVOS);
if (param.get("flag")==1){
- Integer serviceTime = vo.getServiceTime();
+ Double serviceTime = vo.getServiceTime();
Integer serviceTimes = vo.getServiceTimes();
partyMemberAnalysisVOS.get(param.get("index")).setServiceTime(partyMemberAnalysisVOS.get(param.get("index")).getServiceTime()+serviceTime);
partyMemberAnalysisVOS.get(param.get("index")).setServiceTimes(partyMemberAnalysisVOS.get(param.get("index")).getServiceTimes()+serviceTimes);
@@ -1329,6 +1400,39 @@
}
}
}
+
+ if (newPartyMemberList.size()>0){
+ for (PartyMemberAnalysisVO item : newPartyMemberList)
+ {
+ Double time=(item.getServiceTime()/3600000);
+ DecimalFormat df = new DecimalFormat("#.##");
+ String formattedNumber = df.format(time);
+ Double result = Double.parseDouble(formattedNumber);
+ item.setServiceTime(result);
+ if (ObjectUtils.isNotEmpty(item)){
+ if (ObjectUtils.isNotEmpty(item.getMemberId())){
+ Map<String, Integer> param = memberAlreadyAnalysis(item.getMemberId(), partyMemberAnalysisVOS);
+ if (param.get("flag")==1){
+ Double serviceTime = partyMemberAnalysisVOS.get(param.get("index")).getServiceTime()+item.getServiceTime();
+ Integer serviceTimes = item.getServiceTimes();
+
+ DecimalFormat df1 = new DecimalFormat("#.##");
+ String formattedNumber1 = df1.format(serviceTime);
+ Double result1 = Double.parseDouble(formattedNumber1);
+
+ partyMemberAnalysisVOS.get(param.get("index")).setServiceTime(result1);
+ partyMemberAnalysisVOS.get(param.get("index")).setServiceTimes(partyMemberAnalysisVOS.get(param.get("index")).getServiceTimes()+serviceTimes);
+ }else{
+
+
+ partyMemberAnalysisVOS.add(item);
+ }
+ }
+ }
+ }
+ }
+
+
//报道单位统计积分
List<NewFightNeedProblemInventory> allList = newFightNeedProblemInventoryMapper.selectAll();
Map<Long, String> awardMap = allList.stream().filter(Objects::nonNull).collect(Collectors.toMap(NewFightNeedProblemInventory::getId, NewFightNeedProblemInventory::getAward));
@@ -1352,8 +1456,11 @@
// String award = newFightNeedProblemInventory.getAward();
String award = awardMap.get(Long.parseLong(taskId));
Long count = collectMap.get(taskId);
- long i = Long.parseLong(award) * count;
- sum = sum + i;
+ if(!StringUtils.isEmpty(award) )
+ {
+ long i = Long.parseLong(award) * count;
+ sum = sum + i;
+ }
}
unitVO.setAwardSum(sum);
}
@@ -1374,27 +1481,36 @@
for (NewFightNeedProblemClaim inventory : newFightNeedProblemInventories) {
String taskId = inventory.getTaskId();
NewFightNeedProblemInventory newFightNeedProblemInventory = newFightNeedProblemInventoryMapper.selectById(taskId);
- String award = newFightNeedProblemInventory.getAward();
- sumAward = Long.parseLong(award) + sumAward;
+
+ if(newFightNeedProblemInventory!=null && !StringUtils.isEmpty(newFightNeedProblemInventory.getAward()))
+ {
+ String award = newFightNeedProblemInventory.getAward();
+
+ if(!StringUtils.isEmpty(award) )
+ {
+ sumAward = Long.parseLong(award) + sumAward;
+ }
+ }
+
}
memberAnalysisVO.setPartyCount(sumAward);
}
//统计总时长和总次数
Integer unitServiceCount=0;
- Integer unitServiceTotalTime=0;
+ Double unitServiceTotalTime=0.0;
Integer memberServiceCount=0;
- Integer memberServiceTotalTome=0;
+ Double memberServiceTotalTome=0.0;
long awardSumCount=0L;
long partySumCount=0L;
for (UnitActivityAnalysisVO vo : unitActivityAnalysisVOS) {
//避免空指针
if (ObjectUtils.isNotEmpty(vo)){
if (ObjectUtils.isNotEmpty(vo.getServiceTime())){
- unitServiceCount+=vo.getServiceTime();
+ unitServiceTotalTime+=vo.getServiceTime();
}
if (ObjectUtils.isNotEmpty(vo.getServiceTimes())){
- unitServiceTotalTime+=vo.getServiceTimes();
+ unitServiceCount+=vo.getServiceTimes();
}
}
}
@@ -1402,10 +1518,10 @@
//避免空指针
if (ObjectUtils.isNotEmpty(vo)){
if (ObjectUtils.isNotEmpty(vo.getServiceTime())){
- memberServiceCount+=vo.getServiceTime();
+ memberServiceTotalTome+=vo.getServiceTime();
}
if (ObjectUtils.isNotEmpty(vo.getServiceTimes())){
- memberServiceTotalTome+=vo.getServiceTimes();
+ memberServiceCount+=vo.getServiceTimes();
}
}
}
@@ -1476,10 +1592,10 @@
activityVO.setPartyMemberList(memberPage);
//党员数据 聚合
- Map<String, Long> map = new HashMap<>();
+ Map<String, Double> map = new HashMap<>();
partyMemberAnalysisVOS.forEach(vo->{
String name = vo.getBelongTo();
- Long time = Long.valueOf(vo.getServiceTime());
+ Double time = vo.getServiceTime();
if (map.containsKey(name)) {
time += map.get(name);
}
@@ -1536,7 +1652,7 @@
Map<String, Integer> param = alreadyAnalysis(vo.getUnitId(), unitActivityAnalysisVOS);
if (param.get("flag")==1){
//已有数据，将时长,次数相加
- Integer serviceTime = vo.getServiceTime();
+ Double serviceTime = vo.getServiceTime();
Integer serviceTimes = vo.getServiceTimes();
unitActivityAnalysisVOS.get(param.get("index")).setServiceTime(unitActivityAnalysisVOS.get(param.get("index")).getServiceTime()+serviceTime);
unitActivityAnalysisVOS.get(param.get("index")).setServiceTimes(unitActivityAnalysisVOS.get(param.get("index")).getServiceTimes()+serviceTimes);
@@ -1611,7 +1727,7 @@
if (ObjectUtils.isNotEmpty(vo.getMemberId())){
Map<String, Integer> param = memberAlreadyAnalysis(vo.getMemberId(), partyMemberAnalysisVOS);
if (param.get("flag")==1){
- Integer serviceTime = vo.getServiceTime();
+ Double serviceTime = vo.getServiceTime();
Integer serviceTimes = vo.getServiceTimes();
partyMemberAnalysisVOS.get(param.get("index")).setServiceTime(partyMemberAnalysisVOS.get(param.get("index")).getServiceTime()+serviceTime);
partyMemberAnalysisVOS.get(param.get("index")).setServiceTimes(partyMemberAnalysisVOS.get(param.get("index")).getServiceTimes()+serviceTimes);
--
Gitblit v1.7.1