From ac6ab1779431b5563922a38d34adac4ab37882b2 Mon Sep 17 00:00:00 2001 From: masterspirit Date: Sun, 19 Aug 2018 17:02:37 +0800 Subject: [PATCH] =?UTF-8?q?[=E7=B2=BE=E5=87=86=E6=8A=95=E6=94=BE][?= =?UTF-8?q?=E4=BF=AE=E6=94=B9]=E7=B2=BE=E5=87=86=E6=8A=95=E6=94=BE?= =?UTF-8?q?=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/simple/domain/po/CouponInject.java | 33 ++++++++++++- .../service/impl/CouponInjectServiceImpl.java | 49 +++++++++++-------- 2 files changed, 60 insertions(+), 22 deletions(-) diff --git a/mallinkService/src/main/java/com/simple/domain/po/CouponInject.java b/mallinkService/src/main/java/com/simple/domain/po/CouponInject.java index 8be6a9ad0..311277eb5 100644 --- a/mallinkService/src/main/java/com/simple/domain/po/CouponInject.java +++ b/mallinkService/src/main/java/com/simple/domain/po/CouponInject.java @@ -1,8 +1,9 @@ package com.simple.domain.po; +import com.simple.domain.vo.WxChooseTagVo; + import javax.persistence.*; import java.util.*; -import java.math.*; import javax.persistence.Transient; import java.util.List; import javax.persistence.Id; @@ -19,6 +20,14 @@ public class CouponInject implements Serializable { protected List ids; @Transient protected String sortColumns; + @Transient + protected WxChooseTagVo wxChooseTagVo; + + @Transient + protected Date sendTimeStart; + + @Transient + protected Date sendTimeEnd; public Long getId() { return id; @@ -168,6 +177,28 @@ public class CouponInject implements Serializable { public void setUpdateTime(Date _updateTime) { updateTime = _updateTime; } + public WxChooseTagVo getWxChooseTagVo() { + return wxChooseTagVo; + } + + public void setWxChooseTagVo(WxChooseTagVo wxChooseTagVo) { + this.wxChooseTagVo = wxChooseTagVo; + } + public Date getSendTimeStart() { + return sendTimeStart; + } + + public void setSendTimeStart(Date sendTimeStart) { + this.sendTimeStart = sendTimeStart; + } + + public Date getSendTimeEnd() { + return sendTimeEnd; + } + + public void setSendTimeEnd(Date sendTimeEnd) { + this.sendTimeEnd = sendTimeEnd; + } diff --git a/mallinkService/src/main/java/com/simple/service/impl/CouponInjectServiceImpl.java b/mallinkService/src/main/java/com/simple/service/impl/CouponInjectServiceImpl.java index cf4482771..ee3e4bfbe 100644 --- a/mallinkService/src/main/java/com/simple/service/impl/CouponInjectServiceImpl.java +++ b/mallinkService/src/main/java/com/simple/service/impl/CouponInjectServiceImpl.java @@ -82,38 +82,45 @@ public class CouponInjectServiceImpl implements CouponInjectService { }else{ record.setStatus(0); } - + List cUsers = wxCUserTagsService.findUserByTag(tagids); + record.setSendAmount(cUsers.size()); couponInjectMapper.insertSelective(record); - if(record.getSendType()==0) { - sendNow(tagids, wxCoupon); + sendNow(wxCoupon,cUsers); } } - private void sendNow(List tagids,WxCoupon wxCoupon){ + private void sendNow(WxCoupon wxCoupon,List cUsers){ //查询标签用户 - List cUsers = wxCUserTagsService.findUserByTag(tagids); + for (WxCUser tempCUser : cUsers) { - WxCouponOrder wxCouponOrder = new WxCouponOrder(); - wxCouponOrder.setCouponId(wxCoupon.getId()); - wxCouponOrder.setCouponOrderStatus(0); - wxCouponOrder.setCUserId(tempCUser.getId()); - wxCouponOrder.setCouponPrice(0); - wxCouponOrder.setCreateDate(new Date()); - if (wxCoupon.getValidType() == 1) { //时间范围区间 - wxCouponOrder.setExpiredTime(wxCoupon.getValidEndDate()); - } else { - Date date = DateUtils.addDays(new Date(), wxCoupon.getValidDays()); - wxCouponOrder.setExpiredTime(date); - } - wxCouponOrder.setTenantId(wxCoupon.getTenantId()); - wxCouponOrderService.saveOrUpdate(wxCouponOrder); - //短信通知 - } + sendCouponToUser(tempCUser,wxCoupon); + } + } + private void sendCouponToUser(WxCUser tempCUser,WxCoupon wxCoupon){ + try { + WxCouponOrder wxCouponOrder = new WxCouponOrder(); + wxCouponOrder.setCouponId(wxCoupon.getId()); + wxCouponOrder.setCouponOrderStatus(0); + wxCouponOrder.setCUserId(tempCUser.getId()); + wxCouponOrder.setCouponPrice(0); + wxCouponOrder.setCreateDate(new Date()); + if (wxCoupon.getValidType() == 1) { //时间范围区间 + wxCouponOrder.setExpiredTime(wxCoupon.getValidEndDate()); + } else { + Date date = DateUtils.addDays(new Date(), wxCoupon.getValidDays()); + wxCouponOrder.setExpiredTime(date); + } + wxCouponOrder.setTenantId(wxCoupon.getTenantId()); + wxCouponOrderService.saveOrUpdate(wxCouponOrder); + //短信通知 + }catch (Exception e){ + throw e; + } } }