2023-12-21 增加反审核，修改采集单bug，

lzbi-admin/src/main/resources/application-dev.yml

@@ -79,6 +79,9 @@ spring:
           url: jdbc:mysql://10.10.10.56:13306/lzdc_bi_db?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&rewriteBatchedStatements=true
           username: luenmei
           password: 123456
+          #url: jdbc:mysql://localhost:3306/lmlz_dcdb?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8&rewriteBatchedStatements=true
+          #username: root
+          #password: root123456
 #        # 计费数据库
 #        charge:
 #          driverClassName: oracle.jdbc.OracleDriver
@@ -93,7 +96,7 @@ spring:
           password: 123456
         workDB:
           driverClassName: org.postgresql.Driver
-          #type: com.alibaba.druid.pool.DruidDataSource
+          type: com.alibaba.druid.pool.DruidDataSource
           url: jdbc:postgresql://10.10.10.56:5432/dctestdb?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=Asia/Shanghai
           username: postgres
           password: 123456

lzbi-module/src/main/java/com/lzbi/draft/controller/DcBusiParamBillMasterController.java

@@ -1,15 +1,24 @@
 package com.lzbi.draft.controller;
 
+import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
 
+import cn.hutool.core.date.DatePattern;
+import cn.hutool.core.date.DateUtil;
+import com.alibaba.fastjson2.JSONObject;
 import com.lzbi.common.utils.DateUtils;
 import com.lzbi.common.utils.SecurityUtils;
+import com.lzbi.common.utils.StringUtils;
 import com.lzbi.draft.domain.DcBusiParamBillSub;
+
 import com.lzbi.draft.service.DcBusiParamBillSubService;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
-import org.springframework.security.access.prepost.PreAuthorize;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.GetMapping;
 
@@ -64,6 +73,41 @@ public class DcBusiParamBillMasterController extends BaseController
         List<DcBusiParamBillSub> list = dcBusiParamBillSubService.selectByVo(sub);
         return AjaxResult.success(list);
     }
+    @ApiOperation("参数采集单主从详情")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "billNo", value = "", dataType = "String", dataTypeClass = String.class),
+    })
+    @GetMapping("/info/{billNo}")
+    public AjaxResult getParamInBillInfo(@PathVariable String billNo){
+        DcBusiParamBillMaster master = dcBusiParamBillMasterService.selectDcBusiParamBillMasterDaoByNo(billNo);
+        Map<String, List<DcBusiParamBillSub>> map = master.getDcBusiParamBillSubList().stream().collect(Collectors.groupingBy(DcBusiParamBillSub::getCountHourString));
+        master.setCountTimes(map.keySet().stream().collect(Collectors.joining(",")));
+        master.setCountDate(master.getBillIncomeDate());
+        Map<String, JSONObject> mapRow=new HashMap<>();
+        map.keySet().stream().forEach(key->{
+            List<DcBusiParamBillSub> sub=map.get(key);
+            sub.forEach(subItem->{
+                JSONObject jsb=mapRow.get(subItem.getAssetCode()+subItem.getParamCode());
+                if(StringUtils.isNull(jsb)){
+                    jsb=new JSONObject();
+                    jsb.put("assetName",subItem.getAssetName());
+                    jsb.put("assetCode",subItem.getAssetCode());
+                    jsb.put("paramCode",subItem.getParamCode());
+                    jsb.put("paramName",subItem.getParamName());
+                    jsb.put("paramUint",subItem.getParamUint());
+                    jsb.put("val_"+key,subItem.getParamValue());
+                    mapRow.put(subItem.getAssetCode()+subItem.getParamCode(),jsb);
+                    master.setFieldCode(subItem.getFieldCode());
+                    master.setFieldName(subItem.getFieldName());
+                }else{
+                    jsb.put("val_"+key,subItem.getParamValue());
+                }
+            });
+        });
+
+        master.setSubRecord(mapRow.values().stream().collect(Collectors.toList()));
+        return AjaxResult.success(master);
+    }
     @ApiOperation("采集单驳回")
     @ApiImplicitParams({
             @ApiImplicitParam(name = "billNo", value = "", dataType = "String", dataTypeClass = String.class),
@@ -88,7 +132,20 @@ public class DcBusiParamBillMasterController extends BaseController
         master.setUpdatedBy(SecurityUtils.getUsername());
         master.setCreatedTime(DateUtils.getNowDate());
         master.setBillNo(billNo);
-        master.setCheckStatus("1");
+        master.setCheckStatus("2");
+        return AjaxResult.success(dcBusiParamBillMasterService.checkBill(master));
+    }
+    @ApiOperation("采集单反审核")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "billNo", value = "", dataType = "String", dataTypeClass = String.class),
+    })
+    @GetMapping("/checkRevert/{billNo}")
+    public AjaxResult checkParamInBillRevert(@PathVariable String billNo){
+        DcBusiParamBillMaster master=new DcBusiParamBillMaster();
+        master.setUpdatedBy(SecurityUtils.getUsername());
+        master.setCreatedTime(DateUtils.getNowDate());
+        master.setBillNo(billNo);
+        master.setCheckStatus("0");
         return AjaxResult.success(dcBusiParamBillMasterService.checkBill(master));
     }
 

lzbi-module/src/main/java/com/lzbi/draft/controller/DcBusiParamCollectBill.java

@@ -276,6 +276,51 @@ public class DcBusiParamCollectBill extends BaseController
         dcBusiParamBillMaster.setDcBusiParamBillSubList(dcBusiParamBillSubList);
         return AjaxResult.success(dcBusiParamBillMasterService.insertDcBusiParamBillMasterDao(dcBusiParamBillMaster));
     }
+    @ApiOperation("更新参数采集数据-subDatas数组方式")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "dcBusiParamBillMaster", value = "", dataType = "DcBusiParamBillMaster", dataTypeClass = DcBusiParamBillMaster.class),
+    })
+    @PostMapping("/updateBillCollectArray")
+    /*subDatas为动态数据列，值是分开的索要对每个列值进行处理*/
+    public AjaxResult updateBillCollectBy(@RequestBody  DcBusiParamBillMaster dcBusiParamBillMaster){
+        List<DcBusiParamBillSub> dcBusiParamBillSubList =new ArrayList<>();
+        dcBusiParamBillMaster.setUpdatedBy(SecurityUtils.getUsername());
+        JSONObject datasets=Optional.ofNullable(dcBusiParamBillMaster.getSubDatas()).orElse(new JSONObject());
+        JSONArray dataArray=new JSONArray();
+        dataArray.addAll(datasets.getJSONArray("insertRecords"));
+        //dataArray.addAll(datasets.getJSONArray("updateRecords"));
+       //dataArray.addAll(datasets.getJSONArray("removeRecords"));
+        String billNo=dcBusiParamBillMaster.getBillNo();
+        dataArray.forEach(item->{
+            JSONObject jsb = JSONObject.from(item);
+            for(int i=1;i<25;i++){
+                String fname="val_"+String.valueOf(i);
+                Double value=jsb.getDouble(fname);
+                if(StringUtils.isNotNull(value)){
+                    DcBusiParamBillSub dcBusiParamBillSub=new DcBusiParamBillSub();
+                    //基本数据
+                    dcBusiParamBillSub.setBillNo(billNo);
+                    dcBusiParamBillSub.setId(null);
+                    dcBusiParamBillSub.setParamCode(jsb.getString("paramCode"));
+                    dcBusiParamBillSub.setAssetCode(jsb.getString("assetCode"));
+                    dcBusiParamBillSub.setAssetName(jsb.getString("assetName"));
+                    //dcBusiParamBillSub.setCountDate(jsb.getString("countDate"));
+                    dcBusiParamBillSub.setCountDate(dcBusiParamBillMaster.getBillIncomeDate());
+                    dcBusiParamBillSub.setParamUint(jsb.getString("paramUint"));
+                    dcBusiParamBillSub.setParamName(jsb.getString("paramName"));
+                    dcBusiParamBillSub.setFieldCode(jsb.getString("fieldCode"));
+                    dcBusiParamBillSub.setFieldName(jsb.getString("fieldName"));
+                    dcBusiParamBillSub.setCountHour(i);
+                    dcBusiParamBillSub.setParamValue(value);
+                    dcBusiParamBillSubList.add(dcBusiParamBillSub);
+                }
+            }
+
+
+        });
+        dcBusiParamBillMaster.setDcBusiParamBillSubList(dcBusiParamBillSubList);
+        return AjaxResult.success(dcBusiParamBillMasterService.updateDcBusiParamBillMasterDao(dcBusiParamBillMaster));
+    }
     private String getBillModelNo(){
         DcBusiCoderuleConfigDao ruleIdByBusicode =Optional.ofNullable(dcBaseCoderuleDefineService.getRuleIdByBusicode("BILL_MODEL_NO")).orElse(new DcBusiCoderuleConfigDao()) ;
 

lzbi-module/src/main/java/com/lzbi/draft/domain/DcBusiParamBillMaster.java

@@ -84,7 +84,7 @@ public class DcBusiParamBillMaster extends BaseModuleEntity
     private List<DcBusiParamBillSub> dcBusiParamBillSubList;
     @ApiModelProperty(name = "data数组数据未转换",notes = "")
     private JSONObject subDatas;
-
+    private List<JSONObject> subRecord;
 
 
 }

lzbi-module/src/main/java/com/lzbi/draft/domain/DcBusiParamBillSub.java

@@ -1,6 +1,7 @@
 package com.lzbi.draft.domain;
 
 import com.baomidou.mybatisplus.annotation.IdType;
+import com.lzbi.common.utils.StringUtils;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import com.baomidou.mybatisplus.annotation.TableName;
@@ -52,6 +53,9 @@ public class DcBusiParamBillSub extends BaseModuleEntity{
     /** 指标编码 */
     @ApiModelProperty(name = "指标编码",notes = "")
     private String paramCode ;
+    /** 指标编码 */
+    @ApiModelProperty(name = "指标别名",notes = "")
+    private String assetAlialsName ;
     /** 指标单位 */
     @ApiModelProperty(name = "指标单位",notes = "")
     private String paramUint ;
@@ -76,4 +80,10 @@ public class DcBusiParamBillSub extends BaseModuleEntity{
     public String getFieldCode(){
         return Optional.ofNullable(this.fieldCode).orElse("");
     }
+    public String getCountHourString(){
+        return String.valueOf(countHour);
+    }
+    public String getCountHourStringPad(){
+        return StringUtils.leftPad(getCountHourString(),2,'0');
+    }
 }

lzbi-module/src/main/java/com/lzbi/draft/mapper/DcBusiParamBillMasterMapper.java

@@ -22,6 +22,7 @@ public interface DcBusiParamBillMasterMapper extends BaseMapper<DcBusiParamBillM
      * @return 参数采集（录入）单据主
      */
     public DcBusiParamBillMaster selectDcBusiParamBillMasterDaoById(Long id);
+    public DcBusiParamBillMaster selectDcBusiParamBillMasterDaoByNo(String billNo);
 
     /**
      * 查询参数采集（录入）单据主列表

lzbi-module/src/main/java/com/lzbi/draft/service/DcBusiParamBillMasterService.java

@@ -32,7 +32,10 @@ public class DcBusiParamBillMasterService extends ServiceImpl<DcBusiParamBillMas
     {
         return baseMapper.selectDcBusiParamBillMasterDaoById(id);
     }
-
+    public DcBusiParamBillMaster selectDcBusiParamBillMasterDaoByNo(String billNo)
+    {
+        return baseMapper.selectDcBusiParamBillMasterDaoByNo(billNo);
+    }
     /**
      * 查询参数采集（录入）单据主列表
      * 

lzbi-module/src/main/resources/mapper/asset/DcBusiParamBillMasterMapper.xml

@@ -47,6 +47,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         <result property="countDate"    column="sub_count_date"    />
         <result property="countHour"    column="sub_count_hour"    />
         <result property="paramCode"    column="sub_param_code"    />
+        <result property="paramName"    column="sub_param_name"    />
         <result property="paramUint"    column="sub_param_uint"    />
         <result property="paramValue"    column="sub_param_value"    />
     </resultMap>
@@ -73,13 +74,20 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     </select>
     
     <select id="selectDcBusiParamBillMasterDaoById" parameterType="Long" resultMap="DcBusiParamBillMasterDcBusiParamBillSubResult">
-        select a.TENANT_ID, a.REVISION, a.CREATED_BY, a.CREATED_TIME, a.UPDATED_BY, a.UPDATED_TIME, a.DELETE_BY, a.DELETE_TIME, a.id, a.bill_no, a.bill_income_date, a.bill_type, a.check_type, a.check_status,
-               b.TENANT_ID as sub_TENANT_ID, b.CREATED_BY as sub_CREATED_BY, b.CREATED_TIME as sub_CREATED_TIME, b.UPDATED_BY as sub_UPDATED_BY, b.UPDATED_TIME as sub_UPDATED_TIME, b.DELETE_BY as sub_DELETE_BY, b.DELETE_TIME as sub_DELETE_TIME, b.id as sub_id, b.bill_no as sub_bill_no,b.asset_code as sub_asset_code,b.asset_name as sub_asset_name, b.field_code as sub_field_code, b.field_name as sub_field_name, b.param_code as sub_param_code, b.param_value as sub_param_value, b.count_date as sub_count_date, b.count_hour as sub_count_hour
+        select a.TENANT_ID, a.REVISION, a.CREATED_BY, a.CREATED_TIME, a.UPDATED_BY, a.UPDATED_TIME, a.DELETE_BY, a.DELETE_TIME, a.id, a.bill_no, a.bill_income_date, a.bill_type, a.check_type, a.check_status,a.company_id,a.company_name,a.organize_name,a.oragnize_id,
+            b.TENANT_ID as sub_TENANT_ID, b.CREATED_BY as sub_CREATED_BY, b.CREATED_TIME as sub_CREATED_TIME, b.UPDATED_BY as sub_UPDATED_BY, b.UPDATED_TIME as sub_UPDATED_TIME, b.DELETE_BY as sub_DELETE_BY, b.DELETE_TIME as sub_DELETE_TIME, b.id as sub_id, b.bill_no as sub_bill_no,b.asset_code as sub_asset_code,b.asset_name as sub_asset_name, b.field_code as sub_field_code, b.field_name as sub_field_name, b.param_code as sub_param_code,b.param_name as sub_param_name, b.param_value as sub_param_value, b.count_date as sub_count_date, b.count_hour as sub_count_hour, b.param_uint as sub_param_uint
         from dc_busi_param_bill_master a
                  left join dc_busi_param_bill_sub b on b.bill_no = a.bill_no
         where a.id = #{id}
     </select>
-        
+    <select id="selectDcBusiParamBillMasterDaoByNo" parameterType="String" resultMap="DcBusiParamBillMasterDcBusiParamBillSubResult">
+        select a.TENANT_ID, a.REVISION, a.CREATED_BY, a.CREATED_TIME, a.UPDATED_BY, a.UPDATED_TIME, a.DELETE_BY, a.DELETE_TIME, a.id, a.bill_no, a.bill_income_date, a.bill_type, a.check_type, a.check_status,a.company_id,a.company_name,a.organize_name,a.oragnize_id,
+               b.TENANT_ID as sub_TENANT_ID, b.CREATED_BY as sub_CREATED_BY, b.CREATED_TIME as sub_CREATED_TIME, b.UPDATED_BY as sub_UPDATED_BY, b.UPDATED_TIME as sub_UPDATED_TIME, b.DELETE_BY as sub_DELETE_BY, b.DELETE_TIME as sub_DELETE_TIME, b.id as sub_id, b.bill_no as sub_bill_no,b.asset_code as sub_asset_code,b.asset_name as sub_asset_name, b.field_code as sub_field_code, b.field_name as sub_field_name, b.param_code as sub_param_code,b.param_name as sub_param_name, b.param_value as sub_param_value, b.count_date as sub_count_date, b.count_hour as sub_count_hour, b.param_uint as sub_param_uint
+        from dc_busi_param_bill_master a
+                 left join dc_busi_param_bill_sub b on b.bill_no = a.bill_no
+        where a.bill_no = #{billNo}
+    </select>
+
     <insert id="insertDcBusiParamBillMasterDao" parameterType="DcBusiParamBillMaster" useGeneratedKeys="true" keyProperty="id">
         insert into dc_busi_param_bill_master
         <trim prefix="(" suffix=")" suffixOverrides=",">
@@ -138,6 +146,10 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="billType != null">bill_type = #{billType},</if>
             <if test="checkType != null">check_type = #{checkType},</if>
             <if test="checkStatus != null">check_status = #{checkStatus},</if>
+            <if test="companyId != null">company_id=#{companyId},</if>
+            <if test="companyName != null">company_name=#{companyName},</if>
+            <if test="organizeName != null">organize_name=#{organizeName},</if>
+            <if test="oragnizeId != null">oragnize_id=#{oragnizeId},</if>
         </trim>
         where id = #{id}
     </update>
@@ -156,6 +168,10 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
             <if test="billType != null">bill_type = #{billType},</if>
             <if test="checkType != null">check_type = #{checkType},</if>
             <if test="checkStatus != null">check_status = #{checkStatus},</if>
+            <if test="companyId != null">company_id=#{companyId},</if>
+            <if test="companyName != null">company_name=#{companyName},</if>
+            <if test="organizeName != null">organize_name=#{organizeName},</if>
+            <if test="oragnizeId != null">oragnize_id=#{oragnizeId},</if>
         </trim>
         where bill_no = #{billNo}
     </update>
@@ -182,9 +198,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     </delete>
 
     <insert id="batchDcBusiParamBillSubDao">
-        insert into dc_busi_param_bill_sub( TENANT_ID, CREATED_BY, CREATED_TIME, UPDATED_BY, UPDATED_TIME, DELETE_BY, DELETE_TIME, id, bill_no,  asset_code,asset_name, field_code, field_name, param_code, param_value,count_date,count_hour,param_name) values
+        insert into dc_busi_param_bill_sub( TENANT_ID, CREATED_BY, CREATED_TIME, UPDATED_BY, UPDATED_TIME, DELETE_BY, DELETE_TIME, id, bill_no,  asset_code,asset_name, field_code, field_name, param_code, param_value,count_date,count_hour,param_name,param_uint) values
 		<foreach item="item" index="index" collection="list" separator=",">
-            ( #{item.tenantId}, #{item.createdBy}, #{item.createdTime}, #{item.updatedBy}, #{item.updatedTime}, #{item.deleteBy}, #{item.deleteTime}, #{item.id}, #{item.billNo},  #{item.assetCode},  #{item.assetName}, #{item.fieldCode}, #{item.fieldName},#{item.paramCode},  #{item.paramValue}, #{item.countDate},  #{item.countHour},#{item.paramName})
+            ( #{item.tenantId}, #{item.createdBy}, #{item.createdTime}, #{item.updatedBy}, #{item.updatedTime}, #{item.deleteBy}, #{item.deleteTime}, #{item.id}, #{item.billNo},  #{item.assetCode},  #{item.assetName}, #{item.fieldCode}, #{item.fieldName},#{item.paramCode},  #{item.paramValue}, #{item.countDate},  #{item.countHour},#{item.paramName},#{item.paramUint})
         </foreach>
     </insert>
 </mapper>