Skip to content

A
amos-boot-biz
Commit 91afbfc7 authored by changhong's avatar changhong
Browse files
Options

开发派遣单相关接口

parent 95c720d3
Hide whitespace changes
Inline Side-by-side
Showing with 429 additions and 99 deletions
amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/dto/DispatchPaperFormDto.java 0 → 100644
View file @ 91afbfc7
package com.yeejoin.amos.boot.module.tzs.api.dto;
import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
import com.yeejoin.amos.boot.module.tzs.api.entity.AlertFormValue;
import com.yeejoin.amos.boot.module.tzs.api.entity.DispatchPaper;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.util.List;
/**
* 派遣单携带动态表单值
*
* @author kongfm
* @date 2021-08-03
*/
@Data
@EqualsAndHashCode(callSuper = true)
@ApiModel(value="DispatchPaperFormDto", description="派遣单携带动态表单值")
public class DispatchPaperFormDto extends BaseDto {
private static final long serialVersionUID = 1L;
@ApiModelProperty(value = "派遣单")
private DispatchPaper dispatchPaper;
@ApiModelProperty(value = "动态表单值")
private List<AlertFormValue> dynamicFormAlert;
public DispatchPaperFormDto(DispatchPaper dispatchPaper, List<AlertFormValue> formValue) {
this.dispatchPaper = dispatchPaper;
this.dynamicFormAlert = formValue;
}
public DispatchPaperFormDto() {
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/dto/DispatchTaskDto.java
View file @ 91afbfc7
......@@ -72,4 +72,7 @@ public class DispatchTaskDto extends BaseDto {
@ApiModelProperty(value = "任务状态")
private String taskStatus;
@ApiModelProperty(value = "警情类型code")
private String alertCode;
}
amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/enums/DispatchPaperEnums.java 0 → 100644
View file @ 91afbfc7
package com.yeejoin.amos.boot.module.tzs.api.enums;
/**
*
* 派遣单枚举类
* @author kongfm
* @date 2021-08-04
* ***/
public enum DispatchPaperEnums {
//完成状态 WCZT
notFinish("notFinish","未完成"),
hasFinished("hasFinished","已完成"),
//处置环节 CZHJ
receivedAlert("receivedAlert","已接警"),
dispatched("dispatched", "已派遣"),
rescueArrived("rescueArrived", "救援已到达"),
repaireArrived("repaireArrived", "维保已到达"),
rescued("rescued", "救援完成"),
rescueBack("rescueBack", "救援回访"),
repaired("repaired", "维修完成"),
reportorBack("reportorBack", "报修人已反馈"),
disposed("disposed", "维保已处置"),
complainantBack("complainantBack", "投诉人已回访"),
// 警情类型 JJLX
KRJY("KRJY","困人救援","250"),
GZWX("GZWX", "故障维修","251"),
TSZX("TSZX", "投诉咨询","252"),
// 反馈方式 FKFS
mainBack("mainBack","主动反馈"),
phoneBack("phoneBack","电话回访"),
// 维修结果 WXJG
hasRepaired("hasRepaired","维修成功"),
other("other","其他"),
// 处置结果 CZJG
hasDisposed("hasDisposed","已处置"),
notDispose("notDispose","未处置"),
// 反馈结果 FKJG
satisfactory("satisfactory","满意"),
unsatisfactory("unsatisfactory","不满意"),
// 派遣单位 PQDW
useUnit("useUnit","使用单位"),
repairUnit("repairUnit","维保单位"),
levelOneUnit("levelOneUnit","一级响应"),
levelTwoUnit("levelTwoUnit","二级响应"),
levelThreeUnit("levelThreeUnit","三级响应");
private String code;
private String value;
private String dynamicCode;
DispatchPaperEnums(String code, String value) {
this.code=code;
this.value=value;
}
DispatchPaperEnums(String code, String value, String dynamicCode) {
this.code=code;
this.value=value;
this.dynamicCode = dynamicCode;
}
public String getCode() {
return code;
}
public void setCode(String code) {
this.code = code;
}
public String getValue() {
return value;
}
public void setValue(String value) {
this.value = value;
}
public String getDynamicCode() {
return dynamicCode;
}
public void setDynamicCode(String dynamicCode) {
this.dynamicCode = dynamicCode;
}
public static DispatchPaperEnums getEnum(String code)
{
for (DispatchPaperEnums status : DispatchPaperEnums.values())
{
if (status.getCode().equals(code))
{
return status;
}
}
return null;
}
}
amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/service/IDispatchPaperService.java
View file @ 91afbfc7
package com.yeejoin.amos.boot.module.tzs.api.service;
import com.yeejoin.amos.boot.module.tzs.api.entity.DispatchPaper;
/**
* 派遣单接口类
*
......@@ -9,4 +11,15 @@ package com.yeejoin.amos.boot.module.tzs.api.service;
*/
public interface IDispatchPaperService {
DispatchPaper selectDispatchPaperByAlertId(Long alertId);
Object selectDispatchPaperDtoByAlertId(Long alertId);
/**
* 根据警情id 及 警情类别 创建 派遣单
* @param alertId
* @param alertCode
* @return
*/
DispatchPaper createDispatchPaper(Long alertId, String alertCode);
}
amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/service/IDispatchTaskService.java
View file @ 91afbfc7
package com.yeejoin.amos.boot.module.tzs.api.service;
import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchTaskDto;
/**
* 派遣任务接口类
*
......@@ -9,4 +11,8 @@ package com.yeejoin.amos.boot.module.tzs.api.service;
*/
public interface IDispatchTaskService {
Boolean createDispatchTask(DispatchTaskDto dispatchTaskDto);
DispatchTaskDto getTaskInfo(String orgTypeCode, Long alertId);
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/controller/DispatchPaperController.java
View file @ 91afbfc7
package com.yeejoin.amos.boot.module.tzs.biz.controller;
import org.springframework.web.bind.annotation.RequestMapping;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.Api;
import org.springframework.web.bind.annotation.RestController;
import com.alibaba.fastjson.JSONObject;
import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
import com.yeejoin.amos.boot.biz.common.controller.BaseController;
import java.util.List;
import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchPaperDto;
import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchPaperFormDto;
import com.yeejoin.amos.boot.module.tzs.api.entity.DispatchPaper;
import com.yeejoin.amos.boot.module.tzs.biz.service.impl.DispatchPaperServiceImpl;
import org.typroject.tyboot.core.restful.utils.ResponseHelper;
import org.typroject.tyboot.core.restful.utils.ResponseModel;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import javax.servlet.http.HttpServletRequest;
import org.springframework.web.bind.annotation.*;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchPaperDto;
import org.typroject.tyboot.core.restful.doc.TycloudOperation;
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.RestController;
import org.typroject.tyboot.core.foundation.enumeration.UserType;
import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
import org.typroject.tyboot.core.restful.doc.TycloudOperation;
import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
import org.typroject.tyboot.core.restful.utils.ResponseHelper;
import org.typroject.tyboot.core.restful.utils.ResponseModel;
/**
* 派遣单
......@@ -31,6 +39,9 @@ public class DispatchPaperController extends BaseController {
@Autowired
DispatchPaperServiceImpl dispatchPaperServiceImpl;
@Autowired
RedisUtils redisUtils;
/**
* 新增派遣单
*
......@@ -39,11 +50,39 @@ public class DispatchPaperController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY)
@PostMapping(value = "/save")
@ApiOperation(httpMethod = "POST", value = "新增派遣单", notes = "新增派遣单")
public ResponseModel<DispatchPaperDto> save(@RequestBody DispatchPaperDto model) {
model = dispatchPaperServiceImpl.createWithModel(model);
return ResponseHelper.buildResponse(model);
public ResponseModel<DispatchPaperFormDto> save(@RequestBody DispatchPaperFormDto dispatchPaperFormDto) {
if (ValidationUtil.isEmpty(dispatchPaperFormDto)
|| ValidationUtil.isEmpty(dispatchPaperFormDto.getDispatchPaper()))
throw new BadRequest("参数校验失败.");
ReginParams reginParams =
JSONObject.parseObject(null != redisUtils.get(buildKey(getToken())) ?
redisUtils.get(buildKey(getToken())).toString() : null, ReginParams.class);
//获取当前登录人公司
String orgCode= reginParams.getCompany().getOrgCode();
DispatchPaper dispatchPaper = dispatchPaperFormDto.getDispatchPaper();
dispatchPaper.setOrgCode(orgCode);
dispatchPaperFormDto.setDispatchPaper(dispatchPaper);
dispatchPaperFormDto = dispatchPaperServiceImpl.createDispatchPaper(dispatchPaperFormDto);
return ResponseHelper.buildResponse(dispatchPaperFormDto);
}
/**
* 根据警情id查询
*
* @param id
* @return
*/
@TycloudOperation(needAuth = true, ApiLevel = UserType.AGENCY)
@GetMapping(value = "/alert/{id}")
@ApiOperation(httpMethod = "GET", value = "根据警情id查询", notes = "根据警情id查询")
public ResponseModel<Object> selectById(@PathVariable Long id) {
return ResponseHelper.buildResponse(dispatchPaperServiceImpl.selectDispatchPaperDtoByAlertId(id));
}
/**
* 根据sequenceNbr更新
*
......@@ -58,59 +97,7 @@ public class DispatchPaperController extends BaseController {
return ResponseHelper.buildResponse(dispatchPaperServiceImpl.updateWithModel(model));
}
/**
* 根据sequenceNbr删除
*
* @param sequenceNbr 主键
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@DeleteMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除派遣单", notes = "根据sequenceNbr删除派遣单")
public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){
return ResponseHelper.buildResponse(dispatchPaperServiceImpl.removeById(sequenceNbr));
}
/**
* 根据sequenceNbr查询
*
* @param sequenceNbr 主键
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "GET",value = "根据sequenceNbr查询单个派遣单", notes = "根据sequenceNbr查询单个派遣单")
public ResponseModel<DispatchPaperDto> selectOne(@PathVariable Long sequenceNbr) {
return ResponseHelper.buildResponse(dispatchPaperServiceImpl.queryBySeq(sequenceNbr));
}
/**
* 列表分页查询
*
* @param current 当前页
* @param current 每页大小
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@GetMapping(value = "/page")
@ApiOperation(httpMethod = "GET",value = "派遣单分页查询", notes = "派遣单分页查询")
public ResponseModel<Page<DispatchPaperDto>> queryForPage(@RequestParam(value = "current") int current,@RequestParam
(value = "size") int size) {
Page<DispatchPaperDto> page = new Page<DispatchPaperDto>();
page.setCurrent(current);
page.setSize(size);
return ResponseHelper.buildResponse(dispatchPaperServiceImpl.queryForDispatchPaperPage(page));
}
/**
* 列表全部数据查询
*
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@ApiOperation(httpMethod = "GET",value = "派遣单列表全部数据查询", notes = "派遣单列表全部数据查询")
@GetMapping(value = "/list")
public ResponseModel<List<DispatchPaperDto>> selectForList() {
return ResponseHelper.buildResponse(dispatchPaperServiceImpl.queryForDispatchPaperList());
}
}
amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/controller/DispatchTaskController.java
View file @ 91afbfc7
......@@ -39,38 +39,24 @@ public class DispatchTaskController extends BaseController {
@TycloudOperation(ApiLevel = UserType.AGENCY)
@PostMapping(value = "/save")
@ApiOperation(httpMethod = "POST", value = "新增派遣任务", notes = "新增派遣任务")
public ResponseModel<DispatchTaskDto> save(@RequestBody DispatchTaskDto model) {
model = dispatchTaskServiceImpl.createWithModel(model);
return ResponseHelper.buildResponse(model);
public ResponseModel<Boolean> save(@RequestBody DispatchTaskDto model) {
Boolean flag = dispatchTaskServiceImpl.createDispatchTask(model);
return ResponseHelper.buildResponse(flag);
}
/**
* 根据sequenceNbr更新
*
* @param sequenceNbr 主键
* @return
*/
* 根据派遣单位类型和警情id 获取任务模板
* @param orgTypeCode
* @param alertId
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@PutMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "PUT", value = "根据sequenceNbr更新派遣任务", notes = "根据sequenceNbr更新派遣任务")
public ResponseModel<DispatchTaskDto> updateBySequenceNbrDispatchTask(@RequestBody DispatchTaskDto model,@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
model.setSequenceNbr(sequenceNbr);
return ResponseHelper.buildResponse(dispatchTaskServiceImpl.updateWithModel(model));
@GetMapping(value = "/{orgTypeCode}/{alertId}")
@ApiOperation(httpMethod = "GET",value = "根据派遣单位类型和警情id 获取任务信息", notes = "根据派遣单位类型和警情id 获取任务信息")
public ResponseModel<DispatchTaskDto> selectOne(@PathVariable String orgTypeCode, @PathVariable Long alertId) {
return ResponseHelper.buildResponse(dispatchTaskServiceImpl.getTaskInfo(orgTypeCode,alertId));
}
/**
* 根据sequenceNbr删除
*
* @param sequenceNbr 主键
* @return
*/
@TycloudOperation(ApiLevel = UserType.AGENCY)
@DeleteMapping(value = "/{sequenceNbr}")
@ApiOperation(httpMethod = "DELETE", value = "根据sequenceNbr删除派遣任务", notes = "根据sequenceNbr删除派遣任务")
public ResponseModel<Boolean> deleteBySequenceNbr(HttpServletRequest request, @PathVariable(value = "sequenceNbr") Long sequenceNbr){
return ResponseHelper.buildResponse(dispatchTaskServiceImpl.removeById(sequenceNbr));
}
/**
* 根据sequenceNbr查询
*
......
amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/service/impl/DispatchPaperServiceImpl.java
View file @ 91afbfc7
package com.yeejoin.amos.boot.module.tzs.biz.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.tzs.api.dto.AlertFormInitDto;
import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchPaperDto;
import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchPaperFormDto;
import com.yeejoin.amos.boot.module.tzs.api.entity.AlertFormValue;
import com.yeejoin.amos.boot.module.tzs.api.entity.DispatchPaper;
import com.yeejoin.amos.boot.module.tzs.api.enums.DispatchPaperEnums;
import com.yeejoin.amos.boot.module.tzs.api.mapper.DispatchPaperMapper;
import com.yeejoin.amos.boot.module.tzs.api.service.IDispatchPaperService;
import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchPaperDto;
import org.typroject.tyboot.core.rdbms.service.BaseService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.springframework.transaction.annotation.Transactional;
import org.typroject.tyboot.core.rdbms.service.BaseService;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
/**
......@@ -17,6 +27,13 @@ import java.util.List;
*/
@Service
public class DispatchPaperServiceImpl extends BaseService<DispatchPaperDto,DispatchPaper,DispatchPaperMapper> implements IDispatchPaperService {
@Autowired
private AlertFormValueServiceImpl iAlertFormValueService;
@Autowired
private AlertFormServiceImpl alertFormServiceImpl;
/**
* 分页查询
*/
......@@ -30,4 +47,97 @@ public class DispatchPaperServiceImpl extends BaseService<DispatchPaperDto,Dispa
public List<DispatchPaperDto> queryForDispatchPaperList() {
return this.queryForList("" , false);
}
/**
*
* <pre>
* 保存派遣单信息
* </pre>
*
* @param dispatchPaperFormDto
* @return
*/
@Transactional(rollbackFor = RuntimeException.class)
public DispatchPaperFormDto createDispatchPaper(DispatchPaperFormDto dispatchPaperFormDto) {
try {
// 派遣单基本信息
DispatchPaper dispatchPaper = dispatchPaperFormDto.getDispatchPaper();
dispatchPaper.setDispatchTime(new Date());
dispatchPaper.setIsDelete(false);
this.save(dispatchPaper);
// 动态表单
List<AlertFormValue> paperFormValuelist = dispatchPaperFormDto.getDynamicFormAlert();
// 填充警情主键
paperFormValuelist.stream().forEach(paperFormValue -> {
paperFormValue.setAlertCalledId(dispatchPaper.getSequenceNbr());
paperFormValue.setAlertTypeCode(DispatchPaperEnums.getEnum(dispatchPaper.getAlertCode()).getDynamicCode());
});
// 保存动态表单数据
iAlertFormValueService.saveBatch(paperFormValuelist);
dispatchPaperFormDto.setDispatchPaper(dispatchPaper);
dispatchPaperFormDto.setDynamicFormAlert(paperFormValuelist);
return dispatchPaperFormDto;
} catch (Exception e) {
e.printStackTrace();
throw new RuntimeException("派遣失败，系统异常!");
}
}
@Override
public Object selectDispatchPaperDtoByAlertId(Long alertId) {
// 根据警情id 获取 派遣单信息
DispatchPaper dispatchPaper =selectDispatchPaperByAlertId(alertId);
// 封装dto
DispatchPaperFormDto dispatchPaperFormDto = new DispatchPaperFormDto();
dispatchPaperFormDto.setDispatchPaper(dispatchPaper);
QueryWrapper<AlertFormValue> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("alert_called_id", dispatchPaper.getSequenceNbr()).eq("alert_type_code",dispatchPaper.getAlertCode());
// 派遣单动态表单数据
List<AlertFormValue> list = iAlertFormValueService.list(queryWrapper);
dispatchPaperFormDto.setDynamicFormAlert(list);
return dispatchPaperFormDto;
}
@Override
public DispatchPaper createDispatchPaper(Long alertId, String alertCode) {
// 创建基本信息
DispatchPaper dispatchPaper = new DispatchPaper();
dispatchPaper.setAlertCode(alertCode);
dispatchPaper.setAlertId(alertId);
dispatchPaper.setDispatchTime(new Date());
dispatchPaper.setIsDelete(false);
this.save(dispatchPaper);
// 根据类型创建动态表单信息
String dynamicCode = DispatchPaperEnums.getEnum(alertCode).getDynamicCode();
List<AlertFormInitDto> alertFormInitDtoList = alertFormServiceImpl.getFormlist(dynamicCode);
List<AlertFormValue> paperFormValuelist = new ArrayList<AlertFormValue>(alertFormInitDtoList.size());
// 填充警情主键
alertFormInitDtoList.stream().forEach(initDto -> {
initDto.getFormItemDescr().setAlertCalledId(dispatchPaper.getSequenceNbr());
initDto.getFormItemDescr().setAlertTypeCode(DispatchPaperEnums.getEnum(dispatchPaper.getAlertCode()).getDynamicCode());
paperFormValuelist.add(initDto.getFormItemDescr());
});
// 保存动态表单数据
iAlertFormValueService.saveBatch(paperFormValuelist);
return dispatchPaper;
}
@Override
public DispatchPaper selectDispatchPaperByAlertId(Long alertId) {
QueryWrapper<DispatchPaper> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("alert_id", alertId);
// 警情动态表单数据
DispatchPaper dispatchPaper = this.getOne(queryWrapper);
return dispatchPaper;
}
}
\ No newline at end of file
amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/service/impl/DispatchTaskServiceImpl.java
View file @ 91afbfc7
package com.yeejoin.amos.boot.module.tzs.biz.service.impl;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.yeejoin.amos.boot.module.tzs.api.dto.AlertCalledDto;
import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchTaskDto;
import com.yeejoin.amos.boot.module.tzs.api.entity.DispatchPaper;
import com.yeejoin.amos.boot.module.tzs.api.entity.DispatchTask;
import com.yeejoin.amos.boot.module.tzs.api.entity.Elevator;
import com.yeejoin.amos.boot.module.tzs.api.mapper.DispatchTaskMapper;
import com.yeejoin.amos.boot.module.tzs.api.service.IDispatchTaskService;
import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchTaskDto;
import org.typroject.tyboot.core.rdbms.service.BaseService;
import com.yeejoin.amos.boot.module.tzs.biz.utils.BeanDtoVoUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.typroject.tyboot.core.rdbms.service.BaseService;
import java.util.List;
/**
......@@ -17,6 +24,17 @@ import java.util.List;
*/
@Service
public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,DispatchTask,DispatchTaskMapper> implements IDispatchTaskService {
@Autowired
DispatchPaperServiceImpl dispatchPaperServiceImpl;
@Autowired
AlertCalledServiceImpl alertCalledServiceImpl;
@Autowired
ElevatorServiceImpl elevatorServiceImpl;
/**
* 分页查询
*/
......@@ -30,4 +48,61 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc
public List<DispatchTaskDto> queryForDispatchTaskList() {
return this.queryForList("" , false);
}
@Override
public Boolean createDispatchTask(DispatchTaskDto dispatchTaskDto) {
boolean flag = false;
// 判断派遣单是否存在 如果不存在先创建派遣单
DispatchPaper dispatchPaper = dispatchPaperServiceImpl.selectDispatchPaperByAlertId(dispatchTaskDto.getAlertId());
if(dispatchPaper == null) {
dispatchPaper = dispatchPaperServiceImpl.createDispatchPaper(dispatchTaskDto.getAlertId(), dispatchTaskDto.getAlertCode());
}
// 创建派遣单
DispatchTask dispatchTask = BeanDtoVoUtils.convert(dispatchTaskDto, DispatchTask.class);
dispatchTask.setPaperId(dispatchPaper.getSequenceNbr());
flag = this.save(dispatchTask);
return flag;
}
@Override
public DispatchTaskDto getTaskInfo(String orgTypeCode, Long alertId) {
DispatchTaskDto dispatchTaskDto = new DispatchTaskDto();
// 根据类型和警情带出负责人信息
AlertCalledDto alertCalledDto = alertCalledServiceImpl.queryBySeq(alertId);
// 设备类型 和 编码 确定设备的使用单位或者维保单位
String getEquipmentClassificationCode = alertCalledDto.getEquipmentClassificationCode();
String deviceId = alertCalledDto.getDeviceId();
// 目前只有电梯类型
QueryWrapper<Elevator> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("rescue_code", deviceId);
// 警情动态表单数据
Elevator elevator = elevatorServiceImpl.getOne(queryWrapper);
dispatchTaskDto.setOrgTypeCode(orgTypeCode);
dispatchTaskDto.setAlertId(alertId);
switch (orgTypeCode) {
case "useUnit": // 使用单位
case "levelOneUnit": // 一级响应
dispatchTaskDto.setResponseOrgId(elevator.getUseUnitId());
dispatchTaskDto.setResponseOrgName(elevator.getUseUnit());
break;
case "repairUnit": // 维保单位
case "levelTwoUnit": // 二级响应
dispatchTaskDto.setResponseOrgId(elevator.getMaintainUnitId());
dispatchTaskDto.setResponseOrgName(elevator.getMaintainUnit());
dispatchTaskDto.setResponseUserId(elevator.getMaintainLeaderId());
dispatchTaskDto.setResponseUserName(elevator.getMaintainLeader());
dispatchTaskDto.setResponseUserTel(elevator.getMaintainLeaderPhone());
break;
case "levelThreeUnit": // 三级响应
break;
}
// 获取模板 拼接json
return null;
}
}
\ No newline at end of file
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