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
628b9f41
Commit
628b9f41
authored
Nov 12, 2021
by
tangwei
Browse files
Options
Browse Files
Download
Plain Diff
Merge branch 'developer' of
http://172.16.10.76/moa/amos-boot-biz
into developer
parents
5f1cd588
592489d7
Expand all
Hide whitespace changes
Inline
Side-by-side
Showing
23 changed files
with
239 additions
and
123 deletions
+239
-123
DutyPersonShiftMapper.java
.../boot/module/common/api/mapper/DutyPersonShiftMapper.java
+3
-1
FirefightersMapper.java
...mos/boot/module/common/api/mapper/FirefightersMapper.java
+1
-1
OrgUsrMapper.java
...join/amos/boot/module/common/api/mapper/OrgUsrMapper.java
+1
-1
IDutyPersonService.java
...os/boot/module/common/api/service/IDutyPersonService.java
+3
-1
DutyPersonShiftMapper.xml
...n-api/src/main/resources/mapper/DutyPersonShiftMapper.xml
+39
-20
FirefightersMapper.xml
...mmon-api/src/main/resources/mapper/FirefightersMapper.xml
+6
-3
OrgUsrMapper.xml
...ule-common-api/src/main/resources/mapper/OrgUsrMapper.xml
+11
-30
AlertCallePowerTransferRo.java
...os/boot/module/jcs/api/dto/AlertCallePowerTransferRo.java
+1
-1
AlertCalledRo.java
...m/yeejoin/amos/boot/module/jcs/api/dto/AlertCalledRo.java
+97
-1
AlertStageEnums.java
...ejoin/amos/boot/module/jcs/api/enums/AlertStageEnums.java
+1
-0
IAlertCalledService.java
...amos/boot/module/jcs/api/service/IAlertCalledService.java
+3
-0
DutyPersonController.java
...ot/module/common/biz/controller/DutyPersonController.java
+12
-12
OrgPersonController.java
...oot/module/common/biz/controller/OrgPersonController.java
+13
-13
DutyPersonServiceImpl.java
...module/common/biz/service/impl/DutyPersonServiceImpl.java
+7
-10
FirefightersServiceImpl.java
...dule/common/biz/service/impl/FirefightersServiceImpl.java
+3
-2
OrgUsrServiceImpl.java
...oot/module/common/biz/service/impl/OrgUsrServiceImpl.java
+2
-2
FirefightersController.java
...oot/module/jcs/biz/controller/FirefightersController.java
+1
-15
AlertCalledAction.java
...os/boot/module/jcs/biz/rule/action/AlertCalledAction.java
+4
-3
PowerTransferAction.java
.../boot/module/jcs/biz/rule/action/PowerTransferAction.java
+6
-2
AlertCalledServiceImpl.java
...t/module/jcs/biz/service/impl/AlertCalledServiceImpl.java
+22
-2
AlertSubmittedServiceImpl.java
...odule/jcs/biz/service/impl/AlertSubmittedServiceImpl.java
+0
-0
PowerTransferServiceImpl.java
...module/jcs/biz/service/impl/PowerTransferServiceImpl.java
+3
-3
RuleAlertCalledService.java
...t/module/jcs/biz/service/impl/RuleAlertCalledService.java
+0
-0
No files found.
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/mapper/DutyPersonShiftMapper.java
View file @
628b9f41
...
@@ -134,5 +134,7 @@ public interface DutyPersonShiftMapper extends BaseMapper<DutyPersonShift> {
...
@@ -134,5 +134,7 @@ public interface DutyPersonShiftMapper extends BaseMapper<DutyPersonShift> {
List
<
Map
<
String
,
Object
>>
getFirstAidForTypeCodeAndCompanyId
(
long
company
);
List
<
Map
<
String
,
Object
>>
getFirstAidForTypeCodeAndCompanyId
(
long
company
);
List
<
Map
<
String
,
Object
>>
queryByCompanyId
(
Long
companyId
);
List
<
Map
<
String
,
Object
>>
queryByCompanyId
();
List
<
Map
<
String
,
Object
>>
queryByCompanyNew
(
String
bizOrgName
);
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/mapper/FirefightersMapper.java
View file @
628b9f41
...
@@ -37,5 +37,5 @@ public interface FirefightersMapper extends BaseMapper<Firefighters> {
...
@@ -37,5 +37,5 @@ public interface FirefightersMapper extends BaseMapper<Firefighters> {
List
<
FirefightersExcelDto
>
exportToExcel
(
Boolean
isDelete
,
String
name
,
String
postQualification
,
String
fireTeamId
,
List
<
FirefightersExcelDto
>
exportToExcel
(
Boolean
isDelete
,
String
name
,
String
postQualification
,
String
fireTeamId
,
String
state
,
String
areasExpertise
,
String
jobTitle
);
String
state
,
String
areasExpertise
,
String
jobTitle
);
List
<
FirefightersDto
>
queryById
(
Long
teamId
,
String
[]
gw
);
List
<
FirefightersDto
>
queryById
(
@Param
(
"gw"
)
String
[]
gw
);
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/mapper/OrgUsrMapper.java
View file @
628b9f41
...
@@ -92,5 +92,5 @@ public interface OrgUsrMapper extends BaseMapper<OrgUsr> {
...
@@ -92,5 +92,5 @@ public interface OrgUsrMapper extends BaseMapper<OrgUsr> {
List
<
Map
<
String
,
Long
>>
countDeptByCompanyId
(
@Param
(
"companyIdList"
)
List
<
String
>
companyIdList
);
List
<
Map
<
String
,
Long
>>
countDeptByCompanyId
(
@Param
(
"companyIdList"
)
List
<
String
>
companyIdList
);
List
<
Map
<
String
,
Object
>>
queryCompanyId
(
Long
id
);
List
<
Map
<
String
,
Object
>>
queryCompanyId
(
String
bizOrgName
);
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/service/IDutyPersonService.java
View file @
628b9f41
...
@@ -34,5 +34,7 @@ public interface IDutyPersonService extends IDutyCommonService {
...
@@ -34,5 +34,7 @@ public interface IDutyPersonService extends IDutyCommonService {
*/
*/
List
<
DutyPersonDto
>
findByDutyAreaId
(
Long
dutyAreaId
);
List
<
DutyPersonDto
>
findByDutyAreaId
(
Long
dutyAreaId
);
List
<
Map
<
String
,
Object
>>
queryByCompanyId
(
Long
companyId
);
List
<
Map
<
String
,
Object
>>
queryByCompanyId
();
List
<
Map
<
String
,
Object
>>
queryByCompanyNew
(
String
bizOrgName
);
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/resources/mapper/DutyPersonShiftMapper.xml
View file @
628b9f41
...
@@ -342,25 +342,44 @@ AND cft.type_code = (
...
@@ -342,25 +342,44 @@ AND cft.type_code = (
</select>
</select>
<select
id=
'queryByCompanyId'
resultType=
"map"
>
<select
id=
'queryByCompanyId'
resultType=
"map"
>
SELECT
select biz_org_name as bizOrgName,sequence_nbr sequenceNbr,field_value as telephone from (
e.field_code,
select orgUsr.biz_org_name,i.field_value,orgUsr.sequence_nbr
e.field_name,
from cb_org_usr orgUsr left join cb_dynamic_form_instance i on orgUsr.sequence_nbr =
e.field_value
i.instance_id where i.field_code = 'telephone') as d
FROM
where d.sequence_nbr in (
cb_dynamic_form_instance e,
select userId from (
(SELECT
select cb.duty_date,a.deptId,c.userId from cb_duty_person_shift cb
i.*
left join (select i.instance_id id1 ,if(i.field_code = 'deptId',
FROM
i.field_value, null) as 'deptId' from cb_dynamic_form_instance i
cb_dynamic_form_instance i
where i.field_code = 'deptId' and i.field_value is not null) a
,
on cb.instance_id = a.id1
(SELECT * FROM `cb_duty_person_shift` where to_days(duty_date) = to_days(now())) b
left join (select i.instance_id id3 ,if(i.field_code = 'userId',
WHERE
i.field_value, null) as 'userId' from cb_dynamic_form_instance i
i.instance_id = b.instance_id
where i.field_code = 'userId' and i.field_value is not null) c
AND
on cb.instance_id = c.id3
i.field_code = 'deptId'
where to_days(cb.duty_date) = to_days(now()) and
AND
a.deptId in ( select sequence_nbr from cb_org_usr cou where biz_org_name = '消防救援保障部' or
i.field_value = #{companyId}) c
biz_org_name = '综合办公室' or biz_org_name = '消防支队' or biz_org_name = '应急指挥科' )) r )
WHERE
</select>
e. instance_id = c.instance_id
<select
id=
'queryByCompanyNew'
resultType=
"map"
>
select biz_org_name as bizOrgName,sequence_nbr sequenceNbr,field_value as telephone from (
select orgUsr.biz_org_name,i.field_value,orgUsr.sequence_nbr
from cb_org_usr orgUsr left join cb_dynamic_form_instance i on orgUsr.sequence_nbr =
i.instance_id where i.field_code = 'telephone') as d
where d.sequence_nbr in (
select userId from (
select cb.duty_date,a.deptId,c.userId from cb_duty_person_shift cb
left join (select i.instance_id id1 ,if(i.field_code = 'deptId',
i.field_value, null) as 'deptId' from cb_dynamic_form_instance i
where i.field_code = 'deptId' and i.field_value is not null) a
on cb.instance_id = a.id1
left join (select i.instance_id id3 ,if(i.field_code = 'userId',
i.field_value, null) as 'userId' from cb_dynamic_form_instance i
where i.field_code = 'userId' and i.field_value is not null) c
on cb.instance_id = c.id3
where to_days(cb.duty_date) = to_days(now()) and
a.deptId in ( select sequence_nbr from cb_org_usr cou where biz_org_name = #{bizOrgName})) r )
</select>
</select>
</mapper>
</mapper>
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/resources/mapper/FirefightersMapper.xml
View file @
628b9f41
...
@@ -174,11 +174,14 @@
...
@@ -174,11 +174,14 @@
<select
id=
"queryById"
resultType=
"com.yeejoin.amos.boot.module.common.api.dto.FirefightersDto"
>
<select
id=
"queryById"
resultType=
"com.yeejoin.amos.boot.module.common.api.dto.FirefightersDto"
>
SELECT
SELECT
*
firefighters.sequence_nbr sequenceNbr ,
firefighters.name,
mobile_phone as mobilePhone
FROM
FROM
cb_firefighters
cb_firefighters
firefighters
WHERE
WHERE
fire_team_id = #{teamId}
fire_team_id in ( select sequence_nbr from cb_fire_team cft where company in (
select sequence_nbr from cb_org_usr cou where biz_org_name = '消防救援部') )
<if
test=
"gw != null"
>
<if
test=
"gw != null"
>
And job_title_code In
And job_title_code In
<foreach
item=
"item"
collection=
"gw"
index=
"index"
open=
"("
separator=
","
close=
")"
>
<foreach
item=
"item"
collection=
"gw"
index=
"index"
open=
"("
separator=
","
close=
")"
>
...
...
amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/resources/mapper/OrgUsrMapper.xml
View file @
628b9f41
...
@@ -687,35 +687,16 @@ LEFT JOIN (
...
@@ -687,35 +687,16 @@ LEFT JOIN (
</select>
</select>
<select
id=
"queryCompanyId"
resultType=
"map"
>
<select
id=
"queryCompanyId"
resultType=
"map"
>
SELECT
select * from (
d.field_code ,
select cou.biz_org_name bizOrgName,cou.sequence_nbr sequenceNbr ,cou .parent_id parentId,
d.field_name ,
a.fireManagementPostCode, b.telephone from cb_org_usr cou
d.field_value ,
left join (select i.instance_id id1 ,if(i.field_code = 'fireManagementPostCode',
s.sequence_nbr,
i.field_value_label, null) as 'fireManagementPostCode' from cb_dynamic_form_instance i where i.field_code = 'fireManagementPostCode'
s.biz_org_name,
and i.field_value_label is not null) a on cou .sequence_nbr = a.id1
s.parent_id
left join (select i.instance_id id2,if(i.field_code = 'telephone',
FROM
i.field_value, null) as 'telephone' from cb_dynamic_form_instance i where i.field_code = 'telephone'
cb_dynamic_form_instance d ,
and i.field_value is not null) b on cou .sequence_nbr = b.id2
( SELECT
) d where d.parentId in (select sequence_nbr from cb_org_usr cou where biz_org_name = #{bizOrgName})
u.*
and (d.fireManagementPostCode = '消防安全管理人' or d.fireManagementPostCode = '消防安全责任人')
FROM
cb_org_usr u,
cb_dynamic_form_instance i
where
u.parent_id = #{id}
AND
u.is_delete = 0
AND
u.biz_org_type = 'PERSON'
AND
i.instance_id = u.sequence_nbr
AND
i.field_code = 'administrativePositionCode'
AND
i.field_value is not NULL ) s
WHERE
d.instance_id = s.sequence_nbr
AND
d.field_code = 'telephone'
</select>
</select>
</mapper>
</mapper>
amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/dto/AlertCallePowerTransferRo.java
View file @
628b9f41
...
@@ -29,7 +29,7 @@ public class AlertCallePowerTransferRo implements Serializable{
...
@@ -29,7 +29,7 @@ public class AlertCallePowerTransferRo implements Serializable{
*
*
* </pre>
* </pre>
*/
*/
private
static
final
long
serialVersionUID
=
7091835997817930387
L
;
private
static
final
long
serialVersionUID
=
4735920511849348360
L
;
/**
/**
* 通用属性
* 通用属性
...
...
amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/dto/AlertCalledRo.java
View file @
628b9f41
...
@@ -26,7 +26,7 @@ public class AlertCalledRo implements Serializable{
...
@@ -26,7 +26,7 @@ public class AlertCalledRo implements Serializable{
*
*
* </pre>
* </pre>
*/
*/
private
static
final
long
serialVersionUID
=
7091835997817930383
L
;
private
static
final
long
serialVersionUID
=
529623529216238088
L
;
/**
/**
* 通用属性
* 通用属性
...
@@ -46,6 +46,12 @@ public class AlertCalledRo implements Serializable{
...
@@ -46,6 +46,12 @@ public class AlertCalledRo implements Serializable{
@Label
(
value
=
"发送单位"
)
@Label
(
value
=
"发送单位"
)
private
String
companyName
;
private
String
companyName
;
@Label
(
value
=
"联系人"
)
private
String
contactUser
;
@Label
(
value
=
"联系电话"
)
private
String
contactPhone
;
@Label
(
value
=
"被困人数"
)
@Label
(
value
=
"被困人数"
)
private
String
trappedNum
;
private
String
trappedNum
;
...
@@ -57,6 +63,24 @@ public class AlertCalledRo implements Serializable{
...
@@ -57,6 +63,24 @@ public class AlertCalledRo implements Serializable{
@Label
(
value
=
"警情报送id"
)
@Label
(
value
=
"警情报送id"
)
private
String
alertSubmittedId
;
private
String
alertSubmittedId
;
@Label
(
value
=
"事发单位"
)
private
String
unitInvolved
;
@Label
(
value
=
"模板替换内容"
)
private
String
replaceContent
;
@Label
(
value
=
"警情报送类型(0,警情报送,1,警情续报,2,非警情确认,3,警情结案)"
)
private
String
alertWay
;
@Label
(
value
=
"警情续报,非警情确认,警情结案,选择人员ids"
)
private
String
ids
;
@Label
(
value
=
"警情续报自定义内容"
)
private
String
feedback
;
/**
/**
* 一般火灾
* 一般火灾
*/
*/
...
@@ -74,5 +98,77 @@ public class AlertCalledRo implements Serializable{
...
@@ -74,5 +98,77 @@ public class AlertCalledRo implements Serializable{
/**
/**
* 航空器救援
* 航空器救援
*/
*/
@Label
(
value
=
"航班号"
)
private
String
flightNumber
;
@Label
(
value
=
"飞机型号"
)
private
String
aircraftModel
;
@Label
(
value
=
"落地时间"
)
private
String
landingTime
;
@Label
(
value
=
"灾害事故情况"
)
private
String
accidentSituationHkq
;
@Label
(
value
=
"燃油量"
)
private
String
fuelQuantity
;
@Label
(
value
=
"发展态势"
)
private
String
developmentTrend
;
@Label
(
value
=
"载客量"
)
private
String
passengerCapacity
;
@Label
(
value
=
"航空器故障部位"
)
private
String
damageLocation
;
@Label
(
value
=
"迫降跑道"
)
private
String
forcedLandingTrack
;
/**
* 突发事件救援
*/
@Label
(
value
=
"灾害事故情况"
)
private
String
accidentSituation
;
/**
* 漏油现场安全保障
*/
@Label
(
value
=
"航班号"
)
private
String
flightNumberLy
;
@Label
(
value
=
"机位"
)
private
String
seat
;
@Label
(
value
=
"漏油面积"
)
private
String
oilLeakageArea
;
/**
* 专机保障
*/
@Label
(
value
=
"保障等级"
)
private
String
securityLevel
;
@Label
(
value
=
"机位"
)
private
String
seatBz
;
/**
* 120急救
*/
@Label
(
value
=
"患者现状"
)
private
String
patientStatus
;
@Label
(
value
=
"性别"
)
private
String
gender
;
@Label
(
value
=
"年龄段"
)
private
String
ageGroup
;
//
// /**
// * 其他
// */
// @Label(value = "灾害事故情况")
// private String accidentSituation;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/enums/AlertStageEnums.java
View file @
628b9f41
...
@@ -24,6 +24,7 @@ public enum AlertStageEnums {
...
@@ -24,6 +24,7 @@ public enum AlertStageEnums {
LYXC
(
"237"
,
"漏油现场安全保障"
),
LYXC
(
"237"
,
"漏油现场安全保障"
),
ZJBZ
(
"238"
,
"转机保障"
),
ZJBZ
(
"238"
,
"转机保障"
),
QTJQ
(
"242"
,
"其他"
),
QTJQ
(
"242"
,
"其他"
),
JJJQ
(
"1214"
,
"120急救"
),
RG
(
"226"
,
"人工上报"
),
RG
(
"226"
,
"人工上报"
),
DJ
(
"228"
,
"对讲呼入"
),
DJ
(
"228"
,
"对讲呼入"
),
...
...
amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/service/IAlertCalledService.java
View file @
628b9f41
...
@@ -43,6 +43,9 @@ public interface IAlertCalledService {
...
@@ -43,6 +43,9 @@ public interface IAlertCalledService {
Object
selectAlertCalledByIdNoRedis
(
Long
id
);
Object
selectAlertCalledByIdNoRedis
(
Long
id
);
Object
selectAlertCalledByIdNoRedisNew
(
Long
id
);
Map
<
String
,
Object
>
selectAlertCalledKeyValueLabelById
(
Long
id
);
Map
<
String
,
Object
>
selectAlertCalledKeyValueLabelById
(
Long
id
);
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/controller/DutyPersonController.java
View file @
628b9f41
...
@@ -191,18 +191,18 @@ public class DutyPersonController extends BaseController {
...
@@ -191,18 +191,18 @@ public class DutyPersonController extends BaseController {
return
ResponseHelper
.
buildResponse
(
iDutyPersonService
.
findByDutyAreaId
(
dutyAreaId
));
return
ResponseHelper
.
buildResponse
(
iDutyPersonService
.
findByDutyAreaId
(
dutyAreaId
));
}
}
/**
//
/**
*
//
*
*
//
*
* @return ResponseModel
//
* @return ResponseModel
*/
//
*/
@TycloudOperation
(
ApiLevel
=
UserType
.
AGENCY
,
needAuth
=
false
)
//
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@GetMapping
(
value
=
"/companyId/{companyId}"
)
//
@GetMapping(value = "/companyId/{companyId}")
@ApiOperation
(
httpMethod
=
"GET"
,
value
=
"查询当日值班人员"
,
notes
=
"查询当日值班人员"
)
//
@ApiOperation(httpMethod = "GET", value = "查询当日值班人员", notes = "查询当日值班人员")
public
ResponseModel
<
List
<
Map
<
String
,
Object
>>>
queryByCompanyId
(
//
public ResponseModel<List<Map<String, Object>>> queryByCompanyId(
@PathVariable
Long
companyId
)
throws
Exception
{
//
@PathVariable Long companyId) throws Exception {
return
ResponseHelper
.
buildResponse
(
iDutyPersonService
.
queryByCompanyId
(
companyId
));
//
return ResponseHelper.buildResponse(iDutyPersonService.queryByCompanyId(companyId));
}
//
}
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/controller/OrgPersonController.java
View file @
628b9f41
...
@@ -268,17 +268,17 @@ public class OrgPersonController {
...
@@ -268,17 +268,17 @@ public class OrgPersonController {
}
}
}
}
/**
//
/**
* 机场单位下 各单位下人员岗位不为空的人员
//
* 机场单位下 各单位下人员岗位不为空的人员
*
//
*
* @param id
//
* @param id
* @return
//
* @return
*/
//
*/
@TycloudOperation
(
needAuth
=
false
,
ApiLevel
=
UserType
.
AGENCY
)
//
@TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
@RequestMapping
(
value
=
"/companyId/{id}"
,
method
=
RequestMethod
.
GET
)
//
@RequestMapping(value = "/companyId/{id}", method = RequestMethod.GET)
@ApiOperation
(
httpMethod
=
"GET"
,
value
=
"获取人员岗位不为空的人员详情"
,
notes
=
"获取人员岗位不为空的人员详情"
)
//
@ApiOperation(httpMethod = "GET", value = "获取人员岗位不为空的人员详情", notes = "获取人员岗位不为空的人员详情")
public
ResponseModel
<
Object
>
queryCompanyId
(
HttpServletRequest
request
,
//
public ResponseModel<Object> queryCompanyId(HttpServletRequest request,
@PathVariable
Long
id
)
throws
Exception
{
//
@PathVariable Long id) throws Exception {
return
ResponseHelper
.
buildResponse
(
iOrgUsrService
.
queryCompanyId
(
id
));
//
return ResponseHelper.buildResponse(iOrgUsrService.queryCompanyId(id));
}
//
}
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/DutyPersonServiceImpl.java
View file @
628b9f41
...
@@ -303,17 +303,14 @@ public Object BuildScheduleDetails(String dutyDay, Long shiftId, String postType
...
@@ -303,17 +303,14 @@ public Object BuildScheduleDetails(String dutyDay, Long shiftId, String postType
}
}
@Override
public
List
<
Map
<
String
,
Object
>>
queryByCompanyId
(){
return
dutyPersonShiftMapper
.
queryByCompanyId
();
}
@Override
public
List
<
Map
<
String
,
Object
>>
queryByCompanyNew
(
String
bizOrgName
){
return
dutyPersonShiftMapper
.
queryByCompanyNew
(
bizOrgName
);
public
List
<
Map
<
String
,
Object
>>
queryByCompanyId
(
Long
companyId
){
return
dutyPersonShiftMapper
.
queryByCompanyId
(
companyId
);
}
}
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/service/impl/FirefightersServiceImpl.java
View file @
628b9f41
...
@@ -133,9 +133,10 @@ public class FirefightersServiceImpl extends BaseService<FirefightersDto, Firefi
...
@@ -133,9 +133,10 @@ public class FirefightersServiceImpl extends BaseService<FirefightersDto, Firefi
return
firefightersMapper
.
getFirefightersName
();
return
firefightersMapper
.
getFirefightersName
();
}
}
public
List
<
FirefightersDto
>
queryById
(
Long
teamId
,
String
[]
gw
){
public
List
<
FirefightersDto
>
queryById
(
String
[]
gw
){
return
firefightersMapper
.
queryById
(
teamId
,
gw
);
return
firefightersMapper
.
queryById
(
gw
);
}
}
/**
/**
* 获取指定岗位名称下的队伍人员电话号码信息
* 获取指定岗位名称下的队伍人员电话号码信息
...
...
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 @
628b9f41
...
@@ -1860,9 +1860,9 @@ public class OrgUsrServiceImpl extends BaseService<OrgUsrDto, OrgUsr, OrgUsrMapp
...
@@ -1860,9 +1860,9 @@ public class OrgUsrServiceImpl extends BaseService<OrgUsrDto, OrgUsr, OrgUsrMapp
return
resultMap
;
return
resultMap
;
}
}
public
List
<
Map
<
String
,
Object
>>
queryCompanyId
(
Long
id
)
{
public
List
<
Map
<
String
,
Object
>>
queryCompanyId
(
String
bizOrgName
)
{
return
orgUsrMapper
.
queryCompanyId
(
id
);
return
orgUsrMapper
.
queryCompanyId
(
bizOrgName
);
}
}
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/controller/FirefightersController.java
View file @
628b9f41
...
@@ -333,21 +333,7 @@ public class FirefightersController extends BaseController {
...
@@ -333,21 +333,7 @@ public class FirefightersController extends BaseController {
return
ResponseHelper
.
buildResponse
(
menus
);
return
ResponseHelper
.
buildResponse
(
menus
);
}
}
/**
*查询
*
* @param
* @return
* @throws Exception
*/
@TycloudOperation
(
needAuth
=
true
,
ApiLevel
=
UserType
.
AGENCY
)
@RequestMapping
(
value
=
"/gw/{id}"
,
method
=
RequestMethod
.
GET
)
@ApiOperation
(
httpMethod
=
"GET"
,
value
=
"根据id查询"
,
notes
=
"根据id查询"
)
public
ResponseModel
<
Object
>
queryById
(
@PathVariable
Long
teamId
)
throws
Exception
{
//规则提供岗位名称
String
[]
gw
=
new
String
[]{
"1202"
,
"1203"
,
"1204"
,
"1205"
,
"1206"
,
"1207"
,
"1209"
,
"1208"
,
"1210"
,
"1211"
};
return
ResponseHelper
.
buildResponse
(
iFirefightersService
.
queryById
(
teamId
,
gw
));
}
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/rule/action/AlertCalledAction.java
View file @
628b9f41
...
@@ -2,6 +2,8 @@ package com.yeejoin.amos.boot.module.jcs.biz.rule.action;
...
@@ -2,6 +2,8 @@ package com.yeejoin.amos.boot.module.jcs.biz.rule.action;
import
java.util.HashMap
;
import
java.util.HashMap
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Set
;
import
java.util.Set
;
import
org.slf4j.Logger
;
import
org.slf4j.Logger
;
...
@@ -64,14 +66,13 @@ public class AlertCalledAction {
...
@@ -64,14 +66,13 @@ public class AlertCalledAction {
*
*
* @param smsCode 短信模板code
* @param smsCode 短信模板code
* @param sendType 发送类型
* @param sendType 发送类型
* @param sendIds 人员id
* @param object 模板内容对象
* @param object 模板内容对象
* @throws Exception 异常
* @throws Exception 异常
*/
*/
@RuleMethod
(
methodLabel
=
"短信报送"
,
project
=
"西咸机场119接处警规则"
)
@RuleMethod
(
methodLabel
=
"短信报送"
,
project
=
"西咸机场119接处警规则"
)
public
void
sendcmd
(
String
smsCode
,
String
sendType
,
String
sendIds
,
Object
object
)
throws
Exception
{
public
void
sendcmd
(
String
smsCode
,
String
sendType
,
List
<
Map
<
String
,
Object
>>
submittedList
,
Object
object
)
throws
Exception
{
alertSubmittedService
.
ruleCallbackAction
(
smsCode
,
s
endIds
,
object
);
alertSubmittedService
.
ruleCallbackAction
(
smsCode
,
s
ubmittedList
,
object
);
}
}
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/rule/action/PowerTransferAction.java
View file @
628b9f41
...
@@ -24,7 +24,11 @@ import com.yeejoin.amos.component.rule.RuleMethod;
...
@@ -24,7 +24,11 @@ import com.yeejoin.amos.component.rule.RuleMethod;
@RuleActionBean
(
beanLabel
=
"调派报送"
)
@RuleActionBean
(
beanLabel
=
"调派报送"
)
public
class
PowerTransferAction
{
public
class
PowerTransferAction
{
public
static
final
Logger
log
=
LoggerFactory
.
getLogger
(
PowerTransferAction
.
class
);
/**
*
*/
public
static
final
Logger
log
=
LoggerFactory
.
getLogger
(
PowerTransferAction
.
class
);
@Autowired
@Autowired
private
AlertSubmittedServiceImpl
alertSubmittedService
;
private
AlertSubmittedServiceImpl
alertSubmittedService
;
...
@@ -41,7 +45,7 @@ public class PowerTransferAction {
...
@@ -41,7 +45,7 @@ public class PowerTransferAction {
* @throws Exception 异常
* @throws Exception 异常
*/
*/
@RuleMethod
(
methodLabel
=
"短信报送"
,
project
=
"西咸机场119接处警规则"
)
@RuleMethod
(
methodLabel
=
"短信报送"
,
project
=
"西咸机场119接处警规则"
)
public
void
sendcmd
(
String
smsCode
,
String
sendType
,
List
<
String
>
sendIds
,
Object
object
)
throws
Exception
{
public
void
sendcmd
(
String
smsCode
,
String
sendType
,
List
sendIds
,
Object
object
)
throws
Exception
{
// alertSubmittedService.ruleCallbackAction(smsCode, sendIds, object);
// alertSubmittedService.ruleCallbackAction(smsCode, sendIds, object);
System
.
out
.
println
(
"8796w39879873298798"
);
System
.
out
.
println
(
"8796w39879873298798"
);
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/AlertCalledServiceImpl.java
View file @
628b9f41
...
@@ -9,6 +9,7 @@ import java.util.Set;
...
@@ -9,6 +9,7 @@ import java.util.Set;
import
java.util.function.Function
;
import
java.util.function.Function
;
import
java.util.stream.Collectors
;
import
java.util.stream.Collectors
;
import
com.yeejoin.amos.boot.module.jcs.api.enums.AlertBusinessTypeEnum
;
import
org.apache.commons.lang3.StringUtils
;
import
org.apache.commons.lang3.StringUtils
;
import
org.joda.time.DateTime
;
import
org.joda.time.DateTime
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.beans.factory.annotation.Autowired
;
...
@@ -269,6 +270,25 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
...
@@ -269,6 +270,25 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
}
}
/**
/**
* 根据灾情id 查询灾情详情
**/
@Override
public
Object
selectAlertCalledByIdNoRedisNew
(
Long
id
)
{
// 警情基本信息
AlertCalled
alertCalled
=
this
.
getById
(
id
);
QueryWrapper
<
AlertFormValue
>
queryWrapper
=
new
QueryWrapper
<>();
queryWrapper
.
eq
(
"alert_called_id"
,
id
);
// 警情动态表单数据
List
<
AlertFormValue
>
list
=
iAlertFormValueService
.
list
(
queryWrapper
);
List
<
FormValue
>
formValue
=
new
ArrayList
<
FormValue
>();
//
AlertCalledObjsDto
alertCalledFormVo
=
new
AlertCalledObjsDto
();
alertCalledFormVo
.
setAlertCalled
(
alertCalled
);
alertCalledFormVo
.
setAlertFormValue
(
list
);
return
alertCalledFormVo
;
}
/**
* <pre>
* <pre>
* 保存警情信息
* 保存警情信息
* </pre>
* </pre>
...
@@ -348,8 +368,8 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
...
@@ -348,8 +368,8 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
alertCalledObjsDto
.
setAlertCalled
(
alertCalled
);
alertCalledObjsDto
.
setAlertCalled
(
alertCalled
);
alertCalledObjsDto
.
setAlertFormValue
(
alertFormValuelist
);
alertCalledObjsDto
.
setAlertFormValue
(
alertFormValuelist
);
// 警情报送
// 警情报送
// 调用规则
// 调用规则
警情初报
ruleAlertCalledService
.
fireAlertCalledRule
(
alertCalledObjsDto
);
ruleAlertCalledService
.
fireAlertCalledRule
(
alertCalledObjsDto
,
AlertBusinessTypeEnum
.
警情初报
.
getCode
(),
null
);
// 通知实战指挥页面发送mqtt 默认发送 String 类型 0, 新警情 1 警情状态变化
// 通知实战指挥页面发送mqtt 默认发送 String 类型 0, 新警情 1 警情状态变化
emqKeeper
.
getMqttClient
().
publish
(
topic
,
"0"
.
getBytes
(),
RuleConfig
.
DEFAULT_QOS
,
true
);
emqKeeper
.
getMqttClient
().
publish
(
topic
,
"0"
.
getBytes
(),
RuleConfig
.
DEFAULT_QOS
,
true
);
/**
/**
...
...
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 @
628b9f41
This diff is collapsed.
Click to expand it.
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 @
628b9f41
...
@@ -158,7 +158,7 @@ public class PowerTransferServiceImpl extends BaseService<PowerTransferDto, Powe
...
@@ -158,7 +158,7 @@ public class PowerTransferServiceImpl extends BaseService<PowerTransferDto, Powe
//封装调派任务的集合,以便于实现任务规则校验
//封装调派任务的集合,以便于实现任务规则校验
try
{
try
{
//
packagePowerTransferDetail(powerTransferDto);
//
packagePowerTransferDetail(powerTransferDto);
}
catch
(
Exception
e
)
{
}
catch
(
Exception
e
)
{
log
.
error
(
"调用规则失败:PowerTransferServiceImpl。createPowerTransfer()"
);
log
.
error
(
"调用规则失败:PowerTransferServiceImpl。createPowerTransfer()"
);
}
}
...
@@ -190,8 +190,8 @@ public class PowerTransferServiceImpl extends BaseService<PowerTransferDto, Powe
...
@@ -190,8 +190,8 @@ public class PowerTransferServiceImpl extends BaseService<PowerTransferDto, Powe
monitorTeamList
.
add
(
powerTransferCompanyDto
);
monitorTeamList
.
add
(
powerTransferCompanyDto
);
}
}
}
}
ruleAlertCalledService
.
powerTransferCalledRule
(
fullTimeList
,
powerTransferDto
.
getAlertCalledId
(),
FireBrigadeTypeEnum
.
专职消防队
.
getKey
());
//
ruleAlertCalledService.powerTransferCalledRule(fullTimeList,powerTransferDto.getAlertCalledId(),FireBrigadeTypeEnum.专职消防队.getKey());
ruleAlertCalledService
.
powerTransferCalledRule
(
medicalTeamList
,
powerTransferDto
.
getAlertCalledId
(),
FireBrigadeTypeEnum
.
医疗救援队
.
getKey
());
//
ruleAlertCalledService.powerTransferCalledRule(medicalTeamList,powerTransferDto.getAlertCalledId(),FireBrigadeTypeEnum.医疗救援队.getKey());
ruleAlertCalledService
.
powerTransferCalledRule
(
monitorTeamList
,
powerTransferDto
.
getAlertCalledId
(),
FireBrigadeTypeEnum
.
监控大队
.
getKey
());
ruleAlertCalledService
.
powerTransferCalledRule
(
monitorTeamList
,
powerTransferDto
.
getAlertCalledId
(),
FireBrigadeTypeEnum
.
监控大队
.
getKey
());
}
}
...
...
amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/RuleAlertCalledService.java
View file @
628b9f41
This diff is collapsed.
Click to expand it.
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