package com.product.server.report.quartz;

import java.util.HashMap;
import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.product.common.lang.StringUtils;
import com.product.core.cache.DataPoolCacheImpl;
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.spring.context.SpringMVCContextHolder;
import com.product.core.transfer.Transactional;
import com.product.server.report.service.idel.IViewDataConvertService;

/**
 * 对报表原始数据进行清洗处理
 * 定时任务方式
 * @author Administrator
 *
 */
@Component
public class ViewDataConvertService implements IViewDataConvertService {
	@Autowired
	public  BaseDao baseDao = null;
	
	private Map<String,String> configs=null;
	/**
	 * 处理报表数据，把视图的数据插入到实体表中，在properties中读配置信息，[视图，实体表][]
	 * 视图表字段与实体表字段一致
	 * Map<视图表,实体表>
	 * @return  Map<视图表,实体表>
	 */
	public Map<String,String> reportDataProcessConfig() {
		String config=Global.getSystemConfig("report.data.process.config", null);
		if(StringUtils.isEmpty(config)) {
			return null;
		}
		String regex="\\[(.*?)]";
		Pattern pattern = Pattern.compile(regex);
		Matcher matcher = pattern.matcher(config);
		configs=new HashMap<String,String>();
		while (matcher.find()) {
			String tables=matcher.group(1);
			if(!StringUtils.isEmpty(tables)) {
				String tbs[]=tables.split(",");
				if(tbs.length>1) {
					DataTableEntity table_view=DataPoolCacheImpl.getInstance().getCacheData("所有表信息",new String[] {tbs[0]});
					DataTableEntity table=DataPoolCacheImpl.getInstance().getCacheData("所有表信息",new String[] {tbs[1]});
					if(table!=null && table.getRows()>0 
							&& table_view!=null && table_view.getRows()>0 
							&& table_view.getFieldSetEntity(0).getInteger("table_type").intValue()==2
							&& table.getFieldSetEntity(0).getInteger("table_type").intValue()==1) {
						configs.put(tbs[0], tbs[1]);
					}
				}
			}
		}
		return configs;
	}
	/**
	 * 报表数据处理任务
	 * 把视图的数据插入到实体表中
	 * 事务
	 */
	@Transactional
	public void reportDataProcessTask() {
		if(configs==null) {
			reportDataProcessConfig();
		}
		for(String view:configs.keySet()) {
			DataTableEntity table=DataPoolCacheImpl.getInstance().getCacheData("所有表信息",new String[] {view});
			if( table==null || table.getRows()==0) {
				continue;
			}
			FieldSetEntity t=table.getFieldSetEntity(0);
			DataTableEntity ft=DataPoolCacheImpl.getInstance().getCacheData("表字段信息",new String[] {t.getString("uuid")});
			SpringMVCContextHolder.getSystemLogger().info(view+":::::"+configs.get(view));
			if( ft==null || ft.getRows()==0) {
				continue;
			}
			StringBuilder fields=new StringBuilder();
			StringBuilder de_value=new StringBuilder();//默认必须字段的值
			for(int m=0;m<ft.getRows();m++) {
				if(fields.length()>0) {
					fields.append(",");
					de_value.append(",");
				}
				fields.append(ft.getString(m,"field_name"));
				de_value.append(ft.getString(m,"field_name"));
			} 
			fields.append(",uuid,created_by,created_utc_datetime,org_level_uuid");
			de_value.append(",uuid(),1,now(),'00000000-0000-0000-0000-000000000000'");
			SpringMVCContextHolder.getSystemLogger().info(fields.toString());
			SpringMVCContextHolder.getSystemLogger().info(de_value.toString());
			if(fields.length()>0) {
				//首先删除实体表
				baseDao.executeUpdate("truncate table "+configs.get(view));
				SpringMVCContextHolder.getSystemLogger().info("Insert into "+configs.get(view)+"("+fields.toString()+") select "+de_value.toString()+" from "+view);
				//查出视图信息 插入表中
				baseDao.executeUpdate("Insert into "+configs.get(view)+"("+fields.toString()+") select "+de_value.toString()+" from "+view);
			}
		}
	}
	
	static public void main(String args[]) {
		String a="ae[a,b]see[xde,i3343]adee[agsdidg][dddd";
		String regex="\\[(.*?)]";
		Pattern pattern = Pattern.compile(regex);
		Matcher matcher = pattern.matcher(a);
		while (matcher.find()) {
			System.out.println(matcher.group(1));
		}
	}
}