Merge branch 'developer' of http://172.16.10.76/moa/amos-boot-biz into developer

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/dto/LinkageUnitDto.java

@@ -10,6 +10,8 @@ import lombok.EqualsAndHashCode;
 import java.util.Date;
 import java.util.List;
 
+import org.omg.CORBA.PRIVATE_MEMBER;
+
 /**
  * 联动单位
  *
@@ -98,5 +100,10 @@ public class LinkageUnitDto extends BaseDto {
 
     @ApiModelProperty(value = "联动单位图片")
     private List<SourceFile> image;
-
+    
+    @ApiModelProperty(value = "车辆数量")
+    private String vehicleNumber;
+   
+    @ApiModelProperty(value = "特岗人数")
+    private String personNumber;
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/mapper/LinkageUnitMapper.java

 package com.yeejoin.amos.boot.module.common.api.mapper;
 
+import java.util.List;
+import java.util.Map;
+
+import org.apache.ibatis.annotations.Param;
+
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
-import com.yeejoin.amos.boot.module.common.api.dto.CompanyDto;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.module.common.api.dto.LinkageUnitDto;
 import com.yeejoin.amos.boot.module.common.api.dto.LinkageUnitZhDto;
 import com.yeejoin.amos.boot.module.common.api.dto.RequestData;
 import com.yeejoin.amos.boot.module.common.api.entity.LinkageUnit;
-import org.apache.ibatis.annotations.Param;
-
-import java.util.List;
-import java.util.Map;
 
 /**
  * 联动单位 Mapper 接口
@@ -43,4 +45,22 @@ public interface LinkageUnitMapper extends BaseMapper<LinkageUnit> {
     List<LinkageUnitZhDto> listLinkageUnitZhDto(@Param("pageNum")int pageNum, @Param("pageSize")int pageSize, @Param("par") RequestData par);
 
     Integer listLinkageUnitZhDtoCount(@Param("par")RequestData par);
+    
+    /**
+     * 查询当前存在的联动单位及统计
+     * @param isDelete
+     * @param emergencyLinkageUnitCode
+     * @return
+     */
+    List<Map<String, Object>> getEmergencyLinkageUnitCodeGroupByAndCount();
+    
+    /**
+     * 查询包含特岗人数及的具体信息
+     * @return
+     */
+    Page<List<LinkageUnitDto>> getEmergencyLinkageUnitList(IPage<LinkageUnitDto> page,String unitName,
+			 String linkageUnitTypeCode,  String emergencyLinkageUnitCode);
+    
+    
+    
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/service/ILinkageUnitService.java

 package com.yeejoin.amos.boot.module.common.api.service;
 
+import java.util.List;
+
+import org.typroject.tyboot.core.rdbms.annotation.Condition;
+import org.typroject.tyboot.core.rdbms.annotation.Operator;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.yeejoin.amos.boot.biz.common.utils.Menu;
 import com.yeejoin.amos.boot.module.common.api.dto.LinkageUnitDto;
 import com.yeejoin.amos.boot.module.common.api.dto.LinkageUnitZhDto;
 import com.yeejoin.amos.boot.module.common.api.dto.RequestData;
-import org.typroject.tyboot.core.rdbms.annotation.Condition;
-import org.typroject.tyboot.core.rdbms.annotation.Operator;
-
-import java.util.List;
+import com.yeejoin.amos.boot.module.common.api.entity.LinkageUnit;
 
 /**
-* 联动单位接口类
-*
-* @author system_generator
-* @date 2021-07-16
-*/
+ * 联动单位接口类
+ *
+ * @author system_generator
+ * @date 2021-07-16
+ */
 public interface ILinkageUnitService {
 
-
-    List<LinkageUnitZhDto> listLinkageUnitZhDto(Integer pageNum, Integer pageSize, RequestData par);
-
-    Integer listLinkageUnitZhDtoCount(RequestData par);
-
-    LinkageUnitDto queryOne(Long sequenceNbr);
-
-    /**
-     * 联动单位分页查询
-     *
-     * @param page
-     * @param isDelete
-     * @param unitName 单位名称
-     * @param linkageUnitType 联动单位类型
-     * @param emergencyLinkageUnitCode 紧急联动单位类型code
-     * @return
-     */
-    Page<LinkageUnitDto> queryForLinkageUnitPage(Page<LinkageUnitDto> page,
-                                                        @Condition(Operator.eq) Boolean isDelete,
-                                                        @Condition(Operator.like) String unitName,
-                                                        @Condition(Operator.eq) String linkageUnitType,
-                                                        @Condition(Operator.eq) String emergencyLinkageUnitCode);
+	List<LinkageUnitZhDto> listLinkageUnitZhDto(Integer pageNum, Integer pageSize, RequestData par);
+
+	Integer listLinkageUnitZhDtoCount(RequestData par);
+
+	LinkageUnitDto queryOne(Long sequenceNbr);
+
+	/**
+	 * 联动单位分页查询
+	 *
+	 * @param page
+	 * @param isDelete
+	 * @param unitName                 单位名称
+	 * @param linkageUnitType          联动单位类型
+	 * @param emergencyLinkageUnitCode 紧急联动单位类型code
+	 * @return
+	 */
+	Page<LinkageUnitDto> queryForLinkageUnitPage(IPage<LinkageUnitDto> page,
+            @Condition(Operator.eq) Boolean isDelete,
+            @Condition(Operator.like) String unitName,
+            @Condition(Operator.eq) String linkageUnitTypeCode,
+            @Condition(Operator.eq) String emergencyLinkageUnitCode, 
+            String inAgreement);
+	/**
+	 * 获取当前存在的联动单位的类型组code
+	 * @return
+	 */
+	public  List<Menu> getEmergencyLinkageUnitCodeGroupBy(String type, String rootName) ;
 
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/java/com/yeejoin/amos/boot/module/common/api/service/ISourceFileService.java

@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.common.api.service;
 
 
 import com.yeejoin.amos.boot.module.common.api.dto.AttachmentDto;
+import com.yeejoin.amos.boot.module.common.api.entity.SourceFile;
 
 import java.util.List;
 import java.util.Map;
@@ -13,5 +14,14 @@ import java.util.Map;
 * @date 2021-07-16
 */
 public interface ISourceFileService {
-    public Map<String, List<AttachmentDto>> getAttachments(Long sourceId);
+    Map<String, List<AttachmentDto>> getAttachments(Long sourceId);
+
+    /**
+     * 批量保存附件
+     *
+     * @param sequenceNbr sourceId
+     * @param attachmentMap
+     * @return
+     */
+    void saveAttachments(Long sequenceNbr, Map<String, List<AttachmentDto>> attachmentMap);
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-common-api/src/main/resources/mapper/LinkageUnitMapper.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.yeejoin.amos.boot.module.common.api.mapper.LinkageUnitMapper">
-    <select id="selectOne" resultType="com.yeejoin.amos.boot.module.common.api.dto.LinkageUnitDto">
-        select
-        d.*,
-        lu.*
-        from
-        (
-        select
-        i.INSTANCE_ID instanceId,
-        i.GROUP_CODE groupCode,
-        <foreach collection="fieldCodes" item="value" index="key" separator=",">
-            MAX(CASE WHEN i.FIELD_CODE = #{key} THEN i.FIELD_VALUE END) as ${key}
-        </foreach>
-        from
-        cb_dynamic_form_instance i
-        where i.GROUP_CODE = #{groupCode}
-        and is_delete = #{isDelete}
-        GROUP by
-        i.INSTANCE_ID ) d,
-        cb_linkage_unit lu
-        where
-        d.instanceId = lu.instance_id
-        and lu.sequence_nbr = #{sequenceNbr}
-        and is_delete = #{isDelete}
-    </select>
-
-
-
-
-    <select id="listLinkageUnitZhDto" resultType="com.yeejoin.amos.boot.module.common.api.dto.LinkageUnitZhDto">
-
-        select
-        a.sequence_nbr sequenceNbr,
-        a.unit_name  unitName,
-        a.address,
-        a.latitude,
-        a.longitude,
-        Round(st_distance(point(a.longitude,a.latitude),point(#{par.longitude},#{par.latitude}))*111195,1) AS distance
-        FROM cb_linkage_unit a
-        where  a.longitude is not null and a.latitude is not null
-        <if test='par.distance!=null'>
-            and Round(st_distance(point(a.longitude,a.latitude),point(#{par.longitude},#{par.latitude}))*111195,1) &lt;=
-            #{par.distance}
-        </if>
-        ORDER BY distance limit #{pageNum},#{pageSize}
-    </select>
-
-    <select id="listLinkageUnitZhDtoCount" resultType="Integer">
-        select
-        COUNT(a.sequence_nbr) num
-        FROM cb_linkage_unit a
-        where  a.longitude is not null and a.latitude is not null
-        <if test='par.distance!=null'>
-            and Round(st_distance(point(a.longitude,a.latitude),point(#{par.longitude},#{par.latitude}))*111195,1) &lt;=
-            #{par.distance}
-        </if>
-    </select>
+<mapper
+	namespace="com.yeejoin.amos.boot.module.common.api.mapper.LinkageUnitMapper">
+	<select id="selectOne"
+		resultType="com.yeejoin.amos.boot.module.common.api.dto.LinkageUnitDto">
+		select
+		d.*,
+		lu.*
+		from
+		(
+		select
+		i.INSTANCE_ID instanceId,
+		i.GROUP_CODE
+		groupCode,
+		<foreach collection="fieldCodes" item="value" index="key"
+			separator=",">
+			MAX(CASE WHEN i.FIELD_CODE = #{key} THEN i.FIELD_VALUE END)
+			as ${key}
+		</foreach>
+		from
+		cb_dynamic_form_instance i
+		where i.GROUP_CODE = #{groupCode}
+		and
+		is_delete = #{isDelete}
+		GROUP by
+		i.INSTANCE_ID ) d,
+		cb_linkage_unit lu
+		where
+		d.instanceId = lu.instance_id
+		and lu.sequence_nbr = #{sequenceNbr}
+		and is_delete = #{isDelete}
+	</select>
+
+
+
+
+	<select id="listLinkageUnitZhDto"
+		resultType="com.yeejoin.amos.boot.module.common.api.dto.LinkageUnitZhDto">
+
+		select
+		a.sequence_nbr sequenceNbr,
+		a.unit_name unitName,
+		a.address,
+		a.latitude,
+		a.longitude,
+		Round(st_distance(point(a.longitude,a.latitude),point(#{par.longitude},#{par.latitude}))*111195,1)
+		AS distance
+		FROM cb_linkage_unit a
+		where a.longitude is not null and
+		a.latitude is not null
+		<if test='par.distance!=null'>
+			and
+			Round(st_distance(point(a.longitude,a.latitude),point(#{par.longitude},#{par.latitude}))*111195,1)
+			&lt;=
+			#{par.distance}
+		</if>
+		ORDER BY distance limit #{pageNum},#{pageSize}
+	</select>
+
+	<select id="listLinkageUnitZhDtoCount" resultType="Integer">
+		select
+		COUNT(a.sequence_nbr) num
+		FROM cb_linkage_unit a
+		where a.longitude
+		is not null and a.latitude is not null
+		<if test='par.distance!=null'>
+			and
+			Round(st_distance(point(a.longitude,a.latitude),point(#{par.longitude},#{par.latitude}))*111195,1)
+			&lt;=
+			#{par.distance}
+		</if>
+	</select>
+
+
+	<select id="getEmergencyLinkageUnitCodeGroupByAndCount"
+		resultType="java.util.Map">
+		SELECT
+		emergency_linkage_unit_code as
+		emergencyLinkageUnitCode,
+		COUNT(unit_code) AS count
+		FROM
+		cb_linkage_unit
+		WHERE
+		is_delete = 0
+		GROUP BY
+		emergency_linkage_unit_code
+	</select>
+
+
+
+	<select id="getEmergencyLinkageUnitList"
+		resultType="java.util.Map">
+		SELECT
+		clu.sequence_nbr as sequenceNbr,
+		clu.unit_name as unitName,
+		clu.unit_code AS unitCode,
+		clu.parent_id AS parentId,
+		clu.linkage_unit_type AS linkageUnitType,
+		clu.linkage_unit_type_code AS linkageUnitTypeCode,
+		clu.administrative_divisions AS administrativeDivisions,
+		clu.administrative_divisions_code AS administrativeDivisionsCode,
+		clu.address AS address,
+		clu.longitude AS longitude,
+		clu.latitude AS latitude,
+		clu.agreement_start_date AS agreementStartDate,
+		clu.agreement_end_date AS agreementEndDate,
+		clu.emergency_linkage_unit AS emergencyLinkageUnit,
+		clu.emergency_linkage_unit_code AS emergencyLinkageUnitCode,
+		clu.contact_user AS contactUser,
+		clu.contact_phone AS contactPhone,
+		clu.instance_id AS instanceId,
+		clu.org_code AS orgCode,
+		clu.rec_user_name AS recUserName,
+		clu.rec_user_id AS recUserId,
+		clu.rec_date AS recDate,
+		clu.is_delete AS isDelete,
+		cre.vehicle_number AS vehicleNumber,
+		csps.person_number AS personNumber
+		FROM
+		cb_linkage_unit clu
+		LEFT JOIN cb_rescue_equipment cre ON clu.sequence_nbr = cre.company_id
+		LEFT JOIN cb_special_position_staff csps ON clu.sequence_nbr =
+		csps.company_id
+		WHERE clu.is_delete=0
+	 <if test="unitName != null and unitName != ''">
+		AND clu.unit_name LIKE concat(#{unitName}, '%')
+		</if>
+		 <if test="linkageUnitTypeCode != null and linkageUnitTypeCode != ''">
+		AND clu.linkage_unit_type_code =#{linkageUnitTypeCode} 
+		</if>
+		 <if test="emergencyLinkageUnitCode != null and emergencyLinkageUnitCode != ''">
+		AND  clu.emergency_linkage_unit_code =#{emergencyLinkageUnitCode}
+		</if>
+	</select>
 </mapper>

amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/dto/DispatchConsultFeedbackDto.java

+package com.yeejoin.amos.boot.module.tzs.api.dto;
+
+import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+/**
+ * 投诉回访DTO
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value="DispatchConsultFeedbackDto", description="投诉回访DTO")
+public class DispatchConsultFeedbackDto extends BaseDto {
+
+   private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "警情id")
+    private Long alertId;
+
+    @ApiModelProperty(value = "投诉人")
+    private String emergency;
+
+    @ApiModelProperty(value = "投诉人电话")
+    private String emergencyCall;
+
+    @ApiModelProperty(value = "投诉反馈方式")
+    private String consultFeedbackType;
+
+    @ApiModelProperty(value = "投诉反馈结果")
+    private String feedbackResult;
+
+    @ApiModelProperty(value = "投诉回访时间")
+    private Date consultFeedbackTime;
+
+    @ApiModelProperty(value = "投诉回访人")
+    private String consultFeedbackUname;
+
+    @ApiModelProperty(value = "投诉回访人Id")
+    private String consultFeedbackUid;
+
+    @ApiModelProperty(value = "响应人")
+    private String responseUserName;
+
+    @ApiModelProperty(value = "响应人电话")
+    private String responseUserTel;
+
+    @ApiModelProperty(value = "维修反馈方式Code")
+    private String feedbackCode;
+
+    @ApiModelProperty(value = "维修反馈方式")
+    private String feedbackType;
+
+    @ApiModelProperty(value = "处置结果")
+    private String actionResult;
+
+    @ApiModelProperty(value = "回访时间")
+    private Date feedbackTime;
+
+    @ApiModelProperty(value = "维保反馈人id")
+    private String feedbackUid;
+
+    @ApiModelProperty(value = "维保反馈人")
+    private String feedbackUname;
+
+    @ApiModelProperty(value = "电梯故障原因分类")
+    private String errorResult;
+
+    @ApiModelProperty(value = "备注")
+    private String Remark;
+
+    @ApiModelProperty(value = "维保反馈结果")
+    private String mainFeedbackResult;
+
+    @ApiModelProperty(value = "维保完成时间")
+    private Date feedbackFinishTime;
+
+    public DispatchConsultFeedbackDto() {
+
+    }
+}

amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/dto/DispatchPaperUpdateDto.java

-package com.yeejoin.amos.boot.module.tzs.api.dto;
-
-import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-import lombok.Data;
-import lombok.EqualsAndHashCode;
-
-import java.util.Date;
-
-/**
- * 派遣单更新DTO
- */
-@Data
-@EqualsAndHashCode(callSuper = true)
-@ApiModel(value="DispatchPaperUpdateDto", description="派遣单更新DTO")
-public class DispatchPaperUpdateDto extends BaseDto {
-
-   private static final long serialVersionUID = 1L;
-
-    @ApiModelProperty(value = "派遣单Id")
-    private Long pageId;
-
-    @ApiModelProperty(value = "派遣任务单Id")
-    private Long taskId;
-
-   @ApiModelProperty(value = "派遣单位Id")
-    private Long orgId;
-
-    @ApiModelProperty(value = "派遣单位类型code")
-    private String orgTypeCode;
-
-    @ApiModelProperty(value = "派遣单位社会信用代码")
-    private String orgCreditCode;
-
-    @ApiModelProperty(value = "派遣时间")
-    private Date dispatchTime;
-
-    public DispatchPaperUpdateDto() {
-    }
-}

amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/dto/DispatchRepairFeedbackDto.java

+package com.yeejoin.amos.boot.module.tzs.api.dto;
+
+import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+/**
+ * 维修回访DTO
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value="DispatchRepairFeedbackDto", description="维修回访DTO")
+public class DispatchRepairFeedbackDto extends BaseDto {
+
+   private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "警情id")
+    private Long alertId;
+
+    @ApiModelProperty(value = "报修人")
+    private String emergency;
+
+    @ApiModelProperty(value = "报修人电话")
+    private String emergencyCall;
+
+    @ApiModelProperty(value = "报修反馈方式")
+    private String fixFeedbackType;
+
+    @ApiModelProperty(value = "报修反馈结果")
+    private String feedbackResult;
+
+    @ApiModelProperty(value = "报修回访时间")
+    private Date fixFeedbackTime;
+
+    @ApiModelProperty(value = "报修回访人")
+    private String fixFeedbackUname;
+
+    @ApiModelProperty(value = "报修回访人Id")
+    private String fixFeedbackUid;
+
+    @ApiModelProperty(value = "报修备注")
+    private String fixRemark;
+
+    @ApiModelProperty(value = "响应人")
+    private String responseUserName;
+
+    @ApiModelProperty(value = "响应人电话")
+    private String responseUserTel;
+
+    @ApiModelProperty(value = "维修反馈方式Code")
+    private String feedbackCode;
+
+    @ApiModelProperty(value = "维修反馈方式")
+    private String feedbackType;
+
+    @ApiModelProperty(value = "维修结果")
+    private String fixResult;
+
+    @ApiModelProperty(value = "维修完成时间")
+    private Date feedbackFinishTime;
+
+    @ApiModelProperty(value = "维修反馈人id")
+    private String feedbackUid;
+
+    @ApiModelProperty(value = "维修反馈人")
+    private String feedbackUname;
+
+    @ApiModelProperty(value = "电梯故障原因分类")
+    private String errorResult;
+
+    @ApiModelProperty(value = "备注")
+    private String Remark;
+
+    @ApiModelProperty(value = "回访时间")
+    private Date feedbackTime;
+
+
+ public DispatchRepairFeedbackDto() {
+
+    }
+}

amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/dto/DispatchSaveFeedbackDto.java

+package com.yeejoin.amos.boot.module.tzs.api.dto;
+
+import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.util.Date;
+
+/**
+ * 救援回访DTO
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@ApiModel(value="DispatchSaveFeedbackDto", description="救援回访DTO")
+public class DispatchSaveFeedbackDto extends BaseDto {
+
+   private static final long serialVersionUID = 1L;
+
+    @ApiModelProperty(value = "警情id")
+    private Long alertId;
+
+    @ApiModelProperty(value = "求援人")
+    private String emergency;
+
+    @ApiModelProperty(value = "求援电话")
+    private String emergencyCall;
+
+    @ApiModelProperty(value = "救援回访时间")
+    private Date saveFeedbackTime;
+
+    @ApiModelProperty(value = "救援回访人")
+    private String saveFeedbackUser;
+
+    @ApiModelProperty(value = "救援回访人Id")
+    private String saveFeedbackUid;
+
+    @ApiModelProperty(value = "救援回访结果")
+    private String saveFeedbackResult;
+
+    @ApiModelProperty(value = "响应人")
+    private String responseUserName;
+
+    @ApiModelProperty(value = "响应人电话")
+    private String responseUserTel;
+
+    @ApiModelProperty(value = "维修反馈方式Code")
+    private String feedbackCode;
+
+    @ApiModelProperty(value = "维修反馈方式")
+    private String feedbackType;
+
+    @ApiModelProperty(value = "维修结果")
+    private String fixResult;
+
+    @ApiModelProperty(value = "维修完成时间")
+    private Date feedbackFinishTime;
+
+    @ApiModelProperty(value = "维修反馈人id")
+    private String feedbackUid;
+
+    @ApiModelProperty(value = "维修反馈人")
+    private String feedbackUname;
+
+    @ApiModelProperty(value = "电梯故障原因分类")
+    private String errorResult;
+
+    @ApiModelProperty(value = "备注")
+    private String Remark;
+
+    @ApiModelProperty(value = "回访时间")
+    private Date feedbackTime;
+
+
+ public DispatchSaveFeedbackDto() {
+
+    }
+}

amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/dto/ElevatorDto.java

@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.tzs.api.dto;
 
 import com.baomidou.mybatisplus.annotation.TableName;
 import com.yeejoin.amos.boot.biz.common.dto.BaseDto;
+import com.yeejoin.amos.boot.module.common.api.dto.AttachmentDto;
 import io.swagger.annotations.ApiModel;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.Data;
@@ -9,6 +10,8 @@ import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
 
 import java.util.Date;
+import java.util.List;
+import java.util.Map;
 
 /**
  * @author tb
@@ -68,9 +71,15 @@ public class ElevatorDto extends BaseDto {
     @ApiModelProperty(value = "设备类别")
     private String category;
 
+    @ApiModelProperty(value = "设备类别code")
+    private String categoryName;
+
     @ApiModelProperty(value = "使用场所分类")
     private String useSiteCategory;
 
+    @ApiModelProperty(value = "使用场所分类名称")
+    private String useSiteCategoryName;
+
     @ApiModelProperty(value = "电梯型号")
     private String model;
 
@@ -98,6 +107,9 @@ public class ElevatorDto extends BaseDto {
     @ApiModelProperty(value = "拖动方式")
     private String dragMode;
 
+    @ApiModelProperty(value = "拖动方式名称")
+    private String dragModeName;
+
     @ApiModelProperty(value = "电梯使用状态")
     private Integer useStatus;
 
@@ -116,9 +128,15 @@ public class ElevatorDto extends BaseDto {
     @ApiModelProperty(value = "维保类型")
     private String maintainType;
 
+    @ApiModelProperty(value = "维保类型名称")
+    private String maintainTypeName;
+
     @ApiModelProperty(value = "维护周期")
     private String maintainPeriod;
 
+    @ApiModelProperty(value = "维护周期名称")
+    private String maintainPeriodName;
+
     @ApiModelProperty(value = "维保单位")
     private String maintainUnit;
 
@@ -194,10 +212,12 @@ public class ElevatorDto extends BaseDto {
     @ApiModelProperty(value = "原始表id（来自历史数据库）")
     private String originalId;
 
+    @ApiModelProperty(value = "附件")
+    private Map<String, List<AttachmentDto>> attachments;
+
     @ApiModelProperty(value = "经度")
     private String longitude;
 
     @ApiModelProperty(value = "纬度")
     private String latitude;
-
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/mapper/AlertCalledMapper.java

@@ -2,6 +2,9 @@ package com.yeejoin.amos.boot.module.tzs.api.mapper;
 
 import com.yeejoin.amos.boot.module.tzs.api.entity.AlertCalled;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.Map;
 
 /**
  * 警情接警填报记录 Mapper 接口
@@ -11,4 +14,16 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
  */
 public interface AlertCalledMapper extends BaseMapper<AlertCalled> {
 
+    /**
+     * 接警情况统计
+     *
+     * @param beginDate
+     * @param endDate
+     * @return
+     */
+    Map<String, Integer> queryAlertStatusCount(@Param("beginDate") String beginDate,
+                                               @Param("endDate") String endDate,
+                                               @Param("orgCode") String orgCode,
+                                               @Param("recUserId") String recUserId
+                                               );
 }

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

 package com.yeejoin.amos.boot.module.tzs.api.service;
 
 
+import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchConsultFeedbackDto;
+import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchPaperFormDto;
+import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchRepairFeedbackDto;
+import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchSaveFeedbackDto;
 import com.yeejoin.amos.boot.module.tzs.api.entity.DispatchPaper;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 
@@ -14,7 +18,7 @@ public interface IDispatchPaperService {
 
     DispatchPaper selectDispatchPaperByAlertId(Long alertId);
 
-    Object selectDispatchPaperDtoByAlertId(Long alertId);
+    DispatchPaperFormDto selectDispatchPaperDtoByAlertId(Long alertId);
 
     /**
      * 根据警情id 及 警情类别 派遣人 创建 派遣单
@@ -23,5 +27,51 @@ public interface IDispatchPaperService {
      * @param sendUser
      * @return
      */
-    DispatchPaper createDispatchPaper(Long alertId, String alertCode, AgencyUserModel sendUser);
+    DispatchPaperFormDto createDispatchPaper(Long alertId, String alertCode, AgencyUserModel sendUser);
+
+    /**
+     * 根据警情id 返回 救援回访相关信息
+     * @param alertId
+     * @return
+     */
+    DispatchSaveFeedbackDto getDispatchSaveFeedbackDtoByAlertId(Long alertId, AgencyUserModel feedbackUser);
+
+    /**
+     * 坐席填写救援回访相关信息
+     * @param dispatchSaveFeedbackDto
+     * @return
+     */
+    Boolean saveDispatchSaveFeedback(DispatchSaveFeedbackDto dispatchSaveFeedbackDto);
+
+    /**
+     * 根据警情id 返回 维修回访相关信息
+     * @param alertId
+     * @return
+     */
+    DispatchRepairFeedbackDto getDispatchRepairFeedbackDtoByAlertId(Long alertId, AgencyUserModel feedbackUser);
+
+
+    /**
+     * 坐席填写维修回访相关信息
+     * @param dispatchRepairFeedbackDto
+     * @return
+     */
+    Boolean saveDispatchRepairFeedback(DispatchRepairFeedbackDto dispatchRepairFeedbackDto);
+
+    /**
+     * 根据警情id 返回 投诉回访相关信息
+     * @param alertId
+     * @return
+     */
+    DispatchConsultFeedbackDto getDispatchConsultFeedbackDtoByAlertId(Long alertId, AgencyUserModel feedbackUser);
+
+
+    /**
+     * 坐席填写投诉回访相关信息
+     * @param dispatchConsultFeedbackDto
+     * @return
+     */
+    Boolean saveDispatchConsultFeedback(DispatchConsultFeedbackDto dispatchConsultFeedbackDto);
+
+
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/java/com/yeejoin/amos/boot/module/tzs/api/vo/AlarmStatisticsVo.java

+package com.yeejoin.amos.boot.module.tzs.api.vo;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.experimental.Accessors;
+
+import java.util.Map;
+
+/**
+ *  * 警情统计
+ * @author fengwang
+ * @date 2021-08-06.
+ */
+@Data
+@Accessors(chain = true)
+@ApiModel(value = "AlarmStatisticsVo", description = "AlarmStatisticsVo")
+public class AlarmStatisticsVo {
+
+    @ApiModelProperty(value = "我的待办数量")
+    private Integer todoNum;
+
+    @ApiModelProperty(value = "今日接警数量")
+    private Integer todayAlarmNum;
+
+    @ApiModelProperty(value = "今日提交数量")
+    private Integer submitNum;
+
+    @ApiModelProperty(value = "全部待办")
+    private Integer allNum;
+
+    @ApiModelProperty(value = "近七天办理数量")
+    private Map<String,Integer> nearlySevenDaysNum;
+
+    @ApiModelProperty(value = "故障事件数量")
+    private Integer faultRescue;
+
+    @ApiModelProperty(value = "困人救援数量")
+    private Integer sleepyIncident;
+
+    @ApiModelProperty(value = "投诉建议数量")
+    private Integer suggestions;
+
+}

amos-boot-module/amos-boot-module-api/amos-boot-module-tzs-api/src/main/resources/mapper/AlertCalledMapper.xml

@@ -2,4 +2,28 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.yeejoin.amos.boot.module.tzs.api.mapper.AlertCalledMapper">
 
+    <select id="queryAlertStatusCount" resultType="java.util.Map">
+        SELECT
+        count( 1 ) calledCount,
+        sum( CASE WHEN father_alert = null THEN 1 ELSE 0 END ) majorAlertCount
+        sum( CASE WHEN alarm_type_code = 'KRJY' THEN 1 ELSE 0 END ) sleepyIncidentCount
+        sum( CASE WHEN alarm_type_code = 'GZWX'  THEN 1 ELSE 0 END ) faultRescueCount
+        sum( CASE WHEN alarm_type_code = 'TSZX' l THEN 1 ELSE 0 END ) suggestionsCount
+        FROM
+        tz_alert_called
+        WHERE 1 = 1
+        <if test="beginDate != null and beginDate != ''">
+            and call_time >= #{beginDate}
+        </if>
+        <if test="endDate != null and endDate != ''">
+            and call_time <![CDATA[ <= ]]> #{endDate}
+        </if>
+        <if test="alarmTypeCode != null and alarmTypeCode != ''">
+            and alarm_type_code = #{alarmTypeCode}
+        </if>
+        <if test="orgCode != null and orgCode != ''  and  recUserId != null and   recUserId != ''" >
+            and org_code= #{orgCode}
+            or rec_user_id = #{recUserId}
+        </if>
+    </select>
 </mapper>

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

@@ -507,7 +507,7 @@ public class CommandController extends BaseController {
         page.setCurrent(pageNum);
         page.setSize(pageSize);
         Page<LinkageUnitDto> linkageUnitDtoPage = iLinkageUnitService.queryForLinkageUnitPage(page, false,
-                unitName, linkageUnitType, null);
+                unitName, linkageUnitType, null, inAgreement);
 
         return ResponseHelper.buildResponse(linkageUnitDtoPage);
     }

amos-boot-module/amos-boot-module-biz/amos-boot-module-common-biz/src/main/java/com/yeejoin/amos/boot/module/common/biz/controller/LinkageUnitController.java

 package com.yeejoin.amos.boot.module.common.biz.controller;
 
-import com.yeejoin.amos.boot.biz.common.utils.DateUtils;
-import org.apache.commons.lang3.StringUtils;
-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.yeejoin.amos.boot.biz.common.controller.BaseController;
-
-import java.util.Date;
 import java.util.List;
-import java.util.stream.Collectors;
 
-import com.yeejoin.amos.boot.module.common.biz.service.impl.LinkageUnitServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+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.restful.doc.TycloudOperation;
 import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
-import org.springframework.beans.factory.annotation.Autowired;
 
-import org.springframework.web.bind.annotation.*;
 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.LinkageUnitDto;
-import org.typroject.tyboot.core.restful.doc.TycloudOperation;
-import org.typroject.tyboot.core.foundation.enumeration.UserType;
+import com.yeejoin.amos.boot.module.common.api.entity.LinkageUnit;
+import com.yeejoin.amos.boot.module.common.api.service.ILinkageUnitService;
+import com.yeejoin.amos.boot.module.common.biz.service.impl.LinkageUnitServiceImpl;
+
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
 
 
 /**
@@ -37,6 +41,9 @@ public class LinkageUnitController extends BaseController {
 
     @Autowired
     LinkageUnitServiceImpl linkageUnitServiceImpl;
+    
+    @Autowired
+    ILinkageUnitService linkageUnitService;
 
     /**
      * 新增联动单位
@@ -116,20 +123,12 @@ public class LinkageUnitController extends BaseController {
     @GetMapping(value = "/page")
     @ApiOperation(httpMethod = "GET", value = "联动单位分页查询", notes = "联动单位分页查询")
     public ResponseModel<Page<LinkageUnitDto>> queryForPage(@RequestParam(value = "current") int current, @RequestParam
-            (value = "size") int size, String unitName, String linkageUnitType, String inAgreement, String emergencyLinkageUnitCode) {
-        Page<LinkageUnitDto> page = new Page<LinkageUnitDto>();
+            (value = "size") int size, String unitName, String linkageUnitTypeCode, String inAgreement, String emergencyLinkageUnitCode) {
+    	Page<LinkageUnitDto> page = new Page<LinkageUnitDto>();
         page.setCurrent(current);
         page.setSize(size);
-        Page<LinkageUnitDto> linkageUnitDtoPage = linkageUnitServiceImpl.queryForLinkageUnitPage(page, false,
-                unitName, linkageUnitType, emergencyLinkageUnitCode);
-        Date now = new Date();
-        List<LinkageUnitDto> linkageUnitDtoList = linkageUnitDtoPage.getRecords().stream().map(item -> {
-            boolean isInAgreement = DateUtils.belongCalendar(now, item.getAgreementStartDate(),
-                    item.getAgreementEndDate());
-            item.setInAgreement(isInAgreement ? "是" : "否");
-            return item;
-        }).filter(item -> StringUtils.isEmpty(inAgreement) || inAgreement.equals(item.getInAgreement())).collect(Collectors.toList());
-        linkageUnitDtoPage.setRecords(linkageUnitDtoList);
+    	Page<LinkageUnitDto> linkageUnitDtoPage = linkageUnitServiceImpl.queryForLinkageUnitPage(page, false,
+                unitName, linkageUnitTypeCode, emergencyLinkageUnitCode,inAgreement);
         return ResponseHelper.buildResponse(linkageUnitDtoPage);
     }
 
@@ -144,4 +143,15 @@ public class LinkageUnitController extends BaseController {
     public ResponseModel<List<LinkageUnitDto>> selectForList() {
         return ResponseHelper.buildResponse(linkageUnitServiceImpl.queryForLinkageUnitList(false));
     }
+    /**
+     * 列表全部数据查询
+     *
+     * @return
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @ApiOperation(httpMethod = "GET", value = "联动单位列表树及统计", notes = "联动单位列表树及统计")
+    @GetMapping(value = "/getLinkageUnitTree")
+    public ResponseModel<Object> getLinkageUnitTree(@RequestParam String type, @RequestParam String rootName) {
+        return ResponseHelper.buildResponse(linkageUnitService.getEmergencyLinkageUnitCodeGroupBy(type,rootName));
+    }
 }

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

 package com.yeejoin.amos.boot.module.common.biz.service.impl;
 
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
+
+import javax.annotation.Resource;
+
+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.typroject.tyboot.core.foundation.utils.Bean;
+import org.typroject.tyboot.core.rdbms.annotation.Condition;
+import org.typroject.tyboot.core.rdbms.annotation.Operator;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
+
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-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.google.common.collect.Lists;
+import com.yeejoin.amos.boot.biz.common.entity.DataDictionary;
+import com.yeejoin.amos.boot.biz.common.service.impl.DataDictionaryServiceImpl;
+import com.yeejoin.amos.boot.biz.common.utils.DateUtils;
+import com.yeejoin.amos.boot.biz.common.utils.Menu;
 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.LinkageUnitDto;
 import com.yeejoin.amos.boot.module.common.api.dto.LinkageUnitZhDto;
 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.LinkageUnit;
 import com.yeejoin.amos.boot.module.common.api.entity.SourceFile;
-import com.yeejoin.amos.boot.module.common.api.mapper.DynamicFormInstanceMapper;
 import com.yeejoin.amos.boot.module.common.api.mapper.LinkageUnitMapper;
 import com.yeejoin.amos.boot.module.common.api.service.ILinkageUnitService;
-import com.yeejoin.amos.boot.module.common.api.dto.LinkageUnitDto;
-import org.springframework.beans.BeanUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.transaction.annotation.Transactional;
-import org.typroject.tyboot.core.foundation.utils.Bean;
-import org.typroject.tyboot.core.rdbms.annotation.Condition;
-import org.typroject.tyboot.core.rdbms.annotation.Operator;
-import org.typroject.tyboot.core.rdbms.service.BaseService;
-import org.springframework.stereotype.Service;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-
-import javax.annotation.Resource;
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-import java.util.Random;
 
 /**
  * 联动单位服务实现类
@@ -40,183 +46,248 @@ import java.util.Random;
  * @date 2021-07-16
  */
 @Service
-public class LinkageUnitServiceImpl extends BaseService<LinkageUnitDto, LinkageUnit, LinkageUnitMapper> implements ILinkageUnitService {
-
-    @Autowired
-    DynamicFormInstanceServiceImpl dynamicFormInstanceService;
-
-    @Resource
-    LinkageUnitMapper linkageUnitMapper;
-    @Autowired
-    DynamicFormColumnServiceImpl dynamicFormColumnService;
-    @Autowired
-    SourceFileServiceImpl sourceFileServiceImpl;
-
-    public String getGroupCode() {
-        return "linkageUnit";
-    }
-
-    /**
-     * 分页查询
-     */
-    @Override
-    public Page<LinkageUnitDto> queryForLinkageUnitPage(Page<LinkageUnitDto> page,
-                                                        @Condition(Operator.eq) Boolean isDelete,
-                                                        @Condition(Operator.like) String unitName,
-                                                        @Condition(Operator.eq) String linkageUnitType,
-                                                        @Condition(Operator.eq) String emergencyLinkageUnitCode) {
-        return this.queryForPage(page, null, false, isDelete, unitName, linkageUnitType, emergencyLinkageUnitCode);
-    }
-
-    /**
-     * 列表查询 示例
-     */
-    public List<LinkageUnitDto> queryForLinkageUnitList(@Condition(Operator.eq) Boolean isDelete) {
-        return this.queryForList("", false, isDelete);
-    }
-
-    /**
-     * 保存联动单位
-     *
-     * @param linkageUnitDto 对象
-     * @return List<LinkageUnitDto>
-     */
-    @Transactional
-    public LinkageUnitDto saveModel(LinkageUnitDto linkageUnitDto) {
-    	
-    	
-    	
-    	if(linkageUnitDto.getAddress()!=null){
-			String[]  data= linkageUnitDto.getAddress().split("@address@");
+public class LinkageUnitServiceImpl extends BaseService<LinkageUnitDto, LinkageUnit, LinkageUnitMapper>
+		implements ILinkageUnitService {
+
+	@Autowired
+	DynamicFormInstanceServiceImpl dynamicFormInstanceService;
+
+	@Resource
+	LinkageUnitMapper linkageUnitMapper;
+	@Autowired
+	DynamicFormColumnServiceImpl dynamicFormColumnService;
+	@Autowired
+	SourceFileServiceImpl sourceFileServiceImpl;
+
+	@Autowired
+	DataDictionaryServiceImpl iDataDictionaryService;
+
+	public String getGroupCode() {
+		return "linkageUnit";
+	}
+
+	/**
+	 * 分页查询
+	 * 
+	 * @param inAgreement
+	 */
+	@Override
+	public Page<LinkageUnitDto> queryForLinkageUnitPage(IPage<LinkageUnitDto> page,
+			@Condition(Operator.eq) Boolean isDelete, @Condition(Operator.like) String unitName,
+			@Condition(Operator.eq) String linkageUnitTypeCode, @Condition(Operator.eq) String emergencyLinkageUnitCode,
+			String inAgreement) {
+		Page<List<LinkageUnitDto>> linkageUnitList = linkageUnitMapper.getEmergencyLinkageUnitList(page,unitName, linkageUnitTypeCode, emergencyLinkageUnitCode);
+		List<Map> linkageUnitListMap =JSONArray.parseArray(JSONArray.toJSONString(linkageUnitList.getRecords()), Map.class);
+		
+		List<Map<String, Object>> pageList = dynamicFormInstanceService.listAll(getGroupCode());
+		linkageUnitListMap.forEach(i -> {
+			String mainString = i.get("instanceId").toString();
+			pageList.stream().forEach(detail -> {
+				if (detail.get("instanceId").toString().equals(mainString)) {
+					i.putAll(detail);
+				}
+			});
+		});
+		List<LinkageUnitDto> resultDtoList = JSONArray.parseArray(JSONArray.toJSONString(linkageUnitList.getRecords()),
+				LinkageUnitDto.class);
+		List<LinkageUnitDto> detaiList = resultDtoList.stream().map(item -> {
+			Date now = new Date();
+			boolean isInAgreement = DateUtils.belongCalendar(now, item.getAgreementStartDate(),
+					item.getAgreementEndDate());
+			item.setInAgreement(isInAgreement ? "是" : "否");
+			List<SourceFile> sourceFiles = sourceFileServiceImpl.findBySourceId(item.getSequenceNbr());
+			item.setImage(sourceFiles);
+			return item;
+		}).filter(item -> StringUtils.isEmpty(inAgreement) || inAgreement.equals(item.getInAgreement()))
+				.collect(Collectors.toList());
+
+		Page<LinkageUnitDto> page1 = new Page<LinkageUnitDto>();
+		page1.setCurrent(page.getCurrent());
+		page1.setSize(page.getSize());
+		page1.setTotal(detaiList.size());
+		page1.setRecords(detaiList);
+		return page1;
+	}
+
+	/**
+	 * 列表查询 示例
+	 */
+	public List<LinkageUnitDto> queryForLinkageUnitList(@Condition(Operator.eq) Boolean isDelete) {
+		return this.queryForList("", false, isDelete);
+	}
+
+	/**
+	 * 保存联动单位
+	 *
+	 * @param linkageUnitDto 对象
+	 * @return List<LinkageUnitDto>
+	 */
+	@Transactional
+	public LinkageUnitDto saveModel(LinkageUnitDto linkageUnitDto) {
+
+		if (linkageUnitDto.getAddress() != null) {
+			String[] data = linkageUnitDto.getAddress().split("@address@");
 			linkageUnitDto.setAddress(data[0]);
-			 if(data[1]!=null&&!"".equals(data[1])){
-				 JSONObject jSONObject = JSON.parseObject(data[1]);				 
-				 if(jSONObject.getString("longitude")!=null&&!"".equals(jSONObject.getString("longitude"))) {
-					 linkageUnitDto.setLongitude(Double.valueOf(jSONObject.getString("longitude")));
-				 }
-                 if(jSONObject.getString("longitude")!=null&&!"".equals(jSONObject.getString("longitude"))) {
-                	 linkageUnitDto.setLatitude(Double.valueOf(jSONObject.getString("latitude")));
-				 }
-			 }
-		 }
-         //1.保存行数据
-        String groupCode = this.getGroupCode();
-        Map<String, Object> map = Bean.BeantoMap(linkageUnitDto);
-        Long instanceId = dynamicFormInstanceService.commonSave(groupCode, map);
-        linkageUnitDto.setInstanceId(instanceId);
-        //2.保存基本信息
-        linkageUnitDto.setUnitCode(getUnitCodeStr());
-        LinkageUnitDto model = createWithModel(linkageUnitDto);
-        //3.保存照片信息
-        sourceFileServiceImpl.saveSourceFile(model.getSequenceNbr(), model.getImage());
-        //3.返回保存后的数据
-        return model;
-    }
-
-    @Override
-    public LinkageUnitDto queryOne(Long sequenceNbr) {
-        String groupCode = getGroupCode();
-        List<DynamicFormColumn> columns =
-                dynamicFormColumnService.list(new LambdaQueryWrapper<DynamicFormColumn>().eq(DynamicFormColumn::getGroupCode, groupCode));
-        Map<String, Object> fieldCodes = Bean.listToMap(columns, "fieldCode", "queryStrategy", DynamicFormColumn.class);
-        LinkageUnitDto linkageUnitDto = linkageUnitMapper.selectOne(false, fieldCodes, groupCode, sequenceNbr);
-        List<SourceFile> sourceFiles = sourceFileServiceImpl.findBySourceId(linkageUnitDto.getSequenceNbr());
-        linkageUnitDto.setImage(sourceFiles);
-        return linkageUnitDto;
-    }
-
-    @Transactional
-    public Boolean deleteById(Long sequenceNbr) {
-        // 删除基本信息
-        LinkageUnit linkageUnit = getById(sequenceNbr);
-        linkageUnit.setIsDelete(true);
-        updateById(linkageUnit);
-        // 删除行
-        Long instanceId = linkageUnit.getInstanceId();
-        List<DynamicFormInstance> dynamicFormInstanceList =
-                dynamicFormInstanceService.list(new LambdaQueryWrapper<DynamicFormInstance>().eq(DynamicFormInstance::getInstanceId, instanceId));
-        dynamicFormInstanceList.forEach(item -> item.setIsDelete(true));
-        boolean update = dynamicFormInstanceService.updateBatchById(dynamicFormInstanceList);
-        // 删除照片
-        sourceFileServiceImpl.saveSourceFile(sequenceNbr, new ArrayList<>());
-        return update;
-    }
-
-    @Transactional
-    public LinkageUnitDto updateById(LinkageUnitDto linkageUnitDto) {
-    	    	
-    	if(linkageUnitDto.getAddress()!=null){
-			String[]  data= linkageUnitDto.getAddress().split("@address@");
+			if (data[1] != null && !"".equals(data[1])) {
+				JSONObject jSONObject = JSON.parseObject(data[1]);
+				if (jSONObject.getString("longitude") != null && !"".equals(jSONObject.getString("longitude"))) {
+					linkageUnitDto.setLongitude(Double.valueOf(jSONObject.getString("longitude")));
+				}
+				if (jSONObject.getString("longitude") != null && !"".equals(jSONObject.getString("longitude"))) {
+					linkageUnitDto.setLatitude(Double.valueOf(jSONObject.getString("latitude")));
+				}
+			}
+		}
+		// 1.保存行数据
+		String groupCode = this.getGroupCode();
+		Map<String, Object> map = Bean.BeantoMap(linkageUnitDto);
+		Long instanceId = dynamicFormInstanceService.commonSave(groupCode, map);
+		linkageUnitDto.setInstanceId(instanceId);
+		// 2.保存基本信息
+		linkageUnitDto.setUnitCode(getUnitCodeStr());
+		LinkageUnitDto model = createWithModel(linkageUnitDto);
+		// 3.保存照片信息
+		sourceFileServiceImpl.saveSourceFile(model.getSequenceNbr(), model.getImage());
+		// 3.返回保存后的数据
+		return model;
+	}
+
+	@Override
+	public LinkageUnitDto queryOne(Long sequenceNbr) {
+		String groupCode = getGroupCode();
+		List<DynamicFormColumn> columns = dynamicFormColumnService
+				.list(new LambdaQueryWrapper<DynamicFormColumn>().eq(DynamicFormColumn::getGroupCode, groupCode));
+		Map<String, Object> fieldCodes = Bean.listToMap(columns, "fieldCode", "queryStrategy", DynamicFormColumn.class);
+		LinkageUnitDto linkageUnitDto = linkageUnitMapper.selectOne(false, fieldCodes, groupCode, sequenceNbr);
+		List<SourceFile> sourceFiles = sourceFileServiceImpl.findBySourceId(linkageUnitDto.getSequenceNbr());
+		linkageUnitDto.setImage(sourceFiles);
+		return linkageUnitDto;
+	}
+
+	@Transactional
+	public Boolean deleteById(Long sequenceNbr) {
+		// 删除基本信息
+		LinkageUnit linkageUnit = getById(sequenceNbr);
+		linkageUnit.setIsDelete(true);
+		updateById(linkageUnit);
+		// 删除行
+		Long instanceId = linkageUnit.getInstanceId();
+		List<DynamicFormInstance> dynamicFormInstanceList = dynamicFormInstanceService
+				.list(new LambdaQueryWrapper<DynamicFormInstance>().eq(DynamicFormInstance::getInstanceId, instanceId));
+		dynamicFormInstanceList.forEach(item -> item.setIsDelete(true));
+		boolean update = dynamicFormInstanceService.updateBatchById(dynamicFormInstanceList);
+		// 删除照片
+		sourceFileServiceImpl.saveSourceFile(sequenceNbr, new ArrayList<>());
+		return update;
+	}
+
+	@Transactional
+	public LinkageUnitDto updateById(LinkageUnitDto linkageUnitDto) {
+
+		if (linkageUnitDto.getAddress() != null) {
+			String[] data = linkageUnitDto.getAddress().split("@address@");
 			linkageUnitDto.setAddress(data[0]);
-			 if(data[1]!=null&&!"".equals(data[1])){
-				 JSONObject jSONObject = JSON.parseObject(data[1]);				 
-				 if(jSONObject.getString("longitude")!=null&&!"".equals(jSONObject.getString("longitude"))) {
-					 linkageUnitDto.setLongitude(Double.valueOf(jSONObject.getString("longitude")));
-				 }
-                 if(jSONObject.getString("longitude")!=null&&!"".equals(jSONObject.getString("longitude"))) {
-                	 linkageUnitDto.setLatitude(Double.valueOf(jSONObject.getString("latitude")));
-				 }
-			 }
-		 }  	
-        // 修改基本信息
-        updateWithModel(linkageUnitDto);
-        // 修改行信息
-        Long instanceId = linkageUnitDto.getInstanceId();
-        List<DynamicFormInstance> dynamicFormInstanceList =
-                dynamicFormInstanceService.list(new LambdaQueryWrapper<DynamicFormInstance>().eq(DynamicFormInstance::getInstanceId, instanceId));
-        Map<String, Object> objectMap = Bean.BeantoMap(linkageUnitDto);
-        dynamicFormInstanceList.forEach(item -> item.setFieldValue(objectMap.get(item.getFieldCode()) != null ?
-                objectMap.get(item.getFieldCode()).toString() : item.getFieldValue()));
-        dynamicFormInstanceService.updateBatchById(dynamicFormInstanceList);
-        // 修改照片信息
-        sourceFileServiceImpl.saveSourceFile(linkageUnitDto.getSequenceNbr(), linkageUnitDto.getImage());
-        return linkageUnitDto;
-    }
-
-    public static String getUnitCodeStr() {
-        return TreeParser.genTreeCode();
-    }
-
-    @Override
-    public List<LinkageUnitZhDto> listLinkageUnitZhDto(Integer pageNum, Integer pageSize, RequestData par) {
-        if (null == pageNum || null == pageSize) {
-            pageNum = 1;
-            pageSize = Integer.MAX_VALUE;
-        } else {
-            pageNum = (pageNum - 1) * pageSize;
-        }
-        return linkageUnitMapper.listLinkageUnitZhDto(pageNum, pageSize, par);
-    }
-
-    @Override
-    public Integer listLinkageUnitZhDtoCount(RequestData par) {
-        return linkageUnitMapper.listLinkageUnitZhDtoCount(par);
-    }
-
-    /**
-     * 批量删除
-     *
-     * @param sequenceNbrList
-     * @return
-     */
-    public Boolean batchDelete(List<Long> sequenceNbrList) {
-        // 删除基本信息
-        List<LinkageUnit> linkageUnitList = list(new LambdaQueryWrapper<LinkageUnit>().in(LinkageUnit::getSequenceNbr,
-                sequenceNbrList));
-        List<Long> instanceIdList = Lists.newArrayList();
-        linkageUnitList.forEach(item -> {
-            instanceIdList.add(item.getInstanceId());
-            item.setIsDelete(true);
-        });
-        updateBatchById(linkageUnitList);
-        // 删除行信息
-        List<DynamicFormInstance> dynamicFormInstanceList =
-                dynamicFormInstanceService.list(new LambdaQueryWrapper<DynamicFormInstance>().in(DynamicFormInstance::getInstanceId, instanceIdList));
-        dynamicFormInstanceList.forEach(item -> item.setIsDelete(true));
-        boolean update = dynamicFormInstanceService.updateBatchById(dynamicFormInstanceList);
-        // 删除照片
-        sourceFileServiceImpl.getBaseMapper().delete(new LambdaQueryWrapper<SourceFile>().in(SourceFile::getSourceId,
-                sequenceNbrList));
-        return update;
-    }
+			if (data[1] != null && !"".equals(data[1])) {
+				JSONObject jSONObject = JSON.parseObject(data[1]);
+				if (jSONObject.getString("longitude") != null && !"".equals(jSONObject.getString("longitude"))) {
+					linkageUnitDto.setLongitude(Double.valueOf(jSONObject.getString("longitude")));
+				}
+				if (jSONObject.getString("longitude") != null && !"".equals(jSONObject.getString("longitude"))) {
+					linkageUnitDto.setLatitude(Double.valueOf(jSONObject.getString("latitude")));
+				}
+			}
+		}
+		// 修改基本信息
+		updateWithModel(linkageUnitDto);
+		// 修改行信息
+		Long instanceId = linkageUnitDto.getInstanceId();
+		List<DynamicFormInstance> dynamicFormInstanceList = dynamicFormInstanceService
+				.list(new LambdaQueryWrapper<DynamicFormInstance>().eq(DynamicFormInstance::getInstanceId, instanceId));
+		Map<String, Object> objectMap = Bean.BeantoMap(linkageUnitDto);
+		dynamicFormInstanceList.forEach(item -> item.setFieldValue(
+				objectMap.get(item.getFieldCode()) != null ? objectMap.get(item.getFieldCode()).toString()
+						: item.getFieldValue()));
+		dynamicFormInstanceService.updateBatchById(dynamicFormInstanceList);
+		// 修改照片信息
+		sourceFileServiceImpl.saveSourceFile(linkageUnitDto.getSequenceNbr(), linkageUnitDto.getImage());
+		return linkageUnitDto;
+	}
+
+	public static String getUnitCodeStr() {
+		return TreeParser.genTreeCode();
+	}
+
+	@Override
+	public List<LinkageUnitZhDto> listLinkageUnitZhDto(Integer pageNum, Integer pageSize, RequestData par) {
+		if (null == pageNum || null == pageSize) {
+			pageNum = 1;
+			pageSize = Integer.MAX_VALUE;
+		} else {
+			pageNum = (pageNum - 1) * pageSize;
+		}
+		return linkageUnitMapper.listLinkageUnitZhDto(pageNum, pageSize, par);
+	}
+
+	@Override
+	public Integer listLinkageUnitZhDtoCount(RequestData par) {
+		return linkageUnitMapper.listLinkageUnitZhDtoCount(par);
+	}
+
+	/**
+	 * 批量删除
+	 *
+	 * @param sequenceNbrList
+	 * @return
+	 */
+	public Boolean batchDelete(List<Long> sequenceNbrList) {
+		// 删除基本信息
+		List<LinkageUnit> linkageUnitList = list(
+				new LambdaQueryWrapper<LinkageUnit>().in(LinkageUnit::getSequenceNbr, sequenceNbrList));
+		List<Long> instanceIdList = Lists.newArrayList();
+		linkageUnitList.forEach(item -> {
+			instanceIdList.add(item.getInstanceId());
+			item.setIsDelete(true);
+		});
+		updateBatchById(linkageUnitList);
+		// 删除行信息
+		List<DynamicFormInstance> dynamicFormInstanceList = dynamicFormInstanceService.list(
+				new LambdaQueryWrapper<DynamicFormInstance>().in(DynamicFormInstance::getInstanceId, instanceIdList));
+		dynamicFormInstanceList.forEach(item -> item.setIsDelete(true));
+		boolean update = dynamicFormInstanceService.updateBatchById(dynamicFormInstanceList);
+		// 删除照片
+		sourceFileServiceImpl.getBaseMapper()
+				.delete(new LambdaQueryWrapper<SourceFile>().in(SourceFile::getSourceId, sequenceNbrList));
+		return update;
+	}
+
+	public List<Menu> getEmergencyLinkageUnitCodeGroupBy(String type, String rootName) {
+		List<Map<String, Object>> map = linkageUnitMapper.getEmergencyLinkageUnitCodeGroupByAndCount();
+
+		LambdaQueryWrapper<DataDictionary> queryWrapper = new LambdaQueryWrapper<DataDictionary>();
+		queryWrapper.eq(DataDictionary::getType, type);
+		queryWrapper.eq(DataDictionary::getIsDelete, false);
+		queryWrapper.orderByAsc(DataDictionary::getSortNum);
+		List<DataDictionary> list = iDataDictionaryService.list(queryWrapper);
+		List<DataDictionary> resultList = new ArrayList<DataDictionary>();
+		list.stream().forEach(i -> {
+			map.stream().forEach(m -> {
+				if (m.containsKey("emergencyLinkageUnitCode") && m.get("emergencyLinkageUnitCode").toString().equals(i.getCode())) {
+					i.setName(i.getName() + " " + m.get("count"));
+					resultList.add(i);
+				}
+			});
+		});
+		List<Menu> menuList = new ArrayList<Menu>();
+		try {
+			List<Menu>	menus = TreeParser.getTree(null, resultList, DataDictionary.class.getName(), "getCode", 0, "getName",
+					"getParent", null);
+			Menu menu = new Menu(-1L, rootName, -1L, menus, 0);
+			// 挂在主节点
+			menuList.add(menu);
+		} catch (Exception e) {
+		log.debug("拼装tree树失败");
+		}
+		return menuList;
+	}
+
 }
\ 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/SourceFileServiceImpl.java

@@ -86,6 +86,7 @@ public class SourceFileServiceImpl extends BaseService<SourceFileDto, SourceFile
     /**
      * 保存附件
      */
+    @Override
     public void saveAttachments(Long sequenceNbr, Map<String, List<AttachmentDto>> attachmentMap) {
         if (!ValidationUtil.isEmpty(attachmentMap)) {
             List<SourceFile> sourceFiles = Lists.newArrayList();

amos-boot-module/amos-boot-module-biz/amos-boot-module-patrol-biz/src/main/java/com/yeejoin/amos/patrol/common/remote/RemoteWorkFlowService.java

 package com.yeejoin.amos.patrol.common.remote;
 
+import java.util.Map;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.util.StringUtils;
+import org.typroject.tyboot.core.foundation.context.RequestContext;
+
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.google.common.collect.Maps;
 import com.yeejoin.amos.patrol.business.constants.XJConstant;
-import com.yeejoin.amos.patrol.business.param.LatentDangerListParam;
 import com.yeejoin.amos.patrol.business.util.HttpUtil;
 import com.yeejoin.amos.patrol.common.enums.WorkFlowUriEnum;
 import com.yeejoin.amos.patrol.common.enums.YesOrNoEnum;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.stereotype.Service;
-import org.springframework.util.StringUtils;
-import org.typroject.tyboot.core.foundation.context.RequestContext;
-
-import java.util.Map;
 
 @Service("remoteWorkFlowService")
 public class RemoteWorkFlowService {

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/controller/AlertCalledController.java

@@ -4,8 +4,10 @@ import com.alibaba.fastjson.JSONObject;
 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.google.common.collect.Maps;
 import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
+import com.yeejoin.amos.boot.biz.common.utils.DateUtils;
 import com.yeejoin.amos.boot.biz.common.utils.NameUtils;
 import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
 import com.yeejoin.amos.boot.module.tzs.api.dto.AlertCalledDto;
@@ -15,6 +17,7 @@ import com.yeejoin.amos.boot.module.tzs.api.dto.ESAlertCalledRequestDto;
 import com.yeejoin.amos.boot.module.tzs.api.entity.AlertCalled;
 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.vo.AlarmStatisticsVo;
 import com.yeejoin.amos.boot.module.tzs.api.vo.AlertCalledVo;
 import com.yeejoin.amos.boot.module.tzs.biz.service.impl.AlertCalledServiceImpl;
 import com.yeejoin.amos.boot.module.tzs.biz.service.impl.AlertFormValueServiceImpl;
@@ -41,7 +44,9 @@ import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
 import java.lang.reflect.Field;
+import java.text.ParseException;
 import java.util.Arrays;
+import java.util.Date;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -135,6 +140,63 @@ public class AlertCalledController extends BaseController {
 		return ResponseHelper.buildResponse(iAlertCalledService.selectAlertCalledById(id));
 	}
 
+
+	/**
+	 * 警情统计
+	 *
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/alert-statistics")
+	@ApiOperation(httpMethod = "GET",value = "警情统计",  notes = "警情统计")
+	public ResponseModel<AlarmStatisticsVo> alertStatistics() throws ParseException {
+		ReginParams reginParams =
+				JSONObject.parseObject(null != redisUtils.get(buildKey(getToken())) ?
+						redisUtils.get(buildKey(getToken())).toString() : null, ReginParams.class);
+		//我的待办数量
+		QueryWrapper<AlertCalled> todoNumQueryWrapper = new QueryWrapper<>();
+		//全部待办数量
+		QueryWrapper<AlertCalled> allNumQueryWrapper = new QueryWrapper<>();
+
+		AlarmStatisticsVo alarmStatisticsVo = new AlarmStatisticsVo();
+		todoNumQueryWrapper.eq("alert_status",false);
+        allNumQueryWrapper.eq("alert_status",false);
+		if(null != reginParams) {
+			todoNumQueryWrapper.eq("rec_user_id",reginParams.getUserModel().getUserId());
+			todoNumQueryWrapper.or(true);
+			todoNumQueryWrapper.eq("org_code",reginParams.getCompany().getOrgCode());
+
+            alarmStatisticsVo.setTodoNum(iAlertCalledService.list(todoNumQueryWrapper).size());
+            alarmStatisticsVo.setAllNum(iAlertCalledService.list(allNumQueryWrapper).size());
+
+            Map<String, Object> map =    iAlertCalledService.getAlertInfoList(DateUtils.dateFormat(new Date(),"")+" 00:00:00",
+                    DateUtils.dateFormat(new Date(),"")+" 23:59:59",reginParams.getCompany().getOrgCode(),
+                    reginParams.getUserModel().getUserId());
+            // 当天接警
+            alarmStatisticsVo.setTodayAlarmNum(map.get("calledCount") == null  ? 0 : Integer.valueOf(map.get("calledCount").toString()))   ;
+            //当天提交
+            alarmStatisticsVo.setTodayAlarmNum(map.get("majorAlertCount") == null  ? 0 : Integer.valueOf(map.get("majorAlertCount").toString()))   ;
+            //投诉咨询数量
+            alarmStatisticsVo.setSuggestions(map.get("suggestionsCount") == null  ? 0 : Integer.valueOf(map.get("suggestionsCount").toString()))   ;
+            //故障维修数量
+            alarmStatisticsVo.setSuggestions(map.get("faultRescueCount") == null  ? 0 : Integer.valueOf(map.get("faultRescueCount").toString()))   ;
+            //困人救援数量
+            alarmStatisticsVo.setSuggestions(map.get("sleepyIncidentCount") == null  ? 0 : Integer.valueOf(map.get("sleepyIncidentCount").toString()))   ;
+
+            Map<String,Integer> recordMap = Maps.newHashMap();
+            // 近七天办理数量
+            for(int i = 1 ; i < 8; i++) {
+                Map<String, Object> nearlySevenDaysMap   =    iAlertCalledService.getAlertInfoList(
+                        DateUtils.dateFormat(DateUtils.dateAddDays(new Date(), -i),"")+" 00:00:00",
+                        DateUtils.dateFormat(DateUtils.dateAddDays(new Date(), -i),"")+" 23:59:59",reginParams.getCompany().getOrgCode(),
+                        reginParams.getUserModel().getUserId());
+                recordMap.put(DateUtils.dateFormat(DateUtils.dateAddDays(new Date(), -i),""),nearlySevenDaysMap.get("calledCount") == null  ? 0 : Integer.valueOf(nearlySevenDaysMap.get("calledCount").toString()));
+            }
+            alarmStatisticsVo.setNearlySevenDaysNum(recordMap);
+		}
+		return ResponseHelper.buildResponse(alarmStatisticsVo);
+	}
+
 	/**
      * 列表分页查询
      *

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

@@ -4,8 +4,11 @@ import com.alibaba.fastjson.JSONObject;
 import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
 import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
+import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchConsultFeedbackDto;
 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.dto.DispatchRepairFeedbackDto;
+import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchSaveFeedbackDto;
 import com.yeejoin.amos.boot.module.tzs.api.entity.DispatchPaper;
 import com.yeejoin.amos.boot.module.tzs.biz.service.impl.DispatchPaperServiceImpl;
 import io.swagger.annotations.Api;
@@ -42,28 +45,97 @@ public class DispatchPaperController extends BaseController {
 	@Autowired
 	RedisUtils redisUtils;
 
-    /**
-     * 新增派遣单
-     *
-     * @return
-     */
-    @TycloudOperation(ApiLevel = UserType.AGENCY)
-	@PostMapping(value = "/save")
-	@ApiOperation(httpMethod = "POST", value = "新增派遣单", notes = "新增派遣单")
-	public ResponseModel<DispatchPaperFormDto> save(@RequestBody DispatchPaperFormDto dispatchPaperFormDto) {
-		if (ValidationUtil.isEmpty(dispatchPaperFormDto)
-				|| ValidationUtil.isEmpty(dispatchPaperFormDto.getDispatchPaper()))
+	/**
+	 * 通过警情id 获取 救援回访相关信息
+	 * @param alertId
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/feedback/save/{alertId}")
+	@ApiOperation(httpMethod = "GET", value = "通过警情id 获取 救援回访相关信息", notes = "通过警情id 获取 救援回访相关信息")
+	public ResponseModel<DispatchSaveFeedbackDto> getSaveFeedback(@PathVariable Long alertId) {
+		ReginParams reginParams =
+				JSONObject.parseObject(null != redisUtils.get(buildKey(getToken())) ?
+						redisUtils.get(buildKey(getToken())).toString() : null, ReginParams.class);
+		DispatchSaveFeedbackDto dispatchSaveFeedbackDto = dispatchPaperServiceImpl.getDispatchSaveFeedbackDtoByAlertId(alertId,reginParams.getUserModel());
+		return ResponseHelper.buildResponse(dispatchSaveFeedbackDto);
+	}
+
+	/**
+	 * 保存救援回访信息
+	 * @param dispatchSaveFeedbackDto
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PostMapping(value = "/feedback/save")
+	@ApiOperation(httpMethod = "POST", value = "保存救援回访信息", notes = "保存救援回访信息")
+	public ResponseModel<Boolean> saveSaveFeedBack(@RequestBody DispatchSaveFeedbackDto dispatchSaveFeedbackDto) {
+		if (ValidationUtil.isEmpty(dispatchSaveFeedbackDto)
+				|| ValidationUtil.isEmpty(dispatchSaveFeedbackDto.getAlertId()))
 			throw new BadRequest("参数校验失败.");
+	    return ResponseHelper.buildResponse(dispatchPaperServiceImpl.saveDispatchSaveFeedback(dispatchSaveFeedbackDto));
+	}
+
+	/**
+	 * 通过警情id 获取 维修回访相关信息
+	 * @param alertId
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/feedback/repair/{alertId}")
+	@ApiOperation(httpMethod = "GET", value = "通过警情id 获取 维修回访相关信息", notes = "通过警情id 获取 维修回访相关信息")
+	public ResponseModel<DispatchRepairFeedbackDto> getRepairFeedBack(@PathVariable Long alertId) {
 		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);
+		DispatchRepairFeedbackDto dispatchRepairFeedbackDto = dispatchPaperServiceImpl.getDispatchRepairFeedbackDtoByAlertId(alertId,reginParams.getUserModel());
+		return ResponseHelper.buildResponse(dispatchRepairFeedbackDto);
+	}
+
+	/**
+	 * 保存维修回访信息
+	 * @param dispatchRepairFeedbackDto
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PostMapping(value = "/feedback/repair")
+	@ApiOperation(httpMethod = "POST", value = "保存维修回访信息", notes = "保存维修回访信息")
+	public ResponseModel<Boolean> saveRepairFeedBack(@RequestBody DispatchRepairFeedbackDto dispatchRepairFeedbackDto) {
+		if (ValidationUtil.isEmpty(dispatchRepairFeedbackDto)
+				|| ValidationUtil.isEmpty(dispatchRepairFeedbackDto.getAlertId()))
+			throw new BadRequest("参数校验失败.");
+		return ResponseHelper.buildResponse(dispatchPaperServiceImpl.saveDispatchRepairFeedback(dispatchRepairFeedbackDto));
+	}
+
+	/**
+	 * 通过警情id 获取 投诉回访相关信息
+	 * @param alertId
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@GetMapping(value = "/feedback/consult/{alertId}")
+	@ApiOperation(httpMethod = "GET", value = "通过警情id 获取 投诉回访相关信息", notes = "通过警情id 获取 投诉回访相关信息")
+	public ResponseModel<DispatchConsultFeedbackDto> getConsultFeedBack(@PathVariable Long alertId) {
+		ReginParams reginParams =
+				JSONObject.parseObject(null != redisUtils.get(buildKey(getToken())) ?
+						redisUtils.get(buildKey(getToken())).toString() : null, ReginParams.class);
+		DispatchConsultFeedbackDto dispatchConsultFeedbackDto = dispatchPaperServiceImpl.getDispatchConsultFeedbackDtoByAlertId(alertId,reginParams.getUserModel());
+		return ResponseHelper.buildResponse(dispatchConsultFeedbackDto);
+	}
+
+	/**
+	 * 保存投诉回访信息
+	 * @param dispatchConsultFeedbackDto
+	 * @return
+	 */
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@PostMapping(value = "/feedback/consult")
+	@ApiOperation(httpMethod = "POST", value = "保存投诉回访信息", notes = "保存投诉回访信息")
+	public ResponseModel<Boolean> saveConsultFeedBack(@RequestBody DispatchConsultFeedbackDto dispatchConsultFeedbackDto) {
+		if (ValidationUtil.isEmpty(dispatchConsultFeedbackDto)
+				|| ValidationUtil.isEmpty(dispatchConsultFeedbackDto.getAlertId()))
+			throw new BadRequest("参数校验失败.");
+		return ResponseHelper.buildResponse(dispatchPaperServiceImpl.saveDispatchConsultFeedback(dispatchConsultFeedbackDto));
 	}
 
 	/**

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/controller/ElevatorController.java

@@ -38,7 +38,7 @@ import java.util.List;
  */
 @RestController
 @Api(tags = "电梯Api")
-@RequestMapping(value = "/tzs/elevator")
+@RequestMapping(value = "/elevator")
 public class ElevatorController extends BaseController {
 
     private final Logger logger = LoggerFactory.getLogger(ElevatorController.class);
@@ -52,7 +52,7 @@ public class ElevatorController extends BaseController {
      * @param elevatorDto 新增参数
      * @return 返回结果
      */
-    @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
     @RequestMapping(value = "/save", method = RequestMethod.POST)
     @ApiOperation(httpMethod = "POST", value = "新增电梯", notes = "新增电梯")
     public ResponseModel<Boolean> saveElevator(@RequestBody ElevatorDto elevatorDto) {
@@ -67,12 +67,12 @@ public class ElevatorController extends BaseController {
      * @param id id
      * @return 返回结果
      */
-    @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
     @RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
     @ApiOperation(httpMethod = "DELETE", value = "根据id删除", notes = "根据id删除")
     public ResponseModel<Boolean> deleteById(@PathVariable Long id) {
-        boolean remove = iElevatorService.removeById(id);
-        return ResponseHelper.buildResponse(remove);
+        boolean removed = iElevatorService.removeById(id);
+        return ResponseHelper.buildResponse(removed);
     }
 
     /**
@@ -81,7 +81,7 @@ public class ElevatorController extends BaseController {
      * @param elevatorDto 修改参数
      * @return 返回结果
      */
-    @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
     @RequestMapping(value = "/updateById", method = RequestMethod.PUT)
     @ApiOperation(httpMethod = "PUT", value = "修改电梯", notes = "修改电梯")
     public ResponseModel<Boolean> updateByIdElevator(@RequestBody ElevatorDto elevatorDto) {
@@ -211,7 +211,7 @@ public class ElevatorController extends BaseController {
      * @param elevatorDto 查询参数
      * @return 查询结果
      */
-    @TycloudOperation(needAuth = false, ApiLevel = UserType.AGENCY)
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
     @RequestMapping(value = "/query_elevator_list", method = RequestMethod.GET)
     @ApiOperation(httpMethod = "GET", value = "分页查询电梯信息", notes = "分页查询电梯信息")
     public ResponseModel<IPage<ElevatorVo>> queryElevatorList(String pageNum, String pageSize,

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/controller/MaintenanceUnitController.java

@@ -41,7 +41,7 @@ import java.util.Arrays;
  */
 @RestController
 @Api(tags = "维保单位Api")
-@RequestMapping(value = "/tzs/maintenance-unit")
+@RequestMapping(value = "/maintenance-unit")
 public class MaintenanceUnitController extends BaseController {
     private final Logger logger = LoggerFactory.getLogger(MaintenanceUnitController.class);
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/controller/RescueStationController.java

@@ -37,7 +37,7 @@ import java.util.Date;
  */
 @RestController
 @Api(tags = "救援站Api")
-@RequestMapping(value = "/tzs/rescue-station")
+@RequestMapping(value = "/rescue-station")
 public class RescueStationController extends BaseController {
 
     private final Logger logger = LoggerFactory.getLogger(RescueStationController.class);

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/controller/UseUnitController.java

@@ -19,7 +19,11 @@ import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.*;
+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.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;
@@ -29,6 +33,8 @@ import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
 import java.util.Arrays;
 
+//import com.yeejoin.amos.boot.module.tzs.api.service.EquipFeignService;
+
 
 /**
  * 使用单位
@@ -38,7 +44,7 @@ import java.util.Arrays;
  */
 @RestController
 @Api(tags = "使用单位Api")
-@RequestMapping(value = "/tzs/use-unit")
+@RequestMapping(value = "/use-unit")
 public class UseUnitController extends BaseController {
     private final Logger logger = LoggerFactory.getLogger(UseUnitController.class);
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/service/impl/AlertCalledServiceImpl.java

@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.tzs.biz.service.impl;
 
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.google.common.collect.Maps;
 import com.yeejoin.amos.boot.biz.common.utils.DateUtils;
 import com.yeejoin.amos.boot.biz.common.utils.RedisKey;
 import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
@@ -32,6 +33,7 @@ import java.text.ParseException;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
 
 /**
  * 警情接警填报记录服务实现类
@@ -63,6 +65,10 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto,AlertCall
     @Autowired
     private RepairConsultServiceImpl repairConsultService;
 
+    @Autowired
+    AlertCalledMapper alertCalledMapper;
+
+
     private final Logger logger = LogManager.getLogger(AlertCalledServiceImpl.class);
 
 
@@ -224,4 +230,19 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto,AlertCall
         repairConsult.setDescription(transferDetails);
         repairConsultService.save(repairConsult);
     }
+
+    public Map<String, Object> getAlertInfoList(String beginDate, String endDate,String orgCode, String recUserId) {
+
+        Map<String, Object> result = Maps.newHashMap();
+        Map<String, Integer> statusCountMap = alertCalledMapper.queryAlertStatusCount(beginDate, endDate,orgCode,recUserId);
+
+        result.put("calledCount",statusCountMap.get("calledCount"));
+        result.put("majorAlertCount",statusCountMap.get("majorAlertCount"));
+        result.put("sleepyIncidentCount",statusCountMap.get("sleepyIncidentCount"));
+        result.put("faultRescueCount",statusCountMap.get("faultRescueCount"));
+        result.put("suggestionsCount",statusCountMap.get("suggestionsCount"));
+
+        return result;
+    }
+
 }
\ 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/DispatchPaperServiceImpl.java

 package com.yeejoin.amos.boot.module.tzs.biz.service.impl;
 
-import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.yeejoin.amos.boot.biz.common.bo.ReginParams;
-import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
+import com.yeejoin.amos.boot.biz.common.entity.DataDictionary;
+import com.yeejoin.amos.boot.biz.common.service.impl.DataDictionaryServiceImpl;
+import com.yeejoin.amos.boot.module.tzs.api.dto.AlertCalledFormDto;
 import com.yeejoin.amos.boot.module.tzs.api.dto.AlertFormInitDto;
+import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchConsultFeedbackDto;
 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.dto.DispatchRepairFeedbackDto;
+import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchSaveFeedbackDto;
 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.entity.DispatchTask;
+import com.yeejoin.amos.boot.module.tzs.api.entity.Elevator;
+import com.yeejoin.amos.boot.module.tzs.api.entity.MaintenanceUnit;
 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.service.IMaintenanceUnitService;
+import com.yeejoin.amos.boot.module.tzs.api.vo.AlertCalledVo;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
+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.typroject.tyboot.core.rdbms.service.BaseService;
+import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
 
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
 
-import static org.typroject.tyboot.core.foundation.context.RequestContext.getToken;
-
 /**
  * 派遣单服务实现类
  *
@@ -40,6 +50,21 @@ public class DispatchPaperServiceImpl extends BaseService<DispatchPaperDto,Dispa
     @Autowired
     private AlertFormServiceImpl alertFormServiceImpl;
 
+    @Autowired
+    private ElevatorServiceImpl elevatorServiceImpl;
+
+    @Autowired
+    private IMaintenanceUnitService iMaintenanceUnitService;
+
+    @Autowired
+    private AlertCalledServiceImpl alertCalledServiceImpl;
+
+    @Autowired
+    private DispatchTaskServiceImpl dispatchTaskServiceImpl;
+
+    @Autowired
+    private DataDictionaryServiceImpl iDataDictionaryService;
+
     /**
      * 分页查询
      */
@@ -93,7 +118,7 @@ public class DispatchPaperServiceImpl extends BaseService<DispatchPaperDto,Dispa
     }
 
     @Override
-    public Object selectDispatchPaperDtoByAlertId(Long alertId) {
+    public DispatchPaperFormDto selectDispatchPaperDtoByAlertId(Long alertId) {
         // 根据警情id 获取 派遣单信息
         DispatchPaper dispatchPaper =selectDispatchPaperByAlertId(alertId);
         // 封装dto
@@ -110,8 +135,8 @@ public class DispatchPaperServiceImpl extends BaseService<DispatchPaperDto,Dispa
     }
 
     @Override
-    public DispatchPaper createDispatchPaper(Long alertId, String alertCode, AgencyUserModel sendUser) {
-
+    public DispatchPaperFormDto createDispatchPaper(Long alertId, String alertCode, AgencyUserModel sendUser) {
+        DispatchPaperFormDto dispatchPaperFormDto = new DispatchPaperFormDto();
         // 创建基本信息
         DispatchPaper dispatchPaper = new DispatchPaper();
         dispatchPaper.setAlertCode(alertCode);
@@ -131,6 +156,11 @@ public class DispatchPaperServiceImpl extends BaseService<DispatchPaperDto,Dispa
         dispatchPaper.setSendUserId(sendUser.getUserId());
         dispatchPaper.setSendUserName(sendUser.getUserName());
 
+        // 电梯维保单位统一信用代码
+        Elevator elevator = elevatorServiceImpl.selectByAlertId(alertId);
+        MaintenanceUnit maintenanceUnit = iMaintenanceUnitService.getById(elevator.getMaintainUnitId());
+        dispatchPaper.setRepairOrgCreditCode(maintenanceUnit.getSocialCreditCode());
+
         this.save(dispatchPaper);
 
         // 根据类型创建动态表单信息
@@ -145,7 +175,535 @@ public class DispatchPaperServiceImpl extends BaseService<DispatchPaperDto,Dispa
         });
         // 保存动态表单数据
         iAlertFormValueService.saveBatch(paperFormValuelist);
-        return dispatchPaper;
+        dispatchPaperFormDto.setDispatchPaper(dispatchPaper);
+        dispatchPaperFormDto.setDynamicFormAlert(paperFormValuelist);
+        return dispatchPaperFormDto;
+    }
+
+    @Override
+    public DispatchSaveFeedbackDto getDispatchSaveFeedbackDtoByAlertId(Long alertId, AgencyUserModel feedbackUser) {
+        DispatchSaveFeedbackDto dispatchSaveFeedbackDto = new DispatchSaveFeedbackDto();
+        dispatchSaveFeedbackDto.setAlertId(alertId);
+        AlertCalledFormDto alertCalledFormVo = (AlertCalledFormDto) alertCalledServiceImpl.selectAlertCalledById(alertId);
+        // 警情信息
+        AlertCalledVo alertCalledVo = alertCalledFormVo.getAlertCalledVo();
+        dispatchSaveFeedbackDto.setEmergency(alertCalledVo.getEmergencyPerson());
+        dispatchSaveFeedbackDto.setEmergencyCall(alertCalledVo.getEmergencyCall());
+        // 派遣单信息
+        DispatchPaperFormDto dispatchPaperFormDto = this.selectDispatchPaperDtoByAlertId(alertId);
+        if(dispatchPaperFormDto == null || dispatchPaperFormDto.getDispatchPaper() == null) {
+            return new DispatchSaveFeedbackDto(); // 如果没有派遣就没有派遣反馈信息
+        }
+        DispatchPaper dispatchPaper = dispatchPaperFormDto.getDispatchPaper();
+        dispatchSaveFeedbackDto.setFeedbackCode(dispatchPaper.getFeedbackCode());
+        dispatchSaveFeedbackDto.setFeedbackType(dispatchPaper.getFeedbackType());
+        dispatchSaveFeedbackDto.setFeedbackFinishTime(dispatchPaper.getFeedbackFinishTime());
+        dispatchSaveFeedbackDto.setRemark(dispatchPaper.getRemark());
+        if(StringUtils.isBlank(dispatchPaper.getFeedbackUid())) {
+            dispatchSaveFeedbackDto.setFeedbackUid(feedbackUser.getUserId());
+        } else {
+            dispatchSaveFeedbackDto.setFeedbackUid(dispatchPaper.getFeedbackUid());
+        }
+        if(StringUtils.isBlank(dispatchPaper.getFeedbackUname())) {
+            dispatchSaveFeedbackDto.setFeedbackUname(feedbackUser.getUserName());
+        } else {
+            dispatchSaveFeedbackDto.setFeedbackUname(dispatchPaper.getFeedbackUname());
+        }
+
+        //救援响应人和维保响应人
+        Long useOrgTaskId = dispatchPaper.getUseOrgTaskId();
+        Long repairOrgTaskId = dispatchPaper.getRepairOrgTaskId();
+
+        // 如果维保单位和使用单位都下单了 默认显示维保单位
+        DispatchTask dispatchTask = null;
+        if(repairOrgTaskId != null) {
+            dispatchTask = dispatchTaskServiceImpl.getById(repairOrgTaskId);
+            dispatchSaveFeedbackDto.setResponseUserName(dispatchTask.getResponseUserName());
+            dispatchSaveFeedbackDto.setResponseUserTel(dispatchTask.getResponseUserTel());
+        } else if(useOrgTaskId != null) {
+            dispatchTask = dispatchTaskServiceImpl.getById(useOrgTaskId);
+            dispatchSaveFeedbackDto.setResponseUserName(dispatchTask.getResponseUserName());
+            dispatchSaveFeedbackDto.setResponseUserTel(dispatchTask.getResponseUserTel());
+        }
+        // 动态字段
+        List<AlertFormValue> dynamicFormAlert = dispatchPaperFormDto.getDynamicFormAlert();
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        dynamicFormAlert.stream().forEach(alertFormValue -> {
+            String value = null;
+            switch (alertFormValue.getFieldCode()) {
+                case "save_feedback_time":
+                    value = alertFormValue.getFieldValue();
+                    if (StringUtils.isBlank(value)) {
+                        dispatchSaveFeedbackDto.setSaveFeedbackTime(null);
+                    } else {
+                        try {
+                            dispatchSaveFeedbackDto.setSaveFeedbackTime(sdf.parse(value));
+                        } catch (ParseException e) {
+                            throw new BadRequest("救援时间格式错误");
+                        }
+                    }
+                    break;
+                case "save_feedback_user":
+                    value = alertFormValue.getFieldValue();
+                    if (StringUtils.isBlank(value)) {
+                        dispatchSaveFeedbackDto.setSaveFeedbackUser(feedbackUser.getUserName());
+                    } else {
+                        dispatchSaveFeedbackDto.setSaveFeedbackUser(value);
+                    }
+                    break;
+                case "save_feedback_uid":
+                    value = alertFormValue.getFieldValue();
+                    if (StringUtils.isBlank(value)) {
+                        dispatchSaveFeedbackDto.setSaveFeedbackUid(feedbackUser.getUserId());
+                    } else {
+                        dispatchSaveFeedbackDto.setSaveFeedbackUid(value);
+                    }
+                    break;
+                case "save_feedback_result":
+                    value = alertFormValue.getFieldValue();
+                    dispatchSaveFeedbackDto.setSaveFeedbackResult(value);
+                    break;
+                case "fix_result":
+                    value = alertFormValue.getFieldValue();
+                    dispatchSaveFeedbackDto.setFixResult(value);
+                    break;
+                case "error_result":
+                    value = alertFormValue.getFieldValue();
+                    dispatchSaveFeedbackDto.setErrorResult(value);
+                    break;
+            }
+
+        });
+
+        return dispatchSaveFeedbackDto;
+    }
+
+    @Override
+    public Boolean saveDispatchSaveFeedback(DispatchSaveFeedbackDto dispatchSaveFeedbackDto) {
+        Boolean flag = false;
+        // 保存救援回访信息
+        DispatchPaperFormDto dispatchPaperFormDto = this.selectDispatchPaperDtoByAlertId(dispatchSaveFeedbackDto.getAlertId());
+        DispatchPaper dispatchPaper = dispatchPaperFormDto.getDispatchPaper();
+        // 动态字段
+        List<AlertFormValue> dynamicFormAlert = dispatchPaperFormDto.getDynamicFormAlert();
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        dynamicFormAlert.stream().forEach(alertFormValue -> {
+                    switch (alertFormValue.getFieldCode()) {
+                        case "save_feedback_time":
+                            if (dispatchSaveFeedbackDto.getSaveFeedbackTime() != null)
+                                alertFormValue.setFieldValue(sdf.format(dispatchSaveFeedbackDto.getSaveFeedbackTime()));
+                            break;
+                        case "save_feedback_user":
+                            if (StringUtils.isNotBlank(dispatchSaveFeedbackDto.getSaveFeedbackUser()))
+                                alertFormValue.setFieldValue(dispatchSaveFeedbackDto.getSaveFeedbackUser());
+                            break;
+                        case "save_feedback_uid":
+                            if (StringUtils.isNotBlank(dispatchSaveFeedbackDto.getSaveFeedbackUid()))
+                                alertFormValue.setFieldValue(dispatchSaveFeedbackDto.getSaveFeedbackUid());
+                            break;
+                        case "save_feedback_result":
+                            if (StringUtils.isNotBlank(dispatchSaveFeedbackDto.getSaveFeedbackResult()))
+                                alertFormValue.setFieldValue(dispatchSaveFeedbackDto.getSaveFeedbackResult());
+                            break;
+                        case "fix_result":
+                            if (StringUtils.isNotBlank(dispatchSaveFeedbackDto.getFixResult())) {
+                                alertFormValue.setFieldValue(dispatchSaveFeedbackDto.getFixResult());
+                                QueryWrapper<DataDictionary> queryWrapper = new QueryWrapper<>();
+                                queryWrapper.eq("type", "WXJG").eq("name", dispatchSaveFeedbackDto.getFixResult());
+                                DataDictionary fixResult = iDataDictionaryService.getOne(queryWrapper);
+                                alertFormValue.setFieldValueCode(fixResult.getCode());
+                            }
+                            break;
+                        case "error_result":
+                            if (StringUtils.isNotBlank(dispatchSaveFeedbackDto.getErrorResult())) {
+                                alertFormValue.setFieldValue(dispatchSaveFeedbackDto.getErrorResult());
+                                QueryWrapper<DataDictionary> queryWrapper = new QueryWrapper<>();
+                                queryWrapper.eq("type", "GZYY").eq("name", dispatchSaveFeedbackDto.getErrorResult());
+                                DataDictionary errorResult = iDataDictionaryService.getOne(queryWrapper);
+                                alertFormValue.setFieldValueCode(errorResult.getCode());
+                            }
+                            break;
+                    }
+        });
+        dispatchPaper.setFeedbackCode(dispatchSaveFeedbackDto.getFeedbackCode());
+        dispatchPaper.setFeedbackType(dispatchSaveFeedbackDto.getFeedbackType());
+        dispatchPaper.setFeedbackFinishTime(dispatchSaveFeedbackDto.getFeedbackFinishTime());
+        dispatchPaper.setFeedbackUid(dispatchSaveFeedbackDto.getFeedbackUid());
+        dispatchPaper.setFeedbackUname(dispatchSaveFeedbackDto.getFeedbackUname());
+        dispatchPaper.setRemark(dispatchSaveFeedbackDto.getRemark());
+        dispatchPaper.setFeedbackTime(dispatchSaveFeedbackDto.getFeedbackTime());
+        // 保存动态表单数据
+        iAlertFormValueService.saveBatch(dynamicFormAlert);
+        // 保存派遣表
+        flag = this.save(dispatchPaper);
+        return flag;
+    }
+
+    @Override
+    public DispatchRepairFeedbackDto getDispatchRepairFeedbackDtoByAlertId(Long alertId, AgencyUserModel feedbackUser) {
+        DispatchRepairFeedbackDto dispatchRepairFeedbackDto = new DispatchRepairFeedbackDto();
+        dispatchRepairFeedbackDto.setAlertId(alertId);
+        AlertCalledFormDto alertCalledFormVo = (AlertCalledFormDto) alertCalledServiceImpl.selectAlertCalledById(alertId);
+        // 警情信息
+        AlertCalledVo alertCalledVo = alertCalledFormVo.getAlertCalledVo();
+        dispatchRepairFeedbackDto.setEmergency(alertCalledVo.getEmergencyPerson());
+        dispatchRepairFeedbackDto.setEmergencyCall(alertCalledVo.getEmergencyCall());
+
+        // 派遣单信息
+        DispatchPaperFormDto dispatchPaperFormDto = this.selectDispatchPaperDtoByAlertId(alertId);
+        if(dispatchPaperFormDto == null || dispatchPaperFormDto.getDispatchPaper() == null) {
+            return new DispatchRepairFeedbackDto(); // 如果没有派遣就没有派遣反馈信息
+        }
+
+        DispatchPaper dispatchPaper = dispatchPaperFormDto.getDispatchPaper();
+        dispatchRepairFeedbackDto.setFeedbackCode(dispatchPaper.getFeedbackCode());// 维修反馈code
+        dispatchRepairFeedbackDto.setFeedbackType(dispatchPaper.getFeedbackType());// 维修反馈类型
+        dispatchRepairFeedbackDto.setFeedbackFinishTime(dispatchPaper.getFeedbackFinishTime()); //维修完成时间
+        dispatchRepairFeedbackDto.setRemark(dispatchPaper.getRemark()); // 维修反馈备注
+        if(StringUtils.isBlank(dispatchPaper.getFeedbackUid())) { //维修反馈人
+            dispatchRepairFeedbackDto.setFeedbackUid(feedbackUser.getUserId());
+        } else {
+            dispatchRepairFeedbackDto.setFeedbackUid(dispatchPaper.getFeedbackUid());
+        }
+
+        if(StringUtils.isBlank(dispatchPaper.getFeedbackUname())) { //维修反馈人
+            dispatchRepairFeedbackDto.setFeedbackUname(feedbackUser.getUserName());
+        } else {
+            dispatchRepairFeedbackDto.setFeedbackUname(dispatchPaper.getFeedbackUname());
+        }
+
+
+        //维保响应人
+        Long useOrgTaskId = dispatchPaper.getUseOrgTaskId();
+        Long repairOrgTaskId = dispatchPaper.getRepairOrgTaskId();
+
+        // 如果维保单位和使用单位都下单了 默认显示维保单位
+        DispatchTask dispatchTask = null;
+        if(repairOrgTaskId != null) {
+            dispatchTask = dispatchTaskServiceImpl.getById(repairOrgTaskId);
+            dispatchRepairFeedbackDto.setResponseUserName(dispatchTask.getResponseUserName());
+            dispatchRepairFeedbackDto.setResponseUserTel(dispatchTask.getResponseUserTel());
+        } else if(useOrgTaskId != null) {
+            dispatchTask = dispatchTaskServiceImpl.getById(useOrgTaskId);
+            dispatchRepairFeedbackDto.setResponseUserName(dispatchTask.getResponseUserName());
+            dispatchRepairFeedbackDto.setResponseUserTel(dispatchTask.getResponseUserTel());
+        }
+
+        // 动态字段
+        List<AlertFormValue> dynamicFormAlert = dispatchPaperFormDto.getDynamicFormAlert();
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        dynamicFormAlert.stream().forEach(alertFormValue -> {
+            String value = null;
+            switch (alertFormValue.getFieldCode()) {
+                case "fix_feedback_time": //报修反馈时间
+                    value = alertFormValue.getFieldValue();
+                    if (StringUtils.isBlank(value)) {
+                        dispatchRepairFeedbackDto.setFixFeedbackTime(null);
+                    } else {
+                        try {
+                            dispatchRepairFeedbackDto.setFixFeedbackTime(sdf.parse(value));
+                        } catch (ParseException e) {
+                            throw new BadRequest("维修反馈时间格式错误");
+                        }
+                    }
+                    break;
+                case "feedback_result"://报修结果
+                    value = alertFormValue.getFieldValue();
+                    dispatchRepairFeedbackDto.setFeedbackResult(value);
+                    break;
+                case "fix_feedback_type":// 保修反馈方式
+                    value = alertFormValue.getFieldValue();
+                    dispatchRepairFeedbackDto.setFixFeedbackType(value);
+                    break;
+                case "fix_feedback_uname":
+                    value = alertFormValue.getFieldValue();
+                    if (StringUtils.isBlank(value)) {
+                        dispatchRepairFeedbackDto.setFixFeedbackUname(feedbackUser.getUserName());
+                    } else {
+                        dispatchRepairFeedbackDto.setFixFeedbackUname(value);
+                    }
+                    break;
+                case "fix_feedback_uid":
+                    value = alertFormValue.getFieldValue();
+                    if (StringUtils.isBlank(value)) {
+                        dispatchRepairFeedbackDto.setFixFeedbackUid(feedbackUser.getUserId());
+                    } else {
+                        dispatchRepairFeedbackDto.setFixFeedbackUid(value);
+                    }
+                    break;
+                case "fix_result":
+                    value = alertFormValue.getFieldValue();
+                    dispatchRepairFeedbackDto.setFixResult(value);
+                    break;
+                case "error_result":
+                    value = alertFormValue.getFieldValue();
+                    dispatchRepairFeedbackDto.setErrorResult(value);
+                    break;
+                case "fix_remark":
+                    value = alertFormValue.getFieldValue();
+                    dispatchRepairFeedbackDto.setFixRemark(value);
+                    break;
+            }
+
+        });
+
+        return dispatchRepairFeedbackDto;
+    }
+
+    @Override
+    public Boolean saveDispatchRepairFeedback(DispatchRepairFeedbackDto dispatchRepairFeedbackDto) {
+        Boolean flag = false;
+        // 保存救援回访信息
+        DispatchPaperFormDto dispatchPaperFormDto = this.selectDispatchPaperDtoByAlertId(dispatchRepairFeedbackDto.getAlertId());
+        DispatchPaper dispatchPaper = dispatchPaperFormDto.getDispatchPaper();
+        // 动态字段
+        List<AlertFormValue> dynamicFormAlert = dispatchPaperFormDto.getDynamicFormAlert();
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        dynamicFormAlert.stream().forEach(alertFormValue -> {
+            switch (alertFormValue.getFieldCode()) {
+                case "fix_feedback_time":
+                    if (dispatchRepairFeedbackDto.getFixFeedbackTime() != null)
+                        alertFormValue.setFieldValue(sdf.format(dispatchRepairFeedbackDto.getFixFeedbackTime()));
+                    break;
+                case "feedback_result":
+                    if (StringUtils.isNotBlank(dispatchRepairFeedbackDto.getFeedbackResult())) {
+                        alertFormValue.setFieldValue(dispatchRepairFeedbackDto.getFeedbackResult());
+                        QueryWrapper<DataDictionary> queryWrapper = new QueryWrapper<>();
+                        queryWrapper.eq("type", "FKJG").eq("name", dispatchRepairFeedbackDto.getFeedbackResult());
+                        DataDictionary feedbackType = iDataDictionaryService.getOne(queryWrapper);
+                        alertFormValue.setFieldValueCode(feedbackType.getCode());
+                    }
+                    break;
+                case "fix_feedback_type":
+                    if (StringUtils.isNotBlank(dispatchRepairFeedbackDto.getFixFeedbackType())) {
+                        alertFormValue.setFieldValue(dispatchRepairFeedbackDto.getFixFeedbackType());
+                        QueryWrapper<DataDictionary> queryWrapper = new QueryWrapper<>();
+                        queryWrapper.eq("type", "FKFS").eq("name", dispatchRepairFeedbackDto.getFixFeedbackType());
+                        DataDictionary feedbackType = iDataDictionaryService.getOne(queryWrapper);
+                        alertFormValue.setFieldValueCode(feedbackType.getCode());
+                    }
+                    break;
+                case "fix_feedback_uname":
+                    if (StringUtils.isNotBlank(dispatchRepairFeedbackDto.getFixFeedbackUname()))
+                        alertFormValue.setFieldValue(dispatchRepairFeedbackDto.getFixFeedbackUname());
+                    break;
+                case "fix_feedback_uid":
+                    if (StringUtils.isNotBlank(dispatchRepairFeedbackDto.getFixFeedbackUid()))
+                        alertFormValue.setFieldValue(dispatchRepairFeedbackDto.getFixFeedbackUid());
+                    break;
+                case "fix_result":
+                    if (StringUtils.isNotBlank(dispatchRepairFeedbackDto.getFixResult())) {
+                        alertFormValue.setFieldValue(dispatchRepairFeedbackDto.getFixResult());
+                        QueryWrapper<DataDictionary> queryWrapper = new QueryWrapper<>();
+                        queryWrapper.eq("type", "WXJG").eq("name", dispatchRepairFeedbackDto.getFixResult());
+                        DataDictionary fixResult = iDataDictionaryService.getOne(queryWrapper);
+                        alertFormValue.setFieldValueCode(fixResult.getCode());
+                    }
+                    break;
+                case "error_result":
+                    if (StringUtils.isNotBlank(dispatchRepairFeedbackDto.getErrorResult())) {
+                        alertFormValue.setFieldValue(dispatchRepairFeedbackDto.getErrorResult());
+                        QueryWrapper<DataDictionary> queryWrapper = new QueryWrapper<>();
+                        queryWrapper.eq("type", "GZYY").eq("name", dispatchRepairFeedbackDto.getErrorResult());
+                        DataDictionary errorResult = iDataDictionaryService.getOne(queryWrapper);
+                        alertFormValue.setFieldValueCode(errorResult.getCode());
+                    }
+                    break;
+                case "fix_remark":
+                    if (StringUtils.isNotBlank(dispatchRepairFeedbackDto.getFixRemark()))
+                        alertFormValue.setFieldValue(dispatchRepairFeedbackDto.getFixRemark());
+                    break;
+            }
+        });
+        dispatchPaper.setFeedbackCode(dispatchRepairFeedbackDto.getFeedbackCode());
+        dispatchPaper.setFeedbackType(dispatchRepairFeedbackDto.getFeedbackType());
+        dispatchPaper.setFeedbackFinishTime(dispatchRepairFeedbackDto.getFeedbackFinishTime());
+        dispatchPaper.setFeedbackUid(dispatchRepairFeedbackDto.getFeedbackUid());
+        dispatchPaper.setFeedbackUname(dispatchRepairFeedbackDto.getFeedbackUname());
+        dispatchPaper.setRemark(dispatchRepairFeedbackDto.getRemark());
+        dispatchPaper.setFeedbackTime(dispatchRepairFeedbackDto.getFeedbackTime());
+        // 保存动态表单数据
+        iAlertFormValueService.saveBatch(dynamicFormAlert);
+        // 保存派遣表
+        flag = this.save(dispatchPaper);
+        return flag;
+    }
+
+    @Override
+    public DispatchConsultFeedbackDto getDispatchConsultFeedbackDtoByAlertId(Long alertId, AgencyUserModel feedbackUser) {
+        DispatchConsultFeedbackDto dispatchConsultFeedbackDto = new DispatchConsultFeedbackDto();
+        dispatchConsultFeedbackDto.setAlertId(alertId);
+        AlertCalledFormDto alertCalledFormVo = (AlertCalledFormDto) alertCalledServiceImpl.selectAlertCalledById(alertId);
+        // 警情信息
+        AlertCalledVo alertCalledVo = alertCalledFormVo.getAlertCalledVo();
+        dispatchConsultFeedbackDto.setEmergency(alertCalledVo.getEmergencyPerson());
+        dispatchConsultFeedbackDto.setEmergencyCall(alertCalledVo.getEmergencyCall());
+
+        // 派遣单信息
+        DispatchPaperFormDto dispatchPaperFormDto = this.selectDispatchPaperDtoByAlertId(alertId);
+        if(dispatchPaperFormDto == null || dispatchPaperFormDto.getDispatchPaper() == null) {
+            return new DispatchConsultFeedbackDto(); // 如果没有派遣就没有派遣反馈信息
+        }
+
+        DispatchPaper dispatchPaper = dispatchPaperFormDto.getDispatchPaper();
+        dispatchConsultFeedbackDto.setFeedbackCode(dispatchPaper.getFeedbackCode());// 维修反馈code
+        dispatchConsultFeedbackDto.setFeedbackType(dispatchPaper.getFeedbackType());// 维修反馈类型
+        dispatchConsultFeedbackDto.setFeedbackTime(dispatchPaper.getFeedbackTime()); //回访时间
+        dispatchConsultFeedbackDto.setRemark(dispatchPaper.getRemark()); // 维修反馈备注
+        dispatchConsultFeedbackDto.setFeedbackFinishTime(dispatchPaper.getFeedbackFinishTime()); //维保完成时间
+        if(StringUtils.isBlank(dispatchPaper.getFeedbackUid())) { //维修反馈人
+            dispatchConsultFeedbackDto.setFeedbackUid(feedbackUser.getUserId());
+        } else {
+            dispatchConsultFeedbackDto.setFeedbackUid(dispatchPaper.getFeedbackUid());
+        }
+
+        if(StringUtils.isBlank(dispatchPaper.getFeedbackUname())) { //维修反馈人
+            dispatchConsultFeedbackDto.setFeedbackUname(feedbackUser.getUserName());
+        } else {
+            dispatchConsultFeedbackDto.setFeedbackUname(dispatchPaper.getFeedbackUname());
+        }
+
+
+        //维保响应人
+        Long useOrgTaskId = dispatchPaper.getUseOrgTaskId();
+        Long repairOrgTaskId = dispatchPaper.getRepairOrgTaskId();
+
+        // 如果维保单位和使用单位都下单了 默认显示维保单位
+        DispatchTask dispatchTask = null;
+        if(repairOrgTaskId != null) {
+            dispatchTask = dispatchTaskServiceImpl.getById(repairOrgTaskId);
+            dispatchConsultFeedbackDto.setResponseUserName(dispatchTask.getResponseUserName());
+            dispatchConsultFeedbackDto.setResponseUserTel(dispatchTask.getResponseUserTel());
+        } else if(useOrgTaskId != null) {
+            dispatchTask = dispatchTaskServiceImpl.getById(useOrgTaskId);
+            dispatchConsultFeedbackDto.setResponseUserName(dispatchTask.getResponseUserName());
+            dispatchConsultFeedbackDto.setResponseUserTel(dispatchTask.getResponseUserTel());
+        }
+
+        // 动态字段
+        List<AlertFormValue> dynamicFormAlert = dispatchPaperFormDto.getDynamicFormAlert();
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        dynamicFormAlert.stream().forEach(alertFormValue -> {
+            String value = null;
+            switch (alertFormValue.getFieldCode()) {
+                case "consult_feedback_time": //咨询反馈时间
+                    value = alertFormValue.getFieldValue();
+                    if (StringUtils.isBlank(value)) {
+                        dispatchConsultFeedbackDto.setConsultFeedbackTime(null);
+                    } else {
+                        try {
+                            dispatchConsultFeedbackDto.setConsultFeedbackTime(sdf.parse(value));
+                        } catch (ParseException e) {
+                            throw new BadRequest("咨询反馈时间格式错误");
+                        }
+                    }
+                    break;
+                case "action_result"://处置结果
+                    value = alertFormValue.getFieldValue();
+                    dispatchConsultFeedbackDto.setActionResult(value);
+                    break;
+                case "feedback_result"://咨询反馈结果
+                    value = alertFormValue.getFieldValue();
+                    dispatchConsultFeedbackDto.setFeedbackResult(value);
+                    break;
+                case "consult_feedback_type":// 咨询反馈方式
+                    value = alertFormValue.getFieldValue();
+                    dispatchConsultFeedbackDto.setConsultFeedbackType(value);
+                    break;
+                case "consult_feedback_uname":
+                    value = alertFormValue.getFieldValue();
+                    if (StringUtils.isBlank(value)) {
+                        dispatchConsultFeedbackDto.setConsultFeedbackUname(feedbackUser.getUserName());
+                    } else {
+                        dispatchConsultFeedbackDto.setConsultFeedbackUname(value);
+                    }
+                    break;
+                case "consult_feedback_uid":
+                    value = alertFormValue.getFieldValue();
+                    if (StringUtils.isBlank(value)) {
+                        dispatchConsultFeedbackDto.setConsultFeedbackUid(feedbackUser.getUserId());
+                    } else {
+                        dispatchConsultFeedbackDto.setConsultFeedbackUid(value);
+                    }
+                    break;
+                case "main_feedback_result":
+                    value = alertFormValue.getFieldValue();
+                    dispatchConsultFeedbackDto.setMainFeedbackResult(value);
+                    break;
+            }
+
+        });
+        return dispatchConsultFeedbackDto;
+    }
+
+    @Override
+    public Boolean saveDispatchConsultFeedback(DispatchConsultFeedbackDto dispatchConsultFeedbackDto) {
+        Boolean flag = false;
+        // 保存救援回访信息
+        DispatchPaperFormDto dispatchPaperFormDto = this.selectDispatchPaperDtoByAlertId(dispatchConsultFeedbackDto.getAlertId());
+        DispatchPaper dispatchPaper = dispatchPaperFormDto.getDispatchPaper();
+        // 动态字段
+        List<AlertFormValue> dynamicFormAlert = dispatchPaperFormDto.getDynamicFormAlert();
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        dynamicFormAlert.stream().forEach(alertFormValue -> {
+            switch (alertFormValue.getFieldCode()) {
+                case "consult_feedback_time":
+                    if (dispatchConsultFeedbackDto.getConsultFeedbackTime() != null)
+                        alertFormValue.setFieldValue(sdf.format(dispatchConsultFeedbackDto.getConsultFeedbackTime()));
+                    break;
+                case "action_result":
+                    if (StringUtils.isNotBlank(dispatchConsultFeedbackDto.getActionResult())) {
+                        alertFormValue.setFieldValue(dispatchConsultFeedbackDto.getActionResult());
+                        QueryWrapper<DataDictionary> queryWrapper = new QueryWrapper<>();
+                        queryWrapper.eq("type", "CZJG").eq("name", dispatchConsultFeedbackDto.getActionResult());
+                        DataDictionary feedbackType = iDataDictionaryService.getOne(queryWrapper);
+                        alertFormValue.setFieldValueCode(feedbackType.getCode());
+                    }
+                    break;
+                case "consult_feedback_type":
+                    if (StringUtils.isNotBlank(dispatchConsultFeedbackDto.getConsultFeedbackType())) {
+                        alertFormValue.setFieldValue(dispatchConsultFeedbackDto.getConsultFeedbackType());
+                        QueryWrapper<DataDictionary> queryWrapper = new QueryWrapper<>();
+                        queryWrapper.eq("type", "FKFS").eq("name", dispatchConsultFeedbackDto.getConsultFeedbackType());
+                        DataDictionary feedbackType = iDataDictionaryService.getOne(queryWrapper);
+                        alertFormValue.setFieldValueCode(feedbackType.getCode());
+                    }
+                    break;
+                case "consult_feedback_uname":
+                    if (StringUtils.isNotBlank(dispatchConsultFeedbackDto.getConsultFeedbackUname()))
+                        alertFormValue.setFieldValue(dispatchConsultFeedbackDto.getConsultFeedbackUname());
+                    break;
+                case "consult_feedback_uid":
+                    if (StringUtils.isNotBlank(dispatchConsultFeedbackDto.getConsultFeedbackUid()))
+                        alertFormValue.setFieldValue(dispatchConsultFeedbackDto.getConsultFeedbackUid());
+                    break;
+                case "main_feedback_result":
+                    if (StringUtils.isNotBlank(dispatchConsultFeedbackDto.getMainFeedbackResult()))
+                        alertFormValue.setFieldValue(dispatchConsultFeedbackDto.getMainFeedbackResult());
+                    break;
+                case "feedback_result":
+                    if (StringUtils.isNotBlank(dispatchConsultFeedbackDto.getFeedbackResult())) {
+                        alertFormValue.setFieldValue(dispatchConsultFeedbackDto.getFeedbackResult());
+                        QueryWrapper<DataDictionary> queryWrapper = new QueryWrapper<>();
+                        queryWrapper.eq("type", "FKJG").eq("name", dispatchConsultFeedbackDto.getFeedbackResult());
+                        DataDictionary feedbackType = iDataDictionaryService.getOne(queryWrapper);
+                        alertFormValue.setFieldValueCode(feedbackType.getCode());
+                    }
+                    break;
+            }
+        });
+        dispatchPaper.setFeedbackCode(dispatchConsultFeedbackDto.getFeedbackCode());
+        dispatchPaper.setFeedbackType(dispatchConsultFeedbackDto.getFeedbackType());
+        dispatchPaper.setFeedbackTime(dispatchConsultFeedbackDto.getFeedbackTime());
+        dispatchPaper.setFeedbackFinishTime(dispatchConsultFeedbackDto.getFeedbackFinishTime());
+        dispatchPaper.setFeedbackUid(dispatchConsultFeedbackDto.getFeedbackUid());
+        dispatchPaper.setFeedbackUname(dispatchConsultFeedbackDto.getFeedbackUname());
+        dispatchPaper.setRemark(dispatchConsultFeedbackDto.getRemark());
+        // 保存动态表单数据
+        iAlertFormValueService.saveBatch(dynamicFormAlert);
+        // 保存派遣表
+        flag = this.save(dispatchPaper);
+        return flag;
     }
 
     @Override

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

@@ -3,7 +3,7 @@ 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.DispatchPaperUpdateDto;
+import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchPaperFormDto;
 import com.yeejoin.amos.boot.module.tzs.api.dto.DispatchTaskDto;
 import com.yeejoin.amos.boot.module.tzs.api.entity.AlertFormValue;
 import com.yeejoin.amos.boot.module.tzs.api.entity.DispatchPaper;
@@ -13,7 +13,6 @@ import com.yeejoin.amos.boot.module.tzs.api.entity.MaintenanceUnit;
 import com.yeejoin.amos.boot.module.tzs.api.entity.RescueStation;
 import com.yeejoin.amos.boot.module.tzs.api.entity.Template;
 import com.yeejoin.amos.boot.module.tzs.api.entity.UseUnit;
-import com.yeejoin.amos.boot.module.tzs.api.enums.DispatchPaperEnums;
 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.service.IMaintenanceUnitService;
@@ -24,6 +23,7 @@ import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
+import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
 
 import java.text.SimpleDateFormat;
 import java.util.Date;
@@ -83,38 +83,78 @@ public class DispatchTaskServiceImpl extends BaseService<DispatchTaskDto,Dispatc
     public Boolean createDispatchTask(DispatchTaskDto dispatchTaskDto, AgencyUserModel sendUser) {
         boolean flag = false;
         // 判断派遣单是否存在 如果不存在先创建派遣单
-        DispatchPaper dispatchPaper = dispatchPaperServiceImpl.selectDispatchPaperByAlertId(dispatchTaskDto.getAlertId());
-        if(dispatchPaper == null) {
-            dispatchPaper = dispatchPaperServiceImpl.createDispatchPaper(dispatchTaskDto.getAlertId(), dispatchTaskDto.getAlertCode(), sendUser);
+        DispatchPaperFormDto dispatchPaperDto = dispatchPaperServiceImpl.selectDispatchPaperDtoByAlertId(dispatchTaskDto.getAlertId());
+        if(dispatchPaperDto == null || dispatchPaperDto.getDispatchPaper() == null) {
+            dispatchPaperDto = dispatchPaperServiceImpl.createDispatchPaper(dispatchTaskDto.getAlertId(), dispatchTaskDto.getAlertCode(), sendUser);
         }
+        DispatchPaper dispatchPaper = dispatchPaperDto.getDispatchPaper();
+        List<AlertFormValue> dynamicFormAlert = dispatchPaperDto.getDynamicFormAlert();
         // 创建派遣单
         dispatchTaskDto.setDispatchTime(new Date());
         DispatchTask dispatchTask = BeanDtoVoUtils.convert(dispatchTaskDto, DispatchTask.class);
-        dispatchTask.setPaperId(dispatchPaper.getSequenceNbr());
+        dispatchTask.setPaperId(dispatchPaperDto.getSequenceNbr());
         flag = this.save(dispatchTask);
         if(flag) { // 创建好派遣任务单以后根据任务单类型修改派遣单信息
-            DispatchPaperUpdateDto paperUpdateDto = new DispatchPaperUpdateDto();
-            paperUpdateDto.setPageId(dispatchPaper.getSequenceNbr());
-            paperUpdateDto.setTaskId(dispatchTask.getSequenceNbr());
-            paperUpdateDto.setOrgTypeCode(dispatchTask.getOrgTypeCode());
-            paperUpdateDto.setDispatchTime(dispatchTask.getDispatchTime());
-            paperUpdateDto.setOrgId(dispatchTask.getResponseOrgId());
             // 社会信用代码 根据类型查找放入
+            MaintenanceUnit maintenanceUnit = null;
             switch (dispatchTask.getOrgTypeCode()) {
                 case "useUnit": // 使用单位
                     UseUnit useUnit = iUseUnitService.getById(dispatchTask.getResponseOrgId());
-                    paperUpdateDto.setOrgCreditCode(useUnit.getSocialCreditCode());
+                    dispatchPaper.setUseOrgId(useUnit.getSequenceNbr());
+                    dispatchPaper.setUseOrgTaskId(dispatchTask.getSequenceNbr());
                     break;
                 case "repairUnit":
+                    maintenanceUnit  = iMaintenanceUnitService.getById(dispatchTask.getResponseOrgId());
+                    dispatchPaper.setRepairOrgId(maintenanceUnit.getSequenceNbr());
+                    dispatchPaper.setRepairOrgTaskId(dispatchTask.getSequenceNbr());
+                    break;
                 case "levelOneUnit":
-                    MaintenanceUnit maintenanceUnit  = iMaintenanceUnitService.getById(dispatchTask.getResponseOrgId());
-                    paperUpdateDto.setOrgCreditCode(maintenanceUnit.getSocialCreditCode());
+                    if(dispatchPaper.getRepairOrgId() != null) { // 已经派遣过调派
+                        throw new BadRequest("已经派遣过其他力量调派");
+                    } else {
+                        maintenanceUnit  = iMaintenanceUnitService.getById(dispatchTask.getResponseOrgId());
+                        String socialCreditCode = maintenanceUnit.getSocialCreditCode();
+                        dispatchPaper.setRepairOrgId(maintenanceUnit.getSequenceNbr());
+                        dispatchPaper.setRepairOrgTaskId(dispatchTask.getSequenceNbr());
+                        // 修改动态字段
+                        dynamicFormAlert.stream().forEach(alertFormValue -> {
+                            if(alertFormValue.getFieldCode().equals("dispatch_status")) {
+                                alertFormValue.setFieldValue("已派遣");
+                                alertFormValue.setFieldValueCode("hasDispatched");
+                            } else if(alertFormValue.getFieldCode().equals("response_level")) {
+                                alertFormValue.setFieldValue("一级响应");
+                                alertFormValue.setFieldValueCode("levelOneUnit");
+                            } else if(alertFormValue.getFieldCode().equals("save_credit_code")) {
+                                alertFormValue.setFieldValue(socialCreditCode);
+                            }
+                        });
+
+                    }
                     break;
                 case "levelTwoUnit":
-                    RescueStation rescueStation = iRescueStationService.getById(dispatchTask.getResponseOrgId());
+                    if(dispatchPaper.getRepairOrgId() != null) { // 已经派遣过调派
+                        throw new BadRequest("已经派遣过其他力量调派");
+                    } else {
+                        RescueStation rescueStation = iRescueStationService.getById(dispatchTask.getResponseOrgId());
+                        dispatchPaper.setRepairOrgId(rescueStation.getSequenceNbr());
+                        dispatchPaper.setRepairOrgTaskId(dispatchTask.getSequenceNbr());
+                        // 修改动态字段
+                        dynamicFormAlert.stream().forEach(alertFormValue -> {
+                            if(alertFormValue.getFieldCode().equals("dispatch_status")) {
+                                alertFormValue.setFieldValue("已派遣");
+                                alertFormValue.setFieldValueCode("hasDispatched");
+                            } else if(alertFormValue.getFieldCode().equals("response_level")) {
+                                alertFormValue.setFieldValue("二级响应");
+                                alertFormValue.setFieldValueCode("levelTwoUnit");
+                            }
+                        });
+                    }
                     break;
             }
-
+            //  保存派遣单
+            dispatchPaperServiceImpl.save(dispatchPaper);
+            // 保存动态表单数据
+            iAlertFormValueService.saveBatch(dynamicFormAlert);
         }
         return flag;
     }

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/service/impl/ElevatorServiceImpl.java

 package com.yeejoin.amos.boot.module.tzs.biz.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+//import com.yeejoin.amos.boot.module.common.api.service.ISourceFileService;
+import com.yeejoin.amos.boot.module.common.api.service.ISourceFileService;
 import com.yeejoin.amos.boot.module.tzs.api.dto.AlertCalledDto;
+import com.yeejoin.amos.boot.module.tzs.api.dto.ElevatorDto;
 import com.yeejoin.amos.boot.module.tzs.api.entity.Elevator;
 import com.yeejoin.amos.boot.module.tzs.api.mapper.ElevatorMapper;
 import com.yeejoin.amos.boot.module.tzs.api.service.IElevatorService;
 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.service.BaseService;
 import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
 
 /**
@@ -18,12 +21,42 @@ import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
 * @date 2021-06-01
 */
 @Service
-public class ElevatorServiceImpl extends ServiceImpl<ElevatorMapper, Elevator> implements IElevatorService {
+public class ElevatorServiceImpl extends BaseService<ElevatorDto, Elevator, ElevatorMapper> implements IElevatorService {
 
+//    @Autowired
+//    ISourceFileService sourceFileService;
 
     @Autowired
     AlertCalledServiceImpl alertCalledServiceImpl;
 
+    /**
+     * 保存电梯信息
+     *
+     * @param elevatorDto
+     * @return
+     */
+    public ElevatorDto saveElevator(ElevatorDto elevatorDto) {
+        elevatorDto = createWithModel(elevatorDto);
+
+        // TODO 保存附件
+//        sourceFileService.saveAttachments(elevatorDto.getSequenceNbr(), elevatorDto.getAttachments());
+        return elevatorDto;
+    }
+
+    /**
+     * 更新电梯信息
+     *
+     * @param elevatorDto
+     * @return
+     */
+    public ElevatorDto updateElevator(ElevatorDto elevatorDto) {
+        elevatorDto = updateWithModel(elevatorDto);
+
+        // TODO 保存附件
+//        sourceFileService.saveAttachments(elevatorDto.getSequenceNbr(), elevatorDto.getAttachments());
+        return elevatorDto;
+    }
+
 
     @Override
     public Elevator selectByAlertId(Long alertId) {
@@ -37,7 +70,7 @@ public class ElevatorServiceImpl extends ServiceImpl<ElevatorMapper, Elevator> i
         // 目前只有电梯类型
         QueryWrapper<Elevator> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("rescue_code", deviceId);
-        Elevator elevator  = this.getOne(queryWrapper);
+        Elevator elevator = this.getOne(queryWrapper);
         if (ValidationUtil.isEmpty(elevator))
             throw new BadRequest("设备未找到");
         return elevator;

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/service/impl/RescueStationServiceImpl.java

 package com.yeejoin.amos.boot.module.tzs.biz.service.impl;
 
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.yeejoin.amos.boot.module.tzs.api.dto.RescueStationDto;
 import com.yeejoin.amos.boot.module.tzs.api.entity.RescueStation;
 import com.yeejoin.amos.boot.module.tzs.api.mapper.RescueStationMapper;
 import com.yeejoin.amos.boot.module.tzs.api.service.IRescueStationService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
 
 import java.util.List;
 
@@ -17,7 +17,7 @@ import java.util.List;
 * @date 2021-06-01
 */
 @Service
-public class RescueStationServiceImpl extends ServiceImpl<RescueStationMapper, RescueStation> implements IRescueStationService {
+public class RescueStationServiceImpl extends BaseService<RescueStationDto, RescueStation, RescueStationMapper> implements IRescueStationService {
 
     @Autowired
     RescueStationMapper rescueStationMapper;

amos-boot-module/amos-boot-module-biz/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/service/impl/UseUnitServiceImpl.java

 package com.yeejoin.amos.boot.module.tzs.biz.service.impl;
 
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yeejoin.amos.boot.module.tzs.api.dto.UseUnitDto;
 import com.yeejoin.amos.boot.module.tzs.api.entity.UseUnit;
 import com.yeejoin.amos.boot.module.tzs.api.mapper.UseUnitMapper;
 import com.yeejoin.amos.boot.module.tzs.api.service.IUseUnitService;
 import org.springframework.stereotype.Service;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
 
 /**
 *  服务实现类
@@ -13,6 +14,6 @@ import org.springframework.stereotype.Service;
 * @date 2021-06-01
 */
 @Service
-public class UseUnitServiceImpl extends ServiceImpl<UseUnitMapper, UseUnit> implements IUseUnitService {
+public class UseUnitServiceImpl extends BaseService<UseUnitDto, UseUnit, UseUnitMapper> implements IUseUnitService {
 
 }