保存权限组开发完成待测试

wuxw

2019-04-08 baf7e0aab316ecbae2e313a42f94ef2b5617ea3d

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
package com.java110.web.smo.impl;
 
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.common.constant.ServiceConstant;
import com.java110.common.util.Assert;
import com.java110.core.context.IPageData;
import com.java110.web.core.BaseComponentSMO;
import com.java110.web.smo.IPrivilegeServiceSMO;
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;
 
@Service("privilegeServiceSMOImpl")
public class PrivilegeServiceSMOImpl extends BaseComponentSMO implements IPrivilegeServiceSMO {
 
    @Autowired
    private RestTemplate restTemplate;
 
    /**
     * 查询 权限组
     * @param pd
     * @return
     */
    @Override
    public ResponseEntity<String> listPrivilegeGroup(IPageData pd) {
 
        Assert.hasLength(pd.getUserId(),"用户未登录请先登录");
 
        ResponseEntity<String> storeInfo = super.getStoreInfo(pd,restTemplate);
 
        if(storeInfo.getStatusCode() != HttpStatus.OK){
            return storeInfo;
        }
        // 商户返回信息
        JSONObject storeInfoObj = JSONObject.parseObject(storeInfo.getBody());
 
        String  storeId = storeInfoObj.getString("storeId");
        String  storeTypeCd = storeInfoObj.getString("storeTypeCd");
 
        //根据商户ID查询 权限组信息
 
 
        ResponseEntity<String> privilegeGroup = super.callCenterService(restTemplate,pd,"",
                ServiceConstant.SERVICE_API_URL+"/api/query.store.privilegeGroup?storeId="+storeId +"&storeTypeCd="+storeTypeCd, HttpMethod.GET);
        if(privilegeGroup.getStatusCode() != HttpStatus.OK){
            return privilegeGroup;
        }
 
        JSONObject privilegeGroupObj = JSONObject.parseObject(privilegeGroup.getBody().toString());
 
        Assert.jsonObjectHaveKey(privilegeGroupObj,"privilegeGroups","查询菜单未返回privilegeGroups节点");
 
        JSONArray privilegeGroups = privilegeGroupObj.getJSONArray("privilegeGroups");
 
        return new ResponseEntity<String>(privilegeGroups.toJSONString(),HttpStatus.OK);
    }
 
    /**
     * 查询权限
     * @param pd
     * @return
     */
    @Override
    public ResponseEntity<String> loadListPrivilege(IPageData pd) {
        JSONObject privilegeInfoObj = JSONObject.parseObject(pd.getReqData());
        Assert.jsonObjectHaveKey(privilegeInfoObj,"pgId","请求报文中未包含pgId 节点");
 
        String pgId = privilegeInfoObj.getString("pgId");
 
        ResponseEntity<String> privilegeGroup = super.callCenterService(restTemplate,pd,"",
                ServiceConstant.SERVICE_API_URL+"/api/query.privilege.byPgId?pgId="+pgId , HttpMethod.GET);
        if(privilegeGroup.getStatusCode() != HttpStatus.OK){
            return privilegeGroup;
        }
 
        JSONObject privilegeObj = JSONObject.parseObject(privilegeGroup.getBody().toString());
 
        Assert.jsonObjectHaveKey(privilegeObj,"privileges","查询菜单未返回privileges节点");
 
        JSONArray privileges = privilegeObj.getJSONArray("privileges");
 
        return new ResponseEntity<String>(privileges.toJSONString(),HttpStatus.OK);
 
    }
 
    /**
     * 保存权限组
     * @param pd
     * @return
     */
    @Override
    public ResponseEntity<String> savePrivilegeGroup(IPageData pd) {
        Assert.hasLength(pd.getUserId(),"用户未登录请先登录");
 
        JSONObject privilegeInfoObj = JSONObject.parseObject(pd.getReqData());
 
        Assert.jsonObjectHaveKey(privilegeInfoObj,"name","请求报文中未包含权限组名称 节点");
        Assert.jsonObjectHaveKey(privilegeInfoObj,"description","请求报文中未包含权限组描述 节点");
 
        Assert.hasLength(privilegeInfoObj.getString("name"),"请求报文中权限组名称不能为空");
 
 
 
        ResponseEntity<String> storeInfo = super.getStoreInfo(pd,restTemplate);
 
        if(storeInfo.getStatusCode() != HttpStatus.OK){
            return storeInfo;
        }
        // 商户返回信息
        JSONObject storeInfoObj = JSONObject.parseObject(storeInfo.getBody());
 
        String  storeId = storeInfoObj.getString("storeId");
        String  storeTypeCd = storeInfoObj.getString("storeTypeCd");
        privilegeInfoObj.put("storeId",storeId);
        privilegeInfoObj.put("storeTypeCd",storeTypeCd);
 
        ResponseEntity<String> privilegeGroup = super.callCenterService(restTemplate,pd,privilegeInfoObj.toJSONString(),
                ServiceConstant.SERVICE_API_URL+"/api/save.privilegeGroup.info" , HttpMethod.POST);
        return privilegeGroup;
    }
 
    public RestTemplate getRestTemplate() {
        return restTemplate;
    }
 
    public void setRestTemplate(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }
}