package com.gk.firework.Service.ServiceImpl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gk.firework.Domain.EnterpriseResource;
import com.gk.firework.Domain.EnterpriseWarehouse;
import com.gk.firework.Domain.Exception.BusinessException;
import com.gk.firework.Domain.UserInfo;
import com.gk.firework.Domain.Utils.Constants;
import com.gk.firework.Domain.Utils.Properties;
import com.gk.firework.Domain.Utils.StringUtils;
import com.gk.firework.Domain.Utils.UploadUtil;
import com.gk.firework.Domain.Vo.EnterpriseWarehouseVo;
import com.gk.firework.Mapper.EnterpriseWarehouseMapper;
import com.gk.firework.Service.EnterpriseResourceService;
import com.gk.firework.Service.EnterpriseService;
import com.gk.firework.Service.EnterpriseWarehouseService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import java.util.*;

@Service("enterpriseWarehouseService")
public class EnterpriseWarehouseServiceImpl extends ServiceImpl<EnterpriseWarehouseMapper, EnterpriseWarehouse> implements EnterpriseWarehouseService {


    @Autowired
    private EnterpriseResourceService enterpriseResourceService;

    @Autowired
    private EnterpriseWarehouseMapper enterpriseWarehouseMapper;

    /**
    * @Description: 分页查询库房信息
    * @date 2021/3/25 9:29
    */
    @Override
    public IPage selectPage(Page<EnterpriseWarehouse> page, Long id) {
        Map<String, Object> params = new HashMap<>();
        params.put("id", id);
        params.put("tabletype", Constants.WAREHOUSE);
        List<EnterpriseWarehouse> list = enterpriseWarehouseMapper.selectPages(page, params);
        page.setRecords(list);
        return page;

    }

    /**
     * @Description: 新增库房信息
     * @date 2021/3/25 9:29
     */
    @Override
    @Transactional
    public void addEnterpriseWarehouse(EnterpriseWarehouseVo enterpriseWarehouseVo, UserInfo user) throws Exception {

        //新增基本信息
        EnterpriseWarehouse ew = new EnterpriseWarehouse();
        ew.setBulidingnumber(enterpriseWarehouseVo.getBulidingnumber());
        ew.setArea(enterpriseWarehouseVo.getArea());
        ew.setDangerlevel(enterpriseWarehouseVo.getDangerlevel());
        ew.setLimits(enterpriseWarehouseVo.getLimits());
        ew.setSafetyperson(enterpriseWarehouseVo.getSafetyperson());
        ew.setEnterpriseid(enterpriseWarehouseVo.getEnterpriseid());
        ew.setHoldinventory(enterpriseWarehouseVo.getHoldinventory());
        ew.setSafetypersonphone(enterpriseWarehouseVo.getSafetypersonphone());
        ew.setMedicinelimits(enterpriseWarehouseVo.getMedicinelimits());
        ew.setCreatetime(new Date());
        ew.setCreateby(user.getId());
        ew.setCreatebyname(user.getUsername());
        ew.setValidflag(true);
        this.save(ew);

        List<EnterpriseResource> adds = null;
        if (enterpriseWarehouseVo.getFile() !=null && enterpriseWarehouseVo.getFile().length > 0) {
            adds = new ArrayList<>();
            Date now = new Date();
            for (MultipartFile file : enterpriseWarehouseVo.getFile()) {
                String name = UploadUtil.uploadFile(file, Properties.enterprisePath);
                EnterpriseResource er = new EnterpriseResource();
                er.setBelongid(ew.getId());
                er.setTabletype(Constants.WAREHOUSE);
                er.setCreateby(user.getId());
                er.setCreatebyname(user.getUsername());
                er.setCreatetime(now);
                er.setFilename(file.getOriginalFilename());
                er.setUrl(Properties.enterprise + name);
                er.setValidflag(true);
                adds.add(er);
            }
            enterpriseResourceService.saveBatch(adds);
        }
    }

    /**
     * @Description: 修改库房信息
     * @date 2021/3/25 9:29
     */
    @Override
    @Transactional
    public void modEnterpriseWarehouse(EnterpriseWarehouseVo enterpriseWarehouseVo, UserInfo user) throws Exception {

        EnterpriseWarehouse ew = new EnterpriseWarehouse();
        ew.setId(enterpriseWarehouseVo.getId());
        ew.setBulidingnumber(enterpriseWarehouseVo.getBulidingnumber());
        ew.setArea(enterpriseWarehouseVo.getArea());
        ew.setDangerlevel(enterpriseWarehouseVo.getDangerlevel());
        ew.setLimits(enterpriseWarehouseVo.getLimits());
        ew.setHoldinventory(enterpriseWarehouseVo.getHoldinventory());
        ew.setSafetyperson(enterpriseWarehouseVo.getSafetyperson());
        ew.setSafetypersonphone(enterpriseWarehouseVo.getSafetypersonphone());
        ew.setMedicinelimits(enterpriseWarehouseVo.getMedicinelimits());
        ew.setEnterpriseid(enterpriseWarehouseVo.getEnterpriseid());
        ew.setUpdatetime(new Date());
        ew.setUpdateby(user.getId());
        ew.setUpdatebyname(user.getUsername());
        this.updateById(ew);

        //修改图片
        List<Long> imgIds = enterpriseWarehouseVo.getImgids();
        //1.删除图片
        List<EnterpriseResource> dels = null;
        if (imgIds != null && imgIds.size() > 0) {
            dels = new ArrayList<>();
            for (Long id : imgIds) {
                EnterpriseResource er = new EnterpriseResource();
                er.setId(id);
                er.setValidflag(false);
                er.setUpdateby(user.getId());
                er.setUpdatebyname(user.getUsername());
                er.setUpdatetime(new Date());
                dels.add(er);
            }
            //删除
            enterpriseResourceService.updateBatchById(dels);
        }
        //2.新增
        List<EnterpriseResource> adds = null;
        if (enterpriseWarehouseVo.getFile() !=null && enterpriseWarehouseVo.getFile().length > 0) {
            adds = new ArrayList<>();
            Date now = new Date();
            for (MultipartFile file : enterpriseWarehouseVo.getFile()) {
                String name = UploadUtil.uploadFile(file, Properties.enterprisePath);
                EnterpriseResource er = new EnterpriseResource();
                er.setTabletype(Constants.WAREHOUSE);
                er.setFilename(file.getOriginalFilename());
                er.setUrl(Properties.enterprise + name);
                er.setCreatetime(now);
                er.setCreateby(user.getId());
                er.setCreatebyname(user.getUsername());
                er.setBelongid(enterpriseWarehouseVo.getId());
                er.setValidflag(true);
                adds.add(er);
            }
            //执行
            enterpriseResourceService.saveBatch(adds);
        }
    }

    /**
    * @Description: 删除库房信息
    * @date 2021/3/25 9:47
    */
    @Override
    public void delEnterpriseWarehouse(Long id, UserInfo user) {
        LambdaUpdateWrapper<EnterpriseWarehouse> updateWrapper = new LambdaUpdateWrapper<>();
        updateWrapper.set(EnterpriseWarehouse::getUpdatebyname, new Date())
                .set(EnterpriseWarehouse::getUpdateby, user.getId())
                .set(EnterpriseWarehouse::getUpdatebyname, user.getUsername())
                .set(EnterpriseWarehouse::getValidflag, false)
                .eq(EnterpriseWarehouse::getId, id);
        this.update(updateWrapper);
    }

    /**
    * @Description: 新增|修改的校验
    * @date 2021/4/6 14:49
    */
    @Override
    public void checkEnterpriseWarehouse(EnterpriseWarehouseVo enterpriseLicenseVo) {
        if (StringUtils.isBlank(enterpriseLicenseVo.getBulidingnumber())) {
            throw new BusinessException("栋号不能为空");
        }

        if (StringUtils.isBlank(enterpriseLicenseVo.getDangerlevel())) {
            throw new BusinessException("危险等级不能为空");
        }

        if (enterpriseLicenseVo.getArea() == null) {
            throw new BusinessException("面积不能为空");
        }

        if (enterpriseLicenseVo.getLimits() == null) {
            throw new BusinessException("限制作业人数不能为空");
        }

        if (StringUtils.isBlank(enterpriseLicenseVo.getSafetyperson())) {
            throw new BusinessException("安全责任人不能为空");
        }

        if (StringUtils.isBlank(enterpriseLicenseVo.getSafetypersonphone())) {
            throw new BusinessException("安全责任人联系电话不能为空");
        }

    }
}