package com.doumee.service.business.impl; 
 | 
  
 | 
import com.doumee.biz.system.SystemDictDataBiz; 
 | 
import com.doumee.core.constants.ResponseStatus; 
 | 
import com.doumee.core.excel.ExcelReplaceCommon; 
 | 
import com.doumee.core.exception.BusinessException; 
 | 
import com.doumee.core.model.LoginUserInfo; 
 | 
import com.doumee.core.model.PageData; 
 | 
import com.doumee.core.model.PageWrap; 
 | 
import com.doumee.core.utils.Constants; 
 | 
import com.doumee.core.utils.DateUtil; 
 | 
import com.doumee.core.utils.Utils; 
 | 
import com.doumee.dao.business.*; 
 | 
import com.doumee.dao.business.dto.YwSmsEmailBillCallDTO; 
 | 
import com.doumee.dao.business.model.*; 
 | 
import com.doumee.dao.business.vo.YwContractBillCallDataVO; 
 | 
import com.doumee.dao.business.vo.YwContractBillDataVO; 
 | 
import com.doumee.dao.system.MultifileMapper; 
 | 
import com.doumee.dao.system.model.Multifile; 
 | 
import com.doumee.dao.system.model.SystemUser; 
 | 
import com.doumee.service.business.YwContractBillService; 
 | 
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; 
 | 
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; 
 | 
import com.baomidou.mybatisplus.core.metadata.IPage; 
 | 
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; 
 | 
import com.github.yulichang.wrapper.MPJLambdaWrapper; 
 | 
import lombok.extern.java.Log; 
 | 
import org.apache.commons.lang3.StringUtils; 
 | 
import org.checkerframework.checker.units.qual.C; 
 | 
import org.springframework.beans.factory.annotation.Autowired; 
 | 
import org.springframework.stereotype.Service; 
 | 
import org.springframework.util.CollectionUtils; 
 | 
  
 | 
import javax.servlet.http.HttpServletResponse; 
 | 
import java.io.File; 
 | 
import java.math.BigDecimal; 
 | 
import java.net.URLEncoder; 
 | 
import java.nio.charset.Charset; 
 | 
import java.util.*; 
 | 
import java.util.stream.Collectors; 
 | 
  
 | 
/** 
 | 
 * 运维合同账单信息表Service实现 
 | 
 * @author 江蹄蹄 
 | 
 * @date 2024/11/19 16:07 
 | 
 */ 
 | 
@Service 
 | 
public class YwContractBillServiceImpl implements YwContractBillService { 
 | 
  
 | 
    @Autowired 
 | 
    private YwContractBillMapper ywContractBillMapper; 
 | 
  
 | 
    @Autowired 
 | 
    private YwContractRoomMapper ywContractRoomMapper; 
 | 
  
 | 
    @Autowired 
 | 
    private MultifileMapper multifileMapper; 
 | 
  
 | 
    @Autowired 
 | 
    private YwContractRevenueMapper ywContractRevenueMapper; 
 | 
  
 | 
    @Autowired 
 | 
    private SystemDictDataBiz systemDictDataBiz; 
 | 
  
 | 
    @Autowired 
 | 
    private YwContractMapper ywContractMapper; 
 | 
  
 | 
    @Autowired 
 | 
    private MemberMapper memberMapper; 
 | 
  
 | 
    @Autowired 
 | 
    private YwTempConfigMapper ywTempConfigMapper; 
 | 
  
 | 
  
 | 
    @Override 
 | 
    public Integer create(YwContractBill ywContractBill) { 
 | 
        if(Objects.isNull(ywContractBill) 
 | 
                || Objects.isNull(ywContractBill.getContractId()) 
 | 
                || Objects.isNull(ywContractBill.getTotleFee()) 
 | 
                || Objects.isNull(ywContractBill.getPlanPayDate()) 
 | 
                || Objects.isNull(ywContractBill.getCostType()) 
 | 
                || Objects.isNull(ywContractBill.getBillType()) 
 | 
                || Objects.isNull(ywContractBill.getCompanyId()) 
 | 
                || com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(ywContractBill.getYwContractRoomList()) 
 | 
                || Objects.isNull(ywContractBill.getFeeType()) 
 | 
                || (Constants.equalsInteger(ywContractBill.getFeeType(),Constants.ZERO)&& (Objects.isNull(ywContractBill.getStartDate()) 
 | 
                || Objects.isNull(ywContractBill.getEndDate()))) 
 | 
        ){ 
 | 
            throw new BusinessException(ResponseStatus.BAD_REQUEST); 
 | 
        } 
 | 
        YwContract ywContract = ywContractMapper.selectById(ywContractBill.getContractId()); 
 | 
        if(Objects.isNull(ywContract)){ 
 | 
            throw new BusinessException(ResponseStatus.DATA_EMPTY); 
 | 
        } 
 | 
        if(Constants.equalsInteger(ywContract.getStatus(),Constants.THREE)){ 
 | 
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"合同状态已流转,无法进行该操作"); 
 | 
        } 
 | 
  
 | 
        LoginUserInfo loginUserInfo = ywContractBill.getLoginUserInfo(); 
 | 
        ywContractBill.setReceivableFee(ywContractBill.getTotleFee()); 
 | 
        ywContractBill.setCreateDate(new Date()); 
 | 
        ywContractBill.setCreator(loginUserInfo.getId()); 
 | 
        ywContractBill.setIsdeleted(Constants.ZERO); 
 | 
        ywContractBill.setType(Constants.ONE); 
 | 
        ywContractBill.setStatus(Constants.ZERO); 
 | 
        if(Constants.equalsInteger(ywContractBill.getBillType(),Constants.ZERO)){ 
 | 
            ywContractBill.setPayStatus(Constants.ZERO); 
 | 
        }else{ 
 | 
            ywContractBill.setPayStatus(Constants.THREE); 
 | 
        } 
 | 
  
 | 
        if(Constants.equalsInteger(ywContractBill.getFeeType(),Constants.ONE)){ 
 | 
            ywContractBill.setStartDate(ywContractBill.getPlanPayDate()); 
 | 
            ywContractBill.setEndDate(ywContractBill.getPlanPayDate()); 
 | 
        } 
 | 
        //查询合同下的最大的序号 
 | 
        List<YwContractBill> ywContractBillList = ywContractBillMapper.selectList(new QueryWrapper<YwContractBill>() 
 | 
                .lambda().eq(YwContractBill::getContractId,ywContract.getId()) 
 | 
                .in(YwContractBill::getCostType,Constants.ZERO,Constants.SIX,Constants.FOUR,Constants.FIVE,7) 
 | 
                .orderByDesc(YwContractBill::getId)); 
 | 
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractBillList)){ 
 | 
            ywContractBill.setSortnum(ywContractBillList.size() + 1 ); 
 | 
        }else{ 
 | 
            ywContractBill.setSortnum(0); 
 | 
        } 
 | 
        ywContractBillMapper.insert(ywContractBill); 
 | 
  
 | 
        //房源数据 
 | 
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractBill.getYwContractRoomList())){ 
 | 
            for (YwContractRoom ywContractRoom:ywContractBill.getYwContractRoomList()) { 
 | 
                if(Objects.isNull(ywContractRoom) 
 | 
                || Objects.isNull(ywContractRoom.getRoomId())){ 
 | 
                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"请选择房源数据"); 
 | 
                } 
 | 
                ywContractRoom.setCreateDate(new Date()); 
 | 
                ywContractRoom.setCreator(loginUserInfo.getId()); 
 | 
                ywContractRoom.setIsdeleted(Constants.ZERO); 
 | 
                ywContractRoom.setContractId(ywContractBill.getId()); 
 | 
                ywContractRoom.setType(Constants.ONE); 
 | 
            } 
 | 
            ywContractRoomMapper.insert(ywContractBill.getYwContractRoomList()); 
 | 
        } 
 | 
  
 | 
        //附件数据 
 | 
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractBill.getMultifileList())){ 
 | 
            for (Multifile multifile:ywContractBill.getMultifileList()) { 
 | 
                if(Objects.isNull(multifile) 
 | 
                || StringUtils.isBlank(multifile.getFileurl()) 
 | 
                || StringUtils.isBlank(multifile.getName())){ 
 | 
                    throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"附件信息错误"); 
 | 
                } 
 | 
                multifile.setCreator(loginUserInfo.getId()); 
 | 
                multifile.setCreateDate(new Date()); 
 | 
                multifile.setIsdeleted(Constants.ZERO); 
 | 
                multifile.setObjType(Constants.MultiFile.FN_CONTRACT_BILL_FILE.getKey()); 
 | 
                multifile.setObjId(ywContractBill.getId()); 
 | 
            } 
 | 
            multifileMapper.insert(ywContractBill.getMultifileList()); 
 | 
        } 
 | 
  
 | 
        return ywContractBill.getId(); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void deleteById(Integer id, LoginUserInfo user) { 
 | 
        ywContractBillMapper.deleteById(id); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void delete(YwContractBill ywContractBill) { 
 | 
        UpdateWrapper<YwContractBill> deleteWrapper = new UpdateWrapper<>(ywContractBill); 
 | 
        ywContractBillMapper.delete(deleteWrapper); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void deleteByIdInBatch(List<Integer> ids, LoginUserInfo user) { 
 | 
        if (CollectionUtils.isEmpty(ids)) { 
 | 
            return; 
 | 
        } 
 | 
        ywContractBillMapper.deleteBatchIds(ids); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void updateById(YwContractBill ywContractBill) { 
 | 
        ywContractBillMapper.updateById(ywContractBill); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public void updateByIdInBatch(List<YwContractBill> ywContractBills) { 
 | 
        if (CollectionUtils.isEmpty(ywContractBills)) { 
 | 
            return; 
 | 
        } 
 | 
        for (YwContractBill ywContractBill: ywContractBills) { 
 | 
            this.updateById(ywContractBill); 
 | 
        } 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public YwContractBill findById(Integer id) { 
 | 
        return ywContractBillMapper.selectById(id); 
 | 
    } 
 | 
  
 | 
  
 | 
    @Override 
 | 
    public YwContractBill getDetail(Integer id) { 
 | 
        YwContractBill ywContractBill = ywContractBillMapper.selectJoinOne(YwContractBill.class, 
 | 
                new MPJLambdaWrapper<YwContractBill>().selectAll(YwContractBill.class) 
 | 
                        //.select(" ( select ifnull(sum(case when yw.REVENUE_TYPE = 0 then yw.ACT_RECEIVABLE_FEE  else  -yw.ACT_RECEIVABLE_FEE end),0) from  yw_contract_revenue yw where yw.bill_id = t.id and yw.status = 0 and yw.isdeleted = 0 ) as  actReceivableFee  ") 
 | 
                        .select(" ( select ifnull( sum( CASE WHEN t.bill_type = 0 and yw.REVENUE_TYPE = 0 THEN yw.ACT_RECEIVABLE_FEE when  t.bill_type = 0 and yw.REVENUE_TYPE = 1 then -yw.ACT_RECEIVABLE_FEE  when t.bill_type = 1 and yw.REVENUE_TYPE = 0 then -yw.ACT_RECEIVABLE_FEE else  yw.ACT_RECEIVABLE_FEE END),0) from  yw_contract_revenue yw where yw.bill_id = t.id and yw.status = 0 and yw.isdeleted = 0 ) as  actReceivableFee  ") 
 | 
                        .selectAs(YwContract::getCode,YwContractBill::getContractCode) 
 | 
                        .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) 
 | 
                        .selectAs(Company::getId,YwContractBill::getCompanyId) 
 | 
                        .selectAs(Company::getName,YwContractBill::getCompanyName) 
 | 
                        .selectAs(SystemUser::getRealname,YwContractBill::getRealname) 
 | 
                        .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) 
 | 
                        .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) 
 | 
                        .leftJoin(Company.class,Company::getId,YwContract::getCompanyId) 
 | 
                        .leftJoin(SystemUser.class,SystemUser::getId,YwContractBill::getCreator) 
 | 
                        .eq(YwContractBill::getIsdeleted,Constants.ZERO) 
 | 
                        .eq(YwContractBill::getId,id)); 
 | 
        if(Objects.isNull(ywContractBill)){ 
 | 
            throw new BusinessException(ResponseStatus.DATA_EMPTY); 
 | 
        } 
 | 
        ywContractBill.setNeedReceivableFee( 
 | 
                ywContractBill.getReceivableFee().subtract(ywContractBill.getActReceivableFee()) 
 | 
        ); 
 | 
  
 | 
        //房源数据 
 | 
        ywContractBill.setYwContractRoomList( 
 | 
                ywContractRoomMapper.selectJoinList(YwContractRoom.class,new MPJLambdaWrapper<YwContractRoom>() 
 | 
                .selectAll(YwContractRoom.class) 
 | 
                .selectAs(YwProject::getName,YwRoom::getProjectName) 
 | 
                .selectAs(YwFloor::getName,YwRoom::getFloorName) 
 | 
                .selectAs(YwBuilding::getName,YwRoom::getBuildingName) 
 | 
                .selectAs(YwRoom::getCode,YwContractRoom::getRoomName) 
 | 
                .selectAs(YwRoom::getArea,YwContractRoom::getArea) 
 | 
                .leftJoin(YwRoom.class,YwRoom::getId,YwContractRoom::getRoomId) 
 | 
                .leftJoin(YwFloor.class,YwFloor::getId,YwRoom::getFloor) 
 | 
                .leftJoin(YwProject.class,YwProject::getId,YwRoom::getProjectId) 
 | 
                .leftJoin(YwBuilding.class,YwBuilding::getId,YwRoom::getBuildingId) 
 | 
                .eq(Constants.equalsInteger(ywContractBill.getType(),Constants.ONE),YwContractRoom::getContractId,id) 
 | 
                .eq(Constants.equalsInteger(ywContractBill.getType(),Constants.ONE),YwContractRoom::getType,Constants.ONE) 
 | 
                .eq(Constants.equalsInteger(ywContractBill.getType(),Constants.ZERO) || Constants.equalsInteger(ywContractBill.getType(),Constants.TWO),YwContractRoom::getContractId,ywContractBill.getContractId()) 
 | 
                .eq(Constants.equalsInteger(ywContractBill.getType(),Constants.ZERO)| Constants.equalsInteger(ywContractBill.getType(),Constants.TWO),YwContractRoom::getType,Constants.ZERO) 
 | 
        )); 
 | 
  
 | 
        //收支记录 
 | 
        ywContractBill.setYwContractRevenueList( 
 | 
                ywContractRevenueMapper.selectJoinList(YwContractRevenue.class,new MPJLambdaWrapper<YwContractRevenue>() 
 | 
                    .selectAll(YwContractRevenue.class) 
 | 
                    .selectAs(YwCustomer::getName,YwContractRevenue::getCustomerName) 
 | 
                    .leftJoin(YwContract.class,YwContract::getId,YwContractRevenue::getContractId) 
 | 
                    .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) 
 | 
                    .eq(YwContractRevenue::getStatus,Constants.ZERO) 
 | 
                    .eq(YwContractRevenue::getBillId,ywContractBill.getId()) 
 | 
                    .orderByDesc(YwContractRevenue::getId) 
 | 
                ) 
 | 
        ); 
 | 
  
 | 
        //附件数据 
 | 
        List<Multifile> multifileList = multifileMapper.selectJoinList(Multifile.class,new MPJLambdaWrapper<Multifile>() 
 | 
                        .selectAll(Multifile.class) 
 | 
                        .selectAs(SystemUser::getRealname,Multifile::getUserName) 
 | 
                        .leftJoin(SystemUser.class,SystemUser::getId,Multifile::getCreator) 
 | 
                .eq(Multifile::getObjId,id) 
 | 
                .eq(Multifile::getIsdeleted,Constants.ZERO) 
 | 
                .eq(Multifile::getObjType,Constants.MultiFile.FN_CONTRACT_BILL_FILE.getKey())); 
 | 
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(multifileList)){ 
 | 
            String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() 
 | 
                    +systemDictDataBiz.queryByCode(Constants.FTP,Constants.YW_CONTRACT_BILL).getCode(); 
 | 
            for (Multifile multifile:multifileList) { 
 | 
                if(StringUtils.isNotBlank(multifile.getFileurl())){ 
 | 
                    multifile.setFileurlFull(path + multifile.getFileurl()); 
 | 
                } 
 | 
            } 
 | 
            ywContractBill.setMultifileList(multifileList); 
 | 
        } 
 | 
        return ywContractBill; 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public YwContractBill findOne(YwContractBill ywContractBill) { 
 | 
        QueryWrapper<YwContractBill> wrapper = new QueryWrapper<>(ywContractBill); 
 | 
        return ywContractBillMapper.selectOne(wrapper); 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public List<YwContractBill> findList(YwContractBill ywContractBill) { 
 | 
        QueryWrapper<YwContractBill> wrapper = new QueryWrapper<>(ywContractBill); 
 | 
        return ywContractBillMapper.selectList(wrapper); 
 | 
    } 
 | 
   
 | 
    @Override 
 | 
    public PageData<YwContractBill> findPage(PageWrap<YwContractBill> pageWrap) { 
 | 
        IPage<YwContractBill> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); 
 | 
        MPJLambdaWrapper<YwContractBill> queryWrapper = new MPJLambdaWrapper<>(); 
 | 
        Utils.MP.blankToNull(pageWrap.getModel()); 
 | 
        YwContractBill model = pageWrap.getModel(); 
 | 
        IPage<YwContractBill> iPage = ywContractBillMapper.selectJoinPage(page,YwContractBill.class, 
 | 
            queryWrapper.selectAll(YwContractBill.class) 
 | 
                    .select(" ( select ifnull( sum( CASE WHEN t.bill_type = 0 and yw.REVENUE_TYPE = 0 THEN yw.ACT_RECEIVABLE_FEE when  t.bill_type = 0 and yw.REVENUE_TYPE = 1 then -yw.ACT_RECEIVABLE_FEE  when t.bill_type = 1 and yw.REVENUE_TYPE = 0 then -yw.ACT_RECEIVABLE_FEE else  yw.ACT_RECEIVABLE_FEE END),0) from  yw_contract_revenue yw where yw.bill_id = t.id and yw.status = 0 and yw.isdeleted = 0 ) as  actReceivableFee  ") 
 | 
                    .selectAs(YwContract::getCode,YwContractBill::getContractCode) 
 | 
                    .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) 
 | 
                    .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) 
 | 
                    .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) 
 | 
                    .eq(YwContractBill::getIsdeleted,Constants.ZERO) 
 | 
                    .like(Objects.nonNull(model)&&StringUtils.isNotBlank(model.getCustomerName()), 
 | 
                            YwCustomer::getName,model.getCustomerName()) 
 | 
                    .eq(Objects.nonNull(model)&&Objects.nonNull(model.getStatus()), 
 | 
                            YwContractBill::getStatus,model.getStatus()) 
 | 
                    .eq(Objects.nonNull(model)&&Objects.nonNull(model.getBillType()), 
 | 
                            YwContractBill::getBillType,model.getBillType()) 
 | 
                    .eq(Objects.nonNull(model)&&Objects.nonNull(model.getPayStatus()), 
 | 
                            YwContractBill::getPayStatus,model.getPayStatus()) 
 | 
                    .eq(Objects.nonNull(model)&&Objects.nonNull(model.getType()), 
 | 
                            YwContractBill::getType,model.getType()) 
 | 
                    .le(Objects.nonNull(model)&&Objects.nonNull(model.getIsOverdue())&&Constants.equalsInteger(model.getIsOverdue(),Constants.ONE), 
 | 
                            YwContractBill::getPlanPayDate, DateUtil.getCurrDateTime()) 
 | 
                    .eq(Objects.nonNull(model)&&Objects.nonNull(model.getIsOverdue())&&Constants.equalsInteger(model.getIsOverdue(),Constants.ONE), 
 | 
                            YwContractBill::getStatus, Constants.ZERO) 
 | 
                    .eq(Objects.nonNull(model)&&Objects.nonNull(model.getContractId()), 
 | 
                            YwContractBill::getContractId,model.getContractId()) 
 | 
                    .like(Objects.nonNull(model)&&StringUtils.isNotBlank(model.getContractCode()), 
 | 
                            YwContract::getCode,model.getContractCode()) 
 | 
                .ge(Objects.nonNull(model)&&Objects.nonNull(model.getPlanPayDateStart()),YwContractBill::getPlanPayDate, Utils.Date.getStart(model.getPlanPayDateStart())) 
 | 
                .le(Objects.nonNull(model)&&Objects.nonNull(model.getPlanPayDateEnd()),YwContractBill::getPlanPayDate, Utils.Date.getEnd(model.getPlanPayDateEnd())) 
 | 
                    .orderByDesc(YwContractBill::getId)); 
 | 
  
 | 
        this.dealRoomDetail(iPage.getRecords()); 
 | 
        for (YwContractBill ywContractBill:iPage.getRecords()) { 
 | 
            //需收金额 
 | 
            ywContractBill.setNeedReceivableFee( 
 | 
                    ywContractBill.getReceivableFee().subtract(ywContractBill.getActReceivableFee()) 
 | 
            ); 
 | 
            //是否逾期 
 | 
            if(Constants.equalsInteger(ywContractBill.getStatus(),Constants.ZERO) 
 | 
                && (Constants.equalsInteger(ywContractBill.getPayStatus(),Constants.ZERO) 
 | 
                || Constants.equalsInteger(ywContractBill.getPayStatus(),Constants.TWO) 
 | 
                || Constants.equalsInteger(ywContractBill.getPayStatus(),Constants.THREE) 
 | 
                || Constants.equalsInteger(ywContractBill.getPayStatus(),Constants.FOUR)) 
 | 
            && ywContractBill.getPlanPayDate().getTime() < System.currentTimeMillis()){ 
 | 
                ywContractBill.setIsOverdue(Constants.ONE); 
 | 
            }else{ 
 | 
                ywContractBill.setIsOverdue(Constants.ZERO); 
 | 
            } 
 | 
            //楼宇名称 
 | 
            List<YwContractRoom> ywContractRoomList = ywContractBill.getYwContractRoomList(); 
 | 
            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractRoomList)){ 
 | 
                StringBuilder roomPathName = new StringBuilder(); 
 | 
                for (YwContractRoom ywContractRoom:ywContractRoomList) { 
 | 
                    if(StringUtils.isNotBlank(ywContractRoom.getProjectName())){ 
 | 
                        roomPathName.append(ywContractRoom.getProjectName()+"/"); 
 | 
                    } 
 | 
                    if(StringUtils.isNotBlank(ywContractRoom.getBuildingName())){ 
 | 
                        roomPathName.append(ywContractRoom.getBuildingName()+"/"); 
 | 
                    } 
 | 
                    if(StringUtils.isNotBlank(ywContractRoom.getFloorName())){ 
 | 
                        roomPathName.append(ywContractRoom.getFloorName()+"/"); 
 | 
                    } 
 | 
                    if(StringUtils.isNotBlank(ywContractRoom.getRoomName())){ 
 | 
                        roomPathName.append(ywContractRoom.getRoomName()); 
 | 
                    } 
 | 
                    if(StringUtils.isNotBlank(roomPathName)){ 
 | 
                        roomPathName.append(";"); 
 | 
                    } 
 | 
                } 
 | 
                ywContractBill.setRoomPathName(roomPathName.toString()); 
 | 
            } 
 | 
        } 
 | 
  
 | 
        return PageData.from(iPage); 
 | 
    } 
 | 
  
 | 
    /** 
 | 
     * 逾期账单 
 | 
     * @param pageWrap 
 | 
     * @return 
 | 
     */ 
 | 
    @Override 
 | 
    public PageData<YwContractBill> findPageForOverdue(PageWrap<YwContractBill> pageWrap) { 
 | 
        IPage<YwContractBill> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); 
 | 
        MPJLambdaWrapper<YwContractBill> queryWrapper = new MPJLambdaWrapper<>(); 
 | 
        Utils.MP.blankToNull(pageWrap.getModel()); 
 | 
        YwContractBill model = pageWrap.getModel(); 
 | 
        IPage<YwContractBill> iPage = ywContractBillMapper.selectJoinPage(page,YwContractBill.class, 
 | 
                queryWrapper.selectAll(YwContractBill.class) 
 | 
                        .select(" ( select ifnull( sum( CASE WHEN t.bill_type = 0 and yw.REVENUE_TYPE = 0 THEN yw.ACT_RECEIVABLE_FEE when  t.bill_type = 0 and yw.REVENUE_TYPE = 1 then -yw.ACT_RECEIVABLE_FEE  when t.bill_type = 1 and yw.REVENUE_TYPE = 0 then -yw.ACT_RECEIVABLE_FEE else  yw.ACT_RECEIVABLE_FEE END),0) from  yw_contract_revenue yw where yw.bill_id = t.id and yw.status = 0 and yw.isdeleted = 0 ) as  actReceivableFee  ") 
 | 
                        .selectAs(YwContract::getCode,YwContractBill::getContractCode) 
 | 
                        .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) 
 | 
                        .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) 
 | 
                        .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) 
 | 
                        .eq(YwContractBill::getIsdeleted,Constants.ZERO) 
 | 
                        .like(Objects.nonNull(model)&&StringUtils.isNotBlank(model.getCustomerName()), 
 | 
                                YwCustomer::getName,model.getCustomerName()) 
 | 
                        .eq(Objects.nonNull(model)&&Objects.nonNull(model.getStatus()), 
 | 
                                YwContractBill::getStatus,model.getStatus()) 
 | 
                        .eq(Objects.nonNull(model)&&Objects.nonNull(model.getBillType()), 
 | 
                                YwContractBill::getBillType,model.getBillType()) 
 | 
                        .eq(Objects.nonNull(model)&&Objects.nonNull(model.getPayStatus()), 
 | 
                                YwContractBill::getPayStatus,model.getPayStatus()) 
 | 
                        .in(Objects.nonNull(model)&&Objects.nonNull(model.getPayStatus()), 
 | 
                                YwContractBill::getPayStatus,Constants.ZERO,Constants.THREE,Constants.TWO,Constants.FOUR) 
 | 
                        .eq(Objects.nonNull(model)&&Objects.nonNull(model.getType()), 
 | 
                                YwContractBill::getType,model.getType()) 
 | 
                        .le(Objects.nonNull(model)&&Objects.nonNull(model.getIsOverdue())&&Constants.equalsInteger(model.getIsOverdue(),Constants.ONE), 
 | 
                                YwContractBill::getPlanPayDate, DateUtil.getCurrDateTime()) 
 | 
                        .eq(Objects.nonNull(model)&&Objects.nonNull(model.getIsOverdue())&&Constants.equalsInteger(model.getIsOverdue(),Constants.ONE), 
 | 
                                YwContractBill::getStatus, Constants.ZERO) 
 | 
                        .ge(Objects.nonNull(model)&&Objects.nonNull(model.getPlanPayDateStart()),YwContractBill::getPlanPayDate, Utils.Date.getStart(model.getPlanPayDateStart())) 
 | 
                        .le(Objects.nonNull(model)&&Objects.nonNull(model.getPlanPayDateEnd()),YwContractBill::getPlanPayDate, Utils.Date.getEnd(model.getPlanPayDateEnd())) 
 | 
                        .orderByDesc(YwContractBill::getId)); 
 | 
        this.dealRoomDetail(iPage.getRecords()); 
 | 
        for (YwContractBill ywContractBill:iPage.getRecords()) { 
 | 
            //需收金额 
 | 
            ywContractBill.setNeedReceivableFee( 
 | 
                    ywContractBill.getReceivableFee().subtract(ywContractBill.getActReceivableFee()) 
 | 
            ); 
 | 
            //楼宇名称 
 | 
            List<YwContractRoom> ywContractRoomList = ywContractBill.getYwContractRoomList(); 
 | 
            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractRoomList)){ 
 | 
                StringBuilder roomPathName = new StringBuilder(); 
 | 
                for (YwContractRoom ywContractRoom:ywContractRoomList) { 
 | 
                    if(StringUtils.isNotBlank(ywContractRoom.getProjectName())){ 
 | 
                        roomPathName.append(ywContractRoom.getProjectName()+"/"); 
 | 
                    } 
 | 
                    if(StringUtils.isNotBlank(ywContractRoom.getBuildingName())){ 
 | 
                        roomPathName.append(ywContractRoom.getBuildingName()+"/"); 
 | 
                    } 
 | 
                    if(StringUtils.isNotBlank(ywContractRoom.getFloorName())){ 
 | 
                        roomPathName.append(ywContractRoom.getFloorName()+"/"); 
 | 
                    } 
 | 
                    if(StringUtils.isNotBlank(ywContractRoom.getRoomName())){ 
 | 
                        roomPathName.append(ywContractRoom.getRoomName()); 
 | 
                    } 
 | 
                    if(StringUtils.isNotBlank(roomPathName)){ 
 | 
                        roomPathName.append(";"); 
 | 
                    } 
 | 
                } 
 | 
                ywContractBill.setRoomPathName(roomPathName.toString()); 
 | 
            } 
 | 
        } 
 | 
  
 | 
        return PageData.from(iPage); 
 | 
    } 
 | 
  
 | 
    public void dealRoomDetail(List<YwContractBill> ywContractBillList){ 
 | 
        //查询账单下的楼宇数据 
 | 
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractBillList)){ 
 | 
            //获取所有数据 
 | 
            List<Integer> billIdList = ywContractBillList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ONE)).map(i->i.getId()).collect(Collectors.toList()); 
 | 
            List<Integer> contractIdList = ywContractBillList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ZERO)).map(i->i.getContractId()).collect(Collectors.toList()); 
 | 
            List<YwContractRoom> ywContractRoomList  = new ArrayList<>(); 
 | 
            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(billIdList)){ 
 | 
                ywContractRoomList.addAll( ywContractRoomMapper.selectJoinList(YwContractRoom.class,new MPJLambdaWrapper<YwContractRoom>() 
 | 
                        .selectAll(YwContractRoom.class) 
 | 
                        .selectAs(YwProject::getName,YwRoom::getProjectName) 
 | 
                        .selectAs(YwFloor::getName,YwRoom::getFloorName) 
 | 
                        .selectAs(YwBuilding::getName,YwRoom::getBuildingName) 
 | 
                        .selectAs(YwRoom::getCode,YwContractRoom::getRoomName) 
 | 
                        .leftJoin(YwRoom.class,YwRoom::getId,YwContractRoom::getRoomId) 
 | 
                        .leftJoin(YwFloor.class,YwFloor::getId,YwRoom::getFloor) 
 | 
                        .leftJoin(YwProject.class,YwProject::getId,YwRoom::getProjectId) 
 | 
                        .leftJoin(YwBuilding.class,YwBuilding::getId,YwRoom::getBuildingId) 
 | 
                        .in(YwContractRoom::getContractId,billIdList) 
 | 
                        .eq(YwContractRoom::getType,Constants.ONE) 
 | 
                )); 
 | 
  
 | 
            } 
 | 
            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(contractIdList)){ 
 | 
                ywContractRoomList.addAll( ywContractRoomMapper.selectJoinList(YwContractRoom.class,new MPJLambdaWrapper<YwContractRoom>() 
 | 
                        .selectAll(YwContractRoom.class) 
 | 
                        .selectAs(YwProject::getName,YwRoom::getProjectName) 
 | 
                        .selectAs(YwFloor::getName,YwRoom::getFloorName) 
 | 
                        .selectAs(YwBuilding::getName,YwRoom::getBuildingName) 
 | 
                        .selectAs(YwRoom::getCode,YwContractRoom::getRoomName) 
 | 
                        .leftJoin(YwRoom.class,YwRoom::getId,YwContractRoom::getRoomId) 
 | 
                        .leftJoin(YwFloor.class,YwFloor::getId,YwRoom::getFloor) 
 | 
                        .leftJoin(YwProject.class,YwProject::getId,YwRoom::getProjectId) 
 | 
                        .leftJoin(YwBuilding.class,YwBuilding::getId,YwRoom::getBuildingId) 
 | 
                        .in(YwContractRoom::getContractId,contractIdList) 
 | 
                        .eq(YwContractRoom::getType,Constants.ZERO) 
 | 
                )); 
 | 
            } 
 | 
  
 | 
            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractRoomList)){ 
 | 
                for (YwContractBill ywContractBill:ywContractBillList) { 
 | 
                    if(Constants.equalsInteger(ywContractBill.getType(),Constants.ZERO) || Constants.equalsInteger(ywContractBill.getType(),Constants.TWO)){ 
 | 
                        ywContractBill.setYwContractRoomList( 
 | 
                                ywContractRoomList.stream().filter(i->(Constants.equalsInteger(i.getType(),Constants.TWO)||Constants.equalsInteger(i.getType(),Constants.ZERO))&&Constants.equalsInteger(i.getContractId(),ywContractBill.getContractId())).collect(Collectors.toList()) 
 | 
                        ); 
 | 
                    }else{ 
 | 
                        ywContractBill.setYwContractRoomList( 
 | 
                                ywContractRoomList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.ONE)&&Constants.equalsInteger(i.getContractId(),ywContractBill.getId())).collect(Collectors.toList()) 
 | 
                        ); 
 | 
                    } 
 | 
  
 | 
                } 
 | 
            } 
 | 
  
 | 
        } 
 | 
    } 
 | 
  
 | 
  
 | 
    @Override 
 | 
    public long count(YwContractBill ywContractBill) { 
 | 
        QueryWrapper<YwContractBill> wrapper = new QueryWrapper<>(ywContractBill); 
 | 
        return ywContractBillMapper.selectCount(wrapper); 
 | 
    } 
 | 
  
 | 
  
 | 
  
 | 
    @Override 
 | 
    public void dealDayBillCode(){ 
 | 
        List<YwContractBill> ywContractBillList = ywContractBillMapper.selectJoinList(YwContractBill.class, 
 | 
                new MPJLambdaWrapper<YwContractBill>() 
 | 
                        .selectAll(YwContractBill.class) 
 | 
                        .select(" DATE(CREATE_DATE)  as codeDate") 
 | 
                        .isNull(YwContractBill::getCode) 
 | 
                        .orderByAsc(YwContractBill::getId) 
 | 
        ); 
 | 
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractBillList)){ 
 | 
            List<String> codeDateList = ywContractBillList.stream().map(i->i.getCodeDate()).collect(Collectors.toList()); 
 | 
            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(codeDateList)){ 
 | 
                Set<String> codeDateSet = new HashSet<String>(codeDateList); 
 | 
                for (String codeDate:codeDateSet) { 
 | 
                    //获取当前日期的数据 
 | 
                    List<YwContractBill> codeDateBillList = 
 | 
                            ywContractBillList.stream().filter(i->StringUtils.isNotBlank(i.getCodeDate()) && i.getCodeDate().equals(codeDate)).collect(Collectors.toList()); 
 | 
                    if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(codeDateBillList)){ 
 | 
                        continue; 
 | 
                    } 
 | 
                    //查询最大的单号 
 | 
                    YwContractBill ywContractBill = ywContractBillMapper.selectOne(new QueryWrapper<YwContractBill>().lambda() 
 | 
                            .isNotNull(YwContractBill::getCode) 
 | 
                            .apply(" CREATE_DATE like '"+codeDate+"%' ") 
 | 
                            .orderByDesc(YwContractBill::getId) 
 | 
                            .last(" limit  1 ") 
 | 
                    ); 
 | 
                    Integer maxCode = Constants.ZERO; 
 | 
                    if(Objects.nonNull(ywContractBill)){ 
 | 
                        maxCode = Integer.valueOf(ywContractBill.getCode().replace(("ZD"+codeDate+"-"),"")); 
 | 
                    } 
 | 
                    for (YwContractBill contractBill:codeDateBillList) { 
 | 
                        maxCode = maxCode + 1; 
 | 
                        contractBill.setCode("ZD" + codeDate + "-" + StringUtils.leftPad(maxCode.toString() , 4,"0")); 
 | 
                        ywContractBillMapper.update(null, new UpdateWrapper<YwContractBill>().lambda().set(YwContractBill::getCode,contractBill.getCode()) 
 | 
                                .eq(YwContractBill::getId,contractBill.getId())); 
 | 
                    } 
 | 
                } 
 | 
            } 
 | 
        } 
 | 
    } 
 | 
  
 | 
  
 | 
    @Override 
 | 
    public List<YwContractBill> getCanBackBill(YwContractBill model) { 
 | 
        List<YwContractBill> list = ywContractBillMapper.selectJoinList(YwContractBill.class, 
 | 
                new MPJLambdaWrapper<YwContractBill>().selectAll(YwContractBill.class) 
 | 
//                        .select(" ( select ifnull(sum(case when yw.REVENUE_TYPE = 0 then yw.ACT_RECEIVABLE_FEE  else  -yw.ACT_RECEIVABLE_FEE end),0) from  yw_contract_revenue yw where yw.bill_id = t.id and yw.status = 0 and yw.isdeleted = 0 ) as  actReceivableFee  ") 
 | 
                        .select(" ( select ifnull( sum( CASE WHEN t.bill_type = 0 and yw.REVENUE_TYPE = 0 THEN yw.ACT_RECEIVABLE_FEE when  t.bill_type = 0 and yw.REVENUE_TYPE = 1 then -yw.ACT_RECEIVABLE_FEE  when t.bill_type = 1 and yw.REVENUE_TYPE = 0 then -yw.ACT_RECEIVABLE_FEE else  yw.ACT_RECEIVABLE_FEE END),0) from  yw_contract_revenue yw where yw.bill_id = t.id and yw.status = 0 and yw.isdeleted = 0 ) as  actReceivableFee  ") 
 | 
                        .selectAs(YwContract::getCode,YwContractBill::getContractCode) 
 | 
                        .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) 
 | 
                        .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) 
 | 
                        .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) 
 | 
                        .eq(YwContractBill::getIsdeleted,Constants.ZERO) 
 | 
                        .in(YwContractBill::getCostType,Constants.ZERO,Constants.ONE,Constants.FOUR,Constants.FIVE,7) 
 | 
                        .eq(Objects.nonNull(model)&&Objects.nonNull(model.getContractId()), 
 | 
                                YwContractBill::getContractId,model.getContractId()) 
 | 
                        .and(Objects.nonNull(model)&&Objects.nonNull(model.getPlanPayDateEnd()), 
 | 
                                i->i.le(YwContractBill::getStartDate, Utils.Date.getEnd(model.getPlanPayDateEnd())).or() 
 | 
                        .in(YwContractBill::getPayStatus,Constants.ONE,Constants.TWO) )) 
 | 
                ; 
 | 
  
 | 
        for (YwContractBill ywContractBill:list) { 
 | 
            ywContractBill.setNeedReceivableFee(ywContractBill.getReceivableFee().subtract(ywContractBill.getActReceivableFee())); 
 | 
        } 
 | 
        return list; 
 | 
    } 
 | 
  
 | 
  
 | 
    @Override 
 | 
    public YwContractBillDataVO getWaitDealList(Integer contractId){ 
 | 
        YwContractBillDataVO ywContractBillDataVO = new YwContractBillDataVO(); 
 | 
        ywContractBillDataVO.setInAmount(Constants.ZERO); 
 | 
        ywContractBillDataVO.setInFee(BigDecimal.ZERO); 
 | 
        ywContractBillDataVO.setPayAmount(Constants.ZERO); 
 | 
        ywContractBillDataVO.setPayFee(BigDecimal.ZERO); 
 | 
        MPJLambdaWrapper<YwContractBill> queryWrapper = new MPJLambdaWrapper<YwContractBill>(); 
 | 
        queryWrapper.selectAll(YwContractBill.class) 
 | 
            .select(" ( select ifnull( sum( CASE WHEN t.bill_type = 0 and yw.REVENUE_TYPE = 0 THEN yw.ACT_RECEIVABLE_FEE when  t.bill_type = 0 and yw.REVENUE_TYPE = 1 then -yw.ACT_RECEIVABLE_FEE  when t.bill_type = 1 and yw.REVENUE_TYPE = 0 then -yw.ACT_RECEIVABLE_FEE else  yw.ACT_RECEIVABLE_FEE END),0) from  yw_contract_revenue yw where yw.bill_id = t.id and yw.status = 0 and yw.isdeleted = 0 ) as  actReceivableFee  ") 
 | 
            .selectAs(YwContract::getCode,YwContractBill::getContractCode) 
 | 
            .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) 
 | 
            .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) 
 | 
            .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) 
 | 
            .eq(YwContractBill::getIsdeleted,Constants.ZERO) 
 | 
            .in(YwContractBill::getPayStatus,Constants.ZERO,Constants.TWO,Constants.THREE,Constants.FOUR) 
 | 
            .eq(YwContractBill::getContractId,contractId) 
 | 
            .orderByDesc(YwContractBill::getId); 
 | 
        List<YwContractBill> list = ywContractBillMapper.selectJoinList(YwContractBill.class,queryWrapper); 
 | 
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(list)){ 
 | 
            for (YwContractBill ywContractBill:list) { 
 | 
                //需收金额 
 | 
                ywContractBill.setNeedReceivableFee( 
 | 
                        ywContractBill.getReceivableFee().subtract(ywContractBill.getActReceivableFee()) 
 | 
                ); 
 | 
                //收款账单 
 | 
                if(Constants.equalsInteger(ywContractBill.getBillType(),Constants.ZERO)){ 
 | 
                    //应收金额 小于 实收金额 多收金额  应该是退款 
 | 
                     if(ywContractBill.getNeedReceivableFee().compareTo(BigDecimal.ZERO)<Constants.ZERO){ 
 | 
                         ywContractBillDataVO.setPayAmount(ywContractBillDataVO.getPayAmount()+1); 
 | 
                         ywContractBillDataVO.setPayFee(ywContractBillDataVO.getPayFee().add(ywContractBill.getNeedReceivableFee().abs())); 
 | 
                     }else if(ywContractBill.getNeedReceivableFee().compareTo(BigDecimal.ZERO)>Constants.ZERO){ 
 | 
                         ywContractBillDataVO.setInAmount(ywContractBillDataVO.getInAmount()+1); 
 | 
                         ywContractBillDataVO.setInFee(ywContractBillDataVO.getInFee().add(ywContractBill.getNeedReceivableFee().abs())); 
 | 
                     } 
 | 
                }else{ 
 | 
                    //付款账单 
 | 
                    //应付金额 小于 实付金额 应该是付款款 
 | 
                    if(ywContractBill.getNeedReceivableFee().compareTo(BigDecimal.ZERO)<Constants.ZERO){ 
 | 
                        ywContractBillDataVO.setPayAmount(ywContractBillDataVO.getPayAmount()+1); 
 | 
                        ywContractBillDataVO.setPayFee(ywContractBillDataVO.getPayFee().add(ywContractBill.getNeedReceivableFee().abs())); 
 | 
                    }else{ 
 | 
                        ywContractBillDataVO.setInAmount(ywContractBillDataVO.getInAmount()+1); 
 | 
                        ywContractBillDataVO.setInFee(ywContractBillDataVO.getInFee().add(ywContractBill.getNeedReceivableFee().abs())); 
 | 
                    } 
 | 
                } 
 | 
            } 
 | 
            ywContractBillDataVO.setYwContractBillList(list); 
 | 
        } 
 | 
  
 | 
        return ywContractBillDataVO; 
 | 
    } 
 | 
  
 | 
  
 | 
  
 | 
  
 | 
    @Override 
 | 
    public List<YwContractBillCallDataVO> getNoticeCustomerData(List<Integer> billIds){ 
 | 
        List<YwContractBillCallDataVO> ywContractBillCallDataVOList = new ArrayList<>(); 
 | 
        List<YwContractBill> ywContractBillList = ywContractBillMapper.selectJoinList(YwContractBill.class,new MPJLambdaWrapper<YwContractBill>() 
 | 
                .selectAll(YwContractBill.class) 
 | 
                .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) 
 | 
                .selectAs(YwCustomer::getUserId,YwContractBill::getCustomerUserId) 
 | 
                .selectAs(YwCustomer::getId,YwContractBill::getCustomerId) 
 | 
                .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) 
 | 
                .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) 
 | 
                .in(YwContractBill::getId,billIds) 
 | 
        ); 
 | 
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(ywContractBillList) || 
 | 
            !Constants.equalsInteger(billIds.size(),ywContractBillList.size()) 
 | 
        ){ 
 | 
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"账单数据错误,请刷新重试"); 
 | 
        } 
 | 
        this.dealRoomDetail(ywContractBillList); 
 | 
        for (YwContractBill ywContractBill:ywContractBillList) { 
 | 
            YwContractBillCallDataVO ywContractBillCallDataVO = new YwContractBillCallDataVO(); 
 | 
            ywContractBillCallDataVO.setBillId(ywContractBill.getId()); 
 | 
            ywContractBillCallDataVO.setCustomerName(ywContractBill.getCustomerName()); 
 | 
            ywContractBillCallDataVO.setUserId(ywContractBill.getCustomerUserId()); 
 | 
            //查询客户下的所有人员 
 | 
            ywContractBillCallDataVO.setMemberList( 
 | 
                memberMapper.selectList(new QueryWrapper<Member>().lambda().eq(Member::getCustomerId,ywContractBill.getCustomerId()) 
 | 
                        .eq(Member::getIsdeleted,Constants.ZERO)) 
 | 
            ); 
 | 
            ywContractBillCallDataVOList.add(ywContractBillCallDataVO); 
 | 
        } 
 | 
        return ywContractBillCallDataVOList; 
 | 
    } 
 | 
  
 | 
  
 | 
    @Override 
 | 
    public void downloadCallFeeDoc(List<Integer> billIds, LoginUserInfo loginUserInfo,HttpServletResponse response){ 
 | 
        try { 
 | 
            List<YwContractBill> ywContractBillList = ywContractBillMapper.selectJoinList(YwContractBill.class,new MPJLambdaWrapper<YwContractBill>() 
 | 
                    .selectAll(YwContractBill.class) 
 | 
                    .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) 
 | 
                    .selectAs(YwCustomer::getUserId,YwContractBill::getCustomerUserId) 
 | 
                    .selectAs(YwCustomer::getId,YwContractBill::getCustomerId) 
 | 
                    .selectAs(YwContractDetail::getPrice,YwContractBill::getPrice) 
 | 
                    .selectAs(YwContract::getCompanyId,YwContractBill::getCompanyId) 
 | 
                    .selectAs(YwContractDetail::getCircleType,YwContractBill::getCircleType) 
 | 
                    .selectAs(YwContractDetail::getType,YwContractBill::getDetailType) 
 | 
                    .selectAs(YwContract::getZlPayType,YwContractBill::getZlPayType) 
 | 
                    .selectAs(YwContract::getWyPayType,YwContractBill::getWyPayType) 
 | 
                    .select(" ( select ifnull(sum(r.rent_area),0) from yw_room y left join yw_contract_room yr on y.id = yr.room_id where yr.contract_id = t.contract_id and y.IS_INVESTMENT = 0 and yr.type = 0 )  " , YwContractBill::getTotalArea) 
 | 
                    .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) 
 | 
                    .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) 
 | 
                    .leftJoin(YwContractDetail.class,YwContractDetail::getId,YwContractBill::getDetailId) 
 | 
                    .in(YwContractBill::getId,billIds) 
 | 
            ); 
 | 
            List<YwTempConfig> ywTempConfigList = ywTempConfigMapper.selectList(new QueryWrapper<YwTempConfig>().lambda().eq(YwTempConfig::getIsdeleted,Constants.ZERO)); 
 | 
            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(ywTempConfigList)){ 
 | 
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到模板配置项,请联系管理员"); 
 | 
            } 
 | 
            List<YwTempConfig> tempList = ywTempConfigList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.FOUR)|| 
 | 
                    Constants.equalsInteger(i.getType(),Constants.FIVE)|| 
 | 
                    Constants.equalsInteger(i.getType(),Constants.SIX)).collect(Collectors.toList()); 
 | 
            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(tempList)){ 
 | 
                throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到模板配置项,请联系管理员"); 
 | 
            } 
 | 
            List<File> fileList = new ArrayList<>(); 
 | 
            for (YwContractBill ywContractBill:ywContractBillList) { 
 | 
                this.dealTempData(tempList,ywContractBill,loginUserInfo); 
 | 
                String fileName =  "催费通知单_" +ywContractBill.getCode() +"_" + System.currentTimeMillis()+".docx"; 
 | 
                YwTempConfig ywTempConfig = new YwTempConfig(); 
 | 
                if(Constants.equalsInteger(ywContractBill.getType(),Constants.ZERO)){ 
 | 
                    Optional<YwTempConfig> optional = ywTempConfigList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.TWO)).findAny(); 
 | 
                    if (optional.isPresent()) { 
 | 
                        ywTempConfig = optional.get(); 
 | 
                    } 
 | 
                }else{ 
 | 
                    Optional<YwTempConfig> optional = ywTempConfigList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.THREE)).findAny(); 
 | 
                    if (optional.isPresent()) { 
 | 
                        ywTempConfig = optional.get(); 
 | 
                    } 
 | 
                } 
 | 
                if(Objects.isNull(ywTempConfig)){ 
 | 
                    throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"模板信息异常,请联系管理员"); 
 | 
                } 
 | 
                String path = ExcelReplaceCommon.modifyWordTemplate(ywTempConfig.getUrl(),tempList,fileName); 
 | 
                File f = new File(path); 
 | 
                if(f !=null && f.isFile()){ 
 | 
                    fileList.add(f); 
 | 
                } 
 | 
                if(fileList == null || fileList.size() == 0){ 
 | 
                    throw  new BusinessException(ResponseStatus.DATA_EMPTY); 
 | 
                } 
 | 
            } 
 | 
            String fileName =  "催费通知单-" +System.currentTimeMillis(); 
 | 
            String encodeFileName = URLEncoder.encode(fileName, Charset.forName("UTF-8").toString())+".zip"; 
 | 
            response.setHeader("Content-Disposition","attachment;filename=" + encodeFileName); 
 | 
            response.setContentType("application/octet-stream"); 
 | 
            response.setHeader("eva-opera-type", "download"); 
 | 
            response.setHeader("eva-download-filename", encodeFileName); 
 | 
            Constants.packFilesToZip(fileList,response.getOutputStream()); 
 | 
        } catch (Exception e) { 
 | 
            throw new BusinessException(ResponseStatus.EXPORT_EXCEL_ERROR, e); 
 | 
        } 
 | 
    } 
 | 
  
 | 
  
 | 
    public void dealTempData(List<YwTempConfig> ywTempConfigList , YwContractBill ywContractBill, LoginUserInfo loginUserInfo){ 
 | 
        //查询收支账号数据 
 | 
  
 | 
        for (YwTempConfig y:ywTempConfigList) { 
 | 
            if(y.getTitle().equals("${费用名称}")&&Objects.nonNull(ywContractBill.getCostType())){ 
 | 
                //费用类型:0=租赁费;1=物业费;2=租赁押金;3=物业押金;4=水电费;5=杂项费;6=其他; 7=保证金 
 | 
                if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.ZERO)){ 
 | 
                    y.setUrl("租赁费"); 
 | 
                }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.ONE)){ 
 | 
                    y.setUrl("物业费"); 
 | 
                }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.TWO)){ 
 | 
                    y.setUrl("租赁押金"); 
 | 
                }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.THREE)){ 
 | 
                    y.setUrl("物业押金"); 
 | 
                }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.FOUR)){ 
 | 
                    y.setUrl("水电费"); 
 | 
                }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.FIVE)){ 
 | 
                    y.setUrl("杂项费"); 
 | 
                }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.SIX)){ 
 | 
                    y.setUrl("其他"); 
 | 
                }else if(Constants.equalsInteger(ywContractBill.getCostType(),Constants.SEVEN)){ 
 | 
                    y.setUrl("保证金"); 
 | 
                } 
 | 
            }else if(y.getTitle().equals("${计费周期}")&&Objects.nonNull(ywContractBill.getDetailType())){ 
 | 
                if(Constants.equalsInteger(ywContractBill.getDetailType(),Constants.ZERO)){ 
 | 
                    //租赁支付方式 0=一次性付款;1=每三个月一付;2=六个月一付;3=一年一付 
 | 
                    if(Objects.nonNull(ywContractBill.getZlPayType())){ 
 | 
                        if(Constants.equalsInteger(ywContractBill.getZlPayType(),Constants.ZERO)){ 
 | 
                            y.setUrl("一次性付款"); 
 | 
                        }else if(Constants.equalsInteger(ywContractBill.getZlPayType(),Constants.ONE)){ 
 | 
                            y.setUrl("每三个月一付"); 
 | 
                        }else if(Constants.equalsInteger(ywContractBill.getZlPayType(),Constants.TWO)){ 
 | 
                            y.setUrl("六个月一付"); 
 | 
                        }else if(Constants.equalsInteger(ywContractBill.getZlPayType(),Constants.THREE)){ 
 | 
                            y.setUrl("一年一付"); 
 | 
                        } 
 | 
                    } 
 | 
                }else{ 
 | 
                    //物业支付方式 0=一次性付款;1=每三个月一付;2=六个月一付;3=一年一付 
 | 
                    if(Objects.nonNull(ywContractBill.getWyPayType())){ 
 | 
                        if(Constants.equalsInteger(ywContractBill.getWyPayType(),Constants.ZERO)){ 
 | 
                            y.setUrl("一次性付款"); 
 | 
                        }else if(Constants.equalsInteger(ywContractBill.getWyPayType(),Constants.ONE)){ 
 | 
                            y.setUrl("每三个月一付"); 
 | 
                        }else if(Constants.equalsInteger(ywContractBill.getWyPayType(),Constants.TWO)){ 
 | 
                            y.setUrl("六个月一付"); 
 | 
                        }else if(Constants.equalsInteger(ywContractBill.getWyPayType(),Constants.THREE)){ 
 | 
                            y.setUrl("一年一付"); 
 | 
                        } 
 | 
                    } 
 | 
                } 
 | 
            }else if(y.getTitle().equals("${单价}")&&Objects.nonNull(ywContractBill.getPrice())){ 
 | 
                y.setUrl(ywContractBill.getPrice().toString()); 
 | 
            }else if(y.getTitle().equals("${单位}")&&Objects.nonNull(ywContractBill.getCircleType())){ 
 | 
                //付款周期类型 0=元每平米天;1=元每平米月;2=元每平米年;3=元每天;4=元每月;5=元每年;6=元每场; 
 | 
                if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ZERO)){ 
 | 
                    y.setUrl("元每平米天"); 
 | 
                }else if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ONE)){ 
 | 
                    y.setUrl("元每平米月"); 
 | 
                }else if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ONE)){ 
 | 
                    y.setUrl("元每平米年"); 
 | 
                } else if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ONE)){ 
 | 
                    y.setUrl("元每天"); 
 | 
                } else if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ONE)){ 
 | 
                    y.setUrl("元每月"); 
 | 
                } else if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ONE)){ 
 | 
                    y.setUrl("元每年"); 
 | 
                } else if(Constants.equalsInteger(ywContractBill.getCircleType(),Constants.ONE)){ 
 | 
                    y.setUrl("元每场"); 
 | 
                } 
 | 
            }else if(y.getTitle().equals("${应收日期}")&&Objects.nonNull(ywContractBill.getPlanPayDate())){ 
 | 
                y.setUrl(DateUtil.formatDate(ywContractBill.getPlanPayDate(),"yyyy-MM-dd")); 
 | 
            }else if(y.getTitle().equals("${应收金额}")&&Objects.nonNull(ywContractBill.getReceivableFee())){ 
 | 
                y.setUrl(ywContractBill.getReceivableFee().toString()); 
 | 
            }else if(y.getTitle().equals("${账单备注}")){ 
 | 
                if(StringUtils.isNotBlank(ywContractBill.getRemark())){ 
 | 
                    y.setUrl(ywContractBill.getRemark()); 
 | 
                }else{ 
 | 
                    y.setUrl(""); 
 | 
                } 
 | 
            }else if(y.getTitle().equals("${租客名称}")&&StringUtils.isNotBlank(ywContractBill.getCustomerName())){ 
 | 
                y.setUrl(ywContractBill.getCustomerName()); 
 | 
            }else if(y.getTitle().equals("${楼宇/楼层/房源}")){ 
 | 
                if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractBill.getYwContractRoomList())){ 
 | 
                    StringBuilder roomPathName = new StringBuilder(); 
 | 
                    for (YwContractRoom ywContractRoom:ywContractBill.getYwContractRoomList()) { 
 | 
                        if(StringUtils.isNotBlank(ywContractRoom.getProjectName())){ 
 | 
                            roomPathName.append(ywContractRoom.getProjectName()+"/"); 
 | 
                        } 
 | 
                        if(StringUtils.isNotBlank(ywContractRoom.getBuildingName())){ 
 | 
                            roomPathName.append(ywContractRoom.getBuildingName()+"/"); 
 | 
                        } 
 | 
                        if(StringUtils.isNotBlank(ywContractRoom.getFloorName())){ 
 | 
                            roomPathName.append(ywContractRoom.getFloorName()+"/"); 
 | 
                        } 
 | 
                        if(StringUtils.isNotBlank(ywContractRoom.getRoomName())){ 
 | 
                            roomPathName.append(ywContractRoom.getRoomName()); 
 | 
                        } 
 | 
                        if(StringUtils.isNotBlank(roomPathName)){ 
 | 
                            roomPathName.append(";"); 
 | 
                        } 
 | 
                    } 
 | 
                    y.setUrl(roomPathName.toString()); 
 | 
                } 
 | 
            }else if(y.getTitle().equals("${租赁面积}")&&Objects.nonNull(ywContractBill.getTotalArea())){ 
 | 
                y.setUrl(ywContractBill.getTotalArea().toString()); 
 | 
            }else if(y.getTitle().equals("${所属公司账户名称}")){ 
 | 
                y.setUrl("所属公司账户名称"); 
 | 
            }else if(y.getTitle().equals("${所属公司银行账号}")){ 
 | 
                y.setUrl("所属公司银行账号"); 
 | 
            }else if(y.getTitle().equals("${所属公司开户银行}")){ 
 | 
                y.setUrl("所属公司开户银行"); 
 | 
            }else if(y.getTitle().equals("${通知单生成日期}")){ 
 | 
                y.setUrl(DateUtil.formatDate(new Date(),"yyyy-MM-dd")); 
 | 
            }else if(y.getTitle().equals("${当前用户姓名}")){ 
 | 
                y.setUrl(loginUserInfo.getRealname()); 
 | 
            } 
 | 
        } 
 | 
    } 
 | 
  
 | 
  
 | 
    public void sendSmsEmail(List<YwSmsEmailBillCallDTO> ywSmsEmailBillCallDTOList,LoginUserInfo loginUserInfo){ 
 | 
        if(CollectionUtils.isEmpty(ywSmsEmailBillCallDTOList)){ 
 | 
            throw new BusinessException(ResponseStatus.BAD_REQUEST); 
 | 
        } 
 | 
        List<YwTempConfig> ywTempConfigList = ywTempConfigMapper.selectList(new QueryWrapper<YwTempConfig>().lambda().eq(YwTempConfig::getIsdeleted,Constants.ZERO)); 
 | 
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(ywTempConfigList)){ 
 | 
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到模板配置项,请联系管理员"); 
 | 
        } 
 | 
        List<YwTempConfig> tempList = ywTempConfigList.stream().filter(i->Constants.equalsInteger(i.getType(),Constants.FOUR)|| 
 | 
                Constants.equalsInteger(i.getType(),Constants.FIVE)|| 
 | 
                Constants.equalsInteger(i.getType(),Constants.SIX)).collect(Collectors.toList()); 
 | 
        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(tempList)){ 
 | 
            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"未查询到模板配置项,请联系管理员"); 
 | 
        } 
 | 
        for (YwSmsEmailBillCallDTO ywSmsEmailBillCallDTO:ywSmsEmailBillCallDTOList) { 
 | 
            if(Objects.isNull(ywSmsEmailBillCallDTO) 
 | 
            || Objects.isNull(ywSmsEmailBillCallDTO.getBillId()) 
 | 
                    || Objects.isNull(ywSmsEmailBillCallDTO.getUserId()) 
 | 
            ||Objects.isNull(ywSmsEmailBillCallDTO.getSendEmail()) 
 | 
                    || Objects.isNull(ywSmsEmailBillCallDTO.getSendSms())){ 
 | 
                throw new BusinessException(ResponseStatus.BAD_REQUEST); 
 | 
            } 
 | 
  
 | 
            YwContractBill ywContractBill = ywContractBillMapper.selectJoinOne(YwContractBill.class,new MPJLambdaWrapper<YwContractBill>() 
 | 
                    .selectAll(YwContractBill.class) 
 | 
                    .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) 
 | 
                    .selectAs(YwCustomer::getUserId,YwContractBill::getCustomerUserId) 
 | 
                    .selectAs(YwCustomer::getId,YwContractBill::getCustomerId) 
 | 
                    .selectAs(YwContractDetail::getPrice,YwContractBill::getPrice) 
 | 
                    .selectAs(YwContract::getCompanyId,YwContractBill::getCompanyId) 
 | 
                    .selectAs(YwContractDetail::getCircleType,YwContractBill::getCircleType) 
 | 
                    .selectAs(YwContractDetail::getType,YwContractBill::getDetailType) 
 | 
                    .selectAs(YwContract::getZlPayType,YwContractBill::getZlPayType) 
 | 
                    .selectAs(YwContract::getWyPayType,YwContractBill::getWyPayType) 
 | 
                    .select(" ( select ifnull(sum(r.rent_area),0) from yw_room y left join yw_contract_room yr on y.id = yr.room_id where yr.contract_id = t.contract_id and y.IS_INVESTMENT = 0 and yr.type = 0 )  " , YwContractBill::getTotalArea) 
 | 
                    .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) 
 | 
                    .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) 
 | 
                    .leftJoin(YwContractDetail.class,YwContractDetail::getId,YwContractBill::getDetailId) 
 | 
                    .eq(YwContractBill::getId,ywSmsEmailBillCallDTO.getBillId()) 
 | 
                    .last( "limit 1" ) 
 | 
            ); 
 | 
            this.dealTempData(tempList,ywContractBill,loginUserInfo); 
 | 
            Member member = memberMapper.selectById(ywSmsEmailBillCallDTO.getUserId()); 
 | 
            if(Objects.isNull(member)){ 
 | 
                throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"存在未查询到的人员信息"); 
 | 
            } 
 | 
  
 | 
  
 | 
        } 
 | 
  
 | 
  
 | 
        for (YwSmsEmailBillCallDTO ywSmsEmailBillCallDTO:ywSmsEmailBillCallDTOList) { 
 | 
  
 | 
  
 | 
  
 | 
  
 | 
  
 | 
        } 
 | 
  
 | 
  
 | 
  
 | 
  
 | 
  
 | 
  
 | 
  
 | 
  
 | 
  
 | 
  
 | 
         
 | 
    } 
 | 
  
 | 
  
 | 
  
 | 
} 
 |