platform / task-web

/**
 * @(#)SubtaskManagerImpl.java
 *
 * Copyright (c) 2014-2014  苏州犀牛网络科技有限公司 版权所有
 * xiniunet. All rights reserved.
 *
 * This software is the confidential and proprietary
 * information of  xiniunet.
 * ("Confidential Information"). You shall not disclose
 * such Confidential Information and shall use it only
 * in accordance with the terms of the contract agreement
 * you entered into with xiniunet.
 */
package com.xiniunet.task.biz;

import com.xiniunet.foundation.request.IdsGetRequest;
import com.xiniunet.foundation.service.FoundationService;
import com.xiniunet.framework.base.BaseManagerImpl;
import com.xiniunet.framework.base.BaseResponse;
import com.xiniunet.framework.exception.ErrorType;
import com.xiniunet.framework.security.Passport;
import com.xiniunet.framework.util.excel.datatable.DataTable;
import com.xiniunet.task.constant.Message;
import com.xiniunet.task.dal.SubtaskMapper;
import com.xiniunet.task.dal.TaskMapper;
import com.xiniunet.task.domain.Subtask;
import com.xiniunet.task.domain.SubtaskImport;
import com.xiniunet.task.po.SubtaskPO;
import com.xiniunet.task.po.TaskPO;
import com.xiniunet.task.request.*;
import com.xiniunet.task.response.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;

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

/**
 * Created by 沈振家 on 2016-11-28 16:23:01.
 *
 * @author 沈振家
 */
@Transactional
@Service
public class SubtaskManagerImpl extends BaseManagerImpl implements SubtaskManager {

    @Autowired
    private FoundationService foundationService;

    @Autowired
    private SubtaskMapper subtaskMapper;

    @Autowired
    private TaskMapper taskMapper;


    /**
     * 根据Id获取子任务
     *
     * @param request  获取子任务请求
     * @param passport 用户护照
     * @return 获取子任务应答
     */
    @Override
    @Transactional(readOnly = true)
    public SubtaskGetResponse get(SubtaskGetRequest request, Passport passport) {
        SubtaskPO entity = subtaskMapper.getById(request.getId(), passport);
        SubtaskGetResponse response = new SubtaskGetResponse();
        if (entity != null) {
            Subtask subtask = this.getMapper().map(entity, Subtask.class);
            response.setSubtask(subtask);
        } else {
            response.addError(ErrorType.EXPECTATION_NULL, Message.COMMON_GET_FAILURE);
        }
        return response;
    }


    /**
     * 模糊查询子任务
     *
     * @param request  模糊查询子任务请求
     * @param passport 用户护照
     * @return 模糊查询子任务应答
     */
    @Override
    @Transactional(readOnly = true)
    public SubtaskSearchResponse search(SubtaskSearchRequest request, Passport passport) {
        SubtaskSearchResponse response = new SubtaskSearchResponse();
        List<Subtask> modelList = new ArrayList<>();
        Long count = subtaskMapper.searchCount(request, passport);

        if (count > 0) {
            // 处理分页参数
            if (request.getPageSize() > 0) {
                //如果输入的页码大于实际的分页数，将页码设置为最后一页的页码
                int lastPageNumber = (int) ((count - 1) / request.getPageSize() + 1);
                if (request.getPageNumber() > lastPageNumber) {
                    request.setPageNumber(lastPageNumber);
                }
            }

            //通过关键字查询出用户集合
            List<SubtaskPO> entityList = subtaskMapper.search(request, passport);

            for (SubtaskPO entity : entityList) {
                Subtask subtask = this.getMapper().map(entity, Subtask.class);
                modelList.add(subtask);
            }
        }

        response.setTotalCount(count);
        response.setResult(modelList);
        return response;
    }

    /**
     * 高级查询子任务
     *
     * @param request  高级查询子任务请求
     * @param passport 用户护照
     * @return 高级查询应答
     */
    @Override
    @Transactional(readOnly = true)
    public SubtaskFindResponse find(SubtaskFindRequest request, Passport passport) {
        SubtaskFindResponse response = new SubtaskFindResponse();
        List<Subtask> modelList = new ArrayList<>();
        Long count = subtaskMapper.findCount(request, passport);
        if (count > 0) {
            // 处理分页参数
            if (request.getPageSize() > 0) {
                //如果输入的页码大于实际的分页数，将页码设置为最后一页的页码
                int lastPageNumber = (int) ((count - 1) / request.getPageSize() + 1);
                if (request.getPageNumber() > lastPageNumber) {
                    request.setPageNumber(lastPageNumber);
                }
            }


            List<SubtaskPO> entityList = subtaskMapper.find(request, passport);
            for (SubtaskPO entity : entityList) {
                Subtask subtask = this.getMapper().map(entity, Subtask.class);
                modelList.add(subtask);
            }

        }

        response.setTotalCount(count);
        response.setResult(modelList);
        return response;
    }

    /**
     * 获取所有子任务列表
     *
     * @param request  获取所有子任务列表请求
     * @param passport 用户护照
     * @return 获取所有子任务列表应答
     */
    @Override
    @Transactional(readOnly = true)
    public SubtaskGetAllListResponse getAllList(SubtaskGetAllListRequest request, Passport passport) {
        SubtaskGetAllListResponse response = new SubtaskGetAllListResponse();


        List<SubtaskPO> entityList = subtaskMapper.getAllList(request, passport);


        List<Subtask> modelList = new ArrayList<>();
        for (SubtaskPO entity : entityList) {
            Subtask subtask = this.getMapper().map(entity, Subtask.class);
            modelList.add(subtask);
        }

        response.setResult(modelList);

        response.setTotalCount(modelList.size());
        return response;
    }


    /**
     * 创建子任务
     *
     * @param request  创建子任务请求
     * @param passport 用户护照
     * @return 创建子任务应答
     */
    @Override
    public SubtaskCreateResponse create(SubtaskCreateRequest request, Passport passport) {
        SubtaskCreateResponse response = new SubtaskCreateResponse();

        // 获取任务信息
        TaskPO taskPO = taskMapper.getById(request.getTaskId(), passport);
        if (taskPO == null) {
            response.addError(ErrorType.BUSINESS_ERROR, Message.GET_TASK_FAILURE);
            return response;
        }

        SubtaskPO entity = this.getMapper().map(request, SubtaskPO.class);
        long id = foundationService.getNewId();
        entity.setId(id);

    /* 先检查关键数据是否有重复，在检查通过后才能做插入操作 */
        checkValidate(entity, passport, response);

        if (1 != subtaskMapper.insert(entity, passport)) {
            response.addError(ErrorType.EXPECTATION_NULL, Message.COMMON_CREATE_FAILURE);
            return response;
        }

        // 同步任务信息
        taskPO.setHasSubtask(true);
        taskPO.setSubtaskCount((taskPO.getSubtaskCount() == null ? 0 : taskPO.getSubtaskCount()) + 1);
        if (1 != taskMapper.update(taskPO, passport)) {
            response.addError(ErrorType.EXPECTATION_NULL, Message.UPDATE_TASK_FAILURE);
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            return response;
        }

        response.setId(id);
        return response;
    }


    /**
     * 更新子任务
     *
     * @param request  更新子任务请求
     * @param passport 用户护照
     * @return 更新子任务应答
     */
    @Override
    public SubtaskUpdateResponse update(SubtaskUpdateRequest request, Passport passport) {
        SubtaskPO entity = this.getMapper().map(request, SubtaskPO.class);

        SubtaskUpdateResponse response = new SubtaskUpdateResponse();
        Long result = subtaskMapper.update(entity, passport);
        if (result != 1) {
            response.addError(ErrorType.BUSINESS_ERROR, Message.COMMON_UPDATE_FAILURE);
            return response;
        }
        response.setResult(result);
        return response;
    }


    /**
     * 设置子任务完成
     *
     * @param request  设置子任务完成请求
     * @param passport 用户护照
     * @return 设置子任务完成应答
     */
    @Override
    public SubtaskDoneResponse done(SubtaskDoneRequest request, Passport passport) {
        SubtaskDoneResponse response = new SubtaskDoneResponse();

        // 获取子任务信息
        SubtaskPO subtaskPO = subtaskMapper.getById(request.getId(), passport);
        if (subtaskPO == null) {
            response.addError(ErrorType.BUSINESS_ERROR, Message.GET_SUBTASK_FAILURE);
            return response;
        }

        // 获取任务信息
        TaskPO taskPO = taskMapper.getById(subtaskPO.getTaskId(), passport);
        if (taskPO == null) {
            response.addError(ErrorType.BUSINESS_ERROR, Message.GET_TASK_FAILURE);
            return response;
        }

        subtaskPO.setIsDone(true);
        subtaskPO.setDoUserId(passport.getUserId());
        subtaskPO.setDoUserName(passport.getUserName());
        subtaskPO.setDoTime(new Date());
        if (1 != subtaskMapper.done(subtaskPO, passport)) {
            response.addError(ErrorType.EXPECTATION_NULL, Message.COMMON_UPDATE_FAILURE);
            return response;
        }

        // 同步任务信息
        taskPO.setSubtaskDoneCount((taskPO.getSubtaskDoneCount() == null ? 0 : taskPO.getSubtaskDoneCount()) + 1);
        if (1 != taskMapper.update(taskPO, passport)) {
            response.addError(ErrorType.EXPECTATION_NULL, Message.UPDATE_TASK_FAILURE);
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            return response;
        }
        response.setResult(1L);
        return response;
    }


    /**
     * 设置子任务未完成
     *
     * @param request  设置子任务未完成请求
     * @param passport 用户护照
     * @return 设置子任务未完成应答
     */
    @Override
    public SubtaskTodoResponse todo(SubtaskTodoRequest request, Passport passport) {
        SubtaskTodoResponse response = new SubtaskTodoResponse();

        // 获取子任务信息
        SubtaskPO subtaskPO = subtaskMapper.getById(request.getId(), passport);
        if (subtaskPO == null) {
            response.addError(ErrorType.BUSINESS_ERROR, Message.GET_SUBTASK_FAILURE);
            return response;
        }

        // 获取任务信息
        TaskPO taskPO = taskMapper.getById(subtaskPO.getTaskId(), passport);
        if (taskPO == null) {
            response.addError(ErrorType.BUSINESS_ERROR, Message.GET_TASK_FAILURE);
            return response;
        }

        subtaskPO.setIsDone(false);
        subtaskPO.setDoUserId(null);
        subtaskPO.setDoUserName(null);
        subtaskPO.setDoTime(null);
        if (1 != subtaskMapper.done(subtaskPO, passport)) {
            response.addError(ErrorType.EXPECTATION_NULL, Message.COMMON_UPDATE_FAILURE);
            return response;
        }

        // 同步任务信息
        taskPO.setSubtaskDoneCount((taskPO.getSubtaskDoneCount() == null ? 0 : taskPO.getSubtaskDoneCount()) - 1);
        if (1 != taskMapper.update(taskPO, passport)) {
            response.addError(ErrorType.EXPECTATION_NULL, Message.UPDATE_TASK_FAILURE);
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            return response;
        }
        response.setResult(1L);
        return response;
    }


    /**
     * 删除子任务
     *
     * @param request  删除子任务请求
     * @param passport 用户护照
     * @return 删除子任务应答
     */
    @Override
    public SubtaskDeleteResponse delete(SubtaskDeleteRequest request, Passport passport) {
        SubtaskDeleteResponse response = new SubtaskDeleteResponse();

        // 获取子任务信息
        SubtaskPO subtaskPO = subtaskMapper.getById(request.getId(), passport);
        if (subtaskPO == null) {
            response.addError(ErrorType.BUSINESS_ERROR, Message.GET_SUBTASK_FAILURE);
            return response;
        }

        // 获取任务信息
        TaskPO taskPO = taskMapper.getById(subtaskPO.getTaskId(), passport);
        if (taskPO == null) {
            response.addError(ErrorType.BUSINESS_ERROR, Message.GET_TASK_FAILURE);
            return response;
        }

        if (1 != subtaskMapper.delete(request.getId(), passport)) {
            response.addError(ErrorType.EXPECTATION_NULL, Message.COMMON_UPDATE_FAILURE);
            return response;
        }

        // 同步任务信息
        int subtaskCount = (taskPO.getSubtaskCount() == null ? 0 : taskPO.getSubtaskCount()) - 1;
        if (subtaskCount > 0) {
            taskPO.setHasSubtask(true);
            taskPO.setSubtaskCount(subtaskCount);
        } else {
            taskPO.setHasSubtask(false);
            taskPO.setSubtaskCount(0);
        }
        if (1 != taskMapper.update(taskPO, passport)) {
            response.addError(ErrorType.EXPECTATION_NULL, Message.UPDATE_TASK_FAILURE);
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            return response;
        }
        response.setResult(1L);
        return response;
    }


    /**
     * 导入子任务
     *
     * @param request  导入子任务请求
     * @param passport 用户护照
     * @return 导入子任务应答
     */
    @Override
    public SubtaskListImportResponse importList(SubtaskListImportRequest request, Passport passport) {
        DataTable<SubtaskImport> dataTable = request.getDataTable();

        List<SubtaskPO> importList = new ArrayList<>();            //需要创建的对象的集合

        List<Long> result = new LinkedList<>();                    //存储ID的集合
        List<SubtaskImport> beanList = request.getList();            //取出导入对象的集合
        SubtaskListImportResponse response = new SubtaskListImportResponse();//最终的返回结果

    /* 批量获取ID */
        IdsGetRequest idsGetRequest = new IdsGetRequest();
        idsGetRequest.setCount(beanList.size());
        List<Long> ids = foundationService.getNewIds(idsGetRequest).getIds();

        int index = 0;
        for (SubtaskImport importBean : beanList) {
            // 设置
            SubtaskPO entity = this.getMapper().map(importBean, SubtaskPO.class);


            importList.add(entity);
            result.add(ids.get(index));         //将取到的ID放入返回结果中
            entity.setId(ids.get(index));       //设置ID

            index++;
        }

        if (!dataTable.hasError()) {
            if (importList.size() > 0) {
                subtaskMapper.insertBatch(importList, passport);
            }
        } else {
            response.setDataTable(dataTable);
            response.addErrors(dataTable.getErrorList());
        }

        response.setList(result);
        return response;

    }

    /**
     * 验证对象
     *
     * @param subtask  子任务
     * @param passport 用户护照
     */
    private void checkValidate(SubtaskPO subtask, Passport passport, BaseResponse response) {
        // TODO

    }


}