From 3424a58959f004b02c73c53dcc03375831257308 Mon Sep 17 00:00:00 2001 From: hupeng Date: Wed, 22 Aug 2018 19:13:40 +0800 Subject: [PATCH] =?UTF-8?q?[=E7=B3=BB=E7=BB=9F][=E4=BF=AE=E6=94=B9]:?= =?UTF-8?q?=E5=AE=8C=E6=88=90=E6=AF=8F=E6=97=A5=E8=AE=A2=E5=8D=95=E4=BB=98?= =?UTF-8?q?=E6=AC=BE=E6=80=BB=E9=A2=9D,=E6=A0=B8=E9=94=80=E6=80=BB?= =?UTF-8?q?=E9=A2=9D=E8=90=BD=E8=A1=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../simple/schedule/DaliyAmountSchedule.java | 30 ++++++++++++++++++- .../service/WxDateAmountRecordService.java | 8 +++-- .../impl/WxDateAmountRecordServiceImpl.java | 21 ++++++++++++- 3 files changed, 54 insertions(+), 5 deletions(-) diff --git a/mallinkService/src/main/java/com/simple/schedule/DaliyAmountSchedule.java b/mallinkService/src/main/java/com/simple/schedule/DaliyAmountSchedule.java index 6e84d3a21..34e8a1aaa 100644 --- a/mallinkService/src/main/java/com/simple/schedule/DaliyAmountSchedule.java +++ b/mallinkService/src/main/java/com/simple/schedule/DaliyAmountSchedule.java @@ -1,6 +1,8 @@ package com.simple.schedule; +import com.simple.common.IdWorker; import com.simple.domain.po.WxCouponOrder; +import com.simple.domain.po.WxDateAmountRecord; import com.simple.domain.po.WxMall; import com.simple.domain.po.WxMerchant; import com.simple.mapper.*; @@ -90,6 +92,30 @@ public class DaliyAmountSchedule { "TOTAL ORDER=" + total_price); + Date now = new Date(); + Calendar cal = Calendar.getInstance(); + cal.setTime(now); // 将时分秒,毫秒域清零 + cal.set(Calendar.HOUR_OF_DAY, 0); + cal.set(Calendar.MINUTE, 0); + cal.set(Calendar.SECOND, 0); + cal.set(Calendar.MILLISECOND, 0); + now = cal.getTime(); + + WxDateAmountRecord dateAmountRecord = new WxDateAmountRecord(); + dateAmountRecord.setId(IdWorker.get().nextId()); + dateAmountRecord.setCreateDate(new Date()); + dateAmountRecord.setUpdateDate(new Date()); + dateAmountRecord.setPayPrice(total_price); + dateAmountRecord.setMerchantId(merchant.getId()); + dateAmountRecord.setTenantId(merchant.getTenantId()); + dateAmountRecord.setType(0); + dateAmountRecord.setDate(now); + dateAmountRecord.setDayOfWeek(cal.get(Calendar.DAY_OF_WEEK)); + dateAmountRecord.setMonth(cal.get(Calendar.MONTH)); + dateAmountRecord.setWeekOfYear(cal.getWeekYear()); + + wxDateAmountRecordService.saveDaliyAmount(dateAmountRecord); + list= wxCouponOrderMapper.findListOfVerifiedByDate(dateMap); logger.info("find " + list.size() + " coupon order from " + startDate + " to " + new Date()); total_price = 0; @@ -101,7 +127,9 @@ public class DaliyAmountSchedule { "from " + startDate + " to " + new Date() +"\n" + "TOTAL VERIFIED=" + total_price); - //daliy amount 落表 + dateAmountRecord.setPayPrice(total_price); + dateAmountRecord.setType(1); + wxDateAmountRecordService.saveDaliyAmount(dateAmountRecord); } } diff --git a/mallinkService/src/main/java/com/simple/service/WxDateAmountRecordService.java b/mallinkService/src/main/java/com/simple/service/WxDateAmountRecordService.java index b86b617e7..f9881c1b5 100644 --- a/mallinkService/src/main/java/com/simple/service/WxDateAmountRecordService.java +++ b/mallinkService/src/main/java/com/simple/service/WxDateAmountRecordService.java @@ -49,8 +49,10 @@ public interface WxDateAmountRecordService { int updateAmount(String tenantId,Long merchantId ,Integer type,Integer payPrice); - - - + /** + * 记录每日交易核销总额 + */ + + void saveDaliyAmount(WxDateAmountRecord amount); } diff --git a/mallinkService/src/main/java/com/simple/service/impl/WxDateAmountRecordServiceImpl.java b/mallinkService/src/main/java/com/simple/service/impl/WxDateAmountRecordServiceImpl.java index b2f2a7fec..336ca2fa0 100644 --- a/mallinkService/src/main/java/com/simple/service/impl/WxDateAmountRecordServiceImpl.java +++ b/mallinkService/src/main/java/com/simple/service/impl/WxDateAmountRecordServiceImpl.java @@ -62,5 +62,24 @@ public class WxDateAmountRecordServiceImpl implements WxDateAmountRecordService r.setPayPrice(payPrice); return wxDateAmountRecordMapper.updateAmount(r); } - + + @Override + public void saveDaliyAmount(WxDateAmountRecord amount) { + + WxDateAmountRecord record = new WxDateAmountRecord(); + record.setDate(amount.getDate()); + record.setTenantId(amount.getTenantId()); + record.setMerchantId(amount.getMerchantId()); + record.setType(amount.getType()); + + List list = wxDateAmountRecordMapper.findList(record); + + if (list.size() > 0){ + list.get(0).setPayPrice(amount.getPayPrice()); + list.get(0).setUpdateDate(new Date()); + wxDateAmountRecordMapper.updateByPrimaryKeySelective(list.get(0)); + }else{ + wxDateAmountRecordMapper.insertSelective(amount); + } + } }