package com.product.text.message.service;

import java.util.Date;
import java.util.regex.Matcher;

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.FieldMetaEntity;
import com.product.core.entity.FieldSetEntity;
import com.product.core.exception.BaseException;
import com.product.core.spring.context.SpringMVCContextHolder;
import com.product.core.util.SystemParamReplace;
import com.product.text.message.config.CmnConst;
import com.product.text.message.config.SystemCode;
import com.product.text.message.util.HttpSmsSendUtil;
import com.product.module.sys.entity.SystemUser;

@Component
public class SendTextMessageService {

	@Autowired
	BaseDao baseDao;
	
	/**
	 *	 短信发送方式选择
	 * @param fseMailInfo	单个邮件信息
	 * @param attachment	附件
	 * @throws BaseException
	 */
	public String sendMethod(FieldSetEntity fseMessageInfo,String attachment) throws BaseException {
		int trety=fseMessageInfo.getInteger(CmnConst.TREATY);

		//判断短信配置是否完整
		if (StringUtils.isEmpty(trety)) {
			fseMessageInfo.setValue("", Global.getSystemConfig("spring.mail.host",""));
			fseMessageInfo.setValue("", Global.getSystemConfig("spring.mail.port",""));
			fseMessageInfo.setValue("", Global.getSystemConfig("spring.mail.username",""));
			fseMessageInfo.setValue("", Global.getSystemConfig("spring.mail.password",""));
		}else {
			fseMessageInfo.setValue("send_mode", trety);
			//判断第三方配置选择
			if (trety==0) {
				
			}else {
				HttpSmsSendUtil.sendMsg(fseMessageInfo);
			}
		}
		
		//创建人和创建时间
		if (SpringMVCContextHolder.getCurrentUser()!=null) {
			fseMessageInfo.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
		}
		fseMessageInfo.setValue(CmnConst.CREATED_UTC_DATETIME,new Date());
		return baseDao.add(fseMessageInfo);
	}
	
	/**
	 * 	解析短信模板所有数据,根据模板数据动态发送短信
	 * @param templateCode	模板code
	 * @param fseData		表单业务数据
	 * @throws BaseException
	 */
	public String parseMessageTemplate(String templateCode,FieldSetEntity fseData) throws BaseException {

		//获取当前操作人
		SystemUser currentUser=SpringMVCContextHolder.getCurrentUser();
		if(currentUser==null ) {
			Object user=fseData.getObject("current_user");
			if(user!=null) {
				currentUser=(SystemUser )user;
			}
		}
		String org_level_uuid="";	//当前操作人所属公司
		if (currentUser!=null) {
			org_level_uuid=currentUser.getOrg_level_uuid();
		}
		//对应模板信息
		FieldSetEntity fseMessageTemplate=null;
		if (StringUtils.isEmpty(org_level_uuid)) {
			fseMessageTemplate=baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MESSAGE_TEMPLATE, "template_code=?", new Object[] {templateCode}, false);
		}else {
			fseMessageTemplate=baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MESSAGE_TEMPLATE, "org_level_uuid=? and template_code=?", new Object[] {org_level_uuid,templateCode}, false);
			if (fseMessageTemplate==null) {
				fseMessageTemplate=baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_MESSAGE_TEMPLATE, "template_code=?", new Object[] {templateCode}, false);
			}
		}
		
		if (fseMessageTemplate==null) {
			throw new BaseException(SystemCode.SYSTEM_MESSAGE_TEMPLATE_NO_EXIST.getValue(), SystemCode.SYSTEM_MESSAGE_TEMPLATE_NO_EXIST.getText(),this.getClass(),"parseMessageTemplate");
		}
		
		//获取收信人
		String message_address=fseMessageTemplate.getString("template_addressee");
		//模板内容
		String messageContent=fseMessageTemplate.getString(CmnConst.TEMPLATE_CONTENT);
		
		message_address=SystemParamReplace.replaceParamText(message_address, fseData);
		messageContent=SystemParamReplace.paramReplace(messageContent, fseData);
		
		//解析收信人
		DataTableEntity dtMessageInfo = parseStaffInfo(message_address,messageContent,org_level_uuid,currentUser);

		//发送短信
		if (dtMessageInfo!=null && dtMessageInfo.getRows()>0) {
			for (int i = 0; i < dtMessageInfo.getRows(); i++) {
				FieldSetEntity fseMessageInfo=dtMessageInfo.getData().get(i);
				sendMethod(fseMessageInfo,null);
			}
		}

		//返回信息
		return SystemCode.SYSTEM_OPERATION_SUCCESS.getText();
	}
	
	/**
	 * 	解析收信人
	 * @param message_address	收信人数据(user_id,邮箱,电话)
	 * @param message_content	国际化短信内容
	 * @param org_level_uuid	当前人所属公司
	 * @param currentUser		当前操作人
	 * @return
	 * @throws BaseException
	 */
	public DataTableEntity parseStaffInfo(String message_address,String message_content,String org_level_uuid,SystemUser currentUser) throws BaseException {

		//创建收信人列表
		DataTableEntity dtMessageInfo=new DataTableEntity();
		FieldMetaEntity fseMate=new FieldMetaEntity();
		fseMate.setTableName(new Object[]{CmnConst.PRODUCT_SYS_MESSAGE_SEND});

		//解析模板收信人
		String [] new_message_address_array=message_address.split(",");
		if(new_message_address_array.length<1){
			throw new BaseException(SystemCode.REPEATED_MESSAGE_ADDRESS_ERROR.getValue(), SystemCode.REPEATED_MESSAGE_ADDRESS_ERROR.getText(),this.getClass(), "parseStaffInfo");
		}

		FieldSetEntity fseUser=null;		//用户表对象
		FieldSetEntity fseCompanyMessage=null;	//公司短信配置

		//遍历收信人
		for (int i = 0; i < new_message_address_array.length; i++) {

			//创建单个收信人信息
			FieldSetEntity fseMessageInfo=new FieldSetEntity();
			fseMessageInfo.setMeta(fseMate);

			String filter="";	//过滤条件

			//获取单个收信人
			String messageAddress=new_message_address_array[i];
			int addressType=getAddressType(messageAddress);
			
			if (addressType==0) {	//邮箱账户
				filter="user_primary_email=?";
			} else if (addressType==1) {	//手机号码
				filter="tricode=?";
			} else {	//错误收信人
				filter="user_id=?";
			}

			//在员工信息表中获取对应人员信息
			fseUser=baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, filter, new Object[] {messageAddress}, false);

			if (fseUser==null) {	//外部人员
				if (addressType!=1) {	//是否为电话号码
					throw new BaseException("", "", this.getClass(), "");
				}
			}else {	//内部人员
				SystemUser systemUser = DataPoolCacheImpl.getInstance().getSessionUser(String.valueOf(fseUser.getString("user_id")));
				org_level_uuid=systemUser.getOrg_level_uuid();
			}
			//查找公司短信配置信息
			fseCompanyMessage=baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_COMPANY_MESSAGE, "org_level_uuid=?", new Object[] {org_level_uuid}, false);
			if (fseCompanyMessage!=null) {
				fseMessageInfo.setValue(CmnConst.USER_ACCOUNT, fseCompanyMessage.getString(CmnConst.USER_ACCOUNT));
				fseMessageInfo.setValue(CmnConst.SECRETKEY, fseCompanyMessage.getString(CmnConst.SECRETKEY));
				fseMessageInfo.setValue(CmnConst.ECNAME, fseCompanyMessage.getString(CmnConst.ECNAME));
				fseMessageInfo.setValue(CmnConst.SIGN, fseCompanyMessage.getString(CmnConst.SIGN));
				fseMessageInfo.setValue(CmnConst.ADDSERIAL, fseCompanyMessage.getString(CmnConst.ADDSERIAL));
				fseMessageInfo.setValue(CmnConst.URL, fseCompanyMessage.getString(CmnConst.URL));
				fseMessageInfo.setValue(CmnConst.TREATY, fseCompanyMessage.getString(CmnConst.TREATY));
				fseMessageInfo.setValue(CmnConst.SEND_USER, currentUser.getUser_id());
			} else {
				fseMessageInfo.setValue(CmnConst.SEND_USER, CmnConst.SYSADMIN);
			}
			fseCompanyMessage.setValue(CmnConst.TEMPLATE_CONTENT, message_content);
			fseMessageInfo.setValue(CmnConst.RECEIVE_USER,fseUser.getString(CmnConst.USER_PHONE_NUMBER));
			dtMessageInfo.addFieldSetEntity(fseMessageInfo);
		}
		return dtMessageInfo;
	}
	
	/**
	 * 	获取收信人
	 * @param messageAddress
	 * @return
	 */
	public int getAddressType(String messageAddress) {
		Matcher m = CmnConst.CHINA_EMAIL.matcher(messageAddress);
		if (m.matches()) {
			return 0;
		}
		m = CmnConst.CHINA_PHONE.matcher(messageAddress);
		if (m.matches()) {
			return 1;
		}
		return 2;
	}
}