From e64197421cf28099935f71f193989a3394d47fe0 Mon Sep 17 00:00:00 2001
From: mrzcc <121184950@qq.com>
Date: 星期一, 17 二月 2020 18:12:38 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 OrderService/src/main/java/com/java110/order/smo/impl/PrivilegeSMOImpl.java |   72 +++++++++++++++++++++++++++---------
 1 files changed, 54 insertions(+), 18 deletions(-)

diff --git a/OrderService/src/main/java/com/java110/order/smo/impl/PrivilegeSMOImpl.java b/OrderService/src/main/java/com/java110/order/smo/impl/PrivilegeSMOImpl.java
index d5e5f35..2ca0549 100644
--- a/OrderService/src/main/java/com/java110/order/smo/impl/PrivilegeSMOImpl.java
+++ b/OrderService/src/main/java/com/java110/order/smo/impl/PrivilegeSMOImpl.java
@@ -104,6 +104,26 @@
         return new ResponseEntity<String>("鏈煡寮傚父", HttpStatus.INTERNAL_SERVER_ERROR);
     }
 
+    @Override
+    public ResponseEntity<String> editPrivilegeGroup(String privilegeGroupInfo) {
+
+        Assert.isJsonObject(privilegeGroupInfo, "璇锋眰鎶ユ枃涓嶆槸鏈夋晥鐨刯son鏍煎紡");
+
+        Assert.jsonObjectHaveKey(privilegeGroupInfo, "name", "璇锋眰鎶ユ枃涓湭鍖呭惈name鑺傜偣");
+        Assert.jsonObjectHaveKey(privilegeGroupInfo, "pgId", "璇锋眰鎶ユ枃涓湭鍖呭惈pgId鑺傜偣");
+
+        Assert.jsonObjectHaveKey(privilegeGroupInfo, "storeId", "璇锋眰鎶ユ枃涓湭鍖呭惈storeId鑺傜偣");
+
+        Assert.jsonObjectHaveKey(privilegeGroupInfo, "storeTypeCd", "璇锋眰鎶ユ枃涓湭鍖呭惈storeTypeCd鑺傜偣");
+        JSONObject privilegeGroupObj = JSONObject.parseObject(privilegeGroupInfo);
+
+        if (privilegeDAOImpl.updatePrivilegeGroup(privilegeGroupObj)) {
+            return new ResponseEntity<String>("鎴愬姛", HttpStatus.OK);
+        }
+
+        return new ResponseEntity<String>("鏈煡寮傚父", HttpStatus.INTERNAL_SERVER_ERROR);
+    }
+
     /**
      * 鍒犻櫎鏉冮檺缁�
      *
@@ -154,8 +174,11 @@
 
         JSONArray pIds = privilegeObj.getJSONArray("pIds");
         int errorCount = 0;
+        JSONObject tmpPId = null;
         for (int pIdIndex = 0; pIdIndex < pIds.size(); pIdIndex++) {
             try {
+                tmpPId = pIds.getJSONObject(pIdIndex);
+                privilegeObj.put("pId", tmpPId.getString("pId"));
                 if (!privilegeDAOImpl.addPrivilegeRel(privilegeObj)) {
                     errorCount++;
                 }
@@ -209,18 +232,34 @@
     @Override
     public ResponseEntity<String> addStaffPrivilegeOrPrivilegeGroup(String privilegeInfo) {
 
-        JSONObject privilegeObj = validateData(privilegeInfo);
-        //鏍规嵁鏉冮檺缁処D鍜屽晢鎴稩D鏌ヨ鏄惁鏈夋暟鎹�
-        String pFlag = privilegeObj.getString("pFlag");//鏉冮檺缁�
-        privilegeObj.put("privilegeFlag", "1".equals(pFlag) ? "1" : "0");
-        List<Map> privilegeGroups = privilegeDAOImpl.queryUserPrivilege(privilegeObj);
-        Assert.listIsNull(privilegeGroups, "宸茬粡瀛樺湪璇ユ潈闄愭棤闇�澶氭娣诲姞" + privilegeInfo);
+        Assert.jsonObjectHaveKey(privilegeInfo, "pIds", "璇锋眰鎶ユ枃涓湭鍖呭惈pIds鑺傜偣");
 
-        if (!privilegeDAOImpl.addUserPrivilege(privilegeObj)) {
-            return new ResponseEntity<String>("娣诲姞鏉冮檺澶辫触", HttpStatus.INTERNAL_SERVER_ERROR);
+        JSONObject privilegeObj = JSONObject.parseObject(privilegeInfo);
+        JSONArray pIds = privilegeObj.getJSONArray("pIds");
+        int errorCount = 0;
+        for (int pIndex = 0; pIndex < pIds.size(); pIndex++) {
+            privilegeObj.put("pId", pIds.getJSONObject(pIndex).getString("pId"));
+            try {
+                validateData(privilegeObj);
+                //鏍规嵁鏉冮檺缁処D鍜屽晢鎴稩D鏌ヨ鏄惁鏈夋暟鎹�
+                String pFlag = privilegeObj.getString("pFlag");//鏉冮檺缁�
+                privilegeObj.put("privilegeFlag", "1".equals(pFlag) ? "1" : "0");
+
+                List<Map> privilegeGroups = privilegeDAOImpl.queryUserPrivilege(privilegeObj);
+                Assert.listIsNull(privilegeGroups, "宸茬粡瀛樺湪璇ユ潈闄愭棤闇�澶氭娣诲姞" + privilegeInfo);
+                if (!privilegeDAOImpl.addUserPrivilege(privilegeObj)) {
+                    return new ResponseEntity<String>("娣诲姞鏉冮檺澶辫触", HttpStatus.INTERNAL_SERVER_ERROR);
+                }
+            } catch (Exception e) {
+                logger.error("淇濆瓨鏉冮檺澶辫触", e);
+                errorCount++;
+            }
         }
 
-        return new ResponseEntity<String>("鎴愬姛", HttpStatus.OK);
+        JSONObject paramOut = new JSONObject();
+        paramOut.put("success", pIds.size() - errorCount);
+        paramOut.put("error", errorCount);
+        return new ResponseEntity<String>(paramOut.toJSONString(), HttpStatus.OK);
     }
 
     /**
@@ -275,21 +314,18 @@
         return privilegeObj;
     }
 
-    private JSONObject validateData(String privilegeInfo) {
+    private JSONObject validateData(JSONObject privilegeObj) {
 
-        Assert.isJsonObject(privilegeInfo, "璇锋眰鎶ユ枃涓嶆槸鏈夋晥鐨刯son鏍煎紡");
+        Assert.jsonObjectHaveKey(privilegeObj, "pId", "璇锋眰鎶ユ枃涓湭鍖呭惈pId鑺傜偣");
 
-        Assert.jsonObjectHaveKey(privilegeInfo, "pId", "璇锋眰鎶ユ枃涓湭鍖呭惈pId鑺傜偣");
+        Assert.jsonObjectHaveKey(privilegeObj, "pFlag", "璇锋眰鎶ユ枃涓湭鍖呭惈pFlag鑺傜偣");
 
-        Assert.jsonObjectHaveKey(privilegeInfo, "pFlag", "璇锋眰鎶ユ枃涓湭鍖呭惈pFlag鑺傜偣");
+        Assert.jsonObjectHaveKey(privilegeObj, "userId", "璇锋眰鎶ユ枃涓湭鍖呭惈userId鑺傜偣");
 
-        Assert.jsonObjectHaveKey(privilegeInfo, "userId", "璇锋眰鎶ユ枃涓湭鍖呭惈userId鑺傜偣");
+        Assert.jsonObjectHaveKey(privilegeObj, "storeId", "璇锋眰鎶ユ枃涓湭鍖呭惈storeId鑺傜偣");
 
-        Assert.jsonObjectHaveKey(privilegeInfo, "storeId", "璇锋眰鎶ユ枃涓湭鍖呭惈storeId鑺傜偣");
+        Assert.jsonObjectHaveKey(privilegeObj, "storeTypeCd", "璇锋眰鎶ユ枃涓湭鍖呭惈storeTypeCd鑺傜偣");
 
-        Assert.jsonObjectHaveKey(privilegeInfo, "storeTypeCd", "璇锋眰鎶ユ枃涓湭鍖呭惈storeTypeCd鑺傜偣");
-
-        JSONObject privilegeObj = JSONObject.parseObject(privilegeInfo);
         String pFlag = privilegeObj.getString("pFlag");//鏉冮檺缁�
         if ("1".equals(pFlag)) {
             validatePrivilegeGroup(privilegeObj);

--
Gitblit v1.8.0