活动修改

xx-activity/xx-activity-api/src/main/java/com/xxfc/platform/activity/entity/ActivityPopularizeRelation.java

@@ -8,6 +8,7 @@ import javax.persistence.GeneratedValue;
 import javax.persistence.Id;
 import javax.persistence.Table;
 import java.io.Serializable;
+import java.math.BigDecimal;
 
 
 /**
@@ -68,4 +69,8 @@ public class ActivityPopularizeRelation implements Serializable {
     @Column(name = "num")
 	@ApiModelProperty(value = "第几个用户")
 	private Integer num;
+
+    @Column(name = "amount")
+	@ApiModelProperty(value = "获得奖励金额")
+	private BigDecimal amount;
 }

xx-activity/xx-activity-api/src/main/java/com/xxfc/platform/activity/entity/ActivityPopularizeUser.java

 package com.xxfc.platform.activity.entity;
 
-import java.io.Serializable;
-import java.util.Date;
-import javax.persistence.*;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
 
+import javax.persistence.Column;
+import javax.persistence.GeneratedValue;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import java.io.Serializable;
+import java.math.BigDecimal;
+
 
 /**
  * 用户与推广活动（邀请有礼）的关系表
@@ -60,14 +64,14 @@ public class ActivityPopularizeUser implements Serializable {
      */
     @Column(name = "end_progress")
 	@ApiModelProperty(value = "一共需要的进度")
-    private Integer endProgress;
+    private BigDecimal endProgress;
 	
 	    /**
      *  当前进度
      */
     @Column(name = "current_progress")
 	@ApiModelProperty(value = "当前进度")
-    private Integer currentProgress;
+    private BigDecimal currentProgress;
 	
 	    /**
      *  推广活动id

xx-activity/xx-activity-api/src/main/java/com/xxfc/platform/activity/vo/popularize/PopularizeVO.java

 package com.xxfc.platform.activity.vo.popularize;
 
 import com.xxfc.platform.activity.entity.ActivityPopularize;
-import com.xxfc.platform.activity.entity.ActivityPopularizeItem;
 import lombok.Data;
 
 import java.util.List;
@@ -10,4 +9,6 @@ import java.util.List;
 public class PopularizeVO extends ActivityPopularize {
     List<ItemVO> items;
     List<UserVO> userVOs;
+    boolean isComplete;
+
 }

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/biz/ActivityPopularizeBiz.java

@@ -3,6 +3,8 @@ package com.xxfc.platform.activity.biz;
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.json.JSONUtil;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
 import com.github.wxiaoqi.security.admin.dto.RegisterQueueDTO;
 import com.github.wxiaoqi.security.admin.entity.MyWalletDetail;
 import com.github.wxiaoqi.security.admin.feign.UserFeign;
@@ -10,18 +12,17 @@ import com.github.wxiaoqi.security.admin.feign.dto.AppUserDTO;
 import com.github.wxiaoqi.security.common.biz.BaseBiz;
 import com.github.wxiaoqi.security.common.config.rabbit.RabbitConstant;
 import com.xxfc.platform.activity.dto.ApLogDTO;
-import com.xxfc.platform.activity.entity.ActivityPopularize;
-import com.xxfc.platform.activity.entity.ActivityPopularizeLog;
-import com.xxfc.platform.activity.entity.ActivityPopularizeRelation;
-import com.xxfc.platform.activity.entity.ActivityPopularizeUser;
+import com.xxfc.platform.activity.entity.*;
 import com.xxfc.platform.activity.mapper.ActivityPopularizeMapper;
 import com.xxfc.platform.universal.feign.MQSenderFeign;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
 import java.util.Date;
+import java.util.List;
 
 import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_FALSE;
 import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_TRUE;
@@ -49,6 +50,9 @@ public class ActivityPopularizeBiz extends BaseBiz<ActivityPopularizeMapper,Acti
     @Autowired
     ActivityPopularizeLogBiz popularizeLogBiz;
 
+    @Autowired
+    ActivityPopularizeItemBiz activityPopularizeItemBiz;
+
     @Autowired
     UserFeign userFeign;
 
@@ -67,13 +71,14 @@ public class ActivityPopularizeBiz extends BaseBiz<ActivityPopularizeMapper,Acti
         AppUserDTO appUserDTO = userFeign.userDetailById(registerQueueDTO.getAppUserId()).getData();
 
         //获取活动code,并且注册来源是app 并且 非普通登录
-        if(POPULARIZE_0101.equals(activityCode)
-                && !RegisterQueueDTO.SIGN_LOGIN.equals(registerQueueDTO.getSign())) {
+        if(!RegisterQueueDTO.SIGN_LOGIN.equals(registerQueueDTO.getSign())) {
             //查询出活动
             ActivityPopularize activityPopularize = popularizeBiz.selectOne(new ActivityPopularize(){{
                 setCode(activityCode);
             }});
-
+            if (activityPopularize != null) {
+                List<ActivityPopularizeItem> activityPopularizeItems = activityPopularizeItemBiz.selectByPopularizeId(activityPopularize.getId());
+                ActivityPopularizeItem activityPopularizeItem = activityPopularizeItems.get(activityPopularizeItems.size() - 1);
                 Date now = DateUtil.date();
                 Date start = DateUtil.date(activityPopularize.getStartTime());
                 Date end = DateUtil.date(activityPopularize.getEndTime());
@@ -89,24 +94,40 @@ public class ActivityPopularizeBiz extends BaseBiz<ActivityPopularizeMapper,Acti
                     setMajorUserId(majorUserId);
                     setPopularizeId(activityPopularize.getId());
                 }};
+
+                //新增第几个邀请人和邀请金额字段
                 Integer num = relationBiz.getByUserIdAndPopularizeId(activityPopularizeRelation);
+
+                BigDecimal amount = new BigDecimal(0);
+                JSONObject jsonObject = JSONObject.parseObject(activityPopularizeItem.getDetail());
+                if (jsonObject != null && StringUtils.isNotBlank(jsonObject.getString("detail"))) {
+                    JSONArray jsonArray = JSONArray.parseArray(jsonObject.getString("detail"));
+                    if (jsonArray != null) {
+                        JSONObject jsonObject1 = jsonArray.getJSONObject(num - 1);
+                        if (jsonObject1 != null) {
+                            String amountString = jsonObject1.getString("amount");
+                            amount.add(new BigDecimal(amountString));
+                        }
+                    }
+                }
                 //添加活动关系
                 relationBiz.insertSelective(new ActivityPopularizeRelation(){{
                     setPopularizeId(activityPopularize.getId());
                     setMajorUserId(majorUserId);
                     setMinorUserId(appUserDTO.getUserid());
                     setNum(num);
+                    setAmount(amount);
                 }});
 
                 ApLogDTO apLogDTO = popularizeLogBiz.selectOneApLogDTO(new ActivityPopularizeLog(){{
                     setUserId(majorUserId);
-                setItemId(INVITE_ITEMID);
+                    setItemId(activityPopularizeItem.getId());
                 }});
 
                 //生成任务项
                 if(null == apLogDTO){
                     popularizeLogBiz.insertSelectiveRe(new ActivityPopularizeLog(){{
-                    setItemId(INVITE_ITEMID);
+                        setItemId(activityPopularizeItem.getId());
                         setUserId(majorUserId);
                         setStatus(SYS_FALSE);
                         setPopularizeId(activityPopularize.getId());
@@ -118,7 +139,8 @@ public class ActivityPopularizeBiz extends BaseBiz<ActivityPopularizeMapper,Acti
                     setUserId(majorUserId);
                     setPopularizeId(activityPopularize.getId());
                 }});
-
+                //修改当前进度
+                activityPopularizeUser.setCurrentProgress(activityPopularizeUser.getCurrentProgress().add(amount));
                 //任务没有完成
                 if(!SYS_TRUE.equals(activityPopularizeUser.getStatus())) {
 //                AwardDTO awardDTO = JSONUtil.toBean(activityPopularize.getValue(), AwardDTO.class);
@@ -130,7 +152,7 @@ public class ActivityPopularizeBiz extends BaseBiz<ActivityPopularizeMapper,Acti
                         apLogDTO.setStatus(SYS_TRUE);
                         popularizeLogBiz.updateSelectiveById(BeanUtil.toBean(apLogDTO, ActivityPopularizeLog.class));
                         activityPopularizeUser.setStatus(SYS_TRUE);
-                    activityPopularizeUser.setCurrentProgress(apLogDTO.getItem().getProgress());
+                        activityPopularizeUser.setCurrentProgress(new BigDecimal(apLogDTO.getItem().getProgress()));
                         popularizeUserBiz.updateSelectiveById(activityPopularizeUser);
                         mqSenderFeign.sendMessage(RabbitConstant.ADMIN_TOPIC, RabbitConstant.KEY_WALLET_ADD, JSONUtil.toJsonStr(new MyWalletDetail(){{
                             setAmount(new BigDecimal("50"));
@@ -145,4 +167,5 @@ public class ActivityPopularizeBiz extends BaseBiz<ActivityPopularizeMapper,Acti
                 }
             }
         }
+    }
 }
\ No newline at end of file

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/biz/ActivityPopularizeItemBiz.java

 package com.xxfc.platform.activity.biz;
 
-import org.springframework.stereotype.Service;
-
+import com.github.wxiaoqi.security.common.biz.BaseBiz;
 import com.xxfc.platform.activity.entity.ActivityPopularizeItem;
 import com.xxfc.platform.activity.mapper.ActivityPopularizeItemMapper;
-import com.github.wxiaoqi.security.common.biz.BaseBiz;
+import org.springframework.stereotype.Service;
+import tk.mybatis.mapper.entity.Example;
+
+import java.util.List;
 
 /**
  * 推广活动项，一个活动对应多个项
@@ -15,4 +17,12 @@ import com.github.wxiaoqi.security.common.biz.BaseBiz;
  */
 @Service
 public class ActivityPopularizeItemBiz extends BaseBiz<ActivityPopularizeItemMapper,ActivityPopularizeItem> {
+
+	public List<ActivityPopularizeItem> selectByPopularizeId(Integer popularizeId) {
+		Example example = new Example(ActivityPopularizeItem.class);
+		example.createCriteria().andEqualTo("popularizeId", popularizeId);
+		example.orderBy("sort").asc();
+		return  mapper.selectByExample(example);
+	}
+
 }
\ No newline at end of file

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/biz/ActivityPopularizeLogBiz.java

@@ -14,6 +14,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import tk.mybatis.mapper.entity.Example;
 
 import javax.servlet.http.HttpServletRequest;
 
@@ -48,6 +49,11 @@ public class ActivityPopularizeLogBiz extends BaseBiz<ActivityPopularizeLogMappe
         }
     }
 
+    public ActivityPopularizeLog selectByUserIdAndPopularIdAndItemId(ActivityPopularizeLog entity) {
+		Example example = new Example(ActivityPopularizeLog.class);
+		example.createCriteria().andEqualTo("userId", entity.getUserId()).andEqualTo("itemId", entity.getItemId()).andEqualTo("popularizeId", entity.getPopularizeId());
+		return mapper.selectOneByExample(example);
+	}
     public PageDataVO<ActivityPopularizeLog> selectByUserId(QueryLogDto queryLogDto) {
 		String token = request.getHeader("Authorization");
 		AppUserDTO appUserDTO = null;

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/biz/ActivityPopularizeRelationBiz.java

@@ -9,7 +9,6 @@ import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
 import java.util.List;
-import java.util.concurrent.atomic.AtomicInteger;
 
 /**
  * 活动的参与者关系表
@@ -32,14 +31,6 @@ public class ActivityPopularizeRelationBiz extends BaseBiz<ActivityPopularizeRel
 
     public Integer getByUserIdAndPopularizeId(ActivityPopularizeRelation activityPopularizeRelation) {
        Integer num = mapper.getByUserIdAndPopularizeId(activityPopularizeRelation);
-        AtomicInteger atomicInteger = null;
-        if (num != null) {
-            atomicInteger = new AtomicInteger(num);
-            atomicInteger.incrementAndGet();
-        } else {
-            atomicInteger = new AtomicInteger(1);
-        }
-        int a = atomicInteger.get();
-        return a;
+        return num == null ? 1 : num;
     }
 }
\ No newline at end of file

xx-activity/xx-activity-server/src/main/java/com/xxfc/platform/activity/rest/ActivityPopularizeController.java

@@ -28,13 +28,14 @@ import org.springframework.web.bind.annotation.*;
 import tk.mybatis.mapper.entity.Example;
 import tk.mybatis.mapper.weekend.WeekendSqls;
 
-import java.util.ArrayList;
+import java.math.BigDecimal;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
 
-import static com.github.wxiaoqi.security.common.constant.CommonConstants.*;
+import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_FALSE;
+import static com.github.wxiaoqi.security.common.constant.CommonConstants.SYS_TRUE;
 
 @RestController
 @RequestMapping("activityPopularize")
@@ -111,12 +112,21 @@ public class ActivityPopularizeController extends BaseController<ActivityPopular
                     .stream().map(item -> {
                         ItemVO itemVO = BeanUtil.toBean(item, ItemVO.class);
                         itemVO.setStatus(SYS_FALSE);
+
                         if(null != apu[0]) {
                             ActivityPopularizeLog log = aplMap[0].get(item.getId());
                             if(null != log && SYS_TRUE.equals(log.getStatus())) {
                                 itemVO.setStatus(SYS_TRUE);
                             }
                         }
+                        ActivityPopularizeLog activityPopularizeLog = popularizeLogBiz.selectByUserIdAndPopularIdAndItemId(new ActivityPopularizeLog(){{
+                            setUserId(appUserDTO.getUserid());
+                            setPopularizeId(v.getId());
+                            setItemId(item.getId());
+                        }});
+                        if (activityPopularizeLog != null) {
+                            itemVO.setStatus(activityPopularizeLog.getStatus());
+                        }
                         return itemVO;
                     }).collect(Collectors.toList()));
             return vo;
@@ -149,7 +159,7 @@ public class ActivityPopularizeController extends BaseController<ActivityPopular
             activityPopularizeUser = popularizeUserBiz.insertSelectiveReT(new ActivityPopularizeUser(){{
                 setPopularizeId(itemAddDTO.getPopularizeId());
                 setUserId(getAppUser().getUserid());
-                setEndProgress(ap.getProgress());
+                setEndProgress(new BigDecimal(ap.getProgress()));
             }});
         }
 
@@ -176,7 +186,7 @@ public class ActivityPopularizeController extends BaseController<ActivityPopular
             ActivityPopularizeItem item1 = popularizeItemBiz.selectById(al.getItemId());
             progress += item1.getProgress();
         }
-        activityPopularizeUser.setCurrentProgress(progress);
+        activityPopularizeUser.setCurrentProgress(new BigDecimal(progress));
         popularizeUserBiz.updateSelectiveById(activityPopularizeUser);
         return ObjectRestResponse.succ();
     }