Commit 76eab8e2 authored by 刘林's avatar 刘林

fix(cylinder):气瓶区域信息查询

parent e2e4bc65
...@@ -13,4 +13,6 @@ public interface TzsAuthService { ...@@ -13,4 +13,6 @@ public interface TzsAuthService {
List<String> getUserRegionCode(); List<String> getUserRegionCode();
List<RegionModel> getUserReginTree(); List<RegionModel> getUserReginTree();
List<RegionModel> getThreeUserReginTree();
} }
package com.yeejoin.amos.boot.module.cylinder.flc.api.dto;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
/**
* 地市气瓶信息汇总
*
* @author LiuLin
* @date 2024-05-31
*/
@Data
@EqualsAndHashCode(callSuper = true)
@ApiModel(value="CityCylinderInfoDto", description="地市气瓶信息汇总")
public class CityCylinderInfoDto extends BaseDto {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "地市名称")
private String regionName;
@ApiModelProperty(value = "地市Code")
private String regionCode;
@ApiModelProperty(value = "是否报警")
@JsonProperty("isAlarm")
private boolean isAlarm;
@ApiModelProperty(value = "气站数量")
private Integer stationCount;
@ApiModelProperty(value = "气瓶数量")
private Integer cylindersCount;
@ApiModelProperty(value = "经度")
private String longitude;
@ApiModelProperty(value = "纬度")
private String latitude;
}
package com.yeejoin.amos.boot.module.cylinder.flc.api.mapper; package com.yeejoin.amos.boot.module.cylinder.flc.api.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.CityCylinderInfoDto;
import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.CylinderUnitDto; import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.CylinderUnitDto;
import com.yeejoin.amos.boot.module.cylinder.flc.api.entity.CylinderUnit; import com.yeejoin.amos.boot.module.cylinder.flc.api.entity.CylinderUnit;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.List; import java.util.List;
/** /**
...@@ -48,4 +48,11 @@ public interface CylinderUnitMapper extends BaseMapper<CylinderUnit> { ...@@ -48,4 +48,11 @@ public interface CylinderUnitMapper extends BaseMapper<CylinderUnit> {
Integer getThisMonthUnitTotalByRegionCode(String regionCode); Integer getThisMonthUnitTotalByRegionCode(String regionCode);
List<CylinderUnitDto> getMessage(@Param("regionCode") String regionCode); List<CylinderUnitDto> getMessage(@Param("regionCode") String regionCode);
/**
* 根据层级查气瓶信息
* @param level 层级
* @return list
*/
List<CityCylinderInfoDto> getCylinderDataByLevel(@Param("level") String level);
} }
...@@ -3,8 +3,8 @@ package com.yeejoin.amos.boot.module.cylinder.flc.api.service; ...@@ -3,8 +3,8 @@ package com.yeejoin.amos.boot.module.cylinder.flc.api.service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.cylinder.api.entity.ESCylinderInfoDto; import com.yeejoin.amos.boot.module.cylinder.api.entity.ESCylinderInfoDto;
import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.CityCylinderInfoDto;
import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.CylinderInfoDto; import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.CylinderInfoDto;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
...@@ -56,4 +56,6 @@ public interface ICylinderInfoService { ...@@ -56,4 +56,6 @@ public interface ICylinderInfoService {
void saveCylinderInfo2ES(List<CylinderInfoDto> records); void saveCylinderInfo2ES(List<CylinderInfoDto> records);
Integer getInfoTotal(); Integer getInfoTotal();
List<CityCylinderInfoDto> getCityCylinderData(String level);
} }
...@@ -14,6 +14,21 @@ ...@@ -14,6 +14,21 @@
select count(sequence_nbr) from tz_cylinder_unit where region_code like CONCAT('%',#{regionCode},'%') select count(sequence_nbr) from tz_cylinder_unit where region_code like CONCAT('%',#{regionCode},'%')
</select> </select>
<select id="getCylinderDataByLevel" resultType="com.yeejoin.amos.boot.module.cylinder.flc.api.dto.CityCylinderInfoDto">
SELECT
SUBSTRING_INDEX(SUBSTRING_INDEX(cu.region_code, '#', #{level}), '#', -1) AS regionCode,
COUNT(DISTINCT cu.sequence_nbr) AS stationCount,
COUNT(ci.app_id) AS cylindersCount,
CASE
WHEN (SELECT COUNT(1) FROM tz_cylinder_inspection ins WHERE ins.app_id = cu.app_id
AND LENGTH(ins.next_inspection_date) >= 10
AND TO_DAYS(ins.next_inspection_date) - TO_DAYS(NOW()) &lt;= 30) > 0 THEN 1
WHEN (SELECT COUNT(1) FROM view_unit_outofdate v WHERE v.credit_code = cu.credit_code) > 0 THEN 1
ELSE 0
END AS "isAlarm"
FROM tz_cylinder_unit cu LEFT JOIN tz_cylinder_info ci ON cu.app_id = ci.app_id GROUP BY regionCode
</select>
<select id="getWarnNum" resultType="java.lang.Integer"> <select id="getWarnNum" resultType="java.lang.Integer">
select count(1) from view_unit_outofdate v where v.app_id in ( select count(1) from view_unit_outofdate v where v.app_id in (
select u.app_id from tz_cylinder_unit u where u.region_code like CONCAT('%',#{regionCode},'%') select u.app_id from tz_cylinder_unit u where u.region_code like CONCAT('%',#{regionCode},'%')
......
...@@ -36,92 +36,105 @@ import java.util.Map; ...@@ -36,92 +36,105 @@ import java.util.Map;
@RequestMapping(value = "/tzs-auth-api") @RequestMapping(value = "/tzs-auth-api")
public class TzsAuthController extends BaseController { public class TzsAuthController extends BaseController {
@Value("${tzs.auth.user.photo}")
String userPhoto;
@Autowired
TzsAuthService tzsAuthService;
@Autowired @Autowired
TzsAuthService tzsAuthService; TzsCitInfoServiceImpl citInfoService;
@Autowired /**
TzsCitInfoServiceImpl citInfoService; * 判断用户是否是管理员
*
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/isUserAdmin")
@ApiOperation(httpMethod = "GET", value = "判断用户是否是管理员", notes = "判断用户是否是管理员")
public ResponseModel<Boolean> isUserAdmin() {
Boolean flag = false;
AgencyUserModel me = Privilege.agencyUserClient.getme().getResult();
LambdaQueryWrapper<TzsCitInfo> wrapper = new LambdaQueryWrapper<>();
wrapper.eq(TzsCitInfo::getCtiUserId, me.getUserId());
TzsCitInfo ctiInfo = citInfoService.getOne(wrapper);
if (!ValidationUtil.isEmpty(ctiInfo)) {
if ("班长".equals(ctiInfo.getUserRole())) {
flag = true;
}
}
return ResponseHelper.buildResponse(flag);
}
/** /**
* 判断用户是否是管理员 * 获取用户regionCode
* @return */
*/ @TycloudOperation(ApiLevel = UserType.AGENCY)
@TycloudOperation(ApiLevel = UserType.AGENCY) @GetMapping(value = "/getUserRegincode")
@GetMapping(value = "/isUserAdmin") @ApiOperation(httpMethod = "GET", value = "获取用户regionCode", notes = "获取用户regionCode")
@ApiOperation(httpMethod = "GET", value = "判断用户是否是管理员", notes = "判断用户是否是管理员") public ResponseModel<List<String>> getUserRegincode() {
public ResponseModel<Boolean> isUserAdmin() { List<String> regionList = tzsAuthService.getUserRegionCode();
Boolean flag = false; AgencyUserModel me = Privilege.agencyUserClient.getme().getResult();
AgencyUserModel me = Privilege.agencyUserClient.getme().getResult(); return ResponseHelper.buildResponse(regionList);
LambdaQueryWrapper<TzsCitInfo> wrapper = new LambdaQueryWrapper<>(); }
wrapper.eq(TzsCitInfo::getCtiUserId,me.getUserId());
TzsCitInfo ctiInfo = citInfoService.getOne(wrapper);
if(!ValidationUtil.isEmpty(ctiInfo)){
if("班长".equals(ctiInfo.getUserRole())){
flag = true;
}
}
return ResponseHelper.buildResponse(flag);
}
/** /**
* 获取用户regionCode * 获取用户组织机构树
*/ */
@TycloudOperation(ApiLevel = UserType.AGENCY) @TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getUserRegincode") @GetMapping(value = "/getUserReginTree")
@ApiOperation(httpMethod = "GET", value = "获取用户regionCode", notes = "获取用户regionCode") @ApiOperation(httpMethod = "GET", value = "获取用户组织机构树", notes = "获取用户组织机构树")
public ResponseModel<List<String>> getUserRegincode() { public ResponseModel<Collection<RegionModel>> getUserReginTree() {
List<String> regionList = tzsAuthService.getUserRegionCode(); List<RegionModel> result = tzsAuthService.getUserReginTree();
AgencyUserModel me = Privilege.agencyUserClient.getme().getResult(); return ResponseHelper.buildResponse(result);
return ResponseHelper.buildResponse(regionList); }
}
/** /**
* 获取用户组织机构树 * 获取用户组织机构树-到省市区级别三级
*/ *
@TycloudOperation(ApiLevel = UserType.AGENCY) * @author LiuLin
@GetMapping(value = "/getUserReginTree") * @date 2025-05-31
@ApiOperation(httpMethod = "GET", value = "获取用户组织机构树", notes = "获取用户组织机构树") */
public ResponseModel<Collection<RegionModel>> getUserReginTree() { @TycloudOperation(ApiLevel = UserType.AGENCY)
List<RegionModel> result = tzsAuthService.getUserReginTree(); @GetMapping(value = "/getThreeUserReginTree")
return ResponseHelper.buildResponse(result); @ApiOperation(httpMethod = "GET", value = "获取三级用户组织机构树", notes = "获取三级用户组织机构树")
} public ResponseModel<Collection<RegionModel>> getThreeUserReginTree() {
List<RegionModel> result = tzsAuthService.getThreeUserReginTree();
return ResponseHelper.buildResponse(result);
}
@Value("${tzs.auth.user.photo}") /**
String userPhoto; * 获取用户监管机构
*/
/** @TycloudOperation(ApiLevel = UserType.AGENCY)
* 获取用户监管机构 @GetMapping(value = "/getUserRegulator")
*/ @ApiOperation(httpMethod = "GET", value = "获取用户组织机构树", notes = "获取用户组织机构树")
@TycloudOperation(ApiLevel = UserType.AGENCY) public ResponseModel<Map<String, Object>> getUserRegulator() {
@GetMapping(value = "/getUserRegulator") Map<String, Object> map = new HashMap<>();
@ApiOperation(httpMethod = "GET", value = "获取用户组织机构树", notes = "获取用户组织机构树") FeignClientResult<AgencyUserModel> result = Privilege.agencyUserClient.getme();
public ResponseModel<Map<String, Object>> getUserRegulator() { if (result.getResult() != null) {
Map<String, Object> map = new HashMap<>(); List<CompanyModel> list = result.getResult().getCompanys();
FeignClientResult<AgencyUserModel> result = Privilege.agencyUserClient.getme(); if (list != null && !list.isEmpty()) {
if (result.getResult() != null) { CompanyModel company = list.get(0);
List<CompanyModel> list = result.getResult().getCompanys(); if ("company".equals(company.getLevel())) {
if (list != null && !list.isEmpty()) { FeignClientResult<CompanyModel> cResult = Privilege.companyClient.seleteOne(company.getParentId());
CompanyModel company = list.get(0); if (cResult.getResult() != null) {
if ("company".equals(company.getLevel())) { map.put("regulator", cResult.getResult().getCompanyName());
FeignClientResult<CompanyModel> cResult = Privilege.companyClient.seleteOne(company.getParentId()); }
if (cResult.getResult() != null) { map.put("orgCode", cResult.getResult().getOrgCode() + "_" + cResult.getResult().getCompanyName());
map.put("regulator", cResult.getResult().getCompanyName()); } else {
} map.put("regulator", company.getCompanyName());
map.put("orgCode", cResult.getResult().getOrgCode() + "_" + cResult.getResult().getCompanyName()); map.put("orgCode", list.get(0).getOrgCode() + "_" + list.get(0).getCompanyName());
} else { }
map.put("regulator", company.getCompanyName()); map.put("company", company.getCompanyName());
map.put("orgCode", list.get(0).getOrgCode() + "_" + list.get(0).getCompanyName()); map.put("companyId", company.getParentId() != 0L ? company.getParentId() : company.getSequenceNbr());
} map.put("USE_UNIT_NAME", list.get(0).getCompanyName());
map.put("company", company.getCompanyName()); map.put("USE_UNIT_CREDIT_CODE", list.get(0).getCompanyCode());
map.put("companyId", company.getParentId() != 0L ? company.getParentId() : company.getSequenceNbr()); }
map.put("USE_UNIT_NAME", list.get(0).getCompanyName()); map.put("userName", result.getResult().getRealName());
map.put("USE_UNIT_CREDIT_CODE", list.get(0).getCompanyCode()); map.put("userPhoto", userPhoto);
} }
map.put("userName", result.getResult().getRealName()); return ResponseHelper.buildResponse(map);
map.put("userPhoto", userPhoto); }
}
return ResponseHelper.buildResponse(map);
}
} }
...@@ -137,6 +137,68 @@ public class TzsAuthServiceImpl implements TzsAuthService { ...@@ -137,6 +137,68 @@ public class TzsAuthServiceImpl implements TzsAuthService {
return newTree; return newTree;
} }
@Override
public List<RegionModel> getThreeUserReginTree() {
List<String> regionList = this.getUserRegionCode();
//AgencyUserModel me = Privilege.agencyUserClient.getme().getResult();
startPlatformTokenService.getToken();
List<RegionModel> tree = (List<RegionModel>) Systemctl.regionClient.queryForTree(null).getResult();
// 循环list 将List 封装为 省市区 SET
Set<String> city = new HashSet<>();
Set<String> district = new HashSet<>();
for(String regionCode : regionList) {
// 判断是否是某个县
String districtCode = regionCode.substring(4,6);
if("00".equals(districtCode)) { // 为市
city.add(regionCode);
} else { // 为区
district.add(regionCode);
}
}
// 判断市区是否存在区域码的市,如果存在则移除区
Iterator<String> disIt = district.iterator();
while(disIt.hasNext()) {
String regionCode = disIt.next();
String tempCity = regionCode.substring(0,4) + "00";
if(city.contains(tempCity)) {
disIt.remove();
}
}
// 将tree 转换为K-V形式便于处理
Map<Integer, RegionModel> tempMap = new HashMap<Integer, RegionModel>();
RegionModel start = tree.get(0); // 省
filterAndMapRegions(tempMap,start);
List<RegionModel> newTree = new ArrayList<RegionModel>();
List<RegionModel> newCity = new ArrayList<RegionModel>();
// 如果管理市 取得整个市的数据 如果管理某个县 取得某市某县数据
Map<String, RegionModel> tempCityMap = new HashMap<String, RegionModel>();
for(String regionCode : district) {
// 先拿市 再封装新的城市
String cityCode = regionCode.substring(0,4) + "00";
RegionModel tempCity = tempCityMap.get(cityCode);
if(tempCity == null) {
List<RegionModel> tempDisList = new ArrayList<RegionModel>();
tempDisList.add(tempMap.get(Integer.parseInt(regionCode)));
tempCity = tempMap.get(Integer.parseInt(cityCode));
tempCity.setChildren(tempDisList);
tempCityMap.put(cityCode,tempCity);
} else {
List<RegionModel> tempDisList = (List<RegionModel>) tempCity.getChildren();
tempDisList.add(tempMap.get(Integer.parseInt(regionCode)));
}
}
for(String regionCode : city) {// 获取城市
newCity.add(tempMap.get(Integer.parseInt(regionCode)));
}
// 拼接城市
for(Map.Entry<String, RegionModel> entries : tempCityMap.entrySet()) {
newCity.add(entries.getValue());
}
//start.setChildren(newCity);
newTree.addAll(newCity);
return newTree;
}
private void setMap(Map<Integer, RegionModel> tempMap, RegionModel start) { private void setMap(Map<Integer, RegionModel> tempMap, RegionModel start) {
tempMap.put(start.getRegionCode(),start); tempMap.put(start.getRegionCode(),start);
...@@ -146,9 +208,25 @@ public class TzsAuthServiceImpl implements TzsAuthService { ...@@ -146,9 +208,25 @@ public class TzsAuthServiceImpl implements TzsAuthService {
setMap(tempMap,temp); setMap(tempMap,temp);
} }
} }
} }
private static void filterAndMapRegions(Map<Integer, RegionModel> tempMap, RegionModel start) {
// 先检查并过滤子节点
if (start.getChildren() != null) {
Iterator<RegionModel> iterator = start.getChildren().iterator();
while (iterator.hasNext()) {
RegionModel child = iterator.next();
if ("4".equals(child.getLevel().trim())) {
iterator.remove();
} else {
filterAndMapRegions(tempMap, child);
}
}
}
if (!"4".equals(start.getLevel().trim())) {
tempMap.put(start.getRegionCode(), start);
}
}
private void loginCtiUser() { private void loginCtiUser() {
String passwd = DesUtil.encode(ctiUserPwd, "qaz"); String passwd = DesUtil.encode(ctiUserPwd, "qaz");
......
...@@ -12,6 +12,7 @@ import com.yeejoin.amos.boot.biz.common.utils.RedisKey; ...@@ -12,6 +12,7 @@ import com.yeejoin.amos.boot.biz.common.utils.RedisKey;
import com.yeejoin.amos.boot.biz.common.utils.RedisUtils; import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
import com.yeejoin.amos.boot.module.common.api.dto.AttachmentDto; import com.yeejoin.amos.boot.module.common.api.dto.AttachmentDto;
import com.yeejoin.amos.boot.module.common.biz.service.impl.SourceFileServiceImpl; import com.yeejoin.amos.boot.module.common.biz.service.impl.SourceFileServiceImpl;
import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.CityCylinderInfoDto;
import com.yeejoin.amos.boot.module.cylinder.flc.biz.service.impl.*; import com.yeejoin.amos.boot.module.cylinder.flc.biz.service.impl.*;
import com.yeejoin.amos.boot.module.cylinder.api.dto.TzBaseEnterpriseInfoDto; import com.yeejoin.amos.boot.module.cylinder.api.dto.TzBaseEnterpriseInfoDto;
import com.yeejoin.amos.boot.module.cylinder.api.entity.BaseUnitLicence; import com.yeejoin.amos.boot.module.cylinder.api.entity.BaseUnitLicence;
...@@ -1329,4 +1330,18 @@ public class CylinderInfoController extends BaseController { ...@@ -1329,4 +1330,18 @@ public class CylinderInfoController extends BaseController {
map.put("status", number); map.put("status", number);
return ResponseHelper.buildResponse(map); return ResponseHelper.buildResponse(map);
} }
/**
* 地市气瓶,气站信息统计
*
* @author LiuLin
* @date 2025-05-31
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/getCityCylinderData")
@ApiOperation(httpMethod = "GET", value = "获取地市气瓶,气站信息统计", notes = "获取地市气瓶,气站信息统计")
public ResponseModel<Collection<CityCylinderInfoDto>> getCityCylinderData(@RequestParam( value="level") String level) {
List<CityCylinderInfoDto> result = cylinderInfoServiceImpl.getCityCylinderData(level);
return ResponseHelper.buildResponse(result);
}
} }
...@@ -56,6 +56,7 @@ import java.text.SimpleDateFormat; ...@@ -56,6 +56,7 @@ import java.text.SimpleDateFormat;
import java.util.*; import java.util.*;
import java.util.function.Consumer; import java.util.function.Consumer;
import java.util.function.IntConsumer; import java.util.function.IntConsumer;
import java.util.stream.Collectors;
/** /**
* 气瓶基本信息服务实现类 * 气瓶基本信息服务实现类
...@@ -813,6 +814,32 @@ public class CylinderInfoServiceImpl extends BaseService<CylinderInfoDto, Cylind ...@@ -813,6 +814,32 @@ public class CylinderInfoServiceImpl extends BaseService<CylinderInfoDto, Cylind
} }
@Override @Override
public List<CityCylinderInfoDto> getCityCylinderData(String level) {
List<RegionModel> result = Systemctl.regionClient.queryByLevel(level).getResult();
List<CityCylinderInfoDto> cylinderInfoDtoList = cylinderUnitServiceImpl.getCylinderDataByLevel(level);
Map<String, CityCylinderInfoDto> dtoMap = cylinderInfoDtoList.stream()
.collect(Collectors.toMap(CityCylinderInfoDto::getRegionCode, dto -> dto));
result.forEach(regionModel -> {
String regionCode = regionModel.getRegionCode()+"";
CityCylinderInfoDto dto = dtoMap.computeIfAbsent(regionCode, key -> {
CityCylinderInfoDto newDto = new CityCylinderInfoDto();
newDto.setRegionCode(regionCode);
newDto.setRegionName(regionModel.getRegionName());
newDto.setLatitude(regionModel.getLatitude());
newDto.setLongitude(regionModel.getLongitude());
cylinderInfoDtoList.add(newDto);
return newDto;
});
dto.setLatitude(regionModel.getLatitude());
dto.setLongitude(regionModel.getLongitude());
dto.setRegionName(regionModel.getRegionName());
});
return cylinderInfoDtoList;
}
@Override
public ESCylinderInfoDto saveCylinderInfoToES(CylinderInfoDto ci) { public ESCylinderInfoDto saveCylinderInfoToES(CylinderInfoDto ci) {
ESCylinderInfoDto esCylinderInfoDto = new ESCylinderInfoDto(); ESCylinderInfoDto esCylinderInfoDto = new ESCylinderInfoDto();
BeanUtils.copyProperties(ci, esCylinderInfoDto); BeanUtils.copyProperties(ci, esCylinderInfoDto);
......
...@@ -8,6 +8,7 @@ import com.yeejoin.amos.boot.module.cylinder.api.entity.BaseUnitLicence; ...@@ -8,6 +8,7 @@ import com.yeejoin.amos.boot.module.cylinder.api.entity.BaseUnitLicence;
import com.yeejoin.amos.boot.module.cylinder.api.entity.TzBaseEnterpriseInfo; import com.yeejoin.amos.boot.module.cylinder.api.entity.TzBaseEnterpriseInfo;
import com.yeejoin.amos.boot.module.cylinder.biz.service.impl.BaseUnitLicenceServiceImpl; import com.yeejoin.amos.boot.module.cylinder.biz.service.impl.BaseUnitLicenceServiceImpl;
import com.yeejoin.amos.boot.module.cylinder.biz.service.impl.TzBaseEnterpriseInfoServiceImpl; import com.yeejoin.amos.boot.module.cylinder.biz.service.impl.TzBaseEnterpriseInfoServiceImpl;
import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.CityCylinderInfoDto;
import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.CylinderUnitDto; import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.CylinderUnitDto;
import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.RegUnitIcDto; import com.yeejoin.amos.boot.module.cylinder.flc.api.dto.RegUnitIcDto;
import com.yeejoin.amos.boot.module.cylinder.flc.api.entity.CylinderUnit; import com.yeejoin.amos.boot.module.cylinder.flc.api.entity.CylinderUnit;
...@@ -76,6 +77,10 @@ public class CylinderUnitServiceImpl extends BaseService<CylinderUnitDto, Cylind ...@@ -76,6 +77,10 @@ public class CylinderUnitServiceImpl extends BaseService<CylinderUnitDto, Cylind
return baseMapper.getThisMonthUnitTotalByRegionCode(regionCode); return baseMapper.getThisMonthUnitTotalByRegionCode(regionCode);
} }
public List<CityCylinderInfoDto> getCylinderDataByLevel(String level) {
return baseMapper.getCylinderDataByLevel(level);
}
public Integer getUnitTotalByRegionCode(String regionCode) { public Integer getUnitTotalByRegionCode(String regionCode) {
return baseMapper.getUnitTotalByRegionCode(regionCode); return baseMapper.getUnitTotalByRegionCode(regionCode);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment