河北客户体验管理系统移网网络体验明细日信息定时任务新增字段：GIS_LATLON、GIS_FLOW_CODE、SCENE_NAME、GRID、GRID_NAME

README.md

@@ -61,3 +61,13 @@ where rpt_time = '2024-04-29 00:00:00'
 group by cell_name
 having count(1) > 1
 ```
+
+## 执行河北客户体验管理系统移网网络体验明细日信息定时任务
+
+```shell
+curl http://127.0.0.1:12095/job/heDCemMobileExperienceListLogTask?param=20250310
+```
+查看结果
+
+
+http://192.168.70.171:8044/service2/optimization/mainAction?fromSystem=test&token=test_token_hebei

src/main/java/com/nokia/pm_import/task/HeDCemMobileExperienceListLogTask.java

@@ -32,6 +32,7 @@ import java.time.format.DateTimeFormatter;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.Set;
 import java.util.UUID;
 import java.util.concurrent.CompletableFuture;
@@ -118,7 +119,8 @@ public class HeDCemMobileExperienceListLogTask {
             // 定义CSV文件的表头
             List<String> headers = Stream.of("month_id", "day_id", "service_id", "contact_id", "create_time",
                     "mobile_no", "service_type_name1", "pro_name", "code_cust_area", "zyx", "lwly_name", "big_type_name",
-                    "small_type_name", "acct_month", "day_id1", "sheet_no", "compl_city_local").toList();
+                    "small_type_name", "acct_month", "day_id1", "sheet_no", "compl_city_local", "gis_latlon",
+                    "gis_flow_code", "scene_name", "grid", "grid_name").toList();
             // 获取表头的大小
             int headerSize = headers.size();
             // 定义CSV文件的分隔符
@@ -187,8 +189,13 @@ public class HeDCemMobileExperienceListLogTask {
                         data.put("countyCode", cityCode);
                         // 将cplAddress放入数据的Map
                         data.put("cplAddress", rowMap.get("compl_city_local"));
-                        // 将cplContent放入数据的Map
-                        data.put("cplContent", rowMap.get("service_type_name1"));
+                        // 2025-03-12新增字段：GIS_LATLON、GIS_FLOW_CODE、SCENE_NAME、GRID、GRID_NAME
+                        data.put("cplContent", rowMap.get("service_type_name1")
+                                + "；GIS打点经纬度：" + Objects.requireNonNullElse(rowMap.get("gis_latlon"), "")
+                                + "；场景ID：" + Objects.requireNonNullElse(rowMap.get("gis_flow_code"), "")
+                                + "；GIS打点信息：" + Objects.requireNonNullElse(rowMap.get("scene_name"), "")
+                                + "；网格id：" + Objects.requireNonNullElse(rowMap.get("grid"), "")
+                                + "；网格名称：" + Objects.requireNonNullElse(rowMap.get("grid_name"), ""));
                         // 将custTel放入数据的Map
                         data.put("custTel", rowMap.get("mobile_no"));
                         // 将faultTime放入数据的Map

src/main/resources/application-product.properties

@@ -44,8 +44,8 @@ task.pm4g.source-dir=/data/out2/pm_4g_hour/
 task.pm4g.download-dir=download/4g/
 task.pm4g.file-prefix=pm_4g_hour_
 task.pm4g.distinct-dir=distinct/4g/
-task.mobile-experience.source-dir=/data/nenglishangdian/HE_D_CEM_MOBILE_EXPERIENCE_LIST/
-task.mobile-experience.prefix=HE_D_CEM_MOBILE_EXPERIENCE_LIST_1193846275255566336_
+task.mobile-experience.source-dir=/data/nenglishangdian/HE_D_CEM_MOBILE_EXPERIENCE_LIST_NEW/
+task.mobile-experience.prefix=HE_D_CEM_MOBILE_EXPERIENCE_LIST_1348973255222370304_
 task.mobile-experience.api=http://192.168.70.171:8044/service2/optimization/mainAction/casHandler
 spring.datasource.driver-class-name=org.postgresql.Driver
 spring.datasource.username=sqmdb