swagger mysql

src/main/java/com/kiisoo/ic/activity/controller/ActivityController.java

@@ -1,23 +1,24 @@
 package com.kiisoo.ic.activity.controller;
 
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.kiisoo.ic.activity.entity.PmnActivityInstance;
 import com.kiisoo.ic.activity.entity.PmnActivityPromotionCase;
 import com.kiisoo.ic.activity.entity.PmnActivitySchedule;
+import com.kiisoo.ic.activity.entity.PmnActivityStoreRelation;
 import com.kiisoo.ic.activity.mapper.PmnActivityInstanceDOMapper;
 import com.kiisoo.ic.activity.mapper.PmnActivityScheduleDOMapper;
+import com.kiisoo.ic.activity.mapper.PmnActivityStoreRelationMapper;
+import com.kiisoo.ic.activity.service.IPmnActivityStoreRelationService;
 import com.kiisoo.ic.common.BaseController;
 import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.web.bind.annotation.ModelAttribute;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 @RestController
 @Api(value = "后台活动接口", tags = {"后台活动接口"})
@@ -28,6 +29,10 @@ public class ActivityController extends BaseController {
     PmnActivityScheduleDOMapper pmnActivityScheduleDOMapper;
     @Resource
     PmnActivityInstanceDOMapper pmnActivityInstanceDOMapper;
+    @Resource
+    PmnActivityStoreRelationMapper pmnActivityStoreRelationMapper;
+    @Resource
+    IPmnActivityStoreRelationService pmnActivityStoreRelationService;
 
     @ApiOperation(value = "所有活动池列表")
     @RequestMapping(value = "/schedule/list/all")
@@ -50,7 +55,7 @@ public class ActivityController extends BaseController {
     }
 
     @ApiOperation(value = "根据活动池新建实例，修改实例详情")
-    @RequestMapping(value = "/instance/save")
+    @PostMapping(value = "/instance/save")
     @ResponseBody
     public Map<String, Object> saveInstance(@ModelAttribute PmnActivityInstance instance) {
         // TODO 第一步先创建活动实例，包括活动时间范围，状态等()
@@ -72,7 +77,7 @@ public class ActivityController extends BaseController {
     }
 
     @ApiOperation(value = "根据活动实例修改场景")
-    @RequestMapping(value = "/promotionCase/save")
+    @PostMapping(value = "/promotionCase/save")
     public Map<String, Object> savePromotionCase(@ModelAttribute PmnActivityPromotionCase promotionCase){
         try {
             return data(null);
@@ -83,10 +88,36 @@ public class ActivityController extends BaseController {
     }
 
     @ApiOperation(value = "根据活动绑定店铺")
-    @RequestMapping(value = "/promotionStore/save")
-    public Map<String, Object> saveStore(){
+    @PostMapping(value = "/promotionStore/save")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "storeIds", required = true, value = "店铺ID数组", dataType = "array", paramType = "form"),
+            @ApiImplicitParam(name = "caseId", value = "场景id", dataType = "int", paramType = "form", defaultValue = "0"),
+            @ApiImplicitParam(name = "instanceId", required = true, value = "活动实例ID", dataType = "string", paramType = "form"),
+    })
+    public Map<String, Object> saveStore(@RequestBody Long[] storeIds, @RequestParam int caseId, @RequestParam Long instanceId){
         try {
-            return data(null);
+            if(storeIds.length <= 0) {
+                return fail("请选择店铺");
+            }
+            if(instanceId == null) {
+                return fail("请输入活动实例ID");
+            }
+            List<PmnActivityStoreRelation> pmnActivityStoreRelations = new ArrayList<>();
+            for (Long storeId: storeIds) {
+                PmnActivityStoreRelation pmnActivityStoreRelation = pmnActivityStoreRelationService.getOne(Wrappers.<PmnActivityStoreRelation>lambdaQuery().eq(PmnActivityStoreRelation::getStoreId, storeId).eq(PmnActivityStoreRelation::getInstanceId, instanceId));
+                if(pmnActivityStoreRelation == null) {
+                    pmnActivityStoreRelation = new PmnActivityStoreRelation();
+                }
+                pmnActivityStoreRelation.setCaseId(Long.valueOf(caseId));
+                pmnActivityStoreRelation.setCreateTime(new Date());
+                pmnActivityStoreRelation.setStatus(1);
+                pmnActivityStoreRelation.setInstanceId(instanceId);
+                pmnActivityStoreRelation.setStoreId(storeId);
+                pmnActivityStoreRelation.setUpdateTime(new Date());
+                pmnActivityStoreRelations.add(pmnActivityStoreRelation);
+            }
+            boolean save = pmnActivityStoreRelationService.saveOrUpdateBatch(pmnActivityStoreRelations);
+            return save ? success() : fail("操作失败");
         } catch (Exception e) {
             log.error("查询出错", e);
             return fail();

src/main/java/com/kiisoo/ic/activity/entity/PmnActivityStoreRelation.java

@@ -21,7 +21,7 @@ public class PmnActivityStoreRelation {
 
     private Long storeId;
 
-    private Long status;
+    private int status;
 
     private Date createTime;