From cc88ea25dc395b5d1b9b5ac9ddba7713c667c1c1 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 17 十二月 2019 12:45:38 +0800
Subject: [PATCH] 专题与banner设置版本管理

---
 fanli/src/main/java/com/yeshi/fanli/service/impl/homemodule/SwiperPictureServiceImpl.java |  214 ++++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 161 insertions(+), 53 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/homemodule/SwiperPictureServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/homemodule/SwiperPictureServiceImpl.java
index ef56422..39603e7 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/homemodule/SwiperPictureServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/homemodule/SwiperPictureServiceImpl.java
@@ -3,8 +3,11 @@
 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;
@@ -16,10 +19,16 @@
 import org.yeshi.utils.tencentcloud.COSManager;
 
 import com.yeshi.fanli.dao.mybatis.homemodule.SwiperPictureMapper;
+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.Special;
 import com.yeshi.fanli.entity.bus.homemodule.SwiperPicture;
 import com.yeshi.fanli.entity.common.JumpDetailV2;
 import com.yeshi.fanli.exception.banner.SwiperPictureException;
 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.SwiperPictureService;
 import com.yeshi.fanli.util.StringUtil;
 
@@ -28,11 +37,15 @@
 
 	@Resource
 	private SwiperPictureMapper swiperPictureMapper;
-	
+
 	@Resource
 	private JumpDetailV2Service jumpDetailV2Service;
-	
 
+	@Resource
+	private AdActivityVersionControlService adActivityVersionControlService;
+
+	@Resource
+	private AppVersionService appVersionService;
 
 	@Override
 	public int insertSelective(SwiperPicture record) {
@@ -50,47 +63,47 @@
 	}
 
 	@Override
-	public int updateByPrimaryKey(SwiperPicture record){
+	public int updateByPrimaryKey(SwiperPicture record) {
 		return swiperPictureMapper.updateByPrimaryKey(record);
 	}
 
 	@Override
-	public List<SwiperPicture> queryByBannerID(long start, int count, Long bannerId) throws SwiperPictureException{
+	public List<SwiperPicture> queryByBannerID(long start, int count, Long bannerId) throws SwiperPictureException {
 		return swiperPictureMapper.queryByBannerID(start, count, bannerId);
 	}
 
 	@Override
-	public long countQueryByBannerID(Long bannerId) throws SwiperPictureException{
+	public long countQueryByBannerID(Long bannerId) throws SwiperPictureException {
 		return swiperPictureMapper.countQueryByBannerID(bannerId);
 	}
 
-	
 	@Override
-	public void saveObject(MultipartFile file, SwiperPicture record, String jumpType) throws SwiperPictureException, Exception{
-		
+	public void saveObject(MultipartFile file, SwiperPicture record, String jumpType)
+			throws SwiperPictureException, Exception {
+
 		if (record == null) {
 			throw new SwiperPictureException(1, "鍙傛暟涓嶈兘涓虹┖");
 		}
-		
+
 		Long bannerId = record.getBannerId();
 		if (bannerId == null) {
 			throw new SwiperPictureException(1, "鏍囪瘑绠$悊ID涓嶈兘涓虹┖");
 		}
-		
+
 		String params = record.getParams();
-		if (params == null || params.trim().length() == 0 || "null".equalsIgnoreCase(params) ) {
+		if (params == null || params.trim().length() == 0 || "null".equalsIgnoreCase(params)) {
 			record.setParams(null);
 		} else if (!StringUtil.isJson(params)) {
 			throw new SwiperPictureException(1, "璺宠浆鍙傛暟闈濲SON鏍煎紡");
 		}
-		
+
 		if (!StringUtil.isNullOrEmpty(jumpType)) {
 			List<JumpDetailV2> listByType = jumpDetailV2Service.listByType(jumpType);
-			if (listByType !=null && listByType.size() > 0) {
+			if (listByType != null && listByType.size() > 0) {
 				record.setJumpDetail(listByType.get(0));
-			} 
+			}
 		}
-		
+
 		try {
 			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm");
 			String startTime_str = record.getStartTime_str();
@@ -98,40 +111,39 @@
 				startTime_str = startTime_str.replaceAll("T", " ");
 				record.setStartTime(format.parse(startTime_str));
 			}
-			
+
 			String endTime_str = record.getEndTime_str();
 			if (endTime_str != null && endTime_str.trim().length() > 0) {
 				endTime_str = endTime_str.replaceAll("T", " ");
 				record.setEndTime(format.parse(endTime_str));
 			}
-			
+
 		} catch (ParseException e) {
 			e.printStackTrace();
 		}
-		
+
 		String remark = record.getRemark();
 		if (remark != null && (remark.trim().length() == 0 || remark.equalsIgnoreCase("null"))) {
 			record.setRemark(null);
 		}
-		
-		
+
 		String picture = null;
 		if (file != null) {
 			picture = uploadPicture(file);
 		}
-		
+
 		Long id = record.getId();
-		
+
 		if (id == null) {
 			int maxOrder = swiperPictureMapper.getMaxOrderByBannerID(bannerId);
 			record.setOrder(maxOrder + 1);
-			
+
 			Integer state = record.getState();
 			// 榛樿鍋滅敤
 			if (state == null) {
 				record.setState(1);
 			}
-			
+
 			Integer autoControl = record.getAutoControl();
 			if (autoControl == null) {
 				// 榛樿闈炵郴缁熸帶鍒�
@@ -140,7 +152,7 @@
 			record.setCreatetime(new Date());
 			record.setUpdatetime(new Date());
 			record.setSrc(picture);
-			
+
 			swiperPictureMapper.insert(record);
 		} else {
 			// 淇敼
@@ -148,49 +160,49 @@
 			if (resultObj == null) {
 				throw new SwiperPictureException(1, "鍙傛暟涓嶈兘涓虹┖");
 			}
-			
+
 			if (picture != null && picture.trim().length() > 0) {
 				// 鍒犻櫎宸插瓨鍦ㄥ浘鐗�
 				removePicture(resultObj);
-				
+
 				record.setSrc(picture);
 			} else {
 				record.setSrc(resultObj.getSrc());
 			}
-			
+
 			record.setOrder(resultObj.getOrder());
 			record.setCreatetime(resultObj.getCreatetime());
 			record.setUpdatetime(new Date());
-			
+
 			swiperPictureMapper.updateByPrimaryKey(record);
 		}
 	}
-	
 
 	/**
 	 * 涓婁紶鍥剧墖
+	 * 
 	 * @param file
 	 * @return
 	 * @throws Exception
 	 */
 	public String uploadPicture(MultipartFile file) throws Exception {
-		
-		// 鏂囦欢瑙f瀽 
+
+		// 鏂囦欢瑙f瀽
 		InputStream inputStream = file.getInputStream();
 		String contentType = file.getContentType();
 		String type = contentType.substring(contentType.indexOf("/") + 1);
-	
+
 		// 鏂囦欢璺緞
-		String filePath="/img/swiperPic/"+UUID.randomUUID().toString().replace("-", "") + "." + type;
+		String filePath = "/img/swiperPic/" + UUID.randomUUID().toString().replace("-", "") + "." + type;
 		// 鎵ц涓婁紶
-		String fileLink= COSManager.getInstance().uploadFile(inputStream, filePath).getUrl();
-		
+		String fileLink = COSManager.getInstance().uploadFile(inputStream, filePath).getUrl();
+
 		return fileLink;
 	}
-	
-	
+
 	/**
 	 * 鍒犻櫎鍥剧墖-涓嶆洿鏂版暟鎹簱
+	 * 
 	 * @param record
 	 * @throws Exception
 	 */
@@ -200,32 +212,31 @@
 			COSManager.getInstance().deleteFile(picture);
 		}
 	}
-	
+
 	@Override
 	@Transactional
-	public int deleteBatchByPrimaryKey(List<Long> list) throws SwiperPictureException{
-		
+	public int deleteBatchByPrimaryKey(List<Long> list) throws SwiperPictureException {
+
 		List<SwiperPicture> listSwiper = swiperPictureMapper.queryByListPrimaryKey(list);
-		for (SwiperPicture swiperPicture: listSwiper) {
+		for (SwiperPicture swiperPicture : listSwiper) {
 			String src = swiperPicture.getSrc();
 			if (!StringUtil.isNullOrEmpty(src)) {
 				COSManager.getInstance().deleteFile(src);
 			}
 		}
-		
+
 		return swiperPictureMapper.deleteBatchByPrimaryKey(list);
 	}
 
 	@Override
-	public int deleteBatchByBannerID(List<Long> list) throws SwiperPictureException{
+	public int deleteBatchByBannerID(List<Long> list) throws SwiperPictureException {
 		return swiperPictureMapper.deleteBatchByBannerID(list);
 	}
-	
+
 	@Override
-	public List<SwiperPicture> queryByListBannerID(List<Long> list) throws Exception{
+	public List<SwiperPicture> queryByListBannerID(List<Long> list) throws Exception {
 		return swiperPictureMapper.queryByListBannerID(list);
 	}
-
 
 	@Override
 	public List<SwiperPicture> getOrderByBannerID(Long bannerId, Integer type, Integer order) {
@@ -236,13 +247,13 @@
 	public int getMaxOrderByBannerID(Long bannerId) throws SwiperPictureException {
 		return swiperPictureMapper.getMaxOrderByBannerID(bannerId);
 	}
-	
+
 	@Override
 	@Cacheable(value = "bannerCache", key = "'getByBannerCard-'+#card")
 	public List<SwiperPicture> getByBannerCard(String card) {
 		List<SwiperPicture> list = swiperPictureMapper.getByBannerCard(card);
 		if (list != null && list.size() > 0) {
-			for (SwiperPicture swiperPicture: list) {
+			for (SwiperPicture swiperPicture : list) {
 				boolean needLogin = swiperPicture.isJumpNeedLogin();
 				JumpDetailV2 jumpDetail = swiperPicture.getJumpDetail();
 				if (jumpDetail != null) {
@@ -253,13 +264,110 @@
 		}
 		return list;
 	}
-	
-	
+
+	/**
+	 * 涓撻鐗堟湰杩囨护
+	 * 
+	 * @param list
+	 * @param platform
+	 * @param versionCode
+	 */
+	private void filterSwipePicture(List<SwiperPicture> 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 (SwiperPicture picture : list) {
+			sourceIdList.add(picture.getId());
+		}
+
+		Set<Long> sourceIds = adActivityVersionControlService.filterSourceIdByVersion(sourceIdList,
+				AdActivityType.banner, versionIdList);
+		for (int i = 0; i < list.size(); i++) {
+			if (!sourceIds.contains(list.get(i).getId())) {
+				list.remove(i--);
+			}
+		}
+	}
+
+	@Cacheable(value = "bannerCache", key = "'getByBannerCardAndVersion-'+#card+'-'+#platform+'-'+#version")
+	@Override
+	public List<SwiperPicture> getByBannerCardAndVersion(String card, String platform, int version) {
+		List<SwiperPicture> list = swiperPictureMapper.getByBannerCard(card);
+		filterSwipePicture(list, platform, version);
+		return list;
+	}
+
 	@Override
 	@Cacheable(value = "bannerCache", key = "'getByBannerId-'+#bannerId")
 	public List<SwiperPicture> getByBannerId(Long bannerId) {
 		return swiperPictureMapper.getByBannerId(bannerId);
 	}
-	
-}
 
+	@Cacheable(value = "bannerCache", key = "'getByBannerId-'+#bannerId+'-'+#platform+'-'+#version")
+	@Override
+	public List<SwiperPicture> getByBannerId(Long bannerId, String platform, int version)
+			throws SwiperPictureException {
+		List<SwiperPicture> pictureList = swiperPictureMapper.getByBannerId(bannerId);
+		filterSwipePicture(pictureList, platform, version);
+		return pictureList;
+	}
+
+	@Transactional(rollbackFor = Exception.class)
+	@Override
+	public void setVersions(Long id, List<Long> versions) throws SwiperPictureException {
+		SwiperPicture swiperPicture = selectByPrimaryKey(id);
+		if (swiperPicture == null) {
+			throw new SwiperPictureException(1, "Banner涓嶅瓨鍦�");
+		}
+
+		Set<Long> oldSet = new HashSet<>();
+
+		List<AdActivityVersionControl> versionList = adActivityVersionControlService
+				.listByTypeAndSourceId(AdActivityType.banner, swiperPicture.getId());
+		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.banner, 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(swiperPicture.getId());
+			control.setType(AdActivityType.banner);
+			control.setVersion(new AppVersionInfo(versionId));
+			try {
+				adActivityVersionControlService.addVersionControl(control);
+			} catch (Exception e) {
+				throw new SwiperPictureException(2, e.getMessage());
+			}
+		}
+
+	}
+
+}

--
Gitblit v1.8.0