Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
A
amos-boot-biz
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
项目统一框架
amos-boot-biz
Commits
29e66c23
Commit
29e66c23
authored
Aug 02, 2021
by
tianbo
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
代码优化提交
parent
6139c9bc
Hide whitespace changes
Inline
Side-by-side
Showing
28 changed files
with
620 additions
and
412 deletions
+620
-412
TreeParser.java
...va/com/yeejoin/amos/boot/biz/common/utils/TreeParser.java
+5
-1
EquipFeignClient.java
...n/amos/boot/module/common/api/feign/EquipFeignClient.java
+117
-0
MultipartSupportConfig.java
.../boot/module/common/api/feign/MultipartSupportConfig.java
+27
-0
WaterResourceMapper.java
...os/boot/module/common/api/mapper/WaterResourceMapper.java
+9
-0
IKeySiteService.java
.../amos/boot/module/common/api/service/IKeySiteService.java
+2
-2
IMaintenanceCompanyService.java
...module/common/api/service/IMaintenanceCompanyService.java
+0
-9
WaterResourceMapper.xml
...mon-api/src/main/resources/mapper/WaterResourceMapper.xml
+18
-0
EquipFeignClient.java
...join/amos/boot/module/jcs/api/feign/EquipFeignClient.java
+120
-124
MultipartSupportConfig.java
...mos/boot/module/jcs/api/feign/MultipartSupportConfig.java
+27
-27
IFirefightersJacketService.java
...ot/module/jcs/api/service/IFirefightersJacketService.java
+1
-1
CommandController.java
...boot/module/command/biz/controller/CommandController.java
+1
-1
KeySiteController.java
.../boot/module/common/biz/controller/KeySiteController.java
+18
-21
WaterResourceController.java
...module/common/biz/controller/WaterResourceController.java
+30
-12
KeySiteServiceImpl.java
...ot/module/common/biz/service/impl/KeySiteServiceImpl.java
+3
-1
LinkageUnitServiceImpl.java
...odule/common/biz/service/impl/LinkageUnitServiceImpl.java
+2
-9
MaintenanceCompanyServiceImpl.java
...ommon/biz/service/impl/MaintenanceCompanyServiceImpl.java
+82
-110
OrgUsrServiceImpl.java
...oot/module/common/biz/service/impl/OrgUsrServiceImpl.java
+36
-32
SourceFileServiceImpl.java
...module/common/biz/service/impl/SourceFileServiceImpl.java
+33
-0
WaterResourceServiceImpl.java
...ule/common/biz/service/impl/WaterResourceServiceImpl.java
+6
-4
ExcelController.java
.../amos/boot/module/jcs/biz/controller/ExcelController.java
+1
-1
FirefightersJacketController.java
...dule/jcs/biz/controller/FirefightersJacketController.java
+1
-1
PowerTransferController.java
...ot/module/jcs/biz/controller/PowerTransferController.java
+18
-15
AlertSubmittedServiceImpl.java
...odule/jcs/biz/service/impl/AlertSubmittedServiceImpl.java
+41
-22
DataSourcesImpl.java
...mos/boot/module/jcs/biz/service/impl/DataSourcesImpl.java
+1
-1
EquipmentServiceImpl.java
...oot/module/jcs/biz/service/impl/EquipmentServiceImpl.java
+2
-8
FireTeamServiceImpl.java
...boot/module/jcs/biz/service/impl/FireTeamServiceImpl.java
+13
-5
FirefightersJacketServiceImpl.java
...e/jcs/biz/service/impl/FirefightersJacketServiceImpl.java
+3
-3
PowerTransferServiceImpl.java
...module/jcs/biz/service/impl/PowerTransferServiceImpl.java
+3
-2
No files found.
amos-boot-biz-common/src/main/java/com/yeejoin/amos/boot/biz/common/utils/TreeParser.java
View file @
29e66c23
...
...
@@ -11,12 +11,16 @@ import java.util.Random;
/**
* 生成树工具类
*
* @author DELL
* @return <PRE>
* author tw
* date 2021/6/10
* </PRE>
*/
public
class
TreeParser
{
public
static
final
Integer
CODE_LENGTH
=
6
;
/**
* @param topId 父id
* @param entityList 数据集合
...
...
@@ -330,7 +334,7 @@ public class TreeParser {
}
public
static
String
genTreeCode
()
{
int
length
=
6
;
int
length
=
CODE_LENGTH
;
String
str
=
"abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789"
;
Random
random
=
new
Random
();
StringBuffer
sb
=
new
StringBuffer
();
...
...
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/feign/EquipFeignClient.java
0 → 100644
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
common
.
api
.
feign
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.yeejoin.amos.component.feign.config.InnerInvokException
;
import
org.springframework.cloud.openfeign.FeignClient
;
import
org.springframework.web.bind.annotation.RequestBody
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RequestMethod
;
import
org.springframework.web.bind.annotation.RequestParam
;
import
org.typroject.tyboot.core.restful.utils.ResponseModel
;
import
java.util.List
;
import
java.util.Map
;
/**
* 装备服务feign
*
* @author Dell
*/
@FeignClient
(
name
=
"AMOS-EQUIPMANAGE"
,
path
=
"equip"
,
configuration
=
{
MultipartSupportConfig
.
class
})
public
interface
EquipFeignClient
{
/**
* 获取未列装人员装备列表数据
*
* @return
*/
@RequestMapping
(
value
=
"/equipSpecific/getAirEquipSpecificPage"
,
method
=
RequestMethod
.
POST
)
ResponseModel
<
Page
<
Object
>>
getAirEquipSpecificPage
(
@RequestBody
Object
var1
)
throws
InnerInvokException
;
/**
* 人员装备列装
*
* @return
*/
@RequestMapping
(
value
=
"/stock-detail/airport/person/bind"
,
method
=
RequestMethod
.
POST
)
ResponseModel
<
List
<
Object
>>
stockBindEquip
(
@RequestBody
List
<
Long
>
ids
)
throws
InnerInvokException
;
/**
* 人员装备退装
*
* @return
*/
@RequestMapping
(
value
=
"/scrap/airport/person"
,
method
=
RequestMethod
.
POST
)
ResponseModel
<
Object
>
scrapEquip
(
@RequestBody
String
id
)
throws
InnerInvokException
;
/**
* 人员装备回库
*
* @return
*/
@RequestMapping
(
value
=
"/stock-detail/airport/person"
,
method
=
RequestMethod
.
POST
)
ResponseModel
<
Object
>
stockEquip
(
@RequestBody
Map
<
String
,
Object
>
map
)
throws
InnerInvokException
;
/**
* 装备详情
*
* @return
*/
@RequestMapping
(
value
=
"/equipSpecific/getAirEquipSpecificDetail"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
Object
>
getAirEquipSpecificDetail
(
@RequestParam
Long
stockDetailId
)
throws
InnerInvokException
;
/**
* 获取车辆列表
*
* @return
*/
@RequestMapping
(
value
=
"/car/list-all"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
Object
>
getFireCarListAll
();
/**
* 获取个队伍下车辆统计
*
* @return
*/
@RequestMapping
(
value
=
"/car/list-info"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
List
<
Map
<
String
,
Object
>>>
getFireCarListAllcount
();
/**
* 获取消防系统列表
*
* @return
*/
@RequestMapping
(
value
=
"/fire-fighting-system/list"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
Object
>
getFireSystemListAll
();
/**
* 获取消防系统列表
*
* @return
*/
@RequestMapping
(
value
=
"/building/tree"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
Object
>
getBuildingTree
();
/**
* 更新车辆状态
*
* @param carStatusInfo 车辆状态信息
* @return
*/
@RequestMapping
(
value
=
"/car/status"
,
method
=
RequestMethod
.
POST
)
ResponseModel
<
Object
>
updateCarStatus
(
@RequestBody
List
<
Object
>
carStatusInfo
);
/**
* 获取装备平面图
*
* @return
*/
@RequestMapping
(
value
=
"/sourceFile/findImgByFileCategory"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
List
<
Map
<
String
,
Object
>>>
findImgByFileCategory
(
@RequestParam
String
id
,
@RequestParam
String
fileCategory
);
/**
* 车辆信息
**/
@RequestMapping
(
value
=
"/car/getTeamCarList"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
List
<
Map
<
String
,
Object
>>>
getTeamCarList
(
@RequestParam
Double
longitude
,
@RequestParam
Double
latitude
);
}
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/feign/MultipartSupportConfig.java
0 → 100644
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
common
.
api
.
feign
;
import
feign.codec.Encoder
;
import
feign.form.spring.SpringFormEncoder
;
import
org.springframework.beans.factory.ObjectFactory
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.boot.autoconfigure.http.HttpMessageConverters
;
import
org.springframework.cloud.openfeign.support.SpringEncoder
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
/**
* @Author: xl
* @Description:
* @Date: 2020/3/30 16:26
*/
@Configuration
public
class
MultipartSupportConfig
{
@Autowired
private
ObjectFactory
<
HttpMessageConverters
>
messageConverters
;
@Bean
public
Encoder
feignFormEncoder
()
{
return
new
SpringFormEncoder
(
new
SpringEncoder
(
messageConverters
));
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/mapper/WaterResourceMapper.java
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
common
.
api
.
mapper
;
import
com.baomidou.mybatisplus.core.mapper.BaseMapper
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.yeejoin.amos.boot.biz.common.utils.MenuFrom
;
import
com.yeejoin.amos.boot.module.common.api.dto.RequestData
;
import
com.yeejoin.amos.boot.module.common.api.dto.WaterResourceDto
;
...
...
@@ -8,6 +9,8 @@ import com.yeejoin.amos.boot.module.common.api.dto.WaterResourceTypeDto;
import
com.yeejoin.amos.boot.module.common.api.dto.WaterResourceZhDto
;
import
com.yeejoin.amos.boot.module.common.api.entity.WaterResource
;
import
org.apache.ibatis.annotations.Param
;
import
java.util.ArrayList
;
import
java.util.List
;
/**
...
...
@@ -37,4 +40,10 @@ public interface WaterResourceMapper extends BaseMapper<WaterResource> {
List
<
WaterResourceTypeDto
>
getWaterResourceTypeList
(
Boolean
isDelete
);
/**
* 根据参数查询
*
*/
Page
<
WaterResourceDto
>
getWaterResourcePageByParams
(
Page
<
WaterResourceDto
>
page
,
String
name
,
String
resourceType
,
ArrayList
<
Long
>
belongBuildingId
,
Long
belongFightingSystemId
,
Long
sequenceNbr
);
}
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/service/IKeySiteService.java
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
common
.
api
.
service
;
import
java.util.List
;
import
com.yeejoin.amos.boot.module.common.api.dto.KeySiteDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.KeySiteExcleDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgMenuDto
;
import
java.util.List
;
/**
* 重点部位接口类
*
...
...
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/service/IMaintenanceCompanyService.java
View file @
29e66c23
...
...
@@ -162,13 +162,4 @@ public interface IMaintenanceCompanyService {
* @return
*/
public
List
<
MaintenancePersonExcleDto
>
exportToMaintenancePersonExcel
();
/**
* 获取附件列表
*
* @param sequenceNbr
* @return
*/
public
Map
<
String
,
List
<
AttachmentDto
>>
getAttachments
(
Long
sequenceNbr
);
}
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/resources/mapper/WaterResourceMapper.xml
View file @
29e66c23
...
...
@@ -115,6 +115,24 @@
from cb_water_resource
where is_delete = #{isDelete}
</select>
<select
id=
"getWaterResourcePageByParams"
resultType=
"com.yeejoin.amos.boot.module.common.api.dto.WaterResourceDto"
>
select * from cb_water_resource where is_delete = 1
<if
test=
"sequenceNbr != null and sequenceNbr != ''"
>
and sequence_nbr = #{sequenceNbr}
</if>
<if
test=
"resourceType != null and resourceType != ''"
>
and resource_type = #{resourceType}
</if>
<if
test=
"name != null and name != ''"
>
and name like concat('%', #{name}, '%')
</if>
<if
test=
"belongFightingSystemId != null"
>
<if
test=
"belongFightingSystemId > -1"
>
and belong_fighting_system_id = #{belongFightingSystemId}
</if>
<if
test=
"belongFightingSystemId == -1"
>
and belong_fighting_system_id is null
</if>
</if>
<if
test=
"belongBuildingId != null and belongBuildingId.size() > 0"
>
and find_in_set(belong_building_id, #{belongBuildingId}) > 0
</if>
</select>
</mapper>
amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/feign/EquipFeignClient.java
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
jcs
.
api
.
feign
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.CarStatusInfoDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.EquipSpecificDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.EquipmentOnCarDto
;
import
com.yeejoin.amos.component.feign.config.InnerInvokException
;
import
org.springframework.cloud.openfeign.FeignClient
;
import
org.springframework.web.bind.annotation.RequestBody
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RequestMethod
;
import
org.springframework.web.bind.annotation.RequestParam
;
import
org.typroject.tyboot.core.restful.utils.ResponseModel
;
import
java.util.List
;
import
java.util.Map
;
/**
* 装备服务feign
*
* @author Dell
*/
@FeignClient
(
name
=
"AMOS-EQUIPMANAGE"
,
path
=
"equip"
,
configuration
=
{
MultipartSupportConfig
.
class
})
public
interface
EquipFeignClient
{
/**
* 获取未列装人员装备列表数据
*
* @return
*/
@RequestMapping
(
value
=
"/equipSpecific/getAirEquipSpecificPage"
,
method
=
RequestMethod
.
POST
)
ResponseModel
<
Page
<
EquipmentOnCarDto
>>
getAirEquipSpecificPage
(
@RequestBody
EquipSpecificDto
var1
)
throws
InnerInvokException
;
/**
* 人员装备列装
*
* @return
*/
@RequestMapping
(
value
=
"/stock-detail/airport/person/bind"
,
method
=
RequestMethod
.
POST
)
ResponseModel
<
List
<
Object
>>
stockBindEquip
(
@RequestBody
List
<
Long
>
ids
)
throws
InnerInvokException
;
/**
* 人员装备退装
*
* @return
*/
@RequestMapping
(
value
=
"/scrap/airport/person"
,
method
=
RequestMethod
.
POST
)
ResponseModel
<
Object
>
scrapEquip
(
@RequestBody
String
id
)
throws
InnerInvokException
;
/**
* 人员装备回库
*
* @return
*/
@RequestMapping
(
value
=
"/stock-detail/airport/person"
,
method
=
RequestMethod
.
POST
)
ResponseModel
<
Object
>
stockEquip
(
@RequestBody
Map
<
String
,
Object
>
map
)
throws
InnerInvokException
;
/**
* 装备详情
*
* @return
*/
@RequestMapping
(
value
=
"/equipSpecific/getAirEquipSpecificDetail"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
Object
>
getAirEquipSpecificDetail
(
@RequestParam
Long
stockDetailId
)
throws
InnerInvokException
;
/**
* 获取车辆列表
*
* @return
*/
@RequestMapping
(
value
=
"/car/list-all"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
Object
>
getFireCarListAll
();
/**
* 获取个队伍下车辆统计
*
* @return
*/
@RequestMapping
(
value
=
"/car/list-info"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
List
<
Map
<
String
,
Object
>>>
getFireCarListAllcount
();
/**
* 获取消防系统列表
*
* @return
*/
@RequestMapping
(
value
=
"/fire-fighting-system/list"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
Object
>
getFireSystemListAll
();
/**
* 获取消防系统列表
*
* @return
*/
@RequestMapping
(
value
=
"/building/tree"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
Object
>
getBuildingTree
();
/**
* 更新车辆状态
* @param carStatusInfo 车辆状态信息
* @return
*/
@RequestMapping
(
value
=
"/car/status"
,
method
=
RequestMethod
.
POST
)
ResponseModel
<
Object
>
updateCarStatus
(
@RequestBody
List
<
CarStatusInfoDto
>
carStatusInfo
);
/**
* 获取装备平面图
*
* @return
*/
@RequestMapping
(
value
=
"/sourceFile/findImgByFileCategory"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
List
<
Map
<
String
,
Object
>>>
findImgByFileCategory
(
@RequestParam
String
id
,
@RequestParam
String
fileCategory
);
/**
* 车辆信息
*
* **/
@RequestMapping
(
value
=
"/car/getTeamCarList"
,
method
=
RequestMethod
.
GET
)
ResponseModel
<
List
<
Map
<
String
,
Object
>>>
getTeamCarList
(
@RequestParam
Double
longitude
,
@RequestParam
Double
latitude
);
}
//package com.yeejoin.amos.boot.module.jcs.api.feign;
//
//import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
//import com.yeejoin.amos.boot.module.jcs.api.dto.CarStatusInfoDto;
//import com.yeejoin.amos.boot.module.jcs.api.dto.EquipSpecificDto;
//import com.yeejoin.amos.boot.module.jcs.api.dto.EquipmentOnCarDto;
//import com.yeejoin.amos.component.feign.config.InnerInvokException;
//import org.springframework.cloud.openfeign.FeignClient;
//import org.springframework.web.bind.annotation.RequestBody;
//import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RequestMethod;
//import org.springframework.web.bind.annotation.RequestParam;
//import org.typroject.tyboot.core.restful.utils.ResponseModel;
//
//import java.util.List;
//import java.util.Map;
//
///**
// * 装备服务feign
// *
// * @author Dell
// */
//@FeignClient(name = "AMOS-EQUIPMANAGE-tb", path = "equip", configuration = {MultipartSupportConfig.class})
//public interface EquipFeignClient {
//
// /**
// * 获取未列装人员装备列表数据
// *
// * @return
// */
// @RequestMapping(value = "/equipSpecific/getAirEquipSpecificPage", method = RequestMethod.POST)
// ResponseModel<Page<Object>> getAirEquipSpecificPage(@RequestBody Object var1) throws InnerInvokException;
//
// /**
// * 人员装备列装
// *
// * @return
// */
// @RequestMapping(value = "/stock-detail/airport/person/bind", method = RequestMethod.POST)
// ResponseModel<List<Object>> stockBindEquip(@RequestBody List<Long> ids) throws InnerInvokException;
//
// /**
// * 人员装备退装
// *
// * @return
// */
// @RequestMapping(value = "/scrap/airport/person", method = RequestMethod.POST)
// ResponseModel<Object> scrapEquip(@RequestBody String id) throws InnerInvokException;
//
// /**
// * 人员装备回库
// *
// * @return
// */
// @RequestMapping(value = "/stock-detail/airport/person", method = RequestMethod.POST)
// ResponseModel<Object> stockEquip(@RequestBody Map<String, Object> map) throws InnerInvokException;
//
// /**
// * 装备详情
// *
// * @return
// */
// @RequestMapping(value = "/equipSpecific/getAirEquipSpecificDetail", method = RequestMethod.GET)
// ResponseModel<Object> getAirEquipSpecificDetail(@RequestParam Long stockDetailId) throws InnerInvokException;
//
// /**
// * 获取车辆列表
// *
// * @return
// */
// @RequestMapping(value = "/car/list-all", method = RequestMethod.GET)
// ResponseModel<Object> getFireCarListAll();
//
// /**
// * 获取个队伍下车辆统计
// *
// * @return
// */
// @RequestMapping(value = "/car/list-info", method = RequestMethod.GET)
// ResponseModel<List<Map<String,Object>>> getFireCarListAllcount();
//
// /**
// * 获取消防系统列表
// *
// * @return
// */
// @RequestMapping(value = "/fire-fighting-system/list", method = RequestMethod.GET)
// ResponseModel<Object> getFireSystemListAll();
//
// /**
// * 获取消防系统列表
// *
// * @return
// */
// @RequestMapping(value = "/building/tree", method = RequestMethod.GET)
// ResponseModel<Object> getBuildingTree();
//
// /**
// * 更新车辆状态
// * @param carStatusInfo 车辆状态信息
// * @return
// */
// @RequestMapping(value = "/car/status", method = RequestMethod.POST)
// ResponseModel<Object> updateCarStatus(@RequestBody List<Object> carStatusInfo);
//
// /**
// * 获取装备平面图
// *
// * @return
// */
// @RequestMapping(value = "/sourceFile/findImgByFileCategory", method = RequestMethod.GET)
// ResponseModel<List<Map<String,Object>>> findImgByFileCategory(@RequestParam String id,@RequestParam String fileCategory);
//
// /**
// * 车辆信息
// *
// * **/
// @RequestMapping(value = "/car/getTeamCarList", method = RequestMethod.GET)
// ResponseModel<List<Map<String,Object>>> getTeamCarList(@RequestParam Double longitude,@RequestParam Double latitude);
//}
amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/feign/MultipartSupportConfig.java
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
jcs
.
api
.
feign
;
import
feign.codec.Encoder
;
import
feign.form.spring.SpringFormEncoder
;
import
org.springframework.beans.factory.ObjectFactory
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.boot.autoconfigure.http.HttpMessageConverters
;
import
org.springframework.cloud.openfeign.support.SpringEncoder
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
/**
* @Author: xl
* @Description:
* @Date: 2020/3/30 16:26
*/
@Configuration
public
class
MultipartSupportConfig
{
@Autowired
private
ObjectFactory
<
HttpMessageConverters
>
messageConverters
;
@Bean
public
Encoder
feignFormEncoder
()
{
return
new
SpringFormEncoder
(
new
SpringEncoder
(
messageConverters
));
}
}
//
package com.yeejoin.amos.boot.module.jcs.api.feign;
//
//
import feign.codec.Encoder;
//
import feign.form.spring.SpringFormEncoder;
//
import org.springframework.beans.factory.ObjectFactory;
//
import org.springframework.beans.factory.annotation.Autowired;
//
import org.springframework.boot.autoconfigure.http.HttpMessageConverters;
//
import org.springframework.cloud.openfeign.support.SpringEncoder;
//
import org.springframework.context.annotation.Bean;
//
import org.springframework.context.annotation.Configuration;
//
/
//
**
//
* @Author: xl
//
* @Description:
//
* @Date: 2020/3/30 16:26
//
*/
//
@Configuration
//
public class MultipartSupportConfig {
//
//
@Autowired
//
private ObjectFactory<HttpMessageConverters> messageConverters;
//
//
@Bean
//
public Encoder feignFormEncoder() {
//
return new SpringFormEncoder(new SpringEncoder(messageConverters));
//
}
//
}
amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/service/IFirefightersJacketService.java
View file @
29e66c23
...
...
@@ -16,7 +16,7 @@ import java.util.List;
*/
public
interface
IFirefightersJacketService
{
ResponseModel
<
Page
<
EquipmentOnCarDto
>>
getAirEquipSpecificPage
(
EquipSpecificDto
equipSpecificDto
,
int
current
,
int
size
);
ResponseModel
<
Page
<
Object
>>
getAirEquipSpecificPage
(
EquipSpecificDto
equipSpecificDto
,
int
current
,
int
size
);
boolean
saveOrUpdateBatch
(
Long
firefightersId
,
List
<
EquipmentOnCarDto
>
equipmentOnCarDtos
);
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-command-biz/src/main/java/com/yeejoin/amos/boot/module/command/biz/controller/CommandController.java
View file @
29e66c23
...
...
@@ -11,12 +11,12 @@ import com.yeejoin.amos.boot.module.command.api.dto.SeismometeorologyDto;
import
com.yeejoin.amos.boot.module.command.biz.service.impl.RemoteSecurityService
;
import
com.yeejoin.amos.boot.module.common.api.dto.*
;
import
com.yeejoin.amos.boot.module.common.api.entity.FireTeam
;
import
com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient
;
import
com.yeejoin.amos.boot.module.common.api.service.*
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.*
;
import
com.yeejoin.amos.boot.module.jcs.api.entity.AlertCalled
;
import
com.yeejoin.amos.boot.module.jcs.api.entity.AlertFormValue
;
import
com.yeejoin.amos.boot.module.jcs.api.enums.AlertStageEnums
;
import
com.yeejoin.amos.boot.module.jcs.api.feign.EquipFeignClient
;
import
com.yeejoin.amos.boot.module.jcs.api.service.*
;
import
io.swagger.annotations.Api
;
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/controller/KeySiteController.java
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
common
.
biz
.
controller
;
import
java.util.List
;
import
java.util.Map
;
import
javax.servlet.http.HttpServletRequest
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.yeejoin.amos.boot.biz.common.controller.BaseController
;
import
com.yeejoin.amos.boot.module.common.api.dto.AttachmentDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.KeySiteDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgMenuDto
;
import
com.yeejoin.amos.boot.module.common.api.entity.KeySite
;
import
com.yeejoin.amos.boot.module.common.api.service.IKeySiteService
;
import
com.yeejoin.amos.boot.module.common.api.service.IOrgUsrService
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.KeySiteServiceImpl
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.SourceFileServiceImpl
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.web.bind.annotation.DeleteMapping
;
import
org.springframework.web.bind.annotation.GetMapping
;
...
...
@@ -20,20 +28,9 @@ import org.typroject.tyboot.core.restful.doc.TycloudOperation;
import
org.typroject.tyboot.core.restful.utils.ResponseHelper
;
import
org.typroject.tyboot.core.restful.utils.ResponseModel
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.yeejoin.amos.boot.biz.common.controller.BaseController
;
import
com.yeejoin.amos.boot.module.common.api.dto.AttachmentDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.KeySiteDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgMenuDto
;
import
com.yeejoin.amos.boot.module.common.api.entity.KeySite
;
import
com.yeejoin.amos.boot.module.common.api.service.IKeySiteService
;
import
com.yeejoin.amos.boot.module.common.api.service.IMaintenanceCompanyService
;
import
com.yeejoin.amos.boot.module.common.api.service.IOrgUsrService
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.KeySiteServiceImpl
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
javax.servlet.http.HttpServletRequest
;
import
java.util.List
;
import
java.util.Map
;
/**
* 重点部位
...
...
@@ -55,7 +52,7 @@ public class KeySiteController extends BaseController {
IOrgUsrService
iOrgUsrService
;
@Autowired
IMaintenanceCompanyService
maintenanceCompany
Service
;
SourceFileServiceImpl
sourceFile
Service
;
/**
* 新增重点部位
*
...
...
@@ -106,7 +103,7 @@ public class KeySiteController extends BaseController {
@GetMapping
(
value
=
"find/{sequenceNbr}"
)
@ApiOperation
(
httpMethod
=
"GET"
,
value
=
"根据sequenceNbr查询单个重点部位"
,
notes
=
"根据sequenceNbr查询单个重点部位"
)
public
ResponseModel
<
KeySiteDto
>
selectOne
(
@PathVariable
Long
sequenceNbr
)
{
Map
<
String
,
List
<
AttachmentDto
>>
files
=
maintenanceCompany
Service
.
getAttachments
(
sequenceNbr
);
Map
<
String
,
List
<
AttachmentDto
>>
files
=
sourceFile
Service
.
getAttachments
(
sequenceNbr
);
KeySiteDto
dto
=
keySiteService
.
getSequenceNbr
(
sequenceNbr
);
if
(
files
!=
null
&&
dto
!=
null
)
{
dto
.
setAttachments
(
files
);
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/controller/WaterResourceController.java
View file @
29e66c23
...
...
@@ -5,27 +5,46 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.yeejoin.amos.boot.biz.common.controller.BaseController
;
import
com.yeejoin.amos.boot.biz.common.utils.EnumsUtils
;
import
com.yeejoin.amos.boot.module.common.api.dto.*
;
import
com.yeejoin.amos.boot.module.common.api.entity.*
;
import
com.yeejoin.amos.boot.module.common.api.dto.WaterResourceCraneDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.WaterResourceDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.WaterResourceHydrantDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.WaterResourceIotDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.WaterResourceNaturalDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.WaterResourcePoolDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.WaterResourceTypeDto
;
import
com.yeejoin.amos.boot.module.common.api.entity.WaterResource
;
import
com.yeejoin.amos.boot.module.common.api.entity.WaterResourceCrane
;
import
com.yeejoin.amos.boot.module.common.api.entity.WaterResourceHydrant
;
import
com.yeejoin.amos.boot.module.common.api.entity.WaterResourceIot
;
import
com.yeejoin.amos.boot.module.common.api.entity.WaterResourceNatural
;
import
com.yeejoin.amos.boot.module.common.api.entity.WaterResourcePool
;
import
com.yeejoin.amos.boot.module.common.api.enums.WaterResourceTypeEnum
;
import
com.yeejoin.amos.boot.module.common.api.excel.ExcelUtil
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.*
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.WaterResourceCraneServiceImpl
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.WaterResourceHydrantServiceImpl
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.WaterResourceIotServiceImpl
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.WaterResourceNaturalServiceImpl
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.WaterResourcePoolServiceImpl
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.WaterResourceServiceImpl
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.web.bind.annotation.*
;
import
org.springframework.web.multipart.MultipartFile
;
import
org.springframework.web.bind.annotation.DeleteMapping
;
import
org.springframework.web.bind.annotation.GetMapping
;
import
org.springframework.web.bind.annotation.PathVariable
;
import
org.springframework.web.bind.annotation.PostMapping
;
import
org.springframework.web.bind.annotation.PutMapping
;
import
org.springframework.web.bind.annotation.RequestBody
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RequestParam
;
import
org.springframework.web.bind.annotation.RestController
;
import
org.typroject.tyboot.core.foundation.enumeration.UserType
;
import
org.typroject.tyboot.core.foundation.utils.ValidationUtil
;
import
org.typroject.tyboot.core.rdbms.annotation.Condition
;
import
org.typroject.tyboot.core.rdbms.annotation.Operator
;
import
org.typroject.tyboot.core.restful.doc.TycloudOperation
;
import
org.typroject.tyboot.core.restful.utils.ResponseHelper
;
import
org.typroject.tyboot.core.restful.utils.ResponseModel
;
import
javax.servlet.http.HttpServletResponse
;
import
java.util.ArrayList
;
import
java.util.List
;
import
java.util.Optional
;
...
...
@@ -308,15 +327,14 @@ public class WaterResourceController extends BaseController {
@ApiOperation
(
httpMethod
=
"GET"
,
value
=
"分页查询"
,
notes
=
"分页查询"
)
public
ResponseModel
<
Page
<
WaterResourceDto
>>
queryForPage
(
@RequestParam
(
value
=
"current"
)
int
current
,
@RequestParam
(
value
=
"size"
)
int
size
,
String
name
,
ArrayList
<
Long
>
belongBuildingId
,
@RequestParam
(
value
=
"belongBuildingId"
,
required
=
false
)
ArrayList
<
Long
>
belongBuildingId
,
Long
belongFightingSystemId
,
Long
sequenceNbr
,
String
resourceType
)
{
Page
<
WaterResourceDto
>
page
=
new
Page
<>();
page
.
setCurrent
(
current
);
page
.
setSize
(
size
);
return
ResponseHelper
.
buildResponse
(
waterResourceServiceImpl
.
queryForWaterResourcePage
(
page
,
name
,
resourceType
,
belongBuildingId
,
belongFightingSystemId
,
sequenceNbr
,
true
));
resourceType
,
belongBuildingId
,
belongFightingSystemId
,
sequenceNbr
));
}
/**
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/KeySiteServiceImpl.java
View file @
29e66c23
...
...
@@ -7,6 +7,7 @@ import java.util.Map;
import
java.util.Set
;
import
java.util.stream.Collectors
;
import
com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient
;
import
org.apache.commons.lang3.ObjectUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
...
...
@@ -32,7 +33,6 @@ import com.yeejoin.amos.boot.module.common.api.entity.SourceFile;
import
com.yeejoin.amos.boot.module.common.api.mapper.KeySiteMapper
;
import
com.yeejoin.amos.boot.module.common.api.mapper.OrgUsrMapper
;
import
com.yeejoin.amos.boot.module.common.api.service.IKeySiteService
;
import
com.yeejoin.amos.boot.module.jcs.api.feign.EquipFeignClient
;
/**
* 重点部位服务实现类
...
...
@@ -63,6 +63,7 @@ public class KeySiteServiceImpl extends BaseService<KeySiteDto, KeySite, KeySite
keySite
.
getFireEnduranceRate
(),
keySite
.
getUseNature
(),
keySite
.
getFireFacilitiesInfo
());
}
@Override
public
List
<
Object
>
getBuildTree
()
{
ResponseModel
<
Object
>
response
=
equipFeignClient
.
getBuildingTree
();
if
(
200
==
response
.
getStatus
()
&&
ObjectUtils
.
isNotEmpty
(
response
.
getResult
()))
{
...
...
@@ -150,6 +151,7 @@ public class KeySiteServiceImpl extends BaseService<KeySiteDto, KeySite, KeySite
return
sourceFiles
;
}
@Override
@Transactional
(
rollbackFor
=
Exception
.
class
)
public
boolean
update
(
KeySiteDto
keySite
)
{
KeySite
entity
=
new
KeySite
();
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/LinkageUnitServiceImpl.java
View file @
29e66c23
...
...
@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.common.biz.service.impl;
import
com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.google.common.collect.Lists
;
import
com.yeejoin.amos.boot.biz.common.utils.TreeParser
;
import
com.yeejoin.amos.boot.module.common.api.dto.DutyCarDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.LinkageUnitZhDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.RequestData
;
...
...
@@ -140,15 +141,7 @@ public class LinkageUnitServiceImpl extends BaseService<LinkageUnitDto, LinkageU
}
public
static
String
getUnitCodeStr
()
{
int
length
=
6
;
String
str
=
"abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789"
;
Random
random
=
new
Random
();
StringBuffer
sb
=
new
StringBuffer
();
for
(
int
i
=
0
;
i
<
length
;
i
++)
{
int
number
=
random
.
nextInt
(
62
);
sb
.
append
(
str
.
charAt
(
number
));
}
return
sb
.
toString
();
return
TreeParser
.
genTreeCode
();
}
@Override
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/MaintenanceCompanyServiceImpl.java
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
common
.
biz
.
service
.
impl
;
import
java.util.ArrayList
;
import
java.util.Arrays
;
import
java.util.HashMap
;
import
java.util.Iterator
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Map.Entry
;
import
java.util.function.Function
;
import
java.util.stream.Collectors
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
org.springframework.transaction.annotation.Transactional
;
import
org.springframework.util.ObjectUtils
;
import
org.typroject.tyboot.core.foundation.context.RequestContext
;
import
org.typroject.tyboot.core.foundation.utils.Bean
;
import
org.typroject.tyboot.core.foundation.utils.ValidationUtil
;
import
org.typroject.tyboot.core.rdbms.service.BaseService
;
import
org.typroject.tyboot.core.restful.exception.instance.BadRequest
;
import
com.alibaba.fastjson.JSONArray
;
import
com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper
;
import
com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.baomidou.mybatisplus.core.toolkit.Sequence
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.google.common.base.Joiner
;
import
com.google.common.collect.Lists
;
import
com.google.common.collect.Maps
;
import
com.yeejoin.amos.boot.
module.common.api.dto.AttachmentDto
;
import
com.yeejoin.amos.boot.
biz.common.utils.TreeParser
;
import
com.yeejoin.amos.boot.module.common.api.dto.MaintenanceCompanyDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.MaintenancePersonExcleDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgUsrDto
;
import
com.yeejoin.amos.boot.module.common.api.entity.DynamicFormColumn
;
import
com.yeejoin.amos.boot.module.common.api.entity.DynamicFormInstance
;
import
com.yeejoin.amos.boot.module.common.api.entity.MaintenanceCompany
;
import
com.yeejoin.amos.boot.module.common.api.entity.SourceFile
;
import
com.yeejoin.amos.boot.module.common.api.enums.OrgPersonEnum
;
import
com.yeejoin.amos.boot.module.common.api.mapper.DynamicFormInstanceMapper
;
import
com.yeejoin.amos.boot.module.common.api.mapper.MaintenanceCompanyMapper
;
import
com.yeejoin.amos.boot.module.common.api.service.IMaintenanceCompanyService
;
import
com.yeejoin.amos.boot.module.common.api.service.IOrgUsrService
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
org.springframework.transaction.annotation.Transactional
;
import
org.springframework.util.ObjectUtils
;
import
org.typroject.tyboot.core.foundation.context.RequestContext
;
import
org.typroject.tyboot.core.foundation.utils.Bean
;
import
org.typroject.tyboot.core.foundation.utils.ValidationUtil
;
import
org.typroject.tyboot.core.rdbms.service.BaseService
;
import
org.typroject.tyboot.core.restful.exception.instance.BadRequest
;
import
java.util.ArrayList
;
import
java.util.Arrays
;
import
java.util.HashMap
;
import
java.util.Iterator
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Map.Entry
;
import
java.util.function.Function
;
import
java.util.stream.Collectors
;
/**
* 维保单位服务实现类
...
...
@@ -107,7 +106,9 @@ public class MaintenanceCompanyServiceImpl
@Transactional
(
rollbackFor
=
Exception
.
class
)
public
boolean
saveCompanyDetail
(
MaintenanceCompany
maintenanceCompany
)
{
Long
instanceId
=
saveDynamicFormList
(
maintenanceCompany
);
maintenanceCompany
.
setCode
(
OrgUsrServiceImpl
.
getOrgCodeStr
());
// 设置单位code
setTargetObjCode
(
maintenanceCompany
);
maintenanceCompany
.
setOrgCode
(
null
);
maintenanceCompany
.
setBizCode
(
sequence
.
nextId
()
+
""
);
maintenanceCompany
.
setInstanceId
(
instanceId
);
...
...
@@ -121,19 +122,30 @@ public class MaintenanceCompanyServiceImpl
e
.
printStackTrace
();
return
false
;
}
return
true
;
}
/**
* 设置单位code
*
* @param targetObj
*/
private
void
setTargetObjCode
(
MaintenanceCompany
targetObj
)
{
MaintenanceCompany
parent
=
getById
(
targetObj
.
getParentId
());
if
(!
ValidationUtil
.
isEmpty
(
parent
))
{
// 当前的code为上级单位code+6位随机数
targetObj
.
setCode
(
parent
.
getCode
()
+
TreeParser
.
genTreeCode
());
}
else
{
targetObj
.
setCode
(
TreeParser
.
genTreeCode
());
}
}
@Override
public
boolean
savePersonDetail
(
MaintenanceCompany
maintenanceCompany
)
{
Long
instanceId
=
saveDynamicFormList
(
maintenanceCompany
);
Long
parentId
=
maintenanceCompany
.
getParentId
();
MaintenanceCompany
parent
=
maintenanceCompanyMapper
.
selectById
(
parentId
);
if
(
StringUtils
.
isBlank
(
maintenanceCompany
.
getCode
()))
{
// 添加人员时,当前的code 为单位code+6位随机数
maintenanceCompany
.
setCode
(
parent
.
getCode
()
+
OrgUsrServiceImpl
.
getOrgCodeStr
());
}
// 设置人员code
setTargetObjCode
(
maintenanceCompany
);
maintenanceCompany
.
setOrgCode
(
null
);
if
(
ValidationUtil
.
isEmpty
(
maintenanceCompany
.
getBizCode
()))
{
maintenanceCompany
.
setBizCode
(
sequence
.
nextId
()
+
""
);
...
...
@@ -171,9 +183,7 @@ public class MaintenanceCompanyServiceImpl
public
boolean
saveDepartmentDetail
(
MaintenanceCompany
maintenanceCompany
)
{
Long
instanceId
=
saveDynamicFormList
(
maintenanceCompany
);
Long
parentId
=
maintenanceCompany
.
getParentId
();
MaintenanceCompany
parent
=
maintenanceCompanyMapper
.
selectById
(
parentId
);
// 添加人员时,当前的orgcode 为单位code+6位随机数
maintenanceCompany
.
setCode
(
parent
.
getCode
()
+
OrgUsrServiceImpl
.
getOrgCodeStr
());
setTargetObjCode
(
maintenanceCompany
);
maintenanceCompany
.
setOrgCode
(
null
);
maintenanceCompany
.
setBizCode
(
sequence
.
nextId
()
+
""
);
maintenanceCompany
.
setInstanceId
(
instanceId
);
...
...
@@ -192,7 +202,6 @@ public class MaintenanceCompanyServiceImpl
@Override
public
boolean
deleteById
(
Long
sequenceNbr
)
{
MaintenanceCompany
maintenanceCompany
=
maintenanceCompanyMapper
.
selectById
(
sequenceNbr
);
if
(
ObjectUtils
.
isEmpty
(
maintenanceCompany
))
{
return
false
;
...
...
@@ -209,10 +218,8 @@ public class MaintenanceCompanyServiceImpl
maintenanceCompany
.
getInstanceId
()));
dyInstance
.
forEach
(
i
->
i
.
setIsDelete
(
true
));
dynamicFormInstanceService
.
updateBatchById
(
dyInstance
);
return
true
;
}
return
false
;
}
...
...
@@ -228,7 +235,7 @@ public class MaintenanceCompanyServiceImpl
@Override
public
boolean
checkPersonCodeExists
(
String
code
)
{
LambdaQueryWrapper
<
MaintenanceCompany
>
wrapper
=
new
LambdaQueryWrapper
<
MaintenanceCompany
>();
wrapper
.
eq
(
MaintenanceCompany:
:
getCode
,
code
);
wrapper
.
eq
(
MaintenanceCompany:
:
get
Biz
Code
,
code
);
MaintenanceCompany
detail
=
maintenanceCompanyMapper
.
selectOne
(
wrapper
);
if
(
ObjectUtils
.
isEmpty
(
detail
))
{
return
true
;
...
...
@@ -271,14 +278,12 @@ public class MaintenanceCompanyServiceImpl
}
});
return
dynamicFormList
;
}
@Override
public
List
<
MaintenancePersonExcleDto
>
exportToMaintenancePersonExcel
()
{
List
<
Map
<
String
,
Object
>>
list
=
this
.
getAllMaintenanceList
(
PERSON
);
return
JSONArray
.
parseArray
(
JSONArray
.
toJSONString
(
list
),
MaintenancePersonExcleDto
.
class
);
}
/**
...
...
@@ -400,73 +405,64 @@ public class MaintenanceCompanyServiceImpl
}
Map
<
String
,
Object
>
mainMap
=
Bean
.
BeantoMap
(
maintenanceCompany
);
Map
<
String
,
Object
>
dynamicMap
=
dynamicFormInstanceService
.
getOneMap
(
maintenanceCompany
.
getInstanceId
(),
type
);
mainMap
.
put
(
"attachments"
,
getAttachments
(
maintenanceCompany
.
getSequenceNbr
()));
mainMap
.
put
(
"attachments"
,
sourceFileService
.
getAttachments
(
maintenanceCompany
.
getSequenceNbr
()));
mainMap
.
put
(
"dynamicFormValue"
,
dynamicMap
);
return
mainMap
;
}
@Override
public
Map
<
String
,
List
<
AttachmentDto
>>
getAttachments
(
Long
sequenceNbr
)
{
Map
<
String
,
List
<
AttachmentDto
>>
attachmentMap
=
Maps
.
newHashMap
();
List
<
SourceFile
>
sourceFileList
=
sourceFileService
.
findBySourceId
(
sequenceNbr
);
if
(!
ValidationUtil
.
isEmpty
(
sourceFileList
))
{
List
<
AttachmentDto
>
attachmentList
=
sourceFile2AttachmentList
(
sourceFileList
);
attachmentMap
=
attachmentList
.
stream
().
collect
(
Collectors
.
groupingBy
(
AttachmentDto:
:
getType
));
}
return
attachmentMap
;
}
private
List
<
AttachmentDto
>
sourceFile2AttachmentList
(
List
<
SourceFile
>
sourceFileList
)
{
List
<
AttachmentDto
>
attachmentDtoList
=
Lists
.
newArrayList
();
if
(!
ValidationUtil
.
isEmpty
(
sourceFileList
))
{
sourceFileList
.
forEach
(
s
->
{
AttachmentDto
a
=
new
AttachmentDto
();
a
.
setName
(
s
.
getFileName
());
a
.
setUrl
(
s
.
getFilePath
());
a
.
setType
(
s
.
getFileCategory
());
attachmentDtoList
.
add
(
a
);
});
}
return
attachmentDtoList
;
}
@Override
@Transactional
(
rollbackFor
=
Exception
.
class
)
public
boolean
updateMaintenanceCompanyDetail
(
MaintenanceCompany
model
)
throws
Exception
{
return
updateMaintenanceDetail
(
model
,
COMPANY
);
}
public
boolean
updateMaintenanceDetail
(
MaintenanceCompany
model
,
String
type
)
throws
Exception
{
MaintenanceCompanyDto
maintenanceCompany
=
this
.
queryBySeq
(
model
.
getSequenceNbr
());
// try {
//// if (maintenanceCompany != null) {
//// dynamicFormInstanceService.remove(new LambdaQueryWrapper<DynamicFormInstance>()
//// .eq(DynamicFormInstance::getInstanceId, maintenanceCompany.getInstanceId()));
//// }
// } catch (Exception e) {
// return false;
// }
this
.
updateDetail
(
model
,
type
);
return
true
;
return
updateDetail
(
model
,
type
);
}
public
boolean
updateDetail
(
MaintenanceCompany
model
,
String
type
)
throws
Exception
{
// 更新动态表单数据
//
1、
更新动态表单数据
iOrgUsrService
.
updateDynamicFormInstance
(
model
.
getInstanceId
(),
model
.
getDynamicFormValue
());
// 更新主表数据
// 2、更新单位及子单位code
updateCode
(
model
);
// 3、更新主表数据
model
.
setType
(
type
);
try
{
this
.
updateById
(
model
);
// 更新附件
sourceFileService
.
saveAttachments
(
model
.
getSequenceNbr
(),
model
.
getAttachments
());
}
catch
(
Exception
e
)
{
e
.
printStackTrace
();
return
false
;
this
.
updateById
(
model
);
if
(
ValidationUtil
.
isEmpty
(
model
.
getParentId
()))
{
update
(
new
LambdaUpdateWrapper
<
MaintenanceCompany
>().
set
(
MaintenanceCompany:
:
getParentId
,
null
).
eq
(
MaintenanceCompany:
:
getSequenceNbr
,
model
.
getSequenceNbr
()));
}
// 4、更新附件
sourceFileService
.
saveAttachments
(
model
.
getSequenceNbr
(),
model
.
getAttachments
());
return
true
;
}
/**
* 更新单位及子单位code
*
* @return company 维保单位/部门/人员
*/
public
void
updateCode
(
MaintenanceCompany
company
)
{
MaintenanceCompany
parent
=
getById
(
company
.
getParentId
());
// 新父节点的code
String
parentCode
=
""
;
// 父节点不为空
if
(!
ValidationUtil
.
isEmpty
(
parent
))
{
parentCode
=
parent
.
getCode
();
}
// 旧父节点的code
String
oldParentCode
=
company
.
getCode
().
substring
(
0
,
company
.
getCode
().
length
()
-
TreeParser
.
CODE_LENGTH
);
List
<
MaintenanceCompany
>
children
=
list
(
new
LambdaQueryWrapper
<
MaintenanceCompany
>().
eq
(
MaintenanceCompany:
:
getIsDelete
,
false
).
likeRight
(
MaintenanceCompany:
:
getCode
,
company
.
getCode
()).
ne
(
MaintenanceCompany:
:
getSequenceNbr
,
company
.
getSequenceNbr
()));
if
(!
ValidationUtil
.
isEmpty
(
children
))
{
String
finalParentCode
=
parentCode
;
children
.
forEach
(
i
->
{
i
.
setCode
(
i
.
getCode
().
replaceFirst
(
oldParentCode
,
finalParentCode
));
});
updateBatchById
(
children
);
}
company
.
setCode
(
company
.
getCode
().
replaceFirst
(
oldParentCode
,
parentCode
));
}
@Override
@Transactional
(
rollbackFor
=
Exception
.
class
)
public
boolean
updateMaintenancePersonDetail
(
MaintenanceCompany
model
)
throws
Exception
{
...
...
@@ -496,36 +492,12 @@ public class MaintenanceCompanyServiceImpl
@Override
public
List
<
MaintenanceCompany
>
getDepartmentAndPersonTree
(
long
sequenceNbr
)
{
// List<MaintenanceCompany> departmentAllList =new
// ArrayList<MaintenanceCompany>();
List
<
MaintenanceCompany
>
departmentList
=
getDepartmentList
(
sequenceNbr
);
// departmentAllList.addAll(departmentList);
// departmentAllList = getDepartmentAllList(departmentAllList,departmentList);
// for (MaintenanceCompany map : departmentList) {
// Long departmentSequenceNbr=map.getSequenceNbr();
// departmentAllList.addAll(getPersonList(departmentSequenceNbr));
// }
// if (departmentAllList == null) {
// return new ArrayList<>();
// }
// departmentAllList = departmentAllList.stream().filter(o -> !ObjectUtils.isEmpty(o)).collect(Collectors.toList());
// return departmentAllList;
if
(
departmentList
==
null
)
{
return
new
ArrayList
<>();
}
return
departmentList
.
stream
().
filter
(
o
->
!
ObjectUtils
.
isEmpty
(
o
)).
collect
(
Collectors
.
toList
());
}
// public List<MaintenanceCompany> getDepartmentAllList(List<MaintenanceCompany> departmentAllList,List<MaintenanceCompany> departmentList){
// for (MaintenanceCompany map : departmentList) {
// long chrildSequenceNbr=map.getSequenceNbr();
// List<MaintenanceCompany> chrlidList= getDepartmentList(chrildSequenceNbr);
// if(chrlidList.size()>0) {
// departmentAllList.addAll(chrlidList);
// getDepartmentAllList(departmentAllList,chrlidList);
// }
// }
// return departmentAllList;
// }
@Override
public
List
<
MaintenanceCompany
>
getDepartmentList
(
long
sequenceNbr
)
{
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/OrgUsrServiceImpl.java
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
common
.
biz
.
service
.
impl
;
import
java.lang.reflect.Method
;
import
java.text.SimpleDateFormat
;
import
java.util.ArrayList
;
import
java.util.Collection
;
import
java.util.Date
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Random
;
import
java.util.Set
;
import
java.util.stream.Collectors
;
import
javax.annotation.Resource
;
import
com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper
;
import
com.yeejoin.amos.boot.module.common.api.dto.*
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
org.springframework.util.ObjectUtils
;
import
org.typroject.tyboot.core.foundation.utils.Bean
;
import
org.typroject.tyboot.core.rdbms.service.BaseService
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.yeejoin.amos.boot.biz.common.constants.CommonConstant
;
import
com.yeejoin.amos.boot.biz.common.utils.TreeParser
;
import
com.yeejoin.amos.boot.module.common.api.dto.CompanyDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.CompanyPerson
;
import
com.yeejoin.amos.boot.module.common.api.dto.DynamicFormInstanceDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.ESOrgUsrDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.FormValue
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgDepartmentDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgDepartmentFormDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgMenuDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgPersonDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgPersonExcelDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgPersonFormDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgUsrDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgUsrFormDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.OrgUsrzhDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.RequestData
;
import
com.yeejoin.amos.boot.module.common.api.entity.DynamicFormColumn
;
import
com.yeejoin.amos.boot.module.common.api.entity.DynamicFormInstance
;
import
com.yeejoin.amos.boot.module.common.api.entity.OrgUsr
;
...
...
@@ -36,6 +29,25 @@ import com.yeejoin.amos.boot.module.common.api.mapper.OrgUsrMapper;
import
com.yeejoin.amos.boot.module.common.api.service.IOrgUsrService
;
import
com.yeejoin.amos.feign.privilege.Privilege
;
import
com.yeejoin.amos.feign.privilege.model.AgencyUserModel
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
org.springframework.util.ObjectUtils
;
import
org.typroject.tyboot.core.foundation.utils.Bean
;
import
org.typroject.tyboot.core.rdbms.service.BaseService
;
import
javax.annotation.Resource
;
import
java.lang.reflect.Method
;
import
java.text.SimpleDateFormat
;
import
java.util.ArrayList
;
import
java.util.Collection
;
import
java.util.Date
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Set
;
import
java.util.stream.Collectors
;
/**
* 机构/部门/人员表 服务实现类
...
...
@@ -765,15 +777,7 @@ public class OrgUsrServiceImpl extends BaseService<OrgUsrDto, OrgUsr, OrgUsrMapp
public
static
String
getOrgCodeStr
()
{
int
length
=
6
;
String
str
=
"abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789"
;
Random
random
=
new
Random
();
StringBuffer
sb
=
new
StringBuffer
();
for
(
int
i
=
0
;
i
<
length
;
i
++)
{
int
number
=
random
.
nextInt
(
62
);
sb
.
append
(
str
.
charAt
(
number
));
}
return
sb
.
toString
();
return
TreeParser
.
genTreeCode
();
}
public
void
importByExcel
(
List
<
OrgPersonExcelDto
>
list
)
{
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/SourceFileServiceImpl.java
View file @
29e66c23
...
...
@@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import
com.baomidou.mybatisplus.core.toolkit.Sequence
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.google.common.collect.Lists
;
import
com.google.common.collect.Maps
;
import
com.yeejoin.amos.boot.module.common.api.dto.AttachmentDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.SourceFileDto
;
import
com.yeejoin.amos.boot.module.common.api.entity.SourceFile
;
...
...
@@ -22,6 +23,7 @@ import java.util.Collections;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Optional
;
import
java.util.stream.Collectors
;
/**
* 公共附件服务实现类
...
...
@@ -108,4 +110,34 @@ public class SourceFileServiceImpl extends BaseService<SourceFileDto, SourceFile
}
return
sourceFiles
;
}
/**
* 获取附件
*
* @param sourceId
* @return
*/
public
Map
<
String
,
List
<
AttachmentDto
>>
getAttachments
(
Long
sourceId
)
{
Map
<
String
,
List
<
AttachmentDto
>>
attachmentMap
=
Maps
.
newHashMap
();
List
<
SourceFile
>
sourceFileList
=
findBySourceId
(
sourceId
);
if
(!
ValidationUtil
.
isEmpty
(
sourceFileList
))
{
List
<
AttachmentDto
>
attachmentList
=
sourceFile2AttachmentList
(
sourceFileList
);
attachmentMap
=
attachmentList
.
stream
().
collect
(
Collectors
.
groupingBy
(
AttachmentDto:
:
getType
));
}
return
attachmentMap
;
}
private
List
<
AttachmentDto
>
sourceFile2AttachmentList
(
List
<
SourceFile
>
sourceFileList
)
{
List
<
AttachmentDto
>
attachmentDtoList
=
Lists
.
newArrayList
();
if
(!
ValidationUtil
.
isEmpty
(
sourceFileList
))
{
sourceFileList
.
forEach
(
s
->
{
AttachmentDto
a
=
new
AttachmentDto
();
a
.
setName
(
s
.
getFileName
());
a
.
setUrl
(
s
.
getFilePath
());
a
.
setType
(
s
.
getFileCategory
());
attachmentDtoList
.
add
(
a
);
});
}
return
attachmentDtoList
;
}
}
\ No newline at end of file
amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/WaterResourceServiceImpl.java
View file @
29e66c23
...
...
@@ -14,6 +14,7 @@ import org.apache.commons.lang3.StringUtils;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
org.typroject.tyboot.core.foundation.utils.ValidationUtil
;
import
org.typroject.tyboot.core.rdbms.annotation.Condition
;
import
org.typroject.tyboot.core.rdbms.annotation.Operator
;
import
org.typroject.tyboot.core.rdbms.service.BaseService
;
...
...
@@ -55,10 +56,11 @@ public class WaterResourceServiceImpl extends BaseService<WaterResourceDto, Wate
@Condition
(
Operator
.
eq
)
String
resourceType
,
@Condition
(
Operator
.
in
)
ArrayList
<
Long
>
belongBuildingId
,
@Condition
(
Operator
.
eq
)
Long
belongFightingSystemId
,
@Condition
(
Operator
.
eq
)
Long
sequenceNbr
,
@Condition
(
Operator
.
eq
)
Boolean
isDelete
)
{
return
this
.
queryForPage
(
page
,
null
,
false
,
name
,
resourceType
,
belongBuildingId
,
belongFightingSystemId
,
sequenceNbr
,
isDelete
);
@Condition
(
Operator
.
eq
)
Long
sequenceNbr
)
{
// return this.queryForPage(page, null, false, name, resourceType, belongBuildingId, belongFightingSystemId,
// sequenceNbr, isDelete);
return
this
.
waterResourceMapper
.
getWaterResourcePageByParams
(
page
,
name
,
resourceType
,
belongBuildingId
,
belongFightingSystemId
,
sequenceNbr
);
}
/**
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/controller/ExcelController.java
View file @
29e66c23
...
...
@@ -313,7 +313,7 @@ public class ExcelController extends BaseController {
maintenanceCompany
.
setParentId
(
getParentId
);
}
if
(
maintenanceCompanyService
.
checkPersonCodeExists
(
maintenancePersonExcleDto
.
getCode
()))
{
maintenanceCompany
.
setCode
(
maintenancePersonExcleDto
.
getCode
());
maintenanceCompany
.
set
Biz
Code
(
maintenancePersonExcleDto
.
getCode
());
}
else
{
maintenanceCompany
.
setCode
(
null
);
}
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/controller/FirefightersJacketController.java
View file @
29e66c23
...
...
@@ -178,7 +178,7 @@ public class FirefightersJacketController extends BaseController {
@TycloudOperation
(
ApiLevel
=
UserType
.
AGENCY
)
@ApiOperation
(
value
=
"人员装备列表"
)
@RequestMapping
(
value
=
"/airEquipSpecificPage"
,
method
=
RequestMethod
.
GET
)
public
ResponseModel
<
Page
<
EquipmentOnCarDto
>>
getAirEquipSpecificPage
(
int
current
,
int
size
,
public
ResponseModel
<
Page
<
Object
>>
getAirEquipSpecificPage
(
int
current
,
int
size
,
EquipSpecificDto
equipSpecificDto
)
throws
Exception
{
return
iFirefightersJacketService
.
getAirEquipSpecificPage
(
equipSpecificDto
,
current
,
size
);
}
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/controller/PowerTransferController.java
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
jcs
.
biz
.
controller
;
import
java.util.Arrays
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferSimpleDto
;
import
com.yeejoin.amos.boot.module.jcs.api.feign.EquipFeignClient
;
import
io.swagger.annotations.ApiParam
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.transaction.annotation.Transactional
;
import
org.springframework.web.bind.annotation.*
;
import
org.typroject.tyboot.core.foundation.enumeration.UserType
;
import
org.typroject.tyboot.core.restful.doc.TycloudOperation
;
import
org.typroject.tyboot.core.restful.utils.ResponseHelper
;
import
org.typroject.tyboot.core.restful.utils.ResponseModel
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.baomidou.mybatisplus.core.metadata.IPage
;
import
com.baomidou.mybatisplus.extension.plugins.pagination.Page
;
import
com.yeejoin.amos.boot.biz.common.controller.BaseController
;
import
com.yeejoin.amos.boot.biz.common.utils.NameUtils
;
import
com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferSimpleDto
;
import
com.yeejoin.amos.boot.module.jcs.api.entity.PowerTransfer
;
import
com.yeejoin.amos.boot.module.jcs.biz.service.impl.PowerTransferServiceImpl
;
import
com.yeejoin.amos.feign.privilege.model.AgencyUserModel
;
import
io.swagger.annotations.Api
;
import
io.swagger.annotations.ApiOperation
;
import
io.swagger.annotations.ApiParam
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.web.bind.annotation.GetMapping
;
import
org.springframework.web.bind.annotation.PathVariable
;
import
org.springframework.web.bind.annotation.RequestBody
;
import
org.springframework.web.bind.annotation.RequestMapping
;
import
org.springframework.web.bind.annotation.RequestMethod
;
import
org.springframework.web.bind.annotation.RequestParam
;
import
org.springframework.web.bind.annotation.RestController
;
import
org.typroject.tyboot.core.foundation.enumeration.UserType
;
import
org.typroject.tyboot.core.restful.doc.TycloudOperation
;
import
org.typroject.tyboot.core.restful.utils.ResponseHelper
;
import
org.typroject.tyboot.core.restful.utils.ResponseModel
;
import
java.util.Arrays
;
/**
* 力量调派
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/AlertSubmittedServiceImpl.java
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
jcs
.
biz
.
service
.
impl
;
import
java.lang.reflect.Field
;
import
java.util.*
;
import
java.util.stream.Collectors
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.*
;
import
com.yeejoin.amos.boot.module.jcs.api.mapper.PowerTransferCompanyMapper
;
import
io.swagger.annotations.ApiModelProperty
;
import
org.apache.commons.lang3.ObjectUtils
;
import
org.eclipse.paho.client.mqttv3.MqttException
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Value
;
import
org.springframework.stereotype.Service
;
import
org.springframework.transaction.annotation.Transactional
;
import
org.typroject.tyboot.component.emq.EmqKeeper
;
import
org.typroject.tyboot.core.foundation.context.RequestContext
;
import
org.typroject.tyboot.core.foundation.utils.StringUtil
;
import
org.typroject.tyboot.core.foundation.utils.ValidationUtil
;
import
org.typroject.tyboot.core.rdbms.service.BaseService
;
import
com.alibaba.fastjson.JSONObject
;
import
com.baomidou.mybatisplus.core.conditions.query.QueryWrapper
;
import
com.google.common.collect.Lists
;
...
...
@@ -29,8 +9,22 @@ import com.yeejoin.amos.boot.biz.common.utils.RedisKey;
import
com.yeejoin.amos.boot.biz.common.utils.RedisUtils
;
import
com.yeejoin.amos.boot.module.common.api.dto.FormValue
;
import
com.yeejoin.amos.boot.module.common.api.entity.DataDictionary
;
import
com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.DataDictionaryServiceImpl
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledObjsDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledRo
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedExtDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedSMSDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedZHDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.CarStatusInfoDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.InstructionsZHDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferCompanyDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferCompanyZHDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.SchedulingReportingDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.TemplateDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.TemplateExtendDto
;
import
com.yeejoin.amos.boot.module.jcs.api.entity.AlertCalled
;
import
com.yeejoin.amos.boot.module.jcs.api.entity.AlertFormValue
;
import
com.yeejoin.amos.boot.module.jcs.api.entity.AlertSubmitted
;
...
...
@@ -41,12 +35,36 @@ import com.yeejoin.amos.boot.module.jcs.api.enums.AlertSchedulingTypeEnum;
import
com.yeejoin.amos.boot.module.jcs.api.enums.AlertSubmitTypeEnum
;
import
com.yeejoin.amos.boot.module.jcs.api.enums.FireCarStatusEnum
;
import
com.yeejoin.amos.boot.module.jcs.api.enums.SubmissionMethodEnum
;
import
com.yeejoin.amos.boot.module.jcs.api.feign.EquipFeignClient
;
import
com.yeejoin.amos.boot.module.jcs.api.mapper.AlertSubmittedMapper
;
import
com.yeejoin.amos.boot.module.jcs.api.mapper.PowerTransferCompanyMapper
;
import
com.yeejoin.amos.boot.module.jcs.api.service.IAlertSubmittedObjectService
;
import
com.yeejoin.amos.boot.module.jcs.api.service.IAlertSubmittedService
;
import
com.yeejoin.amos.boot.module.jcs.biz.rule.action.AlertCalledAction
;
import
com.yeejoin.amos.component.rule.config.RuleConfig
;
import
org.apache.commons.lang3.ObjectUtils
;
import
org.eclipse.paho.client.mqttv3.MqttException
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Value
;
import
org.springframework.stereotype.Service
;
import
org.springframework.transaction.annotation.Transactional
;
import
org.typroject.tyboot.component.emq.EmqKeeper
;
import
org.typroject.tyboot.core.foundation.context.RequestContext
;
import
org.typroject.tyboot.core.foundation.utils.StringUtil
;
import
org.typroject.tyboot.core.foundation.utils.ValidationUtil
;
import
org.typroject.tyboot.core.rdbms.service.BaseService
;
import
java.lang.reflect.Field
;
import
java.util.ArrayList
;
import
java.util.Comparator
;
import
java.util.Date
;
import
java.util.HashMap
;
import
java.util.HashSet
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Optional
;
import
java.util.Set
;
import
java.util.stream.Collectors
;
/**
* 警情报送记录 服务实现类
...
...
@@ -92,6 +110,7 @@ public class AlertSubmittedServiceImpl extends BaseService<AlertSubmittedDto, Al
@Autowired
AlertSubmittedMapper
alertSubmittedMapper
;
@Autowired
PowerTransferCompanyMapper
powerTransferCompanyMapper
;
...
...
@@ -338,7 +357,7 @@ public class AlertSubmittedServiceImpl extends BaseService<AlertSubmittedDto, Al
// 查询本次警情调派的车辆
List
<
String
>
transferCarIdList
=
powerTransferService
.
queryTransferCarIdsByAlertCalledId
(
alertSubmittedDto
.
getAlertCalledId
());
List
<
CarStatusInfoDto
>
carStatusInfoDtoList
=
Lists
.
newArrayList
();
List
<
Object
>
carStatusInfoDtoList
=
Lists
.
newArrayList
();
if
(!
ValidationUtil
.
isEmpty
(
transferCarIdList
))
{
transferCarIdList
.
forEach
(
carId
->
{
CarStatusInfoDto
carStatusInfo
=
new
CarStatusInfoDto
();
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/DataSourcesImpl.java
View file @
29e66c23
...
...
@@ -7,6 +7,7 @@ import java.util.stream.Collectors;
import
javax.annotation.Resource
;
import
com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Value
;
...
...
@@ -41,7 +42,6 @@ import com.yeejoin.amos.boot.module.common.api.service.IKeySiteService;
import
com.yeejoin.amos.boot.module.common.api.service.IMaintenanceCompanyService
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.FirefightersServiceImpl
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl
;
import
com.yeejoin.amos.boot.module.jcs.api.feign.EquipFeignClient
;
@Service
public
class
DataSourcesImpl
implements
DataSources
{
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/EquipmentServiceImpl.java
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
jcs
.
biz
.
service
.
impl
;
import
com.baomidou.mybatisplus.core.toolkit.BeanUtils
;
import
com.google.common.collect.Lists
;
import
com.yeejoin.amos.boot.biz.common.utils.MenuFrom
;
import
com.yeejoin.amos.boot.biz.common.utils.TreeParser
;
import
com.yeejoin.amos.boot.module.common.api.dto.WaterResourceDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.WaterResourceTypeDto
;
import
com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.WaterResourceServiceImpl
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.FireSystemDto
;
import
com.yeejoin.amos.boot.module.jcs.api.feign.EquipFeignClient
;
import
org.apache.commons.lang3.StringUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
org.springframework.util.StopWatch
;
import
org.typroject.tyboot.core.foundation.utils.ValidationUtil
;
import
org.typroject.tyboot.core.restful.utils.ResponseModel
;
import
java.util.ArrayList
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Timer
;
/**
* @author DELL
...
...
@@ -29,6 +22,7 @@ public class EquipmentServiceImpl {
@Autowired
EquipFeignClient
equipFeignClient
;
@Autowired
WaterResourceServiceImpl
waterResourceServiceImpl
;
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/FireTeamServiceImpl.java
View file @
29e66c23
...
...
@@ -8,14 +8,19 @@ import com.google.common.collect.Maps;
import
com.yeejoin.amos.boot.biz.common.utils.Menu
;
import
com.yeejoin.amos.boot.biz.common.utils.MenuFrom
;
import
com.yeejoin.amos.boot.biz.common.utils.TreeParser
;
import
com.yeejoin.amos.boot.module.common.api.dto.*
;
import
com.yeejoin.amos.boot.module.common.api.dto.FireBrigadeResourceDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.FireTeamCardDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.FireTeamDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.FireTeamListDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.FireTeamZhDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.FirefightersDto
;
import
com.yeejoin.amos.boot.module.common.api.dto.RequestData
;
import
com.yeejoin.amos.boot.module.common.api.entity.FireTeam
;
import
com.yeejoin.amos.boot.module.common.api.entity.Firefighters
;
import
com.yeejoin.amos.boot.module.common.api.entity.OrgUsr
;
import
com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient
;
import
com.yeejoin.amos.boot.module.common.api.mapper.FireTeamMapper
;
import
com.yeejoin.amos.boot.module.common.api.service.IFireTeamService
;
import
com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl
;
import
com.yeejoin.amos.boot.module.jcs.api.feign.EquipFeignClient
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
import
org.typroject.tyboot.core.foundation.exception.BaseException
;
...
...
@@ -24,7 +29,11 @@ import org.typroject.tyboot.core.rdbms.service.BaseService;
import
org.typroject.tyboot.core.restful.utils.ResponseModel
;
import
javax.annotation.Resource
;
import
java.util.*
;
import
java.util.Collection
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Objects
;
import
java.util.stream.Collectors
;
/**
...
...
@@ -163,7 +172,6 @@ public class FireTeamServiceImpl extends BaseService<FireTeamDto, FireTeam, Fire
return
this
.
baseMapper
.
queryFighterByTeamId
(
teamIds
);
}
public
FireTeam
saveFireTeam
(
FireTeam
fireTeam
)
{
if
(
ValidationUtil
.
isEmpty
(
fireTeam
.
getParent
()))
{
fireTeam
.
setTreeCode
(
TreeParser
.
genTreeCode
());
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/FirefightersJacketServiceImpl.java
View file @
29e66c23
...
...
@@ -6,6 +6,7 @@ import java.util.List;
import
java.util.Map
;
import
java.util.stream.Collectors
;
import
com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient
;
import
org.springframework.beans.BeanUtils
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.stereotype.Service
;
...
...
@@ -22,7 +23,6 @@ import com.yeejoin.amos.boot.module.common.api.mapper.FirefightersJacketMapper;
import
com.yeejoin.amos.boot.module.jcs.api.dto.EquipSpecificDto
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.EquipmentOnCarDto
;
import
com.yeejoin.amos.boot.module.jcs.api.enums.EquipTypeEnum
;
import
com.yeejoin.amos.boot.module.jcs.api.feign.EquipFeignClient
;
import
com.yeejoin.amos.boot.module.jcs.api.service.IFirefightersJacketService
;
/**
...
...
@@ -38,10 +38,10 @@ public class FirefightersJacketServiceImpl extends BaseService<FirefightersJacke
private
EquipFeignClient
equipFeignClient
;
@Override
public
ResponseModel
<
Page
<
EquipmentOnCarDto
>>
getAirEquipSpecificPage
(
EquipSpecificDto
equipSpecificDto
,
int
current
,
int
size
)
{
public
ResponseModel
<
Page
<
Object
>>
getAirEquipSpecificPage
(
EquipSpecificDto
equipSpecificDto
,
int
current
,
int
size
)
{
Page
page
=
new
Page
(
current
,
size
);
equipSpecificDto
.
setPage
(
page
);
ResponseModel
<
Page
<
EquipmentOnCarDto
>>
airEquipSpecificPage
=
equipFeignClient
.
getAirEquipSpecificPage
(
equipSpecificDto
);
ResponseModel
<
Page
<
Object
>>
airEquipSpecificPage
=
equipFeignClient
.
getAirEquipSpecificPage
(
equipSpecificDto
);
return
airEquipSpecificPage
;
}
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/PowerTransferServiceImpl.java
View file @
29e66c23
package
com
.
yeejoin
.
amos
.
boot
.
module
.
jcs
.
biz
.
service
.
impl
;
import
java.util.ArrayList
;
import
java.util.Collections
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.stream.Collectors
;
import
com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient
;
import
com.yeejoin.amos.boot.module.jcs.api.dto.*
;
import
com.yeejoin.amos.boot.module.jcs.api.enums.DutyInfoEnum
;
import
com.yeejoin.amos.component.rule.config.RuleConfig
;
...
...
@@ -36,7 +38,6 @@ import com.yeejoin.amos.boot.module.jcs.api.entity.PowerTransferCompanyResources
import
com.yeejoin.amos.boot.module.jcs.api.entity.Template
;
import
com.yeejoin.amos.boot.module.jcs.api.enums.FireBrigadeTypeEnum
;
import
com.yeejoin.amos.boot.module.jcs.api.enums.FireCarStatusEnum
;
import
com.yeejoin.amos.boot.module.jcs.api.feign.EquipFeignClient
;
import
com.yeejoin.amos.boot.module.jcs.api.mapper.PowerTransferMapper
;
import
com.yeejoin.amos.boot.module.jcs.api.service.IPowerTransferService
;
...
...
@@ -243,7 +244,7 @@ public class PowerTransferServiceImpl extends BaseService<PowerTransferDto, Powe
List
<
PowerTransferCompanyDto
>
powerTransferCompanyDotList
=
powerTransferDto
.
getPowerTransferCompanyDotList
();
PowerTransferCompany
powerTransferCompany
;
List
<
CarStatusInfoDto
>
carStatusInfoDtoList
=
Lists
.
newArrayList
();
List
<
Object
>
carStatusInfoDtoList
=
Lists
.
newArrayList
();
for
(
PowerTransferCompanyDto
powerTransferCompanyDto
:
powerTransferCompanyDotList
)
{
powerTransferCompany
=
new
PowerTransferCompany
();
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment