package com.java110.boot.smo.login.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.boot.smo.DefaultAbstractComponentSMO;
|
import com.java110.boot.smo.login.IAdminLoginPropertyAccountServiceSMO;
|
import com.java110.core.cache.Java110RedisConfig;
|
import com.java110.core.context.IPageData;
|
import com.java110.core.factory.AuthenticationFactory;
|
import com.java110.core.log.LoggerFactory;
|
import com.java110.utils.cache.CommonCache;
|
import com.java110.utils.util.Assert;
|
import com.java110.utils.util.StringUtil;
|
import org.slf4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.http.HttpMethod;
|
import org.springframework.http.HttpStatus;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.client.RestTemplate;
|
|
|
/**
|
* 登录信息实现类
|
* Created by wuxw on 2019/3/20.
|
*/
|
|
@Service("adminLoginPropertyAccountServiceSMOImpl")
|
public class AdminLoginPropertyAccountServiceSMOImpl extends DefaultAbstractComponentSMO implements IAdminLoginPropertyAccountServiceSMO {
|
private final static Logger logger = LoggerFactory.getLogger(AdminLoginPropertyAccountServiceSMOImpl.class);
|
|
@Autowired
|
private RestTemplate restTemplate;
|
|
|
/**
|
* 登录处理
|
*
|
* @param pd 页面请求对象
|
* @return
|
*/
|
@Override
|
public ResponseEntity<String> doLogin(IPageData pd) {
|
|
ResponseEntity<String> responseEntity = null;
|
JSONObject loginInfo = JSONObject.parseObject(pd.getReqData());
|
validate(loginInfo);
|
loginInfo.put("curPasswd", AuthenticationFactory.passwdMd5(loginInfo.getString("curPasswd")));
|
responseEntity = this.callCenterService(restTemplate, pd, loginInfo.toJSONString(), "login.adminLoginProperty", HttpMethod.POST);
|
if (responseEntity.getStatusCode() == HttpStatus.OK) {
|
JSONObject userInfo = JSONObject.parseObject(responseEntity.getBody());
|
pd.setToken(userInfo.getString("token"));
|
clearUserCache(userInfo);
|
}
|
return responseEntity;
|
}
|
|
/**
|
* 校验验证码
|
*
|
* @param reqJson 页面请求对象
|
* @return
|
*/
|
public void validate(JSONObject reqJson) {
|
|
Assert.hasKeyAndValue(reqJson, "username", "未包含需要登录的用户名");
|
Assert.hasKeyAndValue(reqJson, "userId", "未包含需要登录的用户ID");
|
Assert.hasKeyAndValue(reqJson, "curPasswd", "未包含当前用户的密码");
|
Assert.hasKeyAndValue(reqJson, "curUserName", "未包含当前用户的用户名");
|
|
}
|
|
/**
|
* 清理用户缓存
|
*
|
* @param userInfo
|
*/
|
private void clearUserCache(JSONObject userInfo) {
|
//员工商户缓存 getStoreInfo
|
String storeId = "";
|
|
String storeInfo = CommonCache.getValue("getStoreInfo" + Java110RedisConfig.GET_STORE_INFO_EXPIRE_TIME_KEY + "::" + userInfo.getString("userId"));
|
if (!StringUtil.isEmpty(storeInfo)) {
|
CommonCache.removeValue("getStoreInfo" + Java110RedisConfig.GET_STORE_INFO_EXPIRE_TIME_KEY + "::" + userInfo.getString("userId"));
|
JSONObject storeObj = JSONObject.parseObject(storeInfo);
|
storeId = storeObj.getJSONObject("msg").getString("storeId");
|
CommonCache.removeValue("getStoreEnterCommunitys" + Java110RedisConfig.GET_STORE_ENTER_COMMUNITYS_EXPIRE_TIME_KEY + "::" + storeId);
|
}
|
//员工权限
|
CommonCache.removeValue("getUserPrivileges" + Java110RedisConfig.DEFAULT_EXPIRE_TIME_KEY + "::" + userInfo.getString("userId"));
|
}
|
|
|
public RestTemplate getRestTemplate() {
|
return restTemplate;
|
}
|
|
public void setRestTemplate(RestTemplate restTemplate) {
|
this.restTemplate = restTemplate;
|
}
|
}
|
