1、查询农户年月的各日用水信息； 2、修改文档名称为《管系统系统增加一个客户的方法》； 3、增加一个文档《洒泉职业技术学院设备配置》。

liurunyu

2025-01-03 c8b2311124fd5785b90d2fb4bd9ae0078aa13055

1、查询农户年月的各日用水信息；
2、修改文档名称为《管系统系统增加一个客户的方法》；
3、增加一个文档《洒泉职业技术学院设备配置》。

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/daoSt/StClientAmountDayMapper.java

@@ -3,10 +3,12 @@
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.dy.pipIrrGlobal.pojoSt.StClientAmountDay;
import com.dy.pipIrrGlobal.voSt.VoClientAmountStatistics;
import com.dy.pipIrrGlobal.voSt.VoStClientAmountDay;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

import java.util.List;
import java.util.Map;

/**
 * @Author: liurunyu
@@ -65,6 +67,21 @@


    //////////////////////////////////////
    //查询统计结果
    /**
     * æŸ¥è¯¢æ€»æ•°é‡
     * @param params
     * @return
     */
    Long selectCountDayStatistics(Map<?, ?> params) ;
    /**
     * æŸ¥è¯¢åˆ†é¡µæ•°æ®
     * @param params
     * @return
     */
    List<VoStClientAmountDay> selectDayStatistics(Map<?, ?> params) ;

    //////////////////////////////////////
    //统计相关
    /**
     * æŸ¥è¯¢ç”¨æ°´æˆ·ä¸€ä¸ªæœˆæ‰€æœ‰æ—¥çš„用水量

 pipIrr-platform/pipIrr-global/src/main/java/com/dy/pipIrrGlobal/voSt/VoStClientAmountDay.java

New file
@@ -0,0 +1,517 @@
package com.dy.pipIrrGlobal.voSt;

import com.alibaba.fastjson2.annotation.JSONField;
import com.alibaba.fastjson2.writer.ObjectWriterImplToString;
import lombok.Data;

/**
 * @Author: liurunyu
 * @Date: 2025/1/3 10:47
 * @Description
 */
@Data
public class VoStClientAmountDay {

    public static final long serialVersionUID = 202412300924001L;
    /**
     * ä¸»é”®
     */
    @JSONField(serializeUsing= ObjectWriterImplToString.class)
    public Long id;

    /**
     * å¤–键，指向农户
     */
    @JSONField(serializeUsing= ObjectWriterImplToString.class)
    public Long clientId;

    /**
     * å†œæˆ·ç¼–号
     */
    public String clientNum ;

    /**
     * å†œæˆ·åç§°
     */
    public String clientName ;

    /**
     * å†œæˆ·åœ°å€
     */
    public String clientAddress ;

    /**
     * å¹´åº¦
     */
    public Integer year;

    /**
     * æœˆä»½
     */
    public Integer month;

    /**
     * 1号用水量统计
     */
    public Double amount1;

    /**
     * 1号花费金额
     */
    public Double money1;

    /**
     * 1号用水次数
     */
    public Integer times1;

    /**
     * 2号用水量统计
     */
    public Double amount2;

    /**
     * 2号花费金额
     */
    public Double money2;

    /**
     * 2号用水次数
     */
    public Integer times2;

    /**
     * 3号用水量统计
     */
    public Double amount3;

    /**
     * 3号花费金额
     */
    public Double money3;

    /**
     * 3号用水次数
     */
    public Integer times3;

    /**
     * 4号用水量统计
     */
    public Double amount4;

    /**
     * 4号花费金额
     */
    public Double money4;

    /**
     * 4号用水次数
     */
    public Integer times4;

    /**
     * 5号用水量统计
     */
    public Double amount5;

    /**
     * 5号花费金额
     */
    public Double money5;

    /**
     * 5号用水次数
     */
    public Integer times5;

    /**
     * 6号用水量统计
     */
    public Double amount6;

    /**
     * 6号花费金额
     */
    public Double money6;

    /**
     * 6号用水次数
     */
    public Integer times6;

    /**
     * 7号用水量统计
     */
    public Double amount7;

    /**
     * 7号花费金额
     */
    public Double money7;

    /**
     * 7号用水次数
     */
    public Integer times7;

    /**
     * 8号用水量统计
     */
    public Double amount8;

    /**
     * 8号花费金额
     */
    public Double money8;

    /**
     * 8号用水次数
     */
    public Integer times8;

    /**
     * 9号用水量统计
     */
    public Double amount9;

    /**
     * 9号花费金额
     */
    public Double money9;

    /**
     * 9号用水次数
     */
    public Integer times9;

    /**
     * 10号用水量统计
     */
    public Double amount10;

    /**
     * 10号花费金额
     */
    public Double money10;

    /**
     * 10号用水次数
     */
    public Integer times10;

    /**
     * 11号用水量统计
     */
    public Double amount11;

    /**
     * 11号花费金额
     */
    public Double money11;

    /**
     * 11号用水次数
     */
    public Integer times11;

    /**
     * 12号用水量统计
     */
    public Double amount12;

    /**
     * 12号花费金额
     */
    public Double money12;

    /**
     * 12号用水次数
     */
    public Integer times12;

    /**
     * 13号用水量统计
     */
    public Double amount13;

    /**
     * 13号花费金额
     */
    public Double money13;

    /**
     * 13号用水次数
     */
    public Integer times13;

    /**
     * 14号用水量统计
     */
    public Double amount14;

    /**
     * 14号花费金额
     */
    public Double money14;

    /**
     * 14号用水次数
     */
    public Integer times14;

    /**
     * 15号用水量统计
     */
    public Double amount15;

    /**
     * 15号花费金额
     */
    public Double money15;

    /**
     * 15号用水次数
     */
    public Integer times15;

    /**
     * 16号用水量统计
     */
    public Double amount16;

    /**
     * 16号花费金额
     */
    public Double money16;

    /**
     * 16号用水次数
     */
    public Integer times16;

    /**
     * 17号用水量统计
     */
    public Double amount17;

    /**
     * 17号花费金额
     */
    public Double money17;

    /**
     * 17号用水次数
     */
    public Integer times17;

    /**
     * 18号用水量统计
     */
    public Double amount18;

    /**
     * 18号花费金额
     */
    public Double money18;

    /**
     * 18号用水次数
     */
    public Integer times18;

    /**
     * 19号用水量统计
     */
    public Double amount19;

    /**
     * 19号花费金额
     */
    public Double money19;

    /**
     * 19号用水次数
     */
    public Integer times19;

    /**
     * 20号用水量统计
     */
    public Double amount20;

    /**
     * 20号花费金额
     */
    public Double money20;

    /**
     * 20号用水次数
     */
    public Integer times20;

    /**
     * 21号用水量统计
     */
    public Double amount21;

    /**
     * 21号花费金额
     */
    public Double money21;

    /**
     * 21号用水次数
     */
    public Integer times21;

    /**
     * 22号用水量统计
     */
    public Double amount22;

    /**
     * 22号花费金额
     */
    public Double money22;

    /**
     * 22号用水次数
     */
    public Integer times22;

    /**
     * 23号用水量统计
     */
    public Double amount23;

    /**
     * 23号花费金额
     */
    public Double money23;

    /**
     * 23号用水次数
     */
    public Integer times23;

    /**
     * 24号用水量统计
     */
    public Double amount24;

    /**
     * 24号花费金额
     */
    public Double money24;

    /**
     * 24号用水次数
     */
    public Integer times24;

    /**
     * 25号用水量统计
     */
    public Double amount25;

    /**
     * 25号花费金额
     */
    public Double money25;

    /**
     * 25号用水次数
     */
    public Integer times25;

    /**
     * 26号用水量统计
     */
    public Double amount26;

    /**
     * 26号花费金额
     */
    public Double money26;

    /**
     * 26号用水次数
     */
    public Integer times26;

    /**
     * 27号用水量统计
     */
    public Double amount27;

    /**
     * 27号花费金额
     */
    public Double money27;

    /**
     * 27号用水次数
     */
    public Integer times27;

    /**
     * 28号用水量统计
     */
    public Double amount28;

    /**
     * 28号花费金额
     */
    public Double money28;

    /**
     * 28号用水次数
     */
    public Integer times28;

    /**
     * 29号用水量统计
     */
    public Double amount29;

    /**
     * 29号花费金额
     */
    public Double money29;

    /**
     * 29号用水次数
     */
    public Integer times29;

    /**
     * 30号用水量统计
     */
    public Double amount30;

    /**
     * 30号花费金额
     */
    public Double money30;

    /**
     * 30号用水次数
     */
    public Integer times30;

    /**
     * 31号用水量统计
     */
    public Double amount31;

    /**
     * 31号花费金额
     */
    public Double money31;

    /**
     * 31号用水次数
     */
    public Integer times31;
}

 pipIrr-platform/pipIrr-global/src/main/resources/mapper/StClientAmountDayMapper.xml

@@ -116,6 +116,22 @@
    times27, amount28, money28, times28, amount29, money29, times29, amount30, money30, 
    times30, amount31, money31, times31
  </sql>
  <sql id="Base_Column_List_with_alias">
    <!--@mbg.generated-->
    #{alias}id, #{alias}client_id, #{alias}`year`, #{alias}`month`, #{alias}amount1, #{alias}money1, #{alias}times1, #{alias}amount2, #{alias}money2, #{alias}times2,
    amount3, #{alias}money3, #{alias}times3, #{alias}amount4, #{alias}money4, #{alias}times4, #{alias}amount5, #{alias}money5, #{alias}times5, #{alias}amount6,
    money6, #{alias}times6, #{alias}amount7, #{alias}money7, #{alias}times7, #{alias}amount8, #{alias}money8, #{alias}times8, #{alias}amount9, #{alias}money9,
    times9, #{alias}amount10, #{alias}money10, #{alias}times10, #{alias}amount11, #{alias}money11, #{alias}times11, #{alias}amount12, #{alias}money12,
    times12, #{alias}amount13, #{alias}money13, #{alias}times13, #{alias}amount14, #{alias}money14, #{alias}times14, #{alias}amount15, #{alias}money15,
    times15, #{alias}amount16, #{alias}money16, #{alias}times16, #{alias}amount17, #{alias}money17, #{alias}times17, #{alias}amount18, #{alias}money18,
    times18, #{alias}amount19, #{alias}money19, #{alias}times19, #{alias}amount20, #{alias}money20, #{alias}times20, #{alias}amount21, #{alias}money21,
    times21, #{alias}amount22, #{alias}money22, #{alias}times22, #{alias}amount23, #{alias}money23, #{alias}times23, #{alias}amount24, #{alias}money24,
    times24, #{alias}amount25, #{alias}money25, #{alias}times25, #{alias}amount26, #{alias}money26, #{alias}times26, #{alias}amount27, #{alias}money27,
    times27, #{alias}amount28, #{alias}money28, #{alias}times28, #{alias}amount29, #{alias}money29, #{alias}times29, #{alias}amount30, #{alias}money30,
    times30, #{alias}amount31, #{alias}money31, #{alias}times31
  </sql>


  <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
    <!--@mbg.generated-->
    select 
@@ -1185,6 +1201,49 @@
  </update>

  <!-- ////////////////////////////////// -->
  <!-- æŸ¥è¯¢ç»Ÿè®¡ç»“æžœ                         -->
  <!-- ////////////////////////////////// -->
  <select id="selectCountDayStatistics" resultType="java.lang.Long">
    select
    count(*)
    from se_client mtb
    <where>
      <if test="name != null and name != ''">
        mtb.name like concat('%', #{name}, '%')
      </if>
    </where>
  </select>

  <select id="selectDayStatistics" resultType="com.dy.pipIrrGlobal.voSt.VoStClientAmountDay">
    select
    mtb.clientNum as clientNum,
    mtb.phone as clientPhone,
    mtb.address as clientAddress,
    <include refid="Base_Column_List_with_alias" >
      <property name="alias" value="mtb"/>
    </include>
    from se_client mtb
    LEFT JOIN st_client_amount_day stTb on stTb.client_id = mtb.id
    <where>
      <if test = "year != null">
        stTb.year = #{year, jdbcType=INTEGER}
      </if>
      <if test = "month != null">
        AND stTb.month = #{month, jdbcType=INTEGER}
      </if>
      <if test="name != null and name != ''">
        AND mtb.name like concat('%', #{name}, '%')
      </if>
    </where>
    order by mtb.id ASC
    <trim prefix="limit " >
      <if test="start != null and count != null">
        #{start,javaType=Integer,jdbcType=INTEGER}, #{count,javaType=Integer,jdbcType=INTEGER}
      </if>
    </trim>
  </select>

  <!-- ////////////////////////////////// -->
  <!-- ç»Ÿè®¡ç›¸å…³                         -->
  <!-- ////////////////////////////////// -->
  <select id="statisticsByClient" resultType="com.dy.pipIrrGlobal.voSt.VoClientAmountStatistics">

 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/stClient/StClientCtrl.java

New file
@@ -0,0 +1,57 @@
package com.dy.pipIrrStatistics.stClient;

import com.dy.common.aop.SsoAop;
import com.dy.common.util.DateTime;
import com.dy.common.webUtil.BaseResponse;
import com.dy.common.webUtil.BaseResponseUtils;
import com.dy.common.webUtil.QueryResultVo;
import com.dy.pipIrrGlobal.voSt.VoDayIntakeAmount;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * @Author: liurunyu
 * @Date: 2024/12/30 15:22
 * @Description
 */

@Slf4j
@RestController
@RequestMapping(path="stClient")
@RequiredArgsConstructor
public class StClientCtrl {

    private StClientSv sv ;

    @Autowired
    private void setSv(StClientSv sv){
        this.sv = sv ;
    }


    /**
     * æŸ¥è¯¢æŒ‡å®šå¹´æœˆå†œæˆ·å„日用水量
     * @param qo
     * @return
     */
    @GetMapping(path = "/amountOfDay")
    @SsoAop()
    public BaseResponse<QueryResultVo<List<VoDayIntakeAmount>>> amountOfDay(StClientQo qo) throws Exception {
        String yearMonth = qo.getYearMonth();
        if(yearMonth == null || yearMonth.trim().equals("")) {
            return BaseResponseUtils.buildErrorMsg("查询条件年月不能为空");
        }

        int[] ymd = DateTime.yyyy_MM_ymdGroup(yearMonth) ;
        qo.year = ymd[0] ;
        qo.month = ymd[1] ;

        return BaseResponseUtils.buildSuccess(this.sv.selectStClientAmountDay(qo));
    }
}

 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/stClient/StClientQo.java

New file
@@ -0,0 +1,34 @@
package com.dy.pipIrrStatistics.stClient;

import com.dy.common.webUtil.QueryConditionVo;
import lombok.Data;
import lombok.EqualsAndHashCode;

/**
 * @Author: liurunyu
 * @Date: 2025/1/3 11:12
 * @Description
 */
@Data
@EqualsAndHashCode(callSuper = false)
public class StClientQo extends QueryConditionVo {

    /**
     * ç»Ÿè®¡å¹´æœˆ
     */
    public String yearMonth;
    /**
     * å¹´
     */
    public Integer year;

    /**
     * æœˆ
     */
    public Integer month;

    /**
     * å–水口编号
     */
    public String clientName;
}

 pipIrr-platform/pipIrr-web/pipIrr-web-statistics/src/main/java/com/dy/pipIrrStatistics/stClient/StClientSv.java

New file
@@ -0,0 +1,60 @@
package com.dy.pipIrrStatistics.stClient;

import com.dy.common.webUtil.QueryResultVo;
import com.dy.pipIrrGlobal.daoSt.StClientAmountDayMapper ;
import com.dy.pipIrrGlobal.daoSt.StClientAmountMonthMapper ;
import com.dy.pipIrrGlobal.daoSt.StClientAmountYearMapper ;
import com.dy.pipIrrGlobal.voSt.VoStClientAmountDay;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.common.utils.PojoUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.text.ParseException;
import java.util.List;
import java.util.Map;

/**
 * @Author: liurunyu
 * @Date: 2024/12/30 15:22
 * @Description
 */

@Slf4j
@Service
public class StClientSv {

    private StClientAmountDayMapper stClientAmountDayDao ;
    private StClientAmountMonthMapper stClientAmountMonthDao ;
    private StClientAmountYearMapper stClientAmountYearDao ;
    @Autowired
    private void setDao(StClientAmountDayMapper dao){
        this.stClientAmountDayDao = dao ;
    }
    @Autowired
    private void setDao(StClientAmountMonthMapper dao){
        this.stClientAmountMonthDao = dao ;
    }
    @Autowired
    private void setDao(StClientAmountYearMapper dao){
        this.stClientAmountYearDao = dao ;
    }


    public QueryResultVo<List<VoStClientAmountDay>> selectStClientAmountDay(StClientQo qo) throws ParseException {
        QueryResultVo<List<VoStClientAmountDay>> rsVo = new QueryResultVo<>() ;
        // ç”ŸæˆæŸ¥è¯¢å‚æ•°
        Map<String, Object> params = (Map<String, Object>) PojoUtils.generalize(qo) ;
        // èŽ·å–符合条件的记录数
        Long itemTotal = stClientAmountDayDao.selectCountDayStatistics(params) ;

        if(itemTotal != null && itemTotal > 0) {
            rsVo.pageSize = qo.pageSize;
            rsVo.pageCurr = qo.pageCurr;
            rsVo.calculateAndSet(itemTotal, params);

            rsVo.obj = stClientAmountDayDao.selectDayStatistics(params);
        }
        return rsVo ;
    }
}

 pipIrr-platform/Îĵµ/SaaS/¹Ü¹àϵͳÔö¼ÓÒ»¸ö¿Í»§·½·¨.docx

Binary files differ

 pipIrr-platform/Îĵµ/SaaS/¾ÆȪְҵ¼¼ÊõѧԺÉ豸ÅäÖÃ.docx

Binary files differ