增加年度统计报表的定时任务

jyzb-biz/src/main/java/com/junmp/jyzb/controller/InventoryController.java

@@ -35,6 +35,13 @@ public class InventoryController {
     public MQProductService mqProductService;
 
 
+    @GetMapping("/TestSum")
+    @ApiOperation("根据组织机构查询库存信息")
+    public ApiRes<Boolean> TestSum( ) {
+        inventorySummaryService.MonthStartSum();
+        return ApiRes.success();
+    }
+
     @GetMapping("/testMQ")
     @ApiOperation("根据组织机构查询库存信息")
     public ApiRes<Boolean> testMQ( ) {

jyzb-biz/src/main/java/com/junmp/jyzb/entity/PriceSumSummary.java

+package com.junmp.jyzb.entity;
+
+import com.baomidou.mybatisplus.annotation.*;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+
+
+/**
+ * <pre>
+ *
+ * 描述：
+ * 版本：1.0.0
+ * 日期：2022/7/29 16:54
+ * 作者：ningzp@junmp.com.cn
+ * <br>修改记录
+ * <br>修改日期        修改人          修改内容
+ *
+ * </pre>
+ */
+@Data
+@TableName("vie_price_sum_summary")
+public class PriceSumSummary implements Serializable {
+
+    @TableId(value = "id")
+    private String id;
+
+    /**
+     *
+     */
+    @TableField("org_id_int")
+    private String orgIdInt;
+
+    /**
+     *
+     */
+    @TableField("org_code")
+    private String orgCode;
+    /**
+     *
+     */
+    @TableField("org_name")
+    private String orgName;
+    /**
+     *
+     */
+    @TableField("org_name_short")
+    private String orgNameShort;
+    /**
+     *
+     */
+    @TableField("sum_type")
+    private String sumType;
+    /**
+     *
+     */
+    private String year;
+    /**
+     *
+     */
+    private String month;
+    /**
+     *
+     */
+    @TableField("start_price")
+    private String startPrice;
+    /**
+     *
+     */
+    @TableField("end_price")
+    private String endPrice;
+
+    /**
+     *
+     */
+    @TableField("start_num")
+    private String startNum;
+    /**
+     *
+     */
+    @TableField("end_num")
+    private String endNum;
+    /**
+     *
+     */
+    @TableField("destory_num")
+    private String destoryNum;
+    /**
+     *
+     */
+    @TableField("destory_price")
+    private String destoryPrice;
+    /**
+     *
+     */
+    @TableField("add_num")
+    private String addNum;
+    /**
+     *
+     */
+    @TableField("add_price")
+    private String addPrice;
+    /**
+     *
+     */
+    @TableField("type_name")
+    private String typeName;
+    /**
+     *
+     */
+    @TableField("type_id")
+    private String typeId;
+    /**
+     *
+     */
+    @TableField("size_name")
+    private String sizeName;
+    /**
+     *
+     */
+    @TableField("size_id")
+    private String sizeId;
+
+    /**
+     * 创建时间
+     */
+    @TableField(value = "create_time", fill = FieldFill.INSERT)
+    private Date createTime;
+
+    /**
+     * 更新时间
+     */
+    @TableField(value = "update_time", fill = FieldFill.UPDATE)
+    private Date updateTime;
+
+
+}

jyzb-biz/src/main/java/com/junmp/jyzb/mapper/PriceSumSummaryMapper.java

+package com.junmp.jyzb.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.junmp.jyzb.entity.PriceSumSummary;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface PriceSumSummaryMapper extends BaseMapper<PriceSumSummary> {
+
+
+    /**
+     * 存储过程-月初金额数量统计
+     */
+    void  MonthStart ();
+
+    /**
+     * 存储过程-月末金额数量统计
+     */
+    void  MonthEnd ();
+
+    /**
+     * 存储过程-月末差值计算统计
+     */
+    void  MonthDifference ();
+}

jyzb-biz/src/main/java/com/junmp/jyzb/service/InventorySummaryService.java

@@ -16,6 +16,10 @@ import java.util.List;
 
 public interface InventorySummaryService extends IService<InventorySummary> {
 
+
+    void MonthStartSum();
+    void MonthEndSum();
+
     //根据条件查询库存汇总信息
     PageResult<InventorySummary> getEquipmentInfo(InventorySumReq req);
 

jyzb-biz/src/main/java/com/junmp/jyzb/service/impl/InventorySummaryServiceImpl.java

@@ -12,6 +12,7 @@ import com.junmp.jyzb.api.bean.query.InventorySumReq;
 import com.junmp.jyzb.api.bean.req.CabinetInOutRecordsReq;
 import com.junmp.jyzb.api.bean.req.RabbitMqOrderReq;
 import com.junmp.jyzb.entity.*;
+import com.junmp.jyzb.mapper.PriceSumSummaryMapper;
 import com.junmp.jyzb.service.*;
 import com.junmp.v2.common.util.BeanPlusUtil;
 import com.junmp.v2.db.api.factory.PageFactory;
@@ -64,8 +65,18 @@ public class InventorySummaryServiceImpl  extends ServiceImpl<InventorySummaryMa
 
     @Resource
     private SysDictItemService sysDictItemService;
+    @Resource
+    private PriceSumSummaryMapper PriceSumSummaryMapper;
 
-
+    @Override
+    public void MonthStartSum() {
+        PriceSumSummaryMapper.MonthStart();
+    }
+    @Override
+    public void MonthEndSum() {
+        PriceSumSummaryMapper.MonthEnd();
+        PriceSumSummaryMapper.MonthDifference();
+    }
     //根据条件查询库存汇总信息
     @Override
     public PageResult<InventorySummary> getEquipmentInfo(InventorySumReq req) {

jyzb-biz/src/main/java/com/junmp/jyzb/task/MonthEnd.java

+package com.junmp.jyzb.task;
+
+import com.junmp.jyzb.service.InventorySummaryService;
+import com.junmp.v2.job.api.JobAction;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Slf4j
+@Component
+public class MonthEnd implements JobAction{
+
+    @Resource
+    public InventorySummaryService inventorySummaryService;
+
+    //月末执行以计算金额
+    @Override
+    public void action() {
+        inventorySummaryService.MonthEndSum();
+    }
+
+}

jyzb-biz/src/main/java/com/junmp/jyzb/task/MonthStart.java

+package com.junmp.jyzb.task;
+
+import com.junmp.jyzb.service.InventorySummaryService;
+import com.junmp.v2.job.api.JobAction;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+@Slf4j
+@Component
+public class MonthStart implements JobAction{
+
+    @Resource
+    public InventorySummaryService inventorySummaryService;
+
+    //月初执行
+    @Override
+    public void action() {
+        inventorySummaryService.MonthStartSum();
+    }
+
+}

jyzb-biz/src/main/resources/mapper/InventorySummaryMapper.xml

@@ -74,6 +74,21 @@
         delete from base_inventory_summary where locationId = #{cabinetId}
     </delete>
 
+    <update  parameterType="java.lang.String" id="id">
+        UPDATE vie_price_sum_summary
+        SET
+            add_price = CASE
+                            WHEN add_price IS NULL THEN start_price - end_price
+                            ELSE add_price
+                END,
+            add_num = CASE
+                          WHEN add_num IS NULL THEN start_num - end_num
+                          ELSE add_num
+                END
+        WHERE add_price IS NULL OR add_num IS NULL;
+    </update>
+
+
     <insert id="getSumByCabinet">
         INSERT INTO base_inventory_summary (id,org_id_int,org_name,type_id, type_name,size_id,size_name,location_id,location_name,
                                             number,unit_price,price,stock_number, outbound_number,destruction_number,expire_number,

jyzb-biz/src/main/resources/mapper/PriceSumSummaryMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.junmp.jyzb.mapper.PriceSumSummaryMapper">
+
+
+<!--    <update  parameterType="java.lang.String" id="PriceNumCacu">-->
+<!--        UPDATE vie_price_sum_summary-->
+<!--        SET-->
+<!--            add_price = CASE-->
+<!--                            WHEN add_price IS NULL THEN start_price - end_price-->
+<!--                            ELSE add_price-->
+<!--                END,-->
+<!--            add_num = CASE-->
+<!--                          WHEN add_num IS NULL THEN start_num - end_num-->
+<!--                          ELSE add_num-->
+<!--                END-->
+<!--        WHERE add_price IS NULL OR add_num IS NULL;-->
+<!--    </update>-->
+
+    <select id="MonthStart" statementType="CALLABLE" >
+        {call UpdateStartSummary()}
+    </select>
+
+    <select id="MonthEnd" statementType="CALLABLE" >
+        {call UpdateEndSummary()}
+    </select>
+
+    <select id="MonthDifference" statementType="CALLABLE" >
+        {call UpdatePriceSummary()}
+    </select>
+</mapper>
\ No newline at end of file