package com.thhy.mobile.modules.biz.repo.service.impl;

import com.alibaba.nacos.api.utils.StringUtils;
import com.thhy.general.common.BasicStatus;
import com.thhy.general.common.enums.ProListenType;
import com.thhy.general.config.SysUserInfo;
import com.thhy.general.exception.BasicException;
import com.thhy.general.utils.ScreenMqUtils;
import com.thhy.general.utils.UserInfoUtils;
import com.thhy.mobile.modules.biz.cultivated.entity.PipeCulSampleInfo;
import com.thhy.mobile.modules.biz.cultivated.entity.PipeIntoListVo;
import com.thhy.mobile.modules.biz.cultivated.mapper.PipeCultivatedMapper;
import com.thhy.mobile.modules.biz.pipeinfo.entity.PipeInfo;
import com.thhy.mobile.modules.biz.pipeinfo.mapper.PipeInfoMapper;
import com.thhy.mobile.modules.biz.repo.entity.*;
import com.thhy.mobile.modules.biz.repo.mapper.RepoRecordMapper;
import com.thhy.mobile.modules.biz.repo.service.RepoRecordService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.Serializable;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 *  服务实现类
 * @author zhang_xiao_bo
 * @since 2023-05-15 11:18:04
 */
@Service
public class RepoRecordServiceImpl implements RepoRecordService {



    @Autowired
    private RepoRecordMapper repoRecordMapper;

    @Autowired
    private PipeInfoMapper pipeInfoMapper;

    @Autowired
    private PipeCultivatedMapper pipeCultivatedMapper;

    @Autowired
    private ScreenMqUtils screenMqUtils;

    public RepoRecord get(Serializable id){
        return repoRecordMapper.queryById(id);
    }

    public List<RepoRecord> findList(RepoRecord repoRecord){
        return repoRecordMapper.findList(repoRecord);
    }

    /**
     * 增加和修改
     * @param repoRecord
     */
    @Transactional
    public void addRepoRecord(RepoRecord repoRecord){
        if(repoRecord.getRecordId() == null){
            //增加操作
            repoRecordMapper.insert(repoRecord);
        }else{
            //修改操作
            repoRecordMapper.update(repoRecord);
        }

    }

    /**
     * 修改
     * @param repoRecord
     */
    public void update(RepoRecord repoRecord){
        repoRecordMapper.update(repoRecord);
    }

    /**
     * 删除
     * @param recordId
     */
    public void delete(Serializable recordId){
        repoRecordMapper.deletelogic(recordId);
    }

    @Override
    public Map<String, Object> scanqr(RepoScanDto repoScanDto) {
        Map<String,Object> map = new HashMap<>();
        PipeInfo pipeInfo = pipeInfoMapper.queryByPipeNum(repoScanDto.getPipeNum());
        if(pipeInfo==null){
            throw new BasicException(BasicStatus.SCAN_QR_IS_EORROR);
        }
        int RingCount = repoRecordMapper.countByRingNum(pipeInfo.getRingNum());
        if(RingCount>0){
            throw new BasicException(BasicStatus.RING_NUM_IS_EXIST);
        }
        List<PipeIntoListVo> pipeIntoList = pipeInfoMapper.queryByRingNum(pipeInfo.getRingNum());

        PipeCulSampleInfo sampleInfo = pipeCultivatedMapper.queryCultivateByRingNum(pipeInfo.getRingNum());

        map.put("pipeIntoList",pipeIntoList);
        map.put("cultivatedInfo",sampleInfo);
        return map;
    }

    @Override
    public PipeCulSampleInfo queryCultivateByRingNum(String ringNum) {
        return pipeCultivatedMapper.queryCultivateByRingNum(ringNum);
    }

    @Override
    @Transactional
    public void intoRepo(RepoScanDto repoScanDto) {

        SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();

        //入库记录
        RepoRecord repoRecord = new RepoRecord();
        repoRecord.setRepoId(repoScanDto.getRepoId());
        repoRecord.setRepoUnitId(repoScanDto.getUnitId());
        repoRecord.setRingNum(repoScanDto.getRingNum());
        Date date = new Date();
        repoRecord.setCreateTime(date);
        repoRecord.setCreateUser(userInfo.getUserId());
        repoRecordMapper.insert(repoRecord);

        pipeCultivatedMapper.updateOutByRingNum(date,repoScanDto.getRingNum(),userInfo.getUserId());

        List<PipeIntoListVo> pipeIntoList = pipeInfoMapper.queryByRingNum(repoScanDto.getRingNum());
        pipeIntoList.forEach(pi ->{
            repoRecordMapper.insertRecordPipe(new RepoRecordPipe(pi.getPipeNum(),repoRecord.getRecordId(),repoScanDto.getRingNum(),repoScanDto.getRepoId(),date));
            pipeInfoMapper.updatePipeInRepo(pi.getPipeNum());
        });

        //出水养窑


        screenMqUtils.send(ProListenType.REPOINFO);
    }

    @Override
    public List<IntoListVo> recordList(RepoScanDto repoScanDto) {
        SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
        if(repoScanDto==null)repoScanDto=new RepoScanDto();
        repoScanDto.setCompanyId(userInfo.getCompanyId());
        return repoRecordMapper.recordList(repoScanDto);
    }

    @Override
    public List<RepoRecordListVo> repoDetail(RepoRecordDto repoRecordDto) {
        if(StringUtils.isEmpty(repoRecordDto.getRepoId())){
            throw new BasicException(BasicStatus.PARAM_IS_EMPTY);
        }
        return repoRecordMapper.repoDetail(repoRecordDto);
    }
}