|
|
@@ -1474,7 +1474,7 @@ public class KittyFallWs extends WebserviceAbstract {
|
|
|
String REQ = reqDf.format(new Date()) + productInfo.getProductId() + msisdn.substring(Common.COUNTRY_CODE.length());
|
|
|
logger.info("after get product info " + fee);
|
|
|
// right -----------------------------------------------
|
|
|
- resultPaid = ws.requestMpsOtp(msisdn, fee, REQ, productInfo.getProductName());
|
|
|
+// resultPaid = ws.requestMpsOtp(msisdn, fee, REQ, productInfo.getProductName());
|
|
|
|
|
|
String errorCode = resultPaid.split("\\|")[0];
|
|
|
if (WSProcessor.LIST_SUCCESS_RES.contains(resultPaid)) {
|
|
|
@@ -1837,9 +1837,8 @@ public class KittyFallWs extends WebserviceAbstract {
|
|
|
@WebParam(name = "WsUser") String wsUser,
|
|
|
@WebParam(name = "WsPass") String wsPass,
|
|
|
@WebParam(name = "Msisdn") String msisdn,
|
|
|
- @WebParam(name = "PackageName") String packageName,
|
|
|
- @WebParam(name = "Fee") String fee,
|
|
|
- @WebParam(name = "ServiceId") String serviceId) {
|
|
|
+ @WebParam(name = "PackageName") String packageName )
|
|
|
+ {
|
|
|
|
|
|
Response response = new Response();
|
|
|
response.setErrorCode(SUCCESS);
|
|
|
@@ -1851,9 +1850,7 @@ public class KittyFallWs extends WebserviceAbstract {
|
|
|
br.append("wsChargeFeeOtp Params:\n").
|
|
|
append("WsUser:").append(wsUser).
|
|
|
append("\n Msisdn:").append(msisdn).
|
|
|
- append("\n serviceId:").append(serviceId).
|
|
|
- append("\n packageName:").append(packageName).
|
|
|
- append("\n Fee:").append(fee);
|
|
|
+ append("\n packageName:").append(packageName);
|
|
|
logger.info(br);
|
|
|
|
|
|
Request request = new Request();
|
|
|
@@ -1871,19 +1868,11 @@ public class KittyFallWs extends WebserviceAbstract {
|
|
|
logger.info("msisdn is null");
|
|
|
response.setErrorCode(PARAM_NOT_ENOUGH);
|
|
|
response.setContent("msisdn is null");
|
|
|
- } else if (serviceId == null || serviceId.length() == 0) {
|
|
|
- logger.info("serviceId is null");
|
|
|
- response.setErrorCode(PARAM_NOT_ENOUGH);
|
|
|
- response.setContent("serviceId is null");
|
|
|
- } else if (packageName == null || packageName.length() == 0) {
|
|
|
+ } else if (packageName == null || packageName.length() == 0) {
|
|
|
logger.info("packageName is null");
|
|
|
response.setErrorCode(PARAM_NOT_ENOUGH);
|
|
|
response.setContent("packageName is null");
|
|
|
- } else if (fee == null || fee.length() == 0) {
|
|
|
- logger.info("fee is null");
|
|
|
- response.setErrorCode(PARAM_NOT_ENOUGH);
|
|
|
- response.setContent("fee is null");
|
|
|
- }
|
|
|
+ }
|
|
|
//------- ----------Dành cho thị trường có OTP -------------------------
|
|
|
/*
|
|
|
if (SUCCESS.equals(response.getErrorCode())) {
|
|
|
@@ -1998,6 +1987,7 @@ public class KittyFallWs extends WebserviceAbstract {
|
|
|
} else {
|
|
|
msisdn = formatMsisdn(msisdn);
|
|
|
int moneyCharge = Common.ADD_SPIN_FEE;
|
|
|
+ String fee = "0";
|
|
|
if (fee != null && fee.length() > 0) {
|
|
|
moneyCharge = Integer.parseInt(fee);
|
|
|
}
|
|
|
@@ -2015,8 +2005,8 @@ public class KittyFallWs extends WebserviceAbstract {
|
|
|
String REQ = reqDf.format(new Date()) + "1" + msisdn.substring(Common.COUNTRY_CODE.length());
|
|
|
|
|
|
// charge
|
|
|
- String resultPaid = ws.chargeFeeOtp(msisdn, moneyCharge, REQ);
|
|
|
-// String resultPaid = "0";
|
|
|
+// String resultPaid = ws.chargeFeeOtp(msisdn, moneyCharge, REQ);
|
|
|
+ String resultPaid = "0";
|
|
|
boolean registered = false;
|
|
|
List<RegisterInfo> listRegInday = null;
|
|
|
listRegInday = db.getRegisterInday(msisdn, productInfo.getProductName());
|
|
|
@@ -2050,27 +2040,27 @@ public class KittyFallWs extends WebserviceAbstract {
|
|
|
chargeLog.setFee(moneyCharge);
|
|
|
chargeLog.setChargeTime(new Timestamp(System.currentTimeMillis()));
|
|
|
chargeLog.setMsisdn(msisdn);
|
|
|
- String mTOOL_RUN = MessageResponse.get(Common.Message.TOOL_RUN,logger);
|
|
|
- if(mTOOL_RUN.equals("START") && msisdnTool == true){
|
|
|
- chargeLog.setDescription("Charge tool " + productInfo.getProductName());
|
|
|
- chargeLog.setAccountId("1");
|
|
|
- }else{
|
|
|
- chargeLog.setDescription("Charge");
|
|
|
- }
|
|
|
+// String mTOOL_RUN = MessageResponse.get(Common.Message.TOOL_RUN,logger);
|
|
|
+// if(mTOOL_RUN.equals("START") && msisdnTool == true){
|
|
|
+// chargeLog.setDescription("Charge tool " + productInfo.getProductName());
|
|
|
+// chargeLog.setAccountId("1");
|
|
|
+// }else{
|
|
|
+ chargeLog.setDescription("Charge " + productInfo.getProductName());
|
|
|
+// }
|
|
|
|
|
|
chargeLog.setStatus(Common.Constant.CHARGE_STATUS);
|
|
|
db.iInsertChargeLog(chargeLog);
|
|
|
}
|
|
|
|
|
|
// Update Spin
|
|
|
-// db.addTurnSpin(msisdn,productInfo.getNumberSpin());
|
|
|
+ db.addTurnSpin(msisdn,productInfo.getNumberSpin());
|
|
|
logger.info("Buy turn success success " + msisdn + ", fee " + fee);
|
|
|
|
|
|
-// LuckySprin mLuckySprin = db.igetLuckySprin(msisdn);
|
|
|
-// if(mLuckySprin != null){
|
|
|
-// response.setRemainSpin(mLuckySprin.getAdded()- mLuckySprin.getUsed());
|
|
|
-// response.setTotalSpin(mLuckySprin.getAdded());
|
|
|
-// }
|
|
|
+ LuckySprin mLuckySprin = db.igetLuckySprin(msisdn);
|
|
|
+ if(mLuckySprin != null){
|
|
|
+ response.setRemainSpin(mLuckySprin.getAdded()- mLuckySprin.getUsed());
|
|
|
+ response.setTotalSpin(mLuckySprin.getAdded());
|
|
|
+ }
|
|
|
response.setMoneyDeducted(moneyCharge);
|
|
|
response.setTotalSpinAdd(productInfo.getNumberSpin());
|
|
|
|
|
|
@@ -2585,6 +2575,109 @@ public class KittyFallWs extends WebserviceAbstract {
|
|
|
}
|
|
|
|
|
|
|
|
|
+ @WebMethod(operationName = "wsAddPoint")
|
|
|
+ @SOAPBinding(style = SOAPBinding.Style.DOCUMENT, use = SOAPBinding.Use.LITERAL)
|
|
|
+ public Response wsAddPoint(
|
|
|
+ @WebParam(name = "WsUser") String wsUser,
|
|
|
+ @WebParam(name = "WsPass") String wsPass,
|
|
|
+ @WebParam(name = "Msisdn") String msisdn,
|
|
|
+ @WebParam(name = "PackageName") String packageName,
|
|
|
+ @WebParam(name = "Point") String point,
|
|
|
+ @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 Point:").append(point);
|
|
|
+ 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 (point == null || point.length() == 0) {
|
|
|
+ logger.info("point 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(point);
|
|
|
+ ws.addPoint(msisdn, dataConvert);
|
|
|
+
|
|
|
+ ChargeLog chargeLog = new ChargeLog();
|
|
|
+ chargeLog.setFee(-dataConvert);
|
|
|
+ chargeLog.setChargeTime(new Timestamp(System.currentTimeMillis()));
|
|
|
+ chargeLog.setMsisdn(msisdn);
|
|
|
+ chargeLog.setDescription("Exchange points to data");
|
|
|
+ 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%", point + "");
|
|
|
+ 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;
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
|
|
|
// ------------------------- END ----------------------
|