|
@@ -1,6 +1,8 @@
|
|
package com.kmall.admin.service.impl.mk;
|
|
package com.kmall.admin.service.impl.mk;
|
|
|
|
|
|
|
|
+import com.google.common.collect.ImmutableBiMap;
|
|
import com.kmall.admin.dao.mk.MkActivitiesPresentIntegralDao;
|
|
import com.kmall.admin.dao.mk.MkActivitiesPresentIntegralDao;
|
|
|
|
+import com.kmall.admin.dto.ActivitiesPresentIntegralDto;
|
|
import com.kmall.admin.entity.mk.MkActivitiesPresentIntegralEntity;
|
|
import com.kmall.admin.entity.mk.MkActivitiesPresentIntegralEntity;
|
|
import com.kmall.admin.fromcomm.entity.SysUserEntity;
|
|
import com.kmall.admin.fromcomm.entity.SysUserEntity;
|
|
import com.kmall.admin.haikong.task.MemberSysAccessTokenRefreshTask;
|
|
import com.kmall.admin.haikong.task.MemberSysAccessTokenRefreshTask;
|
|
@@ -8,12 +10,14 @@ import com.kmall.admin.service.mk.MkActivitiesPresentIntegralService;
|
|
import com.kmall.admin.service.vip.Mall2PointsRulesService;
|
|
import com.kmall.admin.service.vip.Mall2PointsRulesService;
|
|
import com.kmall.admin.utils.ShiroUtils;
|
|
import com.kmall.admin.utils.ShiroUtils;
|
|
import com.kmall.admin.utils.jackson.JacksonUtil;
|
|
import com.kmall.admin.utils.jackson.JacksonUtil;
|
|
-import com.kmall.common.utils.R;
|
|
|
|
|
|
+import com.kmall.common.utils.*;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
|
|
+import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
|
|
+import java.math.BigDecimal;
|
|
import java.util.*;
|
|
import java.util.*;
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -46,8 +50,24 @@ public class MkActivitiesPresentIntegralServiceImpl implements MkActivitiesPrese
|
|
return mkActivitiesPresentIntegralDao.queryTotal(map);
|
|
return mkActivitiesPresentIntegralDao.queryTotal(map);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ private R check(MkActivitiesPresentIntegralEntity mkActivitiesPresentIntegral){
|
|
|
|
+ Map<String, Object> valideDate = MapBeanUtil.fromObject(mkActivitiesPresentIntegral);
|
|
|
|
+ ImmutableBiMap.Builder builder = new ImmutableBiMap.Builder();
|
|
|
|
+ builder.put("activityGiveType", "赠送方式");
|
|
|
|
+ builder.put("activityGiveNum", "赠送数值");
|
|
|
|
+ builder.put("sku", "商品sku");
|
|
|
|
+ builder.put("rejectScore", "是否与积分抵扣互斥");
|
|
|
|
+// builder.put("deadline", "截止日期");
|
|
|
|
+ R r = ValidatorUtil.isEmpty(builder.build(), valideDate);
|
|
|
|
+ return r;
|
|
|
|
+ }
|
|
|
|
+
|
|
@Override
|
|
@Override
|
|
public R save(MkActivitiesPresentIntegralEntity mkActivitiesPresentIntegral) {
|
|
public R save(MkActivitiesPresentIntegralEntity mkActivitiesPresentIntegral) {
|
|
|
|
+ R r = check(mkActivitiesPresentIntegral);
|
|
|
|
+ if (Integer.valueOf(r.get("code").toString()) != 0) {
|
|
|
|
+ return R.error(r.get("msg").toString());
|
|
|
|
+ }
|
|
log.debug("添加营销活动-赠送积分数据:{}", JacksonUtil.toJson(mkActivitiesPresentIntegral));
|
|
log.debug("添加营销活动-赠送积分数据:{}", JacksonUtil.toJson(mkActivitiesPresentIntegral));
|
|
SysUserEntity userEntity = ShiroUtils.getUserEntity();
|
|
SysUserEntity userEntity = ShiroUtils.getUserEntity();
|
|
log.debug("添加营销活动-赠送积分操作人信息:{}", JacksonUtil.toJson(userEntity));
|
|
log.debug("添加营销活动-赠送积分操作人信息:{}", JacksonUtil.toJson(userEntity));
|
|
@@ -82,18 +102,13 @@ public class MkActivitiesPresentIntegralServiceImpl implements MkActivitiesPrese
|
|
|
|
|
|
@Override
|
|
@Override
|
|
public R update(MkActivitiesPresentIntegralEntity mkActivitiesPresentIntegral) {
|
|
public R update(MkActivitiesPresentIntegralEntity mkActivitiesPresentIntegral) {
|
|
|
|
+ R r = check(mkActivitiesPresentIntegral);
|
|
|
|
+ if (Integer.valueOf(r.get("code").toString()) != 0) {
|
|
|
|
+ return R.error(r.get("msg").toString());
|
|
|
|
+ }
|
|
log.debug("修改营销活动-赠送积分数据:{}", JacksonUtil.toJson(mkActivitiesPresentIntegral));
|
|
log.debug("修改营销活动-赠送积分数据:{}", JacksonUtil.toJson(mkActivitiesPresentIntegral));
|
|
SysUserEntity userEntity = ShiroUtils.getUserEntity();
|
|
SysUserEntity userEntity = ShiroUtils.getUserEntity();
|
|
log.debug("修改营销活动-赠送积分操作人信息:{}", JacksonUtil.toJson(userEntity));
|
|
log.debug("修改营销活动-赠送积分操作人信息:{}", JacksonUtil.toJson(userEntity));
|
|
- // sku,条码,门店id查询如果有则说明添加过一次
|
|
|
|
- MkActivitiesPresentIntegralEntity query = new MkActivitiesPresentIntegralEntity();
|
|
|
|
- query.setSku(mkActivitiesPresentIntegral.getSku());
|
|
|
|
- query.setMkaId(mkActivitiesPresentIntegral.getMkaId());
|
|
|
|
-// query.setShopSn(Integer.toString(userEntity.getStoreId()));
|
|
|
|
- List<MkActivitiesPresentIntegralEntity> list = mkActivitiesPresentIntegralDao.list(query);
|
|
|
|
- if (!list.isEmpty()){
|
|
|
|
- return R.error("该赠送积分活动sku:"+mkActivitiesPresentIntegral.getSku()+"已存在!");
|
|
|
|
- }
|
|
|
|
// 校验sku 条码的准确性
|
|
// 校验sku 条码的准确性
|
|
Map<String, Object> map = new HashMap<>();
|
|
Map<String, Object> map = new HashMap<>();
|
|
map.put("sku",mkActivitiesPresentIntegral.getSku());
|
|
map.put("sku",mkActivitiesPresentIntegral.getSku());
|
|
@@ -141,4 +156,31 @@ public class MkActivitiesPresentIntegralServiceImpl implements MkActivitiesPrese
|
|
public Integer deleteByMkaId(int mkaId) {
|
|
public Integer deleteByMkaId(int mkaId) {
|
|
return mkActivitiesPresentIntegralDao.deleteByMkaId(mkaId);
|
|
return mkActivitiesPresentIntegralDao.deleteByMkaId(mkaId);
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ @Override
|
|
|
|
+ @Transactional
|
|
|
|
+ public R uploadExcel(List<ActivitiesPresentIntegralDto> activitiesPresentIntegralDtoList, String storeId, String mkaId) {
|
|
|
|
+ log.debug("营销活动-赠送积分导入数据:{},storeId:{},mkaId:{}", JacksonUtil.toJson(activitiesPresentIntegralDtoList),storeId,mkaId);
|
|
|
|
+ StringBuilder errSku = new StringBuilder();
|
|
|
|
+ activitiesPresentIntegralDtoList.forEach(activitiesPresentIntegralDto -> {
|
|
|
|
+ MkActivitiesPresentIntegralEntity mkActivitiesPresentIntegralEntity = new MkActivitiesPresentIntegralEntity();
|
|
|
|
+ mkActivitiesPresentIntegralEntity.setSku(activitiesPresentIntegralDto.getSku());
|
|
|
|
+ mkActivitiesPresentIntegralEntity.setProductName(activitiesPresentIntegralDto.getProductName());
|
|
|
|
+ mkActivitiesPresentIntegralEntity.setActivityGiveType(activitiesPresentIntegralDto.getActivityGiveType());
|
|
|
|
+ mkActivitiesPresentIntegralEntity.setActivityGiveNum(BigDecimal.valueOf(Long.parseLong(activitiesPresentIntegralDto.getActivityGiveNum())));
|
|
|
|
+ mkActivitiesPresentIntegralEntity.setProductBrand(activitiesPresentIntegralDto.getProductBrand());
|
|
|
|
+ mkActivitiesPresentIntegralEntity.setRejectScore(activitiesPresentIntegralDto.getRejectScore());
|
|
|
|
+ mkActivitiesPresentIntegralEntity.setMkaId(Long.getLong(mkaId));
|
|
|
|
+ mkActivitiesPresentIntegralEntity.setShopSn(storeId);
|
|
|
|
+ log.debug("营销活动-赠送积分数据:{}",JacksonUtil.toJson(mkActivitiesPresentIntegralEntity));
|
|
|
|
+ R r = save(mkActivitiesPresentIntegralEntity);
|
|
|
|
+ if (Integer.valueOf(r.get("code").toString()) != 0) {
|
|
|
|
+ errSku.append("sku:"+activitiesPresentIntegralDto.getSku()+","+r.get("msg").toString());
|
|
|
|
+ }
|
|
|
|
+ });
|
|
|
|
+ if (errSku.length()>0){
|
|
|
|
+ throw new RRException(errSku.toString()+",请确认导入数据无误再进行导入!");
|
|
|
|
+ }
|
|
|
|
+ return R.ok("导入成功");
|
|
|
|
+ }
|
|
}
|
|
}
|