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

import com.thhy.general.common.BasicStatus;
import com.thhy.general.common.enums.MouldFreeType;
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.mouldcheck.entity.MouldFree;
import com.thhy.mobile.modules.biz.pipecheckrecord.entity.*;
import com.thhy.mobile.modules.biz.pipecheckrecord.mapper.PipeCheckRecordMapper;
import com.thhy.mobile.modules.biz.pipecheckrecord.service.PipeCheckRecordService;
import com.thhy.mobile.modules.biz.pipeinfo.entity.MaterialInfo;
import com.thhy.mobile.modules.biz.pipeinfo.entity.PipeInfo;
import com.thhy.mobile.modules.biz.pipeinfo.mapper.PipeInfoMapper;
import org.redisson.SlotCallback;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
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.ArrayList;
import java.util.List;
import java.util.concurrent.TimeUnit;

/**
 *  服务实现类
 * @author zhang_xiao_bo
 * @since 2023-05-08 19:43:32
 */
@Service
public class PipeCheckRecordServiceImpl implements PipeCheckRecordService {



    @Autowired
    private PipeCheckRecordMapper pipeCheckRecordMapper;

    @Autowired
    private PipeInfoMapper pipeInfoMapper;

    @Autowired
    private ScreenMqUtils screenMqUtils;

    @Autowired
    private RedissonClient redissonClient;

    public PipeCheckRecord get(Serializable id){
        return pipeCheckRecordMapper.queryById(id);
    }

    public List<PipeCheckRecord> findList(PipeCheckRecord pipeCheckRecord){
        return pipeCheckRecordMapper.findList(pipeCheckRecord);
    }

    /**
     * 增加和修改
     * @param pipeCheckRecord
     */
    @Transactional
    public void addPipeCheckRecord(PipeCheckRecord pipeCheckRecord){
        if(pipeCheckRecord.getPipeCheckId() == null){
            //增加操作
            pipeCheckRecordMapper.insert(pipeCheckRecord);
        }else{
            //修改操作
            pipeCheckRecordMapper.update(pipeCheckRecord);
        }

    }

    /**
     * 修改
     * @param pipeCheckRecord
     */
    public void update(PipeCheckRecord pipeCheckRecord){
        pipeCheckRecordMapper.update(pipeCheckRecord);
    }

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

    @Override
    @Transactional
    public void check(PipeCheckDto pipeCheckDto) {
        SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
        PipeInfo pipeInfo = pipeInfoMapper.queryByPipeNum(pipeCheckDto.getPipeNum());
        if(pipeInfo==null){
            throw new BasicException(BasicStatus.SCAN_QR_IS_EORROR);
        }
        if(pipeInfo.getCheckResult()!=0){
            throw new BasicException(BasicStatus.PRODUCE_NUM_SCAN_AGAIN);
        }
        //记录
        PipeCheckRecord pipeCheckRecord = new PipeCheckRecord();
        pipeCheckRecord.setPipeId(pipeInfo.getPipeId());
        pipeCheckRecord.setCheckResult(1);
        pipeCheckRecord.setCheckUser(userInfo.getUserId());
        pipeCheckRecordMapper.insert(pipeCheckRecord);
        //更新
        pipeInfoMapper.updateCheckResult(pipeInfo.setCheckResult(1).setCheckUser(userInfo.getUserId()));


        //模具表 改为 空闲状态
        pipeInfoMapper.updateSysMouldFree(new MouldFree(pipeInfo.getModId(), MouldFreeType.FREE.getValue()));
        //管片表 改为 已出模
        pipeInfoMapper.updatePipeOutMod(pipeInfo.getPipeNum());
        //模具检查记录  改为 已出模
        pipeInfoMapper.updateModCheck(pipeInfo.getModId());
        //出窑
        pipeInfoMapper.pipeIdOutUpdate(pipeInfo.getPipeId());


        List<MaterialInfo> materialInfoList = pipeInfoMapper.queryPipeDeplete(pipeInfo);

        //减库存
        RLock lock = redissonClient.getLock("materlock");
        try {
            if (lock.tryLock(5, 10, TimeUnit.SECONDS)) {
                for(MaterialInfo materialInfo : materialInfoList){
                    MaterialInfo current = pipeInfoMapper.queryMaterStock(materialInfo.getMaterialName(), userInfo.getCompanyId());

                    MaterialStockRecord materialStockRecord = new MaterialStockRecord();
                    materialStockRecord.setType(2);
                    materialStockRecord.setOpType(2); //减库存
                    materialStockRecord.setMaterialName(materialInfo.getMaterialName());
                    materialStockRecord.setMaterialValue(materialInfo.getMaterialValue());
                    materialStockRecord.setBeforeStock(current.getMaterialValue());
                    materialStockRecord.setCompanyId(userInfo.getCompanyId());
                    materialStockRecord.setPipeId(pipeInfo.getPipeId());
                    materialStockRecord.setPipeNum(pipeInfo.getPipeNum());
                    double changeValue = current.getMaterialValue()-materialInfo.getMaterialValue();
                    materialStockRecord.setAfterStock(changeValue);
                    pipeInfoMapper.updateMaterStockRecord(materialStockRecord);

                    pipeInfoMapper.updateMaterStock(materialInfo.getMaterialName(), changeValue, userInfo.getCompanyId());
                }
            } else {
                throw new BasicException(BasicStatus.OP_IS_TIMEOUT);
            }
        } catch (InterruptedException e) {
            throw new BasicException(BasicStatus.OP_IS_REPEAT);
        } finally {
            if (lock.isLocked()) {
                lock.unlock();
            }
        }

        int count = pipeInfoMapper.ringCompleteByRingNum(pipeInfo.getRingNum());
        if(count>0){
            screenMqUtils.send(ProListenType.PIPEYEARMONTH);
        }
    }

    @Override
    public void updateResult(PipeCheckDto pipeCheckDto) {
        SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
        //PipeCheckRecord pcr = pipeCheckRecordMapper.queryById(pipeCheckDto.getPipeCheckId());
        PipeInfo pipeInfo = pipeInfoMapper.queryById(pipeCheckDto.getPipeId());
        //记录
        PipeCheckRecord pipeCheckRecord = new PipeCheckRecord();
        pipeCheckRecord.setPipeId(pipeInfo.getPipeId());
        pipeCheckRecord.setCheckResult(pipeCheckDto.getCheckResult());
        pipeCheckRecord.setCheckUser(userInfo.getUserId());
        pipeCheckRecord.setRemark(pipeCheckDto.getRemark());
        pipeCheckRecord.setCheckReason(pipeCheckDto.getCheckReason());
        pipeCheckRecordMapper.insert(pipeCheckRecord);
        System.out.println("#######################"+pipeCheckDto.getCheckResult());
        if(pipeCheckDto.getCheckResult()==3){ //报废
            //pipeCheckRecordMapper.insert(pipeCheckRecord);
            List<PipeCheckFile> fileList = pipeCheckDto.getFileList()==null?new ArrayList<>():pipeCheckDto.getFileList();
            System.out.println(fileList.size());
            for(PipeCheckFile cf : fileList){
                System.out.println("jiance"+cf==null);
                cf.setPipeCheckId(pipeCheckRecord.getPipeCheckId());
                pipeCheckRecordMapper.insertCheckFile(cf);
            }
        }
        //更新
        pipeInfoMapper.updateCheckResult(pipeInfo.setCheckResult(pipeCheckDto.getCheckResult()).setCheckUser(userInfo.getUserId()));
    }

    @Override
    public List<PipeCheckListVo> pipeCheckList(PipeCheckDto pipeCheckDto) {
        SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
        if(pipeCheckDto==null)pipeCheckDto = new PipeCheckDto();
        pipeCheckDto.setCompanyId(userInfo.getCompanyId());
        return pipeCheckRecordMapper.pipeCheckList(pipeCheckDto);
    }

    @Override
    @Transactional
    public void updateResultPass(PipeCheckDto pipeCheckDto) {
        SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
        PipeInfo pipeInfo = pipeInfoMapper.queryById(pipeCheckDto.getPipeId());
        if(pipeInfo.getCheckResult()==1){
            throw new BasicException(BasicStatus.CURRENT_IS_PASS);
        }
        //记录
        PipeCheckRecord pipeCheckRecord = new PipeCheckRecord();
        pipeCheckRecord.setPipeId(pipeInfo.getPipeId());
        pipeCheckRecord.setCheckResult(1);
        pipeCheckRecord.setCheckUser(userInfo.getUserId());
        pipeCheckRecordMapper.insert(pipeCheckRecord);

        //更新
        pipeInfoMapper.updateCheckResult(pipeInfo.setCheckResult(1).setCheckUser(userInfo.getUserId()));
    }
}