//package com.product.data.center.service;
//
//import cn.hutool.core.collection.CollectionUtil;
//import cn.hutool.core.date.DateTime;
//import cn.hutool.core.date.DateUtil;
//import cn.hutool.core.thread.ThreadUtil;
//import cn.hutool.core.util.NumberUtil;
//import cn.hutool.http.HttpRequest;
//import cn.hutool.http.HttpResponse;
//import com.alibaba.fastjson.JSON;
//import com.alibaba.fastjson.JSONObject;
//import com.product.common.utils.spring.SpringUtils;
//import com.product.core.config.CoreConst;
//import com.product.core.config.Global;
//import com.product.core.entity.DataTableEntity;
//import com.product.core.entity.FieldSetEntity;
//import com.product.core.exception.BaseException;
//import com.product.core.service.support.AbstractBaseService;
//import com.product.core.sign.SignUtil;
//import com.product.core.spring.context.SpringBeanUtil;
//import com.product.core.spring.context.SpringMVCContextHolder;
//import com.product.core.transfer.Transactional;
//import com.product.core.util.JsonUtil;
//import com.product.data.center.config.CmnConst;
//import com.product.data.center.config.ErrorCode;
//import com.product.data.center.entity.HistoryEntity;
//import com.product.data.center.service.ide.IMesExternalService;
//import com.product.data.center.utils.QuerySqlParseUtil;
//import com.product.datasource.dao.Dao;
//import com.product.datasource.dao.impl.OracleDaoImpl;
//import com.product.datasource.entity.DataBaseEntity;
//import com.product.quartz.service.IRemoteService;
//import com.product.util.BaseUtil;
//import oracle.jdbc.internal.OracleTypes;
//import org.apache.commons.lang3.StringUtils;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.stereotype.Service;
//
//import javax.servlet.http.HttpServletRequest;
//import java.sql.CallableStatement;
//import java.sql.Connection;
//import java.sql.SQLException;
//import java.util.*;
//import java.util.concurrent.CompletionService;
//import java.util.concurrent.ExecutionException;
//import java.util.concurrent.Future;
//import java.util.stream.Collectors;
//
///**
// * @Author cheng
// * @Date 2022/12/16 13:20
// * @Desc MES外部接口
// */
//@Service
//public class MesExternalService1 extends AbstractBaseService implements IMesExternalService, IRemoteService, com.product.data.service.impl.IRemoteService {
//
//	@Value("${data.system.name}")
//	private String dataSystemName;
//
//	private CommonService commonService = null;
//
//	private FieldSetEntity collectLogCache = null;
//
//	public CommonService getCommonService() {
//		if (this.commonService == null) {
//			this.commonService = SpringBeanUtil.getBean(CommonService.class);
//		}
//		return commonService;
//	}
//
//	/**
//	 * 获取历史数据
//	 */
//	public void getHistoryData(FieldSetEntity fse) throws BaseException, ExecutionException, InterruptedException {
//
//		//机号
//		String serialNumber = fse.getString("serial_number");
//		SpringMVCContextHolder.getSystemLogger().info("准备回写机号数据：" + serialNumber);
//		if (StringUtils.isEmpty(serialNumber)) {
//			throw new BaseException(ErrorCode.SERIAL_NUMBER_IS_NULL);
//		}
//
//		FieldSetEntity fs = getBaseDao().getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_DATA_SYNC_MES, "LENGTH(data_source)>1  limit 1", null, false);
//		if (FieldSetEntity.isEmpty(fs)) {
//			throw new BaseException(ErrorCode.MO_NUMBER_SYNC_DATASOURCE_ERROR);
//		}
//		FieldSetEntity reportDbConfig = getBaseDao().getFieldSetByFilter(CmnConst.PRODUCT_SYS_DATA_SYNC_MANAGER, "SYNC_NAME=?", new Object[]{"报表数据库"}, false);
//		if (FieldSetEntity.isEmpty(reportDbConfig)) {
//			throw new BaseException(ErrorCode.REPORT_DB_CONFIG_FAIL);
//		}
//		DataTableEntity dt = getBaseDao().listTable(CmnConst.PRODUCT_SYS_DATA_COLLECT, "upper(source_table) in ('T_WIP_TRACKING','T_WIP_PRODUCT_KEYP','T_WIP_DETAIL','T_PM_PRODUCT_SN') and data_source in (select  uuid from product_sys_data_sync_manager)", new Object[]{}, new Object[]{"uuid,id,data_source,source_table"});
//
//		Map<String, List<FieldSetEntity>> groupByCollectId = dt.getData().stream().collect(Collectors.groupingBy(item -> item.getString("id")));
//		Map<String, List<FieldSetEntity>> groupBySourceTable = dt.getData().stream().collect(Collectors.groupingBy(item -> item.getString("source_table")));
//
//		DataBaseEntity dbe = new DataBaseEntity(reportDbConfig);
//		Dao reportDao = dbe.getDao();
//		String reportDbName = dbe.getDbName();
//		Set<String> trackingTableSet = QuerySqlParseUtil.getAllTableName(reportDao, reportDbName, "da_t_wip_tracking");
//		HistoryEntity trackingData = historyBeforeDispose(getData(reportDao, trackingTableSet, "serial_number",
//				serialNumber, new ErrorCode[]{ErrorCode.TRACKING_TABLE_NOT_EXISTS, ErrorCode.NOT_FOUND_SERIAL_NUMBER}), CmnConst.T_WIP_TRACKING);
//
//		Set<String> keypTableSet = QuerySqlParseUtil.getAllTableName(reportDao, reportDbName, "da_t_wip_product_keyp");
//		HistoryEntity keypData = historyBeforeDispose(getData(reportDao, keypTableSet, "pk_product_sn", serialNumber, new ErrorCode[]{ErrorCode.KEYP_TABLE_NOT_EXISTS, ErrorCode.KEYP_DATA_NOT_FOUND}), CmnConst.T_WIP_PRODUCT_KEYP);
//
//		Set<String> detailTableSet = QuerySqlParseUtil.getAllTableName(reportDao, reportDbName, "da_t_wip_detail");
//		HistoryEntity detailData = historyBeforeDispose(getData(reportDao, detailTableSet, "serial_number", serialNumber, new ErrorCode[]{ErrorCode.DETAIL_TABLE_NOT_EXISTS, ErrorCode.DETAIL_DATA_NOT_FOUND}), CmnConst.T_WIP_DETAIL);
//
////		Set<String> productSnTableSet = QuerySqlParseUtil.getAllTableName(reportDao, reportDbName, "da_t_pm_product_sn");
////		HistoryEntity productSnData = historyBeforeDispose(getData(reportDao, productSnTableSet, "product_sn", serialNumber, new ErrorCode[]{ErrorCode.PRODUCT_SN_TABLE_NOT_EXISTS, ErrorCode.PRODUCT_SN_DATA_NOT_FOUND}), CmnConst.T_PM_PRODUCT_SN);
//
//
//		//主库数据源配置
//		String masterDataSource = fs.getString("data_source");
//		dbe = new DataBaseEntity(masterDataSource);
//		Map<String, Dao> groupDao = new HashMap<>();
//		Dao dao = dbe.getDao();
//		boolean success = false;
//		try {
//			Connection connection = dao.getConnection();
//			connection.setAutoCommit(false);
//			HistoryEntity[] historyEntities = {trackingData, keypData, detailData};
//			insertMasterTableData(dao, historyEntities);
//			insertSubTableData(groupDao, groupByCollectId, groupBySourceTable, historyEntities);
//			connection.commit();
//			batchCommit(groupDao);
//			success = true;
//			SpringMVCContextHolder.getSystemLogger().info("回写机号：" + serialNumber + "成功");
//		} catch (Exception e) {
//			SpringMVCContextHolder.getSystemLogger().error("回写机号：" + serialNumber + "失败");
//			SpringMVCContextHolder.getSystemLogger().error(e);
//			throw new BaseException(ErrorCode.INSERT_DATA_FAIL);
//		} finally {
//			try {
//				if (!success && !dao.getConnection().getAutoCommit()) {
//					dao.getConnection().rollback();
//				}
//				dao.closeConnection();
//				for (Dao value : groupDao.values()) {
//					try (Connection connection = value.getConnection()) {
//						if (!connection.getAutoCommit()) {
//							connection.rollback();
//						}
//					}
//					value.closeConnection();
//
//				}
//			} catch (Exception e) {
//				e.printStackTrace();
//				SpringMVCContextHolder.getSystemLogger().error(e);
//			}
//		}
//	}
//
//	public void batchCommit(Map<String, Dao> groupDao) throws SQLException {
//		for (Dao value : groupDao.values()) {
//			value.getConnection().commit();
//		}
//	}
//
//	/**
//	 * 插入数据到主库
//	 *
//	 * @param dao
//	 * @param historyEntities
//	 */
//	public void insertMasterTableData(Dao dao, HistoryEntity[] historyEntities) {
//		for (HistoryEntity historyEntity : historyEntities) {
//			if (historyEntity == null) {
//				continue;
//			}
//			DataTableEntity masterDataTable = historyEntity.getMasterDataTable();
//			if (DataTableEntity.isEmpty(masterDataTable)) {
//				continue;
//			}
//			Object[] objects = masterDataTable.getData().stream().map(item -> item.getString(historyEntity.getPrimaryField())).toArray();
//			//查询主库数据是否存在
//			DataTableEntity list = dao.getList(historyEntity.getTableName(),
//					BaseUtil.buildQuestionMarkFilter(historyEntity.getPrimaryField(), objects.length, true),
//					new String[]{historyEntity.getPrimaryField()}, objects);
//			List<String> existsPrimaryValues = null;
//			if (!DataTableEntity.isEmpty(list)) {
//				existsPrimaryValues = list.getData().stream().map(item -> item.getString(historyEntity.getPrimaryField())).collect(Collectors.toList());
//			}
//			for (int i = 0; i < masterDataTable.getRows(); i++) {
//				String primaryValue = masterDataTable.getString(i, historyEntity.getPrimaryField());
//				if (existsPrimaryValues != null && existsPrimaryValues.contains(primaryValue)) {
//					//数据存在跳过该数据
//					continue;
//				}
//				FieldSetEntity fieldSetEntity = masterDataTable.getFieldSetEntity(i);
//				fieldSetEntity.getMeta().setTableName(new Object[]{historyEntity.getTableName()});
//				fieldSetEntity.remove("~table_name~");
//				dao.add(fieldSetEntity);
//			}
//		}
//	}
//
//
//	/**
//	 * 插入子库表数据
//	 *
//	 * @param groupDao           子库dao
//	 * @param groupByCollectId   采集配置按采集id分组
//	 * @param groupBySourceTable 采集配置按表名分组
//	 * @param historyEntities    历史数据
//	 */
//	public void insertSubTableData(Map<String, Dao> groupDao, Map<String, List<FieldSetEntity>> groupByCollectId,
//								   Map<String, List<FieldSetEntity>> groupBySourceTable, HistoryEntity[] historyEntities) throws Exception {
//		for (HistoryEntity historyEntity : historyEntities) {
//			if (historyEntity == null) {
//				continue;
//			}
//			Map<String, List<FieldSetEntity>> groupData = historyEntity.getGroupData();
//			if (groupData == null || groupData.isEmpty()) {
//				continue;
//			}
//			for (Map.Entry<String, List<FieldSetEntity>> entry : groupData.entrySet()) {
//				List<Dao> daoList = new ArrayList<>();
//				if ("ch-kt".equals(entry.getKey())) {
//					List<FieldSetEntity> fieldSetEntityList = groupBySourceTable.get(historyEntity.getTableName().toLowerCase());
//					Set<String> dataSourceSet = fieldSetEntityList.stream().map(item -> item.getString("data_source")).collect(Collectors.toSet());
//					for (String sourceUuid : dataSourceSet) {
//						daoList.add(getDao(groupDao, sourceUuid));
//					}
//				} else {
//					daoList.add(getDao(groupDao, groupByCollectId.get(entry.getKey()).get(0).getString("data_source")));
//				}
//				for (Dao dao : daoList) {
//					List<FieldSetEntity> value = entry.getValue();
//					//查询已存在的数据
//					DataTableEntity list = dao.getList(historyEntity.getTableName(),
//							BaseUtil.buildQuestionMarkFilter(historyEntity.getPrimaryField(), value.size(), true),
//							value.stream().map(item -> item.getString(historyEntity.getPrimaryField())).toArray());
//					List<String> existIds = DataTableEntity.isEmpty(list) ? null : list.getData().stream().map(item -> item.getString(historyEntity.getPrimaryField())).collect(Collectors.toList());
//					for (FieldSetEntity fieldSetEntity : value) {
//						String primaryValue = fieldSetEntity.getString(historyEntity.getPrimaryField());
//						if (existIds != null && existIds.contains(NumberUtil.parseNumber(primaryValue).toString())) {
//							continue;
//						}
//						fieldSetEntity.getMeta().setTableName(new Object[]{historyEntity.getTableName()});
//						fieldSetEntity.remove("~table_name~");
//						dao.add(fieldSetEntity);
//					}
//				}
//			}
//		}
//	}
//
//	public Dao getDao(Map<String, Dao> groupDao, String sourceUuid) throws Exception {
//		Dao dao = groupDao.get(sourceUuid);
//		if (null == dao) {
//			DataBaseEntity dbe = new DataBaseEntity(sourceUuid);
//			dao = dbe.getDao();
//			dao.getConnection().setAutoCommit(false);
//			groupDao.put(sourceUuid, dao);
//		}
//		return dao;
//	}
//
//	public HistoryEntity historyBeforeDispose(DataTableEntity dt, String targetTableName) {
//		if (DataTableEntity.isEmpty(dt)) {
//			return null;
//		}
//		HistoryEntity historyEntity = new HistoryEntity();
//		historyEntity.setMoNumberField("mo_number");
//		if (CmnConst.T_WIP_TRACKING.equalsIgnoreCase(targetTableName)) {
//			historyEntity.setPrimaryField("wip_id");
//			historyEntity.setTimeField("update_date");
//		} else if (CmnConst.T_WIP_PRODUCT_KEYP.equalsIgnoreCase(targetTableName)) {
//			historyEntity.setPrimaryField("pk_id");
//			historyEntity.setTimeField("pk_loadtime");
//
//			historyEntity.setMoNumberField("pk_mo");
//		} else if (CmnConst.T_WIP_DETAIL.equalsIgnoreCase(targetTableName)) {
//			historyEntity.setPrimaryField("wip_detail_id");
//			historyEntity.setTimeField("update_date");
//		} else if (CmnConst.T_PM_PRODUCT_SN.equalsIgnoreCase(targetTableName)) {
//			historyEntity.setPrimaryField("row_id");
//			historyEntity.setTimeField("update_date");
//		} else {
//			return null;
//		}
//		historyEntity.setTableName(targetTableName.toUpperCase());
//		Date now = new Date();
//		for (int i = 0; i < dt.getRows(); i++) {
//			Map<Object, Object> values = dt.getFieldSetEntity(i).getValues();
//			//遍历map中的value是否为数字，如果是数字判断小数点后面是否有值，如果没有值则转换为整数
//			for (Map.Entry<Object, Object> entry : values.entrySet()) {
//				if (entry.getValue() instanceof Number) {
//					Number number = (Number) entry.getValue();
//					if (number.doubleValue() == number.intValue()) {
//						entry.setValue(number.intValue());
//					}
//				}
//			}
//		}
//		DataTableEntity subData = dt.clones();
//		DataTableEntity masterData = dt.clones();
//		for (int i = 0; i < subData.getRows(); i++) {
//			FieldSetEntity fs = subData.getFieldSetEntity(i);
//			String preMasterKey = fs.getString("pre_master_key");
//			if ("ch-kt".equals(fs.getString("source_info")) && StringUtils.isEmpty(preMasterKey)) {
//				preMasterKey = fs.getString(historyEntity.getPrimaryField());
//			}
//			fs.setValue(historyEntity.getPrimaryField(), preMasterKey);
//			fs.setValue("pre_master_key", preMasterKey);
//			masterData.setFieldValue(i, historyEntity.getTimeField(), now);
//			fs.setValue(historyEntity.getTimeField(), now);
//			fs.remove("~table_name~");
//			masterData.getFieldSetEntity(i).remove("~table_name~");
//			masterData.setFieldValue(i, "pre_master_key", null);
//		}
//		historyEntity.setArchivedDataTable(dt);
//		historyEntity.setMasterDataTable(masterData);
//		historyEntity.setSubDataTable(subData);
//		return historyEntity;
//	}
//
//	public DataTableEntity getData(Dao dao, Set<String> tableSet, String filterFieldName, String
//			serialNumber, ErrorCode[] errorCodes) throws InterruptedException, ExecutionException {
//		if (CollectionUtil.isEmpty(tableSet)) {
//			throw new BaseException(errorCodes[0]);
//		}
//		String[] tableArray = tableSet.toArray(new String[]{});
//		CompletionService<DataTableEntity> objectCompletionService = ThreadUtil.newCompletionService();
//		//多线程查询单张表，等待所有线程查询完毕
//		for (String tableName : tableArray) {
//			objectCompletionService.submit(() -> dao.getList("select a.*,'" + tableName + "' as '~table_name~'  from " + tableName + "a where " + filterFieldName + " = ?", new Object[]{serialNumber}));
//		}
//		DataTableEntity data = new DataTableEntity();
//		Future<DataTableEntity> take = objectCompletionService.take();
//		for (int i = 0; i < tableArray.length; i++) {
//			DataTableEntity dataTableEntity = take.get();
//			BaseUtil.dataTableMerge(data, dataTableEntity);
//		}
//
//		if (DataTableEntity.isEmpty(data) && !"product_sn".equals(filterFieldName)) {
//			throw new BaseException(errorCodes[1]);
//		}
//		return data;
//	}
//
//
//	/**
//	 * 初始化制令单
//	 *
//	 * @param moNumbers
//	 * @throws BaseException
//	 */
//	public void initMoBase(String[] moNumbers) throws BaseException {
//		FieldSetEntity fs = getBaseDao().getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_DATA_SYNC_MES, "LENGTH(data_source)>1  limit 1", null, false);
//		if (FieldSetEntity.isEmpty(fs)) {
//			throw new BaseException(ErrorCode.MO_NUMBER_SYNC_DATASOURCE_ERROR);
//		}
//
//		String[] targetDataSource = fs.getString("target_data_source").split(",");
//
//		Dao[] targetDao = Arrays.stream(targetDataSource).map(item -> new DataBaseEntity(item).getDao()).toArray(Dao[]::new);
//		StringBuilder errorMsg = new StringBuilder();
//		for (Dao dao : targetDao) {
//			for (String moNumber : moNumbers) {
//				synchronized (moNumber.intern()) {
//					try (Connection connection = dao.getConnection();
//						 CallableStatement callableStatement = connection.prepareCall(
//								 "{CALL SMT_T_PM_MO_BASE(?,?,?,?,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,?,null,null" +
//										 ",null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null,null)}")) {
//						callableStatement.setInt(1, 5);
//						callableStatement.registerOutParameter(2, OracleTypes.SMALLINT);
//						callableStatement.registerOutParameter(3, OracleTypes.VARCHAR);
//						callableStatement.setString(4, moNumber);
//						callableStatement.setString(5, "1");
//						callableStatement.execute();
//						//执行后返回的错误码
//						int errorCode = callableStatement.getInt(2);
//						//执行后返回的错误信息
//						String errorText = callableStatement.getString(3);
//						if (errorCode != 0) {
//							//错误的
//							errorMsg.append("制令单号:").append(moNumber);
//							errorMsg.append("\nerrorCode：").append(errorCode);
//							errorMsg.append("\nerrorText:").append(errorText);
//						}
//					} catch (Exception e) {
//						SpringMVCContextHolder.getSystemLogger().error(e);
//						e.printStackTrace();
//						errorMsg.append("制令单号:").append(moNumber);
//						errorMsg.append("\n执行时未知错误：").append(e.getMessage());
//					}
//				}
//			}
//		}
//		if (errorMsg.length() > 0) {
//			throw new BaseException(ErrorCode.SUB_MO_BASE_INI_FAIL.getValue(), ErrorCode.SUB_MO_BASE_INI_FAIL.getText() + "。\n" + errorMsg);
//		}
//	}
//
//	/**
//	 * @param moNumbers 制令单号,多个逗号分隔
//	 * @param type      操作类型 1 创建制令单 2 更新制令单中的指定字段
//	 * @throws BaseException
//	 */
//	public void updateMoBase(String[] moNumbers, int type) throws BaseException {
//		FieldSetEntity fs = getBaseDao().getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_DATA_SYNC_MES, "LENGTH(data_source)>1  limit 1", null, false);
//		if (FieldSetEntity.isEmpty(fs)) {
//			throw new BaseException(ErrorCode.MO_NUMBER_SYNC_DATASOURCE_ERROR);
//		}
//		String dataSource = fs.getString("data_source");
//		String[] targetDataSource = fs.getString("target_data_source").split(",");
//		StringBuilder errorMessage = new StringBuilder();
//		DataBaseEntity dbe = new DataBaseEntity(dataSource);
//		for (int i = 0; i < moNumbers.length; i++) {
//			String moNumber = moNumbers[i];
//			try {
//				synchronized (moNumber.intern()) {
//					Dao dao = dbe.getDao();
//					FieldSetEntity one = dao.getOne("T_PM_MO_BASE", "MO_NUMBER=?", new Object[]{moNumber});
//					if (FieldSetEntity.isEmpty(one)) {
//						throw new BaseException(ErrorCode.MO_NUMBER_RECORD_SELECT_EMPTY);
//					}
//					one.setTableName("T_PM_MO_BASE");
//					dao.closeConnection();
//					Dao[] targetDao = Arrays.stream(targetDataSource).map(item -> new DataBaseEntity(item).getDao()).toArray(Dao[]::new);
//					StringBuilder errorMsg = new StringBuilder();
//					try {
//						if (1 == type) {
//							createMoBase(errorMsg, one, targetDao);
//						} else if (2 == type) {
//							updateMoBase(errorMsg, one, targetDao);
//						}
//						if (errorMsg.length() > 0) {
//							//有错误
//							throw new BaseException(ErrorCode.SUB_MO_BASE_CREATE_OR_UPDATE_FAIL.getValue(), ErrorCode.SUB_MO_BASE_CREATE_OR_UPDATE_FAIL.getText() + "。\n" + errorMsg);
//						}
//					} finally {
//						for (Dao dao1 : targetDao) {
//							dao1.closeConnection();
//						}
//					}
//				}
//			} catch (Exception e) {
//				e.printStackTrace();
//				SpringMVCContextHolder.getSystemLogger().error(e);
//				errorMessage.append(e.getMessage()).append("\n");
//			}
//
//		}
//		if (errorMessage.length() > 0) {
//			throw new BaseException(ErrorCode.SUB_MO_BASE_CREATE_OR_UPDATE_FAIL.getValue(), ErrorCode.SUB_MO_BASE_CREATE_OR_UPDATE_FAIL.getText() + "。\n" + errorMessage);
//		}
//	}
//
//	/**
//	 * 创建制令单
//	 *
//	 * @param errorMsg
//	 * @param moBase
//	 * @param subDao
//	 */
//	private void createMoBase(StringBuilder errorMsg, FieldSetEntity moBase, Dao[] subDao) {
//		String moNumber = moBase.getString("mo_number");
//		for (int i = 0; i < subDao.length; i++) {
//			Dao dao = subDao[i];
//			try {
//				//检查工单表是否存在
//				FieldSetEntity projectBase = dao.getOne("T_PM_PROJECT_BASE", "PROJECT_ID = ? ", new Object[]{moNumber});
//				if (FieldSetEntity.isEmpty(projectBase)) {
//					throw new BaseException(ErrorCode.SUB_PROJECT_BASE_CAN_NOT_EMPTY);
//				}
//				//检查制令单表是否已存在
//				FieldSetEntity fs = dao.getOne(moBase.getTableName(), "mo_number = ? ", new Object[]{moNumber});
//				if (!FieldSetEntity.isEmpty(fs)) {
//					//进行更新操作
//					updateMoBase(errorMsg, moBase, new Dao[]{dao});
//					continue;
//				}
//				//将 T_PM_MO_BASE.PROJECT_ID 更改为子库中对应 T_PM_PROJECT_BASE.PROJECT_BASE_ID
//				moBase.setValue("project_id", projectBase.getString("project_base_id"));
////                moBase.setValue("row_id", -1);
//				dao.add(moBase);
//			} catch (BaseException e) {
//				errorMsg.append("制令单号：[ " + moNumber + " ]IP:[").append(getIp(dao)).
//						append("]").append(e.getMessageInfo());
//				e.printStackTrace();
//				SpringMVCContextHolder.getSystemLogger().error(e);
//			} catch (Exception e) {
//				errorMsg.append("制令单号：[ " + moNumber + " ]IP:[").append(getIp(dao)).append("]").append("创建制令单失败，未知的错误");
//				e.printStackTrace();
//				SpringMVCContextHolder.getSystemLogger().error(e);
//			}
//		}
//	}
//
//	/**
//	 * 更新制令单
//	 *
//	 * @param errorMsg
//	 * @param moBase
//	 * @param subDao
//	 */
//	private void updateMoBase(StringBuilder errorMsg, FieldSetEntity moBase, Dao[] subDao) {
//		String moNumber = moBase.getString("mo_number");
//		for (int i = 0; i < subDao.length; i++) {
//			Dao dao = subDao[i];
//			try {
//				//检查制令单表是否已存在
//				FieldSetEntity fs = dao.getOne(moBase.getTableName(), "mo_number = ? ", new Object[]{moNumber});
//				if (FieldSetEntity.isEmpty(fs)) {
//					//进行创建操作
//					createMoBase(errorMsg, moBase, new Dao[]{dao});
//					continue;
//				}
//				// 当子库中制令单 input_qty 字段为 0 或者 为 null 时 更新多个字段，否则只更新target_qty 字段
//				String[] updateField = StringUtils.isEmpty(fs.getString("input_qty")) || "0".equals(fs.getString("input_qty")) ?
//						new String[]{"target_qty", "owner", "mo_create_date", "mo_schedule_date", "mo_due_date", "areaid", "technicsid", "close_flag", "default_group", "end_group"}
//						: new String[]{"target_qty"};
//				StringBuilder sql = new StringBuilder();
//				sql.append(" UPDATE T_PM_MO_BASE SET ");
//				Object[] params = new Object[updateField.length + 1];
//				for (int k = 0; k < updateField.length; k++) {
//					if (k > 0) {
//						sql.append(",");
//					}
//					params[k] = moBase.getObject(updateField[k]);
//					sql.append(updateField[k].toUpperCase()).append(" = ? ");
//				}
//				params[updateField.length] = moNumber;
//				sql.append(" WHERE MO_NUMBER = ?  ");
//				dao.executeSql(sql.toString(), params);
//			} catch (BaseException e) {
//				errorMsg.append("制令单号：[ " + moNumber + " ]IP:[").append(getIp(dao)).
//						append("]").append(e.getMessageInfo());
//				e.printStackTrace();
//				SpringMVCContextHolder.getSystemLogger().error(e);
//			} catch (Exception e) {
//				errorMsg.append("制令单号：[ " + moNumber + " ]IP:[").append(getIp(dao)).append("]").append("更新制令单失败，未知的错误");
//				e.printStackTrace();
//				SpringMVCContextHolder.getSystemLogger().error(e);
//			}
//		}
//	}
//
//	private String getIp(Dao dao) {
//		return ((OracleDaoImpl) dao).getDataBaseEntity().getIp();
//	}
//
//	/**
//	 * 采集配置保存
//	 *
//	 * @param request
//	 * @throws BaseException
//	 */
//	@Override
//	@Transactional
//	public void saveCollectConfig(HttpServletRequest request) throws BaseException {
//		//服务名称
//		String serverName = request.getHeader("server-name");
//		if (StringUtils.isEmpty(serverName)) {
//			throw new BaseException(ErrorCode.SERVER_NAME_CAN_NOT_EMPTY);
//		}
//		FieldSetEntity fse = BaseUtil.getFieldSetEntity(request, CmnConst.PRODUCT_SYS_DATA_COLLECT);
//		//采集来源
//		String sourceInfo = fse.getString("id");
//		if (StringUtils.isEmpty(sourceInfo) || StringUtils.contains(sourceInfo, dataSystemName)) {
//			throw new BaseException(ErrorCode.COLLECT_SOURCE_VALUE);
//		}
//		commonSave(fse);
//	}
//
//	/**
//	 * 提取配置保存
//	 *
//	 * @param fse
//	 * @throws BaseException
//	 */
//	@Override
//	@Transactional
//	public void saveExtractConfig(FieldSetEntity fse) throws BaseException {
//		String dataSource = fse.getString(CmnConst.TABLE_SYNC_MANAGER);
//		if (!StringUtils.isEmpty(dataSource)) {
//			FieldSetEntity fs = JsonUtil.pareseJsonToFieldSetEntity(dataSource);
//			if (!FieldSetEntity.isEmpty(fs)) {
//				commonSave(fs);
//			}
//		}
//		commonSave(fse);
//		getCommonService().saveDelRecordConfig(2, fse.getUUID());
//	}
//
//	/**
//	 * 归档配置保存
//	 *
//	 * @param fse
//	 * @throws BaseException
//	 */
//	@Override
//	@Transactional
//	public void saveArchiveConfig(FieldSetEntity fse) throws BaseException {
//		commonSave(fse);
//	}
//
//	/**
//	 * @param fse
//	 * @throws BaseException
//	 */
//	@Override
//	public void saveCollectLog(FieldSetEntity fse) throws BaseException {
//		this.commonSave(fse);
//	}
//
//	/**
//	 * @param fse
//	 * @throws BaseException
//	 */
//	@Override
//	public void saveExtractLog(FieldSetEntity fse) throws BaseException {
//		this.commonSave(fse);
//	}
//
//	/**
//	 * 数据源保存会调用该方法
//	 *
//	 * @param fse
//	 * @throws BaseException
//	 */
//	@Override
//	public void saveSyncConnectionConfig(FieldSetEntity fse) throws BaseException {
//		//子服务保存数据库连接配置后调用该方法，传输数据到主服务
//		//TODO
//	}
//
//	/**
//	 * 定时任务生成日志会调用该方法
//	 *
//	 * @param fse
//	 * @throws BaseException
//	 */
//	@Override
//	public void saveTimeLog(FieldSetEntity fse) throws BaseException {
//		//主服务提取日志保存后调用该方法传输到子服务
//		//TODO
//
//	}
//
//	private void commonSave(FieldSetEntity fse) throws BaseException {
//		String uuid = fse.getUUID();
//		FieldSetEntity fs = getBaseDao().getFieldSetEntity(fse.getTableName(), new String[]{CmnConst.UUID}, uuid, false);
//		Map<String, DataTableEntity> subData = fse.getSubData();
//		if (!CollectionUtil.isEmpty(subData)) {
//			DataTableEntity addDt = new DataTableEntity();
//			DataTableEntity updateDt = new DataTableEntity();
//			for (Map.Entry<String, DataTableEntity> entry : subData.entrySet()) {
//				String tableName = entry.getKey();
//				DataTableEntity value = entry.getValue();
//				if (DataTableEntity.isEmpty(value)) {
//					continue;
//				}
//				Object[] uuids = value.getUuids();
//				DataTableEntity dt = getBaseDao().listTable(tableName, BaseUtil.buildQuestionMarkFilter(CmnConst.UUID, uuids.length, true), uuids, new String[]{CmnConst.UUID});
//				for (int i = 0; i < value.getRows(); i++) {
//					uuid = value.getString(i, CmnConst.UUID);
//					List<FieldSetEntity> fieldSetEntity = dt.getFieldSetEntity(uuid);
//					if (CollectionUtil.isEmpty(fieldSetEntity)) {
//						addDt.addFieldSetEntity(value.getFieldSetEntity(i));
//						value.setFieldValue(i, CoreConst.SYSTEM_DATA_OPERATE_TYPE, "add");
//					} else {
//						addDt.addFieldSetEntity(updateDt.getFieldSetEntity(i));
//						value.setFieldValue(i, CoreConst.SYSTEM_DATA_OPERATE_TYPE, "update");
//					}
//				}
//				if (!DataTableEntity.isEmpty(addDt)) {
//					getBaseDao().add(addDt);
//				}
//				if (!DataTableEntity.isEmpty(updateDt)) {
//					getBaseDao().update(updateDt);
//				}
//			}
//		}
//		if (FieldSetEntity.isEmpty(fs)) {
//			getBaseDao().add(fse, false);
//		} else {
//			getBaseDao().update(fse, false);
//		}
//	}
//
//	/**
//	 * 调用远程主服务器采集保存
//	 *
//	 * @param fse
//	 * @return
//	 * @throws BaseException
//	 */
//	public FieldSetEntity remoteSaveCollectConfig(FieldSetEntity fse) throws BaseException {
//		if ("ch-kt".equals(dataSystemName)) {
//			return fse;
//		}
//		FieldSetEntity fs = getBaseDao().getFieldSetByFilter(CmnConst.PRODUCT_MES_SERVER, "server_type=0", null, false);
//		if (FieldSetEntity.isEmpty(fs)) {
//			throw new BaseException(ErrorCode.REMOTE_SERVER_CONFIG_EMPTY);
//		}
//		//服务域名的端口
//		String ipPort = fs.getString("server_url");
//		String serverName = fs.getString("server_name");
//		String serverUrl = ipPort + CmnConst.SAVE_COLLECT_URL;
//		FieldSetEntity res = doPost(serverUrl, serverName, fse);
//		return res;
//	}
//
//	/**
//	 * 主服务提取保存日志后调用该方法传入到子服务保存
//	 *
//	 * @param fse
//	 * @return
//	 * @throws BaseException
//	 */
//	public void remoteSaveExtractLog(FieldSetEntity fse) throws BaseException {
//		try {
//			if ("ch-kt".equals(dataSystemName)) {
//				//主服务采集日志uuid
//				String preStepUuid = fse.getString(CmnConst.PRE_STEP_UUID);
//				StringBuilder sql = new StringBuilder();
//				sql.append("\nSELECT ");
//				sql.append("\nserver.* ");
//				sql.append("\nFROM ").append(CmnConst.PRODUCT_SYS_DATA_COLLECT).append(" collect ");
//				sql.append("\nJOIN ").append(CmnConst.PRODUCT_SYS_DATA_CENTER_LOG).append(" log ");
//				sql.append("\nON log.config_uuid=collect.uuid and log.type=1 ");
//				sql.append("\nJOIN ").append(CmnConst.PRODUCT_MES_SERVER).append(" server ");
//				sql.append("\nON collect.id like concat(server.server_name,'%') ");
//				sql.append("\nWHERE log.uuid=? and collect.id not like concat(?,'%')  limit 1");
//				FieldSetEntity fs = getBaseDao().getFieldSetBySQL(sql.toString(), new Object[]{preStepUuid, dataSystemName}, false);
//				if (FieldSetEntity.isEmpty(fs)) {
//					return;
//				}
//				String ipPort = fs.getString("server_url");
//				String serverName = fs.getString("server_name");
//				String serverUrl = ipPort + CmnConst.SAVE_EXTRACT_LOG_URL;
//				doPostAsync(serverUrl, serverName, fse);
//			}
//		} catch (Exception e) {
//			//捕获异常为了使采集定时任务正常运行
//			SpringMVCContextHolder.getSystemLogger().error(e);
//			e.printStackTrace();
//		}
//	}
//
//	/**
//	 * 调用远程主服务器保存
//	 *
//	 * @param fse
//	 * @return
//	 * @throws BaseException
//	 */
//	public void remoteSaveExtractConfig(FieldSetEntity fse) throws BaseException {
//		DataTableEntity dt = getRemoteSubServer();
//		if (DataTableEntity.isEmpty(dt)) {
//			return;
//		}
//		FieldSetEntity extractTargetSource = getBaseDao().getFieldSetEntity(CmnConst.TABLE_SYNC_MANAGER, fse.getString("extract_target_source"), false);
//		if (!FieldSetEntity.isEmpty(extractTargetSource)) {
//			extractTargetSource.setValue(CoreConst.SYSTEM_TABLE_NAME_LABEL, CmnConst.TABLE_SYNC_MANAGER);
//			fse.setValue(CmnConst.TABLE_SYNC_MANAGER, BaseUtil.fieldSetEntityToJson(extractTargetSource));
//		}
//		for (int i = 0; i < dt.getRows(); i++) {
//			FieldSetEntity fs = dt.getFieldSetEntity(i);
//			//服务域名的端口
//			String ipPort = fs.getString("server_url");
//			String serverName = fs.getString("server_name");
//			String serverUrl = ipPort + CmnConst.SAVE_EXTRACT_URL;
//			doPost(serverUrl, serverName, fse);
//		}
//	}
//
//	/**
//	 * 调用远程主服务器保存
//	 *
//	 * @param fse
//	 * @return
//	 * @throws BaseException
//	 */
//	public void remoteSaveArchiveConfig(FieldSetEntity fse) throws BaseException {
//		DataTableEntity dt = getRemoteSubServer();
//		if (DataTableEntity.isEmpty(dt)) {
//			return;
//		}
//		for (int i = 0; i < dt.getRows(); i++) {
//			FieldSetEntity fs = dt.getFieldSetEntity(i);
//			//服务域名的端口
//			String ipPort = fs.getString("server_url");
//			String serverName = fs.getString("server_name");
//			String serverUrl = ipPort + CmnConst.SAVE_ARCHIVE_URL;
//			doPost(serverUrl, serverName, fse);
//		}
//	}
//
//	/**
//	 * 调用远程主服务器保存
//	 *
//	 * @param fse
//	 * @return
//	 * @throws BaseException
//	 */
//	public void remoteSaveCollectLog(FieldSetEntity fse) throws BaseException {
//		if ("ch-kt".equals(dataSystemName) || FieldSetEntity.isEmpty(fse)) {
//			return;
//		}
//		FieldSetEntity fs = getBaseDao().getFieldSetByFilter(CmnConst.PRODUCT_MES_SERVER, "server_type=0", null, false);
//		if (FieldSetEntity.isEmpty(fs)) {
//			throw new BaseException(ErrorCode.REMOTE_SERVER_CONFIG_EMPTY);
//		}
//		//服务域名的端口
//		String ipPort = fs.getString("server_url");
//		String serverName = fs.getString("server_name");
//		String serverUrl = ipPort + CmnConst.SAVE_COLLECT_LOG_URL;
//		doPost(serverUrl, serverName, fse);
//	}
//
//
//	/**
//	 * 获取子服务配置
//	 *
//	 * @return
//	 * @throws BaseException
//	 */
//	private DataTableEntity getRemoteSubServer() throws BaseException {
//		return getBaseDao().listTable(CmnConst.PRODUCT_MES_SERVER, "server_type!=0");
//	}
//
//	//    @Async
//	void doPostAsync(String url, String serverName, FieldSetEntity fse) throws BaseException {
//		doPost(url, serverName, fse);
//	}
//
//	public String getDataSystemName() {
//		return dataSystemName;
//	}
//
//	public boolean remoteRehandle(FieldSetEntity fse) {
//		String type = fse.getString(CmnConst.TYPE);//类型
//		String logUuid;
//		if ("2".equals(type)) {
//			logUuid = fse.getString(CmnConst.PRE_STEP_UUID);
//		} else if ("1".equals(type)) {
//			logUuid = fse.getUUID();
//		} else {
//			return false;
//		}
//		FieldSetEntity fs = getBaseDao().getFieldSetByFilter(CmnConst.PRODUCT_SYS_DATA_COLLECT, "uuid =(select config_uuid FROM product_sys_data_center_log where uuid=?)", new Object[]{logUuid}, false);
//		if (!FieldSetEntity.isEmpty(fs)) {
//			//采集id
//			String collectId = fs.getString(CmnConst.ID);
//			if (collectId.indexOf(dataSystemName) == -1) {
//				fs = getBaseDao().getFieldSetByFilter(CmnConst.PRODUCT_MES_SERVER, "server_type=1 and ? like concat(server_name,'%')", new Object[]{collectId}, false);
//				if (!FieldSetEntity.isEmpty(fs)) {
//					//服务域名的端口
//					String ipPort = fs.getString("server_url");
//					String serverName = fs.getString("server_name");
//					String serverUrl = ipPort + CmnConst.REHANDLE_ERROR_URL;
//					doPost(serverUrl, serverName, fse);
//					//标记日志成功
//					JournalManagerService journalManagerService = SpringUtils.getBean(JournalManagerService.class);
//					journalManagerService.writeBackReDealResult(fse, true);
//				}
//				return true;
//			}
//		}
//		return false;
//	}
//
//	/**
//	 * post 请求
//	 *
//	 * @param url
//	 * @param serverName
//	 * @param fse
//	 * @throws BaseException
//	 */
//	private FieldSetEntity doPost(String url, String serverName, FieldSetEntity fse) throws BaseException {
//		fse.setValue(CoreConst.SYSTEM_TABLE_NAME_LABEL, fse.getTableName());
//		JSONObject requestBody = BaseUtil.fieldSetEntityToJson(fse);
//		String requestData = requestBody.toJSONString();
//		//签名
//		String signature = SignUtil.getHmacSHA1(requestData, Global.getSystemConfig("signature.key", ""));
//		try (HttpResponse response = HttpRequest.post(url)
//				.contentType("application/x-www-form-urlencoded")
//				.header(CoreConst.SYSTEM_LANGUAGE_CODE_, "zh-CN") //语言编码
//				.header(CoreConst.SYSTEM_CLIENT_TYPE_, "Web") //客户端类型
//				.header(CoreConst.SYSTEM_CLIENT_VERSION_, "1.0.0") //客户端版本
//				.header("server-name", serverName) //系统名称
//				.header("signature", signature) //签名
//				.body("formData=" + requestData).execute()) {
//			if (response.getStatus() == 200) {
//				//请求成功
//				String res = response.body();
//				if (!StringUtils.isEmpty(res)) {
//					JSONObject resBody = JSON.parseObject(res);
//					if (resBody != null) {
//						String code = resBody.getString(CoreConst.API_RETURN_KEY_CODE);
//						if (!CoreConst.API_RETURN_VALUE_CODE_200.equals(code)) {
//							//服务内部抛出的错误
//							throw new BaseException("调用接口失败，", resBody.getString(CoreConst.API_RETURN_KEY_MSG));
//						}
//						String formData = resBody.getString(CoreConst.API_RETURN_KEY_DATA);
//						if (StringUtils.isEmpty(formData)) {
//							return null;
//						}
//						FieldSetEntity result = JsonUtil.pareseJsonToFieldSetEntity(formData);
//						return result;
//					}
//				}
//			}
//			throw new BaseException(ErrorCode.OPEN_API_REQUEST_FAIL);
//		}
//
//	}
//
//	/**
//	 * 获取采集日志
//	 *
//	 * @return
//	 */
//	public FieldSetEntity getCollectLog() {
//		collectLogCache = null;
//		if (collectLogCache == null) {
//			loadCollectLogCache();
//		}
//
//		return collectLogCache;
//	}
//
//	public void loadCollectLogCache() {
//		StringBuilder sql = new StringBuilder();
//		sql.append("\n with no_extract as ( ");
//		sql.append("\n 	SELECT ");
//		sql.append("\n 		a.*  ");
//		sql.append("\n 	FROM ");
//		sql.append("\n 		product_sys_data_center_log A ");
//		sql.append("\n 		LEFT JOIN product_sys_data_center_log b ON a.uuid = b.pre_step_uuid  ");
//		sql.append("\n 	WHERE ");
//		sql.append("\n 		a.type = 1  ");
//		sql.append("\n 		and a.result=1 and (a.deal_flag is null or a.deal_flag =0) ");
//		sql.append("\n 		AND ( ");
//		sql.append("\n 					b.pre_step_uuid IS NULL  ");
//		sql.append("\n 					OR  ");
//		sql.append("\n 					( ");
//		sql.append("\n 						b.pre_step_uuid=a.uuid  ");
//		sql.append("\n 						AND  ");
//		sql.append("\n 						(b.result=0 and (b.deal_result = 0 or b.deal_flag is null)) ");
//		sql.append("\n 					) ");
//		sql.append("\n 		) ");
//		sql.append("\n ), ");
//		sql.append("\n last_run_log as ( ");
//		sql.append("\n select max(created_utc_datetime) last_time,config_uuid from product_sys_data_center_log where type=1 and result=1 and deal_flag=0 GROUP BY config_uuid ");
//		sql.append("\n ) ");
//		sql.append("\n 	 ");
//		sql.append("\n SELECT ifnull(COUNT(no_extract.uuid),0) unextracted_batch ,ifnull(sum(no_extract.count),0) unextracted_total_count,b.`name`,(select last_time from last_run_log where b.uuid=last_run_log.config_uuid) last_success_time FROM  product_sys_data_collect b  ");
//		sql.append("\n 	left join no_extract on no_extract.config_uuid=b.uuid ");
//		sql.append("\n  GROUP BY b.uuid ");
//		sql.append("\n 	order by b.`name` ");
//
//		FieldSetEntity fse = new FieldSetEntity();
//		fse.setTableName("temp");
//		fse.setValue("load_log_time", DateTime.now().toString());
//		DataTableEntity dataTableEntity = getBaseDao().listTable(sql.toString(), new Object[]{});
//		if (!DataTableEntity.isEmpty(dataTableEntity)) {
//			fse.setValue("list", BaseUtil.dataTableEntityToJson(dataTableEntity, f -> {
//				JSONObject jsonObject = f[0];
//				Date lastSuccessTime = jsonObject.getDate("last_success_time");
//				if (lastSuccessTime != null) {
//					jsonObject.put("last_success_time", DateUtil.format(lastSuccessTime, "yyyy-MM-dd HH:mm:ss"));
//				}
//			}));
//		} else {
//			fse.setValue("list", "[]");
//		}
//		this.collectLogCache = fse;
//	}
//}