package com.qianwen.mdc.service.plant;

import java.util.ArrayList;
import java.util.Collections;
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.qianwen.mdc.domain.Machine;
import com.qianwen.mdc.domain.plant.Plant;
import com.qianwen.mdc.dto.plant.PlantDTO;
import com.qianwen.mdc.mapper.MachineMapper;
import com.qianwen.mdc.mapper.PlantMapper;

/**
 * @author y_ys79
 * 厂房服务
 */
@Service
public class PlantService {
	@Autowired
    private PlantMapper plantMapper;
	@Autowired
    private MachineMapper machineMapper;
	
	public static final Logger logger = LoggerFactory.getLogger(PlantService.class);
	/**
	 * 新增厂房
	 * @param plantDTO
	 */
	@Transactional
	public void save(PlantDTO plantDTO) {

		Plant p = new Plant();
		p.setName(plantDTO.getName());
		p.setGridSetting(plantDTO.getGridSetting());
       
		
		plantMapper.insert(p);
		
		Long plantId = p.getId();
		
		List<Integer> machineIds = this.parseMachineIdInGrid(plantDTO.getGridSetting());
		
		for(Integer mid:machineIds ) {
			Machine m = machineMapper.selectById(mid);
			if(m != null) {
				m.setPlantId(plantId);
				machineMapper.updateById(m);
			}
		}
		
	}
	
	public List<Integer> parseMachineIdInGrid(String gridSetting){
		List<Integer> macineIds = new ArrayList<>();
		try {
			
			JSONArray arr1 = JSONArray.parseArray(gridSetting);
			JSONObject node;
			for(int i=0;i<arr1.size();i++) {
				JSONArray arr2= arr1.getJSONArray(i);
				
				for(int j=0;j<arr2.size();j++) {
					node = arr2.getJSONObject(j);
					if(node.containsKey("id")) {
						macineIds.add(node.getInteger("id"));
					}
				}
			}
			
			return macineIds;
		}catch(Exception e) {
			logger.error("解析失败",e);
			return Collections.emptyList();
		}
		
	}
	/**
	 * 修改厂房
	 * @param plantDTO
	 */
	@Transactional
	public void modify(PlantDTO plantDTO) {

		Plant p = plantMapper.selectById(plantDTO.getId());
		String oriGridSetting = p.getGridSetting();
       
		//清空原有的machine的plantId
		List<Integer> oriMachineIds = this.parseMachineIdInGrid(oriGridSetting);
		for(Integer mid:oriMachineIds ) {
			Machine m = machineMapper.selectById(mid);
			if(m != null) {
				m.setPlantId(null);
				machineMapper.updateById(m);
			}
		}
		
		//新配置的机床，更新plantId
		List<Integer> machineIds = this.parseMachineIdInGrid(plantDTO.getGridSetting());
		
		Long plantId = plantDTO.getId();
		for(Integer mid:machineIds ) {
			Machine m = machineMapper.selectById(mid);
			if(m != null) {
				m.setPlantId(plantId);
				machineMapper.updateById(m);
			}
		}
		
		//machineMapper.clearPlantIdInPlant(plantId);
		
		p.setName(plantDTO.getName());
		p.setGridSetting(plantDTO.getGridSetting());
		plantMapper.updateById(p);
	}
	
	
	
	/**
	 * 删除厂房
	 * @param ids 厂房id列表
	 */
	@Transactional
	public void delete(List<Long> ids) {
		//TODO 检查厂房的设备数量
		for(Long plantId :ids) {
			plantMapper.deleteById(plantId);
			machineMapper.clearPlantIdInPlant(plantId);
		}
	}
}