package com.product.device.service;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.product.core.config.Global;
import com.product.core.dao.BaseDao;
import com.product.core.entity.DataTableEntity;
import com.product.core.entity.FieldSetEntity;
import com.product.core.service.support.AbstractBaseService;
import com.product.device.config.DeviceConst;
import com.product.module.sys.service.UserService;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.thymeleaf.util.StringUtils;


/**
 * 设备管理
 * @Author
 * @Date 2022/3/8 16:33
 * @Desc 功能相关 service
 */
@Service
public class DeviceManagerService extends AbstractBaseService {

    @Autowired
    public BaseDao baseDao;
    @Autowired
    UserService userService;
    /**
     * 获取设备信息 包括子设备
     * @param uuid
     * @return
     */
    public FieldSetEntity findDeviceAndSub(String uuid,String device_number) {
    	FieldSetEntity dev=findDevice(uuid);
    	if(dev !=null && "device".equals(Global.getSystemConfig("system_platform_type", "")) ) {
    		DataTableEntity dt=baseDao.listTable(DeviceConst.PRODUCT_DEVICE_INFO,"uuid=?", new String[] {uuid},new String[]{});
    		if(!DataTableEntity.isEmpty(dt)) {
    			baseDao.loadPromptData(dt);
    			Map <String,DataTableEntity> sub=new HashMap<>();
    			sub.put("sub", dt);
    			dev.setSubData(sub);
    			//dev.addSubDataTable(dt);
    		}
    	}

    	return dev;
    }
    /**
     * 获取设备信息 包括子设备
     * @param uuid
     * @param asset_code
     * @return
     */
    public FieldSetEntity findDevice(String uuid) {
    	StringBuilder st=new StringBuilder();
    	List<String> pa=new ArrayList<String>();
    	if(!StringUtils.isEmpty(uuid)) {
    		st.append("uuid=?");
    		pa.add(uuid);
    	}else {
    		return null;
    	}
    	FieldSetEntity dev=baseDao.getFieldSetEntityByFilter(DeviceConst.PRODUCT_DEVICE_INFO, new String[]{}, st.toString(), pa.toArray(), false, null);
    	baseDao.loadPromptData(dev);
    	return dev;
    }
    /**
     * 设备的状态变更
     * 如果有子设备，需要把子设备状态一起变更
     * @return
     */
    public boolean deviceStatusChange(String device_number,String status) {
    	return baseDao.executeUpdate("update product_device_info set device_status=? where device_number=?",new String[] {status,device_number});
    }
    /**
     * 添加设备运行记录
     * @param asset_code
     * @param user
     * @param type
     * @param log
     * @return
     */
    public boolean appendDeivceManageLog(String asset_code,String user,String type,String log,String table,String uuid ) {

    	return true;
    }
    /**
     * 设备的相关人员信息
     * @param asset_code
     * @return
     */
    public DataTableEntity findDevicePersion(String asset_code) {
    	StringBuilder sql = new StringBuilder();
        sql.append("\nselect a.user_id userid,b.post,a.user_name,a.user_phone_number tel,thumbnail_img from (");
        sql.append("\nselect yardman userid,'调度人' post from product_device_archives where asset_code='").append(asset_code).append("' union");
        sql.append("\nselect repair_fitter,'钳工维修人员' from product_device_archives where asset_code='").append(asset_code).append("' union");
        sql.append("\nselect repair_electrician,'电工维修人员' from product_device_archives where asset_code='").append(asset_code).append("' union");
        sql.append("\nselect mechanician ,'机械技术员' from product_device_archives where asset_code='").append(asset_code).append("' union");
        sql.append("\nselect electrician ,'电气技术员' from product_device_archives where asset_code='").append(asset_code).append("' union");
        sql.append("\nselect technician  ,'技术负责人' from product_device_archives where asset_code='").append(asset_code).append("' union");
        sql.append("\nselect safety_manager ,'安全管理员' from product_device_archives where asset_code='").append(asset_code).append("'");
        sql.append("\n) b left join product_sys_users a on b.userid=a.user_id");

        DataTableEntity dte = baseDao.listTable(sql.toString(), new Object[]{});
//        dte.getMeta().addAliasTable("product_sys_users", "a");
//        dte.getMeta().addAliasTable("product_device_archives", "b");
//        dte.getMeta().addAliasField("product_sys_users.user_id", "userid");
//        dte.getMeta().addAliasField("product_sys_users.user_id", "post");
//        baseDao.loadPromptData(dte);

        // 头像
        FieldSetEntity tempFse;
        for (int i = 0;i < dte.getRows();i++) {
            tempFse = dte.getFieldSetEntity(i);
            tempFse.setValue(com.product.core.websocket.config.CmnConst.THUMBNAIL_IMG, userService.getUserAvatar(tempFse.getString("userid")));
        }

        return dte;

    }

}