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-ccs-api/src/main/resources/mapper/FireRiskSourceMapper.xml

@@ -7,6 +7,7 @@
             rs.mrid,
             rs.`name`,
             rs.parent_mrid,
+            rs.risk_level_mrid,
             IFNULL(rs.rpn, 0) rpn,
             IFNULL(rs.rpni, 0) rpni
         FROM `asf_fire_risk_source` rs

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/dto/AlertCallCommandDto.java

+package com.yeejoin.amos.boot.module.jcs.api.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * @author litw
+ * @date 2021-11-26.
+ */
+@Data
+public class AlertCallCommandDto {
+
+    @ApiModelProperty(value = "名称")
+    String name;
+
+    @ApiModelProperty(value = "职务")
+    String duty;
+
+}

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/dto/AlertCalledDto.java

@@ -113,4 +113,7 @@ public class AlertCalledDto extends BaseDto{
     private String systemSource;
     @ApiModelProperty(value = "系统来源code")
     private String systemSourceCode;
+
+    @ApiModelProperty(value = "处置记录url")
+    private String recordUrl;
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/dto/AlertCalledMobDto.java

+package com.yeejoin.amos.boot.module.jcs.api.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author ltw
+ * @date 2021-11-25.
+ */
+@Data
+public class AlertCalledMobDto {
+
+    @ApiModelProperty(value = "力量调派")
+    List<AlertCalledPowerInfoDto>  alertCalledPowerInfoDtoList;
+
+    @ApiModelProperty(value = "指挥力量")
+    List<AlertCallCommandDto>  alertCallCommandDtoList;
+
+    @ApiModelProperty(value = "年度")
+    String year;
+
+    @ApiModelProperty(value = "灾害单位")
+    String unit;
+
+    @ApiModelProperty(value = "详细地址")
+    String address;
+
+    @ApiModelProperty(value = "警情类型")
+    String alertType;
+
+    @ApiModelProperty(value = "来源类型")
+    String sourceType;
+
+    @ApiModelProperty(value = "报警人姓名")
+    String reportName;
+
+    @ApiModelProperty(value = "联系电话")
+    String conectPhone;
+
+    @ApiModelProperty(value = "接警时间")
+    String callTime;
+
+    @ApiModelProperty(value = "出动时间")
+    String toTime;
+
+    @ApiModelProperty(value = "到场时间")
+    String arriveTime;
+
+    @ApiModelProperty(value = "控制时间")
+    String controlTime;
+
+    @ApiModelProperty(value = "结束时间")
+    String endTime;
+
+
+
+}

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/dto/AlertCalledPowerInfoDto.java

+package com.yeejoin.amos.boot.module.jcs.api.dto;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+/**
+ * @author litw
+ * @date 2021-11-25.
+ */
+@Data
+public class AlertCalledPowerInfoDto {
+
+    @ApiModelProperty(value = "队站")
+    String station;
+
+    @ApiModelProperty(value = "到场时间")
+    String arriveTime;
+
+    @ApiModelProperty(value = "车辆名称")
+    String carName;
+
+    @ApiModelProperty(value = "参战人数")
+    String personNum;
+
+    @ApiModelProperty(value = "水")
+    String water;
+
+    @ApiModelProperty(value = "泡沫")
+    String foam;
+
+    @ApiModelProperty(value = "干粉")
+    String dryPowder;
+
+    @ApiModelProperty(value = "其他")
+    String other;
+
+    @ApiModelProperty(value = "第一次出动调派车辆数量")
+    String disatchNum;
+
+}

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/dto/AlertCalledZhDto.java

@@ -64,4 +64,13 @@ public class AlertCalledZhDto {
 
     @ApiModelProperty(value = "警情修改时间")
     private Date updateTime;
+
+    @ApiModelProperty(value = "处置记录url")
+    private String recordUrl;
+
+    /**
+     * 警情状态
+     */
+    @ApiModelProperty(value = "警情状态")
+    private Boolean alertStatus;
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/dto/IotSystemAlarmRo.java

+package com.yeejoin.amos.boot.module.jcs.api.dto;
+
+import com.yeejoin.amos.component.rule.Label;
+import com.yeejoin.amos.component.rule.RuleFact;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Map;
+
+/**
+ * @ProjectName: EquipManageRoot
+ * @Package: com.yeejoin.equipmanage.common.vo
+ * @ClassName: ConfirmAlamVo
+ * @Author: Jianqiang Gao
+ * @Description: ConfirmAlamVo
+ * @Date: 2021/9/16 11:31
+ * @Version: 1.0
+ */
+@Data
+@RuleFact(value = "确警消息",project = "消息规则")
+public class IotSystemAlarmRo implements Serializable {
+
+    private static final long serialVersionUID = -8807644006700780121L;
+
+    @Label(value = "物联警情id")
+    private Long id;
+
+    @Label(value = "联系人")
+    private String contactUser;
+
+    @Label(value = "联系人电话")
+    private String contactPhone;
+
+    @Label(value = "事发单位")
+    private String unitInvolvedId;
+
+    @Label(value = "事发单位名称")
+    private String unitInvolvedName;
+
+    @Label(value = "建筑经度")
+    private Double longitude;
+
+    @Label(value = "建筑纬度")
+    private Double latitude;
+
+    @Label(value = "地址")
+    private String address;
+
+    @Label(value = "火灾地址")
+    private String fireLocation;
+
+    @Label(value = "楼经度")
+    private Double floorLongitude;
+
+    @Label(value = "楼纬度")
+    private Double floorLatitude;
+
+    @Label(value = "发送到web标识")
+    private Boolean isSendWeb;
+
+    @Label("关联id")
+    private String relationId;
+
+    @Label("消息类型")
+    private String msgType;
+
+    @Label(value = "终端标识")
+    private String terminal;
+
+    @Label(value = "类别")
+    private Integer category;
+
+    @Label(value = "扩展参数")
+    private Map<String, String> extras;
+}
\ No newline at end of file

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/entity/AlertCalled.java

@@ -104,7 +104,8 @@ public class AlertCalled extends BaseEntity {
     @ApiModelProperty(value = "备注信息")
     private String remark;
 
-
+    @ApiModelProperty(value = "处置记录url")
+    private String recordUrl;
 
 
 

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/mapper/AlertSubmittedMapper.java

@@ -2,10 +2,10 @@ package com.yeejoin.amos.boot.module.jcs.api.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedDto;
-import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedZHDto;
-import com.yeejoin.amos.boot.module.jcs.api.entity.AlertSubmitted;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedExtDto;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedSMSDto;
+import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedZHDto;
+import com.yeejoin.amos.boot.module.jcs.api.entity.AlertSubmitted;
 import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
@@ -57,4 +57,9 @@ public interface AlertSubmittedMapper extends BaseMapper<AlertSubmitted> {
 
     Map<String, Integer> getUseNum(@Param("id") Long id);
 
+
+    List<Map<String, Object>> getFirst(@Param("alertId") Long alertId);
+
+    List<Map<String, Object>> getOther(@Param("alertId") Long alertId);
+
 }

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/java/com/yeejoin/amos/boot/module/jcs/api/service/IVoiceRecordFileService.java

@@ -16,8 +16,6 @@ import java.util.List;
  */
 public interface IVoiceRecordFileService {
 
-    void publishRecord(VoiceRecordFileDto model);
-
     Page<VoiceRecordFileDto> queryRecordListByQueryDto(Page<VoiceRecordFileDto> page, String telEndTimeStr, String telEndTimeStr1, String fileType, String caller, String called, String sortParam, String sortRule);
 
     VoiceRecordFileDto getRecordById(Long sequenceNbr);
@@ -27,4 +25,6 @@ public interface IVoiceRecordFileService {
     List<FusionDto> getCarList(Boolean hasFusion);
 
     List<FusionDto> getSinglePawnList(Boolean hasFusion);
+
+    List <VoiceRecordFileDto> listByAlertId(Long alertId);
 }

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

@@ -34,6 +34,8 @@
         a.address ,
         a.coordinate_x longitude,
         a.coordinate_y latitude,
+        a.record_url,
+        a.alert_status,
         CASE a.response_level_code
         WHEN '1164' THEN '紧急出动'
         WHEN '1165' THEN '紧急集结'

amos-boot-module/amos-boot-module-api/amos-boot-module-jcs-api/src/main/resources/mapper/AlertSubmittedMapper.xml

@@ -131,6 +131,40 @@
 	a.alert_called_id =  ${id}
     </select>
 
+    <select id="getFirst" resultType="Map">
+       SELECT distinct
+        a.rec_date recDate ,
+        b.company_name companyName,
+        c.resources_name carName,
+        c.resources_num carNum,
+		c.resources_id id
+    FROM
+        jc_power_transfer a
+        LEFT JOIN jc_power_transfer_company b ON a.sequence_nbr = b.power_transfer_id
+        LEFT JOIN jc_power_transfer_company_resources c ON c.power_transfer_company_id = b.sequence_nbr
+
+        where a.sequence_nbr = (select sequence_nbr from jc_power_transfer where alert_called_id
+        = #{alertId}
+        order by rec_date asc limit 1)
+    </select>
+
+    <select id="getOther" resultType="Map">
+      SELECT distinct
+        a.rec_date recDate ,
+        b.company_name companyName,
+        c.resources_name carName,
+        c.resources_num carNum,
+		c.resources_id id
+    FROM
+        jc_power_transfer a
+        LEFT JOIN jc_power_transfer_company b ON a.sequence_nbr = b.power_transfer_id
+        LEFT JOIN jc_power_transfer_company_resources c ON c.power_transfer_company_id = b.sequence_nbr
+
+        where a.sequence_nbr = (select sequence_nbr from jc_power_transfer where alert_called_id
+        = #{alertId}
+        order by rec_date asc limit 1,100)
+    </select>
+
 
 
 

amos-boot-module/amos-boot-module-api/amos-boot-module-supervision-api/src/main/java/com/yeejoin/amos/supervision/core/common/dto/CheckReportDangerDto.java

@@ -16,6 +16,9 @@ public class CheckReportDangerDto implements Serializable {
     String companyName;
 
     @ApiModelProperty(value = "隐患id")
+    String id;
+
+    @ApiModelProperty(value = "隐患id")
     String dangerId;
 
     @ApiModelProperty(value = "存在问题")

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

@@ -3,7 +3,6 @@ package com.yeejoin.amos.boot.module.command.biz.controller;
 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.core.metadata.OrderItem;
@@ -19,7 +18,6 @@ import com.yeejoin.amos.boot.module.command.api.dto.CarTaskDto;
 import com.yeejoin.amos.boot.module.command.api.dto.SeismometeorologyDto;
 import com.yeejoin.amos.boot.module.command.biz.service.impl.RemoteSecurityService;
 import com.yeejoin.amos.boot.module.common.api.dto.*;
-import com.yeejoin.amos.boot.module.common.api.dto.FireBrigadeResourceDto;
 import com.yeejoin.amos.boot.module.common.api.entity.FireTeam;
 import com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient;
 import com.yeejoin.amos.boot.module.common.api.feign.IotFeignClient;
@@ -49,15 +47,13 @@ import com.yeejoin.amos.boot.module.jcs.api.service.*;
 import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
-import org.apache.commons.lang3.ObjectUtils;
-import org.apache.poi.ss.formula.functions.T;
+
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
 import org.typroject.tyboot.core.foundation.context.RequestContext;
 import org.typroject.tyboot.core.foundation.enumeration.UserType;
 import org.typroject.tyboot.core.foundation.exception.BaseException;
-import org.typroject.tyboot.core.foundation.utils.Bean;
 import org.typroject.tyboot.core.foundation.utils.DateUtil;
 import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
 import org.typroject.tyboot.core.restful.doc.TycloudOperation;
@@ -74,7 +70,6 @@ import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import java.util.stream.Collectors;
 
 /**
  * *指挥资源Api

amos-boot-module/amos-boot-module-biz/amos-boot-module-fas-biz/src/main/java/com/yeejoin/amos/fas/business/controller/ContingencyPlanController.java

@@ -175,6 +175,7 @@ public class ContingencyPlanController extends AbstractBaseController {
         }
     }
 
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
     @ApiOperation(value = "启动")
     @RequestMapping(value = "/start", method = RequestMethod.POST)
     public ResponseModel start(@RequestBody ContingencyPlanParamVo vo) {
@@ -196,6 +197,7 @@ public class ContingencyPlanController extends AbstractBaseController {
         return CommonResponseUtil2.success(result);
     }
 
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
     @ApiOperation(value = "装备确景")
     @RequestMapping(value = "/scene", method = RequestMethod.GET)
     public ResponseModel scene(@ApiParam(value = "装备Id", required = true) String equipmentId,
@@ -208,6 +210,7 @@ public class ContingencyPlanController extends AbstractBaseController {
         }
     }
 
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
     @ApiOperation(value = "预案启动记录分页列表")
     @RequestMapping(value = "/record/page", method = RequestMethod.GET)
     public ResponseModel recordList(
@@ -229,6 +232,7 @@ public class ContingencyPlanController extends AbstractBaseController {
         return CommonResponseUtil2.success(contingencyPlanService.recordListByPage(page, planId, planName, classifyId, startTimeLeft, startTimeRight, executionType, planPattern));
     }
 
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
     @ApiOperation(value = "第一次查看预案记录")
     @RequestMapping(value = "/frist/getRecord/{batchNo}", method = RequestMethod.GET)
     public ResponseModel firstGetRecord( @PathVariable(value = "batchNo") String batchNo) {
@@ -236,6 +240,7 @@ public class ContingencyPlanController extends AbstractBaseController {
         return CommonResponseUtil2.success(map);
     }
 
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
     @ApiOperation(value = "查看预案记录列表")
     @RequestMapping(value = "/getRecordList/{batchNo}", method = RequestMethod.GET)
     public ResponseModel getRecordList( @PathVariable(value = "batchNo") String batchNo) {

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/pom.xml

@@ -20,6 +20,31 @@
           <artifactId>amos-boot-module-common-biz</artifactId>
           <version>${amos-biz-boot.version}</version>
       </dependency>
+      <dependency>
+          <groupId>com.deepoove</groupId>
+          <artifactId>poi-tl</artifactId>
+          <version>1.6.0</version>
+          <scope>compile</scope>
+          <exclusions>
+              <exclusion>
+                  <artifactId>poi-ooxml</artifactId>
+                  <groupId>org.apache.poi</groupId>
+              </exclusion>
+              <exclusion>
+                  <artifactId>poi-ooxml-schemas</artifactId>
+                  <groupId>org.apache.poi</groupId>
+              </exclusion>
+              <exclusion>
+                  <artifactId>poi</artifactId>
+                  <groupId>org.apache.poi</groupId>
+              </exclusion>
+          </exclusions>
+      </dependency>
+      <dependency>
+          <groupId>e-iceblue</groupId>
+          <artifactId>spire.doc</artifactId>
+          <version>4.9.0</version>
+      </dependency>
   </dependencies>
 
 </project>

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/controller/AlertSubmittedController.java

@@ -9,6 +9,7 @@ import com.yeejoin.amos.boot.biz.common.controller.BaseController;
 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.NameUtils;
+import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledFormDto;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledObjsDto;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledRo;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedDto;
@@ -39,6 +40,9 @@ import org.typroject.tyboot.core.restful.doc.TycloudOperation;
 import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.UnsupportedEncodingException;
 import java.text.ParseException;
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -258,6 +262,29 @@ public class AlertSubmittedController extends BaseController {
         return ResponseHelper.buildResponse(schedulingContent);
     }
 
+    /**
+     * 获取警情续报内容
+     *
+     * @return 返回结果
+     */
+    @TycloudOperation(ApiLevel = UserType.AGENCY)
+    @RequestMapping(value = "/alert_submitted/ddd", method = RequestMethod.GET)
+    @ApiOperation(httpMethod = "GET", value = "获取警情续报内容和模板", notes = "获取警情续报内容和模板")
+    public ResponseModel<Object> getAlertSubmittedContentDD() {
+        try {
+            AlertCalledFormDto alertCalledFormDto = (AlertCalledFormDto)alertCalledService.selectAlertCalledByIdNoRedis(1455815417061728258L);
+
+            alertSubmittedService.generateMob(alertCalledFormDto.getAlertCalled());
+        }  catch (FileNotFoundException e) {
+            e.printStackTrace();
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+        return ResponseHelper.buildResponse(null);
+    }
+
     private String getTaskInformation(String content, Map<String, String> definitions) {
         int size = definitions.size();
         String[] keys = definitions.keySet().toArray(new String[size]);

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/controller/VoiceRecordFileController.java

 package com.yeejoin.amos.boot.module.jcs.biz.controller;
 
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.biz.common.controller.BaseController;
 import com.yeejoin.amos.boot.biz.common.utils.RedisKey;
 import com.yeejoin.amos.boot.module.jcs.api.dto.VoiceRecordFileDto;
-import com.yeejoin.amos.boot.module.jcs.api.entity.VoiceRecordFile;
 import com.yeejoin.amos.boot.module.jcs.biz.service.impl.AlertCalledServiceImpl;
 import com.yeejoin.amos.boot.module.jcs.biz.service.impl.VoiceRecordFileServiceImpl;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
-import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 import org.typroject.tyboot.core.foundation.enumeration.UserType;
@@ -20,7 +17,6 @@ import org.typroject.tyboot.core.restful.exception.instance.BadRequest;
 import org.typroject.tyboot.core.restful.utils.ResponseHelper;
 import org.typroject.tyboot.core.restful.utils.ResponseModel;
 
-import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -35,7 +31,7 @@ import java.util.List;
 public class VoiceRecordFileController extends BaseController {
 
     @Autowired
-    VoiceRecordFileServiceImpl voiceRecordFileServiceImpl;
+    VoiceRecordFileServiceImpl voiceRecordFileService;
 
 	@Autowired
 	AlertCalledServiceImpl iAlertCalledService;
@@ -49,18 +45,7 @@ public class VoiceRecordFileController extends BaseController {
 	@ApiOperation(httpMethod = "GET",value = "根据警情id 查找通话记录信息",   notes = "根据警情id 查找通话记录信息")
 	@GetMapping(value = "/list/alert/{alertId}")
 	public ResponseModel<List<VoiceRecordFileDto>> selectForListByAlertId(@PathVariable Long alertId) {
-		LambdaQueryWrapper<VoiceRecordFile> queryWrapper = new LambdaQueryWrapper<VoiceRecordFile>();
-		queryWrapper.eq(VoiceRecordFile::getAlertId, alertId).orderByDesc(VoiceRecordFile::getRecDate);
-		List<VoiceRecordFile> list = voiceRecordFileServiceImpl.list(queryWrapper);
-		List<VoiceRecordFileDto> dtoList = new ArrayList<VoiceRecordFileDto>(list.size());
-		list.stream().forEach(voiceRecord -> {
-			// 创建新的对象实例
-			VoiceRecordFileDto target = new VoiceRecordFileDto();
-			// 把原对象数据拷贝到新对象
-			BeanUtils.copyProperties(voiceRecord, target);
-			dtoList.add(target);
-		});
-		return ResponseHelper.buildResponse(dtoList);
+		return ResponseHelper.buildResponse(voiceRecordFileService.listByAlertId(alertId));
 	}
 
 	/**
@@ -73,7 +58,7 @@ public class VoiceRecordFileController extends BaseController {
 	@GetMapping(value = "/{sequenceNbr}")
 	public ResponseModel<VoiceRecordFileDto> getRecordById(@PathVariable Long sequenceNbr) {
 
-		VoiceRecordFileDto record = voiceRecordFileServiceImpl.getRecordById(sequenceNbr);
+		VoiceRecordFileDto record = voiceRecordFileService.getRecordById(sequenceNbr);
 		return ResponseHelper.buildResponse(record);
 	}
 
@@ -85,13 +70,22 @@ public class VoiceRecordFileController extends BaseController {
 	@TycloudOperation(ApiLevel = UserType.AGENCY)
 	@PostMapping(value = "/saveRecord")
 	@ApiOperation(httpMethod = "POST", value = "新增通话记录附件", notes = "新增通话记录附件")
-	public ResponseModel<Boolean> saveRecord(@RequestBody VoiceRecordFileDto model) {
+	public ResponseModel<VoiceRecordFileDto> saveRecord(@RequestBody VoiceRecordFileDto model) {
         if (ValidationUtil.isEmpty(model.getCaller())
 				|| ValidationUtil.isEmpty(model.getCalled())){
             throw new BadRequest("参数校验失败.");
         }
-		voiceRecordFileServiceImpl.publishRecord(model);
-		return ResponseHelper.buildResponse(true);
+		return ResponseHelper.buildResponse(voiceRecordFileService.saveRecord(model));
+	}
+
+	@TycloudOperation(ApiLevel = UserType.AGENCY)
+	@RequestMapping(value = "/{sequenceNbr}", method = RequestMethod.PUT)
+	@ApiOperation(httpMethod = "PUT", value = "更新通话记录附件", notes = "更新通话记录附件")
+	public ResponseModel<VoiceRecordFileDto> updateRecord(
+			@RequestBody VoiceRecordFileDto model,
+			@PathVariable(value = "sequenceNbr") Long sequenceNbr) {
+		model.setSequenceNbr(sequenceNbr);
+		return ResponseHelper.buildResponse(voiceRecordFileService.updateRecord(model));
 	}
 
 	@TycloudOperation(ApiLevel = UserType.AGENCY)
@@ -117,7 +111,7 @@ public class VoiceRecordFileController extends BaseController {
 			sortParam = "call_time";
 			sortRule = "desc";
 		}
-		Page<VoiceRecordFileDto> pageBean = voiceRecordFileServiceImpl.queryRecordListByQueryDto(page,
+		Page<VoiceRecordFileDto> pageBean = voiceRecordFileService.queryRecordListByQueryDto(page,
 				model.getTelStartTimeStr(),model.getTelEndTimeStr(),model.getFileType(),model.getCaller(),
 				model.getCalled(),sortParam,sortRule);
 		Page<VoiceRecordFileDto> result = new Page<VoiceRecordFileDto>(pageNum,pageSize);

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

@@ -9,7 +9,10 @@ import java.util.Set;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
+import com.yeejoin.amos.boot.module.jcs.api.dto.*;
+import com.yeejoin.amos.boot.module.jcs.api.entity.*;
 import com.yeejoin.amos.boot.module.jcs.api.enums.AlertBusinessTypeEnum;
+import com.yeejoin.amos.boot.module.jcs.api.service.IVoiceRecordFileService;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
@@ -45,20 +48,6 @@ import com.yeejoin.amos.boot.module.common.biz.service.impl.FirefightersServiceI
 import com.yeejoin.amos.boot.module.common.biz.service.impl.KeySiteServiceImpl;
 import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl;
 import com.yeejoin.amos.boot.module.common.biz.service.impl.WaterResourceServiceImpl;
-import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledDto;
-import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledFormDto;
-import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledObjsDto;
-import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledTodyDto;
-import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledZhDto;
-import com.yeejoin.amos.boot.module.jcs.api.dto.ControllerDto;
-import com.yeejoin.amos.boot.module.jcs.api.dto.ControllerEquipDto;
-import com.yeejoin.amos.boot.module.jcs.api.dto.KeyValueLabel;
-import com.yeejoin.amos.boot.module.jcs.api.dto.PowerData;
-import com.yeejoin.amos.boot.module.jcs.api.entity.Aircraft;
-import com.yeejoin.amos.boot.module.jcs.api.entity.AlertCalled;
-import com.yeejoin.amos.boot.module.jcs.api.entity.AlertFormValue;
-import com.yeejoin.amos.boot.module.jcs.api.entity.AlertLocationLog;
-import com.yeejoin.amos.boot.module.jcs.api.entity.Template;
 import com.yeejoin.amos.boot.module.jcs.api.enums.AlertStageEnums;
 import com.yeejoin.amos.boot.module.jcs.api.enums.ControllerTypeEnum;
 import com.yeejoin.amos.boot.module.jcs.api.enums.DutyInfoEnum;
@@ -134,6 +123,8 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
 
     @Autowired
     OrgUsrServiceImpl orgUsrServiceImpl;
+    @Autowired
+    VoiceRecordFileServiceImpl voiceRecordFileService;
 
     private static int comparingByGroupVal(Map<String, Object> map, Map<String, Object> map2, String key) {
         int result = 0;
@@ -184,7 +175,7 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
 //        List<AlertCalled> list = alertCalledMapper.selectAllPage(pageBean.getCurrent(), pageBean.getSize(), alertStatus, alertTypeCode, alertSourceCode, startTime, endTime, data, lift);
 //    }
     public IPage<AlertCalled> queryForCalledList(Page pageBean, Integer alertStatus, String alertTypeCode,
-			String alertSourceCode, String startTime, String endTime, String sort,String isFatherAlert) {
+                                                 String alertSourceCode, String startTime, String endTime, String sort, String isFatherAlert) {
 
         String[] split = sort != null ? sort.split(",") : null;
         /* 2407 【web】日常值班>警情记录>接警记录，表头排序功能失效 chenzhao 09-28 start */
@@ -212,11 +203,11 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
         String lift = split != null ? split[1] : null;
 
         List<AlertCalled> list = alertCalledMapper.selectAllPage(pageBean.getCurrent(), pageBean.getSize(), alertStatus,
-				alertTypeCode, alertSourceCode, startTime, endTime, data, lift,isFatherAlert);
+                alertTypeCode, alertSourceCode, startTime, endTime, data, lift, isFatherAlert);
         IPage<AlertCalled> iPage = new Page<>();
         iPage.setRecords(list);
         iPage.setTotal(
-				alertCalledMapper.selectAllCount(alertStatus, alertTypeCode, alertSourceCode, startTime, endTime,isFatherAlert));
+                alertCalledMapper.selectAllCount(alertStatus, alertTypeCode, alertSourceCode, startTime, endTime, isFatherAlert));
         //iPage.setSize(pageBean.getSize());
 
         return iPage;
@@ -376,7 +367,7 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
                 alertCalledObjsDto.setAlertFormValue(alertFormValuelist);
                 // 警情报送
                 // 调用规则  警情初报
-				ruleAlertCalledService.fireAlertCalledRule(alertCalledObjsDto, AlertBusinessTypeEnum.警情初报.getCode(), null,null,null);
+                ruleAlertCalledService.fireAlertCalledRule(alertCalledObjsDto, AlertBusinessTypeEnum.警情初报.getCode(), null, null, null);
                 // 通知实战指挥页面发送mqtt 默认发送 String 类型 0, 新警情 1 警情状态变化
                 emqKeeper.getMqttClient().publish(topic, "0".getBytes(), RuleConfig.DEFAULT_QOS, true);
                 /**
@@ -660,16 +651,12 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
             String bellNum = bellNumSb.toString();
             bellNum = bellNum.substring(0, bellNum.length() - 1);
             String[] bellNums = bellNum.split(",");
-			for (int i = 0; i < bellNums.length; i++)
-			{
+            for (int i = 0; i < bellNums.length; i++) {
                 //打开15s后自动关闭
-				try
-				{
+                try {
                     jcsControlServerClient.sendBellActionWithTime(bellNums[i], "1", 15);
-				}
-				catch (Exception e)
-				{
-					logger.info("打开警铃【"+bellNums[i]+"】异常！");
+                } catch (Exception e) {
+                    logger.info("打开警铃【" + bellNums[i] + "】异常！");
                 }
             }
         }
@@ -688,22 +675,16 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
         if (!ValidationUtil.isEmpty(northDoor)) {
             ControllerDto controllerDto = northDoor.get(0);
             // 打开北站车库门
-			try
-			{
+            try {
                 jcsControlServerClient.writeStateAction(controllerDto.getIp(), controllerDto.getPort(), 100, "1,1,1,1");
-			}
-			catch (Exception e)
-			{
-				logger.info("打开北站车库门【"+controllerDto.getIp()+"】异常！");
+            } catch (Exception e) {
+                logger.info("打开北站车库门【" + controllerDto.getIp() + "】异常！");
             }
             // 打开北站车库门弱电警铃
-			try
-			{
+            try {
                 jcsControlServerClient.writeStateAction(controllerDto.getIp(), controllerDto.getPort(), 107, "1");
-			}
-			catch (Exception e)
-			{
-				logger.info("打开北站弱电警铃【"+controllerDto.getIp()+"】异常！");
+            } catch (Exception e) {
+                logger.info("打开北站弱电警铃【" + controllerDto.getIp() + "】异常！");
             }
         }
         /**
@@ -713,22 +694,16 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
         if (!ValidationUtil.isEmpty(southDoor)) {
             ControllerDto controllerDto = southDoor.get(0);
             // 打开南站车库门
-			try
-			{
+            try {
                 jcsControlServerClient.writeStateAction(controllerDto.getIp(), controllerDto.getPort(), 100, "1");
-			}
-			catch (Exception e)
-			{
-				logger.info("打开南站车库门【"+controllerDto.getIp()+"】异常！");
+            } catch (Exception e) {
+                logger.info("打开南站车库门【" + controllerDto.getIp() + "】异常！");
             }
             // 打开南站车库门弱电警铃
-			try
-			{
+            try {
                 jcsControlServerClient.writeStateAction(controllerDto.getIp(), controllerDto.getPort(), 107, "1");
-			}
-			catch (Exception e)
-			{
-				logger.info("打开南站弱电警铃【"+controllerDto.getIp()+"】异常！");
+            } catch (Exception e) {
+                logger.info("打开南站弱电警铃【" + controllerDto.getIp() + "】异常！");
             }
         }
 
@@ -771,7 +746,7 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
         // 警情基本信息
         AlertCalled alertCalled = this.getById(id);
         QueryWrapper<AlertFormValue> queryWrapper = new QueryWrapper<>();
-		Map<String, Object> map = new HashMap<String, Object>();
+        Map<String, Object> map = new HashMap<>();
         map.put("title", "【" + alertCalled.getAlertType() + "】" + alertCalled.getAddress());
         queryWrapper.eq("alert_called_id", id);
 
@@ -806,10 +781,14 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
         }
         map.put("alertType", alertCalled.getAlertType());
         map.put("address", alertCalled.getAddress());
-
         map.put("contactUser", alertCalled.getContactUser());
         map.put("contactPhone", alertCalled.getContactPhone());
         map.put("callTime", alertCalled.getCallTime());
+        //获取通话录音文件地址
+        List<VoiceRecordFileDto> voiceRecordFileDtos = voiceRecordFileService.listByAlertId(alertCalled.getSequenceNbr());
+        if (!voiceRecordFileDtos.isEmpty()) {
+            map.put("voiceRecordFile", voiceRecordFileDtos.get(0).getFilePath());
+        }
         return map;
     }
 
@@ -938,13 +917,13 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
 //        );
 //       firefightersName.addAll(contactNames);
         List<Map<String, String>> list = orgUsrServiceImpl.getPersonSimpleDetail();
-		list.stream().forEach(i->{
-			String phone="";
-	    if(i.containsKey("phone")) {
-	    	phone = QRCodeUtil.generateQRCode()+"@"+ i.get("phone").toString();
+        list.stream().forEach(i -> {
+            String phone = "";
+            if (i.containsKey("phone")) {
+                phone = QRCodeUtil.generateQRCode() + "@" + i.get("phone").toString();
                 i.replace("phone", phone);
-	    }else {
-	    	phone = QRCodeUtil.generateQRCode()+"@"+ phone;
+            } else {
+                phone = QRCodeUtil.generateQRCode() + "@" + phone;
                 i.put("phone", phone);
             }
         });
@@ -961,7 +940,7 @@ public class AlertCalledServiceImpl extends BaseService<AlertCalledDto, AlertCal
     /* 2304 地址 联系人模糊查询缺失 陈召 2021-09-23 结束 */
 
     public Set<Map<String, Object>> getLocationLike(String locationt) {
-		Set<Map<String, Object>> set= alertCalledMapper.getLocation();
+        Set<Map<String, Object>> set = alertCalledMapper.getLocation();
         set.remove(null);
         return set;
     }

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/AlertSubmittedServiceImpl.java

 package com.yeejoin.amos.boot.module.jcs.biz.service.impl;
 
-import static org.hamcrest.CoreMatchers.nullValue;
-
-import java.lang.reflect.Field;
-import java.text.ParseException;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.Comparator;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-import java.util.Set;
-import java.util.stream.Collectors;
-
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
-import com.yeejoin.amos.boot.biz.common.utils.DateUtils;
-import com.yeejoin.amos.boot.module.common.api.entity.FireTeam;
-import com.yeejoin.amos.boot.module.common.api.entity.OrgUsr;
-import com.yeejoin.amos.boot.module.common.api.mapper.DynamicFormInstanceMapper;
-import com.yeejoin.amos.boot.module.common.api.service.IFireTeamService;
-import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCallePowerTransferRo;
-import com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferCompanyResourcesDto;
-import org.apache.commons.lang3.ObjectUtils;
-import org.eclipse.paho.client.mqttv3.MqttException;
-import org.eclipse.paho.client.mqttv3.MqttPersistenceException;
-import org.springframework.beans.BeanUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
-import org.typroject.tyboot.component.emq.EmqKeeper;
-import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
-import org.typroject.tyboot.core.rdbms.service.BaseService;
-
 import com.alibaba.fastjson.JSONException;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.deepoove.poi.XWPFTemplate;
+import com.deepoove.poi.config.Configure;
+import com.deepoove.poi.config.ELMode;
+import com.deepoove.poi.data.RowRenderData;
+import com.deepoove.poi.data.style.Style;
+import com.deepoove.poi.data.style.TableStyle;
+import com.deepoove.poi.policy.DynamicTableRenderPolicy;
+import com.deepoove.poi.policy.MiniTableRenderPolicy;
+import com.deepoove.poi.util.TableTools;
 import com.google.common.collect.Lists;
+import com.spire.doc.Document;
+import com.spire.doc.FileFormat;
 import com.yeejoin.amos.boot.biz.common.constants.RuleConstant;
 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.EnumsUtils;
 import com.yeejoin.amos.boot.biz.common.utils.RedisUtils;
+import com.yeejoin.amos.boot.biz.common.utils.WordConverterUtils;
 import com.yeejoin.amos.boot.module.common.api.dto.FirefightersDto;
 import com.yeejoin.amos.boot.module.common.api.dto.FormValue;
+import com.yeejoin.amos.boot.module.common.api.entity.FireTeam;
+import com.yeejoin.amos.boot.module.common.api.entity.OrgUsr;
 import com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient;
+import com.yeejoin.amos.boot.module.common.api.mapper.DynamicFormInstanceMapper;
 import com.yeejoin.amos.boot.module.common.api.service.IDutyPersonService;
+import com.yeejoin.amos.boot.module.common.api.service.IFireTeamService;
 import com.yeejoin.amos.boot.module.common.biz.service.impl.FirefightersServiceImpl;
 import com.yeejoin.amos.boot.module.common.biz.service.impl.OrgUsrServiceImpl;
+import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCallCommandDto;
+import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCallePowerTransferRo;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledFormDto;
+import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledMobDto;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledObjsDto;
+import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledPowerInfoDto;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertCalledRo;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedDto;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedExtDto;
@@ -62,7 +48,9 @@ import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedSMSDto;
 import com.yeejoin.amos.boot.module.jcs.api.dto.AlertSubmittedZHDto;
 import com.yeejoin.amos.boot.module.jcs.api.dto.CarStatusInfoDto;
 import com.yeejoin.amos.boot.module.jcs.api.dto.InstructionsZHDto;
+import com.yeejoin.amos.boot.module.jcs.api.dto.PowerData;
 import com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferCompanyDto;
+import com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferCompanyResourcesDto;
 import com.yeejoin.amos.boot.module.jcs.api.dto.PowerTransferCompanyZHDto;
 import com.yeejoin.amos.boot.module.jcs.api.dto.PushMessageWebAndAppRo;
 import com.yeejoin.amos.boot.module.jcs.api.dto.SchedulingReportingDto;
@@ -80,18 +68,58 @@ import com.yeejoin.amos.boot.module.jcs.api.enums.FireCarStatusEnum;
 import com.yeejoin.amos.boot.module.jcs.api.enums.SubmissionMethodEnum;
 import com.yeejoin.amos.boot.module.jcs.api.mapper.AlertSubmittedMapper;
 import com.yeejoin.amos.boot.module.jcs.api.mapper.PowerTransferCompanyMapper;
+import com.yeejoin.amos.boot.module.jcs.api.mapper.PowerTransferMapper;
 import com.yeejoin.amos.boot.module.jcs.api.service.IAlertSubmittedObjectService;
 import com.yeejoin.amos.boot.module.jcs.api.service.IAlertSubmittedService;
 import com.yeejoin.amos.boot.module.jcs.biz.rule.action.AlertCalledAction;
+import com.yeejoin.amos.component.feign.model.FeignClientResult;
 import com.yeejoin.amos.component.rule.RuleTrigger;
 import com.yeejoin.amos.component.rule.config.RuleConfig;
+import com.yeejoin.amos.feign.systemctl.Systemctl;
+import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.apache.poi.xwpf.usermodel.XWPFTable;
+import org.apache.poi.xwpf.usermodel.XWPFTableRow;
+import org.eclipse.paho.client.mqttv3.MqttException;
+import org.eclipse.paho.client.mqttv3.MqttPersistenceException;
+import org.joda.time.DateTime;
+import org.openxmlformats.schemas.wordprocessingml.x2006.main.STJc.Enum;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.typroject.tyboot.component.emq.EmqKeeper;
+import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
+import org.typroject.tyboot.core.rdbms.service.BaseService;
 
-
-
+import java.io.BufferedOutputStream;
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.lang.reflect.Field;
+import java.text.ParseException;
+import java.time.LocalDateTime;
+import java.time.ZoneOffset;
+import java.util.ArrayList;
 import java.util.Arrays;
-
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Iterator;
 import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.Set;
+import java.util.function.BiConsumer;
+import java.util.function.Consumer;
+import java.util.stream.Collectors;
+import java.util.stream.IntStream;
 
 
 /**
@@ -130,6 +158,8 @@ public class AlertSubmittedServiceImpl extends BaseService<AlertSubmittedDto, Al
     @Autowired
     IDutyPersonService iDutyPersonService;
 
+    @Autowired
+    PowerTransferMapper powerTransferMapper;
 
     @Autowired
     private EmqKeeper emqKeeper;
@@ -213,7 +243,7 @@ public class AlertSubmittedServiceImpl extends BaseService<AlertSubmittedDto, Al
 
                     Map<String, String> definitions = new HashMap<>();
                     definitions.put("$type",alertCalled.getAlertType());
-                    definitions.put("$callTime",DateUtils.dateTimeToDateString(alertCalled.getCallTime()));
+                    definitions.put("$callTime", DateUtils.dateTimeToDateString(alertCalled.getCallTime()));
                     definitions.put("$replaceContent",replaceContent);
                     definitions.put("$address",alertCalled.getAddress());
                     String content = getTaskInformation( template.getRichContent(),definitions);
@@ -426,7 +456,9 @@ public class AlertSubmittedServiceImpl extends BaseService<AlertSubmittedDto, Al
                     alertSubmittedObject.setAlertSubmittedId(Long.parseLong(alertSubmittedId));
                 }
 
+                if (!ValidationUtil.isEmpty(orgUser.get("amosUserId"))) {
                     usIds.add(orgUser.get("amosUserId").toString());
+                }
 
                 alertSubmittedObject.setType(false);
 
@@ -467,17 +499,17 @@ public class AlertSubmittedServiceImpl extends BaseService<AlertSubmittedDto, Al
 
         if(alertWay.equals(AlertBusinessTypeEnum.警情初报.getCode())) {
             alertCalledAction.sendAlertCalleCmd(smsCode, mobiles, smsParams);
-            besidesMap.put("sendTime",DateUtils.dateFormat(alertCalled.getCallTime(),DateUtils.DATE_TIME_PATTERN));
+            besidesMap.put("sendTime", DateUtils.dateFormat(alertCalled.getCallTime(), DateUtils.DATE_TIME_PATTERN));
             pushPowerTransferToAppAndWeb(AlertBusinessTypeEnum.警情初报.getCode(),besidesMap,smsParams,usIds);
         } else {
             if(alertWay.equals(AlertBusinessTypeEnum.警情续报.getCode())) {
-                besidesMap.put("sendTime",DateUtils.dateFormat(alertCalled.getCallTime(),DateUtils.DATE_TIME_PATTERN));
+                besidesMap.put("sendTime", DateUtils.dateFormat(alertCalled.getCallTime(), DateUtils.DATE_TIME_PATTERN));
                 pushPowerTransferToAppAndWeb(AlertBusinessTypeEnum.警情续报.getCode(),besidesMap,smsParams,usIds);
             }
 
             if(alertWay.equals(AlertBusinessTypeEnum.警情结案.getCode())) {
-                besidesMap.put("startTime",DateUtils.dateFormat(alertCalled.getCallTime(),DateUtils.DATE_TIME_PATTERN));
-                besidesMap.put("endTime",DateUtils.dateFormat(alertCalled.getRecDate(),DateUtils.DATE_TIME_PATTERN));
+                besidesMap.put("startTime", DateUtils.dateFormat(alertCalled.getCallTime(), DateUtils.DATE_TIME_PATTERN));
+                besidesMap.put("endTime", DateUtils.dateFormat(alertCalled.getRecDate(), DateUtils.DATE_TIME_PATTERN));
                 pushPowerTransferToAppAndWeb(AlertBusinessTypeEnum.警情结案.getCode(),besidesMap,smsParams,usIds);
             }
 
@@ -606,7 +638,20 @@ public class AlertSubmittedServiceImpl extends BaseService<AlertSubmittedDto, Al
         }
 
         if(AlertBusinessTypeEnum.警情结案.getCode().equals(alertSubmittedDto.getBusinessTypeCode())) {
-            alertWay =AlertBusinessTypeEnum.警情结案.getCode();
+            alertWay = AlertBusinessTypeEnum.警情结案.getCode();
+
+            // 警情结案生成模板
+            try {
+                AlertCalledFormDto alertCalledFormDto = (AlertCalledFormDto)alertCalledService.selectAlertCalledById(alertSubmittedDto.getAlertCalledId());
+                AlertCalled alertCalled = alertCalledFormDto.getAlertCalled();
+                generateMob(alertCalled);
+            } catch (UnsupportedEncodingException e) {
+                e.printStackTrace();
+            } catch (FileNotFoundException e) {
+                e.printStackTrace();
+            } catch (ParseException e) {
+                e.printStackTrace();
+            }
         }
 
         if(AlertBusinessTypeEnum.非警情确认.getCode().equals(alertSubmittedDto.getBusinessTypeCode())) {
@@ -655,6 +700,308 @@ public class AlertSubmittedServiceImpl extends BaseService<AlertSubmittedDto, Al
         return map;
     }
 
+    public void generateMob(AlertCalled alertCalled) throws UnsupportedEncodingException, FileNotFoundException, ParseException {
+        AlertCalledMobDto report = new AlertCalledMobDto();
+
+        report.setYear(String.valueOf(DateUtils.getYear(new Date())));
+        report.setUnit(ValidationUtil.isEmpty(alertCalled.getUnitInvolved()) ? "" : alertCalled.getUnitInvolved());
+        report.setAddress(ValidationUtil.isEmpty(alertCalled.getAddress()) ? "" : alertCalled.getAddress());
+        report.setAlertType(ValidationUtil.isEmpty(alertCalled.getAlertType()) ? "" : alertCalled.getAlertType());
+        report.setSourceType(ValidationUtil.isEmpty(alertCalled.getAlertSource()) ? "" : alertCalled.getAlertSource());
+        report.setReportName(ValidationUtil.isEmpty(alertCalled.getContactUser()) ? "" : alertCalled.getContactUser());
+        report.setConectPhone(ValidationUtil.isEmpty(alertCalled.getContactPhone()) ? "" : alertCalled.getContactPhone());
+        report.setCallTime(ValidationUtil.isEmpty(alertCalled.getCallTime()) ? "" : DateUtils.convertDateToString(alertCalled.getCallTime(), DateUtils.DATE_TIME_PATTERN));
+
+
+        String urlString="";
+        report.setEndTime(DateUtils.convertDateToString(new Date(), DateUtils.DATE_TIME_PATTERN));
+
+        // 查询第一次调派
+        List<Map<String, Object>> first = alertSubmittedMapper.getFirst(alertCalled.getSequenceNbr());
+
+        // 查询后续调派
+        List<Map<String, Object>> other = alertSubmittedMapper.getFirst(alertCalled.getSequenceNbr());
+
+        LinkedList<AlertCalledPowerInfoDto> list = new LinkedList<>();
+        for(int i = 0; i <first.size(); i++) {
+            AlertCalledPowerInfoDto dto = new AlertCalledPowerInfoDto();
+            if(i == 0) {
+                dto.setDisatchNum(String.valueOf(first.size()));
+            }
+
+            handleFunc(dto,first.get(i));
+            LocalDateTime dateTime =  (LocalDateTime)first.get(i).get("recDate");
+            Date date = Date.from(dateTime.toInstant(ZoneOffset.of("+8")));
+
+            report.setToTime((DateUtils.dateFormat(date,DateUtils.HOUR_PATTERN)));
+
+            report.setArriveTime((DateUtils.dateFormat(date,DateUtils.HOUR_PATTERN)));
+
+            dto.setArriveTime((DateUtils.dateFormat(date,DateUtils.HOUR_PATTERN)));
+            list.add(dto);
+        }
+
+        for(int i = 0; i <other.size(); i++) {
+            AlertCalledPowerInfoDto dto = new AlertCalledPowerInfoDto();
+
+            handleFunc(dto,first.get(i));
+            LocalDateTime dateTime =  (LocalDateTime)first.get(i).get("recDate");
+            Date date = Date.from(dateTime.toInstant(ZoneOffset.of("+8")));
+
+            dto.setArriveTime((DateUtils.dateFormat(date,DateUtils.HOUR_PATTERN)));
+            list.add(dto);
+        }
+
+        // 查询应急指挥辅屏值班人员
+        List<Map<String, Object>> mapList = iDutyPersonService.listOnDutyPerson();
+        List<AlertCallCommandDto> list1 = new ArrayList<>();
+        mapList.forEach(e->{
+            AlertCallCommandDto dto = new AlertCallCommandDto();
+            dto.setName(e.get("userName").toString());
+            dto.setDuty(e.get("postTypeName").toString());
+            list1.add(dto);
+        });
+
+        if (mapList.size() == 0) {
+            AlertCallCommandDto commandDto = new AlertCallCommandDto();
+            commandDto.setName("");
+            commandDto.setDuty("");
+            list1.add(commandDto);
+        }
+
+        report.setAlertCallCommandDtoList(list1);
+
+        report.setAlertCalledPowerInfoDtoList(list);
+
+        if (!ValidationUtil.isEmpty(report)) {
+            String checkReportTemplatePath = this.getClass().getClassLoader().getResource("templates/check-report-template" +
+                    ".docx").getFile();
+
+            String filePath = this.getClass().getClassLoader().getResource("templates").getPath();
+            String fileName = filePath + "/" + System.currentTimeMillis() + ".docx";
+            String newFileName= "";
+
+            AlertCalledPowerInfoTablePolicy calledPowerInfoTablePolicy = new AlertCalledPowerInfoTablePolicy();
+            AlertCallCommandTablePolicy alertCallCommandTablePolicy = new AlertCallCommandTablePolicy();
+
+            Configure.ConfigureBuilder configureBuilder = Configure.newBuilder();
+            configureBuilder.setElMode(ELMode.SPEL_MODE).bind("alertCalledPowerInfoDtoList", calledPowerInfoTablePolicy)
+                    .bind("alertCallCommandDtoList", alertCallCommandTablePolicy).build();
+            XWPFTemplate template = XWPFTemplate.compile(checkReportTemplatePath, configureBuilder.build()).render(report);
+
+            FileOutputStream out = new FileOutputStream(fileName);
+            BufferedOutputStream bos = null;
+            try {
+                bos = new BufferedOutputStream(out);
+                template.write(bos);
+                bos.flush();
+                out.flush();
+
+                // docx 转 doc
+                Document document = new Document();
+
+                String os = System.getProperty("os.name");
+                //拼接完整连接
+                String pa1 = "";
+                if(os.toLowerCase().startsWith("win")){
+                    String pa = fileName.substring(1);
+                    document.loadFromFile(pa);
+                    newFileName = filePath +"/" + System.currentTimeMillis()+".doc";
+                    //保存结果文件
+                    pa1  = newFileName.substring(1);
+                    document.saveToFile(pa1, FileFormat.Doc);
+                } else {
+                    document.loadFromFile(fileName);
+                    newFileName  = filePath + System.currentTimeMillis()+".doc";
+                    document.saveToFile(newFileName, FileFormat.Doc);
+                    pa1 = newFileName;
+                }
+                System.out.println(pa1);
+
+                FeignClientResult<Map<String, String>> date = Systemctl.fileStorageClient.updateCommonFile(WordConverterUtils.fileToMultipartFile(new File(pa1)));
+
+                if (date != null) {
+                    Map<String, String> map = date.getResult();
+                    Iterator<String> it = map.keySet().iterator();
+                    while (it.hasNext()) {
+                        urlString=it.next();
+                    }
+                }
+                System.out.println(urlString);
+
+                // 更新警情信息
+                alertCalled.setRecordUrl(urlString);
+                alertCalledService.updateById(alertCalled);
+            } catch (IOException e) {
+                log.error("生成文档失败---------->");
+                e.printStackTrace();
+            } finally {
+                try {
+                    bos.close();
+                    out.close();
+                    template.close();
+
+                    File file = new File(fileName);
+                    if(file.exists()) {
+                        file.delete();
+                    }
+
+                    File file1 = new File(newFileName);
+                    if(file1.exists()) {
+                        file1.delete();
+                    }
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            }
+        }
+    }
+    void handleFunc(AlertCalledPowerInfoDto dto,Map<String, Object> map) {
+        dto.setCarName(map.get("carName").toString());
+        dto.setStation(map.get("companyName").toString());
+        // 随车人员
+        List<PowerData> powerDataOne = powerTransferMapper.getPowerDataOne(Long.valueOf(map.get("id").toString()));
+        if(!ValidationUtil.isEmpty(powerDataOne)) {
+            dto.setPersonNum(String.valueOf(powerDataOne.size()));
+        } else {
+            dto.setPersonNum("0");
+        }
+    }
+
+    static int dangerListDataStartRow = 2; // 表头占两行
+
+    static int dangerListDataStartRowNew = 1; // 表头占一行
+
+    public static <T> Consumer<T> foreachWithIndex(BiConsumer<T, Integer> consumer) {
+        class Obj {
+            int i;
+        }
+        Obj obj = new Obj();
+        return t -> {
+            int index = obj.i++;
+            consumer.accept(t, index);
+        };
+    }
+
+    public static class AlertCalledPowerInfoTablePolicy extends DynamicTableRenderPolicy {
+
+        @Override
+        public void render(XWPFTable table, Object o) {
+            if (ValidationUtil.isEmpty(o)) {
+                table.removeRow(dangerListDataStartRow);
+                return;
+            }
+            List<AlertCalledPowerInfoDto> reportDto = (List<AlertCalledPowerInfoDto>) o;
+
+            List<RowRenderData> checkDangerList = Lists.newArrayList();
+            reportDto.forEach(foreachWithIndex((report, index) -> {
+                RowRenderData rowRenderData = RowRenderData.build(String.valueOf(reportDto.size() - index),
+                        report.getStation(), report.getArriveTime(), report.getCarName(),report.getPersonNum(),report.getDisatchNum(),report.getDryPowder(),report.getFoam(),report.getOther());
+                checkDangerList.add(rowRenderData);
+            }));
+            generateTableData(table, checkDangerList);
+        }
+    }
+
+    public static class AlertCallCommandTablePolicy extends DynamicTableRenderPolicy {
+
+        @Override
+        public void render(XWPFTable table, Object o) {
+            if (ValidationUtil.isEmpty(o)) {
+                table.removeRow(dangerListDataStartRow);
+                return;
+            }
+            List<AlertCallCommandDto> reportDto = (List<AlertCallCommandDto>) o;
+
+            List<RowRenderData> checkDangerList = Lists.newArrayList();
+            reportDto.forEach(foreachWithIndex((report, index) -> {
+                RowRenderData rowRenderData = RowRenderData.build(String.valueOf(reportDto.size() - index),
+                        report.getName(), report.getDuty());
+                checkDangerList.add(rowRenderData);
+            }));
+            generateTableDataNew(table, checkDangerList);
+        }
+
+        private void generateTableDataNew(XWPFTable table, List<RowRenderData> dangerList) {
+            if (!ValidationUtil.isEmpty(dangerList)) {
+                // 表格渲染和列表数据下标相反，需要翻转一下列表
+                List<RowRenderData> reverseList = Lists.reverse(dangerList);
+                table.removeRow(dangerListDataStartRowNew);
+                // 循环插入行
+                int listLength = dangerList.size();
+                for (int i = 0; i < listLength; i++) {
+                    reverseList.get(i).getCellDatas().forEach(cellRenderData -> {
+                        Style style = new Style();
+                        style.setFontFamily("仿宋");
+                        style.setFontSize(12);
+                        cellRenderData.getRenderData().setStyle(style);
+                    });
+                    XWPFTableRow insertNewTableRow = table.insertNewTableRow(dangerListDataStartRowNew);
+                    IntStream.range(2,6).forEach(j -> insertNewTableRow.createCell());
+                    MiniTableRenderPolicy.Helper.renderRow(table, dangerListDataStartRowNew, reverseList.get(i));
+                }
+
+                TableTools.mergeCellsVertically(table, 0, 0, listLength);
+            }
+        }
+    }
+
+    public static void generateTableData(XWPFTable table, List<RowRenderData> dangerList) {
+        String firstSize ="";
+        if (!ValidationUtil.isEmpty(dangerList)) {
+            firstSize = dangerList.get(0).getCellDatas().get(5).getRenderData().getText();
+            int fSizs = Integer.parseInt(firstSize);
+
+            // 表格渲染和列表数据下标相反，需要翻转一下列表
+            List<RowRenderData> reverseList = Lists.reverse(dangerList);
+            table.removeRow(dangerListDataStartRow);
+            // 循环插入行
+            int listLength = dangerList.size();
+            for (int i = 0; i < fSizs; i++) {
+                if(i == 0) {
+                    TableStyle tableStyle = new TableStyle();
+                    tableStyle.setAlign(Enum.forInt(2));
+                    reverseList.get(i).getCellDatas().get(0).setCellStyle(tableStyle);
+                    reverseList.get(i).getCellDatas().get(0).getRenderData().setText("增\n援\n力\n量");
+                    Style style = new Style();
+                    style.setFontFamily("宋体");
+                    style.setFontSize(12);
+                    style.setBold(true);
+                    reverseList.get(i).getCellDatas().get(0).getRenderData().setStyle(style);
+                } else {
+                    reverseList.get(i).getCellDatas().forEach(cellRenderData -> {
+                        Style style = new Style();
+                        style.setFontFamily("仿宋");
+                        style.setFontSize(12);
+                        cellRenderData.getRenderData().setStyle(style);
+                    });
+                }
+
+                XWPFTableRow insertNewTableRow = table.insertNewTableRow(dangerListDataStartRow);
+                IntStream.range(5,14).forEach(j -> insertNewTableRow.createCell());
+                MiniTableRenderPolicy.Helper.renderRow(table, dangerListDataStartRow, reverseList.get(i));
+            }
+
+            for (int i = fSizs; i < listLength  ; i++) {
+              reverseList.get(i).getCellDatas().forEach(cellRenderData -> {
+                        Style style = new Style();
+                        style.setFontFamily("仿宋");
+                        style.setFontSize(12);
+                        cellRenderData.getRenderData().setStyle(style);
+                    });
+                XWPFTableRow insertNewTableRow = table.insertNewTableRow(dangerListDataStartRow);
+                IntStream.range(5,14).forEach(j -> insertNewTableRow.createCell());
+                MiniTableRenderPolicy.Helper.renderRow(table, dangerListDataStartRow, reverseList.get(i));
+            }
+
+            TableTools.mergeCellsVertically(table, 0, 0, fSizs + 1);
+
+            if(listLength - fSizs > 1 ) {
+                TableTools.mergeCellsVertically(table, 0, fSizs + 2 , listLength + 1);
+            }
+        }
+    }
+
     /**
      * 短信报送对象
      *
@@ -698,10 +1045,10 @@ public class AlertSubmittedServiceImpl extends BaseService<AlertSubmittedDto, Al
                     dataDictionary.getCode()).eq("format", true));
             Map<String, String> definitions = new HashMap<>();
             definitions.put("$type",alertCalled.getAlertType());
-            definitions.put("$callTime",DateUtils.dateTimeToDateString(alertCalled.getCallTime()));
+            definitions.put("$callTime", DateUtils.dateTimeToDateString(alertCalled.getCallTime()));
             definitions.put("$replaceContent",replaceContent);
             definitions.put("$address",alertCalled.getAddress());
-            definitions.put("$recDate",DateUtils.convertDateToString(alertCalled.getRecDate(),DateUtils.DATE_TIME_PATTERN));
+            definitions.put("$recDate", DateUtils.convertDateToString(alertCalled.getRecDate(), DateUtils.DATE_TIME_PATTERN));
             String content = getTaskInformation( template.getContent(),definitions);
             template.setContent(content);
             TemplateDto templateDto = new TemplateDto();

amos-boot-module/amos-boot-module-biz/amos-boot-module-jcs-biz/src/main/java/com/yeejoin/amos/boot/module/jcs/biz/service/impl/VoiceRecordFileServiceImpl.java

@@ -2,6 +2,7 @@ package com.yeejoin.amos.boot.module.jcs.biz.service.impl;
 
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yeejoin.amos.boot.module.common.api.feign.EquipFeignClient;
 import com.yeejoin.amos.boot.module.jcs.api.dto.FusionDto;
@@ -24,6 +25,7 @@ import org.springframework.util.Assert;
 import org.typroject.tyboot.component.emq.EmqKeeper;
 import org.typroject.tyboot.core.foundation.utils.ValidationUtil;
 import org.typroject.tyboot.core.rdbms.service.BaseService;
+import org.typroject.tyboot.core.restful.exception.instance.DataNotFound;
 
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -77,28 +79,25 @@ public class VoiceRecordFileServiceImpl extends BaseService<VoiceRecordFileDto,
         return this.queryForList("", false);
     }
 
-    @Override
-    public void publishRecord(final VoiceRecordFileDto model) {
+    public VoiceRecordFileDto saveRecord(final VoiceRecordFileDto model) {
         Map<String, String> dMap = fusionService.getCallRecordByNumber(model.getCaller(), model.getCalled());
         // 保存到日志表中
         VoiceRecordLog log = new VoiceRecordLog();
-        VoiceRecordFile voiceRecordFile = new VoiceRecordFile();
-        BeanUtils.copyProperties(model, voiceRecordFile);
         log.setAlertId(model.getAlertId());
         String cid = dMap.get("cid");
         Assert.notNull(cid, "CID不能为空");
         Map<String, String> callRecord = fusionService.getCallRecordByCID(cid);
-        voiceRecordFile.setConnectId(cid);
+        model.setConnectId(cid);
         log.setConnectId(cid);
         log.setIsDeal(false);
         log.setDealTimes(0);
-        if (!ValidationUtil.isEmpty(callRecord)){
-            voiceRecordFile.setFilePath(String.format("/%s/%s", callRecord.get("subPath"), callRecord.get("recordName").replace("wav", "mp3")));
+        if (!ValidationUtil.isEmpty(callRecord)) {
+            model.setFilePath(String.format("/%s/%s", callRecord.get("subPath"), callRecord.get("recordName").replace("wav", "mp3")));
             logger.info(String.format("音频地址：【%s】", String.format("/%s/%s", callRecord.get("subPath"), callRecord.get("recordName"))));
         } else { // 无录音地址记录日志
             iVoiceRecordLogServiceImpl.save(log);
         }
-        save(voiceRecordFile);
+        return this.createWithModel(model);
     }
 
     @Override
@@ -118,9 +117,7 @@ public class VoiceRecordFileServiceImpl extends BaseService<VoiceRecordFileDto,
     @Override
     public VoiceRecordFileDto getRecordById(Long sequenceNbr) {
         VoiceRecordFileDto record = baseMapper.getRecordById(sequenceNbr);
-        Map<String, String> callRecord = fusionService.getCallRecordByCID(record.getConnectId());
-        record.setFilePath(String.format("/%s/%s", callRecord.get("subPath"), callRecord.get("recordName")));
-        return record;
+        return buildFilePath(record);
     }
 
     @Override
@@ -169,6 +166,31 @@ public class VoiceRecordFileServiceImpl extends BaseService<VoiceRecordFileDto,
         return fusionDtos;
     }
 
+    @Override
+    public List<VoiceRecordFileDto> listByAlertId(Long alertId) {
+        LambdaQueryWrapper<VoiceRecordFile> queryWrapper = new LambdaQueryWrapper<VoiceRecordFile>();
+        queryWrapper.eq(VoiceRecordFile::getAlertId, alertId).orderByDesc(VoiceRecordFile::getRecDate);
+        List<VoiceRecordFile> list = voiceRecordFileServiceImpl.list(queryWrapper);
+        List<VoiceRecordFileDto> dtoList = new ArrayList<>();
+        list.stream().forEach(voiceRecord -> {
+            // 创建新的对象实例
+            VoiceRecordFileDto target = new VoiceRecordFileDto();
+            // 把原对象数据拷贝到新对象
+            BeanUtils.copyProperties(voiceRecord, target);
+            buildFilePath(target);
+            dtoList.add(target);
+        });
+        return dtoList;
+    }
+
+    public VoiceRecordFileDto updateRecord(VoiceRecordFileDto model) {
+        VoiceRecordFileDto oldModel = this.queryBySeq(model.getSequenceNbr());
+        if (ValidationUtil.isEmpty(oldModel))
+            throw new DataNotFound("找不到指定的数据.");
+        oldModel.setAlertId(model.getAlertId());
+        return this.updateWithModel(oldModel);
+    }
+
     /**
      * 获取在线用户的employeeID集合
      *
@@ -176,7 +198,7 @@ public class VoiceRecordFileServiceImpl extends BaseService<VoiceRecordFileDto,
      */
     private List<String> getAllOnlineUser(Boolean hasFusion) {
         List<String> employeeIDs = new ArrayList<>();
-        if (hasFusion){
+        if (hasFusion) {
             JSONObject jsonObject = fusionService.getAllOnlineUser();
             if (!ValidationUtil.isEmpty(jsonObject)) {
                 JSONArray onlines = jsonObject.getJSONArray("Onlines");
@@ -189,12 +211,12 @@ public class VoiceRecordFileServiceImpl extends BaseService<VoiceRecordFileDto,
         return employeeIDs;
     }
 
-    private FusionDto buildFusionDtoAndId(FusionDto fusionDto, List<String> employeeIDs, Boolean hasFusion, Map map){
+    private FusionDto buildFusionDtoAndId(FusionDto fusionDto, List<String> employeeIDs, Boolean hasFusion, Map map) {
         List carPropertyList = (List) map.get("carPropertyList");
         carPropertyList.forEach(carProperty -> {
             Map carPropertyMap = (Map) carProperty;
             Object nameKey = carPropertyMap.get("nameKey");
-            if (hasFusion && PropertyEnum.GIS.getValue().equals(nameKey)){
+            if (hasFusion && PropertyEnum.GIS.getValue().equals(nameKey)) {
                 fusionDto.setId(String.valueOf(carPropertyMap.get("value")));
             } else if (!hasFusion && PropertyEnum.VIDEO.getValue().equals(nameKey)) {
                 fusionDto.setId(String.valueOf(carPropertyMap.get("value")));
@@ -213,4 +235,10 @@ public class VoiceRecordFileServiceImpl extends BaseService<VoiceRecordFileDto,
         }
         return fusionDto;
     }
+
+    private VoiceRecordFileDto buildFilePath(VoiceRecordFileDto record) {
+        Map<String, String> callRecord = fusionService.getCallRecordByCID(record.getConnectId());
+        record.setFilePath(String.format("/%s/%s", callRecord.get("subPath"), callRecord.get("recordName")));
+        return record;
+    }
 }
\ No newline at end of file

amos-boot-module/amos-boot-module-biz/amos-boot-module-supervision-biz/src/main/java/com/yeejoin/amos/supervision/business/controller/CheckReportController.java

@@ -95,7 +95,7 @@ public class CheckReportController extends BaseController {
     @TycloudOperation(ApiLevel = UserType.AGENCY)
     @ApiOperation(value = "获取检查报告文档", notes = "获取检查报告文档")
     @GetMapping(value = "/docx/{id}")
-    public ResponseModel getCheckReportDocx(HttpServletResponse response, @PathVariable(name = "id") String reportId) throws Exception {
-        return ResponseHelper.buildResponse(iCheckReportService.getCheckReportDocx(response, reportId));
+    public void getCheckReportDocx(HttpServletResponse response, @PathVariable(name = "id") String reportId) throws Exception {
+        iCheckReportService.getCheckReportDocx(response, reportId);
     }
 }

amos-boot-module/amos-boot-module-biz/amos-boot-module-supervision-biz/src/main/java/com/yeejoin/amos/supervision/business/service/impl/CheckReportServiceImpl.java

@@ -231,8 +231,8 @@ public class CheckReportServiceImpl extends BaseService<CheckReportDto, CheckRep
         // 复查已整改隐患
         List<CheckReportDangerDto> reviewReformedList = result.get("reviewReformedList");
         Set<String> reviewDangerIdSet = Sets.newHashSet();
-        reviewDangerIdSet.addAll(Lists.transform(reviewDangerList, CheckReportDangerDto::getDangerId));
-        reviewDangerIdSet.addAll(Lists.transform(reviewReformedList, CheckReportDangerDto::getDangerId));
+        reviewDangerIdSet.addAll(Lists.transform(reviewDangerList, CheckReportDangerDto::getId));
+        reviewDangerIdSet.addAll(Lists.transform(reviewReformedList, CheckReportDangerDto::getId));
         // 保存本次复查隐患id
         checkReport.setReviewDangerIds(Joiner.on(",").join(reviewDangerIdSet));
 //        List<CheckReportDangerDto> reviewReformingList = result.get("reviewReformingList");
@@ -290,7 +290,8 @@ public class CheckReportServiceImpl extends BaseService<CheckReportDto, CheckRep
     }
 
     @Override
-    public Object getCheckReportDocx(HttpServletResponse response, String reportId) throws ParseException, UnsupportedEncodingException {
+    public void getCheckReportDocx(HttpServletResponse response, String reportId) throws ParseException,
+            UnsupportedEncodingException {
         CheckReportDto report = this.getDetailById(reportId);
         report.setReportDate(getCheckReportDateStr(report));
         report.setNowDate(DateUtils.dateFormat(new Date(), DateUtils.CHN_DATE_PATTERN));
@@ -305,7 +306,7 @@ public class CheckReportServiceImpl extends BaseService<CheckReportDto, CheckRep
             configureBuilder.setElMode(ELMode.SPEL_MODE).bind("checkDangerList", checkDangerTablePolicy).bind("reviewDangerList", reviewDangerTablePolicy).build();
             XWPFTemplate template = XWPFTemplate.compile(checkReportTemplatePath, configureBuilder.build()).render(report);
             response.setContentType("application/msword");
-            response.setHeader("Content-disposition",
+            response.setHeader("Content-Disposition",
                     "attachment;filename=" + URLEncoder.encode(fileName, "utf-8"));
             OutputStream out = null;
             BufferedOutputStream bos = null;
@@ -328,7 +329,6 @@ public class CheckReportServiceImpl extends BaseService<CheckReportDto, CheckRep
                 }
             }
         }
-        return null;
     }
 
     private String getCheckReportDateStr(CheckReportDto checkReportDto) throws ParseException {
@@ -394,23 +394,24 @@ public class CheckReportServiceImpl extends BaseService<CheckReportDto, CheckRep
                         report.getCompanyName(), report.getDangerName(), report.getDangerStateName(), report.getCompanyId());
                 checkDangerList.add(rowRenderData);
             }));
-            generateTableData(table, checkDangerList);
+            // companyId字段在RowRenderData中下标(0开始，companyName:1,dangerName:2,dangerStateName:3,companyId:4)
+            generateTableData(table, checkDangerList, 4);
         }
     }
 
-    public static void generateTableData(XWPFTable table, List<RowRenderData> dangerList) {
+    public static void generateTableData(XWPFTable table, List<RowRenderData> dangerList, int bizIndex) {
         if (!ValidationUtil.isEmpty(dangerList)) {
             // 表格渲染和列表数据下标相反，需要翻转一下列表
             List<RowRenderData> reverseList = Lists.reverse(dangerList);
             table.removeRow(dangerListDataStartRow);
             int lastRow = dangerListDataStartRow;
             String sameCompanyId =
-                    dangerList.get(0).getCellDatas().get(4).getRenderData().getText();
+                    dangerList.get(0).getCellDatas().get(bizIndex).getRenderData().getText();
             List<Map<String, Integer>> mergeRowMapList = Lists.newArrayList();
             // 循环插入行
             int listLength = dangerList.size();
             for (int i = 0; i < listLength; i++) {
-                String companyId = dangerList.get(i).getCellDatas().get(4).getRenderData().getText();
+                String companyId = dangerList.get(i).getCellDatas().get(bizIndex).getRenderData().getText();
                 reverseList.get(i).getCellDatas().get(0).getRenderData().setText(String.valueOf(listLength - i));
                 reverseList.get(i).getCellDatas().forEach(cellRenderData -> {
                     Style style = new Style();
@@ -419,10 +420,12 @@ public class CheckReportServiceImpl extends BaseService<CheckReportDto, CheckRep
                     cellRenderData.getRenderData().setStyle(style);
                 });
                 XWPFTableRow insertNewTableRow = table.insertNewTableRow(dangerListDataStartRow);
-                IntStream.range(0, 4).forEach(j -> insertNewTableRow.createCell());
+                // 生成表格字段个数 (不包含companyId字段)
+                int cellLength = reverseList.get(i).getCellDatas().size() - 1;
+                IntStream.range(0, cellLength).forEach(j -> insertNewTableRow.createCell());
 
                 if (!sameCompanyId.equals(companyId)) {
-                    sameCompanyId = dangerList.get(i).getCellDatas().get(4).getRenderData().getText();
+                    sameCompanyId = dangerList.get(i).getCellDatas().get(bizIndex).getRenderData().getText();
                     Map<String, Integer> mergeRowMap = Maps.newHashMap();
                     mergeRowMap.put("fromRow", lastRow);
                     mergeRowMap.put("toRow", i + dangerListDataStartRow - 1);
@@ -464,7 +467,8 @@ public class CheckReportServiceImpl extends BaseService<CheckReportDto, CheckRep
                         report.getRemark(), report.getCompanyId());
                 reviewDangerList.add(rowRenderData);
             }));
-            generateTableData(table, reviewDangerList);
+            // companyId字段在RowRenderData中下标(0开始，companyName:1,dangerName:2,dangerStateName:3,remark:4,companyId:5)
+            generateTableData(table, reviewDangerList, 5);
         }
     }
 

amos-boot-module/amos-boot-module-biz/amos-boot-module-supervision-biz/src/main/java/com/yeejoin/amos/supervision/business/service/intfc/ICheckReportService.java

@@ -38,5 +38,5 @@ public interface ICheckReportService {
      * @param reportId
      * @return
      */
-    Object getCheckReportDocx(HttpServletResponse response, String reportId) throws Exception;
+    void getCheckReportDocx(HttpServletResponse response, String reportId) throws Exception;
 }

amos-boot-system-jcs/src/main/resources/db/changelog/jcs-1.0.0.0.xml

@@ -2298,5 +2298,17 @@
         </sql>
     </changeSet> -->
 
+    <changeSet author="litw" id="2021-11-29-1">
+        <preConditions onFail="MARK_RAN">
+            <not>
+                <columnExists tableName="jc_alert_called" columnName="record_url"/>
+            </not>
+        </preConditions>
+        <comment>update data jc_alert_called</comment>
+        <sql>
+            ALTER TABLE jc_alert_called ADD record_url varchar(200) null COMMENT '处置记录URL';
+        </sql>
+    </changeSet>
+
 </databaseChangeLog>
 

amos-boot-system-patrol/src/main/resources/db/mapper/dbTemplate_plan_task.xml

@@ -627,6 +627,7 @@
 			LEFT JOIN p_input_item pii ON pii.id = ppii.input_item_id
 		WHERE prp.point_id = #{pointId}
 		AND prp.route_id =#{routeId}
+		AND NOT FIND_IN_SET(prpi.point_input_item_id,prp.exclude_items)
 		ORDER BY
 			prpi.order_no
 

amos-boot-system-patrol/src/main/resources/db/mapper/pointMapper.xml

@@ -71,8 +71,10 @@
 			p_point_inputitem pi
 		LEFT JOIN p_input_item ii ON ii.id = pi.input_item_id
 		LEFT JOIN p_point_classify pc ON FIND_IN_SET(pc.id, pi.classify_ids) > 0
+		LEFT JOIN p_route_point prp ON prp.point_id = pi.point_id
 		WHERE
 		pi.point_id = #{pointId}
+		AND NOT FIND_IN_SET(pi.id,prp.exclude_items)
 		ORDER BY
 		    pi.order_no
     </select>
@@ -1088,27 +1090,21 @@
 
 	<select id="queryItemList4RoutePoint" parameterType="long" resultType="map">
 		SELECT
-			pii.id itemId
-			, pii.name
-			, pii.picture_json photo
-			, pii.basis_json basis
-			, pii.check_method method
-			, pii.item_type type
-			, pii.level
-			, pii.risk_desc
-			, pii.input_classify
-		FROM
-			p_input_item pii
-		WHERE
-			pii.id IN (
-				SELECT
-					DISTINCT ppi.input_item_id
+			ppi.id itemId,
+			pii.name,
+			pii.picture_json photo,
+			pii.basis_json basis,
+			pii.check_method method,
+			pii.item_type type,
+			pii.level,
+			pii.risk_desc,
+			pii.input_classify
 		FROM
 			p_point_inputitem ppi
+				LEFT JOIN p_input_item pii ON pii.id = ppi.input_item_id
 		WHERE
 			ppi.point_id =  #{pointId}
 		  AND ppi.classify_ids = #{classifyId}
-			)
 	</select>
 
 	<select id="getPointRefItem" parameterType="list" resultType="map">

amos-boot-utils/amos-boot-utils-speech/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <artifactId>amos-boot-utils</artifactId>
+        <groupId>com.amosframework.boot</groupId>
+        <version>1.0.0</version>
+    </parent>
+
+    <artifactId>amos-boot-utils-speech</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>com.amosframework.boot</groupId>
+            <artifactId>amos-boot-core</artifactId>
+            <version>${amos-biz-boot.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.73</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.aliyun</groupId>
+            <artifactId>aliyun-java-sdk-core</artifactId>
+            <version>3.7.1</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.alibaba.nls</groupId>
+            <artifactId>nls-sdk-transcriber</artifactId>
+            <version>2.2.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+</project>

amos-boot-utils/amos-boot-utils-speech/src/main/java/com/yeejoin/amos/SpeechApplication.java

+package com.yeejoin.amos;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class SpeechApplication {
+
+    public static void main(String[] args) {
+       SpringApplication.run(SpeechApplication.class, args);
+    }
+}
\ No newline at end of file

amos-boot-utils/amos-boot-utils-speech/src/main/java/com/yeejoin/amos/speech/AppNslClient.java

+package com.yeejoin.amos.speech;
+
+import com.alibaba.nls.client.AccessToken;
+import com.alibaba.nls.client.protocol.NlsClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+
+
+/**
+ * 阿里云nlsClient语音识别客户端
+ * 应用全局创建一个NlsClient实例，默认服务地址为阿里云线上服务地址,默认值：wss://nls-gateway.cn-shanghai.aliyuncs.com/ws/v1
+ */
+public class AppNslClient {
+    private static final Logger logger = LoggerFactory.getLogger(AppNslClientToken.class);
+    private volatile static NlsClient nlsClient;
+
+    private AppNslClient() {
+    }
+
+    public static NlsClient instance() {
+        if (nlsClient == null) {
+            synchronized (NlsClient.class) {
+                if (nlsClient == null) {
+                    logger.warn("AppNslClient语音识别客户端为空，开始创建...");
+                    nlsClient = new NlsClient(AppNslClientToken.instance().getToken());
+                    return nlsClient;
+                }
+            }
+        }
+        //设置访问token
+        nlsClient.setToken(AppNslClientToken.instance().getToken());
+        return nlsClient;
+    }
+
+}
+
+/**
+ * AppNslClientToken
+ */
+class AppNslClientToken {
+    private static final Logger logger = LoggerFactory.getLogger(AppNslClientToken.class);
+    private volatile static AccessToken accessToken;
+    private static long getTokenTime;
+
+    private AppNslClientToken() {
+    }
+
+    public static AccessToken instance() {
+        if (accessToken == null) {
+            synchronized (NlsClient.class) {
+                if (accessToken == null) {
+                    logger.warn("token为空，开始获取token...");
+                    accessToken = getAccessToken();
+                    getTokenTime = System.currentTimeMillis();
+                }
+            }
+        }
+        //token过期自更新
+        if (getTokenTime + accessToken.getExpireTime() <= System.currentTimeMillis()) {
+            logger.warn("token已过期，开始重新获取...");
+            accessToken = getAccessToken();
+            getTokenTime = System.currentTimeMillis();
+        } else {
+            long time = getTokenTime + accessToken.getExpireTime() - System.currentTimeMillis();
+            logger.warn("token过期还剩：" + "(" + time / (1000 * 60 * 60 * 24) + "天)");
+        }
+        return accessToken;
+    }
+
+    /**
+     * 获取访问Token,包含token和过期时间（2021-11-30测试Token过期时间为18天）
+     * 集成项目中，token放到缓存中，避免多次获取可能导致已进行的任务token失效
+     *
+     * @return token 访问token
+     */
+    private static AccessToken getAccessToken() {
+        AccessToken accessToken = new AccessToken(SpeechConfig.AccessKeId, SpeechConfig.AccessKeySecret);
+        try {
+            accessToken.apply();
+            logger.warn("获取到最新的token: " + accessToken.getToken() + ", 过期时间: " + accessToken.getExpireTime() + "(" + accessToken.getExpireTime() / (1000 * 60 * 60 * 24) + "天)");
+            return accessToken;
+        } catch (IOException e) {
+            logger.error("获取语音识别客户端token失败！原因：" + e.getMessage());
+            throw new RuntimeException("获取语音识别客户端token失败！原因：" + e.getMessage());
+        }
+    }
+}

amos-boot-utils/amos-boot-utils-speech/src/main/java/com/yeejoin/amos/speech/AppOkHttpClient.java

+package com.yeejoin.amos.speech;
+
+import okhttp3.*;
+
+import java.io.File;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * okHttp客户端
+ */
+public class AppOkHttpClient {
+
+    static OkHttpClient client = new OkHttpClient
+            .Builder()
+            .connectTimeout(20, TimeUnit.SECONDS)
+            .readTimeout(120, TimeUnit.SECONDS)
+            .writeTimeout(120, TimeUnit.SECONDS)
+            .build();
+
+    /**
+     * okHttp post提交文件请求
+     *
+     * @param url        请求地址
+     * @param headers    请求头
+     * @param speechFile 待识别文件
+     * @param callback   识别回调函数
+     */
+    public static void sendPostFile(String url, HashMap<String, String> headers, File speechFile, Callback callback) {
+        RequestBody body = RequestBody.create(MediaType.parse("application/octet-stream"), speechFile);
+        Headers.Builder hb = new Headers.Builder();
+        if (headers != null && !headers.isEmpty()) {
+            for (Map.Entry<String, String> entry : headers.entrySet()) {
+                hb.add(entry.getKey(), entry.getValue());
+            }
+        }
+        Request request = new Request.Builder()
+                .url(url)
+                .headers(hb.build())
+                .post(body)
+                .build();
+        client.newCall(request).enqueue(callback);
+    }
+}
\ No newline at end of file

amos-boot-utils/amos-boot-utils-speech/src/main/java/com/yeejoin/amos/speech/SpeechConfig.java

+package com.yeejoin.amos.speech;
+
+/**
+ * 阿里云语音识别
+ * <p>
+ * 试用版
+ * <p>
+ * 自2020年03月01日起，免费试用版规则调整为如下内容：
+ * 试用版不计费，如有变化，请关注官网通知。
+ * 一句话识别、实时语音识别、语音合成每自然日内支持2个并发调用，每自然日用量不限，免费试用期限为三个月。
+ * 录音文件识别每自然日识别时长不超过2小时，免费试用期限为三个月。
+ * 长文本语音合成和录音文件识别极速版均不支持试用版，如需使用请开通商用版本。
+ * <p>
+ * 商用版
+ * <p>
+ * 2019年06月10日零时后自动调整为如上新规计费方式。
+ * 对于录音文件识别，若您需要超过2个小时或更长的接口使用时长，请开通商用版。
+ * 开通商用版默认为后付费方式。购买预付费资源包后，自动变更为预付费方式，并优先使用资源包内资源进行抵扣，当预付费资源包内资源使用完后，会再次变更为后付费方式。
+ * 商用版按每自然日使用量计费，无免费额度，不使用则不产生费用。北京时间每日24时，系统将自动对当日用量进行全量计算并计费，账单生成将稍有延迟。
+ * 开通商用版后，不建议再次降配为试用版。商用版降配试用版后，可用并发数将置为0，服务将无法继续使用。
+ */
+public class SpeechConfig {
+    /**
+     * 测试信息,可在阿里云上配置
+     */
+    public static final String AccessKeId = "LTAI5t7mGN6dYoCwMdKiLTgt";
+    public static final String AccessKeySecret = "0LYdEnvKzQxBg0lpIahDp5rzB2r4Dp";
+    public static final String AppKey = "EG5fJBBIqkNMj6bM";
+
+}

amos-boot-utils/amos-boot-utils-speech/src/main/java/com/yeejoin/amos/speech/SpeechFlashRecognizer.java

+package com.yeejoin.amos.speech;
+
+import okhttp3.Callback;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.File;
+import java.util.HashMap;
+
+/**
+ * 不支持免费用户测试
+ * 录音文件识别极速版（支持提交音频文件识别，文件大小，文件时长有限制）
+ * <p>
+ * 音频格式：支持AAC/MP3/OPUS/WAV格式编码的音频。
+ * 使用限制：支持100 MB以内且不超过2小时的音频文件的识别。
+ *
+ * @see SpeechRecognizer
+ * 时长超过2小时的文件请使用录音文件识别普通版
+ *
+ * <p>
+ * 模型类型：8000（电话）/16000（非电话）。
+ * <p>
+ * 同步返回识别结果
+ */
+public class SpeechFlashRecognizer {
+    private static final Logger logger = LoggerFactory.getLogger(SpeechFlashRecognizer.class);
+    //音频文件
+    private final File speechFile;
+    //音频格式
+    private final String format;
+    //音频采样率
+    private final int sampleRate;
+    //识别回调函数
+    private final Callback callback;
+
+
+    public SpeechFlashRecognizer(File speechFile, int sampleRate, Callback callback) {
+        if (speechFile == null || !speechFile.exists() || !speechFile.isFile()) {
+            throw new IllegalArgumentException("待识别的文件存在异常");
+        }
+        if (sampleRate == 0) {
+            throw new IllegalArgumentException("音频采样率不能为0");
+        }
+        String[] split = speechFile.getName().split("\\.");
+        if (split.length != 0) {
+            this.format = split[split.length - 1];
+        } else {
+            throw new IllegalArgumentException("音频文件格式提取失败");
+        }
+        this.speechFile = speechFile;
+        this.sampleRate = sampleRate;
+        this.callback = callback;
+    }
+
+    /**
+     * 设置HTTPS REST POST请求
+     * 1.使用http协议
+     * 2.语音识别服务域名：nls-gateway.cn-shanghai.aliyuncs.com
+     * 3.语音识别接口请求路径：/stream/v1/FlashRecognizer
+     * 4.设置必须请求参数：appkey、token、format、sample_rate
+     * 5.Content-Type 类型必须为 application/octet-stream
+     */
+    public void process() {
+        String request = "https://nls-gateway.cn-shanghai.aliyuncs.com/stream/v1/FlashRecognizer";
+        request = request + "?appkey=" + SpeechConfig.AppKey;
+        request = request + "&token=" + AppNslClientToken.instance().getToken();
+        request = request + "&format=" + format;
+        request = request + "&sample_rate=" + sampleRate;
+        logger.info("Request: " + request);
+        HashMap<String, String> headers = new HashMap<>();
+        headers.put("Content-Type", "application/octet-stream");
+        AppOkHttpClient.sendPostFile(request, headers, this.speechFile, this.callback);
+    }
+}

amos-boot-utils/amos-boot-utils-speech/src/main/java/com/yeejoin/amos/speech/SpeechRecognizer.java

+package com.yeejoin.amos.speech;
+
+import com.alibaba.fastjson.JSONObject;
+import com.aliyuncs.CommonRequest;
+import com.aliyuncs.CommonResponse;
+import com.aliyuncs.DefaultAcsClient;
+import com.aliyuncs.IAcsClient;
+import com.aliyuncs.exceptions.ClientException;
+import com.aliyuncs.http.MethodType;
+import com.aliyuncs.profile.DefaultProfile;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 不支持提交文件
+ * 录音文件识别普通版（提供外网访问的音频文件地址）
+ * <p>
+ * 识别的文件需要提交基于HTTP可访问的URL地址，可以通过URL访问，不支持提交本地文件
+ * 上传的录音文件URL的访问权限需要设置为公开，URL中只能使用域名不能使用IP地址、不可包含空格
+ *
+ * @see SpeechFlashRecognizer
+ * （内网考虑使用录音文件识别极速版，极速版可以提交文件识别，但极速版不提供试用）
+ * <p>
+ * 支持单轨/双轨的.wav、.mp3、.m4a、.wma、.aac、.ogg、.amr、.flac格式录音文件识别
+ * 文件大小需控制在512 MB以下
+ * 免费用户每日可识别不超过2小时时长的录音文件
+ * 提交录音文件识别请求后，免费用户的识别任务在24小时内完成并返回识别文本； 付费用户的识别任务在6小时内完成并返回识别文本。识别结果在服务端可保存72小时
+ */
+@Deprecated
+public class SpeechRecognizer {
+    // 地域ID，常量，固定值。
+    public static final String REGIONID = "cn-shanghai";
+    public static final String ENDPOINTNAME = "cn-shanghai";
+    public static final String PRODUCT = "nls-filetrans";
+    public static final String DOMAIN = "filetrans.cn-shanghai.aliyuncs.com";
+    public static final String API_VERSION = "2018-08-17";
+    public static final String POST_REQUEST_ACTION = "SubmitTask";
+    public static final String GET_REQUEST_ACTION = "GetTaskResult";
+
+    // 请求参数
+    public static final String KEY_APP_KEY = "appkey";
+    public static final String KEY_FILE_LINK = "file_link";
+    public static final String KEY_VERSION = "version";
+    public static final String KEY_ENABLE_WORDS = "enable_words";
+
+    // 响应参数
+    public static final String KEY_TASK = "Task";
+    public static final String KEY_TASK_ID = "TaskId";
+    public static final String KEY_STATUS_TEXT = "StatusText";
+    public static final String KEY_RESULT = "Result";
+
+    // 状态值
+    public static final String STATUS_SUCCESS = "SUCCESS";
+    private static final String STATUS_RUNNING = "RUNNING";
+    private static final String STATUS_QUEUEING = "QUEUEING";
+
+    // 阿里云鉴权client
+    IAcsClient client;
+    private static final Logger logger = LoggerFactory.getLogger(SpeechRecognizer.class);
+
+
+    public SpeechRecognizer() {
+        // 设置endpoint
+        try {
+            DefaultProfile.addEndpoint(ENDPOINTNAME, REGIONID, PRODUCT, DOMAIN);
+        } catch (ClientException e) {
+            e.printStackTrace();
+        }
+        // 创建DefaultAcsClient实例并初始化
+        DefaultProfile profile = DefaultProfile.getProfile(REGIONID, SpeechConfig.AccessKeId, SpeechConfig.AccessKeySecret);
+        this.client = new DefaultAcsClient(profile);
+    }
+
+    /**
+     * 提交录音文件地址
+     */
+    public String submitFileTransRequest(String fileLink) {
+        /**
+         * 1. 创建CommonRequest，设置请求参数。
+         */
+        CommonRequest postRequest = new CommonRequest();
+        // 设置域名
+        postRequest.setDomain(DOMAIN);
+        // 设置API的版本号，格式为YYYY-MM-DD。
+        postRequest.setVersion(API_VERSION);
+        // 设置action
+        postRequest.setAction(POST_REQUEST_ACTION);
+        // 设置产品名称
+        postRequest.setProduct(PRODUCT);
+        /**
+         * 2. 设置录音文件识别请求参数，以JSON字符串的格式设置到请求Body中。
+         */
+        JSONObject taskObject = new JSONObject();
+        // 设置appkey
+        taskObject.put(KEY_APP_KEY, SpeechConfig.AppKey);
+        // 设置音频文件访问链接
+        taskObject.put(KEY_FILE_LINK, fileLink);
+        // 新接入请使用4.0版本，已接入（默认2.0）如需维持现状，请注释掉该参数设置。
+        taskObject.put(KEY_VERSION, "4.0");
+        // 设置是否输出词信息，默认为false，开启时需要设置version为4.0及以上。
+        taskObject.put(KEY_ENABLE_WORDS, true);
+        String task = taskObject.toJSONString();
+        logger.info(task);
+        // 设置以上JSON字符串为Body参数。
+        postRequest.putBodyParameter(KEY_TASK, task);
+        // 设置为POST方式的请求。
+        postRequest.setMethod(MethodType.POST);
+        /**
+         * 3. 提交录音文件识别请求，获取录音文件识别请求任务的ID，以供识别结果查询使用。
+         */
+        String taskId = null;
+        try {
+            CommonResponse postResponse = client.getCommonResponse(postRequest);
+            logger.warn("提交录音文件识别请求的响应：" + postResponse.getData());
+            if (postResponse.getHttpStatus() == 200) {
+                JSONObject result = JSONObject.parseObject(postResponse.getData());
+                String statusText = result.getString(KEY_STATUS_TEXT);
+                if (STATUS_SUCCESS.equals(statusText)) {
+                    taskId = result.getString(KEY_TASK_ID);
+                }
+            }
+        } catch (ClientException e) {
+            e.printStackTrace();
+        }
+        return taskId;
+    }
+
+    /**
+     * 根据任务ID轮询识别结果
+     */
+    public String getFileTransResult(String taskId) {
+        /**
+         * 1. 创建CommonRequest，设置任务ID。
+         */
+        CommonRequest getRequest = new CommonRequest();
+        // 设置域名
+        getRequest.setDomain(DOMAIN);
+        // 设置API版本
+        getRequest.setVersion(API_VERSION);
+        // 设置action
+        getRequest.setAction(GET_REQUEST_ACTION);
+        // 设置产品名称
+        getRequest.setProduct(PRODUCT);
+        // 设置任务ID为查询参数
+        getRequest.putQueryParameter(KEY_TASK_ID, taskId);
+        // 设置为GET方式的请求
+        getRequest.setMethod(MethodType.GET);
+        /**
+         * 2. 提交录音文件识别结果查询请求
+         * 以轮询的方式进行识别结果的查询，直到服务端返回的状态描述为“SUCCESS”或错误描述，则结束轮询。
+         */
+        String result = null;
+        while (true) {
+            try {
+                CommonResponse getResponse = client.getCommonResponse(getRequest);
+                logger.warn("识别查询结果：" + getResponse.getData());
+                if (getResponse.getHttpStatus() != 200) {
+                    break;
+                }
+                JSONObject rootObj = JSONObject.parseObject(getResponse.getData());
+                String statusText = rootObj.getString(KEY_STATUS_TEXT);
+                if (STATUS_RUNNING.equals(statusText) || STATUS_QUEUEING.equals(statusText)) {
+                    // 继续轮询，注意设置轮询时间间隔。
+                    TimeUnit.SECONDS.sleep(3);
+                } else {
+                    // 状态信息为成功，返回识别结果；状态信息为异常，返回空。
+                    if (STATUS_SUCCESS.equals(statusText)) {
+                        result = rootObj.getString(KEY_RESULT);
+                        // 状态信息为成功，但没有识别结果，则可能是由于文件里全是静音、噪音等导致识别为空。
+                        if (result == null) {
+                            result = "";
+                        }
+                    }
+                    break;
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+        }
+        return result;
+    }
+
+}

amos-boot-utils/amos-boot-utils-speech/src/main/java/com/yeejoin/amos/speech/SpeechTranscriber.java

+package com.yeejoin.amos.speech;
+
+import com.alibaba.nls.client.protocol.InputFormatEnum;
+import com.alibaba.nls.client.protocol.SampleRateEnum;
+import com.alibaba.nls.client.protocol.asr.SpeechTranscriberListener;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.util.concurrent.TimeUnit;
+
+
+/**
+ * 实时语音识别
+ * <p>
+ * 支持的输入格式：PCM（无压缩的PCM或WAV文件）、16 bit采样位数、单声道（mono）。
+ * 支持的音频采样率：8000 Hz和16000 Hz。
+ */
+public class SpeechTranscriber {
+
+    private static final Logger logger = LoggerFactory.getLogger(SpeechTranscriber.class);
+    //语音识别文件
+    private final File speechFile;
+    //识别回调函数
+    private final SpeechTranscriberListener listener;
+
+    public SpeechTranscriber(File speechFile, SpeechTranscriberListener listener) {
+        if (speechFile != null && speechFile.exists() && speechFile.isFile()) {
+            this.speechFile = speechFile;
+            this.listener = listener;
+        } else {
+            throw new IllegalArgumentException("待识别的文件存在异常");
+        }
+    }
+
+    /**
+     * 开始语音识别
+     */
+    public void process() {
+        com.alibaba.nls.client.protocol.asr.SpeechTranscriber transcriber = null;
+        try {
+            //创建实例、建立连接。
+            transcriber = new com.alibaba.nls.client.protocol.asr.SpeechTranscriber(AppNslClient.instance(), listener);
+            transcriber.setAppKey(SpeechConfig.AppKey);
+            //输入音频编码方式。
+            transcriber.setFormat(InputFormatEnum.PCM);
+            //输入音频采样率。
+            transcriber.setSampleRate(SampleRateEnum.SAMPLE_RATE_16K);
+            //是否返回中间识别结果。
+            transcriber.setEnableIntermediateResult(true);
+            //是否生成并返回标点符号。
+            transcriber.setEnablePunctuation(true);
+            //是否将返回结果规整化，比如将一百返回为100。
+            transcriber.setEnableITN(false);
+
+            //设置vad断句参数。默认值：800ms，有效值：200ms～2000ms。
+            //transcriber.addCustomedParam("max_sentence_silence", 600);
+            //设置是否语义断句。
+            //transcriber.addCustomedParam("enable_semantic_sentence_detection",false);
+            //设置是否开启顺滑。
+            //transcriber.addCustomedParam("disfluency",true);
+            //设置是否开启词模式。
+            //transcriber.addCustomedParam("enable_words",true);
+            //设置vad噪音阈值参数，参数取值为-1～+1，如-0.9、-0.8、0.2、0.9。
+            //取值越趋于-1，判定为语音的概率越大，亦即有可能更多噪声被当成语音被误识别。
+            //取值越趋于+1，判定为噪音的越多，亦即有可能更多语音段被当成噪音被拒绝识别。
+            //该参数属高级参数，调整需慎重和重点测试。
+            //transcriber.addCustomedParam("speech_noise_threshold",0.3);
+            //设置训练后的定制语言模型id。
+            //transcriber.addCustomedParam("customization_id","你的定制语言模型id");
+            //设置训练后的定制热词id。
+            //transcriber.addCustomedParam("vocabulary_id","你的定制热词id");
+            //设置是否忽略单句超时。
+            transcriber.addCustomedParam("enable_ignore_sentence_timeout", false);
+            //vad断句开启后处理。
+            //transcriber.addCustomedParam("enable_vad_unify_post",false);
+            //此方法将以上参数设置序列化为JSON发送给服务端，并等待服务端确认。
+            transcriber.start();
+            FileInputStream fis = new FileInputStream(speechFile);
+            byte[] b = new byte[3200];
+            int len;
+            while ((len = fis.read(b)) > 0) {
+                logger.info("send data pack length: " + len);
+                transcriber.send(b, len);
+                //本案例用读取本地文件的形式模拟实时获取语音流并发送的，因为读取速度较快，这里需要设置sleep,如果实时获取语音则无需设置sleep
+                TimeUnit.MILLISECONDS.sleep(1000);
+            }
+            //通知服务端语音数据发送完毕，等待服务端处理完成。
+            long now = System.currentTimeMillis();
+            logger.info("ASR wait for complete");
+            transcriber.stop();
+            logger.info("ASR latency : " + (System.currentTimeMillis() - now) + " ms");
+        } catch (Exception e) {
+            logger.error(e.getMessage());
+        } finally {
+            if (null != transcriber) {
+                transcriber.close();
+            }
+        }
+    }
+}

amos-boot-utils/amos-boot-utils-speech/src/test/java/com/yejoin/amos/SpeechApplicationTests.java

+package com.yejoin.amos;
+
+import com.alibaba.nls.client.protocol.asr.SpeechTranscriberListener;
+import com.alibaba.nls.client.protocol.asr.SpeechTranscriberResponse;
+import com.yeejoin.amos.speech.SpeechFlashRecognizer;
+import com.yeejoin.amos.speech.SpeechRecognizer;
+import com.yeejoin.amos.speech.SpeechTranscriber;
+import okhttp3.Call;
+import okhttp3.Callback;
+import okhttp3.Response;
+import org.junit.jupiter.api.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.File;
+import java.io.IOException;
+
+public class SpeechApplicationTests {
+    private static final Logger logger = LoggerFactory.getLogger(SpeechApplicationTests.class);
+
+    /**
+     * 实时语音识别使用示例(提交文件流，免费可测试)
+     */
+    @Test
+    void testSpeechTranscriber() {
+        //本案例使用本地文件模拟发送实时流数据。您在实际使用时，可以实时采集或接收语音流并发送到ASR服务端。
+        String fileLink = "https://gw.alipayobjects.com/os/bmw-prod/0574ee2e-f494-45a5-820f-63aee583045a.wav";
+        //将上面fileLink文件下载到本地后，替换filepath为本地地址测试
+        String filepath = "D:\\ffmpeg-4.4-full_build-shared\\bin\\out.pcm";
+        SpeechTranscriber transcriber = new SpeechTranscriber(new File(filepath), new SpeechTranscriberListener() {
+            /**
+             * 语音识别过程中返回的结果。仅当setEnableIntermediateResult为true时，才会返回该消息。
+             */
+            @Override
+            public void onTranscriptionResultChange(SpeechTranscriberResponse response) {
+                logger.warn("语音识别过程中返回的结果");
+                logger.warn("task_id: " + response.getTaskId() +
+                        ", name: " + response.getName() +
+                        //状态码“20000000”表示正常识别。
+                        ", status: " + response.getStatus() +
+                        //句子编号，从1开始递增。
+                        ", index: " + response.getTransSentenceIndex() +
+                        //当前的识别结果。
+                        ", result: " + response.getTransSentenceText() +
+                        //当前已处理的音频时长，单位为毫秒。
+                        ", time: " + response.getTransSentenceTime());
+            }
+
+            /**
+             * 服务端准备好了进行识别
+             */
+            @Override
+            public void onTranscriberStart(SpeechTranscriberResponse response) {
+                logger.warn("服务端准备好了进行识别");
+                logger.warn("task_id: " + response.getTaskId()
+                        + ", name: " + response.getName()
+                        + ", status: " + response.getStatus());
+            }
+
+            /**
+             * 服务端检测到了一句话的开始
+             */
+            @Override
+            public void onSentenceBegin(SpeechTranscriberResponse response) {
+                logger.warn("服务端检测到了一句话的开始");
+                logger.warn("task_id: " + response.getTaskId()
+                        + ", name: " + response.getName()
+                        + ", status: " + response.getStatus());
+
+            }
+
+            /**
+             * 服务端检测到了一句话的结束
+             * 识别出一句话。服务端会智能断句，当识别到一句话结束时会返回此消息。
+             */
+            @Override
+            public void onSentenceEnd(SpeechTranscriberResponse response) {
+                logger.warn("服务端检测到了一句话的结束");
+                logger.warn("task_id: " + response.getTaskId() +
+                        ", name: " + response.getName() +
+                        //状态码“20000000”表示正常识别。
+                        ", status: " + response.getStatus() +
+                        //句子编号，从1开始递增。
+                        ", index: " + response.getTransSentenceIndex() +
+                        //当前的识别结果。
+                        ", result: " + response.getTransSentenceText() +
+                        //置信度
+                        ", confidence: " + response.getConfidence() +
+                        //开始时间
+                        ", begin_time: " + response.getSentenceBeginTime() +
+                        //当前已处理的音频时长，单位为毫秒。
+                        ", time: " + response.getTransSentenceTime());
+            }
+
+            /**
+             * 识别结束后返回的最终结果
+             */
+            @Override
+            public void onTranscriptionComplete(SpeechTranscriberResponse response) {
+                logger.warn("识别结束后返回的最终结果");
+                logger.warn("task_id: " + response.getTaskId()
+                        + ", name: " + response.getName()
+                        + ", status: " + response.getStatus()
+                        + ",result:" + response.getTransSentenceText());
+            }
+
+            /**
+             * 失败处理
+             */
+            @Override
+            public void onFail(SpeechTranscriberResponse response) {
+                logger.error("失败处理");
+                logger.error("task_id: " + response.getTaskId()
+                        + ", status: " + response.getStatus()
+                        + ", status_text: " + response.getStatusText());
+            }
+        });
+        transcriber.process();
+    }
+
+    /**
+     * 语音文件识别极速版使用示例(提交文件，收费无法测试)
+     */
+    @Test
+    void testSpeechFlashRecognizer() {
+        //String fileName = SpeechRecognizerRestfulDemo.class.getClassLoader().getResource("./nls-sample-16k.wav").getPath();
+        // 重要：此处用一个本地文件来模拟发送实时流数据，实际使用时，您可以从某处实时采集或接收语音流并发送到ASR服务端。
+        String fileName = "D:\\ffmpeg-4.4-full_build-shared\\bin\\test.mp3";
+        String format = "mp3";
+        int sampleRate = 16000;
+        SpeechFlashRecognizer speechFlashRecognizer = new SpeechFlashRecognizer(new File(fileName), sampleRate, new Callback() {
+            @Override
+            public void onFailure(Call call, IOException e) {
+                logger.error("语音识别失败，原因：" + e.getMessage());
+            }
+
+            @Override
+            public void onResponse(Call call, Response response) throws IOException {
+                assert response.body() != null;
+                logger.warn("语音识别结果：" + response.body().string());
+            }
+        });
+        speechFlashRecognizer.process();
+    }
+
+    /**
+     * 语音文件识别普通版使用示例(提交文件地址，免费可测试)
+     */
+    @Test
+    void testSpeechRecognizer() {
+        String fileLink = "https://gw.alipayobjects.com/os/bmw-prod/0574ee2e-f494-45a5-820f-63aee583045a.wav";
+        SpeechRecognizer speechRecognizer = new SpeechRecognizer();
+        // 第一步：提交录音文件识别请求，获取任务ID用于后续的识别结果轮询。
+        String taskId = speechRecognizer.submitFileTransRequest(fileLink);
+        if (taskId != null) {
+            logger.info("录音文件识别请求成功，task_id: " + taskId);
+        } else {
+            logger.error("录音文件识别请求失败！");
+            return;
+        }
+        // 第二步：根据任务ID轮询识别结果。
+        String result = speechRecognizer.getFileTransResult(taskId);
+        if (result != null) {
+            logger.info("录音文件识别结果查询成功：" + result);
+        } else {
+            logger.error("录音文件识别结果查询失败！");
+        }
+    }
+}

amos-boot-utils/pom.xml

 <?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
     <parent>
         <artifactId>amos-biz-boot</artifactId>
@@ -18,5 +19,6 @@
     <modules>
         <module>amos-boot-utils-jpush</module>
         <module>amos-boot-utils-video</module>
+        <module>amos-boot-utils-speech</module>
     </modules>
 </project>
\ No newline at end of file

pom.xml

@@ -283,6 +283,11 @@
 			<name>Snapshots</name>
 			<url>http://172.16.1.6:8081/nexus/content/repositories/snapshots/</url>
 		</repository>
+		<repository>
+			<id>com.e-iceblue</id>
+			<name>e-iceblue</name>
+			<url>https://repo.e-iceblue.com/nexus/content/groups/public/</url>
+		</repository>
 	</repositories>
 
 	<modules>