platform / platform-cms · Commits

Go to a project

Authored by csgyoho
Commit 3ad200bae383ea553bfc8fad6916881800a526b0 2 parents 275d6f9a 4c190df7

Merge branch 'dev_grass_20190108' of http://git.yoho.cn/platform/platform-cms in… 

…to dev_grass_20190108
Inline Side-by-side
Showing 10 changed files with 0 additions and 517 deletions
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
<parent>
<artifactId>yohobuy-platform-cms</artifactId>
<groupId>com.yoho.dsf</groupId>
<version>1.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<groupId>com.yoho.dsf.yhplatform</groupId>
<artifactId>platform-cms-mvc</artifactId>
<packaging>jar</packaging>
<name>platform-cms-mvc</name>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.yoho.service.platform.model</groupId>
<artifactId>platform-service-model</artifactId>
</dependency>
<dependency>
<groupId>com.yohobuy.platform</groupId>
<artifactId>platform-common</artifactId>
</dependency>
<dependency>
<groupId>com.yoho.core</groupId>
<artifactId>yoho-core-redis-cluster</artifactId>
</dependency>
</dependencies>
</project>
/**
*
*/
package com.yohobuy.platform.mvc.bean;
import java.util.List;
import com.yoho.tools.common.beans.BaseBean;
/**
* @author ping.huang
* 2016年9月24日
*/
public class ERPProfileRequestBO extends BaseBean {
/**
*
*/
private static final long serialVersionUID = -6299334332126635127L;
private String password;
private String account;
private String auth_site;
private String truename;
private String staff_code;
private String email;
private Integer dept_id;
private Integer role_id;
private Integer create_id;
private Integer pid;
private String phone;
private List<Integer> pIds;
private Integer status;
private Integer pageNo;
private Integer pageSize;
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public String getAccount() {
return account;
}
public void setAccount(String account) {
this.account = account;
}
public String getAuth_site() {
return auth_site;
}
public void setAuth_site(String auth_site) {
this.auth_site = auth_site;
}
public String getTruename() {
return truename;
}
public void setTruename(String truename) {
this.truename = truename;
}
public String getStaff_code() {
return staff_code;
}
public void setStaff_code(String staff_code) {
this.staff_code = staff_code;
}
public String getEmail() {
return email;
}
public void setEmail(String email) {
this.email = email;
}
public Integer getDept_id() {
return dept_id;
}
public void setDept_id(Integer dept_id) {
this.dept_id = dept_id;
}
public Integer getRole_id() {
return role_id;
}
public void setRole_id(Integer role_id) {
this.role_id = role_id;
}
public Integer getCreate_id() {
return create_id;
}
public void setCreate_id(Integer create_id) {
this.create_id = create_id;
}
public Integer getPid() {
return pid;
}
public void setPid(Integer pid) {
this.pid = pid;
}
public String getPhone() {
return phone;
}
public void setPhone(String phone) {
this.phone = phone;
}
public Integer getStatus() {
return status;
}
public void setStatus(Integer status) {
this.status = status;
}
public List<Integer> getpIds() {
return pIds;
}
public void setpIds(List<Integer> pIds) {
this.pIds = pIds;
}
public Integer getPageNo() {
return pageNo;
}
public void setPageNo(Integer pageNo) {
this.pageNo = pageNo;
}
public Integer getPageSize() {
return pageSize;
}
public void setPageSize(Integer pageSize) {
this.pageSize = pageSize;
}
}
/**
*
*/
package com.yohobuy.platform.mvc.controller;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import com.netflix.config.DynamicPropertyFactory;
import com.yoho.core.common.utils.MD5;
import com.yoho.tools.common.beans.Response;
import com.yohobuy.platform.common.enums.CodeEnum;
import com.yohobuy.platform.model.users.response.UserInfoResponseBO;
import com.yohobuy.platform.common.helper.mvc.PlatformConstant;
import com.yohobuy.platform.mvc.service.ILoginService;
import com.yohobuy.platform.common.util.SessionUtil;
/**
* 描述：platform回调cms页面时，验证用户的登录状态
*
*/
@Controller
@RequestMapping("/LoginController")
public class LoginController {
static Logger log = LoggerFactory.getLogger(LoginController.class);
@Resource
ILoginService loginService;
private static String SALT= DynamicPropertyFactory.getInstance().getStringProperty("platform.login.salt", "").get();
@RequestMapping("/loginForPid.do")
public void loginForPid(String pid, String pidMd5, String callbackUrl , HttpServletRequest request, HttpServletResponse response) throws Exception {
log.info("enter login with pid={},pidAes is {},callbackUrl is {}", pid, pidMd5, callbackUrl);
if (StringUtils.isEmpty(pid) || StringUtils.isEmpty(pidMd5)) {
log.warn("loginForPid error. with pid={}, pidMd5={}", pid, pidMd5);
return;
}
UserInfoResponseBO userInfoResponseBO = (UserInfoResponseBO) request.getSession().getAttribute(PlatformConstant.USER_SESSION);
if (null != userInfoResponseBO && pid.equals(userInfoResponseBO.getPid())) {
request.setAttribute("pid", pid);
request.getRequestDispatcher(callbackUrl).forward(request, response);
} else if (pidMd5.equals(MD5.md5(pid + SALT))) {
log.info("loginForPid with session is empty. and login start. with pid={}", pid);
Response<UserInfoResponseBO> responseBO = loginService.loginByPid(pid);
if (responseBO != null && responseBO.getCode() == CodeEnum.SUCCESS.getCode()) {
log.info("loginForPid with session is empty. and login success. with pid={}", pid);
// 登录成功，把用户信息存入redis
SessionUtil.getOpera().setUser(responseBO.getData());
request.setAttribute("pid", pid);
request.getSession().setAttribute(PlatformConstant.USER_SESSION, responseBO.getData());
request.getRequestDispatcher(callbackUrl).forward(request, response);
}
}
}
}
package com.yohobuy.platform.mvc.helper;
import com.alibaba.fastjson.JSONObject;
import com.google.common.collect.Lists;
import com.netflix.config.DynamicPropertyFactory;
import com.yoho.tools.common.beans.Response;
import com.yohobuy.platform.common.enums.CodeEnum;
import com.yohobuy.platform.common.enums.ErpApiEnum;
import com.yohobuy.platform.model.users.response.UserInfoResponseBO;
import com.yohobuy.platform.mvc.bean.ERPProfileRequestBO;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.collections.MapUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
@Component
public class ErpApiServiceHelper {
static Logger log = LoggerFactory.getLogger(ErpApiServiceHelper.class);
@Resource
RestTemplate restTemplate;
private static String ERP_DOMAIN = DynamicPropertyFactory.getInstance().getStringProperty("erp.domain", "").get();
private static String ERP_STORAGE = DynamicPropertyFactory.getInstance().getStringProperty("erp.storage", "").get();
/**
* /account/profile/query_by_id http://192.168.102.47:9098/erp-gateway-web
/service/account/v1/Profile/getAllBrandProfileDataAuthorityApi http://serve.yohobuy.com
/account/profile/query_page http://192.168.102.47:9098/erp-gateway-web
/account/profileDataEntitlement/dataList http://192.168.102.47:9098/erp-gateway-web
*
*/
/**
* 根据pid，查询用户
* @param pid
* @return
*/
@SuppressWarnings("unchecked")
public UserInfoResponseBO getUserByPid(String pid) {
log.info("getUserByPid with pid={}", pid);
ERPProfileRequestBO profile = new ERPProfileRequestBO();
profile.setPid(Integer.parseInt(pid));
Response<Map<String, Object>> resp = restTemplate.postForObject(ERP_DOMAIN + ErpApiEnum.GET_USER_BY_PID.getUrl(), profile, Response.class);
if (resp == null || resp.getCode() != CodeEnum.SUCCESS.getCode()) {
log.warn("getuserbypid error with pid={}", pid);
return null;
}
UserInfoResponseBO user = toSysUserResponse(resp.getData());
return user;
}
/**
* 对象转换
*
* @param map
* @return
*/
private UserInfoResponseBO toSysUserResponse(Map<String, Object> map) {
if (MapUtils.isEmpty(map)) {
return null;
}
UserInfoResponseBO bo = new UserInfoResponseBO();
bo.setCreate_time(MapUtils.getString(map, "create_time"));
bo.setEmail(MapUtils.getString(map, "email"));
bo.setAccount(MapUtils.getString(map, "account"));
bo.setPhone(MapUtils.getString(map, "phone"));
bo.setPid(MapUtils.getString(map, "pid"));
bo.setRole_id(MapUtils.getString(map, "role_id"));
bo.setStatus(MapUtils.getString(map, "status"));
bo.setTruename(MapUtils.getString(map, "truename"));
bo.setAuth_site(MapUtils.getString(map, "auth_site"));
bo.setCreate_date(MapUtils.getString(map, "create_date"));
bo.setCreate_id(MapUtils.getString(map, "create_id"));
bo.setDept_id(MapUtils.getString(map, "dept_id"));
bo.setExpires(MapUtils.getString(map, "expires"));
bo.setIdentity(MapUtils.getString(map, "identity"));
bo.setLogin_time(MapUtils.getString(map, "login_time"));
bo.setLogout_time(MapUtils.getString(map, "logout_time"));
bo.setStaff_code(MapUtils.getString(map, "staff_code"));
return bo;
}
/**
* 北京接口返回：is_all＝ture 说明是全品牌，list就是空；is_all = false 说明不是全品牌 品牌id会在list
* 根据pid，获取用户有品牌权限品牌ID。
* 如果为-1， 不存在，所有品牌都不展示
* 如果为空集合，有所有品牌权限
* 如果不为空 ，有品牌权限品牌ID
*/
public List<Integer> getBrandIds(String pid) {
String url = ERP_STORAGE + "/service/account/v1/Profile/getAllBrandProfileDataAuthorityApi";
try {
Response<Map<String, Object>> response = restTemplate.postForObject(url, "["+pid+"]", Response.class);
log.info("call erp method, url:{} and response:{}.", url, response);
if (response == null || response.getCode() != 200) {
log.warn("call erp method fail, response:{}.",response);
// 所有品牌都不展示
return Lists.newArrayList(-1);
}
Map<String,Object> data= (Map<String,Object>) response.getData();
if ((boolean)data.get("is_all")) {
//有所有品牌权限
return Lists.newArrayList();
}
Object brandIdData = data.get("list");
if (brandIdData instanceof List && ((List)brandIdData).isEmpty()) {
//有所有品牌权限
return Lists.newArrayList();
}
List<Integer> brandIds=Lists.newArrayList();
List<String> brandIdStrs=(List<String>)brandIdData;
for (String brandId : brandIdStrs) {
brandIds.add(Integer.parseInt(brandId));
}
return brandIds;
} catch (Exception e) {
log.error("call erp method fail, url:{} and error message:{}.", url, e.getMessage());
// 所有品牌都不展示
return Lists.newArrayList(-1);
}
}
//根据pid获取店铺权限
public List<Integer> getShopIds(String pid) {
String url = ERP_DOMAIN + "/account/profileDataEntitlement/dataList";
List<Integer> list = new ArrayList<>();
try{
JSONObject req = new JSONObject();
req.put("pid",Integer.valueOf(pid));
req.put("type",2);
Response<Map<String, Object>> response = restTemplate.postForObject(url, req, Response.class);
log.info("getShopIds erp method, url:{} and response:{}.", url, response);
if(response.getCode() != 200){
log.warn("call erp method fail, response:{}.",response);
return Lists.newArrayList(-1);
}
Map<String,Object> shopsMap = response.getData();
boolean isAll = (boolean) shopsMap.get("isAll");
if(isAll){
//如果是全部权限，这是权限空
return list;
}
List<Map> shopList = (List) shopsMap.get("businessList");
if (CollectionUtils.isEmpty(shopList)) {
return Lists.newArrayList(-1);
}
for (Map m : shopList){
list.add(MapUtils.getInteger(m,"id"));
}
}catch (Exception e){
log.info("get shopids from erp-gateway-wab error e={}",e.getMessage());
return Lists.newArrayList(-1);
}
return list;
}
}
/**
*
*/
package com.yohobuy.platform.mvc.service;
import com.yoho.tools.common.beans.Response;
import com.yohobuy.platform.model.users.response.UserInfoResponseBO;
/**
* @author ping.huang
* 2016年8月1日
*/
public interface ILoginService {
Response<UserInfoResponseBO> loginByPid(String pid);
}
/**
*
*/
package com.yohobuy.platform.mvc.service.impl;
import java.util.List;
import javax.annotation.Resource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;
import com.yoho.tools.common.beans.Response;
import com.yohobuy.platform.model.users.response.UserInfoResponseBO;
import com.yohobuy.platform.mvc.helper.ErpApiServiceHelper;
import com.yohobuy.platform.mvc.service.ILoginService;
/**
* @author ping.huang
* 2016年8月1日
*/
@Service
public class LoginServiceImpl implements ILoginService {
static Logger log = LoggerFactory.getLogger(LoginServiceImpl.class);
@Resource
ErpApiServiceHelper erpApiServiceHelper;
@Override
public Response<UserInfoResponseBO> loginByPid(String pid) {
log.info("loginByPid with pid is {}.", pid);
UserInfoResponseBO user = erpApiServiceHelper.getUserByPid(pid);
if(user == null){
return new Response<>();
}
List<Integer> brandIds = erpApiServiceHelper.getBrandIds(pid);
user.setBrandIds(brandIds);
List<Integer> shopIds = erpApiServiceHelper.getShopIds(pid);
user.setShopIds(shopIds);
log.info("loginByPid userInfoResponseBO is {}.", user);
return new Response<>(user);
}
}
package org.mvc;
import junit.framework.Test;
import junit.framework.TestCase;
import junit.framework.TestSuite;
/**
* Unit test for simple App.
*/
public class AppTest
extends TestCase
{
/**
* Create the test case
*
* @param testName name of the test case
*/
public AppTest( String testName )
{
}
/**
* @return the suite of tests being tested
*/
public static Test suite()
{
return new TestSuite( AppTest.class );
}
/**
* Rigourous Test :-)
*/
public void testApp()
{
assertTrue( true );
}
}
... ... @@ -28,11 +28,6 @@
</dependency>
<dependency>
<groupId>com.yoho.dsf.yhplatform</groupId>
<artifactId>platform-cms-mvc</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.yoho.dsf.yhplatform</groupId>
<artifactId>platform-cms-cms</artifactId>
<version>${project.version}</version>
</dependency>
... ... @@ -87,7 +82,6 @@
</dependencies>
<modules>
<module>mvc</module>
<module>cms</module>
<module>suggest</module>
<module>operations</module>
... ...
... ... @@ -25,10 +25,6 @@
</dependency>
<dependency>
<groupId>com.yoho.dsf.yhplatform</groupId>
<artifactId>platform-cms-mvc</artifactId>
</dependency>
<dependency>
<groupId>com.yoho.dsf.yhplatform</groupId>
<artifactId>platform-cms-operations</artifactId>
</dependency>
<dependency>
... ...