package cn.besteam.modules.medical.service.impl;

import cn.besteam.common.constant.CommonConstant;
import cn.besteam.common.constant.ErrorCode;
import cn.besteam.common.constant.MedicalWasteEnum;
import cn.besteam.common.exception.BusinessException;
import cn.besteam.common.util.DateUtil;
import cn.besteam.modules.medical.dto.ApiMedicalBoxingDTO;
import cn.besteam.modules.medical.entity.MwBox;
import cn.besteam.modules.medical.entity.MwBoxItem;
import cn.besteam.modules.medical.entity.MwCollectRecord;
import cn.besteam.modules.medical.mapper.MwBoxMapper;
import cn.besteam.modules.medical.service.IMwBoxItemService;
import cn.besteam.modules.medical.service.IMwBoxService;
import cn.besteam.modules.medical.service.IMwCollectRecordService;
import cn.besteam.modules.medical.vo.ApiMedicalBoxingDetailsVO;
import cn.besteam.modules.shiro.authc.util.EnvUtils;
import cn.besteam.modules.system.entity.SysDepartment;
import cn.besteam.modules.system.entity.SysDictItem;
import cn.besteam.modules.system.service.ISysDepartmentService;
import cn.besteam.modules.system.service.ISysDictItemService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.apache.commons.lang3.time.DateUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

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

import static java.util.stream.Collectors.groupingBy;

/**
 * @Description: 转运箱
 * @author： besteam
 * @date： 2020-04-25
 * @version： V1.0
 */
@Service
@Slf4j
public class MwBoxServiceImpl extends ServiceImpl<MwBoxMapper, MwBox> implements IMwBoxService {

    @Autowired
    private IMwCollectRecordService mwCollectRecordService;

    @Autowired
    private ISysDepartmentService sysDepartmentService;

    @Autowired
    private IMwBoxItemService mwBoxItemService;

    @Autowired
    private IMwCollectRecordService iMwCollectRecordService;

    @Autowired
    private ISysDictItemService sysDictItemService;

    /**
     * 自动装箱
     *
     * @param dto
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public boolean autoBoxing(ApiMedicalBoxingDTO dto) {

        if (dto.getWarehouseId() == null || dto.getWarehouseId() <= 0) {
            throw new BusinessException(ErrorCode.ERR_500, "暂存间ID不能为空");
        }
        SysDepartment warehouse = sysDepartmentService.getById(dto.getWarehouseId());
        if (warehouse == null) {
            throw new BusinessException(ErrorCode.ERR_500, "暂存间不存在");
        }
        if (warehouse.getIsWarehouse().equals(0)) {
            throw new BusinessException(ErrorCode.ERR_500, "暂存间不存在");
        }
        //根据暂存间ID获取未装箱清单列表
        List<MwCollectRecord> mwCollectRecordList = mwCollectRecordService.getUnBoxingList(dto.getWarehouseId(), EnvUtils.getUser().getId());
        if (CollectionUtils.isNotEmpty(mwCollectRecordList)) {
            //获取收集表ID列表
            Set<Integer> mwCollectRecordIdSet = mwCollectRecordList.stream().map(MwCollectRecord::getId).collect(Collectors.toSet());
            //获取转运箱存在收集ID
            int count = mwBoxItemService.count(new QueryWrapper<MwBoxItem>().lambda().in(MwBoxItem::getCollectRecordId, mwCollectRecordIdSet));
            if (count > 0) {
                throw new BusinessException(ErrorCode.ERR_500, "医废已放入转运箱,请重新选择");
            }
            //集合分组
            Map<Integer, List<MwCollectRecord>> collect = mwCollectRecordList.stream().collect(groupingBy(MwCollectRecord::getWasteType));
            log.info("集合分组：" + collect);
            for (Map.Entry<Integer, List<MwCollectRecord>> entry : collect.entrySet()) {
                List<MwCollectRecord> collectRecordList = entry.getValue();
                List<MwCollectRecord> toBoxingCollectRecordList = new ArrayList<>();
                for (MwCollectRecord mwCollectRecord : collectRecordList) {
                    toBoxingCollectRecordList.add(mwCollectRecord);
                    if (toBoxingCollectRecordList.size() == 10) {
                        dealAutoBoxing(toBoxingCollectRecordList);
                        toBoxingCollectRecordList.clear();
                    }
                }
                if (CollectionUtils.isNotEmpty(toBoxingCollectRecordList)) {
                    dealAutoBoxing(toBoxingCollectRecordList);
                    toBoxingCollectRecordList.clear();
                }
            }
        }
        return true;
    }

    @Transactional(rollbackFor = Exception.class)
    public boolean dealAutoBoxing(List<MwCollectRecord> toBoxingCollectRecordList) {

        SysDepartment hospital = sysDepartmentService.getById(toBoxingCollectRecordList.get(0).getHospitalId());
        MwBox mwBox = new MwBox();
        mwBox.setHospitalId(toBoxingCollectRecordList.get(0).getHospitalId());
        //获取装运箱编码
        mwBox.setCode(generateCode(mwBox, hospital.getOrgCode(), toBoxingCollectRecordList.get(0).getWasteType()));
        save(mwBox);
        List<MwBoxItem> mwBoxItemList = new ArrayList<>();
        toBoxingCollectRecordList.forEach(collectRecordId -> {
            MwBoxItem mwBoxItem = new MwBoxItem();
            mwBoxItem.setBoxId(mwBox.getId());
            mwBoxItem.setCollectRecordId(collectRecordId.getId());
            mwBoxItemList.add(mwBoxItem);
        });
        //批量新增
        mwBoxItemService.saveBatch(mwBoxItemList);
        toBoxingCollectRecordList.forEach(mwCollectRecord -> {
            mwCollectRecord.setBoxTime(mwBox.getCreateTime());
        });
        //批量更新收集装箱时间
        mwCollectRecordService.updateBatchById(toBoxingCollectRecordList);
        return true;
    }


    @Override
    public ApiMedicalBoxingDetailsVO boxingAndPrintingNew(ApiMedicalBoxingDTO dto) {
        ApiMedicalBoxingDetailsVO vo = boxingAndPrintingNewDetail(dto);
        //先入库操作
        iMwCollectRecordService.storeCollectBatch(dto.getRecordList());
        return  vo;
    }

    /**
     * 手动装箱并打印
     *
     * @param dto
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public ApiMedicalBoxingDetailsVO boxingAndPrintingNewDetail(ApiMedicalBoxingDTO dto) {

        if (CollectionUtils.isEmpty(dto.getIdList())) {
            throw new BusinessException(ErrorCode.ERR_500, "医废列表不能为空");
        }
        if (dto.getWarehouseId() == null || dto.getWarehouseId() <= 0) {
            throw new BusinessException(ErrorCode.ERR_500, "暂存间ID不能为空");
        }
        //暂存间
        SysDepartment warehouse = sysDepartmentService.getById(dto.getWarehouseId());
        if (warehouse == null) {
            throw new BusinessException(ErrorCode.ERR_500, "暂存间不存在");
        }
        if (warehouse.getIsWarehouse().equals(0)) {
            throw new BusinessException(ErrorCode.ERR_500, "暂存间不存在");
        }
        //医院
        SysDepartment hospital = sysDepartmentService.getHospital(warehouse.getParentId());
        if (hospital == null) {
            throw new BusinessException(ErrorCode.DEPARTMENT_NOT_FOUND);
        }
        ApiMedicalBoxingDetailsVO boxingAndPrintingDetails = new ApiMedicalBoxingDetailsVO();
        List<MwCollectRecord> mwCollectRecordList = mwCollectRecordService.list(new QueryWrapper<MwCollectRecord>()//
                .lambda()//
                .in(MwCollectRecord::getId, dto.getIdList()));
        if (CollectionUtils.isEmpty(mwCollectRecordList)) {
            throw new BusinessException(ErrorCode.ERR_500, "医废列表不能为空");
        }
        //获取收集表医废类型
        Set<Integer> wasteTypeSet = mwCollectRecordList.stream().map(MwCollectRecord::getWasteType).collect(Collectors.toSet());
        if (wasteTypeSet.size() > 1) {
            throw new BusinessException(ErrorCode.ERR_500, "废物类型不同,请重新选择");
        }
        //获取转运箱存在收集ID
        int count = mwBoxItemService.count(new QueryWrapper<MwBoxItem>().lambda().in(MwBoxItem::getCollectRecordId, dto.getIdList()));
        if (count > 0) {
            throw new BusinessException(ErrorCode.ERR_500, "医废已放入转运箱,请重新选择");
        }
        Integer wasteType=0;
        //
        for (MwCollectRecord mwCollectRecord : mwCollectRecordList) {
            wasteType = mwCollectRecord.getWasteType();
            /*if (!mwCollectRecord.getWarehouseId().equals(warehouse.getId())) {
                throw new BusinessException(ErrorCode.ERR_500, "医废" + mwCollectRecord.getCode() + "不在此暂存间,请重新选择");
            }*/
            if (!mwCollectRecord.getStatus().equals(MedicalWasteEnum.MedicalWasteStatusEnum.COLLECT.getStatus())) {
                throw new BusinessException(ErrorCode.ERR_500, "医废" + mwCollectRecord.getCode() + "状态错误,请重新选择");
            }
            if (mwCollectRecord.getDelFlag().equals(CommonConstant.DEL_FLAG_1)) {
                throw new BusinessException(ErrorCode.ERR_500, "医废" + mwCollectRecord.getCode() + "已删除,请重新选择");
            }
        }
        MwBox mwBox = new MwBox();
        mwBox.setHospitalId(hospital.getId());
        //新增芯片ID，由APP端直接上传
        mwBox.setChipId(dto.getChipId());
        if(StringUtils.isEmpty(hospital.getCustomNumber())){
            //获取装运箱编码
            mwBox.setCode(generateCode(mwBox, hospital.getOrgCode(), wasteTypeSet.iterator().next()));
        }else {
            Random random = new Random();
            int ran = random.nextInt(10);
            SysDictItem sysDictItem = sysDictItemService.getById(wasteType);
            mwBox.setCode(generateCodeNew(hospital.getCustomNumber(), new Date(), ran, sysDictItem.getItemValue()));
        }
        save(mwBox);
        List<MwBoxItem> mwBoxItemList = new ArrayList<>();
        dto.getIdList().forEach(collectRecordId -> {
            MwBoxItem mwBoxItem = new MwBoxItem();
            mwBoxItem.setBoxId(mwBox.getId());
            mwBoxItem.setCollectRecordId(collectRecordId);
            mwBoxItemList.add(mwBoxItem);
        });
        //批量新增
        mwBoxItemService.saveBatch(mwBoxItemList);
        //批量更新医废的装箱时间
        for (MwCollectRecord mwCollectRecord : mwCollectRecordList) {
            mwCollectRecord.setBoxTime(mwBox.getCreateTime());
        }
        mwCollectRecordService.updateBatchById(mwCollectRecordList);
        //自动装箱打印时间
        BeanUtils.copyProperties(mwBox, boxingAndPrintingDetails);
        boxingAndPrintingDetails.setBoxTime(mwBox.getCreateTime());
        return boxingAndPrintingDetails;
    }

    /**
     * 手动装箱并打印
     *
     * @param dto
     * @return
     */
    @Override
    @Transactional(rollbackFor = Exception.class)
    public ApiMedicalBoxingDetailsVO boxingAndPrinting(ApiMedicalBoxingDTO dto) {

        if (CollectionUtils.isEmpty(dto.getIdList())) {
            throw new BusinessException(ErrorCode.ERR_500, "医废列表不能为空");
        }
        if (dto.getWarehouseId() == null || dto.getWarehouseId() <= 0) {
            throw new BusinessException(ErrorCode.ERR_500, "暂存间ID不能为空");
        }
        //暂存间
        SysDepartment warehouse = sysDepartmentService.getById(dto.getWarehouseId());
        if (warehouse == null) {
            throw new BusinessException(ErrorCode.ERR_500, "暂存间不存在");
        }
        if (warehouse.getIsWarehouse().equals(0)) {
            throw new BusinessException(ErrorCode.ERR_500, "暂存间不存在");
        }
        //医院
        SysDepartment hospital = sysDepartmentService.getHospital(warehouse.getParentId());
        if (hospital == null) {
            throw new BusinessException(ErrorCode.DEPARTMENT_NOT_FOUND);
        }
        ApiMedicalBoxingDetailsVO boxingAndPrintingDetails = new ApiMedicalBoxingDetailsVO();
        List<MwCollectRecord> mwCollectRecordList = mwCollectRecordService.list(new QueryWrapper<MwCollectRecord>()//
                .lambda()//
                .in(MwCollectRecord::getId, dto.getIdList()));
        if (CollectionUtils.isEmpty(mwCollectRecordList)) {
            throw new BusinessException(ErrorCode.ERR_500, "医废列表不能为空");
        }
        //获取收集表废物类型
        Set<Integer> wasteTypeSet = mwCollectRecordList.stream().map(MwCollectRecord::getWasteType).collect(Collectors.toSet());
        if (wasteTypeSet.size() > 1) {
            throw new BusinessException(ErrorCode.ERR_500, "废物类型不同,请重新选择");
        }
        //获取转运箱存在收集ID
        int count = mwBoxItemService.count(new QueryWrapper<MwBoxItem>().lambda().in(MwBoxItem::getCollectRecordId, dto.getIdList()));
        if (count > 0) {
            throw new BusinessException(ErrorCode.ERR_500, "医废已放入转运箱,请重新选择");
        }
        //
        for (MwCollectRecord mwCollectRecord : mwCollectRecordList) {
            if (!mwCollectRecord.getWarehouseId().equals(warehouse.getId())) {
                throw new BusinessException(ErrorCode.ERR_500, "医废" + mwCollectRecord.getCode() + "不在此暂存间,请重新选择");
            }
            if (!mwCollectRecord.getStatus().equals(MedicalWasteEnum.MedicalWasteStatusEnum.STORE.getStatus())) {
                throw new BusinessException(ErrorCode.ERR_500, "医废" + mwCollectRecord.getCode() + "状态错误,请重新选择");
            }
            if (mwCollectRecord.getDelFlag().equals(CommonConstant.DEL_FLAG_1)) {
                throw new BusinessException(ErrorCode.ERR_500, "医废" + mwCollectRecord.getCode() + "已删除,请重新选择");
            }
        }
        MwBox mwBox = new MwBox();
        mwBox.setHospitalId(hospital.getId());
        //获取装运箱编码
        mwBox.setCode(generateCode(mwBox, hospital.getOrgCode(), wasteTypeSet.iterator().next()));
        //新增芯片ID，由APP端直接上传
        mwBox.setChipId(dto.getChipId());
        save(mwBox);
        List<MwBoxItem> mwBoxItemList = new ArrayList<>();
        dto.getIdList().forEach(collectRecordId -> {
            MwBoxItem mwBoxItem = new MwBoxItem();
            mwBoxItem.setBoxId(mwBox.getId());
            mwBoxItem.setCollectRecordId(collectRecordId);
            mwBoxItemList.add(mwBoxItem);
        });
        //批量新增
        mwBoxItemService.saveBatch(mwBoxItemList);
        //批量更新医废的装箱时间
        for (MwCollectRecord mwCollectRecord : mwCollectRecordList) {
            mwCollectRecord.setBoxTime(mwBox.getCreateTime());
        }
        mwCollectRecordService.updateBatchById(mwCollectRecordList);
        //自动装箱打印时间
        BeanUtils.copyProperties(mwBox, boxingAndPrintingDetails);
        boxingAndPrintingDetails.setBoxTime(mwBox.getCreateTime());
        return boxingAndPrintingDetails;
    }

    /**
     * 获取装运箱编码
     *
     * @param mwBox
     * @param hospitalCode
     * @param wasteType
     * @return
     */
    private String generateCode(MwBox mwBox, String hospitalCode, Integer wasteType) {

        Random random = new Random();
        int ran = random.nextInt(10);
        SysDictItem sysDictItem = sysDictItemService.getById(wasteType);
        Date createTime = new Date();
        StringBuilder sb = new StringBuilder();
        while (true) {
            String currentDate = DateUtil.format(createTime, "yyyyMMddHHmmss");
            sb.append(hospitalCode).append(currentDate).append(ran).append(sysDictItem.getItemValue());
            MwBox mwBoxEntity = getOne(new QueryWrapper<MwBox>().lambda().eq(MwBox::getCode, sb.toString()));
            if (mwBoxEntity == null) {
                break;
            }
            createTime = DateUtils.addSeconds(createTime, 1);
            sb = new StringBuilder();
        }
        mwBox.setCreateTime(createTime);
        return sb.toString();
    }

    private String generateCodeNew(String hospitalCode,  Date createTime,Integer random,String wasteType) {

        Long currentDate = createTime.getTime()/1000;
        StringBuilder sb = new StringBuilder();
        // int count = 0;
        // while (true) {
        sb.append(hospitalCode).append(currentDate).append(random).append(wasteType);
        // MwCollectRecord mwCollectRecord = getOne(new QueryWrapper<MwCollectRecord>().lambda().eq(MwCollectRecord::getCode, sb.toString()));
        //     if (mwCollectRecord == null) {
        //         break;
        //     }
        //     count++;
        //     sb = new StringBuilder();
        // }
        return sb.toString();
    }

}