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

import com.thhy.general.common.BasicStatus;
import com.thhy.general.config.SysUserInfo;
import com.thhy.general.exception.BasicException;
import com.thhy.general.utils.DeepCopyUtils;
import com.thhy.general.utils.UserInfoUtils;
import com.thhy.mobile.modules.biz.cultivated.entity.*;
import com.thhy.mobile.modules.biz.cultivated.mapper.CultivatedDeviceDataMapper;
import com.thhy.mobile.modules.biz.cultivated.mapper.CultivatedDeviceMapper;
import com.thhy.mobile.modules.biz.cultivated.mapper.WaterCultivatedMapper;
import com.thhy.mobile.modules.biz.cultivated.service.WaterCultivatedService;
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.List;
import java.util.Map;

/**
 *  服务实现类
 * @author zhang_xiao_bo
 * @since 2023-05-11 14:45:24
 */
@Service
public class WaterCultivatedServiceImpl implements WaterCultivatedService {



    @Autowired
    private WaterCultivatedMapper waterCultivatedMapper;

    @Autowired
    private CultivatedDeviceDataMapper deviceDataMapper;

    @Autowired
    private CultivatedDeviceMapper deviceMapper;

    public WaterCultivated get(Serializable id){
        return waterCultivatedMapper.queryById(id);
    }

    public List<CulListVo> findList(WaterCultivated waterCultivated){
        SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
        if(waterCultivated==null)waterCultivated = new WaterCultivated();
        waterCultivated.setCompanyId(userInfo.getCompanyId());
        List<CulListVo> culListVoList = waterCultivatedMapper.findList(waterCultivated);
        culListVoList.forEach(cl ->{
            List<DeviceTemVo> temVoList = deviceDataMapper.deviceDataByCultivatedId(cl.getWaterCultivatedId());
            cl.setTemList(temVoList);
        });
        return culListVoList;
    }

    public List<CulListVo> screenFindList(String token){
        SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo(token);
        WaterCultivated waterCultivated = new WaterCultivated();
        waterCultivated.setCompanyId(userInfo.getCompanyId());
        List<CulListVo> culListVoList = waterCultivatedMapper.findList(waterCultivated);
        culListVoList.forEach(cl ->{
            List<DeviceTemVo> temVoList = deviceDataMapper.deviceDataByCultivatedId(cl.getWaterCultivatedId());
            cl.setTemList(temVoList);
        });
        return culListVoList;
    }

    /**
     * 增加和修改
     * @param culDeviceDto
     */
    @Transactional
    public void addWaterCultivated(CulDeviceDto culDeviceDto){
        List<CultivatedDevice> deviceList = culDeviceDto.getDeviceList();
        if(deviceList.size()<1){
            throw new BasicException(BasicStatus.WATER_MISS_DEVICE);
        }

        WaterCultivated waterCultivated = new WaterCultivated();
        DeepCopyUtils.copy(culDeviceDto,waterCultivated);
        SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
        if(waterCultivated.getWaterCultivatedId() == null){
            //增加操作
            int count = deviceMapper.countByDevices(deviceList);
            if(count>0){
                throw new BasicException(BasicStatus.DEVICE_IS_ALREAD_USE);
            }
            waterCultivated.setCompanyId(userInfo.getCompanyId());
            waterCultivated.setCreateUser(userInfo.getUserId());
            waterCultivatedMapper.insert(waterCultivated);
        }else{
            //修改操作
            waterCultivated.setUpdateUser(userInfo.getUserId());
            waterCultivated.setUpdateTime(new Date());
            waterCultivatedMapper.update(waterCultivated);
            deviceList.forEach(cd->{
                List<String> wcIds = deviceMapper.queryWCIDByDeviceId(cd.getDeviceId());
                if(wcIds.size()>0){
                    if(!wcIds.get(0).equals(waterCultivated.getWaterCultivatedId())){
                        throw new BasicException(BasicStatus.DEVICE_IS_ALREAD_USE);
                    }
                }
            });
            deviceMapper.deleteByCultivatedId(waterCultivated.getWaterCultivatedId());
        }
        deviceList.forEach(cd -> {
            cd.setWaterCultivatedId(waterCultivated.getWaterCultivatedId());
            deviceMapper.insert(cd);
        });

    }

    /**
     * 修改
     * @param waterCultivated
     */
    public void update(WaterCultivated waterCultivated){
        waterCultivatedMapper.update(waterCultivated);
    }

    /**
     * 删除
     * @param waterCultivatedId
     */
    @Transactional
    public void delete(String waterCultivatedId){
        int count = waterCultivatedMapper.countRecordByCulId(waterCultivatedId);
        if(count>0){
            throw new BasicException(BasicStatus.WATER_IS_ALREADY_USE);
        }
        waterCultivatedMapper.deletelogic(waterCultivatedId);
    }

    @Override
    public List<CulPullDownVo> pulldown(WaterCultivated waterCultivated) {
        SysUserInfo userInfo = UserInfoUtils.getInstance().getUserInfo();
        if(waterCultivated==null)waterCultivated= new WaterCultivated();
        waterCultivated.setCompanyId(userInfo.getCompanyId());
        return waterCultivatedMapper.pulldown(waterCultivated);
    }

    @Override
    public List<DevicePullDownVo> waterDeviceList(CulDeviceDto culDeviceDto) {
        return waterCultivatedMapper.waterDeviceList(culDeviceDto.getWaterCultivatedId());
    }

    @Override
    public Map<String, Object> getH5WaterRecord(String num) {
        Map<String, Object> h5WaterRecord = waterCultivatedMapper.getH5WaterRecord(num);
        return h5WaterRecord;
    }

}