关联角色查询引用

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

@@ -17,8 +17,18 @@ import com.netease.mail.yanxuan.change.dal.meta.model.rpc.GoodsResponseRpc;
  */
 public interface InteriorChangeConfigService {
 
+    /**
+     * 根据变更信息 返回住变更负责人
+     * @param changeCommander
+     * @return
+     */
     GoodsResponseRpc queryCommanderInfo(ChangeCommanderPO changeCommander);
 
+    /**
+     * 传入商品列表 返回商品信息
+     * @param itemIds
+     * @return
+     */
     Map<Long, ChangeGoodsPrincipalPO> queryGoodsPrincipalInfo(List<Long> itemIds);
 
     /**

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

@@ -7,15 +7,14 @@ import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 
+import com.netease.mail.yanxuan.change.integration.flow.supplier.FlowRpcSupplierInfoService;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.util.Assert;
-
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.netease.mail.yanxuan.change.biz.config.AppConfig;
@@ -30,7 +29,6 @@ import com.netease.mail.yanxuan.change.dal.entity.ChangeConfig;
 import com.netease.mail.yanxuan.change.dal.meta.model.po.ChangeCommanderPO;
 import com.netease.mail.yanxuan.change.dal.meta.model.po.ChangeGoodsPrincipalPO;
 import com.netease.mail.yanxuan.change.dal.meta.model.po.QueryCommanderEmailReq;
-import com.netease.mail.yanxuan.change.dal.meta.model.req.ChangeFlowCreateReq;
 import com.netease.mail.yanxuan.change.dal.meta.model.rpc.CommanderResponse;
 import com.netease.mail.yanxuan.change.dal.meta.model.rpc.GoodsPurchaseRpc;
 import com.netease.mail.yanxuan.change.dal.meta.model.rpc.GoodsResponseRpc;
@@ -42,7 +40,6 @@ import com.netease.mail.yanxuan.change.integration.flow.goods.QcApiRpcService;
 import com.netease.mail.yanxuan.change.integration.flow.supplier.FlowRpcSupplierSendService;
 import com.netease.mail.yanxuan.change.integration.flow.supplier.req.SupplierRelatedUserReq;
 import com.netease.mail.yanxuan.change.integration.flow.supplier.rsp.SupplierUserRsp;
-import com.netease.yanxuan.flowx.sdk.meta.controller.communal.AjaxResponse;
 
 import lombok.extern.slf4j.Slf4j;
 
@@ -75,6 +72,12 @@ public class InteriorChangeConfigServiceImpl implements InteriorChangeConfigServ
     private AppConfig appConfig;
 
     /**
+     *  项目上线后接口需要修改未线上环境
+     */
+    @Autowired
+    private FlowRpcSupplierInfoService supplierInfoService;
+
+    /**
      * 接口不完整,关于商品的查询已经完成  供应商查询不完整接口已对接 具体返回值接口测试未完成
      * @param changeCommander
      * @return
@@ -213,14 +216,18 @@ public class InteriorChangeConfigServiceImpl implements InteriorChangeConfigServ
         }
         req.setSupplierIdList(supplierIdList);
         //进行参数解析
-        //AjaxResponse<List<SupplierUserRsp>> listAjaxResponse = supplierSendService.querySupplierRelatedUser(req);
-        //List<SupplierUserRsp> data = listAjaxResponse.getData();
-       // if (data != null){
-            // 返回结果有问题暂时不动
-            //rpc.setSupplierId();
-       // }
+        List<SupplierUserRsp> listAjaxResponse = supplierInfoService.querySupplierRelatedUser(req);
+        if (listAjaxResponse != null || listAjaxResponse.size() == 0){
             return null;
         }
+        SupplierUserRsp supplierUserRsp = listAjaxResponse.get(0);
+        Map<String, String> uid2NameMap = supplierUserRsp.getUid2NameMap();
+        for (String key : uid2NameMap.keySet()){
+            rpc.setName(key);
+            rpc.setEmail(uid2NameMap.get(key));
+        }
+        return rpc;
+    }
 
 
     /**

yanxuan-qc-change-system-integration/src/main/java/com/netease/mail/yanxuan/change/integration/flow/supplier/impl/FlowRpcSupplierInfoServiceImpl.java

@@ -8,13 +8,10 @@ import com.netease.mail.yanxuan.change.integration.flow.supplier.req.SupplierRel
 import com.netease.mail.yanxuan.change.integration.flow.supplier.rsp.SupplierUserRsp;
 import com.netease.mail.yanxuan.change.integration.rpc.RpcObjectHandler;
 import com.netease.mail.yanxuan.change.integration.rpc.RpcTemplate;
-import com.netease.yanxuan.flowx.sdk.meta.controller.communal.AjaxResponse;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-
-import java.util.HashMap;
 import java.util.List;
 
 /**