EmploymentSite/src/main/java/com/hz/employmentsite/services/impl/companyService/PostServiceImpl.java

package com.hz.employmentsite.services.impl.companyService;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.hz.employmentsite.filter.exception.BaseException;
import com.hz.employmentsite.mapper.*;
import com.hz.employmentsite.mapper.cquery.LabelCQuery;
import com.hz.employmentsite.mapper.cquery.PostCQuery;
import com.hz.employmentsite.mapper.cquery.RecommendMgtCQuery;
import com.hz.employmentsite.model.*;
import com.hz.employmentsite.services.service.companyService.PostService;
import com.hz.employmentsite.services.service.system.DictionaryService;
import com.hz.employmentsite.util.StringUtils;
import com.hz.employmentsite.vo.companyService.PostVo;
import com.hz.employmentsite.vo.companyService.RecommendPostVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

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

@Service("PostService")
public class PostServiceImpl implements PostService {
    @Autowired
    private PostCQuery postCQuery;


    @Autowired
    private StringUtils stringUtils;

    @Autowired
    private PcPostMapper pcPostMapper;

    @Autowired
    private PcRecommendMapper pcRecommendMapper;

    @Autowired
    private PcRecommendMgtMapper pcRecommendMgtMapper;

    @Autowired
    private PcProfessionMapper pcProfessionMapper;

    @Autowired
    private PcCompanyMapper companyMapper;

    @Autowired
    private PcSiteUserMapper pcSiteUserMapper;

    @Autowired
    private DictionaryService dictionaryService;

    @Autowired
    private PcLabelPostMapper pcLabelPostMapper;

    @Autowired
    private LabelCQuery labelCQuery;

    @Autowired
    private RecommendMgtCQuery recommendMgtCQuery;

    @Autowired
    private PcWorkcategoryMapper pcWorkcategoryMapper;

    @Override
    public PageInfo<PostVo> getList(Integer page, Integer rows, List<String> postIDList,
                                    String professionName, Integer minCount, Integer maxCount,
                                    String companyName, String recordStatus, String companyID,
                                    String loginUserID, String siteID, Date startDate,
                                    Date endDate) {
        List<String> curLoginUserSiteCompanyIDs = new ArrayList<>();
        if (!stringUtils.IsNullOrEmpty(loginUserID)) {
            PcSiteUserExample siteUserExp = new PcSiteUserExample();
            siteUserExp.or().andUserIDEqualTo(loginUserID);
            var curLoginUserSiteID = pcSiteUserMapper.selectByExample(siteUserExp).get(0).getSiteID();
            PcCompanyExample companyExp = new PcCompanyExample();
            companyExp.or().andSiteIDEqualTo(curLoginUserSiteID);
            var curLoginUserSiteCompanyList = companyMapper.selectByExample(companyExp).stream().toList();
            for (PcCompany curLoginUserSiteCompany : curLoginUserSiteCompanyList) {
                curLoginUserSiteCompanyIDs.add(curLoginUserSiteCompany.getCompanyID());
            }
        }
        PageHelper.startPage(page, rows);
        List<PostVo> list = postCQuery.selectPostList(stringUtils.ListToInSql(postIDList), professionName, minCount, maxCount, companyName, recordStatus, companyID, stringUtils.ListToInSql(curLoginUserSiteCompanyIDs), siteID, startDate, endDate);
        if(list != null && list.size()>0){
            for(PostVo curPost : list){
                curPost.listLabel = labelCQuery.getPostLabelList(curPost.getPostID());
            }
        }
        PageInfo<PostVo> result = new PageInfo(list);
        return result;

    }

    @Override
    public PageInfo<RecommendPostVo> getCommendPostList(Integer page, Integer rows, String jobUserID) {
        PageHelper.startPage(page, rows);
        List<RecommendPostVo> list = postCQuery.selectRecommendPostList(jobUserID);
        PageInfo<RecommendPostVo> result = new PageInfo(list);
        return result;
    }

    @Override
    public Integer saveCommendPost(RecommendPostVo data, String userId) {
        int result = 0;
        PcRecommend dbData = null;
        if (data.recommendID != null) {
            PcRecommendExample exp = new PcRecommendExample();
            PcRecommendExample.Criteria cro = exp.createCriteria();
            cro.andPostIDEqualTo(data.recommendID);
            dbData = pcRecommendMapper.selectByExample(exp).stream().findFirst().orElse(null);
        }
        Boolean isExist = dbData != null;
        if (!isExist) {
            dbData = new PcRecommend();
            dbData.setRecommendID(UUID.randomUUID().toString());
            dbData.setJobuserID(data.jobUserID);
            dbData.setPostID(data.postID);
            dbData.setIsRead(data.isRead == null ? false : true);
            dbData.setIsSendnotes(data.isSendNotes == null ? false : true);
            dbData.setCreateTime(new Date());
            dbData.setCreateUserID(userId);
            result = pcRecommendMapper.insert(dbData);
        } else {
            dbData.setJobuserID(data.jobUserID);
            dbData.setPostID(data.postID);
            dbData.setIsRead(data.isRead == null ? false : true);
            dbData.setIsSendnotes(data.isSendNotes == null ? false : true);
            dbData.setModifyTime(new Date());
            dbData.setModifyUserID(userId);
            result = pcRecommendMapper.updateByPrimaryKeySelective(dbData);
        }
        return result;
    }


    @Override
    public int save(PostVo data, String userId) {
        int result = 0;
        PcPost dbData = null;
        Boolean isExist = data.getPostID() != null;
        PcPostExample exp = new PcPostExample();
        PcPostExample.Criteria cro = exp.createCriteria();
        if (isExist) {
            cro.andPostIDEqualTo(data.getPostID());
            dbData = pcPostMapper.selectByExample(exp).stream().findFirst().orElse(null);
        }

        //判断岗位id是否为空
        if (stringUtils.IsNullOrEmpty(data.getProfessionID())) {
            PcProfessionExample proEmp = new PcProfessionExample();
            PcProfessionExample.Criteria proCia = proEmp.or();
            proCia.andParentProfessionIDNotEqualTo("");
            proCia.andProfessionNameEqualTo("其他");
            //获取二级其他信息
            PcProfession proOther = pcProfessionMapper.selectByExample(proEmp).stream().findFirst().orElse(null);
            if (proOther != null) {
                proEmp = new PcProfessionExample();
                proEmp.or().andParentProfessionIDEqualTo(proOther.getProfessionID());
//                proCia.andProfessionNameEqualTo(data.getProfessionName());

                //查询其他岗位
                List<PcProfession> proOtherSonList = pcProfessionMapper.selectByExample(proEmp);
                PcProfession proOtherSon = proOtherSonList.stream()
                        .filter(x -> x.getProfessionName().equals(data.getProfessionName())).findFirst().orElse(null);
                if (proOtherSon != null) {
                    data.setProfessionID(proOtherSon.getProfessionID());
                } else {
                    data.setProfessionID(UUID.randomUUID().toString());
                    PcProfession proModel = new PcProfession();
                    proModel.setProfessionID(data.getProfessionID());
                    proModel.setParentProfessionID(proOther.getProfessionID());
                    proModel.setProfessionName(data.getProfessionName());
                    proModel.setStatus(Integer.parseInt("1"));
                    proModel.setOrderNo(proOtherSonList.size() + 1);

                    pcProfessionMapper.insert(proModel);
                }
            }
        }

        if (dbData == null) {
            dbData = new PcPost();
            dbData.setPostID(UUID.randomUUID().toString());
            dbData.setProfessionID(data.getProfessionID());
            dbData.setWorkCode(data.getWorkCode());
            dbData.setWorkName(data.getWorkName());
            dbData.setValidTime(data.getValidTime());
            dbData.setRecruitCount(data.getRecruitCount());
            dbData.setCompanyID(data.getCompanyID());
            dbData.setPostName(data.getPostName());
            dbData.setRecordStatus(data.getRecordStatus());
            dbData.setWorkNature(data.getWorkNature());
            dbData.setValidDay(data.getValidDay());
            dbData.setWorkYear(data.getWorkYear());
            dbData.setWorkNature(data.getWorkNature());
            dbData.setCultureRank(data.getCultureRank());
            dbData.setPostDesc(data.getPostDesc());
            dbData.setMaxSalary(data.getMaxSalary());
            dbData.setMinSalary(data.getMinSalary());
            dbData.setWelfare(data.getWelfare());
            dbData.setUserName(data.getUserName());
            dbData.setUserMobile(data.getUserMobile());
            dbData.setPostEmail(data.getPostEmail());
            dbData.setWorkTime(data.getWorkTime());
            dbData.setIsTrail(data.getIsTrail());
            dbData.setTrailMonths(data.getTrailMonths());
            dbData.setTrailMaxSalary(data.getTrailMaxSalary());
            dbData.setTrailMinSalary(data.getTrailMinSalary());
            dbData.setCreateTime(new Date());
            dbData.setCreateUserID(userId);
            dbData.setJobPlace(data.getJobPlace());
            dbData.setStartTime(data.getStartTime());
            dbData.setEndTime(data.getEndTime());
            dbData.setContactName(data.getContactName());
            dbData.setContactMobile(data.getContactMobile());
            dbData.setContactEmail(data.getContactEmail());
            dbData.setWorkNatureID(data.getWorkNatureID());
//            dbData.setTagID(data.getTagID());
            result = pcPostMapper.insert(dbData);
        } else {
            dbData.setProfessionID(data.getProfessionID());
            dbData.setWorkCode(data.getWorkCode());
            dbData.setValidTime(data.getValidTime());
            dbData.setWorkName(data.getWorkName());
            dbData.setRecruitCount(data.getRecruitCount());
            dbData.setCompanyID(data.getCompanyID());
            dbData.setPostName(data.getPostName());
            dbData.setRecordStatus(data.getRecordStatus());
            dbData.setWorkNature(data.getWorkNature());
            dbData.setValidDay(data.getValidDay());
            dbData.setWorkYear(data.getWorkYear());
            dbData.setWorkNature(data.getWorkNature());
            dbData.setCultureRank(data.getCultureRank());
            dbData.setPostDesc(data.getPostDesc());
            dbData.setMaxSalary(data.getMaxSalary());
            dbData.setMinSalary(data.getMinSalary());
            dbData.setWelfare(data.getWelfare());
            dbData.setUserName(data.getUserName());
            dbData.setUserMobile(data.getUserMobile());
            dbData.setPostEmail(data.getPostEmail());
            dbData.setWorkTime(data.getWorkTime());
            dbData.setIsTrail(data.getIsTrail());
            dbData.setTrailMonths(data.getTrailMonths());
            dbData.setTrailMaxSalary(data.getTrailMaxSalary());
            dbData.setTrailMinSalary(data.getTrailMinSalary());
            dbData.setModifyTime(new Date());
            dbData.setModifyUserID(userId);
            dbData.setJobPlace(data.getJobPlace());
            dbData.setStartTime(data.getStartTime());
            dbData.setEndTime(data.getEndTime());
            dbData.setContactName(data.getContactName());
            dbData.setContactMobile(data.getContactMobile());
            dbData.setContactEmail(data.getContactEmail());
            dbData.setWorkNatureID(data.getWorkNatureID());
//            dbData.setTagID(data.getTagID());
            result = pcPostMapper.updateByPrimaryKeyWithBLOBs(dbData);
        }

        PcLabelPostExample labelEmp = new PcLabelPostExample();
        labelEmp.or().andPostIDEqualTo(data.getPostID());
        pcLabelPostMapper.deleteByExample(labelEmp);
        if (data.listLabel != null && data.listLabel.size() > 0) {
            data.listLabel.forEach(x -> {
                PcLabelPost labelModel = new PcLabelPost();
                labelModel.setPostID(data.getPostID());
                labelModel.setLabelID(x.getLabelID());
                pcLabelPostMapper.insert(labelModel);
            });
        }
        return result;
    }


    @Override
    public int delete(List<String> ids) {
        int result = 0;
        PcPostExample postExp = new PcPostExample();
        postExp.or().andPostIDIn(ids);
        result = pcPostMapper.deleteByExample(postExp);
        if (result > 0) {
            PcLabelPostExample labelEmp = new PcLabelPostExample();
            labelEmp.or().andPostIDIn(ids);
            pcLabelPostMapper.deleteByExample(labelEmp);
        }
        return result;
    }

    @Override
    public int deletePostAndRecommendMgt(String id) {
        try {
            PcRecommendMgtExample exp = new PcRecommendMgtExample();
            PcRecommendMgtExample.Criteria cro = exp.or();
            cro.andPostIDEqualTo(id);
            pcRecommendMgtMapper.deleteByExample(exp);

            PcLabelPostExample labelEmp = new PcLabelPostExample();
            labelEmp.or().andPostIDEqualTo(id);
            pcLabelPostMapper.deleteByExample(labelEmp);

            return pcPostMapper.deleteByPrimaryKey(id);
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
        }
    }

    @Override
    public PostVo getDataById(String id) {
        if (stringUtils.IsNullOrEmpty(id)) {
            return null;
        }

        PostVo data = postCQuery.selectPostList(stringUtils.ListToInSql(Arrays.asList(id)), null, null, null, null, null, null, null, null, null, null).stream().findFirst().orElse(null);
        if (data != null) {
            data.listLabel = labelCQuery.getPostLabelList(id);
        }
        return data;
    }

    @Override
    public List<PostVo> getDataListByCompanyID(String companyId) {
        List<PostVo> resultList = new ArrayList<>();
        PcPostExample postExp = new PcPostExample();
        postExp.or().andCompanyIDEqualTo(companyId);
        var postList = pcPostMapper.selectByExample(postExp);
        for (PcPost curPost : postList) {
            PostVo item = new PostVo();
            item.setPostID(curPost.getPostID());
            item.setProfessionID(curPost.getProfessionID());
            PcProfessionExample professionExp = new PcProfessionExample();
            professionExp.or().andProfessionIDEqualTo(curPost.getProfessionID());
            var curProfession = pcProfessionMapper.selectByExample(professionExp).get(0);
            item.setProfessionName(curProfession.getProfessionName());
            item.setCompanyID(curPost.getCompanyID());
            item.setRecruitCount(curPost.getRecruitCount());
            item.setStartTime(curPost.getStartTime());
            item.setEndTime(curPost.getEndTime());
            resultList.add(item);
        }
        return resultList;
    }

    @Override
    public List<PostVo> importPost(List<PostVo> dataList, String userID) {
        if (dataList.size() <= 0)
            throw new BaseException("", "请添加导入数据！");
        //所属企业
        PcCompanyExample companyExp = new PcCompanyExample();
        companyExp.or().andRecordStatusEqualTo(1);
        List<PcCompany> companyList = companyMapper.selectByExample(companyExp);
        //岗位信息
        List<SysDictionaryItem> thirdLevelProfessionList = new ArrayList<>();
        PcProfessionExample professionExp = new PcProfessionExample();
        professionExp.or().andParentProfessionIDEqualTo("").andStatusEqualTo(1);
        var firstLevelData = pcProfessionMapper.selectByExample(professionExp);
        for (PcProfession curProfession : firstLevelData) {
            professionExp = new PcProfessionExample();
            professionExp.or().andParentProfessionIDEqualTo(curProfession.getProfessionID()).andStatusEqualTo(1);
            var secondLevelData = pcProfessionMapper.selectByExample(professionExp);
            for (PcProfession curParentProfession : secondLevelData) {
                professionExp = new PcProfessionExample();
                professionExp.or().andParentProfessionIDEqualTo(curParentProfession.getProfessionID()).andStatusEqualTo(1);
                var thirdLevelData = pcProfessionMapper.selectByExample(professionExp);
                for (PcProfession curItem : thirdLevelData) {
                    SysDictionaryItem item = new SysDictionaryItem();
                    item.setCode(curItem.getProfessionID());
                    item.setName(curItem.getProfessionName());
                    thirdLevelProfessionList.add(item);
                }
            }
        }
        // 工种信息
        List<SysDictionaryItem> WorkCategoryList = new ArrayList<>();
        // 获取第一级工种
        PcWorkcategoryExample workCategoryExample = new PcWorkcategoryExample();
        workCategoryExample.or().andParentWorkCategoryIDEqualTo("").andStatusEqualTo(1);
        List<PcWorkcategory> firstLevelWorkCategoryList = pcWorkcategoryMapper.selectByExample(workCategoryExample);
        for (PcWorkcategory pcWorkcategory : firstLevelWorkCategoryList) {
            // 获取第二级工种
            workCategoryExample = new PcWorkcategoryExample();
            workCategoryExample.or().andParentWorkCategoryIDEqualTo(pcWorkcategory.getWorkCategoryID()).andStatusEqualTo(1);
            List<PcWorkcategory> secondLevelWorkCategoryList = pcWorkcategoryMapper.selectByExample(workCategoryExample);
            for (PcWorkcategory workCategory : secondLevelWorkCategoryList) {
                // 获取第三级工种
                workCategoryExample = new PcWorkcategoryExample();
                workCategoryExample.or().andParentWorkCategoryIDEqualTo(workCategory.getWorkCategoryID()).andStatusEqualTo(1);
                List<PcWorkcategory> thirdLevelWorkCategoryList = pcWorkcategoryMapper.selectByExample(workCategoryExample);
                for (PcWorkcategory pcWorkCategory1 : thirdLevelWorkCategoryList) {
                    SysDictionaryItem item = new SysDictionaryItem();
                    item.setCode(pcWorkCategory1.getWorkCategoryID());
                    item.setName(pcWorkCategory1.getWorkCategoryName());
                    WorkCategoryList.add(item);
                }
            }
        }

        //文化程度
        List<SysDictionaryItem> dicCultureDataList = dictionaryService.getDictionaryItemList("CultureLevel");
        // 工作年限
        List<SysDictionaryItem> dicWorkYearDataList = dictionaryService.getDictionaryItemList("WorkYearType");
        List<PostVo> resultList = new ArrayList<>();

        dataList.forEach(item -> {
            String errorInfo = "";
            item.setPostID(UUID.randomUUID().toString());
            item.setRecordStatus(1);
            if (stringUtils.IsNullOrEmpty(item.companyName))
                errorInfo += "请填写企业名称!";
            else {
                item.companyID = companyList.stream().filter(it -> it.getCompanyName().equals(item.getCompanyName().trim()))
                        .findFirst().orElse(new PcCompany()).getCompanyID();
                if (item.companyID == null)
                    errorInfo += "企业不存在！";
            }
            if (stringUtils.IsNullOrEmpty(item.professionName))
                errorInfo += "请填写岗位名称!";
            else {
                item.professionID = thirdLevelProfessionList.stream().filter(it -> it.getName().equals(item.getProfessionName().trim()))
                        .findFirst().orElse(new SysDictionaryItem()).getCode();
                if (item.professionID == null || item.professionID == "")
                    errorInfo += "岗位不存在！";
            }
            if (stringUtils.IsNullOrEmpty(item.getWorkCategoryName())) {
                errorInfo += "请填写工种名称";
            } else {
                item.workCode = WorkCategoryList.stream().filter(it -> it.getName().equals(item.getWorkCategoryName().trim()))
                        .findFirst().orElse(new SysDictionaryItem()).getCode();
                if (item.workCode == null || item.workCode == "") {
                    errorInfo += "工种不存在！";
                }
            }

            if (stringUtils.IsNullOrEmpty(String.valueOf(item.recruitCount)) || item.recruitCount == null)
                errorInfo += "请填写招聘人数!";

            if (stringUtils.IsNullOrEmpty(String.valueOf(item.startTime)) || item.startTime == null)
                errorInfo += "请填写开始日期!";
            if (stringUtils.IsNullOrEmpty(String.valueOf(item.startTime)) || item.startTime == null)
                errorInfo += "请填写结束日期!";
            if (stringUtils.IsNullOrEmpty(item.jobPlace))
                errorInfo += "请填写工作地点!";

            if (!stringUtils.IsNullOrEmpty(item.getWorkYearName())) {
                item.workYear = dicWorkYearDataList.stream().filter(it -> it.getName().equals(item.getWorkYearName().trim()))
                        .findFirst().orElse(new SysDictionaryItem()).getValue();
                if (item.workYear == null)
                    errorInfo += "工作年限不存在!";
            }

            if (item.isTrailName.trim().equals("是")) item.isTrail = true;
            else if (item.isTrailName.trim().equals("否")) item.isTrail = false;

            if (!stringUtils.IsNullOrEmpty(item.cultureLevelName)) {
                item.cultureRank = dicCultureDataList.stream().filter(it -> it.getName().equals(item.cultureLevelName.trim()))
                        .findFirst().orElse(new SysDictionaryItem()).getValue();
                if (item.cultureRank == null || item.cultureRank == 0)
                    errorInfo += "输入的学历要求不存在!";
            }

            if (stringUtils.IsNullOrEmpty(errorInfo)) {
                resultList.add(item);
            } else {
                item.setErrorMessage(errorInfo);
            }
        });

        if (dataList.stream().filter(it -> !stringUtils.IsNullOrEmpty(it.errorMessage)).collect(Collectors.toList()).size() > 0)
            return dataList;
        resultList.forEach(item -> {
            save(item, userID);
        });
        return null;
    }
}