const mysql = require("../utils/mysql_db");
const dbhandle = require("../utils/handle_db");
const stringutil = require("../utils/stringUtil");
const httputil = require("../utils/httpcall");
const uuid = require("node-uuid");
const { forEach } = require("async");
const { array } = require("../utils/upload");
const { JSONParser } = require("formidable");
const covers = require("../kriging/caculate_cover");
const json = require("koa-json");
const { JsonWebTokenError } = require("jsonwebtoken");


module.exports = {
	async getNoTokenData(params) {
		let sql = `select * from t_sys_business_config where id_='${params.bid}'`;
		let obj_ = await mysql.query(sql);
		if(!obj_[0]) { return '';}
		let sqls = dbhandle.create_sql(obj_[0]);
		let result = stringutil.replaceParams(sqls,params);	
		let result_obj ;	
		if(result.status == 1) {
			result_obj = await mysql.query_data(result.sql, obj_[0].musterdb);
		}
		if(obj_[0].parent_id) {
			result_obj = this.getParentData(params,obj_[0].parent_id);
		}
		//result['result'] = result_obj;
		let resultMap = {};
		var rs_ass_map = {};
		if(obj_[0].table_name == 'rs_associate') {
			let rs_associate_str = JSON.stringify(result_obj[0]);
			var rs_ass_array = JSON.parse(rs_associate_str);
			for (let index = 0; index < rs_ass_array.length; index++) {
				let rsname_ = rs_ass_array[index].rsname;
				rs_ass_map[rsname_] = rs_ass_array[index];
				let rs_index = rs_ass_map[rsname_].rsindex;
				let rs_associate_str = JSON.stringify(result_obj[rs_index]);
				resultMap[rsname_] = JSON.parse(rs_associate_str);
			}
			result['result'] = parseResults(rs_ass_map,resultMap);
		} else {
			result['result'] = result_obj;
		}
		delete result.sql_count;
		delete result.sql;
		return result;
	},
	async bdata(params) {
		let sql = `select * from t_sys_business_config where id_='${params.bid}'`;
		let obj_ = await mysql.query(sql);
		if(!obj_[0]) { return '';}
		let sqls = [];
		if(!params.pagesize) {
			sqls = dbhandle.create_sql(obj_[0]);
		} else {
			sqls = dbhandle.create_sql(obj_[0],params.pagesize,params.pageno);
		}		
		let result = stringutil.replaceParams(sqls,params);
		let retObj_ = [];
		let retObj_counter_ = [];
		if(result.status == 1) {
			retObj_ = await mysql.query_data(result.sql, obj_[0].musterdb);
			retObj_counter_ = await mysql.query_data(result.sql_count, obj_[0].musterdb);
		}
		if(obj_[0].parent_id) {
			retObj_ = this.getParentData(params,obj_[0].parent_id);
		}
		result['result'] = retObj_;
		result['counter'] = retObj_counter_[0];
		delete result.sql_count;
		delete result.sql;
		return result;
	},
	async getParentData(params,parent_id) {
		let sql = `select * from t_sys_business_config where id_='${parent_id}'`;
		let obj_ = await mysql.query(sql);
		if(!obj_[0]) { return '';}
		let sqls = dbhandle.create_sql(obj_[0]);
		let result = stringutil.replaceParams(sqls,params);			
		let result_obj ;	
		if(result.status == 1) {
			result_obj = await mysql.query_data(result.sql, obj_[0].musterdb);
		}
		if(obj_[0].parent_id) {
			result_obj = await this.getParentData(params,obj_[0].parent_id);
		}
		result['result'] = result_obj;		
		delete result.sql_count;
		delete result.sql;
		return result;
	},
	async syncData(params) {
		let sql = `select * from t_sys_syscdata_config where id_='${params.bid}'`;
		let obj_ = await mysql.query(sql);
		if(!obj_[0]) { return '';}
		let sqls = dbhandle.create_sync_sql(obj_[0]);
		let result = stringutil.replaceSyncParams(sqls[0],params);		
		if(result.status == 1) {
			result['result'] = await mysql.query_data(result.sql, obj_[0].musterdb);
		}
		var res = JSON.stringify(result['data']);
		res =  JSON.parse(res);
		for (let rowindex in  res) {
			let row_ = res[rowindex];
			let result_ = stringutil.replaceSyncParams(sqls[1],row_);
			if(result_.status == 1) {
				result['updateres'] = await mysql.query_data(result_.sql, obj_[0].clusterdb);
			}
		}
		return result;
	},
	async recordMonitorOpt(params) {
		let sql = `select * from t_sys_business_config where id_='${params.bid}'`;
		let obj_ = await mysql.query(sql);
		if(!obj_[0]) { return '';}
		let sqls = dbhandle.create_sql(obj_[0]);
		let result = stringutil.replaceParams(sqls,params);	
		let result_obj ;	
		if(result.status == 1) {
			result_obj = await mysql.query_data(result.sql, obj_[0].musterdb);
		}
		if(obj_[0].parent_id) {
			result_obj = await this.getParentData(params,obj_[0].parent_id);
		}
		result['result'] = result_obj;
		// let send_params = JSON.stringify(result['data'].data[0][0]);
		let send_params = result['data'].data[0][0];
		dealRecordTrans(params,send_params,60000);
		delete result.sql_count;
		delete result.sql;
		return result;
	},
	async calculateCoverRate(params) {
		//'getAssessValue',"&frequencystr=",getQueryString("frequencystr"),"&wdate=",getQueryString("wdate"),"&whour=",getQueryString("whour")		
		params = {"bid":"getCoverFreqsByHour","frequencystr":"1557","wdate":"2021-08-17","whour":"21"};
		let result = await this.dealData(params);
		for (let index = 0; index < result.freqs.length; index++) {
			let element = result.freqs[index];
			console.log(element);
			let lngs = [121.456344, 121.983627, 122.657344, 120.635689, 121.446533, 121.336544, 121.346534, 121.4268344, 121.983344, 121.763344]
			let lats = [31.456344, 31.983627, 31.657344, 31.635689, 31.446533, 31.336544, 31.346534, 31.4268344, 31.983344, 31.763344]
			let values = [1, 3, 5, 5, 3, 5, 3, 2, 2, 1]		
			for (let i = 0; i < element.assess.length; i++) {
				lngs[i] = element.assess[i].regionLong;
				lats[i] = element.assess[i].regionLat;
				values[i] = element.assess[i].paramvalue;
			}
			let ret = covers.caculaterCoverRate(values, lngs, lats);
			for( key in ret) {
				let parameters = {bid:"insertCoverRate","areacode":key,"numerator":ret[key].numerator,"denominator":ret[key].denominator,"freq":element.frequency}
				let r = await this.dealData(parameters);
			}
			
		}
		// let url_ = 'http://localhost/k3/caculater.html?frequencystr=1557&wdate=2021-08-16&whour=21';
		// await httputil.getHttpRequest_(url_);

		return result;
	},
	async recordCoverRate(params) {
		console.log(params);
		
		return ;
	},
	async dealData(params) {
		let sql = `select * from t_sys_business_config where id_='${params.bid}'`;
		let obj_ = await mysql.query(sql);
		if(!obj_[0]) { return '';}
		let sqls = dbhandle.create_sql(obj_[0]);
		let result = stringutil.replaceParams(sqls,params);	
		let result_obj ;	
		if(result.status == 1) {
			result_obj = await mysql.query_data(result.sql, obj_[0].musterdb);
		}
		//result['result'] = result_obj;
		let resultMap = {};
		var rs_ass_map = {};
		if(obj_[0].table_name == 'rs_associate') {
			let rs_associate_str = JSON.stringify(result_obj[0]);
			var rs_ass_array = JSON.parse(rs_associate_str);
			for (let index = 0; index < rs_ass_array.length; index++) {
				let rsname_ = rs_ass_array[index].rsname;
				rs_ass_map[rsname_] = rs_ass_array[index];
				let rs_index = rs_ass_map[rsname_].rsindex;
				let rs_associate_str = JSON.stringify(result_obj[rs_index]);
				resultMap[rsname_] = JSON.parse(rs_associate_str);
			}
			result['result'] = parseResults(rs_ass_map,resultMap);
		} else {
			result['result'] = result_obj;
		}
		return result['data']
	},
	async autoRecording(params) {
		let sql = `select * from t_sys_business_config where id_='${params.bid}'`;
		let obj_ = await mysql.query(sql);
		if(!obj_[0]) { return '';}
		let sqls = dbhandle.create_sql(obj_[0]);
		let result = stringutil.replaceParams(sqls,params);	
		let result_obj ;
		let recordTemp_id =0;
		if(result.status == 1) {
			let rs_ids = await mysql.query_data(result.sql, obj_[0].musterdb);
			recordTemp_id = rs_ids[0][0].id;
		}
		if(obj_[0].parent_id) {
			result_obj = await this.getParentData(params,obj_[0].parent_id);
		}
		let send_params = result_obj.data[0][0];
		dealRecordTrans(params,send_params,60000);

		return result;
	},	

};

function parseResults(rs_ass_map,resultMap) {
	var ret_map = {};
	for (const key in resultMap) {
		var sub_rs_map = getSubRs(key,rs_ass_map);
		if(sub_rs_map != null && rs_ass_map[key].parent == null) {
			ret_map[key] = new Array();
			let key_ = sub_rs_map != null ? sub_rs_map.rsname : null;
			resultMap[key].forEach(function (p_row, p_index, p_array) {
				p_row[key_] = setSubMaps(p_row,key_,rs_ass_map,resultMap);
				ret_map[key].push(p_row);
				// resultMap[key].splice(p_index,1);
			});
		} else {
			// ret_map[key] = resultMap[key];
			console.log('------------');
		}
	}
	return ret_map;
}

function setSubMaps(p_row,sub_key,rs_ass_map,resultMap) {
	let sub_arr = new Array();
	let parentfield_ = rs_ass_map[sub_key].parentfield;
	let subfield_ = rs_ass_map[sub_key].subfield;
	var sub_rs_map = getSubRs(sub_key,rs_ass_map);
	resultMap[sub_key].forEach(function (sub_row, sub_index, sub_array) {
		if (sub_row[subfield_] == p_row[parentfield_]) {
			if(sub_rs_map != null) {
				let key_ = sub_rs_map != null ? sub_rs_map.rsname : null;
				sub_row[key_] = setSubMaps(sub_row,key_,rs_ass_map,resultMap);
			}
			sub_arr.push(sub_row);
			// sub_array.splice(sub_index,1);
		}
	});	
	return sub_arr;
}

function getSubRs(rsname,rs_ass_map) {
	for (var key_ in rs_ass_map) {
		if(rs_ass_map[key_].parent == rsname && key_ != rsname) {
			return rs_ass_map[key_];
		}
	}
	return null;
}

async function dealRecordTrans(params, send_params, millonSeconds) {
	let responseBody = "";
	if (send_params.frequencyValue) {//停止当前录音A
		let url_ = 'http://wiibox.xicp.io:19868/FRP/TNewrecordtask.do?method=delete&key=123456&frequencyValue='
			+ send_params.frequencyValue + '&monitorpointId=' + send_params.monitorpointId;
		//&frequencyValue=1233&monitorpointId=22	
		responseBody = await httputil.getHttpRequest_(url_);
		await httputil.wait(2000);
		//下发新的录音指令B
		url_ = 'http://wiibox.xicp.io:19868/FRP/TNewrecordtask.do?method=record&key=123456&frequencyValue='
			+ params.frequency + '&monitorpointId=' + send_params.monitorpointId
			+ '&recordTimeLength=1';
		responseBody = await httputil.getHttpRequest_(url_);
		await httputil.wait(millonSeconds);
		await httputil.wait(2000);
		//恢复录音A
		if (send_params.frequencyValue && send_params.minutes && send_params.minutes > 0) {
			url_ = 'http://wiibox.xicp.io:19868/FRP/TNewrecordtask.do?method=record&key=123456&frequencyValue='
				+ send_params.frequencyValue + '&monitorpointId=' + send_params.monitorpointId
				+ '&recordTimeLength=' + send_params.minutes;
			responseBody = await httputil.getHttpRequest_(url_);
		}
	} else {
		//下发新的录音指令B
		let url_ = 'http://wiibox.xicp.io:19868/FRP/TNewrecordtask.do?method=record&key=123456&frequencyValue='
			+ params.frequency + '&monitorpointId=' + send_params.monitorpointId
			+ '&recordTimeLength=1';
		responseBody = await httputil.getHttpRequest_(url_).then((result)=> {
			console.log(result);
		}).then((response) => {
			httputil.wait(millonSeconds);
		});
		
	}

}