From e6d1cb162a7688030983d27375570ce2d52f69ff Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期一, 15 六月 2020 15:35:14 +0800
Subject: [PATCH] 上传代码
---
service-front/src/main/java/com/java110/front/smo/ownerLogin/impl/OwnerAppLoginSMOImpl.java | 260 ++++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 242 insertions(+), 18 deletions(-)
diff --git a/service-front/src/main/java/com/java110/front/smo/ownerLogin/impl/OwnerAppLoginSMOImpl.java b/service-front/src/main/java/com/java110/front/smo/ownerLogin/impl/OwnerAppLoginSMOImpl.java
index da82b90..518c8b2 100644
--- a/service-front/src/main/java/com/java110/front/smo/ownerLogin/impl/OwnerAppLoginSMOImpl.java
+++ b/service-front/src/main/java/com/java110/front/smo/ownerLogin/impl/OwnerAppLoginSMOImpl.java
@@ -5,13 +5,19 @@
import com.java110.core.context.IPageData;
import com.java110.core.context.PageData;
import com.java110.core.factory.AuthenticationFactory;
+import com.java110.dto.owner.OwnerAppUserDto;
import com.java110.front.properties.WechatAuthProperties;
import com.java110.front.smo.AppAbstractComponentSMO;
import com.java110.front.smo.ownerLogin.IOwnerAppLoginSMO;
+import com.java110.utils.cache.CommonCache;
+import com.java110.utils.constant.CommonConstant;
+import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.constant.ServiceConstant;
+import com.java110.utils.constant.WechatConstant;
import com.java110.utils.exception.SMOException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.StringUtil;
+import com.java110.vo.ResultVo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -21,6 +27,14 @@
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.net.URL;
+import java.net.URLEncoder;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.UUID;
+
/**
* wx鐧诲綍
*/
@@ -28,6 +42,8 @@
public class OwnerAppLoginSMOImpl extends AppAbstractComponentSMO implements IOwnerAppLoginSMO {
private final static Logger logger = LoggerFactory.getLogger(OwnerAppLoginSMOImpl.class);
+
+ private final static int expireTime = 7200;
@Autowired
private RestTemplate restTemplate;
@@ -45,13 +61,117 @@
}
@Override
- protected void validate(IPageData pd, JSONObject paramIn) {
+ public ResponseEntity<String> getPageAccessToken(IPageData pd) throws SMOException {
+ JSONObject paramIn = JSONObject.parseObject(pd.getReqData());
+ String authCode = paramIn.getString("code");
+ String state = paramIn.getString("state");
+ String urlCode = CommonCache.getAndRemoveValue(paramIn.getString("urlCode"));
- //super.validatePageInfo(pd);
+ if (StringUtil.isEmpty(urlCode)) {
+ return ResultVo.redirectPage("/#/page/login/login");
+ }
+
+ String url = WechatConstant.APP_GET_ACCESS_TOKEN_URL.replace("APPID", wechatAuthProperties.getWechatAppId())
+ .replace("SECRET", wechatAuthProperties.getWechatAppSecret())
+ .replace("CODE", authCode);
+
+ ResponseEntity<String> paramOut = outRestTemplate.getForEntity(url, String.class);
+
+ logger.debug("璋冪敤寰俊鎹㈠幓token ", paramOut);
+ if (paramOut.getStatusCode() != HttpStatus.OK) {
+ return ResultVo.redirectPage("/#/page/login/login");
+
+ }
+
+ JSONObject paramObj = JSONObject.parseObject(paramOut.getBody());
+
+ //鑾峰彇 openId
+ String openId = paramObj.getString("openid");
+ //鍒ゆ柇褰撳墠openId 鏄惁缁戝畾浜嗕笟涓�
+
+ pd = PageData.newInstance().builder("-1", "", "", pd.getReqData(),
+ "", "", "", "",
+ pd.getAppId());
+ ResponseEntity responseEntity = this.callCenterService(restTemplate, pd, "", ServiceConstant.SERVICE_API_URL + "/api/owner.listAppUserBindingOwners?openId=" + openId, HttpMethod.GET);
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ //灏唎penId鏀惧埌redis 缂撳瓨锛岀粰鍓嶆涓嬪彂涓存椂绁ㄦ嵁
+ String code = UUID.randomUUID().toString();
+ CommonCache.setValue(code, openId, expireTime);
+ return ResultVo.redirectPage("/#/page/login/login?code=" + code);
+ }
+ JSONObject ownerInfo = JSONObject.parseObject(responseEntity.getBody().toString());
+ if (ownerInfo.getInteger("total") < 1) {
+ //灏唎penId鏀惧埌redis 缂撳瓨锛岀粰鍓嶆涓嬪彂涓存椂绁ㄦ嵁
+ String code = UUID.randomUUID().toString();
+ CommonCache.setValue(code, openId, expireTime);
+ return ResultVo.redirectPage("/#/page/login/login?code=" + code);
+ }
+
+ // String accessToken = paramObj.getString("access_token");//鏆傛椂涓嶇敤
+ Map userMap = new HashMap();
+ userMap.put(CommonConstant.LOGIN_USER_ID, ownerInfo.getString("userId"));
+ userMap.put(CommonConstant.LOGIN_USER_NAME, ownerInfo.getString("appUserName"));
+ String token = "";
+ try {
+ token = AuthenticationFactory.createAndSaveToken(userMap);
+ pd.setToken(token);
+ } catch (Exception e) {
+ logger.error("鍒涘缓token澶辫触");
+ }
+ return ResultVo.redirectPage(urlCode);
+
+ }
+
+ /**
+ * 鍒锋柊token
+ *
+ * @param pd
+ * @param redirectUrl
+ * @param request
+ * @param response
+ * @return
+ * @throws SMOException
+ */
+ @Override
+ public ResponseEntity<String> refreshToken(IPageData pd, String redirectUrl, HttpServletRequest request, HttpServletResponse response) throws SMOException {
+ //鍒嗛厤urlCode
+ String urlCode = UUID.randomUUID().toString();
+ CommonCache.setValue(urlCode, redirectUrl, expireTime);
+
+ URL url = null;
+ String openUrl = "";
+ try {
+ url = new URL(redirectUrl);
+
+ String newUrl = url.getProtocol() + "://" + url.getHost();
+ if (url.getPort() > 0) {
+ newUrl += (":" + url.getPort());
+ }
+
+ openUrl = WechatConstant.OPEN_AUTH
+ .replace("APPID", wechatAuthProperties.getWechatAppId())
+ .replace("SCOPE", "snsapi_base")
+ .replace(
+ "REDIRECT_URL",
+ URLEncoder
+ .encode(
+ (newUrl
+ + "/app/loginOwnerWechatAuth?appId=992020061452450002&urlCode=" + urlCode),
+ "UTF-8")).replace("STATE", "1");
+
+ } catch (Exception e) {
+ logger.error("寰俊鍏紬鍙烽壌鏉� redirectUrl 閿欒 " + redirectUrl, e);
+ throw new SMOException(ResponseConstant.RESULT_CODE_ERROR, e.getLocalizedMessage());
+ }
+
+ return ResultVo.redirectPage(openUrl);
+ }
+
+ @Override
+ protected void validate(IPageData pd, JSONObject paramIn) {
Assert.hasKeyAndValue(paramIn, "username", "璇锋眰鎶ユ枃涓湭鍖呭惈鐢ㄦ埛鍚�");
Assert.hasKeyAndValue(paramIn, "password", "璇锋眰鎶ユ枃涓湭鍖呭惈瀵嗙爜");
- //super.checkUserHasPrivilege(pd, restTemplate, PrivilegeCodeConstant.LIST_ORG);
}
@Override
@@ -84,37 +204,109 @@
JSONObject ownerInfo = JSONObject.parseObject(responseEntity.getBody().toString());
- if (ownerInfo.getInteger("total") != 1) {
+ if (ownerInfo.getInteger("total") < 1) {
responseEntity = new ResponseEntity<>("鐢ㄦ埛鏈粦瀹氫笟涓�", HttpStatus.BAD_REQUEST);
return responseEntity;
}
- JSONObject appUser = ownerInfo.getJSONArray("auditAppUserBindingOwners").getJSONObject(0);
+ JSONArray auditAppUserBindingOwners = ownerInfo.getJSONArray("auditAppUserBindingOwners");
+
+ JSONObject appUser = auditAppUserBindingOwners.getJSONObject(0);
appUser.put("userId", userId);
appUser.put("userName", paramIn.getString("username"));
JSONObject paramOut = new JSONObject();
paramOut.put("result", 0);
paramOut.put("owner", appUser);
paramOut.put("token", userInfo.getString("token"));
- //鍙兘鏄痑pp 鐧诲綍 鐩存帴杩斿洖
- if (!paramIn.containsKey("code") || StringUtil.isEmpty(paramIn.getString("code"))) {
+
+ String appId = pd.getAppId();
+
+ if ("992020061452450002".equals(appId)) { //鍏紬鍙�
+ return wechat(pd, paramIn, paramOut, userId, auditAppUserBindingOwners);
+ } else if ("992019111758490006".equals(appId)) { //灏忕▼搴�
+ return mina(pd, paramIn, paramOut, userId, auditAppUserBindingOwners);
+ } else {//app
return new ResponseEntity<>(paramOut.toJSONString(), HttpStatus.OK);
}
- //濡傛灉code涓嶄负绌鸿皟鐢ㄥ井淇℃帴鍙ｈ幏鍙杘penId 鍒峰叆鍒板綋鍓嶇敤鎴峰睘鎬ц〃
+ }
+ /**
+ * 鍏紬鍙风櫥褰�
+ *
+ * @param pd
+ * @param paramIn
+ * @param paramOut
+ * @param userId
+ * @param auditAppUserBindingOwners
+ * @return
+ */
+ private ResponseEntity<String> wechat(IPageData pd, JSONObject paramIn, JSONObject paramOut, String userId,
+ JSONArray auditAppUserBindingOwners) {
+
+ ResponseEntity<String> responseEntity = null;
+ //鏌ヨ寰俊淇℃伅
+ pd = PageData.newInstance().builder(userId, "", "", pd.getReqData(),
+ "", "", "", "",
+ pd.getAppId());
+
+
+ String code = paramIn.getString("code");
+
+ String openId = CommonCache.getValue(code);
+
+ if (StringUtil.isEmpty(openId)) {
+ responseEntity = new ResponseEntity<>("椤甸潰澶辨晥锛岃鍒锋柊鍚庨噸璇�", HttpStatus.UNAUTHORIZED);
+ return responseEntity;
+ }
+
+ JSONObject curOwnerApp = judgeCurrentOwnerBind(auditAppUserBindingOwners, OwnerAppUserDto.APP_TYPE_WECHAT_MINA);
+
+ //璇存槑 褰撳墠鐨刼penId 灏辨槸鏈�鏂扮殑
+ if (curOwnerApp != null && openId.equals(curOwnerApp.getString("openId"))) {
+ return new ResponseEntity<>(paramOut.toJSONString(), HttpStatus.OK);
+ }
+
+ JSONObject userOwnerInfo = new JSONObject();
+
+ userOwnerInfo.put("openId", openId);
+ userOwnerInfo.put("appType", OwnerAppUserDto.APP_TYPE_WECHAT_MINA);
+ if (curOwnerApp != null) {
+ userOwnerInfo.put("appUserId", curOwnerApp.getString("appUserId"));
+ userOwnerInfo.put("communityId", curOwnerApp.getString("communityId"));
+ } else {
+ userOwnerInfo.put("oldAppUserId", auditAppUserBindingOwners.getJSONObject(0).getString("appUserId"));
+ userOwnerInfo.put("appUserId", "-1");
+ userOwnerInfo.put("communityId", auditAppUserBindingOwners.getJSONObject(0).getString("communityId"));
+ }
+
+ //鏌ヨ寰俊淇℃伅
+ pd = PageData.newInstance().builder(userId, "", "", pd.getReqData(),
+ "", "", "", "",
+ pd.getAppId());
+ responseEntity = this.callCenterService(restTemplate, pd, userOwnerInfo.toJSONString(),
+ ServiceConstant.SERVICE_API_URL + "/api/owner.refreshAppUserBindingOwnerToken", HttpMethod.POST);
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
+ return responseEntity;
+ }
+ return new ResponseEntity<>(paramOut.toJSONString(), HttpStatus.OK);
+ }
+
+ private ResponseEntity<String> mina(IPageData pd, JSONObject paramIn, JSONObject paramOut, String userId, JSONArray auditAppUserBindingOwners) {
+
+ ResponseEntity<String> responseEntity = null;
//鏌ヨ寰俊淇℃伅
pd = PageData.newInstance().builder(userId, "", "", pd.getReqData(),
"", "", "", "",
pd.getAppId());
responseEntity = this.callCenterService(restTemplate, pd, "",
ServiceConstant.SERVICE_API_URL + "/api/smallWeChat.listSmallWeChats?appId="
- + paramIn.getString("appId")+"&page=1&row=1", HttpMethod.GET);
+ + paramIn.getString("appId") + "&page=1&row=1", HttpMethod.GET);
if (responseEntity.getStatusCode() != HttpStatus.OK) {
return responseEntity;
}
-
- JSONArray smallWeChats = ownerInfo.getJSONArray("smallWeChats");
+ JSONObject smallWechatObj = JSONObject.parseObject(responseEntity.getBody().toString());
+ JSONArray smallWeChats = smallWechatObj.getJSONArray("smallWeChats");
String appId = wechatAuthProperties.getAppId();
String secret = wechatAuthProperties.getSecret();
if (smallWeChats.size() > 0) {
@@ -144,23 +336,55 @@
String openId = responseObj.getString("openid");
- JSONObject userAttrInfo = new JSONObject();
- userAttrInfo.put("userId", userId);
- userAttrInfo.put("specCd", "100201911001");//寰俊openId
- userAttrInfo.put("value", openId);
+ JSONObject curOwnerApp = judgeCurrentOwnerBind(auditAppUserBindingOwners, OwnerAppUserDto.APP_TYPE_WECHAT_MINA);
+
+ //璇存槑 褰撳墠鐨刼penId 灏辨槸鏈�鏂扮殑
+ if (curOwnerApp != null && openId.equals(curOwnerApp.getString("openId"))) {
+ return new ResponseEntity<>(paramOut.toJSONString(), HttpStatus.OK);
+ }
+
+ JSONObject userOwnerInfo = new JSONObject();
+
+ userOwnerInfo.put("openId", openId);
+ userOwnerInfo.put("appType", OwnerAppUserDto.APP_TYPE_WECHAT_MINA);
+ if (curOwnerApp != null) {
+ userOwnerInfo.put("appUserId", curOwnerApp.getString("appUserId"));
+ userOwnerInfo.put("communityId", curOwnerApp.getString("communityId"));
+ } else {
+ userOwnerInfo.put("oldAppUserId", auditAppUserBindingOwners.getJSONObject(0).getString("appUserId"));
+ userOwnerInfo.put("appUserId", "-1");
+ userOwnerInfo.put("communityId", auditAppUserBindingOwners.getJSONObject(0).getString("communityId"));
+ }
//鏌ヨ寰俊淇℃伅
pd = PageData.newInstance().builder(userId, "", "", pd.getReqData(),
"", "", "", "",
pd.getAppId());
- responseEntity = this.callCenterService(restTemplate, pd, userAttrInfo.toJSONString(),
- ServiceConstant.SERVICE_API_URL + "/api/user.saveOrUpdateUserAttr", HttpMethod.POST);
- if(responseEntity.getStatusCode() != HttpStatus.OK){
+ responseEntity = this.callCenterService(restTemplate, pd, userOwnerInfo.toJSONString(),
+ ServiceConstant.SERVICE_API_URL + "/api/owner.refreshAppUserBindingOwnerOpenId", HttpMethod.POST);
+ if (responseEntity.getStatusCode() != HttpStatus.OK) {
return responseEntity;
}
return new ResponseEntity<>(paramOut.toJSONString(), HttpStatus.OK);
}
+ /**
+ * 鍒ゆ柇 缁戝畾琛ㄩ噷鏄惁瀛樺湪褰撳墠 绔� 缁戝畾淇℃伅
+ *
+ * @param auditAppUserBindingOwners
+ * @param appType
+ * @return
+ */
+ private JSONObject judgeCurrentOwnerBind(JSONArray auditAppUserBindingOwners, String appType) {
+
+ for (int appUserIndex = 0; appUserIndex < auditAppUserBindingOwners.size(); appUserIndex++) {
+ if (appType.equals(auditAppUserBindingOwners.getJSONObject(appUserIndex).getString("appType"))) {
+ return auditAppUserBindingOwners.getJSONObject(appUserIndex);
+ }
+ }
+ return null;
+ }
+
public RestTemplate getRestTemplate() {
return restTemplate;
}
--
Gitblit v1.8.0