add udf

src/main/java/com/winhc/bigdata/bean/BaseFieldMeta.java

@@ -39,6 +39,26 @@ public class BaseFieldMeta {
 
     private Integer deleted;
 
+    public Integer getField_position() {
+        return field_position;
+    }
+
+    public void setField_position(Integer field_position) {
+        this.field_position = field_position;
+    }
+
+    private Integer field_position;;
+
+    public String getCustomers_id() {
+        return customers_id;
+    }
+
+    public void setCustomers_id(String customers_id) {
+        this.customers_id = customers_id;
+    }
+
+    private String customers_id;
+
     public String getFid() {
         return fid;
     }

src/main/java/com/winhc/bigdata/udf/DataToStrV2.java

@@ -29,7 +29,7 @@ public class DataToStrV2 extends UDF {
 //    private static final String API_URL = "http://47.101.221.131:55555/api/base/findAll?sign=07014b4cc0ec4938625c9a5d67e76b61";
     //private static final String API_URL = "http://192.168.5.20:55555/api/base/findAll?sign=07014b4cc0ec4938625c9a5d67e76b61";
 //    private static final String API_URL = "http://192.168.5.20:55555/api/base/findAll";
-    private static final String API_URL = "http://192.168.2.65/api/base/findAll";
+    private static final String API_URL = "http://192.168.2.65/api/out/findAll?customers_id=base";
 
     @Override
     public void setup(ExecutionContext ctx) {
@@ -39,7 +39,7 @@ public class DataToStrV2 extends UDF {
         String res = get.execute().body();
 //        String res = HttpUtil.get(API_URL);
         List<BaseFieldMeta> baseFieldMetas = JSON.parseArray(res, BaseFieldMeta.class);
-        meta_map = baseFieldMetas.stream().collect(Collectors.groupingBy(BaseFieldMeta::getTn));
+        meta_map = baseFieldMetas.stream().filter(BaseFieldMeta::getVisible_to_customers).collect(Collectors.groupingBy(BaseFieldMeta::getTn));
     }
 
     public String evaluate(String text, String tn) {