1

陈杰
1 parent 845f9c99
Showing 16 changed files with 270 additions and 2 deletions Show diff stats
src/main/java/com/sincere/wechatbusiness/controller/ChannelController.java
src/main/java/com/sincere/wechatbusiness/dto/CopyDto.java
src/main/java/com/sincere/wechatbusiness/mapper/BannerMapper.java
src/main/java/com/sincere/wechatbusiness/mapper/BannerNextMapper.java
src/main/java/com/sincere/wechatbusiness/mapper/ChannelMapper.java
src/main/java/com/sincere/wechatbusiness/mapper/PageViewMapper.java
src/main/java/com/sincere/wechatbusiness/model/PageView.java
src/main/java/com/sincere/wechatbusiness/service/BannerService.java
src/main/java/com/sincere/wechatbusiness/service/PageViewService.java
src/main/java/com/sincere/wechatbusiness/service/impl/BannerServiceImpl.java
src/main/java/com/sincere/wechatbusiness/service/impl/PageViewServiceImpl.java
src/main/resources/mapper/BannerMapper.xml
src/main/resources/mapper/BannerNextMapper.xml
src/main/resources/mapper/CatalogMapper.xml
src/main/resources/mapper/ChannelMapper.xml
src/main/resources/mapper/PageViewMapper.xml
@@ -6,6 +6,7 @@ import com.alibaba.fastjson.TypeReference;
 import com.fasterxml.jackson.databind.ser.Serializers;
 import com.sincere.wechatbusiness.dto.BaseDto;
 import com.sincere.wechatbusiness.dto.ChannelDto;
+import com.sincere.wechatbusiness.dto.CopyDto;
 import com.sincere.wechatbusiness.logs.LogName;
 import com.sincere.wechatbusiness.logs.LoggerUtils;
 import com.sincere.wechatbusiness.model.*;
@@ -54,11 +55,67 @@ public class ChannelController {
     @Autowired
     AgentService agentService;
  
+    @Autowired
+    PageViewService pageViewService ;
+
     private static final Logger log_channel = LoggerUtils.Logger(LogName.channel);
  
 //    private String domain="https://mytest.myjxt.com:51314";
     private String domain="https://proxy.shunzhi.net:51314";
  
+
+    @RequestMapping(value = "copyChannel",method = RequestMethod.POST)
+    @ApiOperation(value = "内容下发")
+    public BaseDto copyChannel(@RequestBody CopyDto copyDto){
+        Channel channel = channelService.getDetail(copyDto.getSourceId());
+        if(channel.getTemplateId() == 1){
+            List<Banner> banners = bannerService.getList(copyDto.getSourceId());
+            Attention attention = attentionService.getDetail(copyDto.getSourceId());
+            List<Catalog> catalogs = catalogService.getList(copyDto.getSourceId());
+            for(Integer channelId : copyDto.getTargetIdList()){
+                for(Banner banner : banners){
+                    banner.setChannelId(channelId);
+                    bannerService.copy(banner);
+                }
+                if(attention != null){
+                    attention.setChannelId(channelId);
+                    attentionService.insert(attention);
+                }
+                for(Catalog catalog : catalogs){
+                    catalog.setChannelId(channelId);
+                    catalogService.insert(catalog);
+                    List<CatalogContent> list = catalogContentService.getList(catalog.getId());
+                    for(CatalogContent catalogContent : list){
+                        catalogContent.setCatalogId(catalog.getId());
+                        catalogContentService.insert(catalogContent);
+                    }
+                }
+            }
+        }else if(channel.getTemplateId() == 2){
+            List<Banner> banners = bannerService.getList(copyDto.getSourceId());
+            List<BannerNext> bannerNexts = bannerService.getBannerNextList(copyDto.getSourceId());
+            for(Integer channelId : copyDto.getTargetIdList()){
+                for(Banner banner : banners){
+                    banner.setChannelId(channelId);
+                    bannerService.copy(banner);
+                }
+                for(BannerNext bannerNext : bannerNexts){
+                    bannerNext.setChannelId(channelId);
+                    bannerService.copyBannerNext(bannerNext);
+                }
+            }
+        }
+        return new BaseDto();
+    }
+
+
+    @RequestMapping(value = "updateLook",method = RequestMethod.POST)
+    @ApiOperation(value = "增加浏览量")
+    public BaseDto updateLook(@RequestBody PageView pageView){
+        pageViewService.updateLook(pageView);
+        return new BaseDto();
+    }
+
     @RequestMapping(value = "getBannerNextList",method = RequestMethod.GET)
     @ApiOperation(value = "获取左右轮播图列表")
     public BaseDto<List<BannerNext>> getBannerNextList(int channelId){
@@ -0,0 +1,25 @@
+package com.sincere.wechatbusiness.dto;
+
+import java.util.List;
+
+public class CopyDto {
+
+    private int sourceId ;
+    private List<Integer> targetIdList ;
+
+    public int getSourceId() {
+        return sourceId;
+    }
+
+    public void setSourceId(int sourceId) {
+        this.sourceId = sourceId;
+    }
+
+    public List<Integer> getTargetIdList() {
+        return targetIdList;
+    }
+
+    public void setTargetIdList(List<Integer> targetIdList) {
+        this.targetIdList = targetIdList;
+    }
+}
@@ -12,4 +12,6 @@ public interface BannerMapper {
     int update(Banner banner);
  
     int deleteBanner(int id);
+
+    int copy(Banner banner);
 }
@@ -14,6 +14,8 @@ public interface BannerNextMapper {
  
     int insert(BannerNext record);
  
+    int copy(BannerNext record);
+
     int insertSelective(BannerNext record);
  
     BannerNext selectByPrimaryKey(Integer id);
@@ -7,6 +7,9 @@ import org.springframework.web.bind.annotation.RequestParam;
 import java.util.List;
  
 public interface ChannelMapper {
+
+    List<Channel> get2List();
+
     List<Channel> getList(Channel channel);
  
     int getListCount(Channel channel);
@@ -0,0 +1,12 @@
+package com.sincere.wechatbusiness.mapper;
+
+import com.sincere.wechatbusiness.model.PageView;
+
+public interface PageViewMapper {
+
+    int insert(PageView record);
+
+    PageView getDetail(PageView pageView);
+
+    int updateLook(PageView pageView);
+}
 \ No newline at end of file
@@ -0,0 +1,65 @@
+package com.sincere.wechatbusiness.model;
+
+import java.util.Date;
+
+public class PageView {
+    private Integer id;
+
+    private Integer channelId;
+
+    private Integer agentId;
+
+    private Integer channelProductId;
+
+    private Integer lookNumber;
+
+    private Date createTime;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public Integer getChannelId() {
+        return channelId;
+    }
+
+    public void setChannelId(Integer channelId) {
+        this.channelId = channelId;
+    }
+
+    public Integer getAgentId() {
+        return agentId;
+    }
+
+    public void setAgentId(Integer agentId) {
+        this.agentId = agentId;
+    }
+
+    public Integer getChannelProductId() {
+        return channelProductId;
+    }
+
+    public void setChannelProductId(Integer channelProductId) {
+        this.channelProductId = channelProductId;
+    }
+
+    public Integer getLookNumber() {
+        return lookNumber;
+    }
+
+    public void setLookNumber(Integer lookNumber) {
+        this.lookNumber = lookNumber;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+}
 \ No newline at end of file
@@ -10,6 +10,8 @@ public interface BannerService {
  
     int insert(Banner banner);
  
+    int copy(Banner banner);
+
     int update(Banner banner);
  
     int deleteBanner(int id);
@@ -23,4 +25,6 @@ public interface BannerService {
  
     int update(BannerNext bannerNext);
  
+    int copyBannerNext(BannerNext bannerNext);
+
 }
@@ -0,0 +1,8 @@
+package com.sincere.wechatbusiness.service;
+
+import com.sincere.wechatbusiness.model.PageView;
+
+public interface PageViewService {
+
+    int updateLook(PageView pageView);
+}
@@ -50,4 +50,14 @@ public class BannerServiceImpl implements BannerService {
     public int update(BannerNext bannerNext) {
         return bannerNextMapper.update(bannerNext);
     }
+
+    @Override
+    public int copy(Banner banner) {
+        return bannerMapper.copy(banner);
+    }
+
+    @Override
+    public int copyBannerNext(BannerNext bannerNext) {
+        return bannerNextMapper.copy(bannerNext);
+    }
 }
@@ -0,0 +1,26 @@
+package com.sincere.wechatbusiness.service.impl;
+
+import com.sincere.wechatbusiness.mapper.PageViewMapper;
+import com.sincere.wechatbusiness.model.PageView;
+import com.sincere.wechatbusiness.service.PageViewService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class PageViewServiceImpl implements PageViewService {
+
+    @Autowired
+    PageViewMapper pageViewMapper ;
+
+    @Override
+    public int updateLook(PageView pageView) {
+        PageView temp = pageViewMapper.getDetail(pageView);
+        if(temp != null){
+            pageViewMapper.updateLook(pageView);
+        }else {
+            pageView.setLookNumber(1);
+            pageViewMapper.insert(pageView);
+        }
+        return 1;
+    }
+}
@@ -20,6 +20,12 @@
       )
     </insert>
  
+    <insert id="copy" parameterType="com.sincere.wechatbusiness.model.Banner">
+    insert into banner (channelId, img_url,link_url,create_time)
+    values (#{channelId,jdbcType=INTEGER}, #{imgUrl,jdbcType=VARCHAR}, #{linkUrl,jdbcType=VARCHAR},#{createTime}
+      )
+    </insert>
+
     <update id="update" parameterType="com.sincere.wechatbusiness.model.Banner">
         update banner
         <trim prefix="set" suffixOverrides=",">
@@ -13,7 +13,7 @@
   </sql>
  
   <select id="getByChannel" parameterType="java.lang.Integer" resultMap="BaseResultMap">
-    select * from banner_next where channel_id = #{channelId} order by sort
+    select * from banner_next where channel_id = #{channelId} order by create_time
   </select>
  
   <update id="update" parameterType="com.sincere.wechatbusiness.model.BannerNext">
@@ -45,6 +45,14 @@
     values ( #{imgUrl,jdbcType=VARCHAR}, #{channelId,jdbcType=INTEGER},
       getdate(), #{sort,jdbcType=INTEGER})
   </insert>
+
+  <insert id="copy" parameterType="com.sincere.wechatbusiness.model.BannerNext">
+    insert into banner_next ( img_url, channel_id,
+      create_time, sort)
+    values ( #{imgUrl,jdbcType=VARCHAR}, #{channelId,jdbcType=INTEGER},
+      #{createTime}, #{sort,jdbcType=INTEGER})
+  </insert>
+
   <insert id="insertSelective" parameterType="com.sincere.wechatbusiness.model.BannerNext">
     insert into banner_next
     <trim prefix="(" suffix=")" suffixOverrides=",">
@@ -18,7 +18,7 @@
         select * from catalog where channelId=#{channelId} and sort=#{sort} and state=1
     </select>
  
-    <insert id="insert" parameterType="com.sincere.wechatbusiness.model.Catalog">
+    <insert id="insert" parameterType="com.sincere.wechatbusiness.model.Catalog" useGeneratedKeys="true" keyProperty="id">
     insert into catalog (channelId, name,sort)
     values (#{channelId,jdbcType=INTEGER}, #{name,jdbcType=VARCHAR}, #{sort,jdbcType=INTEGER}
       )
@@ -65,6 +65,10 @@
         <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
     </resultMap>
  
+    <select id="get2List"  resultMap="ChannelMap">
+        select * from channel where templateId = 2
+    </select>
+
     <select id="getList" parameterType="com.sincere.wechatbusiness.model.Channel" resultMap="ChannelMap">
         select *,(select count(0) from channel_product where channelId=c.id and state=1) as product_count,
          (select title from template where id=c.templateId) as template_name from channel c
@@ -0,0 +1,36 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.sincere.wechatbusiness.mapper.PageViewMapper">
+  <resultMap id="BaseResultMap" type="com.sincere.wechatbusiness.model.PageView">
+    <id column="id" jdbcType="INTEGER" property="id" />
+    <result column="channel_id" jdbcType="INTEGER" property="channelId" />
+    <result column="agent_id" jdbcType="INTEGER" property="agentId" />
+    <result column="channel_product_id" jdbcType="INTEGER" property="channelProductId" />
+    <result column="look_number" jdbcType="INTEGER" property="lookNumber" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+  </resultMap>
+  <select id="selectByPrimaryKey" parameterType="java.lang.Integer" resultMap="BaseResultMap">
+    select *
+    from page_view
+    where id = #{id,jdbcType=INTEGER}
+  </select>
+
+  <insert id="insert" parameterType="com.sincere.wechatbusiness.model.PageView">
+    insert into page_view (channel_id, agent_id,
+      channel_product_id, look_number, create_time
+      )
+    values ( #{channelId,jdbcType=INTEGER}, #{agentId,jdbcType=INTEGER},
+      #{channelProductId,jdbcType=INTEGER}, #{lookNumber,jdbcType=INTEGER}, getdate()
+      )
+  </insert>
+
+  <select id="getDetail" parameterType="com.sincere.wechatbusiness.model.PageView" resultMap="BaseResultMap">
+    select * from page_view
+    where channel_id = #{channelId} and agent_id = #{agentId} and channel_product_id = #{channelProductId}
+  </select>
+  
+  <update id="updateLook" parameterType="com.sincere.wechatbusiness.model.PageView">
+    update page_view set look_number = look_number + 1
+        where channel_id = #{channelId} and agent_id = #{agentId} and channel_product_id = #{channelProductId}
+  </update>
+</mapper>
 \ No newline at end of file
...	...	@@ -6,6 +6,7 @@ import com.alibaba.fastjson.TypeReference;
6	6	import com.fasterxml.jackson.databind.ser.Serializers;
7	7	import com.sincere.wechatbusiness.dto.BaseDto;
8	8	import com.sincere.wechatbusiness.dto.ChannelDto;
	9	+import com.sincere.wechatbusiness.dto.CopyDto;
9	10	import com.sincere.wechatbusiness.logs.LogName;
10	11	import com.sincere.wechatbusiness.logs.LoggerUtils;
11	12	import com.sincere.wechatbusiness.model.*;
...	...	@@ -54,11 +55,67 @@ public class ChannelController {
54	55	@Autowired
55	56	AgentService agentService;
56	57
	58	+ @Autowired
	59	+ PageViewService pageViewService ;
	60	+
57	61	private static final Logger log_channel = LoggerUtils.Logger(LogName.channel);
58	62
59	63	// private String domain="https://mytest.myjxt.com:51314";
60	64	private String domain="https://proxy.shunzhi.net:51314";
61	65
	66	+
	67	+ @RequestMapping(value = "copyChannel",method = RequestMethod.POST)
	68	+ @ApiOperation(value = "内容下发")
	69	+ public BaseDto copyChannel(@RequestBody CopyDto copyDto){
	70	+ Channel channel = channelService.getDetail(copyDto.getSourceId());
	71	+ if(channel.getTemplateId() == 1){
	72	+ List<Banner> banners = bannerService.getList(copyDto.getSourceId());
	73	+ Attention attention = attentionService.getDetail(copyDto.getSourceId());
	74	+ List<Catalog> catalogs = catalogService.getList(copyDto.getSourceId());
	75	+ for(Integer channelId : copyDto.getTargetIdList()){
	76	+ for(Banner banner : banners){
	77	+ banner.setChannelId(channelId);
	78	+ bannerService.copy(banner);
	79	+ }
	80	+ if(attention != null){
	81	+ attention.setChannelId(channelId);
	82	+ attentionService.insert(attention);
	83	+ }
	84	+ for(Catalog catalog : catalogs){
	85	+ catalog.setChannelId(channelId);
	86	+ catalogService.insert(catalog);
	87	+ List<CatalogContent> list = catalogContentService.getList(catalog.getId());
	88	+ for(CatalogContent catalogContent : list){
	89	+ catalogContent.setCatalogId(catalog.getId());
	90	+ catalogContentService.insert(catalogContent);
	91	+ }
	92	+ }
	93	+ }
	94	+ }else if(channel.getTemplateId() == 2){
	95	+ List<Banner> banners = bannerService.getList(copyDto.getSourceId());
	96	+ List<BannerNext> bannerNexts = bannerService.getBannerNextList(copyDto.getSourceId());
	97	+ for(Integer channelId : copyDto.getTargetIdList()){
	98	+ for(Banner banner : banners){
	99	+ banner.setChannelId(channelId);
	100	+ bannerService.copy(banner);
	101	+ }
	102	+ for(BannerNext bannerNext : bannerNexts){
	103	+ bannerNext.setChannelId(channelId);
	104	+ bannerService.copyBannerNext(bannerNext);
	105	+ }
	106	+ }
	107	+ }
	108	+ return new BaseDto();
	109	+ }
	110	+
	111	+
	112	+ @RequestMapping(value = "updateLook",method = RequestMethod.POST)
	113	+ @ApiOperation(value = "增加浏览量")
	114	+ public BaseDto updateLook(@RequestBody PageView pageView){
	115	+ pageViewService.updateLook(pageView);
	116	+ return new BaseDto();
	117	+ }
	118	+
62	119	@RequestMapping(value = "getBannerNextList",method = RequestMethod.GET)
63	120	@ApiOperation(value = "获取左右轮播图列表")
64	121	public BaseDto<List<BannerNext>> getBannerNextList(int channelId){
...	...
...	...	@@ -0,0 +1,25 @@
	1	+package com.sincere.wechatbusiness.dto;
	2	+
	3	+import java.util.List;
	4	+
	5	+public class CopyDto {
	6	+
	7	+ private int sourceId ;
	8	+ private List<Integer> targetIdList ;
	9	+
	10	+ public int getSourceId() {
	11	+ return sourceId;
	12	+ }
	13	+
	14	+ public void setSourceId(int sourceId) {
	15	+ this.sourceId = sourceId;
	16	+ }
	17	+
	18	+ public List<Integer> getTargetIdList() {
	19	+ return targetIdList;
	20	+ }
	21	+
	22	+ public void setTargetIdList(List<Integer> targetIdList) {
	23	+ this.targetIdList = targetIdList;
	24	+ }
	25	+}
...	...
...	...	@@ -12,4 +12,6 @@ public interface BannerMapper {
12	12	int update(Banner banner);
13	13
14	14	int deleteBanner(int id);
	15	+
	16	+ int copy(Banner banner);
15	17	}
...	...
...	...	@@ -14,6 +14,8 @@ public interface BannerNextMapper {
14	14
15	15	int insert(BannerNext record);
16	16
	17	+ int copy(BannerNext record);
	18	+
17	19	int insertSelective(BannerNext record);
18	20
19	21	BannerNext selectByPrimaryKey(Integer id);
...	...
...	...	@@ -7,6 +7,9 @@ import org.springframework.web.bind.annotation.RequestParam;
7	7	import java.util.List;
8	8
9	9	public interface ChannelMapper {
	10	+
	11	+ List<Channel> get2List();
	12	+
10	13	List<Channel> getList(Channel channel);
11	14
12	15	int getListCount(Channel channel);
...	...
...	...	@@ -0,0 +1,12 @@
	1	+package com.sincere.wechatbusiness.mapper;
	2	+
	3	+import com.sincere.wechatbusiness.model.PageView;
	4	+
	5	+public interface PageViewMapper {
	6	+
	7	+ int insert(PageView record);
	8	+
	9	+ PageView getDetail(PageView pageView);
	10	+
	11	+ int updateLook(PageView pageView);
	12	+}
0	13	\ No newline at end of file
...	...
...	...	@@ -0,0 +1,65 @@
	1	+package com.sincere.wechatbusiness.model;
	2	+
	3	+import java.util.Date;
	4	+
	5	+public class PageView {
	6	+ private Integer id;
	7	+
	8	+ private Integer channelId;
	9	+
	10	+ private Integer agentId;
	11	+
	12	+ private Integer channelProductId;
	13	+
	14	+ private Integer lookNumber;
	15	+
	16	+ private Date createTime;
	17	+
	18	+ public Integer getId() {
	19	+ return id;
	20	+ }
	21	+
	22	+ public void setId(Integer id) {
	23	+ this.id = id;
	24	+ }
	25	+
	26	+ public Integer getChannelId() {
	27	+ return channelId;
	28	+ }
	29	+
	30	+ public void setChannelId(Integer channelId) {
	31	+ this.channelId = channelId;
	32	+ }
	33	+
	34	+ public Integer getAgentId() {
	35	+ return agentId;
	36	+ }
	37	+
	38	+ public void setAgentId(Integer agentId) {
	39	+ this.agentId = agentId;
	40	+ }
	41	+
	42	+ public Integer getChannelProductId() {
	43	+ return channelProductId;
	44	+ }
	45	+
	46	+ public void setChannelProductId(Integer channelProductId) {
	47	+ this.channelProductId = channelProductId;
	48	+ }
	49	+
	50	+ public Integer getLookNumber() {
	51	+ return lookNumber;
	52	+ }
	53	+
	54	+ public void setLookNumber(Integer lookNumber) {
	55	+ this.lookNumber = lookNumber;
	56	+ }
	57	+
	58	+ public Date getCreateTime() {
	59	+ return createTime;
	60	+ }
	61	+
	62	+ public void setCreateTime(Date createTime) {
	63	+ this.createTime = createTime;
	64	+ }
	65	+}
0	66	\ No newline at end of file
...	...
...	...	@@ -10,6 +10,8 @@ public interface BannerService {
10	10
11	11	int insert(Banner banner);
12	12
	13	+ int copy(Banner banner);
	14	+
13	15	int update(Banner banner);
14	16
15	17	int deleteBanner(int id);
...	...	@@ -23,4 +25,6 @@ public interface BannerService {
23	25
24	26	int update(BannerNext bannerNext);
25	27
	28	+ int copyBannerNext(BannerNext bannerNext);
	29	+
26	30	}
...	...
...	...	@@ -0,0 +1,8 @@
	1	+package com.sincere.wechatbusiness.service;
	2	+
	3	+import com.sincere.wechatbusiness.model.PageView;
	4	+
	5	+public interface PageViewService {
	6	+
	7	+ int updateLook(PageView pageView);
	8	+}
...	...
...	...	@@ -50,4 +50,14 @@ public class BannerServiceImpl implements BannerService {
50	50	public int update(BannerNext bannerNext) {
51	51	return bannerNextMapper.update(bannerNext);
52	52	}
	53	+
	54	+ @Override
	55	+ public int copy(Banner banner) {
	56	+ return bannerMapper.copy(banner);
	57	+ }
	58	+
	59	+ @Override
	60	+ public int copyBannerNext(BannerNext bannerNext) {
	61	+ return bannerNextMapper.copy(bannerNext);
	62	+ }
53	63	}
...	...