产品供销存-后端
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
gaoluyang
10 天以前 344a18cc69dd2f728734e940421b717cacb85563 
 src/main/java/com/ruoyi/staff/service/impl/PersonalShiftServiceImpl.java


@@ -2,26 +2,22 @@




import cn.hutool.core.collection.CollUtil;


import cn.hutool.core.date.DateTime;


import cn.hutool.core.date.DateUtil;


import cn.hutool.core.util.StrUtil;


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.ruoyi.common.utils.SecurityUtils;


import com.ruoyi.project.system.domain.SysDictData;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ruoyi.staff.dto.PerformanceShiftAddDto;


import com.ruoyi.staff.dto.PerformanceShiftMapDto;


import com.ruoyi.staff.mapper.PersonalAttendanceLocationConfigMapper;


import com.ruoyi.staff.mapper.PersonalShiftMapper;


import com.ruoyi.staff.pojo.PersonalAttendanceLocationConfig;


import com.ruoyi.staff.pojo.PersonalShift;


import com.ruoyi.staff.mapper.PersonalShiftMapper;


import com.ruoyi.staff.service.PersonalAttendanceLocationConfigService;


import com.ruoyi.staff.service.PersonalShiftService;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.ruoyi.staff.utils.JackSonUtil;


import org.apache.commons.lang3.StringUtils;


import org.springframework.beans.factory.annotation.Autowired;


import lombok.RequiredArgsConstructor;


import org.springframework.stereotype.Service;


import cn.hutool.core.date.DateUtil;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.ObjectUtils;




@@ -29,7 +25,6 @@


import java.text.SimpleDateFormat;


import java.time.LocalDate;


import java.time.LocalDateTime;


import java.time.YearMonth;


import java.time.ZoneId;


import java.time.format.DateTimeFormatter;


import java.time.temporal.TemporalAdjusters;


@@ -46,10 +41,10 @@


 */


@Service


@Transactional(rollbackFor = Exception.class)


@RequiredArgsConstructor


public class PersonalShiftServiceImpl extends ServiceImpl<PersonalShiftMapper, PersonalShift> implements PersonalShiftService {




    @Autowired


    private PersonalAttendanceLocationConfigMapper personalAttendanceLocationConfigMapper;


    private final PersonalAttendanceLocationConfigMapper personalAttendanceLocationConfigMapper;




    @Override


    public int performanceShiftAdd(PerformanceShiftAddDto performanceShiftAddDto) {


@@ -161,6 +156,12 @@


                }


            }


        }


        // 合计出勤天数以实际打卡记录为准（排班只代表计划）


        Map<String, Integer> attendanceDays = loadMonthAttendanceDays(time, userName, sysDeptId);


        for (PerformanceShiftMapDto i : mapIPage.getRecords()) {


            i.getMonthlyAttendance().put("totalAttendance",


                    attendanceDays.getOrDefault(i.getUserId(), 0));


        }


        // 获取header时间


        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");


        DateTimeFormatter formatters = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");


@@ -195,7 +196,8 @@


        IPage<Map<String, Object>> mapYearIPage = baseMapper.performanceShiftYear(page, time, userName, sysDeptId);


        //查询所有班次(打卡规则)


        List<PersonalAttendanceLocationConfig> personalAttendanceLocationConfigs = personalAttendanceLocationConfigMapper.selectList(null);


        mapYearIPage.setRecords(annualAttendanceProcessing(mapYearIPage.getRecords(), personalAttendanceLocationConfigs));


        Map<String, Map<Integer, Integer>> attendanceCounts = loadYearAttendanceDays(time, userName, sysDeptId);


        mapYearIPage.setRecords(annualAttendanceProcessing(mapYearIPage.getRecords(), personalAttendanceLocationConfigs, attendanceCounts));


        return mapYearIPage;


    }




@@ -209,7 +211,8 @@


        LocalDateTime localDateTime = LocalDateTime.parse(time, formatters);


        map.put("header", getYearHeader(localDateTime.getYear() + " 年", personalAttendanceLocationConfigs));


        List<Map<String, Object>> mapYearList = baseMapper.performanceShiftYearList(time, userName, sysDeptId);


        annualAttendanceProcessing(mapYearList, personalAttendanceLocationConfigs);


        Map<String, Map<Integer, Integer>> attendanceCounts = loadYearAttendanceDays(time, userName, sysDeptId);


        annualAttendanceProcessing(mapYearList, personalAttendanceLocationConfigs, attendanceCounts);


        List<List<Object>> lists = dataRequiredForProcessingIntoExcel(mapYearList, personalAttendanceLocationConfigs);


        map.put("data", lists);


        return map;


@@ -220,6 +223,8 @@


        //查询所有班次(打卡规则)


        List<PersonalAttendanceLocationConfig> personalAttendanceLocationConfigs = personalAttendanceLocationConfigMapper.selectList(null);


        List<PerformanceShiftMapDto> mapIPage = baseMapper.performanceShiftList(time, userName, sysDeptId);


        // 合计出勤天数以实际打卡记录为准（排班只代表计划）


        Map<String, Integer> attendanceDays = loadMonthAttendanceDays(time, userName, sysDeptId);


        mapIPage.forEach(i -> {


            String[] shiftTimes = i.getShiftTime().split(";");


            double totalAttendance = 0;


@@ -228,6 +233,9 @@


            for (String shiftTime : shiftTimes) {


                Map<String, Object> hashMap = new HashMap<>();


                String[] shiftTimeAndShift = shiftTime.split("：");


                if(shiftTimeAndShift.length != 3){


                    continue;


                }


                for (PersonalAttendanceLocationConfig personalAttendanceLocationConfig : personalAttendanceLocationConfigs) {


                    if (!i.getMonthlyAttendance().containsKey(personalAttendanceLocationConfig.getShift())) {


                        i.getMonthlyAttendance().put(personalAttendanceLocationConfig.getShift(), 0);


@@ -251,6 +259,8 @@


            }


            i.setList(map);


            i.setShiftTime(null);


            i.getMonthlyAttendance().put("totalAttendance",


                    attendanceDays.getOrDefault(i.getUserId(), 0));


        });


        Map<Object, Object> map = new HashMap<>();


        DateTimeFormatter formatters = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");


@@ -258,20 +268,60 @@


        LocalDateTime localDateTime = LocalDateTime.parse(time, formatters);


        map.put("header", getMonthHeader(localDateTime));


        List<List<Object>> lists = dataRequiredForProcessingIntoExcelMonth(mapIPage, personalAttendanceLocationConfigs);


        int maxSize = lists.stream()


                .mapToInt(List::size)


                .max()


                .orElse(0);




        for (List<Object> row : lists) {


            while (row.size() < maxSize) {


                row.add("-");


            }


        }


        map.put("data", lists);


        return map;


    }




    // 实际打卡出勤天数（按月）


    private Map<String, Integer> loadMonthAttendanceDays(String time, String userName, Integer sysDeptId) {


        Map<String, Integer> result = new HashMap<>();


        for (Map<String, Object> row : baseMapper.attendanceDayCountByMonth(time, userName, sysDeptId)) {


            Object userId = row.get("user_id");


            Object days = row.get("days");


            if (userId != null && days != null) {


                result.put(String.valueOf(userId), new BigDecimal(days.toString()).intValue());


            }


        }


        return result;


    }




    // 实际打卡出勤天数（按年，每人每月）


    private Map<String, Map<Integer, Integer>> loadYearAttendanceDays(String time, String userName, Integer sysDeptId) {


        Map<String, Map<Integer, Integer>> result = new HashMap<>();


        for (Map<String, Object> row : baseMapper.attendanceMonthCountByYear(time, userName, sysDeptId)) {


            Object userId = row.get("user_id");


            Object month = row.get("month");


            Object days = row.get("days");


            if (userId == null || month == null || days == null) {


                continue;


            }


            result.computeIfAbsent(String.valueOf(userId), k -> new HashMap<>())


                    .put(Integer.parseInt(month.toString()), new BigDecimal(days.toString()).intValue());


        }


        return result;


    }




    // 年分页与导出共同使用


    public List<Map<String, Object>> annualAttendanceProcessing(List<Map<String, Object>> mapYearList,List<PersonalAttendanceLocationConfig> personalAttendanceLocationConfigs) {


    public List<Map<String, Object>> annualAttendanceProcessing(List<Map<String, Object>> mapYearList, List<PersonalAttendanceLocationConfig> personalAttendanceLocationConfigs, Map<String, Map<Integer, Integer>> attendanceCounts) {


        for (Map<String, Object> map : mapYearList) {


            Map<String, Object> resultMap = new LinkedHashMap<>();


            Map<String, Object> hashMapYear = new LinkedHashMap<>();


            double totalYearAttendance = 0;


            // 每个月的合计出勤天数以实际打卡记录为准


            Map<Integer, Integer> staffMonthAttendance = attendanceCounts.getOrDefault(String.valueOf(map.get("user_id")), Collections.emptyMap());


            // 一年12个月


            for (int i = 1; i < 13; i++) {


                Map<String, Object> hashMapMonth = new LinkedHashMap<>();


                double totalMonthAttendance = 0;


                for (PersonalAttendanceLocationConfig personalAttendanceLocationConfig : personalAttendanceLocationConfigs) {


                    // 初始化赋值


                    if (!hashMapYear.containsKey(personalAttendanceLocationConfig.getShift())){


@@ -283,14 +333,6 @@


                        int count = countOccurrences(charArray, i + "：" + personalAttendanceLocationConfig.getShift());


                        hashMapMonth.put(personalAttendanceLocationConfig.getShift(), count);


                        hashMapYear.put(personalAttendanceLocationConfig.getShift(), new BigDecimal(hashMapYear.get(personalAttendanceLocationConfig.getShift()).toString()).add(new BigDecimal(count)));


                        // 早，中，夜，差


                        if (personalAttendanceLocationConfig.getShift().contains("早") ||


                                personalAttendanceLocationConfig.getShift().contains("中") ||


                                personalAttendanceLocationConfig.getShift().contains("晚") ||


                                personalAttendanceLocationConfig.getShift().contains("夜")) {


                            totalMonthAttendance += count;


                            totalYearAttendance += count;


                        }


                    }


                    // 空数据


                    else {


@@ -298,7 +340,9 @@


                        hashMapMonth.put(personalAttendanceLocationConfig.getShift(), 0);


                    }


                }


                hashMapMonth.put("totalMonthAttendance", totalMonthAttendance);


                int monthAttendance = staffMonthAttendance.getOrDefault(i, 0);


                totalYearAttendance += monthAttendance;


                hashMapMonth.put("totalMonthAttendance", monthAttendance);


                hashMapYear.put("totalYearAttendance", totalYearAttendance);


                resultMap.put(i + "", hashMapMonth);


            }