/**
* 2012-8-3 上午10:25:29
* @author zhangjun
*/
package org.fdzz.service;
import java.lang.reflect.Proxy;
import java.sql.Connection;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Properties;
import java.util.Set;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.fdzz.db.DBManager;
import org.fdzz.proxy.ServiceProxy;
import org.fdzz.server.BusinessClient;
import org.fdzz.service.impl.BalanceServiceImpl;
import org.fdzz.service.impl.ChargeServiceImpl;
import org.fdzz.service.impl.LoginServiceImpl;
import org.fdzz.service.impl.MessageServiceImpl;
import org.fdzz.service.impl.SPServiceImpl;
import org.fdzz.service.impl.WeatherServiceImpl;
import org.fdzz.util.PropertyUtil;
import org.fdzz.util.ProtocolAnalysis;
/**
* @author zhangjun
* 2012-8-3 上午10:25:29
* 业务转发功能模块，主要获得各种业务功能接口
*/
public class ServiceManager {
private static ServiceManager serviceManager = null;
private Map<String, BaseService> services = new HashMap<String, BaseService>();//存放各种业务接口
private ProtocolAnalysis protocolAnalysis = ProtocolAnalysis.getInstance();//协议工具类
private DBManager dbManager = DBManager.getInstance();//数据库管理类
private String path = "src/proxy.properties";//代理方法事务配置文件
private PropertyUtil propertyUtil = PropertyUtil.getInstance();//读取配置文件工具类
private Set<String> methodNames = new HashSet<String>();
private Log logger = LogFactory.getLog(ServiceManager.class);
//这里的常量主要是获取代理方法的配置
public static String LOGIN_SERVICE = "LoginService";//登陆业务
public static String MESSAGE_SERVICE = "MessageService";//短信业务
public static String SP_SERVICE = "SPService";//SP服务业务
public static String CHARGE_SERVICE = "ChargeService";//话费业务
public static String WEATHER_SERVICE = "WeatherService";//天气业务
public static String Balance_SERVICE = "BalanceService";//话费查询
private ServiceManager() {
}
/**
* 打开一个连接
* @return
*/
public Connection openConnection() {
return dbManager.getConnection();
}
/**
* 获取业务接口
* @param serviceName
* @return
*/
public BaseService getService(String serviceName) {
Connection connection = dbManager.getConnection();
BaseService service = services.get(serviceName);
service.setConnection(connection);
return service;
}
/**
* 获取业务功能模块接口
* @return
*/
public static ServiceManager getInstance() {
if (serviceManager == null) {
serviceManager = new ServiceManager();
serviceManager.initialServices();
}
return serviceManager;
}
/**
* 初始化业务管理类，主要是实例化各业务类的代理对象和读取需要添加事务的方法名
*/
@SuppressWarnings("unchecked")
public void initialServices() {
Properties prop = propertyUtil.getProperty(path);
String loginMethod = prop.getProperty(LOGIN_SERVICE);
if (loginMethod != null) {
String[] methods = loginMethod.split(",");
for (int i = 0; i < methods.length; i++) {
methodNames.add(methods[i].trim());
}
}
String spMethod = prop.getProperty(SP_SERVICE);
if (spMethod != null) {
String[] methods = spMethod.split(",");
for (int i = 0; i < methods.length; i++) {
methodNames.add(methods[i].trim());
}
}
String messageMethod = prop.getProperty(MESSAGE_SERVICE);
if (messageMethod != null) {
String[] methods = messageMethod.split(",");
for (int i = 0; i < methods.length; i++) {
methodNames.add(methods[i].trim());
}
}
String weatherMethod = prop.getProperty(WEATHER_SERVICE);
if (weatherMethod != null) {
String[] methods = weatherMethod.split(",");
for (int i = 0; i < methods.length; i++) {
methodNames.add(methods[i].trim());
}
}
String balanceMethod = prop.getProperty(Balance_SERVICE);
if (balanceMethod != null) {
String[] methods = balanceMethod.split(",");
for (int i = 0; i < methods.length; i++) {
methodNames.add(methods[i].trim());
}
}
String chargeMethod = prop.getProperty(CHARGE_SERVICE);
if (chargeMethod != null) {
String[] methods = chargeMethod.split(",");
for (int i = 0; i < methods.length; i++) {
methodNames.add(methods[i].trim());
}
}
LoginServiceImpl ls = new LoginServiceImpl();
Class clazz = ls.getClass();
BaseService loginProxy = (BaseService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new ServiceProxy(ls));
serviceManager.services.put(LOGIN_SERVICE, loginProxy);
SPServiceImpl si = new SPServiceImpl();
clazz = si.getClass();
BaseService spProxy = (BaseService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new ServiceProxy(si));
serviceManager.services.put(SP_SERVICE, spProxy);
MessageServiceImpl ms = new MessageServiceImpl();
clazz = ms.getClass();
BaseService messageProxy = (BaseService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new ServiceProxy(ms));
serviceManager.services.put(MESSAGE_SERVICE, messageProxy);
WeatherServiceImpl ws = new WeatherServiceImpl();
clazz = ws.getClass();
BaseService weatherProxy = (BaseService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new ServiceProxy(ws));
serviceManager.services.put(ProtocolAnalysis.MAP_DESTINATE_WEATHER, weatherProxy);
BalanceServiceImpl bs = new BalanceServiceImpl();
clazz = bs.getClass();
BaseService balanceProxy = (BaseService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new ServiceProxy(bs));
serviceManager.services.put(ProtocolAnalysis.MAP_DESTINATE_LEFTMONEY, balanceProxy);
ChargeServiceImpl cs = new ChargeServiceImpl();
clazz = cs.getClass();
BaseService chargeProxy = (BaseService) Proxy.newProxyInstance(clazz.getClassLoader(), clazz.getInterfaces(), new ServiceProxy(cs));
serviceManager.services.put(ProtocolAnalysis.MAP_DESTINATE_CHARGE, chargeProxy);
}
/**
* 获取代理方法名称
* @return
*/
public Set<String> getMethodNames() {
return methodNames;
}
/**
* 实现业务转发
* @param request
* @
*/
public void doBusiness(BusinessClient bizClient, Map<String, String> request) {
if (logger.isInfoEnabled()) {
logger.info("用户" + bizClient.getUsername() + "进行业务选择....");
}
String cmd = request.get(ProtocolAnalysis.MAP_PDU);
Map<String, String> response = null;
if (cmd.equals(ProtocolAnalysis.CMD_LOGOUT)) {//登出请求
if (logger.isInfoEnabled()) {
logger.info("用户" + bizClient.getUsername() + "启动登出业务....");
}
LoginService loginService = (LoginService) serviceManager.getService(ServiceManager.LOGIN_SERVICE);
String username = request.get(ProtocolAnalysis.MAP_USERNAME);
response = loginService.logout(username);
String message = protocolAnalysis.makeResponseMessage(response);
bizClient.sendMessage(message);
bizClient.clients.remove(username);
bizClient.beConnected = false;
} else if (cmd.equals(ProtocolAnalysis.CMD_LOGIN)) {//登入请求
if (logger.isInfoEnabled()) {
logger.info("用户" + bizClient.getUsername() + "启动登陆业务....已在登陆状态，重复登入，出错啦！");
}
//已在登陆状态，重复登入，出错啦
response = new HashMap<String, String>();
response.put(ProtocolAnalysis.MAP_STATUS, ProtocolAnalysis.STATUS_REPEATLOGIN);
String message = protocolAnalysis.makeResponseMessage(response);
bizClient.sendMessage(message);
} else if (cmd.equals(ProtocolAnalysis.CMD_MESSAGE)) {//短信请求
if (logger.isInfoEnabled()) {
logger.info("用户" + bizClient.getUsername() + "启动短信请求业务....");
logger.info("把这条短信记录下来....");
}
String destinate = request.get(ProtocolAnalysis.MAP_DESTINATE).trim();
//首先记录这条短信
MessageService messageService = (Message
MCP.rar_增值 （225个子文件） 
ServiceManager.class 11KB MessageServiceImpl.class 10KB ProtocolAnalysis.class 8KB PhoneInterface2.class 7KB WeatherServiceImpl.class 7KB ChargeServiceImpl.class 6KB ChinaMobile.class 6KB PhoneInterface.class 6KB CellPhone.class 6KB BalanceServiceImpl.class 5KB BusinessClient.class 5KB MtpmsgDAOImpl.class 5KB JdbcTemplate.class 5KB LoginInterface.class 4KB MtpuserDAOImpl.class 4KB LoginServiceImpl.class 4KB MtptransDAOImpl.class 4KB MtpspcardDAOImpl.class 3KB ReceiveClient.class 3KB MtpmsgDAOTest.class 3KB BaseServiceImpl.class 3KB MtpmsghisDAOImpl.class 3KB MtpspDAOImpl.class 3KB StatusMessageUtil.class 3KB DBManager.class 3KB MtpspqsinfoDAOImpl.class 3KB Mtpspcard.class 2KB MtpuserDAOTest.class 2KB Mtpmsghis.class 2KB Mtpuser.class 2KB ServiceProxy.class 2KB Mtpmsg.class 2KB MtpoperatorDAOImpl.class 2KB DAOFactory.class 2KB MappingFactory.class 2KB SptxtinfoDAOImpl.class 2KB MtpmsghisDAOTest.class 2KB Mtptrans.class 2KB MtpspcardDAOTest.class 2KB MtptransDAOTest.class 2KB PropertyUtil.class 2KB Mtpsp.class 2KB MtpspDAOTest.class 2KB MtpoperatorDAOTest.class 2KB MtpspqsinfoDAOTest.class 2KB SptxtinfoDAOTest.class 2KB LoginInterface$3.class 2KB LoginServiceTest.class 1KB BalanceServiceTest.class 1KB SPServiceImpl.class 1KB MtpspcardMapping.class 1KB MtpuserMapping.class 1KB MtpmsghisMapping.class 1KB MtpmsgMapping.class 1KB MtptransMapping.class 1KB ProtocolAnalysisTest.class 1KB Test.class 1KB MtpspMapping.class 1KB MessageServiceTest.class 1KB WeatherServiceTest.class 1KB Mtpoperator.class 1KB TestDate.class 1KB MessageService.class 1KB BaseDAOImpl.class 999B MtpoperatorMapping.class 977B MtpspqsinfoMapping.class 969B Mtpspqsinfo.class 941B PhoneInterface2$1.class 922B LoginInterface$1.class 881B LoginInterface$2.class 861B SptxtinfoMapping.class 852B StatusMessageUtilTest.class 825B PhoneInterface$1.class 812B Sptxtinfo.class 724B TestStringSub.class 702B MtpmsgDAO.class 616B BaseDAOTest.class 559B WeatherService.class 516B LoginService.class 488B BaseService.class 445B MtpuserDAO.class 438B SPService.class 430B ChargeService.class 426B BalanceService.class 344B MtptransDAO.class 310B MtpspqsinfoDAO.class 275B MtpspcardDAO.class 272B MtpspDAO.class 249B EntityMapping.class 235B SptxtinfoDAO.class 221B MtpoperatorDAO.class 221B MtpmsghisDAO.class 215B BaseDAO.class 174B .classpath 446B
ok.gif 2KB ok.gif 2KB 5.gif 2KB 5.gif 2KB 7.gif 2KB 7.gif 2KB共 225 条
- 1
- 2
- 3
资源评论
