package com.qianwen.smartman.modules.smis.service;

import java.io.IOException;
import java.nio.charset.Charset;
import java.util.List;

import org.apache.commons.io.IOUtils;
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.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.qianwen.core.log.exception.ServiceException;
import com.qianwen.core.mp.base.BaseServiceImpl;
import com.qianwen.smartman.common.mqtt.MqttMessageSender;
import com.qianwen.smartman.modules.smis.entity.CollectDeviceType;
import com.qianwen.smartman.modules.smis.entity.Workstation;
import com.qianwen.smartman.modules.smis.entity.WorkstationDatapoints;
import com.qianwen.smartman.modules.smis.mapper.CollectDeviceTypeMapper;
import com.qianwen.smartman.modules.smis.mapper.WorkstationDatapointsMapper;
import com.qianwen.smartman.modules.smis.mapper.WorkstationMapper;
import com.qianwen.smartman.modules.smis.vo.WorkstationDatapointsSubmitVO;
import com.qianwen.smartman.modules.smis.vo.WorkstationDatapointsVO;

import cn.hutool.core.util.ObjectUtil;

@Service
public class WorkstationDatapointsService extends BaseServiceImpl<WorkstationDatapointsMapper, WorkstationDatapoints> {
	private Logger log = LoggerFactory.getLogger(this.getClass());
	@Autowired
	private CollectDeviceTypeMapper typeMapper;

	@Autowired
	private MqttMessageSender mqttSender;
	
	@Autowired
	private WorkstationMapper workstationMapper;
	/**
	 * mqtt topic，用于通知collect应用，数据点改变
	 */
	private final String WORKSTATION_DATAPOINT_CHANGED_TOPIC = "mdc/workstation_datapoint_changed";
	/**
	 * 新增或者修改工位点位配置
	 * @param tplVO
	 */
	@Transactional
    public void submit(WorkstationDatapointsSubmitVO dpVO) {
      
		if(ObjectUtil.isEmpty(dpVO.getAppId())) {
			throw new ServiceException("应用ID不能为空");
		}
		Workstation usingWorkstation = appIdUsingWorkstation(dpVO.getAppId(),dpVO.getWorkstationId());
		if(usingWorkstation != null) {
			//appId被使用
			String err = "应用ID被占用，工位名称+编号:"+usingWorkstation.getName()+"-"+usingWorkstation.getCode();
			throw new ServiceException(err);
		}
		
		WorkstationDatapoints dp = this.baseMapper.selectOne(Wrappers.<WorkstationDatapoints>lambdaQuery().eq(WorkstationDatapoints::getWorkstationId, dpVO.getWorkstationId()));
        if (dp == null) {
        	//新增
        	dp = new WorkstationDatapoints();
        	dp.setDpConfig(dpVO.getDpConfig());
        	dp.setIsDeleted(0);
        	dp.setWorkstationId(dpVO.getWorkstationId());
        	dp.setType(dpVO.getType());
        	dp.setAppId(dpVO.getAppId());
        }else {
        	dp.setDpConfig(dpVO.getDpConfig());
        	dp.setIsDeleted(0);
        	dp.setWorkstationId(dpVO.getWorkstationId());
        	dp.setType(dpVO.getType());
        	dp.setAppId(dpVO.getAppId());
        }
        
        saveOrUpdate(dp);
        
        /*
        WorkstationAppMapping appMap = mpmapper.selectById(dpVO.getWorkstationId());
        if(appMap == null) {
        	appMap = new WorkstationAppMapping();
        	appMap.setAppId(dpVO.getAppId());
        	appMap.setWorkstationId(dpVO.getWorkstationId());
        	mpmapper.insert(appMap);
        }else {
        	appMap.setAppId(dpVO.getAppId());
        	mpmapper.updateById(appMap);
        }*/
        
        //发送变更消息
        JSONObject payloadObj = new JSONObject();
        payloadObj.put("appId", dpVO.getAppId());
        payloadObj.put("workstationId", dpVO.getWorkstationId());
        mqttSender.sendMessage(WORKSTATION_DATAPOINT_CHANGED_TOPIC, payloadObj.toJSONString());
    }
	/**
	 * appId是否被其他工位使用，如果使用返回使用的工位数据
	 * @param appId
	 * @param workstationId
	 * @return 使用该appId的工位
	 */
	Workstation appIdUsingWorkstation(String appId,long workstationId) {
		//long cnt = baseMapper.selectCount(Wrappers.<WorkstationDatapoints>lambdaQuery().ne(WorkstationDatapoints::getWorkstationId, workstationId).eq(WorkstationDatapoints::getAppId, appId));
		//return cnt > 0;
		List<WorkstationDatapoints> dpList = baseMapper.selectList(Wrappers.<WorkstationDatapoints>lambdaQuery().ne(WorkstationDatapoints::getWorkstationId, workstationId).eq(WorkstationDatapoints::getAppId, appId));
		
		if(dpList.isEmpty()) {
			return null;
		}
		
		Workstation ws = workstationMapper.selectById(dpList.get(0).getWorkstationId());
		return ws;
	}
	/**
	 * 获取工位数据点配置
	 * @param workstationId
	 * @return
	 */
	public WorkstationDatapointsVO getDatapoints(Long workstationId) {
		log.info("woid={}",workstationId);
		WorkstationDatapoints dp = baseMapper.selectOne(Wrappers.<WorkstationDatapoints>lambdaQuery().eq(WorkstationDatapoints::getWorkstationId, workstationId));
		
		log.info("dp={}",dp);
		
		WorkstationDatapointsVO dpVO = new WorkstationDatapointsVO();
		dpVO.setWorkstationId(workstationId);
		if(dp != null) {
			
			dpVO.setDpConfig(dp.getDpConfig());
			dpVO.setType(dp.getType());
			dpVO.setAppId(dp.getAppId());
			
			Charset utf8charset = Charset.forName("utf8");
			String startJsonStr= "[]";
	    	String endJsonStr = "[]";
			try {
				startJsonStr = IOUtils.resourceToString("/dp/dpstart.json",  utf8charset);
				endJsonStr = IOUtils.resourceToString("/dp/dpend.json",  utf8charset);
			} catch (IOException e) {
				log.error("读取默认dpHead异常",e);
			}

			CollectDeviceType collectType = typeMapper.selectById(dp.getType());
			String fullHead = CollectDeviceTypeService.mergeJson(startJsonStr,collectType.getDpHead(),endJsonStr);
			dpVO.setDpHead(fullHead);
			
		}
		return dpVO;
	}

	/**
	 * 删除工位的采集数据点位配置
	 * @param workstationId
	 */
	public void removeByWorkstation(List<Long> workstationIds) {
		log.info("删除工位数据点配置，workstationIds",workstationIds);
		baseMapper.delete(Wrappers.<WorkstationDatapoints>lambdaQuery().in(WorkstationDatapoints::getWorkstationId, workstationIds));
	}
}