|
|
@ -1,7 +1,9 @@ |
|
|
package com.epmet.service.impl; |
|
|
package com.epmet.service.impl; |
|
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.convert.Convert; |
|
|
import com.alibaba.fastjson.JSON; |
|
|
import com.alibaba.fastjson.JSON; |
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
import com.alibaba.fastjson.JSONObject; |
|
|
|
|
|
import com.alibaba.fastjson.TypeReference; |
|
|
import com.alibaba.nacos.client.config.utils.IOUtils; |
|
|
import com.alibaba.nacos.client.config.utils.IOUtils; |
|
|
import com.epmet.commons.tools.constant.NumConstant; |
|
|
import com.epmet.commons.tools.constant.NumConstant; |
|
|
import com.epmet.commons.tools.exception.RenException; |
|
|
import com.epmet.commons.tools.exception.RenException; |
|
|
@ -12,10 +14,8 @@ import com.epmet.constant.ThirdRedisKeyConstant; |
|
|
import com.epmet.constant.ThirdRunTimeInfoConstant; |
|
|
import com.epmet.constant.ThirdRunTimeInfoConstant; |
|
|
import com.epmet.dao.*; |
|
|
import com.epmet.dao.*; |
|
|
import com.epmet.dto.form.*; |
|
|
import com.epmet.dto.form.*; |
|
|
import com.epmet.dto.result.AuthCodeResultDTO; |
|
|
import com.epmet.dto.result.*; |
|
|
import com.epmet.dto.result.AuthorizationInfoResultDTO; |
|
|
import com.epmet.feign.EpmetUserOpenFeignClient; |
|
|
import com.epmet.dto.result.CreateOpenResultDTO; |
|
|
|
|
|
import com.epmet.dto.result.WillOverDueResultDTO; |
|
|
|
|
|
import com.epmet.mpaes.WXBizMsgCrypt; |
|
|
import com.epmet.mpaes.WXBizMsgCrypt; |
|
|
import com.epmet.mpaes.WXXmlToMapUtil; |
|
|
import com.epmet.mpaes.WXXmlToMapUtil; |
|
|
import com.epmet.redis.RedisThird; |
|
|
import com.epmet.redis.RedisThird; |
|
|
@ -32,9 +32,7 @@ import org.springframework.web.bind.annotation.RequestBody; |
|
|
|
|
|
|
|
|
import javax.servlet.http.HttpServletRequest; |
|
|
import javax.servlet.http.HttpServletRequest; |
|
|
import javax.servlet.http.HttpServletResponse; |
|
|
import javax.servlet.http.HttpServletResponse; |
|
|
import java.io.IOException; |
|
|
|
|
|
import java.io.InputStream; |
|
|
import java.io.InputStream; |
|
|
import java.io.UnsupportedEncodingException; |
|
|
|
|
|
import java.lang.reflect.Field; |
|
|
import java.lang.reflect.Field; |
|
|
import java.util.*; |
|
|
import java.util.*; |
|
|
|
|
|
|
|
|
@ -79,6 +77,10 @@ public class ComponentVerifyTicketServiceImpl implements ComponentVerifyTicketSe |
|
|
private MiniCategoryInfoDao miniCategoryInfoDao; |
|
|
private MiniCategoryInfoDao miniCategoryInfoDao; |
|
|
@Autowired |
|
|
@Autowired |
|
|
private BusinessInfoDao businessInfoDao; |
|
|
private BusinessInfoDao businessInfoDao; |
|
|
|
|
|
@Autowired |
|
|
|
|
|
private EpmetUserOpenFeignClient epmetUserOpenFeignClient; |
|
|
|
|
|
@Autowired |
|
|
|
|
|
private AuthResultRecordDao authResultRecordDao; |
|
|
|
|
|
|
|
|
@Value("${third.platform.appId}") |
|
|
@Value("${third.platform.appId}") |
|
|
private String componentAppId; |
|
|
private String componentAppId; |
|
|
@ -109,20 +111,17 @@ public class ComponentVerifyTicketServiceImpl implements ComponentVerifyTicketSe |
|
|
String nonce = request.getParameter(ModuleConstant.NONCE); |
|
|
String nonce = request.getParameter(ModuleConstant.NONCE); |
|
|
String encryptType = request.getParameter(ModuleConstant.ENCRYPT_TYPE); |
|
|
String encryptType = request.getParameter(ModuleConstant.ENCRYPT_TYPE); |
|
|
String signature = request.getParameter(ModuleConstant.SIGNATURE); |
|
|
String signature = request.getParameter(ModuleConstant.SIGNATURE); |
|
|
log.info(String.format(ThirdRunTimeInfoConstant.VERIFY_TICKET,msgSignature,timeStamp,nonce,encryptType,signature)); |
|
|
|
|
|
// 从请求中读取整个post数据
|
|
|
// 从请求中读取整个post数据
|
|
|
InputStream inputStream; |
|
|
InputStream inputStream; |
|
|
String postData = null; |
|
|
String postData = null; |
|
|
inputStream = request.getInputStream(); |
|
|
inputStream = request.getInputStream(); |
|
|
postData= IOUtils.toString(inputStream,ModuleConstant.UTF8); |
|
|
postData= IOUtils.toString(inputStream,ModuleConstant.UTF8); |
|
|
log.info("postData = "+postData); |
|
|
|
|
|
WXBizMsgCrypt wxBizMsgCrypt = new WXBizMsgCrypt(token,aesKey,componentAppId); |
|
|
WXBizMsgCrypt wxBizMsgCrypt = new WXBizMsgCrypt(token,aesKey,componentAppId); |
|
|
String msg = wxBizMsgCrypt.decryptMsg(msgSignature, timeStamp, nonce, postData); |
|
|
String msg = wxBizMsgCrypt.decryptMsg(msgSignature, timeStamp, nonce, postData); |
|
|
log.info(String.format(ThirdRunTimeInfoConstant.MSG,msg)); |
|
|
log.info(String.format(ThirdRunTimeInfoConstant.MSG,msg)); |
|
|
// 将xml转为map
|
|
|
// 将xml转为map
|
|
|
Map<String, String> result = WXXmlToMapUtil.xmlToMap(msg); |
|
|
Map<String, String> result = WXXmlToMapUtil.xmlToMap(msg); |
|
|
String infotype = result.get(ModuleConstant.INFO_TYPE); //获取infotype,注：微信开放平台文档中标明固定为："component_verify_ticket",但参考其他代码，还包含authorized？？？
|
|
|
String infotype = result.get(ModuleConstant.INFO_TYPE); |
|
|
log.info(infotype); |
|
|
|
|
|
switch (infotype){ |
|
|
switch (infotype){ |
|
|
case ModuleConstant.TICKET_UNDERLINE_KEY: //接收票据 【component_verify_ticket】
|
|
|
case ModuleConstant.TICKET_UNDERLINE_KEY: //接收票据 【component_verify_ticket】
|
|
|
String ComponentVerifyTicket = result.get(ModuleConstant.TICKET_KEY); |
|
|
String ComponentVerifyTicket = result.get(ModuleConstant.TICKET_KEY); |
|
|
@ -133,29 +132,22 @@ public class ComponentVerifyTicketServiceImpl implements ComponentVerifyTicketSe |
|
|
ticketFormDTO.setComponentAppId(componentAppId); |
|
|
ticketFormDTO.setComponentAppId(componentAppId); |
|
|
ticketFormDTO.setComponentVerifyTicket(ComponentVerifyTicket); |
|
|
ticketFormDTO.setComponentVerifyTicket(ComponentVerifyTicket); |
|
|
//先逻辑删
|
|
|
//先逻辑删
|
|
|
ticketDao.updateOldComponentVerifyTicket(); |
|
|
ticketDao.deleteOldComponentVerifyTicket(); |
|
|
ticketDao.insertComponentVerifyTicket(ticketFormDTO); |
|
|
ticketDao.insertComponentVerifyTicket(ticketFormDTO); |
|
|
log.info(ModuleConstant.TICKET_UNDERLINE_KEY+"："+ComponentVerifyTicket); |
|
|
log.info(ModuleConstant.TICKET_UNDERLINE_KEY+"："+ComponentVerifyTicket); |
|
|
break; |
|
|
break; |
|
|
case ModuleConstant.AUTHORIZED: //授权成功
|
|
|
case ModuleConstant.AUTHORIZED: //授权成功
|
|
|
// 更改customer_mp 授权信息，appId,并绑定
|
|
|
this.disposeAuthResult(result); |
|
|
// String authAppId = result.get(ModuleConstant.APP_ID);
|
|
|
break; |
|
|
String authCode = result.get(ModuleConstant.AUTHORIZATION_CODE_HUMP); |
|
|
|
|
|
log.info("=============================="+authCode); |
|
|
|
|
|
AuthCodeResultDTO authCodeResultDTO = authCodeDao.selectCustomerIdByAuthCode(authCode); |
|
|
|
|
|
String clientType = authCodeResultDTO.getClientType(); |
|
|
|
|
|
String customerId = authCodeResultDTO.getCustomerId(); |
|
|
|
|
|
Map<String, Object> authorizerRefreshToken = redisThird.getAuthorizerRefreshToken(customerId + ThirdRedisKeyConstant.COLON + clientType); |
|
|
|
|
|
String authAppId = authorizerRefreshToken.get("authorizerAppid").toString(); |
|
|
|
|
|
this.updateCustomerMpAppIdAndCreateOpenPlatform(customerId,authAppId,clientType); |
|
|
|
|
|
// this.authInfoByAuthCode(authCode, customerId,clientType);
|
|
|
|
|
|
authCodeDao.updateAppId(customerId,clientType,authAppId); |
|
|
|
|
|
this.saveAuthAccountInfo(customerId,authAppId,clientType); |
|
|
|
|
|
// customerMpDao.updateAuthorizationFlag(authAppId);
|
|
|
|
|
|
case ModuleConstant.UNAUTHORIZED://用户取消授权
|
|
|
case ModuleConstant.UNAUTHORIZED://用户取消授权
|
|
|
//todo 取消授权
|
|
|
//todo 取消授权
|
|
|
String authorizerAppId = result.get(ModuleConstant.AUTHORIZER_APP_ID_HUMP); |
|
|
String authorizerAppId = result.get(ModuleConstant.AUTHORIZER_APP_ID_HUMP); |
|
|
customerMpDao.updateAuthorizationFlag(authorizerAppId); |
|
|
customerMpDao.updateAuthorizationFlag(authorizerAppId); |
|
|
|
|
|
this.disposeAuthResult(result); |
|
|
|
|
|
break; |
|
|
|
|
|
case ModuleConstant.UPDATE_AUTHORIZED://授权变更
|
|
|
|
|
|
this.disposeAuthResult(result); |
|
|
|
|
|
break; |
|
|
} |
|
|
} |
|
|
} catch (Exception e) { |
|
|
} catch (Exception e) { |
|
|
log.error(e.getMessage()); |
|
|
log.error(e.getMessage()); |
|
|
@ -170,6 +162,24 @@ public class ComponentVerifyTicketServiceImpl implements ComponentVerifyTicketSe |
|
|
return ModuleConstant.SUCCESS; |
|
|
return ModuleConstant.SUCCESS; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
* @Description 授权结果插入 |
|
|
|
|
|
* @param result |
|
|
|
|
|
* @author zxc |
|
|
|
|
|
*/ |
|
|
|
|
|
@Transactional(rollbackFor = Exception.class) |
|
|
|
|
|
public void disposeAuthResult(Map<String,String> result){ |
|
|
|
|
|
Map tempMap = result; |
|
|
|
|
|
Map<String,Object> data = tempMap; |
|
|
|
|
|
AuthResultRecordFormDTO authResultRecord = mapToEntity(data, AuthResultRecordFormDTO.class); |
|
|
|
|
|
authResultRecord.setWechatCreateTime(this.sToDate(result.get(ModuleConstant.CREATE_TIME))); |
|
|
|
|
|
if (result.containsKey(ModuleConstant.AUTHORIZATION_CODE_EXPIRED_TIME)) { |
|
|
|
|
|
authResultRecord.setExpiredTime(this.sToDate(result.get(ModuleConstant.AUTHORIZATION_CODE_EXPIRED_TIME))); |
|
|
|
|
|
} |
|
|
|
|
|
authResultRecord.setComponentAppId(componentAppId); |
|
|
|
|
|
authResultRecordDao.insertAuthResultRecord(authResultRecord); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|
* @Description 定时获取 (令牌，component_access_token) 第三方与微信交互使用的component_access_token |
|
|
* @Description 定时获取 (令牌，component_access_token) 第三方与微信交互使用的component_access_token |
|
|
* 每十分钟执行一次,判断是否有马上超时的（15分钟以内算马上超时） |
|
|
* 每十分钟执行一次,判断是否有马上超时的（15分钟以内算马上超时） |
|
|
@ -283,28 +293,13 @@ public class ComponentVerifyTicketServiceImpl implements ComponentVerifyTicketSe |
|
|
authInfoDTO.setExpiresInTime(expiresInTime); |
|
|
authInfoDTO.setExpiresInTime(expiresInTime); |
|
|
authInfoDTO.setCustomerId(customerId); |
|
|
authInfoDTO.setCustomerId(customerId); |
|
|
authInfoDTO.setClientType(clientType); |
|
|
authInfoDTO.setClientType(clientType); |
|
|
//先逻辑删除，在插入
|
|
|
|
|
|
authorizationInfoDao.updateOldAuthorizationInfo(customerId,clientType); |
|
|
|
|
|
authorizationInfoDao.insertAuthorizationInfo(authInfoDTO); |
|
|
|
|
|
// 2. 权限列表
|
|
|
|
|
|
log.info(START_INSERT_FUNC_INFO); |
|
|
|
|
|
List<FuncInfoFormDTO> funcInfos = new ArrayList<>(); |
|
|
|
|
|
List<Map> func_info = authorizationInfoResultDTO.getFunc_info(); |
|
|
List<Map> func_info = authorizationInfoResultDTO.getFunc_info(); |
|
|
log.info("权限列表信息："+func_info); |
|
|
log.info("权限列表信息："+func_info); |
|
|
/*func_info.forEach(func -> { |
|
|
String funcInfo = JSON.toJSONString(func_info); |
|
|
func.forEach((key,value) -> { |
|
|
authInfoDTO.setFuncInfo(funcInfo); |
|
|
FuncInfoFormDTO fu = new FuncInfoFormDTO(); |
|
|
//先逻辑删除，在插入
|
|
|
fu.setFuncscopeCategory((String) key); |
|
|
authorizationInfoDao.updateOldAuthorizationInfo(authAppId); |
|
|
Map funcScope = (Map) value; |
|
|
authorizationInfoDao.insertAuthorizationInfo(authInfoDTO); |
|
|
fu.setFuncscopeId(funcScope.get(ModuleConstant.ID).toString()); |
|
|
|
|
|
fu.setAuthorizationInfoAppid(authAppId); |
|
|
|
|
|
fu.setCustomerId(customerId); |
|
|
|
|
|
funcInfos.add(fu); |
|
|
|
|
|
}); |
|
|
|
|
|
});*/ |
|
|
|
|
|
// todo 先逻辑删除，在插入
|
|
|
|
|
|
/*funcInfoDao.updateOldFuncInfo(customerId,authAppId); |
|
|
|
|
|
funcInfoDao.insertFuncInfo(funcInfos);*/ |
|
|
|
|
|
// 授权信息放入缓存
|
|
|
// 授权信息放入缓存
|
|
|
redisThird.setAuthInfo(authorizationInfoResultDTO,customerId,clientType); |
|
|
redisThird.setAuthInfo(authorizationInfoResultDTO,customerId,clientType); |
|
|
//authorizer_refresh_token 放入缓存
|
|
|
//authorizer_refresh_token 放入缓存
|
|
|
@ -338,27 +333,29 @@ public class ComponentVerifyTicketServiceImpl implements ComponentVerifyTicketSe |
|
|
String componentAccessToken = redisThird.getComponentAccessToken(); |
|
|
String componentAccessToken = redisThird.getComponentAccessToken(); |
|
|
String data = HttpClientManager.getInstance().sendPostByJSON(WxMaCodeConstant.API_AUTHORIZER_TOKEN_URL + componentAccessToken, JSON.toJSONString(jsonObject)).getData(); |
|
|
String data = HttpClientManager.getInstance().sendPostByJSON(WxMaCodeConstant.API_AUTHORIZER_TOKEN_URL + componentAccessToken, JSON.toJSONString(jsonObject)).getData(); |
|
|
Map map = JSON.parseObject(data, HashMap.class); |
|
|
Map map = JSON.parseObject(data, HashMap.class); |
|
|
//authorizer_access_token
|
|
|
if (!map.containsKey(ModuleConstant.ERR_CODE)) { |
|
|
String authorizerAccessToken = map.get(ModuleConstant.AUTHORIZER_ACCESS_TOKEN).toString(); |
|
|
log.info(REFRESH_AUTH_ACCESS_TOKEN); |
|
|
String expiresIn = map.get(ModuleConstant.EXPIRES_IN).toString(); |
|
|
String authorizerAccessToken = map.get(ModuleConstant.AUTHORIZER_ACCESS_TOKEN).toString(); |
|
|
String authorizerRefreshToken = map.get(ModuleConstant.AUTHORIZER_REFRESH_TOKEN).toString(); |
|
|
String expiresIn = map.get(ModuleConstant.EXPIRES_IN).toString(); |
|
|
Date expiresInTime = this.countExpirationTime(expiresIn); |
|
|
String authorizerRefreshToken = map.get(ModuleConstant.AUTHORIZER_REFRESH_TOKEN).toString(); |
|
|
//更新DB
|
|
|
Date expiresInTime = this.countExpirationTime(expiresIn); |
|
|
AuthorizerAccessTokenFormDTO formDTO = new AuthorizerAccessTokenFormDTO(); |
|
|
//更新DB
|
|
|
AuthorizationInfoFormDTO authorizationInfo = new AuthorizationInfoFormDTO(); |
|
|
AuthorizerAccessTokenFormDTO formDTO = new AuthorizerAccessTokenFormDTO(); |
|
|
BeanUtils.copyProperties(formDTO,authorizationInfo); |
|
|
AuthorizationInfoFormDTO authorizationInfo = new AuthorizationInfoFormDTO(); |
|
|
authorizationInfo.setAuthorizerAppid(authAppId); |
|
|
BeanUtils.copyProperties(formDTO, authorizationInfo); |
|
|
formDTO.setAuthorizerAccessToken(authorizerAccessToken); |
|
|
authorizationInfo.setAuthorizerAppid(authAppId); |
|
|
formDTO.setAuthorizerRefreshToken(authorizerRefreshToken); |
|
|
formDTO.setAuthorizerAccessToken(authorizerAccessToken); |
|
|
formDTO.setExpiresInTime(expiresInTime); |
|
|
formDTO.setAuthorizerRefreshToken(authorizerRefreshToken); |
|
|
formDTO.setCustomerId(customerId); |
|
|
formDTO.setExpiresInTime(expiresInTime); |
|
|
formDTO.setAuthAppid(authAppId); |
|
|
formDTO.setCustomerId(customerId); |
|
|
//先逻辑删除，在插入
|
|
|
formDTO.setAuthAppid(authAppId); |
|
|
authorizationInfoDao.updateOldAuthorizerAccessToken(willOverDueDTO.getCustomerId(),clientType); |
|
|
formDTO.setClientType(clientType); |
|
|
authorizationInfoDao.insertAuthorizerAccessToken(formDTO); |
|
|
//先逻辑删除，在插入
|
|
|
|
|
|
authorizationInfoDao.updateOldAuthorizerAccessToken(customerId, clientType); |
|
|
//缓存 refreshAuthorizerAccessToken
|
|
|
authorizationInfoDao.insertAuthorizerAccessToken(formDTO); |
|
|
redisThird.setAuthorizerRefreshToken(authorizationInfo); |
|
|
//缓存 refreshAuthorizerAccessToken
|
|
|
|
|
|
redisThird.setAuthorizerRefreshToken(authorizationInfo); |
|
|
|
|
|
} |
|
|
}); |
|
|
}); |
|
|
log.info("更新authorizer_access_token成功"); |
|
|
log.info("更新authorizer_access_token成功"); |
|
|
} |
|
|
} |
|
|
@ -375,27 +372,31 @@ public class ComponentVerifyTicketServiceImpl implements ComponentVerifyTicketSe |
|
|
public void redirectUri(TokenDto tokenDto, @RequestBody AuthCodeAndTimeFromDTO authCodeAndTime){ |
|
|
public void redirectUri(TokenDto tokenDto, @RequestBody AuthCodeAndTimeFromDTO authCodeAndTime){ |
|
|
log.info("开始执行回调URL"); |
|
|
log.info("开始执行回调URL"); |
|
|
String authCode = authCodeAndTime.getAuthCode(); |
|
|
String authCode = authCodeAndTime.getAuthCode(); |
|
|
String client = authCodeAndTime.getClientType(); |
|
|
String clientType = authCodeAndTime.getClientType(); |
|
|
String expiresIn = authCodeAndTime.getExpiresIn(); |
|
|
String expiresIn = authCodeAndTime.getExpiresIn(); |
|
|
String customerId = tokenDto.getCustomerId(); |
|
|
String customerId = this.getLoginUserCustomerId(tokenDto); |
|
|
customerId = "f530774b31e0609a3c7f0f83794cda0c"; |
|
|
|
|
|
Date expiresInTime = this.countExpirationTime(expiresIn); |
|
|
Date expiresInTime = this.countExpirationTime(expiresIn); |
|
|
if (StringUtils.isBlank(customerId)||StringUtils.isBlank(client)||StringUtils.isBlank(authCode)||StringUtils.isBlank(expiresIn)){ |
|
|
|
|
|
log.info("客户ID = "+customerId+", 客户端类型为 = "+client+", 授权码为 = "+authCode+", 有效期 = "+expiresIn); |
|
|
|
|
|
} |
|
|
|
|
|
//authCode存数据库
|
|
|
//authCode存数据库
|
|
|
AuthCodeFormDTO formDTO = new AuthCodeFormDTO(); |
|
|
AuthCodeFormDTO formDTO = new AuthCodeFormDTO(); |
|
|
formDTO.setAuthCode(authCode); |
|
|
formDTO.setAuthCode(authCode); |
|
|
formDTO.setExpiresInTime(expiresInTime); |
|
|
formDTO.setExpiresInTime(expiresInTime); |
|
|
formDTO.setClientType(client); |
|
|
formDTO.setClientType(clientType); |
|
|
//授权方AppId
|
|
|
|
|
|
formDTO.setCustomerId(customerId); |
|
|
formDTO.setCustomerId(customerId); |
|
|
log.info(formDTO.toString()); |
|
|
log.info(formDTO.toString()); |
|
|
authCodeDao.deleteCustomerAuthCode(customerId,client); |
|
|
authCodeDao.deleteCustomerAuthCode(customerId,clientType); |
|
|
authCodeDao.insertRedirectAuthCode(formDTO); |
|
|
authCodeDao.insertRedirectAuthCode(formDTO); |
|
|
//authCode存缓存
|
|
|
//authCode存缓存
|
|
|
redisThird.setAuthCode(formDTO); |
|
|
redisThird.setAuthCode(formDTO); |
|
|
this.authInfoByAuthCode(authCode, customerId,client); |
|
|
// 1. 开始获取授权信息（使用授权码）
|
|
|
|
|
|
AuthorizationInfoResultDTO authorizationInfoResultDTO = this.authInfoByAuthCode(authCode, customerId, clientType); |
|
|
|
|
|
String authAppId = authorizationInfoResultDTO.getAuthorizer_appid(); |
|
|
|
|
|
// 2. 创建开放平台账号并绑定 或者 直接绑定开放平台
|
|
|
|
|
|
this.createAndBindOpenAccount(customerId,authAppId,clientType); |
|
|
|
|
|
// 3. 更新 customer_mp 表授权状态和AuthAppId
|
|
|
|
|
|
this.updateCustomerMpAppId(customerId,authAppId,clientType); |
|
|
|
|
|
authCodeDao.updateAppId(customerId,clientType,authAppId); |
|
|
|
|
|
// 4. 保存授权方账户信息
|
|
|
|
|
|
this.saveAuthAccountInfo(customerId,authAppId,clientType); |
|
|
log.info("回调结束"); |
|
|
log.info("回调结束"); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
@ -456,18 +457,20 @@ public class ComponentVerifyTicketServiceImpl implements ComponentVerifyTicketSe |
|
|
//todo 小程序配置的类目信息插入
|
|
|
//todo 小程序配置的类目信息插入
|
|
|
List<MiniCategoryInfoFormDTO> categoryInfoList = new ArrayList<>(); |
|
|
List<MiniCategoryInfoFormDTO> categoryInfoList = new ArrayList<>(); |
|
|
List<Map> categories = (List<Map>) miniProgramInfo.get(ModuleConstant.CATEGORIES); |
|
|
List<Map> categories = (List<Map>) miniProgramInfo.get(ModuleConstant.CATEGORIES); |
|
|
categories.forEach(category -> { |
|
|
if (categories.size() != NumConstant.ZERO) { |
|
|
category.forEach((key,value) -> { |
|
|
categories.forEach(category -> { |
|
|
MiniCategoryInfoFormDTO categoryInfo = new MiniCategoryInfoFormDTO(); |
|
|
category.forEach((key, value) -> { |
|
|
categoryInfo.setCustomerId(customerId); |
|
|
MiniCategoryInfoFormDTO categoryInfo = new MiniCategoryInfoFormDTO(); |
|
|
categoryInfo.setClientType(clientType); |
|
|
categoryInfo.setCustomerId(customerId); |
|
|
categoryInfo.setCategorySort(key.toString()); |
|
|
categoryInfo.setClientType(clientType); |
|
|
categoryInfo.setCategoryName(value.toString()); |
|
|
categoryInfo.setCategorySort(key.toString()); |
|
|
categoryInfo.setPrimaryId(primaryId); |
|
|
categoryInfo.setCategoryName(value.toString()); |
|
|
categoryInfoList.add(categoryInfo); |
|
|
categoryInfo.setPrimaryId(primaryId); |
|
|
|
|
|
categoryInfoList.add(categoryInfo); |
|
|
|
|
|
}); |
|
|
}); |
|
|
}); |
|
|
}); |
|
|
miniCategoryInfoDao.insertCategoryInfo(categoryInfoList); |
|
|
miniCategoryInfoDao.insertCategoryInfo(categoryInfoList); |
|
|
} |
|
|
}else { |
|
|
}else { |
|
|
log.info("授权方为公众号 并 开始插入信息"); |
|
|
log.info("授权方为公众号 并 开始插入信息"); |
|
|
PaInfoFormDTO paInfoFormDTO = this.mapToEntity(authorizerInfo, PaInfoFormDTO.class); |
|
|
PaInfoFormDTO paInfoFormDTO = this.mapToEntity(authorizerInfo, PaInfoFormDTO.class); |
|
|
@ -493,89 +496,107 @@ public class ComponentVerifyTicketServiceImpl implements ComponentVerifyTicketSe |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|
* @Description 1.创建开放平台账号并绑定 2.回填 customer_mp appId |
|
|
* @Description 回填 customer_mp appId , 更改授权状态 |
|
|
* @param |
|
|
* @param |
|
|
* @author zxc |
|
|
* @author zxc |
|
|
*/ |
|
|
*/ |
|
|
@Transactional(rollbackFor = Exception.class) |
|
|
@Transactional(rollbackFor = Exception.class) |
|
|
public void updateCustomerMpAppIdAndCreateOpenPlatform(String customerId,String authAppId,String clientType){ |
|
|
public void updateCustomerMpAppId(String customerId,String authAppId,String clientType){ |
|
|
log.info("开始创建开放平台账号并绑定"); |
|
|
log.info("==========回填customer_mp开始=========="); |
|
|
Integer authCount = customerMpDao.selectAuthCount(customerId); |
|
|
Integer checkBindCount = customerMpDao.checkBind(authAppId, clientType); |
|
|
String openPlatformId = null; |
|
|
if (checkBindCount == NumConstant.ZERO) { |
|
|
|
|
|
AuthCodeFormDTO formDTO = new AuthCodeFormDTO(); |
|
|
|
|
|
formDTO.setClientType(clientType); |
|
|
|
|
|
formDTO.setAuthAppId(authAppId); |
|
|
|
|
|
formDTO.setCustomerId(customerId); |
|
|
|
|
|
//回填customer_mp的appId 只需以上三个字段
|
|
|
|
|
|
customerMpDao.updateAppIDByCustomerIdAndClient(formDTO); |
|
|
|
|
|
} |
|
|
|
|
|
log.info("==========回填customer_mp结束=========="); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
public void createAndBindOpenAccount(String customerId,String authAppId,String clientType){ |
|
|
Map<String, Object> authorizerRefreshToken = redisThird.getAuthorizerRefreshToken(customerId + ThirdRedisKeyConstant.COLON + clientType); |
|
|
Map<String, Object> authorizerRefreshToken = redisThird.getAuthorizerRefreshToken(customerId + ThirdRedisKeyConstant.COLON + clientType); |
|
|
String authorizerAccessToken = authorizerRefreshToken.get("authorizerAccessToken").toString(); |
|
|
String authorizerAccessToken = authorizerRefreshToken.get("authorizerAccessToken").toString(); |
|
|
if (authCount==NumConstant.ZERO){ |
|
|
JSONObject bindInfoForm = new JSONObject(); |
|
|
log.info("未查询到该客户授权信息，先创建开放平台账号，再绑定"); |
|
|
bindInfoForm.put(ModuleConstant.LOW_APP_ID,authAppId); |
|
|
//没有任何一个小程序/公众号授权,【先创建，再绑定】
|
|
|
String bindResult = HttpClientManager.getInstance().sendPostByJSON(WxMaCodeConstant.API_OPEN_GET + authorizerAccessToken, JSON.toJSONString(bindInfoForm)).getData(); |
|
|
JSONObject jsonObject = new JSONObject(); |
|
|
Map<String,Object> bindInfo = JSON.parseObject(bindResult, Map.class); |
|
|
jsonObject.put(ModuleConstant.LOW_APP_ID,authAppId); |
|
|
boolean bindStatus = bindInfo.containsKey(ModuleConstant.OPEN_APP_ID); |
|
|
// 此处的 access_token 为 【authorizer_access_token】
|
|
|
if (bindStatus != true) { |
|
|
String data = HttpClientManager.getInstance().sendPostByJSON(WxMaCodeConstant.API_CREATE_OPEN + authorizerAccessToken, JSON.toJSONString(jsonObject)).getData(); |
|
|
log.info(CREATE_AND_BIND_SUCCESS); |
|
|
Map<String,String> map = JSON.parseObject(data, Map.class); |
|
|
List<String> authCount = customerMpDao.selectAuthCount(customerId); |
|
|
CreateOpenResultDTO createOpen = new CreateOpenResultDTO(); |
|
|
String openPlatformId = null; |
|
|
createOpen.setErrCode(Integer.valueOf(map.get(ModuleConstant.ERR_CODE))); |
|
|
if (authCount.size() > 0) { |
|
|
createOpen.setErrMsg(map.get(ModuleConstant.ERR_MSG)); |
|
|
openPlatformId = openPlatformAccountDao.selectOpenAppIdByCustomerId(customerId); |
|
|
createOpen.setOpenAppId(map.get(ModuleConstant.OPEN_APP_ID)); |
|
|
|
|
|
switch (createOpen.getErrCode()){ |
|
|
|
|
|
case NumConstant.ONE: |
|
|
|
|
|
log.info(CREATE_AND_BIND_SUCCESS); |
|
|
|
|
|
break; |
|
|
|
|
|
case NumConstant.ONE_NEG: |
|
|
|
|
|
throw new RenException(SYSTEM_ERROR); |
|
|
|
|
|
case ModuleConstant.FORTY_THOUSAND_AND_THIRTEEN: |
|
|
|
|
|
throw new RenException(INVALID_APP_ID); |
|
|
|
|
|
case ModuleConstant.EIGHTY_NINE_THOUSAND: |
|
|
|
|
|
throw new RenException(ACCOUNT_HAS_BOUND_OPEN); |
|
|
|
|
|
} |
|
|
} |
|
|
CreateOpenFormDTO coForm = new CreateOpenFormDTO(); |
|
|
if (authCount.size() == NumConstant.ZERO) { |
|
|
coForm.setOpenid(map.get(ModuleConstant.OPEN_APP_ID)); |
|
|
log.info("未查询到该客户授权信息，先创建开放平台账号，再绑定"); |
|
|
coForm.setCustomerId(customerId); |
|
|
//没有任何一个小程序/公众号授权,【先创建，再绑定】
|
|
|
//插入 open_platform_account 表
|
|
|
JSONObject jsonObject = new JSONObject(); |
|
|
openPlatformAccountDao.insertOpenPlatFormAccount(coForm); |
|
|
jsonObject.put(ModuleConstant.LOW_APP_ID, authAppId); |
|
|
openPlatformId = coForm.getId(); |
|
|
// 此处的 access_token 为 【authorizer_access_token】
|
|
|
}else if (authCount>NumConstant.ZERO){ |
|
|
String data = HttpClientManager.getInstance().sendPostByJSON(WxMaCodeConstant.API_CREATE_OPEN + authorizerAccessToken, JSON.toJSONString(jsonObject)).getData(); |
|
|
log.info("该客户已创建过开放平台账号，直接绑定"); |
|
|
Map<String, Object> map = JSON.parseObject(data, Map.class); |
|
|
String openAppId = openPlatformAccountDao.selectOpenAppIdByCustomerId(customerId); |
|
|
openPlatformId = map.get(ModuleConstant.OPEN_APP_ID).toString(); |
|
|
JSONObject jsonObject = new JSONObject(); |
|
|
CreateOpenResultDTO createOpen = new CreateOpenResultDTO(); |
|
|
jsonObject.put(ModuleConstant.LOW_APP_ID,componentAppId); |
|
|
createOpen.setErrCode((Integer) map.get(ModuleConstant.ERR_CODE)); |
|
|
jsonObject.put(ModuleConstant.OPEN_APP_ID,openAppId); |
|
|
createOpen.setErrMsg(map.get(ModuleConstant.ERR_MSG).toString()); |
|
|
String data = HttpClientManager.getInstance().sendPostByJSON(WxMaCodeConstant.API_BIND_OPEN + authorizerRefreshToken, JSON.toJSONString(jsonObject)).getData(); |
|
|
createOpen.setOpenAppId(map.get(ModuleConstant.OPEN_APP_ID).toString()); |
|
|
Map<String,String> map = JSON.parseObject(data, Map.class); |
|
|
switch (createOpen.getErrCode()) { |
|
|
CreateOpenResultDTO createOpen = new CreateOpenResultDTO(); |
|
|
case NumConstant.ZERO: |
|
|
createOpen.setErrCode(Integer.valueOf(map.get(ModuleConstant.ERR_CODE))); |
|
|
log.info(CREATE_AND_BIND_SUCCESS); |
|
|
createOpen.setErrMsg(map.get(ModuleConstant.ERR_MSG)); |
|
|
CreateOpenFormDTO coForm = new CreateOpenFormDTO(); |
|
|
switch (createOpen.getErrCode()){ |
|
|
coForm.setOpenid(map.get(ModuleConstant.OPEN_APP_ID).toString()); |
|
|
case NumConstant.ONE: |
|
|
coForm.setCustomerId(customerId); |
|
|
log.info(BIND_SUCCESS); |
|
|
//插入 open_platform_account 表
|
|
|
break; |
|
|
openPlatformAccountDao.deleteOldOpenPlatFprmAccount(customerId); |
|
|
case NumConstant.ONE_NEG: |
|
|
openPlatformAccountDao.insertOpenPlatFormAccount(coForm); |
|
|
throw new RenException(SYSTEM_ERROR); |
|
|
break; |
|
|
case ModuleConstant.FORTY_THOUSAND_AND_THIRTEEN: |
|
|
case NumConstant.ONE_NEG: |
|
|
throw new RenException(INVALID_APP_ID); |
|
|
throw new RenException(SYSTEM_ERROR); |
|
|
case ModuleConstant.EIGHTY_NINE_THOUSAND: |
|
|
case ModuleConstant.FORTY_THOUSAND_AND_THIRTEEN: |
|
|
throw new RenException(ACCOUNT_HAS_BOUND_OPEN); |
|
|
throw new RenException(INVALID_APP_ID); |
|
|
case ModuleConstant.EIGHTY_NINE_THOUSAND_AND_ONE: |
|
|
case ModuleConstant.EIGHTY_NINE_THOUSAND: |
|
|
throw new RenException(NOT_SAME_CONTRACTOR); |
|
|
throw new RenException(ACCOUNT_HAS_BOUND_OPEN); |
|
|
case ModuleConstant.EIGHTY_NINE_THOUSAND_AND_THREE: |
|
|
} |
|
|
throw new RenException(NOT_ALLOWED_OPERATE); |
|
|
} else if (authCount.size() > NumConstant.ZERO && !authCount.contains(authAppId)) { |
|
|
case ModuleConstant.EIGHTY_NINE_THOUSAND_AND_FOUR: |
|
|
log.info("该客户已创建过开放平台账号，直接绑定"); |
|
|
throw new RenException(TO_LIMIT); |
|
|
JSONObject jsonObject = new JSONObject(); |
|
|
|
|
|
jsonObject.put(ModuleConstant.LOW_APP_ID, authAppId); |
|
|
|
|
|
jsonObject.put(ModuleConstant.OPEN_APP_ID, openPlatformId); |
|
|
|
|
|
String data = HttpClientManager.getInstance().sendPostByJSON(WxMaCodeConstant.API_BIND_OPEN + authorizerAccessToken, JSON.toJSONString(jsonObject)).getData(); |
|
|
|
|
|
Map<String, Object> map = JSON.parseObject(data, Map.class); |
|
|
|
|
|
CreateOpenResultDTO createOpen = new CreateOpenResultDTO(); |
|
|
|
|
|
createOpen.setErrCode((Integer) map.get(ModuleConstant.ERR_CODE)); |
|
|
|
|
|
createOpen.setErrMsg(map.get(ModuleConstant.ERR_MSG).toString()); |
|
|
|
|
|
switch (createOpen.getErrCode()) { |
|
|
|
|
|
case NumConstant.ZERO: |
|
|
|
|
|
log.info(BIND_SUCCESS); |
|
|
|
|
|
break; |
|
|
|
|
|
case NumConstant.ONE_NEG: |
|
|
|
|
|
throw new RenException(SYSTEM_ERROR); |
|
|
|
|
|
case ModuleConstant.FORTY_THOUSAND_AND_THIRTEEN: |
|
|
|
|
|
throw new RenException(INVALID_APP_ID); |
|
|
|
|
|
case ModuleConstant.EIGHTY_NINE_THOUSAND: |
|
|
|
|
|
throw new RenException(ACCOUNT_HAS_BOUND_OPEN); |
|
|
|
|
|
case ModuleConstant.EIGHTY_NINE_THOUSAND_AND_ONE: |
|
|
|
|
|
throw new RenException(NOT_SAME_CONTRACTOR); |
|
|
|
|
|
case ModuleConstant.EIGHTY_NINE_THOUSAND_AND_THREE: |
|
|
|
|
|
throw new RenException(NOT_ALLOWED_OPERATE); |
|
|
|
|
|
case ModuleConstant.EIGHTY_NINE_THOUSAND_AND_FOUR: |
|
|
|
|
|
throw new RenException(TO_LIMIT); |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
//插入 binding_account
|
|
|
|
|
|
BindingAccountFormDTO bindingAccount = new BindingAccountFormDTO(); |
|
|
|
|
|
bindingAccount.setOpenPlatformAccountId(openPlatformId); |
|
|
|
|
|
bindingAccount.setAuthAppId(authAppId); |
|
|
|
|
|
bindingAccount.setClientType(clientType); |
|
|
|
|
|
bindingAccount.setCustomerId(customerId); |
|
|
|
|
|
bindingAccountDao.insertBindingAccount(bindingAccount); |
|
|
|
|
|
log.info("创建绑定账号结束"); |
|
|
} |
|
|
} |
|
|
AuthCodeFormDTO formDTO = new AuthCodeFormDTO(); |
|
|
|
|
|
formDTO.setClientType(clientType); |
|
|
|
|
|
formDTO.setAuthAppId(authAppId); |
|
|
|
|
|
formDTO.setCustomerId(customerId); |
|
|
|
|
|
//回填customer_mp的appId 只需以上三个字段
|
|
|
|
|
|
customerMpDao.updateAppIDByCustomerIdAndClient(formDTO); |
|
|
|
|
|
//插入 binding_account
|
|
|
|
|
|
BindingAccountFormDTO bindingAccount = new BindingAccountFormDTO(); |
|
|
|
|
|
bindingAccount.setOpenPlatformAccountId(openPlatformId); |
|
|
|
|
|
bindingAccount.setAuthAppId(authAppId); |
|
|
|
|
|
bindingAccount.setClientType(clientType); |
|
|
|
|
|
bindingAccount.setCustomerId(customerId); |
|
|
|
|
|
bindingAccountDao.insertBindingAccount(bindingAccount); |
|
|
|
|
|
log.info("创建绑定账号结束"); |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|
@ -620,4 +641,28 @@ public class ComponentVerifyTicketServiceImpl implements ComponentVerifyTicketSe |
|
|
date.setTime(l); |
|
|
date.setTime(l); |
|
|
return date; |
|
|
return date; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
* @Description 查询客户Id |
|
|
|
|
|
* @param tokenDto |
|
|
|
|
|
* @author zxc |
|
|
|
|
|
*/ |
|
|
|
|
|
public String getLoginUserCustomerId(TokenDto tokenDto){ |
|
|
|
|
|
LoginUserDetailsFormDTO dto = new LoginUserDetailsFormDTO(); |
|
|
|
|
|
BeanUtils.copyProperties(tokenDto,dto); |
|
|
|
|
|
LoginUserDetailsResultDTO data = epmetUserOpenFeignClient.getLoginUserDetails(dto).getData(); |
|
|
|
|
|
return data.getCustomerId(); |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
|
* @Description 时间戳（秒级）转换 Date |
|
|
|
|
|
* @param t |
|
|
|
|
|
* @author zxc |
|
|
|
|
|
*/ |
|
|
|
|
|
public Date sToDate(String t){ |
|
|
|
|
|
Long aLong = Long.valueOf(t + "000"); |
|
|
|
|
|
Date date = new Date(); |
|
|
|
|
|
date.setTime(aLong); |
|
|
|
|
|
return date; |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
|
jianjun
6 years ago