feature: 日志打印

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

@@ -165,9 +165,12 @@ public class MallOrderStatusChangeApiServiceImpl implements MallOrderStatusChang
     @Override
     public ServiceResponse<Void> dealWeimoOrder(String params) {
 
+        log.info("处理微盟订单 {}", params);
+
         //订单分为tab_gic_eorder 和 tab_gic_ordeer
         MemberOrderBo memberOrderBo = JSON.parseObject(params, MemberOrderBo.class);
         if (memberOrderBo == null) {
+            log.info("dealWeimoOrder 数据为空 {}", params);
             return ServiceResponse.success();
         }
         String enterpriseId = memberOrderBo.getEnterpriseId();

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

@@ -325,36 +325,36 @@ public class QywxGroupMsgTaskApiServiceImpl implements QywxGroupMsgTaskApiServic
 
         }
         List<OrderConvertBo> orderConvertBos = new ArrayList<>();
-        try {
-            HoloClient client = holoDataSource.getClient();
-            if (client == null) {
-                log.error("recordMemberOrderForData 数仓数据源链接异常, 请检查！！！！{}", JSON.toJSONString(orderConvertBos));
-                return ServiceResponse.success();
-            }
-            TableSchema tableSchema = client.getTableSchema("tab_haoban_trigger_customer_detail");
-
-            SerializeConfig serializeConfig = new SerializeConfig();
-            serializeConfig.setPropertyNamingStrategy(PropertyNamingStrategy.SnakeCase);
-            // id, enterprise_id, wx_enterprise_id, biz_id, biz_type, clerk_id, staff_id,store_id, channel_type, customer_id, create_time, update_time, delete_flag
-            List<Put> puts = orderConvertBos
-                    .stream()
-                    .map(item -> {
-                        Put temp = new Put(tableSchema);
-                        JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(item, serializeConfig));
-                        for (Map.Entry<String, Object> entry : jsonObject.entrySet()) {
-                            temp.setObject(entry.getKey(), entry.getValue());
-                        }
-                        // 时间戳格式不行
-                        temp.setObject("create_time", com.gic.haoban.common.utils.DateUtil.dateToStr(new Date(), "yyyy-MM-dd HH:mm:ss"));
-                        temp.setObject("update_time", com.gic.haoban.common.utils.DateUtil.dateToStr(new Date(), "yyyy-MM-dd HH:mm:ss"));
-                        return temp;
-                    })
-                    .collect(Collectors.toList());
-            client.put(puts);
-            log.info("recordMemberOrderForData 会员订单数据组写入完成 >>>>>");
-        }catch (Exception ex) {
-            log.info("recordMemberOrderForData 数据组写入异常 {}", JSON.toJSONString(orderConvertBos), ex);
-        }
+//        try {
+//            HoloClient client = holoDataSource.getClient();
+//            if (client == null) {
+//                log.error("recordMemberOrderForData 数仓数据源链接异常, 请检查！！！！{}", JSON.toJSONString(orderConvertBos));
+//                return ServiceResponse.success();
+//            }
+//            TableSchema tableSchema = client.getTableSchema("tab_haoban_trigger_customer_detail");
+//
+//            SerializeConfig serializeConfig = new SerializeConfig();
+//            serializeConfig.setPropertyNamingStrategy(PropertyNamingStrategy.SnakeCase);
+//            // id, enterprise_id, wx_enterprise_id, biz_id, biz_type, clerk_id, staff_id,store_id, channel_type, customer_id, create_time, update_time, delete_flag
+//            List<Put> puts = orderConvertBos
+//                    .stream()
+//                    .map(item -> {
+//                        Put temp = new Put(tableSchema);
+//                        JSONObject jsonObject = JSON.parseObject(JSON.toJSONString(item, serializeConfig));
+//                        for (Map.Entry<String, Object> entry : jsonObject.entrySet()) {
+//                            temp.setObject(entry.getKey(), entry.getValue());
+//                        }
+//                        // 时间戳格式不行
+//                        temp.setObject("create_time", com.gic.haoban.common.utils.DateUtil.dateToStr(new Date(), "yyyy-MM-dd HH:mm:ss"));
+//                        temp.setObject("update_time", com.gic.haoban.common.utils.DateUtil.dateToStr(new Date(), "yyyy-MM-dd HH:mm:ss"));
+//                        return temp;
+//                    })
+//                    .collect(Collectors.toList());
+//            client.put(puts);
+//            log.info("recordMemberOrderForData 会员订单数据组写入完成 >>>>>");
+//        }catch (Exception ex) {
+//            log.info("recordMemberOrderForData 数据组写入异常 {}", JSON.toJSONString(orderConvertBos), ex);
+//        }
         return ServiceResponse.success();
     }
 }

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

@@ -316,7 +316,7 @@ public class KafkaMessageServiceImpl implements MessageListener<String, GicRecor
             return;
         }
         try {
-            logger.info("发送微盟订单处理消息 {}", "dealweimoOrder");
+            logger.info("发送微盟订单处理消息 dealweimoOrder {}", JSON.toJSONString(memberOrderBo));
             /**
              * @see com.gic.haoban.manage.api.service.content.MallOrderStatusChangeApiService#dealWeimoOrder(String) 
              */