|
@@ -1,14 +1,17 @@
|
|
|
package com.dayou.service.impl;
|
|
|
|
|
|
import cn.hutool.core.collection.CollectionUtil;
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
import com.baomidou.dynamic.datasource.annotation.DS;
|
|
|
import com.dayou.common.BaseEntity;
|
|
|
import com.dayou.dto.FinanceRealFundExportDTO;
|
|
|
import com.dayou.dto.FinanceRealNotClaimDTO;
|
|
|
import com.dayou.entity.FinanceClaim;
|
|
|
import com.dayou.entity.FinanceRealFund;
|
|
|
+import com.dayou.entity.User;
|
|
|
import com.dayou.exception.ErrorCode;
|
|
|
import com.dayou.mapper.FinanceRealFundMapper;
|
|
|
+import com.dayou.mapper.UserMapper;
|
|
|
import com.dayou.service.IFinanceClaimService;
|
|
|
import com.dayou.service.IFinanceRealFundService;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
@@ -35,6 +38,8 @@ import java.math.BigDecimal;
|
|
|
import java.util.Collections;
|
|
|
import java.util.List;
|
|
|
import java.util.ArrayList;
|
|
|
+import java.util.stream.Collectors;
|
|
|
+
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
import com.dayou.enums.BatchTaskTypeEnum;
|
|
|
|
|
@@ -55,6 +60,8 @@ public class FinanceRealFundServiceImpl extends ServiceImpl<FinanceRealFundMappe
|
|
|
|
|
|
@Autowired
|
|
|
private IFinanceClaimService financeClaimService;
|
|
|
+ @Autowired
|
|
|
+ private UserMapper userMapper;
|
|
|
|
|
|
@Override
|
|
|
@SuppressWarnings("unchecked")
|
|
@@ -140,23 +147,59 @@ public class FinanceRealFundServiceImpl extends ServiceImpl<FinanceRealFundMappe
|
|
|
@Override
|
|
|
public Page<SettleMajorProductionVO> majorEvaluatorSettleProd(SettleMajorProductionVO settleVO, Page page,String keyword) {
|
|
|
Page<SettleMajorProductionVO> result = financeRealFundMapper.majorEvaluatorSettleProd(page,settleVO,keyword);
|
|
|
+ List<SettleMajorProductionVO> records = result.getRecords();
|
|
|
+ for (SettleMajorProductionVO record : records) {
|
|
|
+ List<Long> userIdS = JSON.parseArray(record.getMembers(), Long.class);
|
|
|
+ if (CollectionUtil.isNotEmpty(userIdS)){
|
|
|
+ List<User> users = userMapper.selectList(new LambdaQueryWrapper<User>().in(BaseEntity::getId, userIdS).select(User::getName).ne(BaseEntity::getId,1L));
|
|
|
+ List<String> names = users.stream().map(User::getName).collect(Collectors.toList());
|
|
|
+ record.setJoiner(String.join(",",names));
|
|
|
+ }
|
|
|
+ }
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public Page<SettleMajorProductionVO> majorMarketSettleProd(SettleMajorProductionVO settleVO, Page page,String keyword) {
|
|
|
Page<SettleMajorProductionVO> result = financeRealFundMapper.majorMarketerSettleProd(page,settleVO,keyword);
|
|
|
+ List<SettleMajorProductionVO> records = result.getRecords();
|
|
|
+ for (SettleMajorProductionVO record : records) {
|
|
|
+ List<Long> userIdS = JSON.parseArray(record.getMembers(), Long.class);
|
|
|
+ if (CollectionUtil.isNotEmpty(userIdS)){
|
|
|
+ List<User> users = userMapper.selectList(new LambdaQueryWrapper<User>().in(BaseEntity::getId, userIdS).select(User::getName).ne(BaseEntity::getId,1L));
|
|
|
+ List<String> names = users.stream().map(User::getName).collect(Collectors.toList());
|
|
|
+ record.setJoiner(String.join(",",names));
|
|
|
+ }
|
|
|
+ }
|
|
|
return result;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public List<SettleMajorProductionVO> majorMarketSettleExport(SettleMajorProductionVO production,Page page,String keyword) {
|
|
|
- return financeRealFundMapper.majorMarketSettleExport(page,production,keyword);
|
|
|
+ List<SettleMajorProductionVO> settleMajorProductionVOS = financeRealFundMapper.majorMarketSettleExport(page, production, keyword);
|
|
|
+ for (SettleMajorProductionVO record : settleMajorProductionVOS) {
|
|
|
+ List<Long> userIdS = JSON.parseArray(record.getMembers(), Long.class);
|
|
|
+ if (CollectionUtil.isNotEmpty(userIdS)){
|
|
|
+ List<User> users = userMapper.selectList(new LambdaQueryWrapper<User>().in(BaseEntity::getId, userIdS).select(User::getName).ne(BaseEntity::getId,1L));
|
|
|
+ List<String> names = users.stream().map(User::getName).collect(Collectors.toList());
|
|
|
+ record.setJoiner(String.join(",",names));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return settleMajorProductionVOS;
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public List<SettleMajorProductionVO> majorEvaluatorSettleExport(SettleMajorProductionVO production,Page page,String keyword) {
|
|
|
- return financeRealFundMapper.majorEvaluatorSettleExport(page,production,keyword);
|
|
|
+ List<SettleMajorProductionVO> settleMajorProductionVOS = financeRealFundMapper.majorEvaluatorSettleExport(page, production, keyword);
|
|
|
+ for (SettleMajorProductionVO record : settleMajorProductionVOS) {
|
|
|
+ List<Long> userIdS = JSON.parseArray(record.getMembers(), Long.class);
|
|
|
+ if (CollectionUtil.isNotEmpty(userIdS)){
|
|
|
+ List<User> users = userMapper.selectList(new LambdaQueryWrapper<User>().in(BaseEntity::getId, userIdS).select(User::getName).ne(BaseEntity::getId,1L));
|
|
|
+ List<String> names = users.stream().map(User::getName).collect(Collectors.toList());
|
|
|
+ record.setJoiner(String.join(",",names));
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return settleMajorProductionVOS;
|
|
|
}
|
|
|
|
|
|
@Override
|