feature: 微盟订单

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/content/MallOrderStatusChangeApiServiceImpl.java

@@ -193,11 +193,11 @@ public class MallOrderStatusChangeApiServiceImpl implements MallOrderStatusChang
             }
             memberOrderBo.setTimes(memberOrderBo.getTimes() + 1);
             try {
-                log.info("发送微盟订单处理消息 {}", "dealweimoOrder");
+                log.info("发送微盟订单处理消息 {}", params);
                 /**
                  * @see com.gic.haoban.manage.api.service.content.MallOrderStatusChangeApiService#dealWeimoOrder(String)
                  */
-                GICMQClientUtil.getClientInstance().sendMessage("dealWeimoOrder", JSON.toJSONString(memberOrderBo), 60);
+                GICMQClientUtil.getClientInstance().sendMessage("dealWeimoOrderForInteractRecord", JSON.toJSONString(memberOrderBo), 60);
             }catch (Exception ex) {
                 log.info("处理会员订单异常 ", ex);
             }

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/KafkaMessageServiceImpl.java

@@ -28,6 +28,7 @@ import org.apache.commons.lang3.StringUtils;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.kafka.listener.MessageListener;
 
@@ -99,14 +100,16 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
         }
         else if (StringUtils.startsWith(record.value().getTableName(), tab_gic_eorder)) {
             // 处理线上单微盟订单
-            MemberOrderBo memberOrderBo = EntityUtil.changeEntityByJSON(MemberOrderBo.class, pojo);
+            MemberOrderBo memberOrderBo = new MemberOrderBo();
+            BeanUtils.copyProperties((MaterialMemberEOrderPojo)pojo, memberOrderBo);
             this.dealMemberOrder(memberOrderBo);
             // 处理会员订单新增事件
             dealMemberEOrder((MaterialMemberEOrderPojo) pojo);
         }
         else if (StringUtils.startsWith(record.value().getTableName(), tab_gic_order)) {
 
-            MemberOrderBo memberOrderBo = EntityUtil.changeEntityByJSON(MemberOrderBo.class, pojo);
+            MemberOrderBo memberOrderBo = new MemberOrderBo();
+            BeanUtils.copyProperties((MaterialMemberGicOrderPojo)pojo, memberOrderBo);
             this.dealMemberOrder(memberOrderBo);
             // 处理会员订单新增事件
             dealMemberGicOrder((MaterialMemberGicOrderPojo) pojo);
@@ -316,17 +319,17 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
             return;
         }
         try {
-            logger.info("发送微盟订单处理消息 dealweimoOrder {}", JSON.toJSONString(memberOrderBo));
+            logger.info("发送微盟订单处理消息 dealWeimoOrderForInteractRecord {}", JSON.toJSONString(memberOrderBo));
             /**
              * @see com.gic.haoban.manage.api.service.content.MallOrderStatusChangeApiService#dealWeimoOrder(String) 
              */
-            GICMQClientUtil.getClientInstance().sendMessage("dealWeimoOrder", JSON.toJSONString(memberOrderBo));
+            GICMQClientUtil.getClientInstance().sendMessage("dealWeimoOrderForInteractRecord", JSON.toJSONString(memberOrderBo));
         }catch (Exception ex) {
             logger.info("处理会员订单异常 ", ex);
         }
 
         try {
-            logger.info("发送微盟订单处理消息 {}", "recordMemberOrderForData");
+            logger.info("发送微盟订单处理消息 recordMemberOrderForData");
             /**
              * @see QywxGroupMsgTaskApiService#recordMemberOrderForData(String)
              */