java-insagent-pc/src/main/java/com/ydtech/modules/admin/service/impl/DeptBalanceServiceImpl.java

package com.ydtech.modules.admin.service.impl;

import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.ydtech.core.page.HttpResult;
import com.ydtech.modules.admin.dao.DeptBalanceMapper;
import com.ydtech.modules.admin.model.dto.DeptBalanceDto;
import com.ydtech.modules.admin.model.dto.EsmUserReferrerDTO;
import com.ydtech.modules.admin.model.dto.QxFrontlineAgentDto;
import com.ydtech.modules.admin.model.vo.DeptBalanceVo;
import com.ydtech.modules.admin.service.DeptBalanceService;
import com.ydtech.modules.admin.service.SysAgencyLeaderService;
import com.ydtech.modules.base.model.vo.PageVo;
import com.ydtech.modules.fnc.entity.SettlementDocumentaryFeesSumEntity;
import org.apache.commons.lang3.ObjectUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.*;
import java.util.function.Function;
import java.util.stream.Collectors;

@Service
public class DeptBalanceServiceImpl implements DeptBalanceService {


    @Autowired
    private SysAgencyLeaderService sysAgencyLeaderService;

    @Autowired
    private DeptBalanceMapper deptBalanceMapper;

    /**
     *  @version
     *  @author: whp
     *  @Date: 2024/08/14 9:04
     *  @Description:  机构负责人统计
     */
    @Override
    public HttpResult<IPage<DeptBalanceDto>> queryDeptLeaderStatistics(DeptBalanceVo deptBalanceVo) {
        try {
            PageVo<DeptBalanceDto> pageVo = new PageVo<>();
            Page page = new Page(deptBalanceVo.getPageNum(), deptBalanceVo.getPageSize());
            pageVo.setPageNum(deptBalanceVo.getPageNum());
            pageVo.setPageSize(deptBalanceVo.getPageSize());
            IPage<DeptBalanceDto> sysUserListPage = deptBalanceMapper.queryDeptLeaderStatistics(page, deptBalanceVo);
            return HttpResult.ok(sysUserListPage);
        } catch (Exception e) {
            e.printStackTrace();
            return HttpResult.error("查询异常");
        }
    }

}