package org.springblade.mdm.basesetting.machine.service;

import io.jsonwebtoken.lang.Collections;
import org.apache.commons.lang3.StringUtils;
import org.springblade.core.excel.util.ExcelUtil;
import org.springblade.core.mp.base.BizServiceImpl;
import org.springblade.core.tool.api.R;
import org.springblade.core.tool.utils.StringUtil;
import org.springblade.mdm.basesetting.machine.entity.Machine;
import org.springblade.mdm.basesetting.machine.mapper.MachineMapper;
import org.springblade.mdm.basesetting.machine.vo.MachineExcel;
import org.springblade.mdm.basesetting.producedivision.entity.MdmDept;
import org.springblade.mdm.basesetting.producedivision.service.MdmDeptService;
import org.springblade.mdm.basesetting.producedivision.vo.ImportResult;
import org.springblade.system.feign.IDictBizClient;
import org.springblade.system.feign.ISysClient;
import org.springblade.system.pojo.entity.DictBiz;
import org.springframework.beans.BeanUtils;
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 java.util.ArrayList;
import java.util.List;
import java.util.Optional;

@Service
public class MachineImportService extends BizServiceImpl<MachineMapper, Machine> {
	@Autowired
	private ISysClient sysClient;
	@Autowired
	private IDictBizClient dictBizClient;
	@Autowired
	private MdmDeptService mdmDeptService;
	@Autowired
	private MachineService machineService;
	@Transactional
	public ImportResult importMachines(MultipartFile file) {
		ImportResult res1 = new ImportResult();
		if(file == null || file.isEmpty()){
			res1.setMessage("文件为空");
			return res1;
		}

		List<MachineExcel> list = ExcelUtil.read(file, MachineExcel.class);
		return transAndSave(list);
	}

	@Transactional
	ImportResult transAndSave(List<MachineExcel> list){
		ImportResult result1= checkImport( list);
		if(result1.getFailure()>0){
			return result1;
		}
		//machine_spec
			//machine_control_system
		//machine_control_system
		R<List<DictBiz>> machineSpecListRes = dictBizClient.getList("machine_spec");
		List<DictBiz> machineSpecList = machineSpecListRes.isSuccess() ? machineSpecListRes.getData() : Collections.emptyList();

		R<List<DictBiz>> machineSystemRes = dictBizClient.getList("machine_control_system");
		List<DictBiz> machineSystemList = machineSystemRes.isSuccess() ? machineSystemRes.getData() : Collections.emptyList();

		R<List<DictBiz>> machineGroupRes = dictBizClient.getList("machine_group");
		List<DictBiz>  machineGroupList = machineGroupRes.isSuccess() ? machineGroupRes.getData() : Collections.emptyList();
		DictBiz emptyDit = new DictBiz();

		List<Machine> entityList = new ArrayList<>();
		MdmDept ownerDept;
		ImportResult ir = new ImportResult();
		int failCount = 0;
		int successCount = 0;
		StringBuilder msg = new StringBuilder();
		for(MachineExcel excelVO : list){
			Machine machine = new Machine();

			BeanUtils.copyProperties(excelVO, machine);
			ownerDept = mdmDeptService.getByName(excelVO.getOwnerDeptName());
			if(ownerDept != null){
				machine.setOwnerDept(ownerDept.getId());
			}
			//类型
			Optional<DictBiz> specOpt = machineSpecList.stream().filter(s -> StringUtils.equals(s.getDictValue(),excelVO.getMachineSpecName())).findFirst();
			machine.setMachineSpec(specOpt.orElse(emptyDit).getDictKey());
			//系统
			Optional<DictBiz> sysOpt = machineSystemList.stream().filter(s -> StringUtils.equals(s.getDictValue(),excelVO.getControlSystemName())).findFirst();
			machine.setControlSystem(sysOpt.orElse(emptyDit).getDictKey());

			//机床组
			//key = FANUK,
			Optional<DictBiz> groupOpt = machineGroupList.stream().filter(s -> StringUtils.equals(s.getDictValue(),excelVO.getMachineGroupName())).findFirst();
			machine.setMachineGroupCode(groupOpt.orElse(emptyDit).getDictKey());

			//entityList.add(machine);
			Machine oriMachine = machineService.getByCode(machine.getCode());

			if(oriMachine != null){
				msg.append(machine.getCode()).append("机床编码重复:").append(machine.getCode());
				failCount ++;
			}else if(machine.getMachineGroupCode() == null){
				msg.append(excelVO.getCode()+"机床组不匹配"+excelVO.getMachineGroupName()).append("<br/>");
				failCount ++;
			}else if(machine.getMachineSpec() == null){
				msg.append(excelVO.getCode()+"机床类型不匹配"+excelVO.getMachineSpecName()).append("<br/>");
				failCount ++;
			}else {
				try {
					machineService.save(machine);
					successCount++;
				}catch(Exception e){
					log.error("入库失败",e);
					failCount ++;
					msg.append(excelVO.getCode()+"入库失败");
				}
			}
		}

		ir.setFailure(failCount);
		ir.setSuccess(successCount);

		if(ir.getFailure()==0){
			ir.setMessage("导入成功");
		}else{
			ir.setMessage(msg.toString());
		}
		return ir;
	}

	private ImportResult checkImport(List<MachineExcel> list) {
		StringBuffer msg = new StringBuffer();;
		int failCount = 0;
		MachineExcel excelVO;
		String temp;
		for(int i=0;i<list.size();i++){
			excelVO = list.get(0);
			temp ="";
			if(StringUtil.isBlank(excelVO.getCode())){
				//msg.append("第"+(i+1)+"行机床编码为空,");
				temp = "机床编码为空,";
			}
			if(StringUtil.isBlank(excelVO.getName())){
				//msg.append("第"+(i+1)+"行机床编码为空,");
				temp += "机床型号为空,";
			}
			if(StringUtil.isBlank(excelVO.getMachineGroupName())){
				temp += "机床组为空,";
			}

			if(StringUtil.isBlank(excelVO.getMachineSpecName())){
				temp += "机床类型为空,";
			}


			if(StringUtil.isNotBlank(temp)){
				msg.append("行"+(i+1)+" "+StringUtils.removeEnd(temp,",")).append(";");
				failCount ++;
			}
		}

		ImportResult res= new ImportResult();
		res.setFailure(failCount);
		res.setMessage(msg.toString());

		return res;
	}
}