wuxw
2020-02-16 2bc6d9750e3806337f2d920b06ed464230158888
OrderService/src/main/java/com/java110/order/smo/impl/PrivilegeSMOImpl.java
@@ -1,5 +1,6 @@
package com.java110.order.smo.impl;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.constant.MappingConstant;
@@ -64,6 +65,7 @@
    /**
     * 删除用户权限
     *
     * @param privilegeInfo
     * @return
     */
@@ -104,6 +106,7 @@
    /**
     * 删除权限组
     *
     * @param privilegeGroupInfo
     * @return
     */
@@ -139,22 +142,38 @@
        Assert.jsonObjectHaveKey(privilegeInfo, "pgId", "请求报文中未包含pgId节点");
        Assert.jsonObjectHaveKey(privilegeInfo, "storeId", "请求报文中未包含storeId节点");
        Assert.jsonObjectHaveKey(privilegeInfo, "pId", "请求报文中未包含pId节点");
        JSONObject privilegeObj = JSONObject.parseObject(privilegeInfo);
        //Assert.jsonObjectHaveKey(privilegeInfoObj,"pId","请求报文中未包含权限ID 节点");
        if (!privilegeObj.containsKey("pIds") || privilegeObj.getJSONArray("pIds").size() < 1) {
            throw new IllegalArgumentException("请求报文中未包含权限");
        }
        //根据权限组ID和商户ID查询是否有数据
        List<Map> privilegeGroups = privilegeDAOImpl.queryPrivilegeGroup(privilegeObj);
        Assert.isNotNull(privilegeGroups, "当前没有权限操作权限组pgId = " + privilegeObj.getString("pgId"));
        JSONArray pIds = privilegeObj.getJSONArray("pIds");
        int errorCount = 0;
        for (int pIdIndex = 0; pIdIndex < pIds.size(); pIdIndex++) {
            try {
        if (!privilegeDAOImpl.addPrivilegeRel(privilegeObj)) {
            return new ResponseEntity<String>("添加权限失败", HttpStatus.INTERNAL_SERVER_ERROR);
                    errorCount++;
        }
        return new ResponseEntity<String>("成功", HttpStatus.OK);
            } catch (Exception e) {
                logger.error("保存权限关系失败", e);
                errorCount++;
            }
        }
        JSONObject paramOut = new JSONObject();
        paramOut.put("success", pIds.size() - errorCount);
        paramOut.put("error", errorCount);
        return new ResponseEntity<String>(paramOut.toJSONString(), HttpStatus.OK);
    }
    /**
     *
     * @param privilegeInfo
     * @return
     */
@@ -183,6 +202,7 @@
    /**
     * 员工添加权限或权限组
     *
     * @param privilegeInfo
     * @return
     */
@@ -205,6 +225,7 @@
    /**
     * 删除员工权限
     *
     * @param privilegeInfo
     * @return
     */
@@ -226,6 +247,7 @@
    /**
     * 数据校验
     *
     * @param privilegeInfo
     * @return
     */
@@ -279,6 +301,7 @@
    /**
     * 权限组数据校验
     *
     * @param privilegeObj
     */
    private void validatePrivilegeGroup(JSONObject privilegeObj){
@@ -293,6 +316,7 @@
    /**
     * 权限数据校验
     *
     * @param privilegeObj
     */
    private void validatePrivilege(JSONObject privilegeObj){