1.增加钢材到货情况统计

src/main/java/com/dsic/gj_erp/bean/钢材到货情况统计.java

@@ -0,0 +1,24 @@
+package com.dsic.gj_erp.bean;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
+import lombok.Getter;
+import lombok.Setter;
+
+import java.math.BigDecimal;
+
+@Getter
+@Setter
+@TableName("钢材到货情况统计")
+public class 钢材到货情况统计 {
+
+    @MppMultiId
+    private String dcCh;
+    @MppMultiId
+    private String plZ;
+    @MppMultiId
+    private String dzwz;
+    private BigDecimal planTon;//订货重量(吨)
+    private String planDate;//计划到货日期
+    private BigDecimal completeTon;//已到货重量(吨)
+}

src/main/java/com/dsic/gj_erp/controller/钢材到货情况统计Controller.java

@@ -0,0 +1,21 @@
+package com.dsic.gj_erp.controller;
+
+import com.dsic.gj_erp.bean.ResultBean;
+import com.dsic.gj_erp.service.钢材到货情况统计Service;
+import lombok.AllArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("钢材到货情况统计")
+@AllArgsConstructor
+public class 钢材到货情况统计Controller {
+
+    private final 钢材到货情况统计Service service;
+
+    @GetMapping("list")
+    public ResultBean<?> list(){
+        return new ResultBean<>(service.list());
+    }
+}

src/main/java/com/dsic/gj_erp/mapper/钢材到货情况统计Mapper.java

@@ -0,0 +1,13 @@
+package com.dsic.gj_erp.mapper;
+
+import com.dsic.gj_erp.bean.钢材到货情况统计;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+@Mapper
+public interface 钢材到货情况统计Mapper extends MppBaseMapper<钢材到货情况统计> {
+
+    List<钢材到货情况统计> 钢材到货情况统计();
+}

src/main/java/com/dsic/gj_erp/service/钢材到货情况统计Service.java

@@ -0,0 +1,40 @@
+package com.dsic.gj_erp.service;
+
+import cn.hutool.cron.CronUtil;
+import cn.hutool.cron.task.Task;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.dsic.gj_erp.bean.钢材到货情况统计;
+import com.dsic.gj_erp.mapper.钢材到货情况统计Mapper;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.PostConstruct;
+import java.util.ArrayList;
+import java.util.List;
+
+@Service
+public class 钢材到货情况统计Service extends MppServiceImpl<钢材到货情况统计Mapper, 钢材到货情况统计> {
+
+    @PostConstruct
+    public void start(){
+        CronUtil.schedule("* * 16 * * ?", (Task) this::process);
+        CronUtil.start();
+    }
+
+    public void process(){
+        List<钢材到货情况统计> 钢材到货情况统计 = baseMapper.钢材到货情况统计();
+
+        List<钢材到货情况统计> insertOrUpdateList=new ArrayList<>();
+        钢材到货情况统计.forEach(item->{
+            钢材到货情况统计 _钢材到货情况统计 = this.selectByMultiId(item);
+            if (_钢材到货情况统计!=null){
+                if (item.getCompleteTon().compareTo(_钢材到货情况统计.getCompleteTon())>0){
+                    _钢材到货情况统计.setCompleteTon(item.getCompleteTon());
+                    insertOrUpdateList.add(_钢材到货情况统计);
+                }
+            }else{
+                insertOrUpdateList.add(item);
+            }
+        });
+    }
+}

src/main/resources/mappers/钢材到货情况统计Mappere.xml

@@ -0,0 +1,21 @@
+<?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.dsic.gj_erp.mapper.钢材到货情况统计Mapper">
+
+    <select id="钢材到货情况统计" resultType="com.dsic.gj_erp.bean.钢材到货情况统计">
+        SELECT
+            a.dc_ch,a.pl_z,a.DZWZ,sum(a.dhsl1) plan_ton,sum(dhsl) complete_ton
+        FROM (
+            SELECT
+               DISTINCT MS_DDJBP.WJWZ dc_ch,MS_DDJBP.BZO pl_z,MS_DDJBP.DZWZ ,MS_DDMXP.WPH ,MS_DDMXP.DHSL1
+                      ,case when isnull(IM_CKWPKWP.WPH ,'')!='' then MS_DDMXP.DHSL1 else 0 end dhsl
+            FROM
+               MS_DDJBP left join MS_DDMXP on MS_DDJBP.DDH=MS_DDMXP.DDH and MS_DDJBP.CGFLM =MS_DDJBP.CGFLM
+                left join IM_CKWPKWP on MS_DDMXP.DC_CM =IM_CKWPKWP.DC_FD and MS_DDMXP.WPH =IM_CKWPKWP.WPH and MS_DDMXP.DC_CH =IM_CKWPKWP.GCDDH
+            WHERE  MS_DDJBP.CGFLM ='01' and MS_DDJBP.WJWZ in (select CBBM from DM_CBXXP WHERE wgbs='N')
+            ) a
+        group by a.dc_ch,a.pl_z,a.DZWZ
+        order by a.dc_ch,a.pl_z,a.DZWZ
+    </select>
+
+</mapper>