kcim-cost/src/main/java/com/imed/costaccount/service/impl/CostResponsibilityDepartmentServiceImpl.java

package com.imed.costaccount.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.imed.costaccount.common.exception.CostException;
import com.imed.costaccount.constants.NumberConstant;
import com.imed.costaccount.mapper.CostResponsibilityDepartmentMapper;
import com.imed.costaccount.model.CostResponsibilityDepartment;
import com.imed.costaccount.model.Department;
import com.imed.costaccount.model.User;
import com.imed.costaccount.model.vo.CostDepartmentVO;
import com.imed.costaccount.service.CostResponsibilityDepartmentService;
import com.imed.costaccount.common.util.BeanUtil;
import org.apache.shiro.SecurityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;

import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;


@Service("/costResponsibilityDepartmentService")
public class CostResponsibilityDepartmentServiceImpl extends ServiceImpl<CostResponsibilityDepartmentMapper, CostResponsibilityDepartment> implements CostResponsibilityDepartmentService {

    @Autowired
    private DepartmentServiceImpl departmentService;
    /**
     * 根据责任中心的Id获取对应的科室信息的集合
     *
     * @param responsibilityId
     * @return
     */
    @Override
    public List<CostDepartmentVO> getByResponsibilityId(Integer responsibilityId) {
        if (responsibilityId<=0){
            throw new CostException("请选择责任中心数据");
        }
        User user = (User) SecurityUtils.getSubject().getPrincipal();
        // 当前医院责任中心所具有的的科室
        List<CostResponsibilityDepartment> costResponsibilityDepartmentList = baseMapper.selectList(new QueryWrapper<CostResponsibilityDepartment>().lambda().eq(CostResponsibilityDepartment::getResponsibilityId, responsibilityId));
        Map<Long, List<CostResponsibilityDepartment>> costResponsibilityDepartmentMap = costResponsibilityDepartmentList.stream().distinct().collect(Collectors.groupingBy(CostResponsibilityDepartment::getDepartmentId));
        // 所有科室
        List<Department> departmentList = departmentService.getByDepartment(null,null,null,user.getHospId());
        List<CostDepartmentVO> departVOList = BeanUtil.convertList(departmentList, CostDepartmentVO.class);
        departVOList.forEach(i->{
            if (!CollectionUtils.isEmpty(costResponsibilityDepartmentMap.get(i.getId()))){
                i.setDepartmentStatus(NumberConstant.ONE);
            }else {
                i.setDepartmentStatus(NumberConstant.ZERO);
            }
        });
        return departVOList;
    }

    /**
     * 批量删除责任中心科室损益信息
     *
     * @param idList 责任中心科室对应的Id集合
     */
    @Override
    @Transactional(propagation = Propagation.REQUIRED,rollbackFor = Exception.class)
    public void deleteByIds(List<Integer> idList) {
        this.removeByIds(idList);
    }
}