From 48b4f619d997207af701789f3a391728301584bb Mon Sep 17 00:00:00 2001 From: gongbiao Date: Sat, 27 Apr 2019 11:56:55 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1][?= =?UTF-8?q?=E6=B7=BB=E5=8A=A0][=E6=AF=8F=E5=A4=A91=E7=82=B9=E6=89=A7?= =?UTF-8?q?=E8=A1=8C=E8=B4=A6=E5=8D=95=E6=9B=B4=E6=96=B0=E7=8A=B6=E6=80=81?= =?UTF-8?q?]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iformall/schedule/BillStatusSchedule.java | 48 +++++++++++++++++++ .../java/com/iformall/common/ErrorCode.java | 2 +- .../iformall/service/WxBillAllService.java | 14 ++++-- .../service/impl/WxBillAllServiceImpl.java | 4 +- 4 files changed, 60 insertions(+), 8 deletions(-) create mode 100644 mallinkSchedule/src/main/java/com/iformall/schedule/BillStatusSchedule.java diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/BillStatusSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/BillStatusSchedule.java new file mode 100644 index 000000000..962b9a7db --- /dev/null +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/BillStatusSchedule.java @@ -0,0 +1,48 @@ +package com.iformall.schedule; + +import com.iformall.domain.po.WxMall; +import com.iformall.domain.vo.WxBillAll; +import com.iformall.mapper.WxMallMapper; +import com.iformall.service.WxBillAllService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import java.util.List; + +/** + * @author gongbiao + */ +@Component +public class BillStatusSchedule { + + private final Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + private WxBillAllService wxBillAllService; + + @Autowired + private WxMallMapper wxMallMapper; + + /** + * 每天1点执行 + */ + @Scheduled(cron = "0 0 1 * * ?") + public void updateBillStatus() { + logger.info("账单状态更新开始"); + + List wxMalls = wxMallMapper.findList(null); + for (WxMall wxMall : wxMalls) { + String tenantId = wxMall.getTenantId(); + WxBillAll wxBillAll = new WxBillAll(); + wxBillAll.setTenantId(tenantId); + wxBillAllService.updateBillStatus(wxBillAll); + } + + logger.info("账单状态更新结束"); + } + + +} \ No newline at end of file diff --git a/mallinkService/src/main/java/com/iformall/common/ErrorCode.java b/mallinkService/src/main/java/com/iformall/common/ErrorCode.java index 4b48b62c7..a4cbb0b98 100644 --- a/mallinkService/src/main/java/com/iformall/common/ErrorCode.java +++ b/mallinkService/src/main/java/com/iformall/common/ErrorCode.java @@ -239,7 +239,7 @@ public enum ErrorCode{ * 核销 */ VERIFY_ERROR(12050, "核销异常"), - MSG_REPEAT_SEND(12061, "短信重新发送"), + MSG_REPEAT_SEND(12061, "短信重复发送"), /** * 解单 diff --git a/mallinkService/src/main/java/com/iformall/service/WxBillAllService.java b/mallinkService/src/main/java/com/iformall/service/WxBillAllService.java index da6d55718..802bd6b65 100644 --- a/mallinkService/src/main/java/com/iformall/service/WxBillAllService.java +++ b/mallinkService/src/main/java/com/iformall/service/WxBillAllService.java @@ -12,19 +12,19 @@ import java.util.Map; */ public interface WxBillAllService { - Map listAsPage(WxBillAll wxBillAll, Integer pageNum, Integer pageSize); + Map listAsPage(WxBillAll wxBillAll, Integer pageNum, Integer pageSize); - List> listBillOweAndWaitPay(WxBillAll wxBillAll); + List> listBillOweAndWaitPay(WxBillAll wxBillAll); ResultData listBill(WxBillAll wxBillAll); - void updateBill(Map bill); + void updateBill(Map bill); void exportBill(HttpServletRequest request, HttpServletResponse response, WxBillAll wxBillAll); Object getBillInfo(WxBillAll wxBillAll); - Long hasOweBill(Long contractId,Integer type); + Long hasOweBill(Long contractId, Integer type); /** * 发送待缴通知邮件 @@ -38,10 +38,14 @@ public interface WxBillAllService { /** * 欠缴商户分页列表 + * * @return */ Map getOweBillAsPage(WxBillAll record, Integer pageNum, Integer pageSize); void exportOweMerchant(WxBillAll record, HttpServletRequest request, HttpServletResponse response); -} + + void updateBillStatus(WxBillAll record); + +} \ No newline at end of file diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxBillAllServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxBillAllServiceImpl.java index c88e44b8b..f23adc733 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxBillAllServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxBillAllServiceImpl.java @@ -549,8 +549,8 @@ public class WxBillAllServiceImpl implements WxBillAllService { return count; } - - private void updateBillStatus(WxBillAll record) { + @Override + public void updateBillStatus(WxBillAll record) { logger.info("更新各账单状态开始"); //更新其他押金账单 //WxBillOtherDeposit wxBillOtherDeposit = new WxBillOtherDeposit();