package com.thhy.materials.modules.biz.embedment.service.impl;

import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.thhy.general.common.BasicMessage;
import com.thhy.general.common.BasicResult;
import com.thhy.general.common.IBasicStatus;
import com.thhy.general.config.SysUserInfo;
import com.thhy.general.exception.BasicException;
import com.thhy.general.utils.ExcelUtils;
import com.thhy.general.utils.UserInfoUtils;
import com.thhy.materials.modules.biz.embedment.dto.EmbedmentRecordDto;
import com.thhy.materials.modules.biz.embedment.entity.SysEmbedmentGoodsEntity;
import com.thhy.materials.modules.biz.embedment.entity.SysEmbedmentRecordEntity;
import com.thhy.materials.modules.biz.embedment.mapper.SysEmbedmentGoodsMapper;
import com.thhy.materials.modules.biz.embedment.mapper.SysEmbedmentRecordMapper;
import com.thhy.materials.modules.biz.embedment.service.SysEmbedmentRecordService;
import com.thhy.materials.modules.biz.utils.ExcelUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.multipart.MultipartFile;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;

/**
 * @Author QiuYuHao
 * @CreateDate 2023-09-22 16:28:24
 * 预埋件出入库实现
 */
@Service
public class SysEmbedmentRecordServiceImpl implements SysEmbedmentRecordService{

	@Autowired
	private SysEmbedmentRecordMapper sysEmbedmentRecordMapper;

	@Autowired
	private SysEmbedmentGoodsMapper sysEmbedmentGoodsMapper;


	@Override
	public BasicResult insert(SysEmbedmentRecordEntity sysEmbedmentRecordEntity) {
		SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
		sysEmbedmentRecordEntity.setCreateUser(sysUserInfo.getRealName());
		SysEmbedmentGoodsEntity entity = sysEmbedmentGoodsMapper.findEntity(sysEmbedmentRecordEntity.getEmbedmentId());
		if(entity!=null){
			String stockType = sysEmbedmentRecordEntity.getStockType();
			//stockType 1入库 2出库
			int result = entity.getStock();
			if("1".equals(stockType)){
				result= entity.getStock() + sysEmbedmentRecordEntity.getChangeStock();
			}else{
				result= entity.getStock() - sysEmbedmentRecordEntity.getChangeStock();
			}
			if(result < 0 ){
				return BasicResult.faild("11111","库存不足","库存不足");
			}
			entity.setStock(result);
			sysEmbedmentGoodsMapper.update(entity);//更改库存
		}else {
			return BasicResult.faild("11111","库存没有该预埋件,请到【预埋件种类】添加","库存没有该预埋件,请到【预埋件种类】添加");
		}
		sysEmbedmentRecordMapper.insert(sysEmbedmentRecordEntity);
		return BasicResult.success();
	}

	@Override
	public BasicResult embedmentRecordDel(String id) {
		sysEmbedmentRecordMapper.embedmentRecordDel(id);
		return BasicResult.success();
	}

	@Override
	public BasicResult update(SysEmbedmentRecordEntity sysEmbedmentRecordEntity) {
		sysEmbedmentRecordMapper.update(sysEmbedmentRecordEntity);
		return BasicResult.success();
	}

	@Override
	public BasicResult embedmentRecordList(EmbedmentRecordDto embedmentRecordDto) {
		SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
		embedmentRecordDto.setCompanyId(sysUserInfo.getCompanyId());
		PageHelper.startPage(embedmentRecordDto.getPageNum(),embedmentRecordDto.getPageSize());
		List<SysEmbedmentRecordEntity> sysEmbedmentRecordEntities = sysEmbedmentRecordMapper.embedmentRecordList(embedmentRecordDto);
		PageInfo<SysEmbedmentRecordEntity> info = new PageInfo<>(sysEmbedmentRecordEntities);
		return BasicResult.success(info);
	}

	@Override
	public BasicResult embedmentRecordOutList(EmbedmentRecordDto embedmentRecordDto) {
		SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
		embedmentRecordDto.setCompanyId(sysUserInfo.getCompanyId());
		PageHelper.startPage(embedmentRecordDto.getPageNum(),embedmentRecordDto.getPageSize());
		List<SysEmbedmentRecordEntity> sysEmbedmentRecordEntities = sysEmbedmentRecordMapper.embedmentRecordOutList(embedmentRecordDto);
		PageInfo<SysEmbedmentRecordEntity> info = new PageInfo<>(sysEmbedmentRecordEntities);
		return BasicResult.success(info);
	}

	@Override
	public BasicResult embedmentRecordInfo(String id) {
		return BasicResult.success(sysEmbedmentRecordMapper.embedmentRecordInfo(id));
	}

	@Override
	public void export(EmbedmentRecordDto embedmentRecordDto, HttpServletResponse response) {
		SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
		embedmentRecordDto.setCompanyId(sysUserInfo.getCompanyId());
		List<SysEmbedmentRecordEntity> sysEmbedmentRecordEntities = sysEmbedmentRecordMapper.embedmentRecordList(embedmentRecordDto);
		ExcelUtils.downExcel(sysEmbedmentRecordEntities,SysEmbedmentRecordEntity.class,response,"预埋件入库");
	}

	@Override
	public void recordExportTemplate(EmbedmentRecordDto embedmentRecordDto, HttpServletResponse response) {
		List<SysEmbedmentRecordEntity> sysEmbedmentRecordEntities = new ArrayList<>();
		ExcelUtils.downExcel(sysEmbedmentRecordEntities,SysEmbedmentRecordEntity.class,response,"预埋件出入库");
	}

	@Override
	@Transactional(rollbackFor = Exception.class)
	public BasicResult variateExcel(MultipartFile file, HttpServletRequest request) {
		List<List<Object>> lists = null;//去工具类处理，返回excel中的数据
		try {
			lists = ExcelUtil.getUserListByExcel(file.getInputStream(), file.getOriginalFilename());
		} catch (Exception e) {
			e.printStackTrace();
		}
		lists.remove(0);
		if (lists.size()>0){
			for (List<Object> list :lists){
				String embedmentNameAndModel = list.get(0).toString();
				String[] split = embedmentNameAndModel.split("-");
				String embedmentName = split[0];
				String embedmentModel = split[1];
				String id =  sysEmbedmentGoodsMapper.embedmentNameAndType(embedmentName,null);
				SysEmbedmentRecordEntity sysEmbedmentRecordEntity = new SysEmbedmentRecordEntity();
				sysEmbedmentRecordEntity.setEmbedmentId(id);
				//入库数量
				Integer changeStock = Integer.valueOf(list.get(2).toString());
				sysEmbedmentRecordEntity.setChangeStock(changeStock);
				//单价
				String dj = list.get(3).toString();
				BigDecimal singlePrice = new BigDecimal(dj);
				sysEmbedmentRecordEntity.setSinglePrice(singlePrice);
				//金额
				String je = list.get(4).toString();
				BigDecimal amount = new BigDecimal(je);
				sysEmbedmentRecordEntity.setAmount(amount);
				//备注
				String remark = list.get(5).toString();
				sysEmbedmentRecordEntity.setRemark(remark);
				//入库人
				SysUserInfo sysUserInfo = UserInfoUtils.getInstance().getUserInfo();
				String companyId = sysUserInfo.getCompanyId();
				sysEmbedmentRecordEntity.setCreateUser(sysUserInfo.getRealName());
				sysEmbedmentRecordEntity.setCompanyId(companyId);
				//stockType 1入库
				sysEmbedmentRecordEntity.setStockType("1");
				SysEmbedmentGoodsEntity entity = sysEmbedmentGoodsMapper.findEntity(sysEmbedmentRecordEntity.getEmbedmentId());
				if(entity!=null){
					int result = entity.getStock() + sysEmbedmentRecordEntity.getChangeStock();
					entity.setStock(result);
					sysEmbedmentGoodsMapper.update(entity);//更改库存
				}else {
					throw new BasicException(new BasicMessage("500","库存没有【"+embedmentName+"】,请到预埋件种类新增,新增完可重新导入！"));
				}
				sysEmbedmentRecordMapper.insert(sysEmbedmentRecordEntity);
			}
			return BasicResult.success("导入成功");
		}else {
			return BasicResult.faild("11111","error","空文件");
		}
	}


}