Merge remote-tracking branch 'origin/develop_tzs_register' into develop_tzs_register

amos-boot-system-tzs/amos-boot-module-app/amos-boot-module-app-biz/src/main/java/com/yeejoin/amos/boot/module/app/biz/service/impl/CertDetailServiceImpl.java

@@ -32,7 +32,7 @@ public class CertDetailServiceImpl {
         String version = this.deCodeByAES(requestParam.getVersion());
         String certType = this.deCodeByBase64(requestParam.getCertType());
         JgUseRegistrationManageDto jgUseRegistrationManage = this.checkParam(certOrApplyNo, version);
-        return SearchDetailStrategyContext.getHandler(this.getManageType(jgUseRegistrationManage)).hanlder(jgUseRegistrationManage, certType);
+        return SearchDetailStrategyContext.getHandler(this.getManageType(jgUseRegistrationManage)).handler(jgUseRegistrationManage, certType);
     }
 
     private String deCodeByBase64(String certType) {

amos-boot-system-tzs/amos-boot-module-app/amos-boot-module-app-biz/src/main/java/com/yeejoin/amos/boot/module/app/biz/service/impl/SetSearchDetailDetailHandlerImpl.java

 package com.yeejoin.amos.boot.module.app.biz.service.impl;
 
 import com.yeejoin.amos.boot.biz.common.dto.JgUseRegistrationManageDto;
+import com.yeejoin.amos.boot.module.app.api.exception.AuthException;
 import com.yeejoin.amos.boot.module.app.biz.strategy.ISearchDetailHandler;
 import org.springframework.stereotype.Component;
 
@@ -15,7 +16,8 @@ public class SetSearchDetailDetailHandlerImpl implements ISearchDetailHandler {
     }
 
     @Override
-    public Map<String, Object> hanlder(JgUseRegistrationManageDto manageDto, String from) {
-        return Collections.emptyMap();
+    public Map<String, Object> handler(JgUseRegistrationManageDto manageDto, String from) {
+        throw new AuthException("该设备种类暂不支持扫码，敬请期待！");
+//        return Collections.emptyMap();
     }
 }

amos-boot-system-tzs/amos-boot-module-app/amos-boot-module-app-biz/src/main/java/com/yeejoin/amos/boot/module/app/biz/service/impl/UnitSearchDetailDetailHandlerImpl.java

 package com.yeejoin.amos.boot.module.app.biz.service.impl;
 
 import com.yeejoin.amos.boot.biz.common.dto.JgUseRegistrationManageDto;
+import com.yeejoin.amos.boot.module.app.api.exception.AuthException;
 import com.yeejoin.amos.boot.module.app.biz.strategy.ISearchDetailHandler;
 import org.springframework.stereotype.Component;
 
@@ -15,8 +16,9 @@ public class UnitSearchDetailDetailHandlerImpl implements ISearchDetailHandler {
     }
 
     @Override
-    public Map<String, Object> hanlder(JgUseRegistrationManageDto manageDto, String from) {
-        return Collections.emptyMap();
+    public Map<String, Object> handler(JgUseRegistrationManageDto manageDto, String from) {
+        throw new AuthException("该设备种类暂不支持扫码，敬请期待！");
+//        return Collections.emptyMap();
     }
 
 }

amos-boot-system-tzs/amos-boot-module-app/amos-boot-module-app-biz/src/main/java/com/yeejoin/amos/boot/module/app/biz/service/impl/VehicleSearchDetailDetailHandlerImpl.java

@@ -40,7 +40,7 @@ public class VehicleSearchDetailDetailHandlerImpl implements ISearchDetailHandle
     }
 
     @Override
-    public Map<String, Object> hanlder(JgUseRegistrationManageDto manageDto, String certType) {
+    public Map<String, Object> handler(JgUseRegistrationManageDto manageDto, String certType) {
         return this.getQueryCarCylinderInfo(manageDto);
     }
 

amos-boot-system-tzs/amos-boot-module-app/amos-boot-module-app-biz/src/main/java/com/yeejoin/amos/boot/module/app/biz/strategy/ISearchDetailHandler.java

@@ -18,7 +18,7 @@ public interface ISearchDetailHandler {
      * @param from 来源
      * @return T
      */
-    Map<String, Object> hanlder(JgUseRegistrationManageDto manageDto, String from);
+    Map<String, Object> handler(JgUseRegistrationManageDto manageDto, String from);
 
     String defaultVersion = "1";
 }

amos-boot-system-tzs/amos-boot-module-cylinder/amos-boot-module-cylinder-api/src/main/resources/mapper/CylinderInfoMapper.xml

@@ -622,8 +622,9 @@
             tz_base_enterprise_info i
         WHERE
             i.app_id = f.app_id
-          AND	f.filling_endtime >= concat(#{startTime}, ' 00:00:00')
+          AND f.filling_endtime >= concat(#{startTime}, ' 00:00:00')
           AND i.org_code like concat(#{orgCode}, '%')
+          AND i.unit_type like '%充装单位%'
         GROUP BY
             filling_time
         ORDER BY

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/dto/JgUseRegistrationDto.java

@@ -60,6 +60,15 @@ public class JgUseRegistrationDto extends BaseDto {
     @ApiModelProperty(value = "终审通过时间")
     private Date auditPassDate;
 
+    @ApiModelProperty(value = "办理日期范围")
+    private String auditPassDateRange;
+
+    @ApiModelProperty(value = "办理日期起始日期")
+    private Date auditPassDateStart;
+
+    @ApiModelProperty(value = "办理日期结束日期")
+    private Date auditPassDateEnd;
+
     @ApiModelProperty(value = "登记类别")
     private String regType;
 

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/mapper/JgUseRegistrationMapper.java

@@ -31,7 +31,7 @@ public interface JgUseRegistrationMapper extends BaseMapper<JgUseRegistration> {
                                           @Param("dto") JgUseRegistrationDto dto,
                                           @Param("roleIds") List<String> roleIds);
 
-    List<RegistrationVo> queryRegistrationInIds(@Param("ids") List<String> ids);
+    List<RegistrationVo> queryRegistrationInIds(@Param("dto") JgUseRegistrationDto dto);
 
     Map<String, Object> getDetail(@Param("id") String id);
 

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/java/com/yeejoin/amos/boot/module/jg/api/vo/tableDataExportVo/RegistrationVo.java

@@ -14,49 +14,52 @@ public class RegistrationVo {
     
     @ExcelProperty(value = "申请日期", index = 1)
     String createDate;
+
+    @ExcelProperty(value = "登记证来源", index = 2)
+    String regType;
     
-    @ExcelProperty(value = "设备种类", index = 2)
+    @ExcelProperty(value = "设备种类", index = 3)
     String equListName;
     
-    @ExcelProperty(value = "设备类别", index = 3)
+    @ExcelProperty(value = "设备类别", index = 4)
     String equCategory;
     
-    @ExcelProperty(value = "设备品种", index = 4)
+    @ExcelProperty(value = "设备品种", index = 5)
     String equDefine;
     
-    @ExcelProperty(value = "设备代码", index = 5)
+    @ExcelProperty(value = "设备代码", index = 6)
     String equCode;
     
-    @ExcelProperty(value = "使用登记证编号", index = 6)
+    @ExcelProperty(value = "使用登记证编号", index = 7)
     String useRegistrationCode;
     
-    @ExcelProperty(value = "96333识别码", index = 7)
+    @ExcelProperty(value = "96333识别码", index = 8)
     String code96333;
     
-    @ExcelProperty(value = "监管码", index = 8)
+    @ExcelProperty(value = "监管码", index = 9)
     String supervisoryCode;
     
-    @ExcelProperty(value = "设备地址", index = 9)
+    @ExcelProperty(value = "设备地址", index = 10)
     String fullAddress;
     
-    @ExcelProperty(value = "详细地址", index = 10)
+    @ExcelProperty(value = "详细地址", index = 11)
     String detailedAddress;
     
-    @ExcelProperty(value = "使用单位", index = 11)
+    @ExcelProperty(value = "使用单位", index = 12)
     String useUnitName;
     
-    @ExcelProperty(value = "接收机构", index = 12)
+    @ExcelProperty(value = "接收机构", index = 13)
     String receiveOrgName;
     
-    @ExcelProperty(value = "属地监管部门", index = 13)
+    @ExcelProperty(value = "属地监管部门", index = 14)
     String orgBranchName;
     
-    @ExcelProperty(value = "作废原因", index = 14)
+    @ExcelProperty(value = "作废原因", index = 15)
     String cancelReason;
     
-    @ExcelProperty(value = "办理状态", index = 15)
+    @ExcelProperty(value = "办理状态", index = 16)
     String status;
     
-    @ExcelProperty(value = "办理日期", index = 16)
+    @ExcelProperty(value = "办理日期", index = 17)
     String auditPassDate;
 }

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-api/src/main/resources/mapper/JgUseRegistrationMapper.xml

@@ -182,6 +182,9 @@
             <if test="dto.useUnitCode != null and dto.useUnitCode != ''">
                 and use_unit_credit_code = #{dto.useUnitCode}
             </if>
+            <if test="dto.auditPassDateStart != null and dto.auditPassDateEnd != null">
+                AND auditPassDate BETWEEN #{dto.auditPassDateStart} AND #{dto.auditPassDateEnd}
+            </if>
             <if test="dto.dataType == 'supervision' ">
                 AND (receive_company_code = #{dto.receiveCompanyCode} or transfer_to_user_ids LIKE concat ('%',
                 #{dto.currentUserId}, '%'))
@@ -203,19 +206,73 @@
     </select>
 
     <select id="queryRegistrationInIds" resultType="com.yeejoin.amos.boot.module.jg.api.vo.tableDataExportVo.RegistrationVo">
-        <include refid="page-list"/>
+        select
+        *
+        from
+        (
+        <include refid="page-list-sub-select"/>
+        )
+
         <where>
-            <if test='ids != null'>
-                and ur.sequence_nbr in
-                <foreach collection="ids" item="id" open="(" close=")" separator=",">
-                    #{id}
-                </foreach>
+            is_delete = 0
+            <if test="dto.equList != null and dto.equList != ''">
+                and equListCode= #{dto.equList}
+            </if>
+            <if test="dto.equCategory != null and dto.equCategory != ''">
+                and equCategoryCode = #{dto.equCategory}
+            </if>
+            <if test="dto.equDefine != null and dto.equDefine != ''">
+                and equDefineCode = #{dto.equDefine}
+            </if>
+            <if test="dto.status != null and dto.status != ''">
+                and status = #{dto.status}
+            </if>
+            <if test="dto.applicationDate != null">
+                and create_date like concat('%',DATE_FORMAT(#{dto.applicationDate},'%Y-%m-%d'),'%')
+            </if>
+            <if test="dto.equCode != null and dto.equCode != ''">
+                and equCode like concat('%',#{dto.equCode},'%')
+            </if>
+            <if test="dto.code96333 != null and dto.code96333 != ''">
+                and code96333 like concat('%',#{dto.code96333},'%')
+            </if>
+            <if test="dto.supervisoryCode != null and dto.supervisoryCode != ''">
+                and supervisoryCode like concat('%',#{dto.supervisoryCode},'%')
+            </if>
+            <if test="dto.fullAddress != null and dto.fullAddress != ''">
+                AND fullAddress LIKE CONCAT('%', #{dto.fullAddress}, '%')
+            </if>
+            <if test="dto.receiveCompanyCode != null and dto.receiveCompanyCode != ''">
+                AND receive_company_code = #{dto.receiveCompanyCode}
+            </if>
+            <if test="dto.useUnitName != null and dto.useUnitName != ''">
+                and useUnitName like concat('%',#{dto.useUnitName},'%')
+            </if>
+            <if test="dto.applyNo != null and dto.applyNo != ''">
+                and applyNo like concat('%',#{dto.applyNo},'%')
+            </if>
+            <if test="dto.useRegistrationCode != null and dto.useRegistrationCode != ''">
+                and useRegistrationCode like concat('%',#{dto.useRegistrationCode},'%')
+            </if>
+            <if test="dto.useUnitCode != null and dto.useUnitCode != ''">
+                and use_unit_credit_code = #{dto.useUnitCode}
+            </if>
+            <if test="dto.auditPassDateStart != null and dto.auditPassDateEnd != null">
+                AND auditPassDate BETWEEN #{dto.auditPassDateStart} AND #{dto.auditPassDateEnd}
+            </if>
+            <if test="dto.dataType == 'supervision' ">
+                AND (receive_company_code = #{dto.receiveCompanyCode} or transfer_to_user_ids LIKE concat ('%',
+                #{dto.currentUserId}, '%'))
+                AND status  <![CDATA[<>]]>  '使用单位待提交'
+            </if>
+            <if test="dto.dataType == 'company' ">
+                AND (use_unit_credit_code = #{dto.unitCode} or transfer_to_user_ids LIKE concat ('%',#{dto.currentUserId}, '%'))
             </if>
         </where>
-        GROUP BY
-        re.equip_transfer_id
+--         GROUP BY
+--         re.equip_transfer_id
         order by
-        ur.create_date DESC, ur.apply_no DESC
+        create_date DESC, applyNo DESC
     </select>
 
     <select id="getDetail" resultType="java.util.Map">

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/controller/JgTableDataExportController.java

 package com.yeejoin.amos.boot.module.jg.biz.controller;
 
 
+import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
+import com.yeejoin.amos.boot.module.jg.api.dto.JgUseRegistrationDto;
+import com.yeejoin.amos.boot.module.jg.api.enums.CompanyTypeEnum;
 import com.yeejoin.amos.boot.module.jg.biz.service.IJgTableDataExportService;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
@@ -91,9 +94,18 @@ public class JgTableDataExportController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @GetMapping(value = "/registration")
     @ApiOperation(httpMethod = "GET", value = "使用登记列表数据导出", notes = "使用登记列表数据导出")
-    public void registrationExport(HttpServletResponse response, String ids) {
-        Assert.hasText(ids,"未选择导出数据");
-        iJgTableDataExportService.registration(response, Arrays.asList(ids.split(",")));
+    public void registrationExport(HttpServletResponse response, JgUseRegistrationDto dto) {
+        ReginParams info = getSelectedOrgInfo();
+        dto.setCurrentUserId(info.getUserModel().getUserId());
+        if (info.getCompany().getLevel().equals(BaseController.COMPANY_TYPE_COMPANY)) {
+            dto.setDataType(BaseController.COMPANY_TYPE_COMPANY);
+            dto.setUnitCode(CompanyTypeEnum.INDIVIDUAL.getName().equals(info.getCompany().getCompanyType()) ?
+                    info.getCompany().getCompanyCode().split("_")[1] : info.getCompany().getCompanyCode());
+        } else {
+            dto.setDataType(BaseController.COMPANY_TYPE_SUPERVISION);
+            dto.setReceiveCompanyCode(info.getCompany().getCompanyCode());
+        }
+        iJgTableDataExportService.registration(response, dto);
     }
 
     @TycloudOperation(ApiLevel = UserType.AGENCY)

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/controller/JgUseRegistrationController.java

@@ -27,6 +27,8 @@ import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
 import javax.servlet.http.HttpServletResponse;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
 import java.util.*;
 
 /**
@@ -111,6 +113,26 @@ public class JgUseRegistrationController extends BaseController {
             dto.setDataType(BaseController.COMPANY_TYPE_SUPERVISION);
             dto.setReceiveCompanyCode(info.getCompany().getCompanyCode());
         }
+        if (dto.getAuditPassDateRange() != null && !dto.getAuditPassDateRange().isEmpty() && !dto.getAuditPassDateRange().equals("[, ]")) {
+            String dateRangeStr = dto.getAuditPassDateRange();
+            String[] dates = dateRangeStr.replace("[", "").replace("]", "").split(", ");
+
+            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+            Date start = null;
+            Date end = null;
+            try {
+                start = dateFormat.parse(dates[0]);
+                end = dateFormat.parse(dates[1]);
+            } catch (ParseException e) {
+                throw new RuntimeException(e);
+            }
+            Calendar calendar = Calendar.getInstance();
+            calendar.setTime(start);
+            calendar.add(Calendar.DAY_OF_MONTH, -1);
+            start = calendar.getTime();
+            dto.setAuditPassDateStart(start);
+            dto.setAuditPassDateEnd(end);
+        }
         Page<Map<String, Object>> list = jgUseRegistrationServiceImpl.getList(dto, sort, page, dto.getRoleIds());
         list.getRecords().forEach(x -> {
             x.put("companyType", info.getCompany().getCompanyType());
@@ -252,6 +274,7 @@ public class JgUseRegistrationController extends BaseController {
 
     /**
      * 使用登记流程错误数据处理
+     *
      * @param applyNo applyNo
      * @return s
      */
@@ -260,7 +283,7 @@ public class JgUseRegistrationController extends BaseController {
     @ApiOperation(httpMethod = "POST", value = "使用登记流程错误数据处理", notes = "使用登记流程错误数据处理")
     public ResponseModel<Object> handleErrorForm(@RequestParam("applyNo") String applyNo) {
         jgUseRegistrationServiceImpl.handleErrorForm(applyNo);
-        return ResponseHelper.buildResponse("申请单【"+applyNo+"】处理成功");
+        return ResponseHelper.buildResponse("申请单【" + applyNo + "】处理成功");
     }
 
 
@@ -271,12 +294,13 @@ public class JgUseRegistrationController extends BaseController {
     public ResponseModel<Object> saveHistoryEquip(@RequestBody JSONObject map) {
         JSONObject firstMap = JSONObject.parseObject(JSONObject.toJSONString(map.get("first")));
         JSONObject secondMap = JSONObject.parseObject(JSONObject.toJSONString(map.get("second")));
-        secondMap.put("type",firstMap.get("type"));
+        secondMap.put("type", firstMap.get("type"));
         return ResponseHelper.buildResponse(jgUseRegistrationServiceImpl.saveHistoryEquip(secondMap));
     }
 
     /**
      * 根据使用登记证查询工程装置名称
+     *
      * @param useRegistrationCode 使用登记证
      * @return projectContraption
      */
@@ -287,7 +311,7 @@ public class JgUseRegistrationController extends BaseController {
         ReginParams selectedOrgInfo = getSelectedOrgInfo();
         String companyCode = selectedOrgInfo.getCompany().getCompanyCode();
         String companyType = selectedOrgInfo.getCompany().getCompanyType();
-        String useUnitCreditCode = "个人主体".equals(companyType) && companyCode.contains("_")? companyCode.split("_", 2)[1]
+        String useUnitCreditCode = "个人主体".equals(companyType) && companyCode.contains("_") ? companyCode.split("_", 2)[1]
                 : companyCode;
         HashMap<String, Object> map = new HashMap<>();
         map.put("useRegistrationCode", useRegistrationCode);

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/IJgTableDataExportService.java

 package com.yeejoin.amos.boot.module.jg.biz.service;
 
 
+import com.yeejoin.amos.boot.module.jg.api.dto.JgUseRegistrationDto;
+
 import javax.servlet.http.HttpServletResponse;
 import java.util.List;
 
@@ -23,7 +25,7 @@ public interface IJgTableDataExportService {
 
     void transfer(HttpServletResponse response, List<String> ids);
 
-    void registration(HttpServletResponse response, List<String> ids);
+    void registration(HttpServletResponse response, JgUseRegistrationDto dto);
 
     void changeRegistrationUnit(HttpServletResponse response, List<String> ids);
 

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/IdxBizJgRegisterInfoServiceImpl.java

@@ -3012,9 +3012,7 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
             esEquipmentDto.setUSE_INNER_CODE(useInfo.getUseInnerCode());
             esEquipmentDto.setUSE_ORG_CODE(equipInfoDto.getUseOrgCode());
             esEquipmentDto.setIS_INTO_MANAGEMENT("his".equals(equipInfoDto.getDataSource()));
-            if ("his".equals(equipInfoDto.getDataSource())) {
-                esEquipmentDto.setEQU_CODE(registerInfo.getEquCode());
-            }
+            esEquipmentDto.setEQU_CODE(registerInfo.getEquCode());
             esEquipmentDto.setEQU_CATEGORY_CODE(equipInfoDto.getEquCategoryCode());
             esEquipmentDto.setEQU_CATEGORY(equipInfoDto.getEquCategory());
             esEquipmentDto.setEQU_LIST_CODE(equipInfoDto.getEquListCode());
@@ -3362,21 +3360,19 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
             checkNotBlank(data.getEquCodeType(), "是否有设备代码不能为空；", result);
             if ("1".equals(data.getEquCodeType())) {
                 checkNotBlank(data.getEquCode(), "设备代码不能为空；", result);
-                String equCode = data.getEquCode();
-                if (equCode.matches("[a-zA-Z0-9]+")) {
-                    if (equCode.length() <= 17) {
-                        result.append("设备代码不能小于17位；");
-                    }
-                    if (equCode.length() >= 20) {
-                        result.append("设备代码不能大于20位；");
-                    }
-                } else {
-                    result.append("设备代码不能包含特殊字符；");
-                }
-                if (equCodeList.contains(data.getEquCode())) {
-                    result.append("设备代码不能重复；");
-                }
-                this.checkEquCodeUniqueness(data.getEquCode(), result);
+                Optional.ofNullable(data.getEquCode())
+                        .ifPresent(equCode -> {
+                            if (!equCode.matches("[a-zA-Z0-9]+")) {
+                                result.append("设备代码不能包含特殊字符；");
+                            } else {
+                                Stream.of(equCode.length() <= 17 ? "设备代码不能小于17位；" : "",
+                                                equCode.length() >= 20 ? "设备代码不能大于20位；" : "",
+                                                equCodeList.contains(equCode) ? "设备代码不能重复；" : ""
+                                        ).filter(msg -> !msg.isEmpty())
+                                        .forEach(result::append);
+                                this.checkEquCodeUniqueness(equCode, result);
+                            }
+                        });
             } else {
                 data.setEquCode("");
             }
@@ -3389,9 +3385,6 @@ public class IdxBizJgRegisterInfoServiceImpl extends BaseService<IdxBizJgRegiste
             checkNotBlank(data.getProduceLicenseNum(), "制造许可编号不能为空；", result);
             checkNotBlank(data.getFactoryNum(), "出厂编号/产品编码不能为空；", result);
             if ("0".equals(data.getWhetherVehicleCylinder())) {
-                if (factoryNumList.contains(data.getFactoryNum())) {
-                    result.append("出厂编号/产品编码不能重复；");
-                }
                 checkNotBlank(data.getCylinderCategory(), "气瓶分类不能为空；", result);
                 checkFactoryNumUnique(data.getFactoryNum(), data.getProduceUnitCreditCode(), result);
             } else {

amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/service/impl/JgTableDataExportServiceImpl.java

@@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.yeejoin.amos.boot.biz.common.excel.ExcelUtil;
+import com.yeejoin.amos.boot.module.jg.api.dto.JgUseRegistrationDto;
 import com.yeejoin.amos.boot.module.jg.api.mapper.*;
 import com.yeejoin.amos.boot.module.jg.api.vo.tableDataExportVo.*;
 import com.yeejoin.amos.boot.module.jg.biz.service.IJgTableDataExportService;
@@ -16,6 +17,10 @@ import java.io.IOException;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Calendar;
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -226,11 +231,37 @@ public class JgTableDataExportServiceImpl implements IJgTableDataExportService {
      * 使用登记列表数据导出
      *
      * @param response 响应
-     * @param ids 数据id
+     * @param dto 筛选面板数据
      */
-    @Override
-    public void registration(HttpServletResponse response, List<String> ids) {
-        List<RegistrationVo> exportData = registrationMapper.queryRegistrationInIds(ids);
+    public void registration(HttpServletResponse response, JgUseRegistrationDto dto) {
+        if (dto.getAuditPassDateRange() != null && !dto.getAuditPassDateRange().isEmpty() && !dto.getAuditPassDateRange().equals("[, ]")) {
+            String dateRangeStr = dto.getAuditPassDateRange();
+            String[] dates = dateRangeStr.replace("[", "").replace("]", "").split(", ");
+
+            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+            Date start = null;
+            Date end = null;
+            try {
+                start = dateFormat.parse(dates[0]);
+                end = dateFormat.parse(dates[1]);
+            } catch (ParseException e) {
+                throw new RuntimeException(e);
+            }
+            Calendar calendar = Calendar.getInstance();
+            calendar.setTime(start);
+            calendar.add(Calendar.DAY_OF_MONTH, -1); // 减去一天
+            start = calendar.getTime();
+            dto.setAuditPassDateStart(start);
+            dto.setAuditPassDateEnd(end);
+        }
+        List<RegistrationVo> exportData = registrationMapper.queryRegistrationInIds(dto);
+        for (RegistrationVo vo : exportData) {
+            if (vo.getRegType()== null) {
+                vo.setRegType("新增登记");
+            } else if(vo.getRegType().equals("1")){
+                vo.setRegType("历史登记");
+            }
+        }
         ExcelUtil.createTemplate(response, "使用登记列表数据", "使用登记列表", exportData, RegistrationVo.class, null, false);
     }
 

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-api/src/main/resources/mapper/AQZSDPStatisticsMapper.xml

@@ -109,6 +109,7 @@
 			tzs_safety_problem_tracing
 		WHERE
 			governing_body_org_code LIKE concat ( #{orgCode}, '%' )
+			AND problem_level IS NOT NULL
 			<if test="now != null and now != ''">
 				AND DATE_FORMAT(problem_time,'%Y-%m') &gt;= #{now}
 			</if>
@@ -372,6 +373,7 @@
 		from tzs_safety_problem_tracing spt
 		<where>
 			spt.is_delete = false
+			AND spt.problem_level IS NOT NULL
 			<if test="problemModel.problemNum != null and problemModel.problemNum != ''">
 				and spt.problem_num = LIKE CONCAT('%', #{problemModel.problemNum}, '%')
 			</if>

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-api/src/main/resources/mapper/CylinderStatisticsMapper.xml

@@ -50,7 +50,7 @@
                    ( T.filling_quantity )
         FROM
             tz_cylinder_filling_record T
-                INNER JOIN tz_base_enterprise_info E ON T.app_id = E.app_id
+                INNER JOIN tz_base_enterprise_info E ON T.app_id = E.app_id and E.unit_type like '%充装单位%'
         WHERE
             E.supervise_org_code LIKE concat ( #{orgCode}, '%' )
     </select>
@@ -60,7 +60,7 @@
                    ( T.offloading_volume )
         FROM
             tz_cylinder_offloading T
-                INNER JOIN tz_base_enterprise_info E ON T.app_id = E.app_id
+                INNER JOIN tz_base_enterprise_info E ON T.app_id = E.app_id and E.unit_type like '%充装单位%'
         WHERE
             E.supervise_org_code LIKE concat ( #{orgCode}, '%' )
     </select>
@@ -69,7 +69,7 @@
                    ( DISTINCT ( E.app_id ) )
         FROM
             tz_cylinder_filling_record
-                T INNER JOIN tz_base_enterprise_info E ON T.app_id = E.app_id
+                T INNER JOIN tz_base_enterprise_info E ON T.app_id = E.app_id and E.unit_type like '%充装单位%'
         WHERE
             E.supervise_org_code LIKE concat ( #{orgCode}, '%' )
     </select>

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-biz/src/main/java/com/yeejoin/amos/boot/module/statistcs/biz/controller/AQZSDPStatisticsController.java

@@ -308,8 +308,8 @@ public class AQZSDPStatisticsController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @PostMapping(value = "/page/dp")
     @ApiOperation(httpMethod = "POST",value = "分页查询安全追溯问题-大屏使用",  notes = "分页查询安全追溯问题-大屏使用")
-    public ResponseModel<Page<SafetyProblemTracingDto>> getProblemRecords(@RequestParam(value = "current") int current,
-                                                                          @RequestParam(value = "size") int size,
+    public ResponseModel<Page<SafetyProblemTracingDto>> getProblemRecords(@RequestParam(value = "current",defaultValue = "1") int current,
+                                                                          @RequestParam(value = "size",defaultValue = "20") int size,
                                                                           @RequestBody(required = false) SafetyProblemTracingDto problemModel) {
         Page<SafetyProblemTracingDto> page = new Page<>();
         page.setCurrent(current);

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-biz/src/main/java/com/yeejoin/amos/boot/module/statistcs/biz/service/impl/CylinderDPStatisticsServiceImpl.java

@@ -328,10 +328,10 @@ public class CylinderDPStatisticsServiceImpl {
             result.put("jycqsbCount", this.countForCylinderOverdueInspect(orgCode));
             // 充气量
             Long fillingVolumeCount = cylinderStatisticsMapper.countFillingVolumeCount(orgCode);
-            result.put("fillingVolumeCount", fillingVolumeCount == null ? 0L : fillingVolumeCount);
+            result.put("fillingVolumeCount", fillingVolumeCount == null ? 0L : new BigDecimal(fillingVolumeCount).divide(new BigDecimal("10000000")).setScale(3,RoundingMode.HALF_UP).toString());
             // 卸液量
             Long dischargeVolumeCount = cylinderStatisticsMapper.countDischargeVolumeCount(orgCode);
-            result.put("dischargeVolumeCount", dischargeVolumeCount == null ? 0L : dischargeVolumeCount);
+            result.put("dischargeVolumeCount", dischargeVolumeCount == null ? 0L : new BigDecimal(dischargeVolumeCount).divide(new BigDecimal("10000000")).setScale(3,RoundingMode.HALF_UP).toString());
         } else {
             this.setDefaultValueIfNoData(result, "cylindersCount", "stationCount", "operatorCount", "liquefiedGasCount", "automotiveGasCount", "industrialGasCount", "useRegistrationQuantityCount", "jylqsbCount", "jycqsbCount","fillingVolumeCount","dischargeVolumeCount");
         }

amos-boot-system-tzs/amos-boot-module-statistics/amos-boot-module-statistics-biz/src/main/java/com/yeejoin/amos/boot/module/statistcs/biz/service/impl/YJDPStatisticsServiceImpl.java

@@ -744,7 +744,7 @@ public class YJDPStatisticsServiceImpl {
             lambda.likeRight(AlertUseUnitStatistics::getSupervisoryUnitOrgCode, orgCode);
         }
         String date = DateUtil.formatDate(DateTimeUtil.addMonths(new Date(), -1), "yyyy-MM");
-        lambda.ge(AlertUseUnitStatistics::getStatisticsDate, date);
+        lambda.eq(AlertUseUnitStatistics::getStatisticsDate, date);
         // 使用单位
         if (!ValidationUtil.isEmpty(detailDto.getCompanyName())){
             lambda.like(AlertUseUnitStatistics::getUseUnit, detailDto.getCompanyName().trim());
@@ -753,15 +753,16 @@ public class YJDPStatisticsServiceImpl {
         if (!ValidationUtil.isEmpty(detailDto.getMaintenanceCompanyName())){
             lambda.like(AlertUseUnitStatistics::getMaintenanceUnit, detailDto.getMaintenanceCompanyName().trim());
         }
-        // 开始时间
-        if (!ValidationUtil.isEmpty(detailDto.getTimeSearchOne().getBeginDate())){
-            lambda.ge(AlertUseUnitStatistics::getStartDate, detailDto.getTimeSearchOne().getBeginDate());
-        }
-        // 结束时间
-        if (!ValidationUtil.isEmpty(detailDto.getTimeSearchOne().getEndDate())){
-            lambda.le(AlertUseUnitStatistics::getEndDate, detailDto.getTimeSearchOne().getEndDate());
+        if(!ValidationUtil.isEmpty(detailDto.getTimeSearchOne())) {
+            // 开始时间
+            if (!ValidationUtil.isEmpty(detailDto.getTimeSearchOne().getBeginDate())) {
+                lambda.ge(AlertUseUnitStatistics::getStartDate, detailDto.getTimeSearchOne().getBeginDate());
+            }
+            // 结束时间
+            if (!ValidationUtil.isEmpty(detailDto.getTimeSearchOne().getEndDate())) {
+                lambda.le(AlertUseUnitStatistics::getEndDate, detailDto.getTimeSearchOne().getEndDate());
+            }
         }
-
         // 设备类型
         if (!ValidationUtil.isEmpty(detailDto.getEquListCode())){
             lambda.le(AlertUseUnitStatistics::getEquipmentClassificationCode, detailDto.getEquListCode());

amos-boot-system-tzs/amos-boot-module-ymt/amos-boot-module-ymt-api/src/main/resources/mapper/TzBaseEnterpriseInfoMapper.xml

@@ -106,7 +106,7 @@
 			and open_biz_type = #{tzBaseEnterpriseInfoDto.jyjcType}
 			</if>
 			group by unit_code,open_biz_type) t1
-			ON t1.unit_code = unit_code
+			ON t1.unit_code = use_code
 		</if>
 		<where>
 <!--			<if-->