|
@@ -26,7 +26,6 @@ import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
|
|
import java.time.LocalDateTime;
|
|
import java.time.LocalDateTime;
|
|
|
import java.time.LocalTime;
|
|
import java.time.LocalTime;
|
|
|
-import java.util.HashMap;
|
|
|
|
|
|
|
|
|
|
import static com.kym.entity.admin.Activity.APPLY_STATION_部分站点;
|
|
import static com.kym.entity.admin.Activity.APPLY_STATION_部分站点;
|
|
|
import static com.kym.entity.admin.Activity.DISCOUNT_TYPE_服务费折扣权益;
|
|
import static com.kym.entity.admin.Activity.DISCOUNT_TYPE_服务费折扣权益;
|
|
@@ -67,7 +66,7 @@ public class ActivityServiceImpl extends ServiceImpl<ActivityMapper, Activity> i
|
|
|
*/
|
|
*/
|
|
|
@Override
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@Transactional(rollbackFor = Exception.class)
|
|
|
- public ActivityVo createActivity(ActivityVo activityVo) {
|
|
|
|
|
|
|
+ public void createActivity(ActivityVo activityVo) {
|
|
|
// 新增activity
|
|
// 新增activity
|
|
|
var activity = new Activity();
|
|
var activity = new Activity();
|
|
|
activity.setId(IDGenerator.INS().nextId());
|
|
activity.setId(IDGenerator.INS().nextId());
|
|
@@ -82,12 +81,13 @@ public class ActivityServiceImpl extends ServiceImpl<ActivityMapper, Activity> i
|
|
|
|
|
|
|
|
// 新增rechargeRights
|
|
// 新增rechargeRights
|
|
|
if (activityVo.getDiscountType().equals(DISCOUNT_TYPE_服务费折扣权益) && !CommUtil.isEmptyOrNull(activityVo.getRechargeRightsList())) {
|
|
if (activityVo.getDiscountType().equals(DISCOUNT_TYPE_服务费折扣权益) && !CommUtil.isEmptyOrNull(activityVo.getRechargeRightsList())) {
|
|
|
- var rechargeRightsList = activityVo.getRechargeRightsList().stream().peek(rechargeRights -> BeanUtils.copyProperties(activity, rechargeRights)).toList();
|
|
|
|
|
|
|
+ var rechargeRightsList = activityVo.getRechargeRightsList().stream().peek(rechargeRights -> {
|
|
|
|
|
+ BeanUtils.copyProperties(activity, rechargeRights, "id");
|
|
|
|
|
+ rechargeRights.setActivityId(activity.getId());
|
|
|
|
|
+ }).toList();
|
|
|
rechargeRightsService.saveBatch(rechargeRightsList);
|
|
rechargeRightsService.saveBatch(rechargeRightsList);
|
|
|
activityVo.setRechargeRightsList(rechargeRightsList);
|
|
activityVo.setRechargeRightsList(rechargeRightsList);
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
- return activityVo;
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -111,20 +111,22 @@ public class ActivityServiceImpl extends ServiceImpl<ActivityMapper, Activity> i
|
|
|
/**
|
|
/**
|
|
|
* 活动详情
|
|
* 活动详情
|
|
|
*
|
|
*
|
|
|
- * @param params
|
|
|
|
|
|
|
+ * @param activityId
|
|
|
* @return
|
|
* @return
|
|
|
*/
|
|
*/
|
|
|
@Override
|
|
@Override
|
|
|
- public HashMap<String, Object> activityDetail(ActivityQueryParam params) {
|
|
|
|
|
- var res = new HashMap<String, Object>(2);
|
|
|
|
|
- if (params.getDiscountType().equals(DISCOUNT_TYPE_服务费折扣权益)) {
|
|
|
|
|
- var rechargeRightsList = rechargeRightsService.lambdaQuery().eq(RechargeRights::getActivityId, params.getId()).list();
|
|
|
|
|
- res.put("rechargeRightsList", rechargeRightsList);
|
|
|
|
|
- var activityStationIds = activityStationService.lambdaQuery().eq(ActivityStation::getActivityId, params.getId()).list().stream().map(ActivityStation::getStationId).toList();
|
|
|
|
|
|
|
+ public ActivityVo activityDetail(String activityId) {
|
|
|
|
|
+ var activity = lambdaQuery().eq(Activity::getId, activityId).one();
|
|
|
|
|
+ var activityVo = new ActivityVo();
|
|
|
|
|
+ BeanUtils.copyProperties(activity, activityVo);
|
|
|
|
|
+ if (activity.getDiscountType().equals(DISCOUNT_TYPE_服务费折扣权益)) {
|
|
|
|
|
+ var rechargeRightsList = rechargeRightsService.lambdaQuery().eq(RechargeRights::getActivityId, activityId).list();
|
|
|
|
|
+ activityVo.setRechargeRightsList(rechargeRightsList);
|
|
|
|
|
+ var activityStationIds = activityStationService.lambdaQuery().eq(ActivityStation::getActivityId, activityId).list().stream().map(ActivityStation::getStationId).toList();
|
|
|
var stationList = stationService.lambdaQuery().in(Station::getStationId, activityStationIds).list();
|
|
var stationList = stationService.lambdaQuery().in(Station::getStationId, activityStationIds).list();
|
|
|
- res.put("stationList", stationList);
|
|
|
|
|
|
|
+ activityVo.setStationList(stationList);
|
|
|
}
|
|
}
|
|
|
- return res;
|
|
|
|
|
|
|
+ return activityVo;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|