diff --git a/com-core-model/src/main/java/com/jinrui/core/service/impl/MarriageActivityServiceImpl.java b/com-core-model/src/main/java/com/jinrui/core/service/impl/MarriageActivityServiceImpl.java
index 57eba72..f49f4db 100644
--- a/com-core-model/src/main/java/com/jinrui/core/service/impl/MarriageActivityServiceImpl.java
+++ b/com-core-model/src/main/java/com/jinrui/core/service/impl/MarriageActivityServiceImpl.java
@@ -118,9 +118,7 @@ public class MarriageActivityServiceImpl extends ServiceImpl<MarriageActivityMap
         marriageActivity.setCreateTime(DateTimeUtil.now());
         try {
             save(marriageActivity);
-
-            // TODO 初始化核销码
-
+            marriageCodeService.createCode(marriageActivity);
 
 
         } catch (Exception e) {
diff --git a/com-core-model/src/main/java/com/jinrui/core/service/impl/MarriageCodeServiceImpl.java b/com-core-model/src/main/java/com/jinrui/core/service/impl/MarriageCodeServiceImpl.java
index 554c54e..550b7e0 100644
--- a/com-core-model/src/main/java/com/jinrui/core/service/impl/MarriageCodeServiceImpl.java
+++ b/com-core-model/src/main/java/com/jinrui/core/service/impl/MarriageCodeServiceImpl.java
@@ -11,6 +11,7 @@ import com.jinrui.core.util.SecurityUtils;
 import org.apache.catalina.security.SecurityUtil;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 /**
  * <p>
@@ -23,6 +24,7 @@ import org.springframework.stereotype.Service;
 @Service
 public class MarriageCodeServiceImpl extends ServiceImpl<MarriageCodeMapper, MarriageCode> implements IMarriageCodeService {
 
+    @Transactional
     @Override
     @Async
     public void createCode(MarriageActivity marriageActivity) {
@@ -34,6 +36,8 @@ public class MarriageCodeServiceImpl extends ServiceImpl<MarriageCodeMapper, Mar
                     .createBy(SecurityUtils.getUsername())
                     .createTime(DateTimeUtil.now())
                     .build();
+            baseMapper.insert(marriageCode);
+
         }
 
     }