From b480fc1df57d1e11b836f6dac27bff4d25617a05 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期六, 30 五月 2020 14:56:25 +0800
Subject: [PATCH] 删除logagent cache 模块 合并至core

---
 Api/src/main/java/com/java110/api/bmo/msg/impl/MsgBMOImpl.java |   15 +++++----------
 1 files changed, 5 insertions(+), 10 deletions(-)

diff --git a/Api/src/main/java/com/java110/api/bmo/msg/impl/MsgBMOImpl.java b/Api/src/main/java/com/java110/api/bmo/msg/impl/MsgBMOImpl.java
index 99dbef4..c3345bc 100644
--- a/Api/src/main/java/com/java110/api/bmo/msg/impl/MsgBMOImpl.java
+++ b/Api/src/main/java/com/java110/api/bmo/msg/impl/MsgBMOImpl.java
@@ -4,8 +4,9 @@
 import com.java110.api.bmo.ApiBaseBMO;
 import com.java110.api.bmo.msg.IMsgBMO;
 import com.java110.core.context.DataFlowContext;
+import com.java110.po.message.MsgReadPo;
 import com.java110.utils.constant.BusinessTypeConstant;
-import com.java110.utils.constant.CommonConstant;
+import com.java110.utils.util.BeanConvertUtil;
 import org.springframework.stereotype.Service;
 
 /**
@@ -20,19 +21,13 @@
 public class MsgBMOImpl extends ApiBaseBMO implements IMsgBMO {
 
 
-    public Object addReadMsg(JSONObject paramInJson, DataFlowContext context) {
+    public void addReadMsg(JSONObject paramInJson, DataFlowContext context) {
 
-        JSONObject business = JSONObject.parseObject("{\"datas\":{}}");
-        business.put(CommonConstant.HTTP_BUSINESS_TYPE_CD, BusinessTypeConstant.BUSINESS_TYPE_SAVE_MSG_READ);
-        business.put(CommonConstant.HTTP_SEQ, DEFAULT_SEQ);
-        business.put(CommonConstant.HTTP_INVOKE_MODEL, CommonConstant.HTTP_INVOKE_MODEL_S);
         JSONObject businessMsgRead = new JSONObject();
-        //businessApplicationKey.putAll(paramInJson);
         businessMsgRead.put("msgReadId", "-1");
         businessMsgRead.putAll(paramInJson);
+        MsgReadPo msgReadPo = BeanConvertUtil.covertBean(businessMsgRead, MsgReadPo.class);
 
-        //璁$畻 搴旀敹閲戦
-        business.getJSONObject(CommonConstant.HTTP_BUSINESS_DATAS).put("businessMsgRead", businessMsgRead);
-        return business;
+        super.insert(context, msgReadPo, BusinessTypeConstant.BUSINESS_TYPE_SAVE_MSG_READ);
     }
 }

--
Gitblit v1.8.0