<chore>[ceph]: support systemTag for diskAO.diskOfferingUuid

the systemTag for diskAO.diskOfferingUuid is not initialized in
the previous version and uses the default value of the systemTag.
so, now initialize the systemTag for each diskAO whose
diskOfferingUuid is not null.

Resolves: ZSV-11278

Change-Id: I616462756a656e646563716579716a6172687573

Author: Chen, Taiyue

plugin/ceph/src/main/java/org/zstack/storage/ceph/primary/CephPrimaryStorageFactory.java

@@ -799,6 +799,7 @@ private Boolean isCephPrimaryStorageVolume(String volumeUuid) {
     public void preCreateVmInstance(CreateVmInstanceMsg msg) {
         settingRootVolume(msg);
         settingDataVolume(msg);
+        settingDataDisks(msg);
     }
 
     private void settingRootVolume(CreateVmInstanceMsg msg) {
@@ -909,15 +910,48 @@ private void settingDataVolume(CreateVmInstanceMsg msg) {
 
             if (config.getAllocate().getPrimaryStorage() instanceof CephPrimaryStorageAllocateConfig) {
                 CephPrimaryStorageAllocateConfig primaryStorageAllocateConfig = (CephPrimaryStorageAllocateConfig) config.getAllocate().getPrimaryStorage();
-                msg.getDataVolumeSystemTags().add(CephSystemTags.USE_CEPH_PRIMARY_STORAGE_POOL.instantiateTag(
-                        map(
-                                e(CephSystemTags.USE_CEPH_PRIMARY_STORAGE_POOL_TOKEN, primaryStorageAllocateConfig.getPoolNames().get(0))
-                        )
-                ));
+                if (!isEmpty(primaryStorageAllocateConfig.getPoolNames())) {
+                    msg.getDataVolumeSystemTags().add(CephSystemTags.USE_CEPH_PRIMARY_STORAGE_POOL.instantiateTag(
+                            map(
+                                    e(CephSystemTags.USE_CEPH_PRIMARY_STORAGE_POOL_TOKEN, primaryStorageAllocateConfig.getPoolNames().get(0))
+                            )
+                    ));
+                }
             }
         }
     }
 
+    private void settingDataDisks(CreateVmInstanceMsg msg) {
+        List<DiskAO> diskAOs = msg.getDataDisks();
+        if (diskAOs == null) {
+            return;
+        }
+        for (DiskAO diskAO : diskAOs) {
+            String diskOffering = diskAO.getDiskOfferingUuid();
+            if (diskOffering == null || !DiskOfferingSystemTags.DISK_OFFERING_USER_CONFIG.hasTag(diskOffering)) {
+                continue;
+            }
+            DiskOfferingUserConfig config = OfferingUserConfigUtils.getDiskOfferingConfig(diskOffering, DiskOfferingUserConfig.class);
+            if (config.getAllocate() == null) {
+                continue;
+            }
+
+            if (diskAO.getSystemTags() == null) {
+                diskAO.setSystemTags(new ArrayList<>());
+            }
+
+            if (config.getAllocate().getPrimaryStorage() instanceof CephPrimaryStorageAllocateConfig) {
+                CephPrimaryStorageAllocateConfig primaryStorageAllocateConfig = (CephPrimaryStorageAllocateConfig) config.getAllocate().getPrimaryStorage();
+                if (!isEmpty(primaryStorageAllocateConfig.getPoolNames())) {
+                    diskAO.getSystemTags().add(CephSystemTags.USE_CEPH_PRIMARY_STORAGE_POOL.instantiateTag(
+                            map(
+                                    e(CephSystemTags.USE_CEPH_PRIMARY_STORAGE_POOL_TOKEN, primaryStorageAllocateConfig.getPoolNames().get(0))
+                            )
+                    ));
+                }
+            }
+        }
+    }
     @Override
     public void preCreateVolume(VolumeCreateMessage msg) {
         String diskOffering = msg.getDiskOfferingUuid();