From fd22a2c83f60ff0daebff5fdb78f637f17d58cee Mon Sep 17 00:00:00 2001
From: 101captain <237651143@qq.com>
Date: 星期二, 22 二月 2022 15:01:59 +0800
Subject: [PATCH] 三社功能提交

---
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/ComActRaffleRecordService.java          |    7 ++
 springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/ComActRaffleRecordApi.java                                      |   11 +++
 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/CommunityService.java                               |    9 +++
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComActRafflePrizeDao.java                   |    1 
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComActRaffleRecordMapper.xml                                        |   13 ++++
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/message/RaffleMessage.java                      |   62 ++++++++++++++++++++
 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/community/raffle/ComActRaffleRecordVO.java                  |   15 +++++
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/ComActRaffleRecordApi.java                  |    4 
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActRaffleRecordServiceImpl.java |    5 +
 springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComActRaffleRecordDao.java                  |    8 ++
 10 files changed, 131 insertions(+), 4 deletions(-)

diff --git a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/ComActRaffleRecordApi.java b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/ComActRaffleRecordApi.java
index caa944e..ce24e63 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/ComActRaffleRecordApi.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/applets/src/main/java/com/panzhihua/applets/api/ComActRaffleRecordApi.java
@@ -91,4 +91,15 @@
         comActRaffleRecordVO.setStatus(0);
         return communityService.insertRaffleRecord(comActRaffleRecordVO);
     }
+    /**
+     * 通过主键查询单条数据
+     *
+     * @param id 主键
+     * @return 单条数据
+     */
+    @ApiOperation("详情")
+    @GetMapping("{id}")
+    public R selectOne(@PathVariable("id") Long id) {
+        return this.communityService.selectOneRaffleRecord(id);
+    }
 }
diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/community/raffle/ComActRaffleRecordVO.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/community/raffle/ComActRaffleRecordVO.java
index 74c1045..f8a0912 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/community/raffle/ComActRaffleRecordVO.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/community/raffle/ComActRaffleRecordVO.java
@@ -1,5 +1,6 @@
 package com.panzhihua.common.model.vos.community.raffle;
 
+import com.fasterxml.jackson.annotation.JsonFormat;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.AllArgsConstructor;
@@ -81,4 +82,18 @@
     @ApiModelProperty(value = "联系电话")
     private String phone;
 
+    /**
+     * 兑奖开始时间
+     */
+    @ApiModelProperty(value = "兑奖开始时间")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm", timezone = "GMT+8")
+    private Date raffleStartTime;
+
+    /**
+     * 兑奖结束时间
+     */
+    @ApiModelProperty(value = "兑奖结束时间")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm", timezone = "GMT+8")
+    private Date raffleStopTime;
+
 }
diff --git a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/CommunityService.java b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/CommunityService.java
index 338b0b3..55c09b6 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/CommunityService.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/community/CommunityService.java
@@ -8129,6 +8129,15 @@
 
     @PostMapping("/comActRaffleRecord")
     R insertRaffleRecord(@RequestBody ComActRaffleRecordVO comActRaffleRecordVO);
+
+    /**
+     * 通过主键查询单条数据
+     *
+     * @param id 主键
+     * @return 单条数据
+     */
+    @GetMapping("/comActRaffleRecord/{id}")
+    R selectOneRaffleRecord(@PathVariable("id") Long id);
     /**
      * 导出
      *
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/ComActRaffleRecordApi.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/ComActRaffleRecordApi.java
index 4830876..9a34f86 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/ComActRaffleRecordApi.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/api/ComActRaffleRecordApi.java
@@ -68,8 +68,8 @@
      * @return 单条数据
      */
     @GetMapping("{id}")
-    public R selectOne(@PathVariable("id") Serializable id) {
-        return R.ok(this.comActRaffleRecordService.getById(id));
+    public R selectOne(@PathVariable("id") Long id) {
+        return R.ok(this.comActRaffleRecordService.selectById(id));
     }
 
     /**
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComActRafflePrizeDao.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComActRafflePrizeDao.java
index 91e0b90..dfc4275 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComActRafflePrizeDao.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComActRafflePrizeDao.java
@@ -3,6 +3,7 @@
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.panzhihua.common.model.vos.community.raffle.ComActRafflePrizeCount;
 import com.panzhihua.common.model.vos.community.raffle.ComActRafflePrizeVO;
+import com.panzhihua.common.model.vos.community.raffle.ComActRaffleRecordVO;
 import org.apache.ibatis.annotations.Mapper;
 import com.panzhihua.service_community.entity.ComActRafflePrize;
 
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComActRaffleRecordDao.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComActRaffleRecordDao.java
index 2653a58..982c2d4 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComActRaffleRecordDao.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/dao/ComActRaffleRecordDao.java
@@ -45,4 +45,12 @@
      * @return
      */
     List<ComActRaffleRecordExcelVO> export(@Param("commonPage")CommonPage commonPage);
+
+
+    /**
+     * 根据id查询
+     * @param id
+     * @return
+     */
+    ComActRaffleRecordVO selectById(Long id);
 }
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/message/RaffleMessage.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/message/RaffleMessage.java
index 21b1fe9..8b05192 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/message/RaffleMessage.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/message/RaffleMessage.java
@@ -1,14 +1,25 @@
 package com.panzhihua.service_community.message;
 
+import cn.hutool.core.date.DateUnit;
+import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.panzhihua.common.model.vos.community.raffle.ComActRaffleVO;
+import com.panzhihua.common.utlis.StringUtils;
 import com.panzhihua.service_community.dao.ComActRaffleDao;
+import com.panzhihua.service_community.dao.ComActRafflePrizeDao;
+import com.panzhihua.service_community.dao.ComActRaffleRecordDao;
 import com.panzhihua.service_community.entity.ComActRaffle;
+import com.panzhihua.service_community.entity.ComActRafflePrize;
+import com.panzhihua.service_community.entity.ComActRaffleRecord;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
+import java.util.ArrayList;
 import java.util.Date;
+import java.util.List;
+import java.util.Random;
 
 /**
  * @author zzj
@@ -19,12 +30,61 @@
 
     @Resource
     private ComActRaffleDao comActRaffleDao;
+    @Resource
+    private ComActRaffleRecordDao comActRaffleRecordDao;
+    @Resource
+    private ComActRafflePrizeDao comActRafflePrizeDao;
+    @Resource
+    private RabbitTemplate rabbitTemplate;
 
     @RabbitListener(queues=DELAYED_QUEUE)
     public void doRaffle(ComActRaffleVO comActRaffleVO){
         ComActRaffle comActRaffle=comActRaffleDao.selectOne(new QueryWrapper<ComActRaffle>().lambda().eq(ComActRaffle::getId,comActRaffleVO.getId()));
-        if(comActRaffle!=null&&comActRaffle.getStatus()==0&&comActRaffle.getLotteryTime().before(new Date())){
+        if(comActRaffle!=null&&comActRaffle.getStatus()==2&&comActRaffle.getLotteryTime().before(new Date())){
+            List<ComActRafflePrize> comActRafflePrizeList=comActRafflePrizeDao.selectList(new QueryWrapper<ComActRafflePrize>().lambda().eq(ComActRafflePrize::getRaffleId,comActRaffleVO.getId()));
+            if(StringUtils.isNotEmpty(comActRafflePrizeList)){
+                List<ComActRaffleRecord> comActRaffleRecords=comActRaffleRecordDao.selectList(new QueryWrapper<ComActRaffleRecord>().lambda().eq(ComActRaffleRecord::getRaffleId,comActRaffleVO.getId()));
+                if(StringUtils.isNotEmpty(comActRaffleRecords)){
+                    Random random=new Random();
+                    comActRafflePrizeList.forEach(comActRafflePrize -> {
+                        int a=0;
+                        for(int i=1;i<=comActRafflePrize.getSurplus();i++){
+                            if(comActRaffleRecords.size()>0){
+                                ComActRaffleRecord comActRaffleRecord=comActRaffleRecords.get(random.nextInt(comActRaffleRecords.size()));
+                                comActRaffleRecord.setPrizeId(comActRafflePrize.getId());
+                                comActRaffleRecord.setStatus(1);
+                                comActRaffleRecordDao.updateById(comActRaffleRecord);
+                                comActRaffleRecords.remove(comActRaffleRecord);
+                                a++;
+                            }
+                        }
+                        comActRafflePrize.setSurplus(comActRafflePrize.getSurplus()-a);
+                        comActRafflePrizeDao.updateById(comActRafflePrize);
+                    });
 
+                }
+            }
+            comActRaffle.setStatus(3);
+            comActRaffleDao.updateById(comActRaffle);
         }
+        if(comActRaffle!=null&&comActRaffle.getStatus()==0&&comActRaffle.getStartTime().before(new Date())){
+            comActRaffle.setStatus(1);
+            comActRaffleDao.updateById(comActRaffle);
+            rabbitTemplate.convertAndSend("raffle.exchange", "raffle.key", comActRaffleVO, message -> {
+                message.getMessageProperties().setHeader("x-delay", dateToSecond(comActRaffle.getStopTime()));
+                return message;
+            });
+        }
+        if(comActRaffle!=null&&comActRaffle.getStatus()==1&&comActRaffle.getStopTime().before(new Date())){
+            comActRaffle.setStatus(2);
+            comActRaffleDao.updateById(comActRaffle);
+            rabbitTemplate.convertAndSend("raffle.exchange", "raffle.key", comActRaffleVO, message -> {
+                message.getMessageProperties().setHeader("x-delay", dateToSecond(comActRaffle.getLotteryTime()));
+                return message;
+            });
+        }
+    }
+    private Long dateToSecond(Date expireTime){
+        return DateUtil.between(new Date(),expireTime, DateUnit.MS);
     }
 }
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/ComActRaffleRecordService.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/ComActRaffleRecordService.java
index 7fa5b2b..86f6310 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/ComActRaffleRecordService.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/ComActRaffleRecordService.java
@@ -44,4 +44,11 @@
      * @return
      */
     R export(CommonPage commonPage);
+
+    /**
+     * 根据Id查询
+     * @param id
+     * @return
+     */
+    R selectById(Long id);
 }
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActRaffleRecordServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActRaffleRecordServiceImpl.java
index 6976103..374ea73 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActRaffleRecordServiceImpl.java
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComActRaffleRecordServiceImpl.java
@@ -56,4 +56,9 @@
     public R export(CommonPage commonPage) {
         return R.ok(this.baseMapper.export(commonPage));
     }
+
+    @Override
+    public R selectById(Long id) {
+        return R.ok(this.baseMapper.selectById(id));
+    }
 }
diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComActRaffleRecordMapper.xml b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComActRaffleRecordMapper.xml
index 213cab8..5f6eed7 100644
--- a/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComActRaffleRecordMapper.xml
+++ b/springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/resources/mapper/ComActRaffleRecordMapper.xml
@@ -21,11 +21,12 @@
     </select>
 
     <select id="pageList" resultType="com.panzhihua.common.model.vos.community.raffle.ComActRaffleRecordVO">
-        select t.*, t1.image, t1.name as prizeName, t2.nick_name, t2.phone, t2.`name` as username, t3.name as staffName
+        select t.*, t1.image, t1.name as prizeName, t2.nick_name, t2.phone, t2.`name` as username, t3.name as staffName,t4.raffle_start_time as raffleStartTime,t4.raffle_stop_time as raffleStopTime
         from com_act_raffle_record t
         left join com_act_raffle_prize t1 on t.prize_id = t1.id
         left join sys_user t2 on t.user_id = t2.user_id
         left join sys_user t3 on t.staff_id = t3.user_id
+        left join com_act_raffle t4 on t.raffle_id = t4.id
         <where>
             <if test="commonPage.status!=null">
                 and t.status = #{commonPage.status}
@@ -39,6 +40,9 @@
             </if>
             <if test="commonPage.userId !=null">
                 and t.user_id = #{commonPage.userId}
+            </if>
+            <if test="commonPage.paramId2 !=null">
+                and t.staff_id = #{commonPage.paramId2}
             </if>
         </where>
         order by t.create_time desc
@@ -67,4 +71,11 @@
         </where>
         order by t.create_time desc
     </select>
+
+    <select id="selectById" resultType="com.panzhihua.common.model.vos.community.raffle.ComActRaffleRecordVO">
+        select t.*, t1.`name`, t1.image
+        from com_act_raffle_record t
+        LEFT JOIN com_act_raffle_prize t1 on t.prize_id = t1.id
+        where t.id=#{id}
+    </select>
 </mapper>

--
Gitblit v1.7.1