|
@@ -830,20 +830,21 @@ public class KwpGoodsService {
|
|
|
* @return: void
|
|
* @return: void
|
|
|
*/
|
|
*/
|
|
|
private void sendMsg(MessageEnum msgEnum, KwpGoods goods) {
|
|
private void sendMsg(MessageEnum msgEnum, KwpGoods goods) {
|
|
|
- Map<String, Object> map = CollectionUtils.createHashMap();
|
|
|
|
|
- map.put("productName", goods.getName());
|
|
|
|
|
- //给创建人发消息
|
|
|
|
|
- List<UserInfo> userInfos = new ArrayList<>();
|
|
|
|
|
- UserInfo createUser = new UserInfo();
|
|
|
|
|
- createUser.setUserId(goods.getCreateBy()).setEntId(goods.getEntId());
|
|
|
|
|
- userInfos.add(createUser);
|
|
|
|
|
- HashMap<String, String> urlMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
- urlMap.put(ClientTypeEnum.app.getValue(), appGoodsListUrl);
|
|
|
|
|
- urlMap.put(ClientTypeEnum.pc.getValue(), pcGoodsListUrl);
|
|
|
|
|
- SckwMessage msg = new SckwMessage(msgEnum);
|
|
|
|
|
- msg.setParams(map).setMsgUrls(urlMap).setUserInfos(userInfos).setCreateBy(LoginUserHolder.getUserId());
|
|
|
|
|
- log.info(msgEnum.getTitle() + "消息:{}", JSON.toJSONString(msg));
|
|
|
|
|
- streamBridge.send("sckw-message", JSON.toJSONString(msg));
|
|
|
|
|
|
|
+ log.info("发送消息提醒, msgEnum:{}, goods:{}", JSON.toJSONString(msgEnum), JSON.toJSONString(goods));
|
|
|
|
|
+// Map<String, Object> map = CollectionUtils.createHashMap();
|
|
|
|
|
+// map.put("productName", goods.getName());
|
|
|
|
|
+// //给创建人发消息
|
|
|
|
|
+// List<UserInfo> userInfos = new ArrayList<>();
|
|
|
|
|
+// UserInfo createUser = new UserInfo();
|
|
|
|
|
+// createUser.setUserId(goods.getCreateBy()).setEntId(goods.getEntId());
|
|
|
|
|
+// userInfos.add(createUser);
|
|
|
|
|
+// HashMap<String, String> urlMap = new HashMap<>(Global.NUMERICAL_SIXTEEN);
|
|
|
|
|
+// urlMap.put(ClientTypeEnum.app.getValue(), appGoodsListUrl);
|
|
|
|
|
+// urlMap.put(ClientTypeEnum.pc.getValue(), pcGoodsListUrl);
|
|
|
|
|
+// SckwMessage msg = new SckwMessage(msgEnum);
|
|
|
|
|
+// msg.setParams(map).setMsgUrls(urlMap).setUserInfos(userInfos).setCreateBy(LoginUserHolder.getUserId());
|
|
|
|
|
+// log.info(msgEnum.getTitle() + "消息:{}", JSON.toJSONString(msg));
|
|
|
|
|
+// streamBridge.send("sckw-message", JSON.toJSONString(msg));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|