diff --git a/src/main/java/com/glxp/api/dao/inout/IoStatDayDao.java b/src/main/java/com/glxp/api/dao/inout/IoStatDayDao.java new file mode 100644 index 000000000..bcc0657b1 --- /dev/null +++ b/src/main/java/com/glxp/api/dao/inout/IoStatDayDao.java @@ -0,0 +1,7 @@ +package com.glxp.api.dao.inout; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.glxp.api.entity.inout.IoStatDayEntity; + +public interface IoStatDayDao extends BaseMapper { +} \ No newline at end of file diff --git a/src/main/java/com/glxp/api/dao/inout/IoStatMonthDao.java b/src/main/java/com/glxp/api/dao/inout/IoStatMonthDao.java new file mode 100644 index 000000000..183d674e6 --- /dev/null +++ b/src/main/java/com/glxp/api/dao/inout/IoStatMonthDao.java @@ -0,0 +1,7 @@ +package com.glxp.api.dao.inout; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.glxp.api.entity.inout.IoStatMonthEntity; + +public interface IoStatMonthDao extends BaseMapper { +} \ No newline at end of file diff --git a/src/main/java/com/glxp/api/dao/inout/IoStatOrderDao.java b/src/main/java/com/glxp/api/dao/inout/IoStatOrderDao.java new file mode 100644 index 000000000..b4473c307 --- /dev/null +++ b/src/main/java/com/glxp/api/dao/inout/IoStatOrderDao.java @@ -0,0 +1,7 @@ +package com.glxp.api.dao.inout; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.glxp.api.entity.inout.IoStatOrderEntity; + +public interface IoStatOrderDao extends BaseMapper { +} \ No newline at end of file diff --git a/src/main/java/com/glxp/api/dao/inout/IoStatQuarterDao.java b/src/main/java/com/glxp/api/dao/inout/IoStatQuarterDao.java new file mode 100644 index 000000000..4da6f23c3 --- /dev/null +++ b/src/main/java/com/glxp/api/dao/inout/IoStatQuarterDao.java @@ -0,0 +1,7 @@ +package com.glxp.api.dao.inout; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.glxp.api.entity.inout.IoStatQuarterEntity; + +public interface IoStatQuarterDao extends BaseMapper { +} \ No newline at end of file diff --git a/src/main/java/com/glxp/api/dao/inout/IoStatYearDao.java b/src/main/java/com/glxp/api/dao/inout/IoStatYearDao.java new file mode 100644 index 000000000..827373e5b --- /dev/null +++ b/src/main/java/com/glxp/api/dao/inout/IoStatYearDao.java @@ -0,0 +1,7 @@ +package com.glxp.api.dao.inout; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.glxp.api.entity.inout.IoStatYearEntity; + +public interface IoStatYearDao extends BaseMapper { +} \ No newline at end of file diff --git a/src/main/java/com/glxp/api/entity/inout/IoStatDayEntity.java b/src/main/java/com/glxp/api/entity/inout/IoStatDayEntity.java new file mode 100644 index 000000000..95ce350dd --- /dev/null +++ b/src/main/java/com/glxp/api/entity/inout/IoStatDayEntity.java @@ -0,0 +1,160 @@ +package com.glxp.api.entity.inout; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.math.BigDecimal; +import java.util.Date; + +/** + * 物资出入库汇总 - 天 + */ +@Data +@TableName(value = "io_stat_day") +public class IoStatDayEntity { + + @TableId(value = "id", type = IdType.AUTO) + private Integer id; + + /** + * 年度 + */ + @TableField(value = "`year`") + private Integer year; + + /** + * 季度 + */ + @TableField(value = "quarter") + private Integer quarter; + + /** + * 月份 + */ + @TableField(value = "`month`") + private Integer month; + + /** + * 日 + */ + @TableField(value = "`day`") + private Integer day; + + /** + * 物资编码主键 + */ + @TableField(value = "relIdFk") + private String relIdFk; + + /** + * 产品DI + */ + @TableField(value = "nameCode") + private String nameCode; + + /** + * 产品名称 + */ + @TableField(value = "productName") + private String productName; + + /** + * 规格型号 + */ + @TableField(value = "ggxh") + private String ggxh; + + /** + * 批次号 + */ + @TableField(value = "batchNo") + private String batchNo; + + /** + * 期初数量 + */ + @TableField(value = "beginCount") + private Integer beginCount; + + /** + * 期初价格 + */ + @TableField(value = "beginPrice") + private BigDecimal beginPrice; + + /** + * 期初金额 + */ + @TableField(value = "beginAmount") + private BigDecimal beginAmount; + + /** + * 入库数量 + */ + @TableField(value = "inCount") + private String inCount; + + /** + * 入库价格 + */ + @TableField(value = "inPrice") + private BigDecimal inPrice; + + /** + * 入库金额 + */ + @TableField(value = "inAmount") + private String inAmount; + + /** + * 出库数量 + */ + @TableField(value = "outCount") + private String outCount; + + /** + * 出库价格 + */ + @TableField(value = "outPrice") + private BigDecimal outPrice; + + /** + * 出库金额 + */ + @TableField(value = "outAmount") + private String outAmount; + + /** + * 结余数量 + */ + @TableField(value = "balanceCount") + private String balanceCount; + + /** + * 结余价格 + */ + @TableField(value = "balancePrice") + private BigDecimal balancePrice; + + /** + * 结余金额 + */ + @TableField(value = "balanceAmount") + private String balanceAmount; + + /** + * 备注 + */ + @TableField(value = "remark") + private String remark; + + /** + * 更新时间 + */ + @TableField(value = "updateTime") + private Date updateTime; + +} \ No newline at end of file diff --git a/src/main/java/com/glxp/api/entity/inout/IoStatMonthEntity.java b/src/main/java/com/glxp/api/entity/inout/IoStatMonthEntity.java new file mode 100644 index 000000000..acd259d3a --- /dev/null +++ b/src/main/java/com/glxp/api/entity/inout/IoStatMonthEntity.java @@ -0,0 +1,154 @@ +package com.glxp.api.entity.inout; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.math.BigDecimal; +import java.util.Date; + +/** + * 物资出入库汇总 - 月 + */ +@Data +@TableName(value = "io_stat_month") +public class IoStatMonthEntity { + + @TableId(value = "id", type = IdType.AUTO) + private Integer id; + + /** + * 年度 + */ + @TableField(value = "`year`") + private Integer year; + + /** + * 季度 + */ + @TableField(value = "quarter") + private Integer quarter; + + /** + * 月份 + */ + @TableField(value = "`month`") + private Integer month; + + /** + * 物资编码主键 + */ + @TableField(value = "relIdFk") + private String relIdFk; + + /** + * 产品DI + */ + @TableField(value = "nameCode") + private String nameCode; + + /** + * 产品名称 + */ + @TableField(value = "productName") + private String productName; + + /** + * 规格型号 + */ + @TableField(value = "ggxh") + private String ggxh; + + /** + * 批次号 + */ + @TableField(value = "batchNo") + private String batchNo; + + /** + * 期初数量 + */ + @TableField(value = "beginCount") + private Integer beginCount; + + /** + * 期初价格 + */ + @TableField(value = "beginPrice") + private BigDecimal beginPrice; + + /** + * 期初金额 + */ + @TableField(value = "beginAmount") + private BigDecimal beginAmount; + + /** + * 入库数量 + */ + @TableField(value = "inCount") + private String inCount; + + /** + * 入库价格 + */ + @TableField(value = "inPrice") + private BigDecimal inPrice; + + /** + * 入库金额 + */ + @TableField(value = "inAmount") + private String inAmount; + + /** + * 出库数量 + */ + @TableField(value = "outCount") + private String outCount; + + /** + * 出库价格 + */ + @TableField(value = "outPrice") + private BigDecimal outPrice; + + /** + * 出库金额 + */ + @TableField(value = "outAmount") + private String outAmount; + + /** + * 结余数量 + */ + @TableField(value = "balanceCount") + private String balanceCount; + + /** + * 结余价格 + */ + @TableField(value = "balancePrice") + private BigDecimal balancePrice; + + /** + * 结余金额 + */ + @TableField(value = "balanceAmount") + private String balanceAmount; + + /** + * 备注 + */ + @TableField(value = "remark") + private String remark; + + /** + * 更新时间 + */ + @TableField(value = "updateTime") + private Date updateTime; + +} \ No newline at end of file diff --git a/src/main/java/com/glxp/api/entity/inout/IoStatOrderEntity.java b/src/main/java/com/glxp/api/entity/inout/IoStatOrderEntity.java new file mode 100644 index 000000000..61d2a722a --- /dev/null +++ b/src/main/java/com/glxp/api/entity/inout/IoStatOrderEntity.java @@ -0,0 +1,57 @@ +package com.glxp.api.entity.inout; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.util.Date; + +/** + * 物资出入库汇总 - 总表 + */ +@Data +@TableName(value = "io_stat_order") +public class IoStatOrderEntity { + + @TableId(value = "id", type = IdType.AUTO) + private Integer id; + + /** + * 记录号 + */ + @TableField(value = "recordKey") + private String recordKey; + + /** + * 生成时间 + */ + @TableField(value = "`date`") + private Date date; + + /** + * 1:年；2.季度，3：月 + */ + @TableField(value = "`type`") + private Integer type; + + /** + * 更新时间 + */ + @TableField(value = "updateTime") + private Date updateTime; + + /** + * 表格表头 + */ + @TableField(value = "title") + private String title; + + /** + * 备注 + */ + @TableField(value = "remark") + private String remark; + +} \ No newline at end of file diff --git a/src/main/java/com/glxp/api/entity/inout/IoStatQuarterEntity.java b/src/main/java/com/glxp/api/entity/inout/IoStatQuarterEntity.java new file mode 100644 index 000000000..42f3a894d --- /dev/null +++ b/src/main/java/com/glxp/api/entity/inout/IoStatQuarterEntity.java @@ -0,0 +1,147 @@ +package com.glxp.api.entity.inout; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.math.BigDecimal; +import java.util.Date; + +/** + * 物资出入库汇总 - 季度 + */ +@Data +@TableName(value = "io_stat_quarter") +public class IoStatQuarterEntity { + @TableId(value = "id", type = IdType.AUTO) + private Integer id; + + /** + * 年度 + */ + @TableField(value = "`year`") + private Integer year; + + /** + * 季度 + */ + @TableField(value = "quarter") + private Integer quarter; + + /** + * 物资编码主键 + */ + @TableField(value = "relIdFk") + private String relIdFk; + + /** + * 产品DI + */ + @TableField(value = "nameCode") + private String nameCode; + + /** + * 产品名称 + */ + @TableField(value = "productName") + private String productName; + + /** + * 规格型号 + */ + @TableField(value = "ggxh") + private String ggxh; + + /** + * 批次号 + */ + @TableField(value = "batchNo") + private String batchNo; + + /** + * 期初数量 + */ + @TableField(value = "beginCount") + private Integer beginCount; + + /** + * 期初价格 + */ + @TableField(value = "beginPrice") + private BigDecimal beginPrice; + + /** + * 期初金额 + */ + @TableField(value = "beginAmount") + private BigDecimal beginAmount; + + /** + * 入库数量 + */ + @TableField(value = "inCount") + private String inCount; + + /** + * 入库价格 + */ + @TableField(value = "inPrice") + private BigDecimal inPrice; + + /** + * 入库金额 + */ + @TableField(value = "inAmount") + private String inAmount; + + /** + * 出库数量 + */ + @TableField(value = "outCount") + private String outCount; + + /** + * 出库价格 + */ + @TableField(value = "outPrice") + private BigDecimal outPrice; + + /** + * 出库金额 + */ + @TableField(value = "outAmount") + private String outAmount; + + /** + * 结余数量 + */ + @TableField(value = "balanceCount") + private String balanceCount; + + /** + * 结余价格 + */ + @TableField(value = "balancePrice") + private BigDecimal balancePrice; + + /** + * 结余金额 + */ + @TableField(value = "balanceAmount") + private String balanceAmount; + + /** + * 备注 + */ + @TableField(value = "remark") + private String remark; + + /** + * 更新时间 + */ + @TableField(value = "updateTime") + private Date updateTime; + +} \ No newline at end of file diff --git a/src/main/java/com/glxp/api/entity/inout/IoStatYearEntity.java b/src/main/java/com/glxp/api/entity/inout/IoStatYearEntity.java new file mode 100644 index 000000000..f1e954b48 --- /dev/null +++ b/src/main/java/com/glxp/api/entity/inout/IoStatYearEntity.java @@ -0,0 +1,142 @@ +package com.glxp.api.entity.inout; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.math.BigDecimal; +import java.util.Date; + +/** + * 物资出入库汇总 - 年 + */ +@Data +@TableName(value = "io_stat_year") +public class IoStatYearEntity { + + @TableId(value = "id", type = IdType.AUTO) + private Integer id; + + /** + * 年度 + */ + @TableField(value = "`year`") + private Integer year; + + /** + * 物资编码主键 + */ + @TableField(value = "relIdFk") + private String relIdFk; + + /** + * 产品DI + */ + @TableField(value = "nameCode") + private String nameCode; + + /** + * 产品名称 + */ + @TableField(value = "productName") + private String productName; + + /** + * 规格型号 + */ + @TableField(value = "ggxh") + private String ggxh; + + /** + * 批次号 + */ + @TableField(value = "batchNo") + private String batchNo; + + /** + * 期初数量 + */ + @TableField(value = "beginCount") + private Integer beginCount; + + /** + * 期初价格 + */ + @TableField(value = "beginPrice") + private BigDecimal beginPrice; + + /** + * 期初金额 + */ + @TableField(value = "beginAmount") + private BigDecimal beginAmount; + + /** + * 入库数量 + */ + @TableField(value = "inCount") + private String inCount; + + /** + * 入库价格 + */ + @TableField(value = "inPrice") + private BigDecimal inPrice; + + /** + * 入库金额 + */ + @TableField(value = "inAmount") + private String inAmount; + + /** + * 出库数量 + */ + @TableField(value = "outCount") + private String outCount; + + /** + * 出库价格 + */ + @TableField(value = "outPrice") + private BigDecimal outPrice; + + /** + * 出库金额 + */ + @TableField(value = "outAmount") + private String outAmount; + + /** + * 结余数量 + */ + @TableField(value = "balanceCount") + private String balanceCount; + + /** + * 结余价格 + */ + @TableField(value = "balancePrice") + private BigDecimal balancePrice; + + /** + * 结余金额 + */ + @TableField(value = "balanceAmount") + private String balanceAmount; + + /** + * 备注 + */ + @TableField(value = "remark") + private String remark; + + /** + * 更新时间 + */ + @TableField(value = "updateTime") + private Date updateTime; + +} \ No newline at end of file diff --git a/src/main/java/com/glxp/api/service/inout/IoStatDayService.java b/src/main/java/com/glxp/api/service/inout/IoStatDayService.java new file mode 100644 index 000000000..a3198aadf --- /dev/null +++ b/src/main/java/com/glxp/api/service/inout/IoStatDayService.java @@ -0,0 +1,16 @@ +package com.glxp.api.service.inout; + +import java.util.Date; + +/** + * 物资出入库汇总 - 天 Service + */ +public interface IoStatDayService { + + /** + * 统计出入库汇总数据 + * + * @param date + */ + void statData(Date date); +} diff --git a/src/main/java/com/glxp/api/service/inout/IoStatMonthService.java b/src/main/java/com/glxp/api/service/inout/IoStatMonthService.java new file mode 100644 index 000000000..65b7629a0 --- /dev/null +++ b/src/main/java/com/glxp/api/service/inout/IoStatMonthService.java @@ -0,0 +1,17 @@ +package com.glxp.api.service.inout; + +import java.util.Date; + +/** + * 物资出入库汇总 - 月 Service + */ +public interface IoStatMonthService { + + /** + * 统计出入库汇总数据 + * + * @param date + */ + void statData(Date date); + +} diff --git a/src/main/java/com/glxp/api/service/inout/IoStatOrderService.java b/src/main/java/com/glxp/api/service/inout/IoStatOrderService.java new file mode 100644 index 000000000..3b5ad5383 --- /dev/null +++ b/src/main/java/com/glxp/api/service/inout/IoStatOrderService.java @@ -0,0 +1,7 @@ +package com.glxp.api.service.inout; + +/** + * 物资出入库汇总 - 总表 Service + */ +public interface IoStatOrderService { +} diff --git a/src/main/java/com/glxp/api/service/inout/IoStatQuarterService.java b/src/main/java/com/glxp/api/service/inout/IoStatQuarterService.java new file mode 100644 index 000000000..9ef46bf65 --- /dev/null +++ b/src/main/java/com/glxp/api/service/inout/IoStatQuarterService.java @@ -0,0 +1,17 @@ +package com.glxp.api.service.inout; + +import java.util.Date; + +/** + * 物资出入库汇总 - 季度 Service + */ +public interface IoStatQuarterService { + + /** + * 统计出入库汇总数据 + * + * @param date + */ + void statData(Date date); + +} diff --git a/src/main/java/com/glxp/api/service/inout/IoStatYearService.java b/src/main/java/com/glxp/api/service/inout/IoStatYearService.java new file mode 100644 index 000000000..8fe2083e5 --- /dev/null +++ b/src/main/java/com/glxp/api/service/inout/IoStatYearService.java @@ -0,0 +1,17 @@ +package com.glxp.api.service.inout; + +import java.util.Date; + +/** + * 物资出入库汇总 - 年 Service + */ +public interface IoStatYearService { + + /** + * 统计出入库汇总数据 + * + * @param date + */ + void statData(Date date); + +} diff --git a/src/main/java/com/glxp/api/service/inout/impl/IoStatDayServiceImpl.java b/src/main/java/com/glxp/api/service/inout/impl/IoStatDayServiceImpl.java new file mode 100644 index 000000000..4892f1230 --- /dev/null +++ b/src/main/java/com/glxp/api/service/inout/impl/IoStatDayServiceImpl.java @@ -0,0 +1,97 @@ +package com.glxp.api.service.inout.impl; + +import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.date.DateTime; +import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.StrUtil; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.glxp.api.constant.ConstantType; +import com.glxp.api.dao.inout.IoOrderDao; +import com.glxp.api.dao.inout.IoOrderDetailResultDao; +import com.glxp.api.dao.inout.IoStatDayDao; +import com.glxp.api.entity.inout.IoOrderDetailResultEntity; +import com.glxp.api.entity.inout.IoOrderEntity; +import com.glxp.api.entity.inout.IoStatDayEntity; +import com.glxp.api.service.inout.IoStatDayService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import javax.annotation.Resource; +import java.math.BigDecimal; +import java.util.Date; +import java.util.List; +import java.util.concurrent.CopyOnWriteArrayList; + +@Slf4j +@Service +@Transactional(rollbackFor = Exception.class) +public class IoStatDayServiceImpl implements IoStatDayService { + + @Resource + private IoStatDayDao statDayDao; + @Resource + private IoOrderDetailResultDao ioOrderDetailResultDao; + @Resource + private IoOrderDao orderDao; + + @Override + public void statData(Date date) { + //汇总前一天的数据 + DateTime yesterday = DateUtil.offsetDay(date, -1); + List orderDetailResultEntities = ioOrderDetailResultDao.selectList(new QueryWrapper() + .select("orderIdFk", "bindRlFk", "nameCode", "batchNo", "productDate", "expireDate", "coName", "spec", "price", "count", "reCount") + .between("createTime", DateUtil.beginOfDay(yesterday), DateUtil.endOfDay(yesterday))); + if (CollUtil.isNotEmpty(orderDetailResultEntities)) { + List dataList = new CopyOnWriteArrayList<>(orderDetailResultEntities); + dataList.parallelStream().forEach(orderDetailResultEntity -> { + //查询此产品前一天的数据 + IoStatDayEntity statDayEntity = statDayDao.selectOne(buildQueryWrapper(orderDetailResultEntity, yesterday)); + if (null == statDayEntity) { + //第一次汇总次产品数据 + statDayEntity = new IoStatDayEntity(); + statDayEntity.setYear(yesterday.year()); + statDayEntity.setMonth(yesterday.month()); + statDayEntity.setDay(DateUtil.dayOfMonth(yesterday)); + statDayEntity.setRelIdFk(String.valueOf(orderDetailResultEntity.getBindRlFk())); + statDayEntity.setNameCode(orderDetailResultEntity.getNameCode()); + statDayEntity.setProductName(orderDetailResultEntity.getCoName()); + statDayEntity.setGgxh(orderDetailResultEntity.getSpec()); + statDayEntity.setBatchNo(orderDetailResultEntity.getBatchNo()); + + //设置期初数据 + statDayEntity.setBeginCount(0); + statDayEntity.setBeginPrice(orderDetailResultEntity.getPrice()); + statDayEntity.setBeginAmount(BigDecimal.ZERO); + //查询此单是出库还是入库 + IoOrderEntity order = orderDao.selectOne(new QueryWrapper().select("mainAction").eq("billNo", orderDetailResultEntity.getOrderIdFk())); + if (order.getMainAction().equals(ConstantType.TYPE_PUT)) { + //入库 + statDayEntity.setInCount(String.valueOf(orderDetailResultEntity.getReCount())); + statDayEntity.setInPrice(orderDetailResultEntity.getPrice()); + BigDecimal inAmount = orderDetailResultEntity.getPrice().multiply(BigDecimal.valueOf(orderDetailResultEntity.getReCount())); + statDayEntity.setInAmount(inAmount.toString()); + + } else if (order.getMainAction().equals(ConstantType.TYPE_OUT)) { + //出库 + + } + + } + }); + } + + } + + private static QueryWrapper buildQueryWrapper(IoOrderDetailResultEntity orderDetailResultEntity, DateTime yesterday) { + QueryWrapper wrapper = new QueryWrapper<>(); + wrapper.eq("year", yesterday.year()) + .eq("month", yesterday.month()) + .eq("day", DateUtil.dayOfMonth(yesterday)) + .eq("relIdFk", orderDetailResultEntity.getBindRlFk()) + .eq(StrUtil.isNotBlank(orderDetailResultEntity.getBatchNo()), "batchNo", orderDetailResultEntity.getBatchNo()) + .eq(StrUtil.isNotBlank(orderDetailResultEntity.getNameCode()), "nameCode", orderDetailResultEntity.getNameCode()); + return wrapper; + } + +} diff --git a/src/main/java/com/glxp/api/service/inout/impl/IoStatMonthServiceImpl.java b/src/main/java/com/glxp/api/service/inout/impl/IoStatMonthServiceImpl.java new file mode 100644 index 000000000..9cd1dfbdb --- /dev/null +++ b/src/main/java/com/glxp/api/service/inout/impl/IoStatMonthServiceImpl.java @@ -0,0 +1,18 @@ +package com.glxp.api.service.inout.impl; + +import com.glxp.api.service.inout.IoStatMonthService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.util.Date; + +@Slf4j +@Service +@Transactional(rollbackFor = Exception.class) +public class IoStatMonthServiceImpl implements IoStatMonthService { + @Override + public void statData(Date date) { + + } +} diff --git a/src/main/java/com/glxp/api/service/inout/impl/IoStatOrderServiceImpl.java b/src/main/java/com/glxp/api/service/inout/impl/IoStatOrderServiceImpl.java new file mode 100644 index 000000000..7ccac1799 --- /dev/null +++ b/src/main/java/com/glxp/api/service/inout/impl/IoStatOrderServiceImpl.java @@ -0,0 +1,12 @@ +package com.glxp.api.service.inout.impl; + +import com.glxp.api.service.inout.IoStatOrderService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +@Slf4j +@Service +@Transactional(rollbackFor = Exception.class) +public class IoStatOrderServiceImpl implements IoStatOrderService { +} diff --git a/src/main/java/com/glxp/api/service/inout/impl/IoStatQuarterServiceImpl.java b/src/main/java/com/glxp/api/service/inout/impl/IoStatQuarterServiceImpl.java new file mode 100644 index 000000000..6888d597a --- /dev/null +++ b/src/main/java/com/glxp/api/service/inout/impl/IoStatQuarterServiceImpl.java @@ -0,0 +1,18 @@ +package com.glxp.api.service.inout.impl; + +import com.glxp.api.service.inout.IoStatQuarterService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.util.Date; + +@Slf4j +@Service +@Transactional(rollbackFor = Exception.class) +public class IoStatQuarterServiceImpl implements IoStatQuarterService { + @Override + public void statData(Date date) { + + } +} diff --git a/src/main/java/com/glxp/api/service/inout/impl/IoStatYearServiceImpl.java b/src/main/java/com/glxp/api/service/inout/impl/IoStatYearServiceImpl.java new file mode 100644 index 000000000..e36fa39a9 --- /dev/null +++ b/src/main/java/com/glxp/api/service/inout/impl/IoStatYearServiceImpl.java @@ -0,0 +1,18 @@ +package com.glxp.api.service.inout.impl; + +import com.glxp.api.service.inout.IoStatYearService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.util.Date; + +@Slf4j +@Service +@Transactional(rollbackFor = Exception.class) +public class IoStatYearServiceImpl implements IoStatYearService { + @Override + public void statData(Date date) { + + } +} diff --git a/src/main/java/com/glxp/api/task/IoStatOrderTask.java b/src/main/java/com/glxp/api/task/IoStatOrderTask.java new file mode 100644 index 000000000..f31532e13 --- /dev/null +++ b/src/main/java/com/glxp/api/task/IoStatOrderTask.java @@ -0,0 +1,90 @@ +package com.glxp.api.task; + + +import cn.hutool.core.thread.ThreadUtil; +import com.glxp.api.dao.schedule.ScheduledDao; +import com.glxp.api.entity.system.ScheduledEntity; +import com.glxp.api.req.system.ScheduledRequest; +import com.glxp.api.service.inout.IoStatDayService; +import com.glxp.api.service.inout.IoStatMonthService; +import com.glxp.api.service.inout.IoStatQuarterService; +import com.glxp.api.service.inout.IoStatYearService; +import com.glxp.api.util.DateUtil; +import lombok.extern.slf4j.Slf4j; +import org.springframework.scheduling.annotation.SchedulingConfigurer; +import org.springframework.scheduling.config.ScheduledTaskRegistrar; +import org.springframework.scheduling.support.CronTrigger; +import org.springframework.stereotype.Component; + +import javax.annotation.Resource; +import java.util.Date; + +/** + * 物资出入库汇总定时任务 + */ +@Slf4j +@Component +public class IoStatOrderTask implements SchedulingConfigurer { + + @Resource + private ScheduledDao scheduledDao; + @Resource + private IoStatDayService statDayService; + @Resource + private IoStatMonthService statMonthService; + @Resource + private IoStatQuarterService statQuarterService; + @Resource + private IoStatYearService statYearService; + + @Override + public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { + taskRegistrar.addTriggerTask(this::process, triggerContext -> { + ScheduledRequest scheduledRequest = new ScheduledRequest(); + scheduledRequest.setCronName("ioStatOrderTask"); + ScheduledEntity scheduled = scheduledDao.findScheduled(scheduledRequest); + if (null == scheduled) { + log.info("物资出入库汇总定时任务未配置，请注意！"); + return null; + } + String cron = scheduled.getCron(); + return new CronTrigger(cron).nextExecutionTime(triggerContext); + }); + } + + private void process() { + log.info("开始汇总物资出入库数据"); + //生成每日汇总数据 + Date today = new Date(); + ThreadUtil.execAsync(() -> { + log.info("开始生成每日物资出入库汇总数据"); + statDayService.statData(today); + log.info("每日物资出入库数据汇总生成结束"); + }); + + if (DateUtil.isMonthStart(today)) { + ThreadUtil.execAsync(() -> { + log.info("本日为月初，生成月度物资出入库汇总数据"); + statMonthService.statData(today); + log.info("月度物资出入库汇总数据生成结束"); + }); + } + + if (DateUtil.isQuarterStart(today)) { + ThreadUtil.execAsync(() -> { + log.info("本日为季初，生成季度物资出入库汇总数据"); + statQuarterService.statData(today); + log.info("季度物资出入库汇总数据生成结束"); + }); + } + + if (DateUtil.isYearStart(today)) { + ThreadUtil.execAsync(() -> { + log.info("本日为年初，生成年度物资出入库汇总数据"); + statYearService.statData(today); + log.info("年度物资出入库汇总数据生成结束"); + }); + } + } + +} diff --git a/src/main/java/com/glxp/api/util/DateUtil.java b/src/main/java/com/glxp/api/util/DateUtil.java index 3fbc116b4..dfb08735c 100644 --- a/src/main/java/com/glxp/api/util/DateUtil.java +++ b/src/main/java/com/glxp/api/util/DateUtil.java @@ -1,5 +1,6 @@ package com.glxp.api.util; +import cn.hutool.core.date.DateTime; import cn.hutool.core.util.StrUtil; import com.glxp.api.entity.inout.IoOrderEntity; import lombok.extern.slf4j.Slf4j; @@ -639,4 +640,47 @@ public class DateUtil extends DateUtils { } return null; } + + /** + * 判断给定时间是否是月初第一天 + * + * @param date + * @return + */ + public static boolean isMonthStart(Date date) { + if (null == date) { + return false; + } + DateTime monthStart = cn.hutool.core.date.DateUtil.beginOfMonth(date); + return monthStart.toString("yyyy-MM-dd").equals(formatDate(date, "yyyy-MM-dd")); + } + + /** + * 判断给定时间是否是季度第一天 + * + * @param date + * @return + */ + public static boolean isQuarterStart(Date date) { + if (null == date) { + return false; + } + DateTime quarterStart = cn.hutool.core.date.DateUtil.beginOfQuarter(date); + return quarterStart.toString("yyyy-MM-dd").equals(formatDate(date, "yyyy-MM-dd")); + } + + /** + * 判断给定时间是否是年度第一天 + * + * @param date + * @return + */ + public static boolean isYearStart(Date date) { + if (null == date) { + return false; + } + DateTime yearStart = cn.hutool.core.date.DateUtil.beginOfYear(date); + return yearStart.toString("yyyy-MM-dd").equals(formatDate(date, "yyyy-MM-dd")); + } + } \ No newline at end of file diff --git a/src/main/resources/mybatis/mapper/inout/IoStatDayDao.xml b/src/main/resources/mybatis/mapper/inout/IoStatDayDao.xml new file mode 100644 index 000000000..c4a561845 --- /dev/null +++ b/src/main/resources/mybatis/mapper/inout/IoStatDayDao.xml @@ -0,0 +1,5 @@ + + + + + \ No newline at end of file diff --git a/src/main/resources/mybatis/mapper/inout/IoStatMonthDao.xml b/src/main/resources/mybatis/mapper/inout/IoStatMonthDao.xml new file mode 100644 index 000000000..8becbedf8 --- /dev/null +++ b/src/main/resources/mybatis/mapper/inout/IoStatMonthDao.xml @@ -0,0 +1,4 @@ + + + + \ No newline at end of file diff --git a/src/main/resources/mybatis/mapper/inout/IoStatOrderDao.xml b/src/main/resources/mybatis/mapper/inout/IoStatOrderDao.xml new file mode 100644 index 000000000..3e644610e --- /dev/null +++ b/src/main/resources/mybatis/mapper/inout/IoStatOrderDao.xml @@ -0,0 +1,4 @@ + + + + \ No newline at end of file diff --git a/src/main/resources/mybatis/mapper/inout/IoStatQuarterDao.xml b/src/main/resources/mybatis/mapper/inout/IoStatQuarterDao.xml new file mode 100644 index 000000000..362d9eca5 --- /dev/null +++ b/src/main/resources/mybatis/mapper/inout/IoStatQuarterDao.xml @@ -0,0 +1,4 @@ + + + + \ No newline at end of file diff --git a/src/main/resources/mybatis/mapper/inout/IoStatYearDao.xml b/src/main/resources/mybatis/mapper/inout/IoStatYearDao.xml new file mode 100644 index 000000000..7d142a125 --- /dev/null +++ b/src/main/resources/mybatis/mapper/inout/IoStatYearDao.xml @@ -0,0 +1,4 @@ + + + + \ No newline at end of file