|
|
@@ -2673,7 +2673,105 @@ public class KittyFallWs extends WebserviceAbstract {
|
|
|
return response;
|
|
|
}
|
|
|
|
|
|
-
|
|
|
+ @WebMethod(operationName = "wsAddedRewardCosts")
|
|
|
+ @SOAPBinding(style = SOAPBinding.Style.DOCUMENT, use = SOAPBinding.Use.LITERAL)
|
|
|
+ public Response wsAddedRewardCosts(
|
|
|
+ @WebParam(name = "WsUser") String wsUser,
|
|
|
+ @WebParam(name = "WsPass") String wsPass,
|
|
|
+ @WebParam(name = "Msisdn") String msisdn,
|
|
|
+ @WebParam(name = "PackageName") String packageName,
|
|
|
+ @WebParam(name = "Expense") String expense,
|
|
|
+ @WebParam(name = "ServiceId") String serviceId) {
|
|
|
+
|
|
|
+ Response response = new Response();
|
|
|
+ response.setErrorCode(SUCCESS);
|
|
|
+
|
|
|
+ try {
|
|
|
+ String ip = getIpClient();
|
|
|
+ UserInfo userInfo = null;
|
|
|
+ br.setLength(0);
|
|
|
+ br.append("wsAddPoint Params:\n").
|
|
|
+ append("WsUser:").append(wsUser).
|
|
|
+ append("\n Msisdn:").append(msisdn).
|
|
|
+ append("\n PackageName:").append(packageName).
|
|
|
+ append("\n Msisdn:").append(msisdn).
|
|
|
+ append("\n ServiceId:").append(serviceId).
|
|
|
+ append("\n expense:").append(expense);
|
|
|
+ logger.info(br);
|
|
|
+
|
|
|
+ Request request = new Request();
|
|
|
+ request.setUser(wsUser);
|
|
|
+// request.setPass(password);
|
|
|
+ if (wsUser == null || wsUser.length() == 0) {
|
|
|
+ logger.info("wsUser is null");
|
|
|
+ response.setErrorCode(PARAM_NOT_ENOUGH);
|
|
|
+ response.setContent("wsUser is null");
|
|
|
+ } else if (wsPass == null || wsPass.length() == 0) {
|
|
|
+ logger.info("wsPass is null");
|
|
|
+ response.setErrorCode(PARAM_NOT_ENOUGH);
|
|
|
+ response.setContent("wsPass is null");
|
|
|
+ } else if (msisdn == null || msisdn.length() == 0) {
|
|
|
+ logger.info("msisdn is null");
|
|
|
+ response.setErrorCode(PARAM_NOT_ENOUGH);
|
|
|
+ response.setContent("msisdn is null");
|
|
|
+ } else if (packageName == null || packageName.length() == 0) {
|
|
|
+ logger.info("packageName is null");
|
|
|
+ response.setErrorCode(PARAM_NOT_ENOUGH);
|
|
|
+ response.setContent("packageName is null");
|
|
|
+ } else if (expense == null || expense.length() == 0) {
|
|
|
+ logger.info("expense is null");
|
|
|
+ response.setErrorCode(PARAM_NOT_ENOUGH);
|
|
|
+ response.setContent("point is null");
|
|
|
+ } else if (serviceId == null || serviceId.length() == 0) {
|
|
|
+ logger.info("serviceId is null");
|
|
|
+ response.setErrorCode(PARAM_NOT_ENOUGH);
|
|
|
+ response.setContent("serviceId is null");
|
|
|
+ }
|
|
|
+
|
|
|
+ if (SUCCESS.equals(response.getErrorCode())) {
|
|
|
+ // kiem tra thong tin dang nhap
|
|
|
+ userInfo = authenticate(wsUser, wsPass, ip);
|
|
|
+ if (userInfo == null || userInfo.getWsUserId() <= 0) {
|
|
|
+ response.setErrorCode(WRONG_PASSWORD);
|
|
|
+ response.setContent("Authenticate fail!");
|
|
|
+ } else {
|
|
|
+ msisdn = formatMsisdn(msisdn);
|
|
|
+ // check account
|
|
|
+ AccountInfo accountInfo = db.iGetAccountByMsisdn(msisdn, serviceId);
|
|
|
+ // create account
|
|
|
+ if (accountInfo.getMsisdn() == null || accountInfo.getMsisdn().isEmpty()) {
|
|
|
+ response.setErrorCode(Common.ErrorCode.ACCOUNT_NOT_EXISTED);
|
|
|
+ response.setContent(MessageResponse.getDefaultMessage(Common.Message.ACCOUNT_NOT_EXISTED, logger));
|
|
|
+ } else {
|
|
|
+
|
|
|
+ int dataConvert = Integer.parseInt(expense);
|
|
|
+
|
|
|
+ ChargeLog chargeLog = new ChargeLog();
|
|
|
+ chargeLog.setFee(-dataConvert);
|
|
|
+ chargeLog.setChargeTime(new Timestamp(System.currentTimeMillis()));
|
|
|
+ chargeLog.setMsisdn(msisdn);
|
|
|
+ chargeLog.setDescription("Exchange expense");
|
|
|
+ chargeLog.setStatus(Common.Constant.UNCHARGE_STATUS);
|
|
|
+ db.iInsertChargeLog(chargeLog);
|
|
|
+
|
|
|
+ response.setErrorCode(Common.ErrorCode.SUCCESS);
|
|
|
+ String message = MessageResponse.get(Common.Message.EXCHANGE_POINT_SUCCESS, logger);
|
|
|
+ message = message.replaceAll("%point%", expense + "");
|
|
|
+ response.setContent(message);
|
|
|
+
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ } catch (Exception e) {
|
|
|
+ logger.error("Error processing", e);
|
|
|
+ response.setErrorCode(EXCEPTION);
|
|
|
+ String message = MessageResponse.get(Common.Message.SYSTEM_FAIL, logger);
|
|
|
+ response.setContent(message);
|
|
|
+ }
|
|
|
+
|
|
|
+ return response;
|
|
|
+ }
|
|
|
|
|
|
|
|
|
|