This commit is contained in:
mx 2024-12-26 17:10:51 +08:00
parent 50a3b0d23c
commit 21185aa726
6 changed files with 46 additions and 12 deletions

View File

@ -28,7 +28,7 @@
</encoder> </encoder>
<filter class="ch.qos.logback.classic.filter.ThresholdFilter"> <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
<!-- 过滤的级别 --> <!-- 过滤的级别 -->
<level>INFO</level> <level>DEBUG</level>
</filter> </filter>
</appender> </appender>
@ -47,7 +47,7 @@
</encoder> </encoder>
<filter class="ch.qos.logback.classic.filter.LevelFilter"> <filter class="ch.qos.logback.classic.filter.LevelFilter">
<!-- 过滤的级别 --> <!-- 过滤的级别 -->
<level>INFO</level> <level>DEBUG</level>
<!-- 匹配时的操作:接收(记录) --> <!-- 匹配时的操作:接收(记录) -->
<onMatch>ACCEPT</onMatch> <onMatch>ACCEPT</onMatch>
<!-- 不匹配时的操作:拒绝(不记录) --> <!-- 不匹配时的操作:拒绝(不记录) -->

View File

@ -64,7 +64,7 @@ public class PsCompanyInfoController extends BaseController {
* 服务公司列表 * 服务公司列表
*/ */
@SaCheckPermission("business:companyInfo:list") @SaCheckPermission("business:companyInfo:list")
@Log(title = "服务公司列表" ) // @Log(title = "服务公司列表" )
@GetMapping("/serviceList") @GetMapping("/serviceList")
public TableDataInfo<PsCompanyInfoVo> serviceList(PsCompanyQueryBo queryBo, PageQuery pageQuery) { public TableDataInfo<PsCompanyInfoVo> serviceList(PsCompanyQueryBo queryBo, PageQuery pageQuery) {
return psCompanyInfoService.queryServiceCompany(queryBo, pageQuery); return psCompanyInfoService.queryServiceCompany(queryBo, pageQuery);

View File

@ -36,4 +36,8 @@ public interface PsCompanyInfoMapper extends BaseMapperPlus<PsCompanyInfo, PsCom
List<PsCompanyInfoVo> selectVoCustomManager(@Param(Constants.WRAPPER) Wrapper<PsCompanyInfo> queryWrapper, @Param("contractCode")String contractCode); List<PsCompanyInfoVo> selectVoCustomManager(@Param(Constants.WRAPPER) Wrapper<PsCompanyInfo> queryWrapper, @Param("contractCode")String contractCode);
List<SysUserVo> selectFollowUser(@Param(Constants.WRAPPER) Wrapper<PsCompanyInfo> queryWrapper); List<SysUserVo> selectFollowUser(@Param(Constants.WRAPPER) Wrapper<PsCompanyInfo> queryWrapper);
List<PsCompanyInfoVo> selectContractServiceCompany(@Param(Constants.WRAPPER) Wrapper<PsCompanyInfoVo> queryWrapper);
} }

View File

@ -15,6 +15,7 @@ import com.pusong.business.enums.ApproverStatusEnum;
import com.pusong.business.enums.ApproverTypeEnum; import com.pusong.business.enums.ApproverTypeEnum;
import com.pusong.business.enums.PayStatusEnum; import com.pusong.business.enums.PayStatusEnum;
import com.pusong.business.mapper.PsApproverRecordMapper; import com.pusong.business.mapper.PsApproverRecordMapper;
import com.pusong.business.mapper.PsCompanyInfoMapper;
import com.pusong.business.mapper.PsContractPayMapper; import com.pusong.business.mapper.PsContractPayMapper;
import com.pusong.business.service.IPsCompanyInfoService; import com.pusong.business.service.IPsCompanyInfoService;
import com.pusong.business.service.approver.ApproverContainer; import com.pusong.business.service.approver.ApproverContainer;
@ -34,6 +35,8 @@ import jakarta.annotation.Resource;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/** /**
* 审批记录Service接口 * 审批记录Service接口
@ -54,6 +57,8 @@ public abstract class ApproverAbstractServiceImpl implements ApproverService {
private IPsCompanyInfoService companyInfoService; private IPsCompanyInfoService companyInfoService;
@Resource @Resource
private ISysNoticeService noticeService; private ISysNoticeService noticeService;
@Resource
private PsCompanyInfoMapper companyInfoMapper;
/** /**
* 通用申请方法 * 通用申请方法
* @param bussinessId * @param bussinessId
@ -129,18 +134,28 @@ public abstract class ApproverAbstractServiceImpl implements ApproverService {
} }
Page<PsApproverRecordVo> res = recordMapper.selectPageApproverList(pageQuery.build(), lqw, bo.getPay()); Page<PsApproverRecordVo> res = recordMapper.selectPageApproverList(pageQuery.build(), lqw, bo.getPay());
List<String> codes = res.getRecords().stream().map(PsApproverRecordVo::getContractCode).toList();
QueryWrapper<PsCompanyInfoVo> wq = Wrappers.<PsCompanyInfoVo>query()
.eq("com.del_flag", "0")
.eq("pcc.del_flag","0")
.in("pcc.contract_code", codes);
List<PsCompanyInfoVo> list = companyInfoMapper.selectContractServiceCompany(wq);
Map<String, List<PsCompanyInfoVo>> contractCompanyMap = list.stream().collect(Collectors.groupingBy(PsCompanyInfoVo::getContractCode));
if(CollectionUtils.isNotEmpty(res.getRecords())){ if(CollectionUtils.isNotEmpty(res.getRecords())){
res.getRecords().forEach(item->{ res.getRecords().forEach(item->{
if (item.getContractAmount() != null) if (item.getContractAmount() != null)
item.setResidualMoney(item.getContractAmount().subtract(item.getPayMoney())); item.setResidualMoney(item.getContractAmount().subtract(item.getPayMoney()));
//装填回款周期 //装填回款周期
List<PsContractPayVo> payList = queryListByContractCode(item.getContractCode(),"1", PayStatusEnum.SUCCESS); // List<PsContractPayVo> payList = queryListByContractCode(item.getContractCode(),"1", PayStatusEnum.SUCCESS);
if(CollectionUtils.isNotEmpty(payList)){ // if(CollectionUtils.isNotEmpty(payList)){
item.setPeriod(DateUtils.calWorkDate(payList.get(0).getPayDate(),payList.get(payList.size()-1).getPayDate())); // item.setPeriod(DateUtils.calWorkDate(payList.get(0).getPayDate(), payList.get(payList.size() - 1).getPayDate()));
} // }
//装填服务公司信息 //装填服务公司信息
List<PsCompanyInfoVo> list = companyInfoService.getServiceCompany(item.getContractCode()); // List<PsCompanyInfoVo> list = companyInfoService.getServiceCompany(item.getContractCode());
item.setServicePsCompanyInfoVo(list); item.setServicePsCompanyInfoVo(contractCompanyMap.get(item.getContractCode()));
}); });
} }
return res; return res;
@ -155,7 +170,9 @@ public abstract class ApproverAbstractServiceImpl implements ApproverService {
* @return * @return
*/ */
public List<PsContractPayVo> queryListByContractCode(String contractCode, String business, PayStatusEnum enu){ public List<PsContractPayVo> queryListByContractCode(String contractCode, String business, PayStatusEnum enu){
if(StringUtils.isBlank(contractCode)){return new ArrayList<>();} if(StringUtils.isBlank(contractCode)){
return new ArrayList<>();
}
List<PsContractPayVo> list = baseMapper.selectVoList(Wrappers.<PsContractPay>lambdaQuery(). List<PsContractPayVo> list = baseMapper.selectVoList(Wrappers.<PsContractPay>lambdaQuery().
eq(PsContractPay::getContractCode, contractCode).eq(PsContractPay::getDelFlag,0) eq(PsContractPay::getContractCode, contractCode).eq(PsContractPay::getDelFlag,0)
.eq(StringUtils.isNotBlank(business),PsContractPay::getBusinessType,business) .eq(StringUtils.isNotBlank(business),PsContractPay::getBusinessType,business)

View File

@ -191,20 +191,24 @@ public class PsCompanyInfoServiceImpl implements IPsCompanyInfoService {
lqw.orderByAsc("CASE WHEN bus.min_end_date IS NULL THEN 1 ELSE 0 END, bus.min_end_date"); lqw.orderByAsc("CASE WHEN bus.min_end_date IS NULL THEN 1 ELSE 0 END, bus.min_end_date");
lqw.orderByDesc("finish_date"); lqw.orderByDesc("finish_date");
logger.info("1222222222");
// lqw.groupBy("com.id"); // lqw.groupBy("com.id");
Page<PsCompanyInfoVo> result = baseMapper.selectPageList2(pageQuery.build(), lqw); Page<PsCompanyInfoVo> result = baseMapper.selectPageList2(pageQuery.build(), lqw);
logger.info("333333333333333");
if (!result.getRecords().isEmpty()){ if (!result.getRecords().isEmpty()){
//填充代账服务项目 //填充代账服务项目
List<Long> companyIds = result.getRecords().stream().map(PsCompanyInfoVo::getId).collect(Collectors.toList()); List<Long> companyIds = result.getRecords().stream().map(PsCompanyInfoVo::getId).collect(Collectors.toList());
QueryWrapper<PsContractBusiness> queryParam = Wrappers.query(); QueryWrapper<PsContractBusiness> queryParam = Wrappers.query();
queryParam.in("cc.company_id", companyIds); queryParam.in("cc.company_id", companyIds);
logger.info("44444444444");
List<PsContractBusinessVo> psContractBusinessVos = contractBusinessMapper.selectTuoGuanBusinessList(queryParam); List<PsContractBusinessVo> psContractBusinessVos = contractBusinessMapper.selectTuoGuanBusinessList(queryParam);
Map<Long, List<PsContractBusinessVo>> contractBusinessVoMap = psContractBusinessVos.stream().collect(Collectors.groupingBy(PsContractBusinessVo::getCompanyId, Collectors.toList())); Map<Long, List<PsContractBusinessVo>> contractBusinessVoMap = psContractBusinessVos.stream().collect(Collectors.groupingBy(PsContractBusinessVo::getCompanyId, Collectors.toList()));
QueryWrapper<PsCompanyInfo> query = Wrappers.query(); QueryWrapper<PsCompanyInfo> query = Wrappers.query();
query.in("cf.company_id", companyIds); query.in("cf.company_id", companyIds);
logger.info("5555555555555");
List<SysUserVo> sysUsers = baseMapper.selectFollowUser(query); List<SysUserVo> sysUsers = baseMapper.selectFollowUser(query);
logger.info("666666666666");
Map<Long, List<SysUserVo>> userMap = new HashMap<>(); Map<Long, List<SysUserVo>> userMap = new HashMap<>();
for (SysUserVo sysUser : sysUsers) { for (SysUserVo sysUser : sysUsers) {
List<SysUserVo> list = userMap.computeIfAbsent(sysUser.getCompanyId(), aLong -> new ArrayList<>()); List<SysUserVo> list = userMap.computeIfAbsent(sysUser.getCompanyId(), aLong -> new ArrayList<>());
@ -229,7 +233,7 @@ public class PsCompanyInfoServiceImpl implements IPsCompanyInfoService {
} }
} }
} }
logger.info("777777777777");
return TableDataInfo.build(result); return TableDataInfo.build(result);
} }

View File

@ -130,6 +130,15 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
left join ps_contract_business_detail det on det.business_id = bus.id left join ps_contract_business_detail det on det.business_id = bus.id
${ew.getCustomSqlSegment} ${ew.getCustomSqlSegment}
</select> </select>
<select id="selectContractServiceCompany" resultMap="serviceCompanyServiceResult2">
select pcc.contract_code,com.*
from ps_contract_company pcc
inner join ps_company_info com on pcc.company_id = com.id
${ew.getCustomSqlSegment}
</select>
<select id="selectFollowUser" resultType="com.pusong.system.domain.vo.SysUserVo"> <select id="selectFollowUser" resultType="com.pusong.system.domain.vo.SysUserVo">
select u.*,cf.company_id from ps_company_follow cf select u.*,cf.company_id from ps_company_follow cf
inner join sys_user u on u.user_id = cf.user_id inner join sys_user u on u.user_id = cf.user_id