|
|
@@ -1,162 +1,162 @@
|
|
|
-//package com.fdkankan.scene.Interceptor;
|
|
|
-//
|
|
|
-//import cn.hutool.http.HttpUtil;
|
|
|
-//import com.alibaba.fastjson.JSON;
|
|
|
-//import com.alibaba.fastjson.JSONArray;
|
|
|
-//import com.alibaba.fastjson.JSONObject;
|
|
|
-//import com.fdkankan.common.util.ThreeDESUtil;
|
|
|
-//import com.fdkankan.common.util.UserAgentUtils;
|
|
|
-//import com.fdkankan.common.util.WebUtil;
|
|
|
-//import com.fdkankan.common.exception.BusinessException;
|
|
|
-//import com.fdkankan.feign.TietaFeignClient;
|
|
|
-//import com.fdkankan.feign.WS4AServiceClient;
|
|
|
-//import com.fdkankan.scene.entity.SceneViewLog;
|
|
|
-//import com.fdkankan.scene.service.SceneViewLogService;
|
|
|
-//import lombok.extern.log4j.Log4j2;
|
|
|
-//import org.aspectj.lang.JoinPoint;
|
|
|
-//import org.aspectj.lang.annotation.Aspect;
|
|
|
-//import org.aspectj.lang.annotation.Before;
|
|
|
-//import org.aspectj.lang.annotation.Pointcut;
|
|
|
-//import org.springframework.beans.factory.annotation.Autowired;
|
|
|
-//import org.springframework.beans.factory.annotation.Value;
|
|
|
-//import org.springframework.core.annotation.Order;
|
|
|
-//import org.springframework.stereotype.Component;
|
|
|
-//import org.springframework.web.context.request.RequestContextHolder;
|
|
|
-//import org.springframework.web.context.request.ServletRequestAttributes;
|
|
|
-//
|
|
|
-//import javax.annotation.Resource;
|
|
|
-//import javax.servlet.http.HttpServletRequest;
|
|
|
-//import java.io.IOException;
|
|
|
-//import java.util.Date;
|
|
|
-//import java.util.HashMap;
|
|
|
-//import java.util.Map;
|
|
|
-//
|
|
|
-//@Log4j2
|
|
|
-//@Aspect
|
|
|
-//@Component
|
|
|
-//@Order(101)
|
|
|
-//public class ViewLogAspect {
|
|
|
-//
|
|
|
-// @Value("${spring.cloud.nacos.discovery.access-key}")
|
|
|
-// private String accessKey;
|
|
|
-//
|
|
|
-// @Value("${tieta.checkToken.syscode}")
|
|
|
-// private String syscode;
|
|
|
-// @Value("${gateway.key:6#dPz>3F}")
|
|
|
-// private String gatewayKey;
|
|
|
-// @Value("${gateway.url}")
|
|
|
-// private String gatewayUrl;
|
|
|
-// @Resource
|
|
|
-// private TietaFeignClient tietaFeignClient;
|
|
|
-// @Autowired
|
|
|
-// private WS4AServiceClient ws4AServiceClient;
|
|
|
-// @Autowired
|
|
|
-// private SceneViewLogService sceneViewLogService;
|
|
|
-//
|
|
|
-// @Pointcut("@annotation(com.fdkankan.scene.annotation.VrLog)")
|
|
|
-// public void checkCooperationPermit() {
|
|
|
-// }
|
|
|
-//
|
|
|
-// /**
|
|
|
-// * 前置通知 用于判断用户协作场景是否有协作权限
|
|
|
-// *
|
|
|
-// * @param joinPoint
|
|
|
-// * 切点
|
|
|
-// * @throws IOException
|
|
|
-// */
|
|
|
-// @Before("checkCooperationPermit()")
|
|
|
-// public void doBefore(JoinPoint joinPoint) throws Exception {
|
|
|
-// log.info("记录日志开始");
|
|
|
-// HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
|
|
|
-// boolean mobileDevice = UserAgentUtils.isMobileDevice(request);
|
|
|
-// String userAgent = "pc";
|
|
|
-// if(mobileDevice){
|
|
|
-// userAgent = "mobile";
|
|
|
-// }
|
|
|
-//
|
|
|
-// //请求4a接口获取用户信息
|
|
|
-// Map<String, Object> parameter = WebUtil.getParameter(joinPoint, request);
|
|
|
-// String acctId = (String) parameter.get("acctId");
|
|
|
-// String token = (String) parameter.get("token");
|
|
|
-// String num = (String) parameter.get("num");
|
|
|
-//
|
|
|
-// //token校验
|
|
|
-// JSONObject checkProwadaTokenParam = new JSONObject();
|
|
|
-// JSONObject params = new JSONObject();
|
|
|
-// params.put("SYSCODE", syscode);
|
|
|
-// params.put("ACCTID", acctId);
|
|
|
-// params.put("TOKEN", token);
|
|
|
-// String encode = ThreeDESUtil.encode(JSON.toJSONString(params), gatewayKey);
|
|
|
-// checkProwadaTokenParam.put("args", encode);
|
|
|
-// JSONObject result = ws4AServiceClient.checkProwadaToken(checkProwadaTokenParam);
|
|
|
-// log.info("场景：{},4A校验token结果:{}", num, result);
|
|
|
-// if(!"SUCCESS".equals(result.getString("resultStat"))){
|
|
|
-// throw new BusinessException(4000, "4A鉴权失败");
|
|
|
-// }
|
|
|
-// String data = result.getString("data");
|
|
|
-// JSONObject dataObj = JSONObject.parseObject(data);
|
|
|
-// if(!"0".equals(dataObj.getString("RSP"))){
|
|
|
-// throw new BusinessException(4000, "4A鉴权失败:" + dataObj.getString("ERRDESC"));
|
|
|
-// }
|
|
|
-// String USERCODE = dataObj.getString("USERCODE");
|
|
|
-// String SERVICEID = dataObj.getString("SERVICEID");
|
|
|
-// String ORGCODE = dataObj.getString("ORGCODE");
|
|
|
-//
|
|
|
-// //查询用户信息
|
|
|
-// JSONObject param2 = new JSONObject();
|
|
|
-// param2.put("SERVICEID", SERVICEID);
|
|
|
-// param2.put("LOGINACCOUNT", USERCODE);
|
|
|
-// param2.put("TOKEN", token);
|
|
|
-// encode = ThreeDESUtil.encode(JSON.toJSONString(param2), gatewayKey);
|
|
|
-// Map<String, Object> param = new HashMap<>();
|
|
|
-// param.put("args", encode);
|
|
|
-// String queryLoginUserInfoResp = HttpUtil.get(gatewayUrl + "/QUERY4A/user/queryLoginUserInfo?args=" + encode);
|
|
|
-// result = JSON.parseObject(queryLoginUserInfoResp);
|
|
|
-//// result = ws4AServiceClient.queryLoginUserInfo(encode);
|
|
|
-// log.info("场景：{},4A查询用户信息结果:{}", num, result);
|
|
|
-// if(!"SUCCESS".equals(result.getString("resultStat"))){
|
|
|
-// throw new BusinessException(4000, "4A查询用户信息失败");
|
|
|
-// }
|
|
|
-// data = result.getString("data");
|
|
|
-// dataObj = JSONObject.parseObject(data);
|
|
|
-// if(!"0".equals(dataObj.getString("RSP"))){
|
|
|
-// throw new BusinessException(4000, "4A查询用户信息失败:" + dataObj.getString("ERRDESC"));
|
|
|
-// }
|
|
|
-// String nickName = dataObj.getString("LOGINNAME");
|
|
|
-//
|
|
|
-// JSONObject param3 = new JSONObject();
|
|
|
-// param3.put("SERVICEID", SERVICEID);
|
|
|
-// param3.put("QUERYMODE", "3");
|
|
|
-// param3.put("ORGCODE", ORGCODE);
|
|
|
-// param3.put("TOKEN", token);
|
|
|
-// encode = ThreeDESUtil.encode(JSON.toJSONString(param3), gatewayKey);
|
|
|
-//// result = ws4AServiceClient.queryOrgs(encode);
|
|
|
-// String queryOrgsResp = HttpUtil.get(gatewayUrl + "/QUERY4A/query/queryOrgs?args=" + encode);
|
|
|
-// result = JSON.parseObject(queryOrgsResp);
|
|
|
-// log.info("场景：{},4A查询用户组织结果:{}", num, result);
|
|
|
-// if(!"SUCCESS".equals(result.getString("resultStat"))){
|
|
|
-// throw new BusinessException(4000, "查询用户组织失败");
|
|
|
-// }
|
|
|
-// data = result.getString("data");
|
|
|
-// dataObj = JSONObject.parseObject(data);
|
|
|
-// if(!"0".equals(dataObj.getString("RSP"))){
|
|
|
-// throw new BusinessException(4000, "4A查询用户组织失败:" + dataObj.getString("ERRDESC"));
|
|
|
-// }
|
|
|
-// JSONObject ORGS = dataObj.getJSONObject("ORGS");
|
|
|
-// JSONArray ORG = ORGS.getJSONArray("ORG");
|
|
|
-// JSONObject ORG1 = ORG.getJSONObject(0);
|
|
|
-// String ORGNAMEPATH = ORG1.getString("ORGNAMEPATH");
|
|
|
-//
|
|
|
-// //写入表
|
|
|
-// SceneViewLog sceneViewLog = new SceneViewLog();
|
|
|
-// sceneViewLog.setOrgNamePath(ORGNAMEPATH);
|
|
|
-// sceneViewLog.setFuncName("VR全景");
|
|
|
-// sceneViewLog.setFuncDesc("VR全景试图");
|
|
|
-// sceneViewLog.setUserName(USERCODE);
|
|
|
-// sceneViewLog.setNickName(nickName);
|
|
|
-// sceneViewLog.setCreateTime(new Date());
|
|
|
-// sceneViewLog.setTerminalType(userAgent);
|
|
|
-// sceneViewLogService.save(sceneViewLog);
|
|
|
-// }
|
|
|
-//
|
|
|
-//}
|
|
|
+package com.fdkankan.scene.Interceptor;
|
|
|
+
|
|
|
+import cn.hutool.http.HttpUtil;
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
+import com.alibaba.fastjson.JSONArray;
|
|
|
+import com.alibaba.fastjson.JSONObject;
|
|
|
+import com.fdkankan.common.util.ThreeDESUtil;
|
|
|
+import com.fdkankan.common.util.UserAgentUtils;
|
|
|
+import com.fdkankan.common.util.WebUtil;
|
|
|
+import com.fdkankan.common.exception.BusinessException;
|
|
|
+import com.fdkankan.feign.TietaFeignClient;
|
|
|
+import com.fdkankan.feign.WS4AServiceClient;
|
|
|
+import com.fdkankan.scene.entity.SceneViewLog;
|
|
|
+import com.fdkankan.scene.service.SceneViewLogService;
|
|
|
+import lombok.extern.log4j.Log4j2;
|
|
|
+import org.aspectj.lang.JoinPoint;
|
|
|
+import org.aspectj.lang.annotation.Aspect;
|
|
|
+import org.aspectj.lang.annotation.Before;
|
|
|
+import org.aspectj.lang.annotation.Pointcut;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.beans.factory.annotation.Value;
|
|
|
+import org.springframework.core.annotation.Order;
|
|
|
+import org.springframework.stereotype.Component;
|
|
|
+import org.springframework.web.context.request.RequestContextHolder;
|
|
|
+import org.springframework.web.context.request.ServletRequestAttributes;
|
|
|
+
|
|
|
+import javax.annotation.Resource;
|
|
|
+import javax.servlet.http.HttpServletRequest;
|
|
|
+import java.io.IOException;
|
|
|
+import java.util.Date;
|
|
|
+import java.util.HashMap;
|
|
|
+import java.util.Map;
|
|
|
+
|
|
|
+@Log4j2
|
|
|
+@Aspect
|
|
|
+@Component
|
|
|
+@Order(101)
|
|
|
+public class ViewLogAspect {
|
|
|
+
|
|
|
+ @Value("${spring.cloud.nacos.discovery.access-key}")
|
|
|
+ private String accessKey;
|
|
|
+
|
|
|
+ @Value("${tieta.checkToken.syscode}")
|
|
|
+ private String syscode;
|
|
|
+ @Value("${gateway.key:6#dPz>3F}")
|
|
|
+ private String gatewayKey;
|
|
|
+ @Value("${gateway.url}")
|
|
|
+ private String gatewayUrl;
|
|
|
+ @Resource
|
|
|
+ private TietaFeignClient tietaFeignClient;
|
|
|
+ @Autowired
|
|
|
+ private WS4AServiceClient ws4AServiceClient;
|
|
|
+ @Autowired
|
|
|
+ private SceneViewLogService sceneViewLogService;
|
|
|
+
|
|
|
+ @Pointcut("@annotation(com.fdkankan.scene.annotation.VrLog)")
|
|
|
+ public void checkCooperationPermit() {
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 前置通知 用于判断用户协作场景是否有协作权限
|
|
|
+ *
|
|
|
+ * @param joinPoint
|
|
|
+ * 切点
|
|
|
+ * @throws IOException
|
|
|
+ */
|
|
|
+ @Before("checkCooperationPermit()")
|
|
|
+ public void doBefore(JoinPoint joinPoint) throws Exception {
|
|
|
+ log.info("记录日志开始");
|
|
|
+ HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
|
|
|
+ boolean mobileDevice = UserAgentUtils.isMobileDevice(request);
|
|
|
+ String userAgent = "pc";
|
|
|
+ if(mobileDevice){
|
|
|
+ userAgent = "mobile";
|
|
|
+ }
|
|
|
+
|
|
|
+ //请求4a接口获取用户信息
|
|
|
+ Map<String, Object> parameter = WebUtil.getParameter(joinPoint, request);
|
|
|
+ String acctId = (String) parameter.get("acctId");
|
|
|
+ String token = (String) parameter.get("token");
|
|
|
+ String num = (String) parameter.get("num");
|
|
|
+
|
|
|
+ //token校验
|
|
|
+ JSONObject checkProwadaTokenParam = new JSONObject();
|
|
|
+ JSONObject params = new JSONObject();
|
|
|
+ params.put("SYSCODE", syscode);
|
|
|
+ params.put("ACCTID", acctId);
|
|
|
+ params.put("TOKEN", token);
|
|
|
+ String encode = ThreeDESUtil.encode(JSON.toJSONString(params), gatewayKey);
|
|
|
+ checkProwadaTokenParam.put("args", encode);
|
|
|
+ JSONObject result = ws4AServiceClient.checkProwadaToken(checkProwadaTokenParam);
|
|
|
+ log.info("场景：{},4A校验token结果:{}", num, result);
|
|
|
+ if(!"SUCCESS".equals(result.getString("resultStat"))){
|
|
|
+ throw new BusinessException(4000, "4A鉴权失败");
|
|
|
+ }
|
|
|
+ String data = result.getString("data");
|
|
|
+ JSONObject dataObj = JSONObject.parseObject(data);
|
|
|
+ if(!"0".equals(dataObj.getString("RSP"))){
|
|
|
+ throw new BusinessException(4000, "4A鉴权失败:" + dataObj.getString("ERRDESC"));
|
|
|
+ }
|
|
|
+ String USERCODE = dataObj.getString("USERCODE");
|
|
|
+ String SERVICEID = dataObj.getString("SERVICEID");
|
|
|
+ String ORGCODE = dataObj.getString("ORGCODE");
|
|
|
+
|
|
|
+ //查询用户信息
|
|
|
+ JSONObject param2 = new JSONObject();
|
|
|
+ param2.put("SERVICEID", SERVICEID);
|
|
|
+ param2.put("LOGINACCOUNT", USERCODE);
|
|
|
+ param2.put("TOKEN", token);
|
|
|
+ encode = ThreeDESUtil.encode(JSON.toJSONString(param2), gatewayKey);
|
|
|
+ Map<String, Object> param = new HashMap<>();
|
|
|
+ param.put("args", encode);
|
|
|
+ String queryLoginUserInfoResp = HttpUtil.get(gatewayUrl + "/QUERY4A/user/queryLoginUserInfo?args=" + encode);
|
|
|
+ result = JSON.parseObject(queryLoginUserInfoResp);
|
|
|
+// result = ws4AServiceClient.queryLoginUserInfo(encode);
|
|
|
+ log.info("场景：{},4A查询用户信息结果:{}", num, result);
|
|
|
+ if(!"SUCCESS".equals(result.getString("resultStat"))){
|
|
|
+ throw new BusinessException(4000, "4A查询用户信息失败");
|
|
|
+ }
|
|
|
+ data = result.getString("data");
|
|
|
+ dataObj = JSONObject.parseObject(data);
|
|
|
+ if(!"0".equals(dataObj.getString("RSP"))){
|
|
|
+ throw new BusinessException(4000, "4A查询用户信息失败:" + dataObj.getString("ERRDESC"));
|
|
|
+ }
|
|
|
+ String nickName = dataObj.getString("LOGINNAME");
|
|
|
+
|
|
|
+ JSONObject param3 = new JSONObject();
|
|
|
+ param3.put("SERVICEID", SERVICEID);
|
|
|
+ param3.put("QUERYMODE", "3");
|
|
|
+ param3.put("ORGCODE", ORGCODE);
|
|
|
+ param3.put("TOKEN", token);
|
|
|
+ encode = ThreeDESUtil.encode(JSON.toJSONString(param3), gatewayKey);
|
|
|
+// result = ws4AServiceClient.queryOrgs(encode);
|
|
|
+ String queryOrgsResp = HttpUtil.get(gatewayUrl + "/QUERY4A/query/queryOrgs?args=" + encode);
|
|
|
+ result = JSON.parseObject(queryOrgsResp);
|
|
|
+ log.info("场景：{},4A查询用户组织结果:{}", num, result);
|
|
|
+ if(!"SUCCESS".equals(result.getString("resultStat"))){
|
|
|
+ throw new BusinessException(4000, "查询用户组织失败");
|
|
|
+ }
|
|
|
+ data = result.getString("data");
|
|
|
+ dataObj = JSONObject.parseObject(data);
|
|
|
+ if(!"0".equals(dataObj.getString("RSP"))){
|
|
|
+ throw new BusinessException(4000, "4A查询用户组织失败:" + dataObj.getString("ERRDESC"));
|
|
|
+ }
|
|
|
+ JSONObject ORGS = dataObj.getJSONObject("ORGS");
|
|
|
+ JSONArray ORG = ORGS.getJSONArray("ORG");
|
|
|
+ JSONObject ORG1 = ORG.getJSONObject(0);
|
|
|
+ String ORGNAMEPATH = ORG1.getString("ORGNAMEPATH");
|
|
|
+
|
|
|
+ //写入表
|
|
|
+ SceneViewLog sceneViewLog = new SceneViewLog();
|
|
|
+ sceneViewLog.setOrgNamePath(ORGNAMEPATH);
|
|
|
+ sceneViewLog.setFuncName("VR全景");
|
|
|
+ sceneViewLog.setFuncDesc("VR全景试图");
|
|
|
+ sceneViewLog.setUserName(USERCODE);
|
|
|
+ sceneViewLog.setNickName(nickName);
|
|
|
+ sceneViewLog.setCreateTime(new Date());
|
|
|
+ sceneViewLog.setTerminalType(userAgent);
|
|
|
+ sceneViewLogService.save(sceneViewLog);
|
|
|
+ }
|
|
|
+
|
|
|
+}
|
dengsixing