diff --git a/src/main/java/com/peanut/modules/common/entity/CourseCatalogueEntity.java b/src/main/java/com/peanut/modules/common/entity/CourseCatalogueEntity.java
index bb10f9b3..76237456 100644
--- a/src/main/java/com/peanut/modules/common/entity/CourseCatalogueEntity.java
+++ b/src/main/java/com/peanut/modules/common/entity/CourseCatalogueEntity.java
@@ -1,5 +1,6 @@
 package com.peanut.modules.common.entity;
 
+import com.baomidou.mybatisplus.annotation.TableField;
 import com.baomidou.mybatisplus.annotation.TableId;
 import com.baomidou.mybatisplus.annotation.TableLogic;
 import com.baomidou.mybatisplus.annotation.TableName;
@@ -31,4 +32,10 @@ public class CourseCatalogueEntity{
 
     @TableLogic
     private Integer delFlag;
+
+    /**
+     * 是否同步创建商品
+     */
+    @TableField(exist = false)
+    private Integer needCreate;
 }
diff --git a/src/main/java/com/peanut/modules/common/entity/ShopProduct.java b/src/main/java/com/peanut/modules/common/entity/ShopProduct.java
index 2ceb84a8..8fc2c94e 100644
--- a/src/main/java/com/peanut/modules/common/entity/ShopProduct.java
+++ b/src/main/java/com/peanut/modules/common/entity/ShopProduct.java
@@ -129,7 +129,7 @@ public class ShopProduct implements Serializable {
      */
     private Integer sumSales;
     /**
-     * 商品类型 01: 画册 02：书 04：仪器，03：预售书
+     * 商品类型01挂图02书籍03预售书04仪器05课程06小店商品
      */
     private String goodsType;
     private String goodsTypeCode;
diff --git a/src/main/java/com/peanut/modules/common/entity/ShopProductCourseEntity.java b/src/main/java/com/peanut/modules/common/entity/ShopProductCourseEntity.java
index fd5fa5e2..b632fd16 100644
--- a/src/main/java/com/peanut/modules/common/entity/ShopProductCourseEntity.java
+++ b/src/main/java/com/peanut/modules/common/entity/ShopProductCourseEntity.java
@@ -14,6 +14,8 @@ public class ShopProductCourseEntity {
     @TableId
     private Integer id;
 
+    private Integer productId;
+
     private Integer courseId;
 
     private Integer catalogueId;
diff --git a/src/main/java/com/peanut/modules/master/controller/CourseController.java b/src/main/java/com/peanut/modules/master/controller/CourseController.java
index 9c7c96f2..a39249df 100644
--- a/src/main/java/com/peanut/modules/master/controller/CourseController.java
+++ b/src/main/java/com/peanut/modules/master/controller/CourseController.java
@@ -59,9 +59,7 @@ public class CourseController {
 
     @RequestMapping("/addCourseCatalogue")
     public R addCourseCatalogue(@RequestBody CourseCatalogueEntity courseCatalogue){
-
-        //课程这里增加对应商品的还没有做
-        courseCatalogueService.save(courseCatalogue);
+        courseCatalogueService.addCourseCatalogue(courseCatalogue);
         return R.ok();
     }
 
diff --git a/src/main/java/com/peanut/modules/master/service/CourseCatalogueService.java b/src/main/java/com/peanut/modules/master/service/CourseCatalogueService.java
index 592809da..60c2cb10 100644
--- a/src/main/java/com/peanut/modules/master/service/CourseCatalogueService.java
+++ b/src/main/java/com/peanut/modules/master/service/CourseCatalogueService.java
@@ -11,4 +11,6 @@ public interface CourseCatalogueService extends IService<CourseCatalogueEntity>
     List<CourseCatalogueEntity> getCourseCatalogues(int id);
 
     R delCourseCatalogue(int id);
+
+    void addCourseCatalogue(CourseCatalogueEntity courseCatalogue);
 }
diff --git a/src/main/java/com/peanut/modules/master/service/impl/CourseCatalogueServiceImpl.java b/src/main/java/com/peanut/modules/master/service/impl/CourseCatalogueServiceImpl.java
index 5507fc34..f9a810ea 100644
--- a/src/main/java/com/peanut/modules/master/service/impl/CourseCatalogueServiceImpl.java
+++ b/src/main/java/com/peanut/modules/master/service/impl/CourseCatalogueServiceImpl.java
@@ -3,14 +3,8 @@ package com.peanut.modules.master.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.peanut.common.utils.R;
-import com.peanut.modules.common.dao.CourseCatalogueChapterDao;
-import com.peanut.modules.common.dao.CourseCatalogueDao;
-import com.peanut.modules.common.dao.ShopProductCourseDao;
-import com.peanut.modules.common.dao.UserToCourseDao;
-import com.peanut.modules.common.entity.CourseCatalogueChapterEntity;
-import com.peanut.modules.common.entity.CourseCatalogueEntity;
-import com.peanut.modules.common.entity.ShopProductCourseEntity;
-import com.peanut.modules.common.entity.UserToCourseEntity;
+import com.peanut.modules.common.dao.*;
+import com.peanut.modules.common.entity.*;
 import com.peanut.modules.master.service.CourseCatalogueService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -28,6 +22,11 @@ public class CourseCatalogueServiceImpl extends ServiceImpl<CourseCatalogueDao,
     private UserToCourseDao userToCourseDao;
     @Autowired
     private ShopProductCourseDao shopProductCourseDao;
+    @Autowired
+    private ShopProductDao shopProductDao;
+    @Autowired
+    private CourseDao courseDao;
+
 
     @Override
     public List<CourseCatalogueEntity> getCourseCatalogues(int id) {
@@ -59,4 +58,50 @@ public class CourseCatalogueServiceImpl extends ServiceImpl<CourseCatalogueDao,
         this.removeById(id);
         return R.ok();
     }
+
+
+    @Override
+    public void addCourseCatalogue(CourseCatalogueEntity courseCatalogue) {
+        this.save(courseCatalogue);
+        if(courseCatalogue.getNeedCreate()==1){
+            this.createProduct(courseCatalogue);
+        }
+
+    }
+
+
+    private void createProduct(CourseCatalogueEntity courseCatalogue){
+        CourseEntity courseEntity = courseDao.selectById(courseCatalogue.getCourseId());
+
+        //添加半年期商品
+        ShopProduct shopProduct = new ShopProduct();
+        shopProduct.setProductName(courseEntity.getTitle()+"."+courseCatalogue.getTitle()+"(半年)");
+        shopProduct.setPrice(courseCatalogue.getHalfFee());
+        shopProduct.setGoodsType("05");
+        shopProductDao.insert(shopProduct);
+        //添加半年期的商品课程对应关系
+        ShopProductCourseEntity shopProductCourseEntity = new ShopProductCourseEntity();
+        shopProductCourseEntity.setProductId(shopProduct.getProductId());
+        shopProductCourseEntity.setCourseId(courseCatalogue.getCourseId());
+        shopProductCourseEntity.setCatalogueId(courseCatalogue.getId());
+        shopProductCourseEntity.setDays(180);
+        shopProductCourseDao.insert(shopProductCourseEntity);
+
+        //添加一年期商品
+        ShopProduct shopProduct1 = new ShopProduct();
+        shopProduct1.setProductName(courseEntity.getTitle()+"."+courseCatalogue.getTitle()+"(一年)");
+        shopProduct1.setPrice(courseCatalogue.getFee());
+        shopProduct1.setGoodsType("05");
+        shopProductDao.insert(shopProduct1);
+        //添加一年期的商品课程对应关系
+        ShopProductCourseEntity shopProductCourseEntity1 = new ShopProductCourseEntity();
+        shopProductCourseEntity1.setProductId(shopProduct1.getProductId());
+        shopProductCourseEntity1.setCourseId(courseCatalogue.getCourseId());
+        shopProductCourseEntity1.setCatalogueId(courseCatalogue.getId());
+        shopProductCourseEntity1.setDays(365);
+        shopProductCourseDao.insert(shopProductCourseEntity1);
+
+
+
+    }
 }