EmploymentSite/src/main/java/com/hz/employmentsite/services/impl/taskAndLog/DoTaskImpl.java

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

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.hz.employmentsite.mapper.PcDotaskMapper;
import com.hz.employmentsite.mapper.PcDotaskUserMapper;
import com.hz.employmentsite.mapper.PcSiteUserMapper;
import com.hz.employmentsite.mapper.cquery.DoTaskCQuery;
import com.hz.employmentsite.model.*;
import com.hz.employmentsite.services.service.taskAndLog.DoTaskService;
import com.hz.employmentsite.util.StringUtils;
import com.hz.employmentsite.vo.taskAndLog.DoTaskUserVo;
import com.hz.employmentsite.vo.taskAndLog.DoTaskVo;
import com.hz.employmentsite.vo.baseSettings.SiteUserVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.UUID;

@Service("DoTaskService")
public class DoTaskImpl implements DoTaskService {

    @Autowired
    private DoTaskCQuery doTaskCQuery;

    @Autowired
    private StringUtils stringUtils;

    @Autowired
    private PcDotaskMapper doTaskMapper;

    @Autowired
    private PcSiteUserMapper pcSiteUserMapper;

    @Autowired
    private PcDotaskUserMapper doTaskUserMapper;

    @Override
    public PageInfo<DoTaskVo> getList(Integer page, Integer rows,List<String> doTaskIDList, String name, String startTime, String endTime, String finishStartTime, String finishEndTime, String regionCode, String streetCode, String workTypeId,Integer taskStatus) {
        try {
            PageHelper.startPage(page, rows);
            List<DoTaskVo> list = doTaskCQuery.getList(stringUtils.ListToInSql(doTaskIDList), name, startTime, endTime, finishStartTime, finishEndTime, regionCode, streetCode, workTypeId,taskStatus);
            PageInfo<DoTaskVo> result = new PageInfo(list);
            return result;
        } catch (Exception e) {
            throw new RuntimeException("Database query exception: " + e.getMessage(), e);
        }
    }

    @Override
    public PageInfo<DoTaskVo> getMyTasks(Integer page, Integer rows,String doTaskID,String taskName, String curUserID) {
        PcSiteUserExample siteUserExp = new PcSiteUserExample();
        PcSiteUserExample.Criteria siteUserCro = siteUserExp.createCriteria();
        siteUserCro.andUserIDEqualTo(curUserID);
        var curSiteUserInfo = pcSiteUserMapper.selectByExample(siteUserExp).stream().findFirst().orElse(null);
        if(curSiteUserInfo==null){
            throw new RuntimeException("当前用户未绑定站点人员，未能查询到相关工作任务！");
        }else{
            try {
                PageHelper.startPage(page, rows);
                String siteUserID = curSiteUserInfo.getSiteUserID();
                var list = doTaskCQuery.getListByUserID(siteUserID,doTaskID,taskName);
                PageInfo<DoTaskVo> result = new PageInfo(list);
                return result;
            } catch (Exception e) {
                throw new RuntimeException("Database query exception: " + e.getMessage(), e);
            }
        }
    }

    @Override
    public List<DoTaskUserVo> getWorkUserList(String doTaskID) {
        List<DoTaskUserVo> list = doTaskCQuery.getWorkUserList(doTaskID);
        return list;
    }

    @Override
    public List<SiteUserVo> getUserList() {
        List<SiteUserVo> list = doTaskCQuery.getUserList();
        return list;
    }

    @Override
    public DoTaskVo getDataById(String id) {
        if (stringUtils.IsNullOrEmpty(id)) {
            return null;
        }
        List<String> ids = new ArrayList<>();
        ids.add(id);
        return doTaskCQuery.getList(stringUtils.ListToInSql(ids), null, null, null, null, null, null, null, null,null).stream().findFirst().orElse(null);
    }

    @Override
    public int taskFinish(String doTaskID,String finishUserID, Date completeTime){
        int result = 0;
        PcSiteUserExample siteUserExp = new PcSiteUserExample();
        PcSiteUserExample.Criteria siteUserCro = siteUserExp.createCriteria();
        siteUserCro.andUserIDEqualTo(finishUserID);
        var curSiteUserInfo = pcSiteUserMapper.selectByExample(siteUserExp).stream().findFirst().orElse(null);
        if(curSiteUserInfo==null){
            throw new RuntimeException("当前用户未绑定站点人员，未能查询到相关工作任务！");
        }
        PcDotaskUserExample taskUserExp = new PcDotaskUserExample();
        PcDotaskUserExample.Criteria taskUserCro = taskUserExp.createCriteria();
        taskUserCro.andSiteUserIDEqualTo(curSiteUserInfo.getSiteUserID());
        taskUserCro.andDotaskIDEqualTo(doTaskID);
        var curUserTaskInfo = doTaskUserMapper.selectByExample(taskUserExp).stream().findFirst().orElse(null);
        if (curUserTaskInfo != null) {
            curUserTaskInfo.setUserTaskStatus(1);
            curUserTaskInfo.setCompleteTime(completeTime);
            result = doTaskUserMapper.updateByExample(curUserTaskInfo,taskUserExp);
        }
        return result;
    }

    @Override
    public int save(DoTaskVo data, String userId) {
        int result = 0;
        PcDotask dbData = doTaskMapper.selectByPrimaryKey(data.getDoTaskID());
        PcDotaskUserExample exp = new PcDotaskUserExample();
        PcDotaskUserExample.Criteria cro = exp.createCriteria();
        cro.andDotaskIDEqualTo(data.getDoTaskID());
        PcDotaskUser taskUser = doTaskUserMapper.selectByExample(exp).stream().findFirst().orElse(null);
        if (dbData == null) {
            dbData = new PcDotask();
            dbData.setDotaskID(data.getDoTaskID());
            dbData.setWorkTypeID(data.getWorkTypeID());
            dbData.setContent(data.getContent());
            dbData.setDotaskName(data.getDoTaskName());
            dbData.setRegionCode(data.getRegionCode());
            dbData.setStreetCode(data.getStreetCode());
            dbData.setSiteID(data.getSiteID());
            dbData.setFinishTime(data.getFinishTime());
            dbData.setCreateTime(new Date());
            dbData.setCreateUserID(userId);
            dbData.setTaskStatus(data.getTaskStatus());
            result = doTaskMapper.insert(dbData);
        } else {
            dbData.setWorkTypeID(data.workTypeID);
            dbData.setContent(data.content);
            dbData.setDotaskName(data.doTaskName);
            dbData.setRegionCode(data.regionCode);
            dbData.setStreetCode(data.streetCode);
            dbData.setSiteID(data.siteID);
            dbData.setFinishTime(data.finishTime);
            dbData.setModifyTime(new Date());
            dbData.setModifyUserID(userId);
            dbData.setTaskStatus(data.taskStatus);
            result = doTaskMapper.updateByPrimaryKeySelective(dbData);
        }
        if (result == 1) {
            String doTaskID = dbData.getDotaskID();
            if (taskUser != null) {
                PcDotaskUserExample example = new PcDotaskUserExample();
                example.or().andDotaskIDEqualTo(data.getDoTaskID());
                doTaskUserMapper.deleteByExample(example);
            }
            var doTaskUsers = data.doTaskUser.stream().toList();
            for (var curData: doTaskUsers) {
                PcDotaskUser user = new PcDotaskUser();
                user.setDotaskUserID(UUID.randomUUID().toString());
                user.setDotaskID(doTaskID);
                user.setSiteUserID(curData.siteUserID);
                user.setUserTaskStatus(0);
                doTaskUserMapper.insert(user);
            };
        }
        return result;
    }

    @Override
    public int delete(List<String> ids) {
        int result = 0;
        PcDotaskUserExample expUser = new PcDotaskUserExample();
        PcDotaskUserExample.Criteria croUser = expUser.or();
        croUser.andDotaskIDIn(ids);
        result += doTaskUserMapper.deleteByExample(expUser);
        PcDotaskExample exp = new PcDotaskExample();
        PcDotaskExample.Criteria cro = exp.or();
        cro.andDotaskIDIn(ids);
        result += doTaskMapper.deleteByExample(exp);
        return result;
    }


}