|
|
@@ -45,4 +45,27 @@ public class ConsumeEventStrategyImpl implements IYktEventStrategy {
|
|
|
remoteConsumeService.dealKafkaConsumeData(recordBo);
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ public static void main(String[] args) {
|
|
|
+ String msg = "{\n" +
|
|
|
+ " \"cardNo\": 35193,\n" +
|
|
|
+ " \"consumeDate\": \"2025-02-19 19:32:30\",\n" +
|
|
|
+ " \"consumeMoney\": 0.00,\n" +
|
|
|
+ " \"creditType\": \"TERM_CONSUME\",\n" +
|
|
|
+ " \"factoryId\": 3656457030,\n" +
|
|
|
+ " \"operatorId\": 0,\n" +
|
|
|
+ " \"realName\": \"苏兵\",\n" +
|
|
|
+ " \"recordStatus\": 364,\n" +
|
|
|
+ " \"statusFlag\": 4,\n" +
|
|
|
+ " \"termNo\": 100,\n" +
|
|
|
+ " \"termRecordId\": 47309,\n" +
|
|
|
+ " \"userNo\": 0,\n" +
|
|
|
+ " \"userNumb\": \"15674973790\"\n" +
|
|
|
+ " }";
|
|
|
+ JSONObject entries = JSONUtil.parseObj(msg);
|
|
|
+ entries.set("creditType", null);
|
|
|
+ entries.set("useType", null);
|
|
|
+ RemoteConsumeBo recordBo = JSONUtil.toBean(entries, RemoteConsumeBo.class);
|
|
|
+ System.err.println(recordBo);
|
|
|
+ }
|
|
|
}
|