package com.java110.oa.cmd.work;

import com.alibaba.fastjson.JSONObject;
import com.java110.core.annotation.Java110Cmd;
import com.java110.core.context.CmdContextUtils;
import com.java110.core.context.ICmdDataFlowContext;
import com.java110.core.event.cmd.Cmd;
import com.java110.core.event.cmd.CmdEvent;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.dto.user.UserDto;
import com.java110.dto.work.WorkCopyDto;
import com.java110.dto.work.WorkEventDto;
import com.java110.dto.work.WorkPoolDto;
import com.java110.dto.work.WorkTaskItemDto;
import com.java110.intf.oa.IWorkCopyV1InnerServiceSMO;
import com.java110.intf.oa.IWorkEventV1InnerServiceSMO;
import com.java110.intf.oa.IWorkTaskItemV1InnerServiceSMO;
import com.java110.intf.user.IUserV1InnerServiceSMO;
import com.java110.po.workPool.WorkCopyPo;
import com.java110.po.workPool.WorkEventPo;
import com.java110.po.workPool.WorkTaskItemPo;
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.ListUtil;
import com.java110.utils.util.StringUtil;
import org.springframework.beans.factory.annotation.Autowired;

import java.text.ParseException;
import java.util.List;

@Java110Cmd(serviceCode = "work.finishWorkCopy")
public class FinishWorkCopyCmd extends Cmd {

    @Autowired
    private IWorkCopyV1InnerServiceSMO workCopyV1InnerServiceSMOImpl;

    @Autowired
    private IWorkTaskItemV1InnerServiceSMO workTaskItemV1InnerServiceSMOImpl;

    @Autowired
    private IUserV1InnerServiceSMO userV1InnerServiceSMOImpl;

    @Autowired
    private IWorkEventV1InnerServiceSMO workEventV1InnerServiceSMOImpl;

    @Override
    public void validate(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {
        Assert.hasKeyAndValue(reqJson, "copyId", "未包含抄送人");
        Assert.hasKeyAndValue(reqJson, "itemId", "未包含内容ID");
        Assert.hasKeyAndValue(reqJson, "deductionReason", "未包含说明");
        String userId = CmdContextUtils.getUserId(context);
        WorkCopyDto workCopyDto = new WorkCopyDto();
        workCopyDto.setCopyId(reqJson.getString("copyId"));
        workCopyDto.setState(WorkPoolDto.STATE_DOING);
        workCopyDto.setStaffId(userId);
        List<WorkCopyDto> workCopyDtos = workCopyV1InnerServiceSMOImpl.queryWorkCopys(workCopyDto);

        if (ListUtil.isNull(workCopyDtos)) {
            throw new CmdException("抄送单不存在");
        }

    }

    @Override
    public void doCmd(CmdEvent event, ICmdDataFlowContext context, JSONObject reqJson) throws CmdException, ParseException {

        WorkTaskItemDto workTaskItemDto = new WorkTaskItemDto();
        workTaskItemDto.setItemId(reqJson.getString("itemId"));
        List<WorkTaskItemDto> workTaskItemDtos = workTaskItemV1InnerServiceSMOImpl.queryWorkTaskItems(workTaskItemDto);

        if (ListUtil.isNull(workTaskItemDtos)) {
            throw new CmdException("工作单内容不存在");
        }

        if (!WorkTaskItemDto.STATE_COMPLETE.equals(workTaskItemDtos.get(0).getState())) {
            throw new CmdException("工作单内容未办理完成，抄送不能办理");
        }

        reqJson.put("taskId", workTaskItemDtos.get(0).getTaskId());
        String userId = CmdContextUtils.getUserId(context);

        UserDto userDto = new UserDto();
        userDto.setUserId(userId);
        List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);

        Assert.listOnlyOne(userDtos, "用户不存在");
        String deductionMoney = "0.00";
        String score= "10";
        String deductionReason = reqJson.getString("deductionReason");
        if (reqJson.containsKey("deductionMoney") && !StringUtil.isEmpty(reqJson.getString("deductionMoney"))) {
            deductionMoney = reqJson.getString("deductionMoney");
            deductionReason += (" 扣款 " + deductionMoney + "元");
        }
        if (reqJson.containsKey("score") && !StringUtil.isEmpty(reqJson.getString("score"))) {
            score = reqJson.getString("score");
        }

        WorkTaskItemPo workTaskItemPo = new WorkTaskItemPo();
        workTaskItemPo.setItemId(reqJson.getString("itemId"));
        workTaskItemPo.setDeductionMoney(deductionMoney);
        workTaskItemPo.setDeductionReason(deductionReason);
        workTaskItemPo.setScore(score);
        workTaskItemPo.setDeductionPersonId(userDtos.get(0).getUserId());
        workTaskItemPo.setDeductionPersonName(userDtos.get(0).getName());
        workTaskItemPo.setState(WorkTaskItemDto.STATE_COPY_COMPLETE);
        workTaskItemV1InnerServiceSMOImpl.updateWorkTaskItem(workTaskItemPo);

        WorkEventPo workEventPo = new WorkEventPo();
        workEventPo.setWorkId(workTaskItemDtos.get(0).getWorkId());
        workEventPo.setEventId(GenerateCodeFactory.getGeneratorId("11"));
        workEventPo.setCommunityId(workTaskItemDtos.get(0).getCommunityId());
        workEventPo.setRemark(reqJson.getString("deductionReason"));
        workEventPo.setStaffId(userId);
        workEventPo.setPreStaffId(userId);
        workEventPo.setPreStaffName(userDtos.get(0).getName());
        workEventPo.setStaffName(userDtos.get(0).getName());
        workEventPo.setStoreId(workTaskItemDtos.get(0).getStoreId());
        workEventPo.setTaskId(workTaskItemDtos.get(0).getTaskId());
        workEventPo.setItemId(reqJson.getString("itemId"));
        workEventPo.setContentId(workTaskItemDtos.get(0).getContentId());
        workEventPo.setEventType(WorkEventDto.EVENT_TYPE_COPY_COMPLETE);

        workEventV1InnerServiceSMOImpl.saveWorkEvent(workEventPo);

        workTaskItemDto = new WorkTaskItemDto();
        workTaskItemDto.setTaskId(reqJson.getString("taskId"));
        workTaskItemDto.setStates(new String[]{WorkTaskItemDto.STATE_COMPLETE,WorkTaskItemDto.STATE_WAIT});
        int count = workTaskItemV1InnerServiceSMOImpl.queryWorkTaskItemsCount(workTaskItemDto);

        if (count > 0) {
            return;
        }

        WorkCopyPo workCopyPo = new WorkCopyPo();
        workCopyPo.setCopyId(reqJson.getString("copyId"));
        workCopyPo.setState(WorkPoolDto.STATE_COMPLETE);
        workCopyPo.setRemark(reqJson.getString("deductionReason"));
        workCopyV1InnerServiceSMOImpl.updateWorkCopy(workCopyPo);
    }
}