kafka-cndc-server | 修改 |

DM501未传UUID处理
mt
2025年6月23日17:45:28

@@ -47,6 +47,8 @@ public interface Constant {
         String TW = "TW";
         String TW = "TW";
         //收件人国家
         //收件人国家
         String CN = "CN";
         String CN = "CN";
+        //DM501消息的UUID为空，赋值默认值
+        String UUID_DEFAULT = "10000";
     }
     }
     //ceInfo转换为consignment忽略字段
     //ceInfo转换为consignment忽略字段
     interface CE_CONSIGNMENT_COPY_IGNORE_PROP_KEYS{
     interface CE_CONSIGNMENT_COPY_IGNORE_PROP_KEYS{

@@ -129,8 +129,15 @@ public class Dm501Util {
         }
         }
         //重量单位
         //重量单位
         ceInfo.setWeightunit(dm501Consignment.getWeightUnit());
         ceInfo.setWeightunit(dm501Consignment.getWeightUnit());
-        //用户uuid
-        ceInfo.setUserUuid(dm501Consignment.getUserId());
+        /**
+         * 用户uuid
+         * 如果后端判断下来确实有DM501存在，需要显示所有运单数据，但是UUID又为空。是不是可以给这种运单赋值一个特殊的UUID比如1000。保存的时候，如果是1000这种特殊UUID，那么就置空保存。
+         */
+        if(StringUtils.isBlank(dm501Consignment.getUserId())){
+            ceInfo.setUserUuid(Constant.CE_INFO_KEYS.UUID_DEFAULT);
+        }else{
+            ceInfo.setUserUuid(dm501Consignment.getUserId());
+        }
         //发件人邮箱
         //发件人邮箱
         ceInfo.setShipperEmail(dm501Consignment.getShipperEmail());
         ceInfo.setShipperEmail(dm501Consignment.getShipperEmail());
         //参考信息
         //参考信息