feat: 接入商品合规负责人接口

yanxuan-qc-change-system-biz/src/main/java/com/netease/mail/yanxuan/change/biz/service/impl/InteriorChangeConfigServiceImpl.java

@@ -227,16 +227,21 @@ public class InteriorChangeConfigServiceImpl implements InteriorChangeConfigServ
                 }
             }
         } else if (ChangePrincipalEnum.COMPLIANCE.getName().equals(commander)) {
-            // TODO: 待合规RPC接口提供后实现
-            logger.warn("[queryGoodsCommander] 合规类型暂未实现，goodsInfos={}", goodsInfos);
-            // 暂时使用兜底配置
+            for (Long goods: goodsInfos) {
+                String detail = qcApiRpcService.getQaUserListByItemId(goods.intValue());
+                logger.info("[queryGoodsCommander] compliance:{}", detail);
+                JSONObject jsonObject = JSONObject.parseObject(detail);
+                List<JSONObject> qaUserList = JSONObject.parseArray(jsonObject.getString("data"), JSONObject.class);
+                if (CollectionUtils.isNotEmpty(qaUserList)) {
+                    for (JSONObject qaUser: qaUserList) {
                         GoodsResponseRpc rpc = new GoodsResponseRpc();
-            rpc.setEmail(appConfig.getComplianceEmail());
-            rpc.setName(appConfig.getComplianceName());
-            if (StringUtils.isNotBlank(rpc.getEmail()) && StringUtils.isNotBlank(rpc.getName())) {
+                        rpc.setEmail(qaUser.getString("uid"));
+                        rpc.setName(qaUser.getString("userName"));
                         emails.add(rpc);
                     }
                 }
+            }
+        }
         //逻辑发生变更
         /*
          * for (GoodsResponseRpc email: emails) { if (!map.containsKey(email.getName())) { email.setOccurrenceNumber(1);
@@ -399,12 +404,19 @@ public class InteriorChangeConfigServiceImpl implements InteriorChangeConfigServ
             }
         }
         //合规
-        // TODO: 待合规RPC接口提供后实现
         for (Long itemId: itemIds) {
-            // 暂时使用兜底配置
-            map.get(itemId).setGoodsComplianceName(appConfig.getComplianceName());
-            map.get(itemId).setGoodsComplianceEmail(appConfig.getComplianceEmail());
-            goodsRpc(ChangePrincipalEnum.COMPLIANCE.getType(), appConfig.getComplianceName(), map.get(itemId));
+            String compliance = qcApiRpcService.getQaUserListByItemId(itemId.intValue());
+            logger.info("[queryGoodsPrincipalInfo] compliance:{}", compliance);
+            JSONObject jsonObject1 = JSONObject.parseObject(compliance);
+            List<JSONObject> qaUserList = JSONObject.parseArray(jsonObject1.getString("data"), JSONObject.class);
+            if (CollectionUtils.isNotEmpty(qaUserList)) {
+                JSONObject qaUser = qaUserList.get(0);
+                map.get(itemId).setGoodsComplianceName(qaUser.getString("userName"));
+                map.get(itemId).setGoodsComplianceEmail(qaUser.getString("uid"));
+                goodsRpc(ChangePrincipalEnum.COMPLIANCE.getType(), qaUser.getString("uid"), map.get(itemId));
+            } else {
+                goodsRpc(ChangePrincipalEnum.COMPLIANCE.getType(), null, map.get(itemId));
+            }
         }
         return map;
     }
@@ -631,6 +643,11 @@ public class InteriorChangeConfigServiceImpl implements InteriorChangeConfigServ
                 goodsResponseRpc.setName(appConfig.getSqeName());
                 goodsResponseRpc.setEmail(appConfig.getSqeEmail());
                 break;
+            case 5:
+                //合规
+                goodsResponseRpc.setName(appConfig.getComplianceName());
+                goodsResponseRpc.setEmail(appConfig.getComplianceEmail());
+                break;
         }
     }
 

yanxuan-qc-change-system-integration/src/main/java/com/netease/mail/yanxuan/change/integration/flow/goods/QcApiRpcService.java

@@ -17,4 +17,7 @@ public interface QcApiRpcService {
     @GetMapping(value = "/xhr/item/basic/sqe.json")
     String getDetail(@RequestParam("itemId") Integer itemId);
 
+    @GetMapping(value = "/getQaUserListByItemId")
+    String getQaUserListByItemId(@RequestParam("itemId") Integer itemId);
+
 }