Commit 17f408be authored by tianyiming's avatar tianyiming

报送警情和调派的时候添加对应技能组

parent 156ed72b
...@@ -166,5 +166,8 @@ public class AlertCalledDto extends BaseDto { ...@@ -166,5 +166,8 @@ public class AlertCalledDto extends BaseDto {
@ApiModelProperty(value = "现场照片") @ApiModelProperty(value = "现场照片")
private List<AttachmentDto> images; private List<AttachmentDto> images;
@ApiModelProperty(value = "技能组")
private String skillGroup;
private String equipment; private String equipment;
} }
...@@ -232,4 +232,8 @@ public class AlertCalled extends BaseEntity { ...@@ -232,4 +232,8 @@ public class AlertCalled extends BaseEntity {
@ApiModelProperty(value = "现场照片") @ApiModelProperty(value = "现场照片")
private List<AttachmentDto> images; private List<AttachmentDto> images;
@ApiModelProperty(value = "技能组")
@TableField("skill_group")
private String skillGroup;
} }
...@@ -221,4 +221,11 @@ public class DispatchPaper extends BaseEntity { ...@@ -221,4 +221,11 @@ public class DispatchPaper extends BaseEntity {
*/ */
@TableField("save_time") @TableField("save_time")
private Date saveTime; private Date saveTime;
/**
* 技能组
*/
@TableField("skill_group")
private String skillGroup;
} }
...@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.elevator.api.entity; ...@@ -3,6 +3,7 @@ package com.yeejoin.amos.boot.module.elevator.api.entity;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import com.yeejoin.amos.boot.biz.common.entity.BaseEntity; import com.yeejoin.amos.boot.biz.common.entity.BaseEntity;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
...@@ -131,4 +132,10 @@ public class DispatchTask extends BaseEntity { ...@@ -131,4 +132,10 @@ public class DispatchTask extends BaseEntity {
@TableField("save_time") @TableField("save_time")
private Date saveTime; private Date saveTime;
/**
* 技能组
*/
@TableField("skill_group")
private String skillGroup;
} }
...@@ -132,9 +132,11 @@ public class AlertCalledController extends BaseController { ...@@ -132,9 +132,11 @@ public class AlertCalledController extends BaseController {
if(ObjectUtils.isEmpty(map)) { if(ObjectUtils.isEmpty(map)) {
throw new BadRequest("未找到相关电梯."); throw new BadRequest("未找到相关电梯.");
} }
List<AgencyUserModel> userModels = FeignUtil.remoteCall(()->Privilege.agencyUserClient.queryByIds(RequestContext.getExeUserId(),false)); ReginParams reginParams = getSelectedOrgInfo();
//由于查询的当前登录的用户信息 所以一定有 未作冗余判空 if(ObjectUtils.isEmpty(reginParams)){
AgencyUserModel userModel = userModels.get(0); throw new BadRequest("当前登录用户失效,请重新登录.");
}
AgencyUserModel userModel = reginParams.getUserModel();
alertCalledObjsDto = iAlertCalledService.createAlertCalled(alertCalledObjsDto, userModel); alertCalledObjsDto = iAlertCalledService.createAlertCalled(alertCalledObjsDto, userModel);
// 坐席接警后,辅屏由常态化切换为处置态 // 坐席接警后,辅屏由常态化切换为处置态
......
...@@ -533,7 +533,8 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto,AlertCall ...@@ -533,7 +533,8 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto,AlertCall
String code= getCode.get(alertCalledObjsDto.getAlertCalledDto().getEquipment().toString()); String code= getCode.get(alertCalledObjsDto.getAlertCalledDto().getEquipment().toString());
alertCalled.setEquipmentClassificationCode(code); alertCalled.setEquipmentClassificationCode(code);
alertCalled.setCallTime(DateUtils.longStr2Date(alertCalled.getCallTimeStr())); alertCalled.setCallTime(DateUtils.longStr2Date(alertCalled.getCallTimeStr()));
String groupCode = ctiService.getSkillGroup(user.getUserId());
alertCalled.setSkillGroup(groupCode);
// 判断是否归并警情 // 判断是否归并警情
if (alertCalled.getFatherAlert() != null) { if (alertCalled.getFatherAlert() != null) {
// 警情归并,设置当前警情状态为结束。 // 警情归并,设置当前警情状态为结束。
......
...@@ -114,6 +114,9 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc ...@@ -114,6 +114,9 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc
private EmqKeeper emqKeeper; private EmqKeeper emqKeeper;
@Autowired @Autowired
CtiServiceImpl ctiService;
@Autowired
private ElevatorMapper elevatorMapper; private ElevatorMapper elevatorMapper;
@Autowired @Autowired
...@@ -810,6 +813,11 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc ...@@ -810,6 +813,11 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc
// 创建派遣单 // 创建派遣单
dispatchTaskDto.setDispatchTime(new Date()); dispatchTaskDto.setDispatchTime(new Date());
DispatchTask dispatchTask = BeanDtoVoUtils.convert(dispatchTaskDto, DispatchTask.class); DispatchTask dispatchTask = BeanDtoVoUtils.convert(dispatchTaskDto, DispatchTask.class);
String groupCode = ctiService.getSkillGroup(sendUser.getUserId());
dispatchTask.setSkillGroup(groupCode);
dispatchPaper.setSkillGroup(groupCode);
if(AlertStageEnums.KRJY.getId().equals(dispatchTaskDto.getAlertCode())) { if(AlertStageEnums.KRJY.getId().equals(dispatchTaskDto.getAlertCode())) {
dispatchTask.setIsSaveTask(true); dispatchTask.setIsSaveTask(true);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment