From 81ed418ee16df24b768a3f78cd22d02f020d6314 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期三, 08 一月 2020 13:58:47 +0800
Subject: [PATCH] 小黄条+ 首页弹框 版本区分

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/homemodule/FloatADServiceImpl.java |  123 +++++++++++++++++++++++++++++++++++++++-
 1 files changed, 119 insertions(+), 4 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/homemodule/FloatADServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/homemodule/FloatADServiceImpl.java
index 907610e..7df4f67 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/homemodule/FloatADServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/homemodule/FloatADServiceImpl.java
@@ -3,23 +3,33 @@
 import java.io.InputStream;
 import java.text.ParseException;
 import java.text.SimpleDateFormat;
+import java.util.ArrayList;
 import java.util.Date;
+import java.util.HashSet;
 import java.util.List;
+import java.util.Set;
 import java.util.UUID;
 
 import javax.annotation.Resource;
 
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.multipart.MultipartFile;
 import org.yeshi.utils.tencentcloud.COSManager;
 
 import com.yeshi.fanli.dao.mybatis.homemodule.FloatADMapper;
+import com.yeshi.fanli.entity.AppVersionInfo;
+import com.yeshi.fanli.entity.bus.homemodule.AdActivityVersionControl;
+import com.yeshi.fanli.entity.bus.homemodule.AdActivityVersionControl.AdActivityType;
 import com.yeshi.fanli.entity.bus.homemodule.FloatAD;
 import com.yeshi.fanli.entity.bus.homemodule.FloatAD.FloatADTypeEnum;
 import com.yeshi.fanli.entity.common.JumpDetailV2;
+import com.yeshi.fanli.exception.banner.SwiperPictureException;
 import com.yeshi.fanli.exception.homemodule.FloatADException;
 import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;
+import com.yeshi.fanli.service.inter.config.AppVersionService;
+import com.yeshi.fanli.service.inter.homemodule.AdActivityVersionControlService;
 import com.yeshi.fanli.service.inter.homemodule.FloatADService;
 import com.yeshi.fanli.util.FilePathEnum;
 import com.yeshi.fanli.util.StringUtil;
@@ -32,6 +42,12 @@
 	
 	@Resource
 	private JumpDetailV2Service jumpDetailV2Service;
+	
+	@Resource
+	private AppVersionService appVersionService;
+	
+	@Resource
+	private AdActivityVersionControlService adActivityVersionControlService;
 	
 	
 	@Override
@@ -210,6 +226,12 @@
 		// 鍒犻櫎宸插瓨鍦ㄥ浘鐗�
 		for (FloatAD floatAD: listSwiper) {
 			removePicture(floatAD.getPicture());
+			
+			List<AdActivityVersionControl> versionList = adActivityVersionControlService
+					.listByTypeAndSourceId(AdActivityType.floatAD, floatAD.getId());
+			if (versionList != null)
+				for (AdActivityVersionControl control : versionList)
+					adActivityVersionControlService.deleteByPrimaryKey(control.getId());
 		}
 		
 		return floatADMapper.deleteByPrimaryKeyList(list);
@@ -274,6 +296,7 @@
 		return floatADMapper.countQuery(key, state);
 	}
 
+	@Cacheable(value = "configCache", key = "'getEffectiveFloatAD-'+#position+'-'+#type")
 	@Override
 	public FloatAD getEffectiveFloatAD(String position, Integer type) {
 		FloatAD floatAD = floatADMapper.getEffectiveFloatAD(position, type);
@@ -295,14 +318,106 @@
 	}
 	
 	
+	@Transactional(rollbackFor = Exception.class)
 	@Override
-	public List<FloatAD> getValidCommonByPosition(String position) {
-		return floatADMapper.getValidFloatAD(position, 1);
+	public void setVersions(Long id, List<Long> versions) throws Exception {
+		FloatAD record = floatADMapper.selectByPrimaryKey(id);
+		if (record == null) {
+			throw new Exception("涓撻涓嶅瓨鍦�");
+		}
+
+		Set<Long> oldSet = new HashSet<>();
+
+		List<AdActivityVersionControl> versionList = adActivityVersionControlService
+				.listByTypeAndSourceId(AdActivityType.floatAD, id);
+		if (versionList != null) {
+			for (AdActivityVersionControl control : versionList)
+				oldSet.add(control.getVersion().getId());
+		}
+
+		Set<Long> newSet = new HashSet<>();
+		for (Long version : versions) {
+			newSet.add(version);
+		}
+
+		Set<Long> delSet = new HashSet<>();
+		delSet.addAll(oldSet);
+		delSet.removeAll(newSet);
+		for (Long versionId : delSet) {
+			adActivityVersionControlService.deleteBySourceAndVersion(id, AdActivityType.floatAD, versionId);
+		}
+
+		Set<Long> addSet = new HashSet<>();
+		addSet.addAll(newSet);
+		addSet.removeAll(oldSet);
+		// 娣诲姞鏄犲皠
+		for (Long versionId : addSet) {
+			AdActivityVersionControl control = new AdActivityVersionControl();
+			control.setCreateTime(new Date());
+			control.setSourceId(id);
+			control.setType(AdActivityType.floatAD);
+			control.setVersion(new AppVersionInfo(versionId));
+			try {
+				adActivityVersionControlService.addVersionControl(control);
+			} catch (Exception e) {
+				throw new SwiperPictureException(2, e.getMessage());
+			}
+		}
 	}
 	
+	@Cacheable(value = "configCache", key = "'getValidFloatADCache-'+#position+'-'+#type+'-'+#platform+'-'+#versionCode")
 	@Override
-	public List<FloatAD> getValidByPosition(String position) {
-		return floatADMapper.getValidFloatAD(position, null);
+	public List<FloatAD> getValidFloatADCache(String position, Integer type, String platform, Integer versionCode) {
+		List<FloatAD> list = floatADMapper.getValidFloatAD(position, type);
+		// 杩囨护
+		filterFloatAD(list, platform, versionCode);
+		
+		return list;
 	}
+	
+	/**
+	 * 杩囨护
+	 * 
+	 * @param list
+	 * @param platform
+	 * @param versionCode
+	 */
+	private void filterFloatAD(List<FloatAD> list, String platform, int versionCode) {
+		if (list == null || list.size() == 0)
+			return;
+		AppVersionInfo app = appVersionService.getClientVersion(platform, versionCode);
+		if (app == null) {
+			list.clear();
+			return;
+		}
+		List<Long> versionIdList = new ArrayList<>();
+		versionIdList.add(app.getId());
+		List<Long> sourceIdList = new ArrayList<>();
+		for (FloatAD record : list) {
+			sourceIdList.add(record.getId());
+		}
+
+		Set<Long> sourceIds = adActivityVersionControlService.filterSourceIdByVersion(sourceIdList,
+				AdActivityType.floatAD, versionIdList);
+		
+		for (int i = 0; i < list.size(); i++) {
+			// 杩囨护鐗堟湰
+			if (!sourceIds.contains(list.get(i).getId())) {
+				list.remove(i--);
+				continue;
+			}
+			
+			// 璺宠浆鏄惁鐧诲綍
+			FloatAD floatAD = list.get(i);
+			JumpDetailV2 jumpDetail = floatAD.getJumpDetail();
+			if (jumpDetail != null) {
+				jumpDetail = jumpDetailV2Service.selectByPrimaryKey(jumpDetail.getId());
+				if (jumpDetail != null) {
+					jumpDetail.setNeedLogin(floatAD.isJumpNeedLogin());
+				}
+			}
+		}
+	}
+
 }
 

--
Gitblit v1.8.0