测试调用给供应商发送消息邮件接口

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

 package com.netease.mail.yanxuan.change.biz.service.impl;
 
 import com.alibaba.fastjson.JSONObject;
+import com.netease.mail.yanxuan.change.biz.meta.exception.ExceptionFactory;
 import com.netease.mail.yanxuan.change.biz.service.InteriorChangeConfigService;
 import com.netease.mail.yanxuan.change.biz.service.change.ChangeConfigService;
+import com.netease.mail.yanxuan.change.common.bean.ResponseCode;
 import com.netease.mail.yanxuan.change.common.enums.ChangeCommanderEnum;
 import com.netease.mail.yanxuan.change.common.enums.ChangeSubjectEnum;
 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.rpc.GoodsResponseSqeRpc;
-import com.netease.mail.yanxuan.change.integration.flow.PfuApiRpcService;
-import com.netease.mail.yanxuan.change.integration.flow.QcApiRpcService;
+import com.netease.mail.yanxuan.change.integration.flow.goods.ItemcenterApiRpcService;
+import com.netease.mail.yanxuan.change.integration.flow.goods.PfuApiRpcService;
+import com.netease.mail.yanxuan.change.integration.flow.goods.QcApiRpcService;
 import org.springframework.beans.factory.annotation.Autowired;
 
 import java.util.ArrayList;
@@ -26,11 +29,15 @@ public class InteriorChangeConfigServiceImpl implements InteriorChangeConfigServ
     @Autowired
     private ChangeConfigService changeConfigService;
 
+    //查询商品的SQE
     @Autowired
     private QcApiRpcService qcApiRpcService;
-
+    //查看执行人
     @Autowired
     private PfuApiRpcService pfuApiRpcService;
+    //查看商品BU
+    @Autowired
+    private ItemcenterApiRpcService itemcenterApiRpcService;
 
     @Override
     public String queryCommanderInfo(ChangeCommanderPO changeCommander) {
@@ -72,40 +79,37 @@ public class InteriorChangeConfigServiceImpl implements InteriorChangeConfigServ
         //记录最大值
         String name = "";
         //记录出现的所有值
-        List<String> commanders = new ArrayList<String>();
+        List<String> emails = new ArrayList<String>();
         //遍历取出所有商品关联的人
         if (commander.equals("商品BU")) {
-
+            String detail = itemcenterApiRpcService.getDetail(goodsInfos);
+            getGoodsNameEmail(emails,detail);
         } else if (commander.equals("采购")) {
 
         } else if (commander.equals("计划")) {
             String detail = pfuApiRpcService.getDetail(goodsInfos);
-            JSONObject jsonObject = JSONObject.parseObject(detail);
-            Map<String,JSONObject> rpcMap = JSONObject.parseObject(jsonObject.get("data").toString(), Map.class);
-            for (String rpc : rpcMap.keySet()){
-                commanders.add(rpcMap.get(rpc).get("uid").toString());
-            }
+            getGoodsNameEmail(emails,detail);
         } else if (commander.equals("SQE")) {
             for (Long goods:goodsInfos) {
                 String detail = qcApiRpcService.getDetail(goods.intValue());
                 JSONObject jsonObject = JSONObject.parseObject(detail);
                 GoodsResponseSqeRpc data = jsonObject.getObject("data", GoodsResponseSqeRpc.class);
                 if (data != null){
-                    commanders.add(data.getUserName());
+                    emails.add(data.getUserName());
                 }
             }
         }
-        for (String goods : commanders){
-            if (!map.containsKey(goods)){
-                map.put(goods,1);
+        for (String email : emails){
+            if (!map.containsKey(email)){
+                map.put(email,1);
             }else{
-                Integer integer = map.get(goods);
+                Integer integer = map.get(email);
                 ++integer;
                 if (temp < integer){
                     temp = integer;
-                    name = goods;
+                    name = email;
                 }
-                map.put(goods,integer);
+                map.put(email,integer);
             }
         }
         return name;
@@ -134,4 +138,21 @@ public class InteriorChangeConfigServiceImpl implements InteriorChangeConfigServ
     }
 
 
+    /**
+     * 重复代码复用方法
+     * @param emails 储存邮箱队列
+     * @param response  请求返结果
+     */
+    private void getGoodsNameEmail(List<String> emails,String response){
+        JSONObject jsonObject = JSONObject.parseObject(response);
+        Map<String,JSONObject> rpcMap = JSONObject.parseObject(jsonObject.get("data").toString(), Map.class);
+        if (rpcMap == null){
+            throw ExceptionFactory.createBiz(ResponseCode.OPERATOR_NOT_EXIST);
+        }
+        for (String rpc : rpcMap.keySet()){
+            emails.add(rpcMap.get(rpc).get("uid").toString());
+        }
+    }
+
+
 }

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

-package com.netease.mail.yanxuan.change.integration.flow;
+package com.netease.mail.yanxuan.change.integration.flow.goods;
 
 import com.netease.yanxuan.missa.client.annotation.MissaClient;
 import org.springframework.stereotype.Service;

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

-package com.netease.mail.yanxuan.change.integration.flow;
+package com.netease.mail.yanxuan.change.integration.flow.goods;
 
 import com.netease.yanxuan.missa.client.annotation.MissaClient;
 import org.springframework.stereotype.Service;

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

-package com.netease.mail.yanxuan.change.integration.flow;
+package com.netease.mail.yanxuan.change.integration.flow.goods;
 
 import com.netease.yanxuan.missa.client.annotation.MissaClient;
 import org.springframework.stereotype.Service;

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

+package com.netease.mail.yanxuan.change.integration.flow.supplier;
+
+import com.netease.yanxuan.missa.client.annotation.MissaClient;
+import org.springframework.stereotype.Service;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+
+/**
+ * @author WangJiaXiang
+ * @date 2022/11/24/024$
+ */
+@Service
+@MissaClient(serviceCode = "yanxuan-supplier-ms")
+public interface FlowRpcSupplierSendEmailService {
+
+    @PostMapping("/api/supplier/msg/sendMail.json")
+    String sendEmail(@RequestBody SupplierSendEmailReq req);
+
+
+}

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

+package com.netease.mail.yanxuan.change.integration.flow.supplier;
+
+import lombok.Data;
+
+/**
+ * @author WangJiaXiang
+ * @date 2022/11/24/024$
+ * 供应商发送邮件模板
+ */
+@Data
+public class SupplierSendEmailReq {
+
+    //供应商ID
+    private String supplierId;
+
+    //邮件主题
+    private String mailSubject;
+
+    //邮件内容
+    private String mailContent;
+
+    //是否要发送所有账号标记 1：是；0：不是（范围：供应商信息中的通知邮箱 + 除供应商信息中的主账号以外的所有登录邮箱）
+    private Integer isAllAccountResolved;
+
+
+
+}

yanxuan-qc-change-system-web/src/main/java/com/netease/mail/yanxuan/change/web/controller/ChangeConfigController.java

@@ -5,13 +5,10 @@ import com.netease.mail.yanxuan.change.common.bean.AjaxResult;
 import com.netease.mail.yanxuan.change.biz.service.change.AdminChangeConfigService;
 import com.netease.mail.yanxuan.change.dal.meta.model.req.ChangeConfigQueryReq;
 import com.netease.mail.yanxuan.change.dal.meta.model.req.ChangeConfigReq;
-import com.netease.mail.yanxuan.change.integration.flow.ItemcenterApiRpcService;
-import com.netease.mail.yanxuan.change.integration.flow.PfuApiRpcService;
+import com.netease.mail.yanxuan.change.integration.flow.supplier.FlowRpcSupplierSendEmailService;
+import com.netease.mail.yanxuan.change.integration.flow.supplier.SupplierSendEmailReq;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
-import java.util.List;
-import java.util.Map;
-
 /**
  * @author WangJiaXiang
  * @date 2022/11/11/011$
@@ -105,22 +102,18 @@ public class ChangeConfigController {
     }
 
     @Autowired
-    private PfuApiRpcService pfuApiRpcService;
-
-    @Autowired
-    private ItemcenterApiRpcService itemcenterApiRpcService;
-
+    private FlowRpcSupplierSendEmailService sendEmailService;
 
-    @PostMapping("/test")
-    public String queryExecuteUserByItemId(@RequestBody List<Long> goodsId){
-        String detail = itemcenterApiRpcService.getDetail(goodsId);
-        JSONObject jsonObject = JSONObject.parseObject(detail);
-        Map<String,JSONObject> map = JSONObject.parseObject(jsonObject.get("data").toString(), Map.class);
-        StringBuilder stringBuilder = new StringBuilder();
-        for (String rpc : map.keySet()){
-            stringBuilder.append(map.get(rpc).get("uid")+"\n");
-        }
-        return stringBuilder.toString();
+    @GetMapping("/test")
+    public String queryExecuteUserByItemId(){
+        SupplierSendEmailReq req = new SupplierSendEmailReq();
+        req.setSupplierId("YX0001");
+        req.setMailContent("测试发送主题");
+        req.setMailContent("测试发送内容");
+        req.setIsAllAccountResolved(1);
+        String s = sendEmailService.sendEmail(req);
+        JSONObject jsonObject = JSONObject.parseObject(s);
+        return jsonObject.get("code").toString();
     }
 
 }