Merge remote-tracking branch 'origin/test_future_wangge' into test_future_w...

huanghongfa

2021-06-07 55427247b31582f5b6eda25dc811c48d3f9809e8

Merge remote-tracking branch 'origin/test_future_wangge' into test_future_wangge

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/grid/CommonEventBatchRepublishDTO.java

New file
@@ -0,0 +1,33 @@
package com.panzhihua.common.model.dtos.grid;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import javax.validation.constraints.Max;
import javax.validation.constraints.NotNull;
import java.util.List;


/**
 * 事件重新发布请求参表单
 *
 * @author cedoo email:cedoo(a)qq.com
 * @version 1.0
 * @since 1.0
 * @date 2021-05-26
 * */
@Data
@ApiModel("事件重新发布请求参数")
public class CommonEventBatchRepublishDTO {

    @ApiModelProperty(value = "事件id", hidden = false, example = "1", required = true)
    @NotNull
    private List<Long> id;

    @ApiModelProperty(value = "(当前操作)用户ID", hidden = true, example = "1")
    private Long userId;

    @ApiModelProperty(value = "(当前操作)用户姓名", hidden = true, example = "张三")
    private String userName;
}

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/grid/EventBatchRevokeDTO.java

New file
@@ -0,0 +1,39 @@
package com.panzhihua.common.model.dtos.grid;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import javax.validation.constraints.Max;
import javax.validation.constraints.NotNull;
import java.util.List;

/**
 * 编辑表单
 *
 * @author cedoo email:cedoo(a)qq.com
 * @version 1.0
 * @since 1.0
 * @date 2021-05-26
 * */
@Data
@ApiModel("撤销事件请求参数")
public class EventBatchRevokeDTO {

    @ApiModelProperty(value = "id", hidden = false, example = "1", required = true)
    @NotNull
    private List<Long> id;

    @ApiModelProperty(value = "(当前操作)用户ID", hidden = true, example = "1")
    private Long userId;

    @ApiModelProperty(value = "(当前操作)用户姓名", hidden = true, example = "李四")
    private String userName;

    @ApiModelProperty(value = "操作人所属社区", hidden = true, example = "学院社区")
    private String communityName;

    @ApiModelProperty(value = "操作人所属社区", hidden = true, example = "学院社区")
    private Long communityId;

}

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/grid/EventDeleteDTO.java

@@ -4,6 +4,7 @@
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import javax.validation.constraints.NotNull;
import java.util.List;


@@ -20,7 +21,8 @@
public class EventDeleteDTO {

    @ApiModelProperty(value = "id", hidden = false, example = "1")
    private Long id;
    @NotNull
    private List<Long> id;

    @ApiModelProperty(value = "(当前操作)用户ID", hidden = true, example = "1")
    private Long userId;

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/grid/PageEventGridNearbyDTO.java

New file
@@ -0,0 +1,56 @@
package com.panzhihua.common.model.dtos.grid;

import com.fasterxml.jackson.annotation.JsonFormat;
import com.google.common.base.CaseFormat;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import org.hibernate.validator.constraints.Length;

import javax.validation.constraints.Max;
import javax.validation.constraints.NotNull;
import javax.validation.constraints.Pattern;
import java.util.Date;

/**
 * 分页查询表单
 *
 * @author cedoo email:cedoo(a)qq.com
 * @version 1.0
 * @since 1.0
 * @date 2021-05-26
 * */
@Data
@ApiModel("查询事件请求参数")
public class PageEventGridNearbyDTO {

    @ApiModelProperty(value = "分页-当前页数", example = "1")
    private Long pageNum = 1L;

    @ApiModelProperty(value = "分页-每页记录数", example = "10")
    private Long pageSize = 10L;

    @ApiModelProperty(value = "排序字段, 默认createAt", example = "createAt")
    private String sortAttr="createAt";

    @ApiModelProperty(value = "排序方式: asc/desc(默认)", example = "desc")
    @Pattern(regexp = "asc|desc|ASC|DESC", message = "排序方式参数错误")
    private String sortType="desc";

    public String getSortColumns(){
        String dbColumn = CaseFormat.LOWER_CAMEL.to(CaseFormat.LOWER_UNDERSCORE, sortAttr);
        return dbColumn;
    }

    @Length(max=255)
    @ApiModelProperty(value = "发生的精度纬度信息（逗号隔开）", hidden = false, example = "", required = true)
    @NotNull
    private String happentLatLng;

    @ApiModelProperty(value = "(当前操作)用户ID", hidden = true, example = "1")
    private Long userId;

    @ApiModelProperty(value = "(当前操作)用户ID", hidden = true, example = "1")
    private Long userName;

}

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/dtos/grid/PublicityEventAddDTO.java

@@ -49,6 +49,11 @@
    @NotNull(message = "宣传区域不能为空")
    private Long gridId;

    @Max(9223372036854775807L)
    @ApiModelProperty(value = "上报人ID", hidden = false, example = "1", required = true)
    @NotNull(message = "上报人不能为空")
    private Long gridMemberId;

    @Length(max=255)
    @ApiModelProperty(value = "宣传主题", hidden = false, example = "", required = true)
    @NotNull(message = "宣传主题不能为空")

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/model/vos/grid/LatLngVO.java

@@ -1,8 +1,10 @@
package com.panzhihua.common.model.vos.grid;

import lombok.AllArgsConstructor;
import lombok.Data;

@Data
@AllArgsConstructor
public class LatLngVO {

    private Double lng;

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/service/grid/GridService.java

@@ -823,6 +823,38 @@
    R gridMemberStatistics(@RequestBody MemberStatisticsAdminDTO statisticsAdminDTO);

    /**
     * 批量删除
     * @param eventDeleteDTO
     * @return
     */
    @PostMapping("/event/deleteEventBatch")
    R deleteEventBatch(@RequestBody EventDeleteDTO eventDeleteDTO);

    /**
     * 批量发布事件
     * @param commonEventBatchRepublishDTO
     * @return
     */
    @PostMapping("/event/batchRepublishEvent")
    R batchRepublishEvent(@RequestBody CommonEventBatchRepublishDTO commonEventBatchRepublishDTO);

    /**
     * 批量事件标为无效
     * @param eventBatchRevokeDTO
     * @return
     */
    @PostMapping("/event/batchMarkInvalid")
    R batchMarkEventInvalid(@RequestBody EventBatchRevokeDTO eventBatchRevokeDTO);

    /**
     * 批量事件标为无效
     * @param pageEventGridNearbyDTO
     * @return
     */
    @PostMapping("/event/grid/nearby")
    R getNearByGrid(PageEventGridNearbyDTO pageEventGridNearbyDTO);

    /**
     * 根据网格id查询网格统计数据
     * @param gridId    网格id
     * @return  网格统计数据

 springcloud_k8s_panzhihuazhihuishequ/common/src/main/java/com/panzhihua/common/utlis/LngLatUtils.java

@@ -36,4 +36,30 @@
        }
        return check(point, pointList);
    }

    /**
     * 从txt数据中获取经纬度
     * @param latlngTxt
     * @return
     */
    public static List<LatLngVO> getLatLngFromText(String latlngTxt){
        List<LatLngVO> rtResult = new ArrayList<>();
        String str = latlngTxt.replace("[[","");

        str=str.replace("]]","");
        String[] loca=str.split("],\\[");
        for (int i=0;i<loca.length;i++)
        {
            String[] loca1=loca[i].split(",");
            rtResult.add(new LatLngVO(Double.valueOf(loca1[1]), Double.valueOf(loca1[0])));
        }
        return rtResult;
    }

    public static void main(String[] args) {
        String latLngTxt = "[[104.065958,30.662621],[104.06419,30.663172],[104.06315,30.660648],[104.065548,30.661036]]";
        List<LatLngVO> latLngList = getLatLngFromText(latLngTxt);
        System.out.println(isInPolygon(latLngList, 104.0612, 30.6608));
    }

}

 springcloud_k8s_panzhihuazhihuishequ/grid_backstage/src/main/java/com/panzhihua/grid_backstage/api/CommonApi.java

@@ -79,6 +79,11 @@
            fileExtension = ".mp4";
        }

        if(originName.toLowerCase().endsWith(".mp3")){
            fileExtension = ".mp3";
        }


        String fileName = property + File.separator + UUID.randomUUID().toString().replace("-", "") + fileExtension;
        File file1 = new File(fileName);


 springcloud_k8s_panzhihuazhihuishequ/grid_backstage/src/main/java/com/panzhihua/grid_backstage/api/EventApi.java

New file
@@ -0,0 +1,99 @@
package com.panzhihua.grid_backstage.api;

import com.panzhihua.common.controller.BaseController;
import com.panzhihua.common.model.dtos.grid.CommonEventBatchRepublishDTO;
import com.panzhihua.common.model.dtos.grid.EventBatchRevokeDTO;
import com.panzhihua.common.model.dtos.grid.EventDeleteDTO;
import com.panzhihua.common.model.dtos.grid.PageEventGridNearbyDTO;
import com.panzhihua.common.model.vos.LoginUserInfoVO;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.service.grid.GridService;
import com.panzhihua.common.utlis.ClazzUtils;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;

/**
 * @ClasssName EventApi
 * @Description 事件通用接口
 * @Author cedoo
 * @Date 2021/6/7
 * @Version 1.0
 **/
@Slf4j
@RestController
@RequestMapping("/event/common")
@Api(tags = {"宣传教育 @chendong", "事件管理 @chendong"})
public class EventApi extends BaseController {


    @Resource
    private GridService gridService;

    /**
     * 重新发布事件
     *
     * @param commonEventBatchRepublishDTO 重新发布事件传递对象
     * @return 修改结果
     */
    @PutMapping("/republishBatch")
    @ApiOperation(value = "(批量)重新发布已标记无效事件", response = R.class)
    R republishBatch(@Validated @RequestBody CommonEventBatchRepublishDTO commonEventBatchRepublishDTO) {
        ClazzUtils.setIfStringIsEmpty(commonEventBatchRepublishDTO);
        LoginUserInfoVO loginUserInfoVO = this.getLoginUserInfo();
        commonEventBatchRepublishDTO.setUserId(loginUserInfoVO.getUserId());
        commonEventBatchRepublishDTO.setUserName(loginUserInfoVO.getName());
        return gridService.batchRepublishEvent(commonEventBatchRepublishDTO);
    }


    /**
     * (批量)删除
     *
     * @param eventDeleteDTO 删除事件传递对象
     * @return 删除结果
     */
    @DeleteMapping()
    @ApiOperation(value = "(批量)删除", response = R.class)
    R deleteBatch(@Validated @RequestBody EventDeleteDTO eventDeleteDTO) {
        ClazzUtils.setIfStringIsEmpty(eventDeleteDTO);
        eventDeleteDTO.setUserId(this.getUserId());
        return gridService.deleteEventBatch(eventDeleteDTO);
    }


    /**
     * 事件标为无效
     *
     * @param eventBatchRevokeDTO 修改事件传递对象
     * @return 修改结果
     */
    @PutMapping("/markInvalidBatch")
    @ApiOperation(value = "(批量)事件标为无效", response = R.class)
    R markInvalidBatch(@Validated @RequestBody EventBatchRevokeDTO eventBatchRevokeDTO) {
        ClazzUtils.setIfStringIsEmpty(eventBatchRevokeDTO);
        LoginUserInfoVO loginUserInfoVO = getLoginUserInfo();
        eventBatchRevokeDTO.setUserId(loginUserInfoVO.getUserId());
        eventBatchRevokeDTO.setUserName(loginUserInfoVO.getName());
        eventBatchRevokeDTO.setCommunityName(loginUserInfoVO.getCommunityName());
        eventBatchRevokeDTO.setCommunityId(loginUserInfoVO.getCommunityId());
        return gridService.batchMarkEventInvalid(eventBatchRevokeDTO);
    }


    /**
     * 查询距离当前事件最近的网格数据
     * @param pageEventGridNearbyDTO
     * @return
     */
    @PostMapping("/grid/nearby")
    @ApiOperation(value = "查询距离当前事件最近的网格数据", response = R.class)
    R getNearByGrid(@Validated @RequestBody PageEventGridNearbyDTO pageEventGridNearbyDTO){
        return gridService.getNearByGrid(pageEventGridNearbyDTO);
    }

}

 springcloud_k8s_panzhihuazhihuishequ/grid_backstage/src/main/java/com/panzhihua/grid_backstage/api/EventManageApi.java

@@ -54,9 +54,6 @@
    @ApiOperation(value = "事件列表", response= EventVO.class)
    R usersList(@Validated @RequestBody PageEventManageDTO pageEventManageDTO){
        ClazzUtils.setIfStringIsEmpty(pageEventManageDTO);
        if(!isCommonType(pageEventManageDTO.getEventType())){
            return R.fail(400, "事件类型错误");
        }
        LoginUserInfoVO loginUserInfoVO = this.getLoginUserInfo();
        pageEventManageDTO.setUserId(loginUserInfoVO.getUserId());
        pageEventManageDTO.setCommunityId(loginUserInfoVO.getCommunityId());

 springcloud_k8s_panzhihuazhihuishequ/grid_backstage/src/main/java/com/panzhihua/grid_backstage/api/PublicityEventApi.java

@@ -41,9 +41,9 @@
     * @param pagePublicityEventDTO 查找事件
     * @return 查找结果
     */
    @GetMapping("/usersList")
    @PostMapping("/usersList")
    @ApiOperation(value = "宣传教育事件列表", response = EventVO.class)
    R usersPublicityList(@Validated @ModelAttribute PagePublicityEventCommunityDTO pagePublicityEventDTO) {
    R usersPublicityList(@Validated @RequestBody PagePublicityEventCommunityDTO pagePublicityEventDTO) {
        ClazzUtils.setIfStringIsEmpty(pagePublicityEventDTO);
        LoginUserInfoVO loginUserInfoVO = this.getLoginUserInfo();
        pagePublicityEventDTO.setUserId(loginUserInfoVO.getUserId());
@@ -81,20 +81,6 @@
    }

    /**
     * 删除
     *
     * @param eventDeleteDTO 删除事件传递对象
     * @return 删除结果
     */
    @DeleteMapping()
    @ApiOperation(value = "删除事件", response = R.class)
    R delete(@Validated @RequestBody EventDeleteDTO eventDeleteDTO) {
        ClazzUtils.setIfStringIsEmpty(eventDeleteDTO);
        return gridService.delete(eventDeleteDTO);
    }


    /**
     * 撤销事件
     *
     * @param eventRevokeDTO 修改事件传递对象
@@ -124,25 +110,6 @@
        commonEventRepublishDTO.setUserId(loginUserInfoVO.getUserId());
        commonEventRepublishDTO.setUserName(loginUserInfoVO.getName());
        return gridService.republishEvent(commonEventRepublishDTO);
    }


    /**
     * 事件标为无效
     *
     * @param eventRevokeDTO 修改事件传递对象
     * @return 修改结果
     */
    @PutMapping("/markInvalid")
    @ApiOperation(value = "事件标为无效", response = R.class)
    R markInvalid(@Validated @RequestBody EventRevokeDTO eventRevokeDTO) {
        ClazzUtils.setIfStringIsEmpty(eventRevokeDTO);
        LoginUserInfoVO loginUserInfoVO = getLoginUserInfo();
        eventRevokeDTO.setUserId(loginUserInfoVO.getUserId());
        eventRevokeDTO.setUserName(loginUserInfoVO.getName());
        eventRevokeDTO.setCommunityName(loginUserInfoVO.getCommunityName());
        eventRevokeDTO.setCommunityId(loginUserInfoVO.getCommunityId());
        return gridService.markEventInvalid(eventRevokeDTO);
    }

    @ApiOperation(value = "查询当前社区所有网格员", response = EventGridMemberAdminVO.class)

 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/api/EventApi.java

@@ -46,8 +46,17 @@
    @PostMapping("/delete")
    R delete(@RequestBody CommonEventDeleteDTO commonEventDeleteDTO){
        return eventService.delete(commonEventDeleteDTO);
    };
    }

    /**
     * 批量删除
     * @param eventDeleteDTO
     * @return
     */
    @PostMapping("/deleteEventBatch")
    R deleteEventBatch(@RequestBody EventDeleteDTO eventDeleteDTO){
        return  eventService.deleteEventBatch(eventDeleteDTO);
    }
    /**
     * 查询事件详细信息
     * @param id 事件 id
@@ -56,7 +65,7 @@
    @PostMapping("/{id}")
    R<EventDetailsVO> eventDetails(@PathVariable("id") Long id){
        return eventService.eventDetails(id);
    };
    }

    /**
     * 添加突发事件
@@ -66,7 +75,7 @@
    @PostMapping("/addCommon")
    R addCommon(@RequestBody CommonEventAddDTO commonEventAddDTO){
        return eventService.addCommon(commonEventAddDTO);
    };
    }
    /**
     * 保存草稿
     * @param {classNameFirstLower}AddDTO 添加事件传递对象
@@ -135,6 +144,15 @@
        return eventService.republishEvent(commonEventRepublishDTO);
    }

    /**
     * 批量发布事件
     * @param commonEventBatchRepublishDTO
     * @return
     */
    @PostMapping("/batchRepublishEvent")
    R batchRepublishEvent(@RequestBody CommonEventBatchRepublishDTO commonEventBatchRepublishDTO){
        return eventService.batchRepublishEvent(commonEventBatchRepublishDTO);
    }
    /**
     * 草稿发布
     * @param commonEventPublicDTO
@@ -246,6 +264,16 @@
    }

    /**
     * 批量事件标为无效
     * @param eventBatchRevokeDTO
     * @return
     */
    @PostMapping("/batchMarkInvalid")
    R batchMarkEventInvalid(@RequestBody EventBatchRevokeDTO eventBatchRevokeDTO){
        return eventService.batchMarkEventInvalid(eventBatchRevokeDTO);
    }

    /**
     * 社区网格后台重新发布已标记无效的事件
     * @param commonEventRepublishDTO
     * @return
@@ -255,4 +283,14 @@
        return eventService.republishInvalidEvent(commonEventRepublishDTO);
    }

    /**
     * 查询距离当前事件最近的网格数据
     * @param pageEventGridNearbyDTO
     * @return
     */
    @PostMapping("/grid/nearby")
    R getNearByGrid(@RequestBody PageEventGridNearbyDTO pageEventGridNearbyDTO){
        return eventService.getNearByGrid(pageEventGridNearbyDTO);
    }

}

 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/dao/EventGridDataMapper.java

@@ -7,6 +7,7 @@
import com.panzhihua.common.model.dtos.grid.EventGridTodoDataDTO;
import com.panzhihua.common.model.dtos.grid.PageEventGridDataAdminDTO;
import com.panzhihua.common.model.dtos.grid.PageEventGridDataDTO;
import com.panzhihua.common.model.dtos.grid.PageEventGridNearbyDTO;
import com.panzhihua.common.model.vos.R;
import com.panzhihua.common.model.vos.grid.*;
import com.panzhihua.service_grid.model.dos.EventGridDataDO;
@@ -64,4 +65,6 @@
    List<EventGridMemberAdminVO> getGridMemberListsByGrid(@Param("gridId") Long gridId);

    List<EventGridDataAreaVO> getGridDataListByCommunity(@Param("communityId") Long communityId);

    List<EventGridDataAreaVO> selectGridWithArea(Page page, PageEventGridNearbyDTO pageEventGridNearbyDTO);
}

 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/EventService.java

@@ -193,6 +193,34 @@
    R gridMemberStatistics(MemberStatisticsAdminDTO statisticsAdminDTO);

    /**
     * 获取最近的网格
     * @return
     * @param pageEventGridNearbyDTO
     */
    R getNearByGrid(PageEventGridNearbyDTO pageEventGridNearbyDTO);

    /**
     * 批量删除事件
     * @param eventDeleteDTO
     * @return
     */
    R deleteEventBatch(EventDeleteDTO eventDeleteDTO);

    /**
     * 批量重新发布事件
     * @param commonEventBatchRepublishDTO
     * @return
     */
    R batchRepublishEvent(CommonEventBatchRepublishDTO commonEventBatchRepublishDTO);

    /**
     * 批量标记事件无效
     * @param eventBatchRevokeDTO
     * @return
     */
    R batchMarkEventInvalid(EventBatchRevokeDTO eventBatchRevokeDTO);

    /**
     * 根据网格id查询网格统计数据
     * @param gridId    网格id
     * @return  网格统计数据

 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java

@@ -13,9 +13,11 @@
import com.panzhihua.common.model.vos.community.ComActVO;
import com.panzhihua.common.model.vos.grid.*;
import com.panzhihua.common.service.community.CommunityService;
import com.panzhihua.common.utlis.LngLatUtils;
import com.panzhihua.common.utlis.StringUtils;
import com.panzhihua.service_grid.dao.*;
import com.panzhihua.service_grid.model.dos.*;
import com.panzhihua.service_grid.service.EventGridDataService;
import com.panzhihua.service_grid.service.EventResourceService;
import com.panzhihua.service_grid.service.EventService;
import com.panzhihua.service_grid.service.EventTransferRecordService;
@@ -51,23 +53,26 @@
    private EventGridDataMapper eventGridDataMapper;
    @Resource
    private EventGridMemberRelationMapper eventGridMemberRelationMapper;
    @Resource
    private EventGridDataService eventGridDataService;

    /**
     * 分页查找事件
     *
     * @param pageEventDTO
     * @return 维护结果
     */
    @Override
    public R<IPage<EventVO>> query(PageEventDTO pageEventDTO){
        Page page = new Page(1,10);
        if(pageEventDTO.getPageNum()!=null) {
    public R<IPage<EventVO>> query(PageEventDTO pageEventDTO) {
        Page page = new Page(1, 10);
        if (pageEventDTO.getPageNum() != null) {
            page.setCurrent(pageEventDTO.getPageNum());
        }
        if(pageEventDTO.getPageSize()!=null) {
        if (pageEventDTO.getPageSize() != null) {
            page.setSize(pageEventDTO.getPageSize());
        }
        IPage<EventVO> ipage = eventMapper.findByPage(page, pageEventDTO);
        if(ipage!=null){
        if (ipage != null) {
            List<EventVO> eventVOList = ipage.getRecords();
            eventVOList.forEach(eventVO -> {
                List<EventResourceDO> eventResourceDOList =
@@ -79,7 +84,7 @@
                List<EventResourceVO> audioList = new ArrayList<>();
                List<EventResourceVO> videoList = new ArrayList<>();
                eventResourceDOList.forEach(eventResourceDO -> {
                    switch (eventResourceDO.getType()){
                    switch (eventResourceDO.getType()) {
                        case 1:
                            EventResourceVO picEventResourceVO = new EventResourceVO();
                            BeanUtils.copyProperties(eventResourceDO, picEventResourceVO);
@@ -103,7 +108,7 @@

                //查询网格员头像
                String imageUrl = eventMapper.getGridMemberImageUrl(eventVO.getGridMemberId());
                if(StringUtils.isNotEmpty(imageUrl)){
                if (StringUtils.isNotEmpty(imageUrl)) {
                    eventVO.setGridMemberImageUrl(imageUrl);
                }
            });
@@ -114,38 +119,40 @@

    /**
     * 删除事件
     *
     * @param commonEventDeleteDTO
     * @return 平台用户信息
     */
    @Override
    public R delete(CommonEventDeleteDTO commonEventDeleteDTO){
    public R delete(CommonEventDeleteDTO commonEventDeleteDTO) {
        EventDO eventDO = eventMapper.selectById(commonEventDeleteDTO.getId());
        if(eventDO==null){
        if (eventDO == null) {
            return R.fail("事件不存在");
        }
        if(eventDO.getEventStatus()!=null &&
                (eventDO.getEventStatus().intValue()==1||eventDO.getEventStatus().intValue()==4)){//草稿 或者 已撤销 的事件可以删除
        if (eventDO.getEventStatus() != null &&
                (eventDO.getEventStatus().intValue() == 1 || eventDO.getEventStatus().intValue() == 4)) {//草稿 或者 已撤销 的事件可以删除
            eventDO.setEventStatus(3);//逻辑删除
            eventDO.setUpdateBy(commonEventDeleteDTO.getUserId());
            int updated = this.getBaseMapper().updateById(eventDO);
            return updated==1?R.ok():R.fail();
            return updated == 1 ? R.ok() : R.fail();
        }
        return R.fail("事件不是草稿/已撤销/无效状态， 不允许删除");
    }

    /**
     * 查询事件详细信息
     *
     * @param id 事件 id
     * @return 查找结果
     */
    @Override
    public R<EventDetailsVO> eventDetails(Long id){
    public R<EventDetailsVO> eventDetails(Long id) {
        EventDO eventDO = eventMapper.selectById(id);
        if(eventDO!=null) {
        if (eventDO != null) {
            EventDetailsVO eventDetailsVO = new EventDetailsVO();
            BeanUtils.copyProperties(eventDO, eventDetailsVO);
            EventGridDataDO eventGridDataDO = eventGridDataMapper.selectById(eventDO.getGridId());
            if(eventGridDataDO!=null) {
            if (eventGridDataDO != null) {
                eventDetailsVO.setGridName(eventGridDataDO.getGridName());
            }

@@ -159,7 +166,7 @@
            List<EventResourceVO> audioList = new ArrayList<>();
            List<EventResourceVO> videoList = new ArrayList<>();
            eventResourceDOList.forEach(eventResourceDO -> {
                switch (eventResourceDO.getType()){
                switch (eventResourceDO.getType()) {
                    case 1:
                        EventResourceVO picEventResourceVO = new EventResourceVO();
                        BeanUtils.copyProperties(eventResourceDO, picEventResourceVO);
@@ -182,7 +189,6 @@
            eventDetailsVO.setVideos(videoList);



            //查询事件流转记录
            List<EventTransferRecordDO> eventTransferRecordDOList = eventTransferRecordService.getBaseMapper()
                    .selectList(new LambdaQueryWrapper<EventTransferRecordDO>()
@@ -203,7 +209,7 @@
                List<EventResourceVO> transferAudioList = new ArrayList<>();
                List<EventResourceVO> transferVideoList = new ArrayList<>();
                eventTransferResourceDOList.forEach(eventResourceDO -> {
                    switch (eventResourceDO.getType()){
                    switch (eventResourceDO.getType()) {
                        case 1:
                            EventResourceVO picEventResourceVO = new EventResourceVO();
                            BeanUtils.copyProperties(eventResourceDO, picEventResourceVO);
@@ -230,7 +236,7 @@

            //查询事件发布人头像
            String imageUrl = eventMapper.getGridMemberImageUrl(eventDO.getGridMemberId());
            if(StringUtils.isNotEmpty(imageUrl)){
            if (StringUtils.isNotEmpty(imageUrl)) {
                eventDetailsVO.setGridMemberImageUrl(imageUrl);
            }

@@ -244,14 +250,14 @@
    public R addCommon(CommonEventAddDTO commonEventAddDTO) {
        EventDO eventDO = new EventDO();
        BeanUtils.copyProperties(commonEventAddDTO, eventDO);
        if(commonEventAddDTO instanceof  CommonEventCommunityAddDTO) {
            CommonEventCommunityAddDTO commonEventCommunityAddDTO = (CommonEventCommunityAddDTO)commonEventAddDTO;
        if (commonEventAddDTO instanceof CommonEventCommunityAddDTO) {
            CommonEventCommunityAddDTO commonEventCommunityAddDTO = (CommonEventCommunityAddDTO) commonEventAddDTO;
            eventDO.setGridMemberId(commonEventCommunityAddDTO.getGridMemberId());
        }else{
        } else {
            eventDO.setGridMemberId(commonEventAddDTO.getUserId());
        }
        EventGridDataDO eventGridDataDO = eventGridDataMapper.selectById(commonEventAddDTO.getGridId());
        if(eventGridDataDO==null){
        if (eventGridDataDO == null) {
            return R.fail("网格不存在");
        }
        eventDO.setEventCategory(1l);//办件事件
@@ -264,9 +270,9 @@
        eventDO.setCreateBy(commonEventAddDTO.getUserId());
        eventDO.setSubmitDate(new Date());
        eventDO.setOrderSn(getEventOrderSn(eventDO.getEventType()));
        if(eventMapper.insert(eventDO)==1){
        if (eventMapper.insert(eventDO) == 1) {
            //添加音频
            if(StringUtils.isNotEmpty(commonEventAddDTO.getAudio())){
            if (StringUtils.isNotEmpty(commonEventAddDTO.getAudio())) {
                EventResourceDO eventResourceDO = new EventResourceDO();
                eventResourceDO.setClassification(1);
                eventResourceDO.setType(2);
@@ -275,12 +281,12 @@
                eventResourceDO.setCreateBy(commonEventAddDTO.getUserId());
                eventResourceDO.setResourceTime(commonEventAddDTO.getAudioTime());
                int audioAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                if(audioAdd!=1){
                if (audioAdd != 1) {
                    throw new ServiceException("添加音频失败");
                }
            }
            //添加视频
            if(StringUtils.isNotEmpty(commonEventAddDTO.getVideo())){
            if (StringUtils.isNotEmpty(commonEventAddDTO.getVideo())) {
                EventResourceDO eventResourceDO = new EventResourceDO();
                eventResourceDO.setClassification(1);
                eventResourceDO.setType(3);
@@ -289,12 +295,12 @@
                eventResourceDO.setCreateBy(commonEventAddDTO.getUserId());
                eventResourceDO.setResourceTime(commonEventAddDTO.getVideoTime());
                int videoAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                if(videoAdd!=1){
                if (videoAdd != 1) {
                    throw new ServiceException("添加视频失败");
                }
            }
            //添加图片
            if(StringUtils.isNotEmpty(commonEventAddDTO.getPics())){
            if (StringUtils.isNotEmpty(commonEventAddDTO.getPics())) {
                String[] pica = commonEventAddDTO.getPics().split(",");
                for (int i = 0; i < pica.length; i++) {
                    EventResourceDO eventResourceDO = new EventResourceDO();
@@ -304,7 +310,7 @@
                    eventResourceDO.setRefId(eventDO.getId());
                    eventResourceDO.setCreateBy(commonEventAddDTO.getUserId());
                    int picAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                    if(picAdd!=1){
                    if (picAdd != 1) {
                        throw new ServiceException("添加图片失败");
                    }
                }
@@ -319,10 +325,10 @@
    @Transactional(rollbackFor = Exception.class)
    public R saveDraft(CommonEventEditDTO commonEventEditDTO) {
        EventGridDataDO eventGridDataDO = eventGridDataMapper.selectById(commonEventEditDTO.getGridId());
        if(eventGridDataDO==null){
        if (eventGridDataDO == null) {
            return R.fail("网格不存在");
        }
        if(commonEventEditDTO.getId()==null) {
        if (commonEventEditDTO.getId() == null) {
            EventDO eventDO = new EventDO();
            BeanUtils.copyProperties(commonEventEditDTO, eventDO);
            eventDO.setGridMemberId(commonEventEditDTO.getUserId());
@@ -383,10 +389,10 @@
                return R.ok();
            }
            return R.fail();
        }else{
        } else {
            //编辑原来的
            EventDO eventDO = eventMapper.selectById(commonEventEditDTO.getId());
            if(eventDO.getEventStatus()!=null && eventDO.getEventStatus()!=1 && eventDO.getEventDealStatus()!=6){
            if (eventDO.getEventStatus() != null && eventDO.getEventStatus() != 1 && eventDO.getEventDealStatus() != 6) {
                return R.fail("保存草稿失败，事件不是草稿/已撤销状态");
            }
            BeanUtils.copyProperties(commonEventEditDTO, eventDO);
@@ -400,7 +406,7 @@
            if (eventMapper.updateById(eventDO) > 0) {
                int deleted = eventResourceService.getBaseMapper()
                        .delete(new LambdaQueryWrapper<EventResourceDO>()
                                .eq(EventResourceDO::getClassification,1)
                                .eq(EventResourceDO::getClassification, 1)
                                .eq(EventResourceDO::getRefId, eventDO.getId()));
                //添加音频
                if (StringUtils.isNotEmpty(commonEventEditDTO.getAudio())) {
@@ -456,22 +462,22 @@
    @Transactional(rollbackFor = Exception.class)
    public R report(CommonEventReportDTO commonEventReportDTO) {
        EventDO eventDO = this.getBaseMapper().selectById(commonEventReportDTO.getEventId());
        if(eventDO==null){
        if (eventDO == null) {
            return R.fail("事件不存在");
        }
        if(eventDO.getEventStatus()!=2){
        if (eventDO.getEventStatus() != 2) {
            return R.fail("当前事件不能上报社区");
        }
        if(eventDO.getProcessType()==2){
        if (eventDO.getProcessType() == 2) {
            return R.fail("当前事件已交由社区处理");
        }

        R r  = communityService.detailCommunity(commonEventReportDTO.getToId());
        if(!R.isOk(r)){
        R r = communityService.detailCommunity(commonEventReportDTO.getToId());
        if (!R.isOk(r)) {
            return R.fail("社区不存在");
        }
        ComActVO comActVO= JSONObject.parseObject(JSONObject.toJSONString(r.getData()),ComActVO.class);
        if(comActVO==null){
        ComActVO comActVO = JSONObject.parseObject(JSONObject.toJSONString(r.getData()), ComActVO.class);
        if (comActVO == null) {
            return R.fail("社区不存在");
        }
        eventDO.setCommunityProcess(1);    //社区处理
@@ -481,7 +487,7 @@
        eventDO.setUpdateBy(commonEventReportDTO.getUserId());
        eventDO.setSubmitDate(new Date());
        int updated = this.getBaseMapper().updateById(eventDO);
        if(updated!=1){
        if (updated != 1) {
            throw new ServiceException("更新突发事件状态更新失败");
        }
        addTransferRecord(eventDO.getId(), commonEventReportDTO.getToId(), comActVO.getName(), 2, commonEventReportDTO.getProcessResult(),
@@ -494,15 +500,15 @@
    @Transactional(rollbackFor = Exception.class)
    public R emergenciesRevoke(EventRevokeDTO eventRevokeDTO) {
        EventDO eventDO = this.getBaseMapper().selectById(eventRevokeDTO.getId());
        if(eventDO==null){
        if (eventDO == null) {
            return R.fail("事件不存在");
        }
        boolean canRevoke = eventDO.getEventStatus()==2; //发布状态
        if(!canRevoke){
        boolean canRevoke = eventDO.getEventStatus() == 2; //发布状态
        if (!canRevoke) {
            return R.fail("当前事件不允许·");
        }
        Integer eventProcessStatus = eventDO.getEventProcessStatus()!=null?eventDO.getEventProcessStatus():-1;
         if(eventProcessStatus==2 ||eventProcessStatus==3) {   //已解决 或者 待验证 不允许撤销
        Integer eventProcessStatus = eventDO.getEventProcessStatus() != null ? eventDO.getEventProcessStatus() : -1;
        if (eventProcessStatus == 2 || eventProcessStatus == 3) {   //已解决 或者 待验证 不允许撤销
            return R.fail("当前事件不允许撤销");
        }
        eventDO.setEventStatus(4);
@@ -510,9 +516,9 @@
        eventDO.setProcessType(1);//网格员处理
        eventDO.setCommunityProcess(0);//非 社区处理
        int updated = this.getBaseMapper().updateById(eventDO);
        if(updated == 1){
        if (updated == 1) {
            addTransferRecord(eventDO.getId(), eventRevokeDTO.getUserId(), eventRevokeDTO.getUserName(),
                    1,"撤销成功", eventRevokeDTO.getUserId(), eventRevokeDTO.getUserName(), 7);
                    1, "撤销成功", eventRevokeDTO.getUserId(), eventRevokeDTO.getUserName(), 7);
            return R.ok();
        }
        return R.fail();
@@ -525,12 +531,12 @@
        if (eventDO == null) {
            return R.fail("事件不存在");
        }
        boolean canDealByUser = eventDO.getEventStatus()==2 && eventDO.getEventProcessStatus()==1;
        if(!canDealByUser){
            if(eventDO.getEventStatus()!=2){
        boolean canDealByUser = eventDO.getEventStatus() == 2 && eventDO.getEventProcessStatus() == 1;
        if (!canDealByUser) {
            if (eventDO.getEventStatus() != 2) {
                return R.fail("事件不是发布状态");
            }
            if(eventDO.getEventProcessStatus()!=1){
            if (eventDO.getEventProcessStatus() != 1) {
                return R.fail("事件不是待处理状态");
            }
            return R.fail("事件当前不可自处理");
@@ -546,20 +552,20 @@
        eventDO.setProcessDesc(commonEventDealDTO.getProcessResult());

        int updated = this.getBaseMapper().updateById(eventDO);
        if(updated!=1){
        if (updated != 1) {
            return R.fail("更新事件状态失败");
        }
        Integer processType = -1;
        if(eventDO.getInvalid()!=null){
        if (eventDO.getInvalid() != null) {
            processType = 5;
        }else{
        } else {
            processType = 1;
        }
        EventTransferRecordDO transferRecordDO =
                addTransferRecord(eventDO.getId(), commonEventDealDTO.getUserId(), commonEventDealDTO.getUserName(),1, "网格员自处理完成",  commonEventDealDTO.getUserId(), commonEventDealDTO.getUserName(), processType);
        if(transferRecordDO!=null && transferRecordDO.getId()!=null){
                addTransferRecord(eventDO.getId(), commonEventDealDTO.getUserId(), commonEventDealDTO.getUserName(), 1, "网格员自处理完成", commonEventDealDTO.getUserId(), commonEventDealDTO.getUserName(), processType);
        if (transferRecordDO != null && transferRecordDO.getId() != null) {
            //添加音频
            if(StringUtils.isNotEmpty(commonEventDealDTO.getAudio())){
            if (StringUtils.isNotEmpty(commonEventDealDTO.getAudio())) {
                EventResourceDO eventResourceDO = new EventResourceDO();
                eventResourceDO.setClassification(3);
                eventResourceDO.setType(2);
@@ -568,12 +574,12 @@
                eventResourceDO.setCreateBy(commonEventDealDTO.getUserId());
                eventResourceDO.setResourceTime(commonEventDealDTO.getAudioTime());
                int audioAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                if(audioAdd!=1){
                if (audioAdd != 1) {
                    throw new ServiceException("添加音频失败");
                }
            }
            //添加视频
            if(StringUtils.isNotEmpty(commonEventDealDTO.getVideo())){
            if (StringUtils.isNotEmpty(commonEventDealDTO.getVideo())) {
                EventResourceDO eventResourceDO = new EventResourceDO();
                eventResourceDO.setClassification(3);
                eventResourceDO.setType(3);
@@ -582,12 +588,12 @@
                eventResourceDO.setCreateBy(commonEventDealDTO.getUserId());
                eventResourceDO.setResourceTime(commonEventDealDTO.getVideoTime());
                int videoAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                if(videoAdd!=1){
                if (videoAdd != 1) {
                    throw new ServiceException("添加视频失败");
                }
            }
            //添加图片
            if(StringUtils.isNotEmpty(commonEventDealDTO.getPics())){
            if (StringUtils.isNotEmpty(commonEventDealDTO.getPics())) {
                String[] pica = commonEventDealDTO.getPics().split(",");
                for (int i = 0; i < pica.length; i++) {
                    EventResourceDO eventResourceDO = new EventResourceDO();
@@ -597,7 +603,7 @@
                    eventResourceDO.setRefId(transferRecordDO.getId());
                    eventResourceDO.setCreateBy(commonEventDealDTO.getUserId());
                    int picAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                    if(picAdd!=1){
                    if (picAdd != 1) {
                        throw new ServiceException("添加图片失败");
                    }
                }
@@ -607,12 +613,12 @@
            EventDO eventDOToUpdate = this.getBaseMapper().selectById(commonEventDealDTO.getId());
            eventDOToUpdate.setProcessRecordId(transferRecordId);
            int transferRecordUpdated = this.getBaseMapper().updateById(eventDOToUpdate);
            if(transferRecordUpdated!=1){
            if (transferRecordUpdated != 1) {
                throw new ServiceException("更新事件处理流程失败");
            }

            return R.ok();
        }else{
        } else {
            throw new ServiceException("处理事件记录出错");
        }
    }
@@ -621,19 +627,19 @@
    @Override
    public R verifyEvent(CommonEventVerifyDTO commonEventVerifyDTO) {
        EventDO eventDO = this.getBaseMapper().selectById(commonEventVerifyDTO.getId());
        boolean canVerifyByUser = eventDO.getEventProcessStatus()==3;
        if(!canVerifyByUser){
        boolean canVerifyByUser = eventDO.getEventProcessStatus() == 3;
        if (!canVerifyByUser) {
            return R.fail("当前不是待验证状态");
        }
        boolean processTypeRight = eventDO.getProcessType()==1;
        if(!processTypeRight){
        boolean processTypeRight = eventDO.getProcessType() == 1;
        if (!processTypeRight) {
            return R.fail("当前处理对象不是网格员");
        }

        eventDO.setEventProcessStatus(2);//2已解决
        eventDO.setUpdateBy(commonEventVerifyDTO.getUserId());
        int updated = this.getBaseMapper().updateById(eventDO);
        if(updated!=1){
        if (updated != 1) {
            return R.fail("更新事件状态失败");
        }
        addTransferRecord(eventDO.getId(), commonEventVerifyDTO.getUserId(), commonEventVerifyDTO.getUserName(), 1, commonEventVerifyDTO.getProcessResult(),
@@ -644,8 +650,8 @@
    @Override
    public R republishEvent(CommonEventRepublishDTO commonEventRepublishDTO) {
        EventDO eventDO = this.getBaseMapper().selectById(commonEventRepublishDTO.getId());
        boolean canRepublishByUser = eventDO.getEventStatus()==4||eventDO.getEventStatus()==1;
        if(!canRepublishByUser){
        boolean canRepublishByUser = eventDO.getEventStatus() == 4 || eventDO.getEventStatus() == 1;
        if (!canRepublishByUser) {
            return R.fail("当前不是撤销/草稿状态");
        }

@@ -654,7 +660,7 @@
        eventDO.setProcessType(1);   //网格员处理
        eventDO.setUpdateBy(commonEventRepublishDTO.getUserId());
        int updated = this.getBaseMapper().updateById(eventDO);
        if(updated!=1){
        if (updated != 1) {
            return R.fail("更新事件状态失败");
        }
        addTransferRecord(eventDO.getId(), commonEventRepublishDTO.getUserId(), commonEventRepublishDTO.getUserName(), 1,
@@ -666,8 +672,8 @@
    @Transactional(rollbackFor = Exception.class)
    public R draftRelease(CommonEventPublicDTO commonEventPublicDTO) {
        EventDO eventDO = this.getBaseMapper().selectById(commonEventPublicDTO.getId());
        boolean draftCanRelease = eventDO.getEventStatus()==1;
        if(!draftCanRelease){
        boolean draftCanRelease = eventDO.getEventStatus() == 1;
        if (!draftCanRelease) {
            return R.fail("当前不是草稿状态");
        }
        eventDO.setOrderSn(getEventOrderSn(eventDO.getEventType()));
@@ -677,7 +683,7 @@
        eventDO.setEventProcessStatus(1);//待处理
        eventDO.setUpdateBy(commonEventPublicDTO.getUserId());
        int updated = this.getBaseMapper().updateById(eventDO);
        if(updated!=1){
        if (updated != 1) {
            return R.fail("更新事件状态失败");
        }
        addReleaseRecord(eventDO.getId(), commonEventPublicDTO.getUserId(), commonEventPublicDTO.getUserName());
@@ -686,28 +692,29 @@

    /**
     * 生成服务单号
     *
     * @param eventType 事件类型，宣传事件默认为20
     * @return
     */
    private String getEventOrderSn(Integer eventType) {
        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyyMMdd");
        if(eventType==null){
            eventType =  20;
        if (eventType == null) {
            eventType = 20;
        }
        String pre = String.format(simpleDateFormat.format(new Date()) + "%02d", eventType);
        Integer todayCount = this.getBaseMapper().selectCount(new LambdaQueryWrapper<EventDO>().likeRight(EventDO::getOrderSn, pre));
        String orderSn =  String.format(pre + "%04d", todayCount+1);
        String orderSn = String.format(pre + "%04d", todayCount + 1);
        return orderSn;
    }

    @Override
    public R saveSpecialDraft(SpecialEventEditDTO specialEventEditDTO) {
        EventGridDataDO eventGridDataDO = eventGridDataMapper.selectById(specialEventEditDTO.getGridId());
        if(eventGridDataDO==null){
        if (eventGridDataDO == null) {
            return R.fail("网格不存在");
        }
        R rtVal = R.fail();
        if(specialEventEditDTO.getId()==null) {
        if (specialEventEditDTO.getId() == null) {
            EventDO eventDO = new EventDO();
            BeanUtils.copyProperties(specialEventEditDTO, eventDO);
            eventDO.setGridMemberId(specialEventEditDTO.getUserId());
@@ -766,7 +773,7 @@
                rtVal = R.ok();
            }
            rtVal = R.fail();
        }else{
        } else {
            //编辑原来的
            EventDO eventDO = eventMapper.selectById(specialEventEditDTO.getId());
            BeanUtils.copyProperties(specialEventEditDTO, eventDO);
@@ -780,7 +787,7 @@
            if (eventMapper.updateById(eventDO) > 0) {
                int deleted = eventResourceService.getBaseMapper()
                        .delete(new LambdaQueryWrapper<EventResourceDO>()
                                .eq(EventResourceDO::getClassification,1)
                                .eq(EventResourceDO::getClassification, 1)
                                .eq(EventResourceDO::getRefId, eventDO.getId()));
                //添加音频
                if (StringUtils.isNotEmpty(specialEventEditDTO.getAudio())) {
@@ -830,7 +837,7 @@
            }
            rtVal = R.fail();
        }
        if(R.isOk(rtVal)){
        if (R.isOk(rtVal)) {
            //TODO 处理特殊人群实有人口数据

        }
@@ -840,7 +847,7 @@
    @Override
    public R addSpecial(SpecialEventAddDTO specialEventAddDTO) {
        EventGridDataDO eventGridDataDO = eventGridDataMapper.selectById(specialEventAddDTO.getGridId());
        if(eventGridDataDO==null){
        if (eventGridDataDO == null) {
            return R.fail("网格不存在");
        }
        R rtVal = R.fail();
@@ -903,7 +910,7 @@
        }
        rtVal = R.fail();

        if(R.isOk(rtVal)){
        if (R.isOk(rtVal)) {
            //TODO 处理特殊人群实有人口数据

            addReleaseRecord(eventDO.getId(), specialEventAddDTO.getUserId(), specialEventAddDTO.getUserName());
@@ -924,7 +931,7 @@
    @Override
    public R addPublicity(PublicityEventAddDTO publicityEventAddDTO) {
        EventGridDataDO eventGridDataDO = eventGridDataMapper.selectById(publicityEventAddDTO.getGridId());
        if(eventGridDataDO==null){
        if (eventGridDataDO == null) {
            return R.fail("网格不存在");
        }
        EventDO eventDO = new EventDO();
@@ -932,14 +939,19 @@
        eventDO.setGridMemberId(publicityEventAddDTO.getUserId());
        eventDO.setEventCategory(2l);//宣传事件
        eventDO.setEventStatus(2);//事件状态 2发布
        eventDO.setGridMemberId(publicityEventAddDTO.getUserId());
        eventDO.setEventType(8);
        if(publicityEventAddDTO.getGridMemberId()!=null) {
            eventDO.setGridMemberId(publicityEventAddDTO.getGridMemberId());
        }else{
            eventDO.setGridMemberId(publicityEventAddDTO.getUserId());
        }
        eventDO.setGridMemberName(publicityEventAddDTO.getUserName());
        eventDO.setGridMemberTelephone(publicityEventAddDTO.getPhone());
        eventDO.setCreateBy(publicityEventAddDTO.getUserId());
        eventDO.setOrderSn(getEventOrderSn(eventDO.getEventType()));
        if(eventMapper.insert(eventDO)==1){
        if (eventMapper.insert(eventDO) == 1) {
            //添加音频
            if(StringUtils.isNotEmpty(publicityEventAddDTO.getAudio())){
            if (StringUtils.isNotEmpty(publicityEventAddDTO.getAudio())) {
                EventResourceDO eventResourceDO = new EventResourceDO();
                eventResourceDO.setClassification(1);
                eventResourceDO.setType(2);
@@ -948,12 +960,12 @@
                eventResourceDO.setCreateBy(publicityEventAddDTO.getUserId());
                eventResourceDO.setResourceTime(publicityEventAddDTO.getAudioTime());
                int audioAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                if(audioAdd!=1){
                if (audioAdd != 1) {
                    throw new ServiceException("添加音频失败");
                }
            }
            //添加视频
            if(StringUtils.isNotEmpty(publicityEventAddDTO.getVideo())){
            if (StringUtils.isNotEmpty(publicityEventAddDTO.getVideo())) {
                EventResourceDO eventResourceDO = new EventResourceDO();
                eventResourceDO.setClassification(1);
                eventResourceDO.setType(3);
@@ -962,12 +974,12 @@
                eventResourceDO.setCreateBy(publicityEventAddDTO.getUserId());
                eventResourceDO.setResourceTime(publicityEventAddDTO.getVideoTime());
                int videoAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                if(videoAdd!=1){
                if (videoAdd != 1) {
                    throw new ServiceException("添加视频失败");
                }
            }
            //添加图片
            if(StringUtils.isNotEmpty(publicityEventAddDTO.getPics())){
            if (StringUtils.isNotEmpty(publicityEventAddDTO.getPics())) {
                String[] pica = publicityEventAddDTO.getPics().split(",");
                for (int i = 0; i < pica.length; i++) {
                    EventResourceDO eventResourceDO = new EventResourceDO();
@@ -977,7 +989,7 @@
                    eventResourceDO.setRefId(eventDO.getId());
                    eventResourceDO.setCreateBy(publicityEventAddDTO.getUserId());
                    int picAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                    if(picAdd!=1){
                    if (picAdd != 1) {
                        throw new ServiceException("添加图片失败");
                    }
                }
@@ -992,10 +1004,10 @@
    @Override
    public R savePublicityDraft(PublicityEventEditDTO publicityEventEditDTO) {
        EventGridDataDO eventGridDataDO = eventGridDataMapper.selectById(publicityEventEditDTO.getGridId());
        if(eventGridDataDO==null){
        if (eventGridDataDO == null) {
            return R.fail("网格不存在");
        }
        if(publicityEventEditDTO.getId()==null) {
        if (publicityEventEditDTO.getId() == null) {
            EventDO eventDO = new EventDO();
            BeanUtils.copyProperties(publicityEventEditDTO, eventDO);
            eventDO.setGridMemberId(publicityEventEditDTO.getUserId());
@@ -1006,6 +1018,7 @@
            eventDO.setGridMemberName(publicityEventEditDTO.getUserName());
            eventDO.setGridMemberTelephone(publicityEventEditDTO.getPhone());
            eventDO.setEventDealStatus(5);//草稿状态
            eventDO.setEventType(8);
            if (eventMapper.insert(eventDO) > 0) {
                //添加音频
                if (StringUtils.isNotEmpty(publicityEventEditDTO.getAudio())) {
@@ -1054,10 +1067,10 @@
                return R.ok();
            }
            return R.fail();
        }else{
        } else {
            //编辑原来的
            EventDO eventDO = eventMapper.selectById(publicityEventEditDTO.getId());
            if(eventDO.getEventStatus()!=null && eventDO.getEventStatus()!=1 && eventDO.getEventDealStatus()!=6){
            if (eventDO.getEventStatus() != null && eventDO.getEventStatus() != 1 && eventDO.getEventDealStatus() != 6) {
                return R.fail("保存草稿失败，事件不是草稿/撤销状态");
            }
            BeanUtils.copyProperties(publicityEventEditDTO, eventDO);
@@ -1071,7 +1084,7 @@
            if (eventMapper.updateById(eventDO) > 0) {
                int deleted = eventResourceService.getBaseMapper()
                        .delete(new LambdaQueryWrapper<EventResourceDO>()
                                .eq(EventResourceDO::getClassification,1)
                                .eq(EventResourceDO::getClassification, 1)
                                .eq(EventResourceDO::getRefId, eventDO.getId()));
                //添加音频
                if (StringUtils.isNotEmpty(publicityEventEditDTO.getAudio())) {
@@ -1125,15 +1138,15 @@

    @Override
    public R selectPublicity(PagePublicityEventDTO pagePublicityEventDTO) {
        Page page = new Page(1,10);
        if(pagePublicityEventDTO.getPageNum()!=null) {
        Page page = new Page(1, 10);
        if (pagePublicityEventDTO.getPageNum() != null) {
            page.setCurrent(pagePublicityEventDTO.getPageNum());
        }
        if(pagePublicityEventDTO.getPageSize()!=null) {
        if (pagePublicityEventDTO.getPageSize() != null) {
            page.setSize(pagePublicityEventDTO.getPageSize());
        }
        IPage<EventVO> ipage = eventMapper.findPublicityByPage(page, pagePublicityEventDTO);
        if(ipage!=null){
        if (ipage != null) {
            List<EventVO> eventVOList = ipage.getRecords();
            eventVOList.forEach(eventVO -> {
                List<EventResourceDO> eventResourceDOList =
@@ -1145,7 +1158,7 @@
                List<EventResourceVO> audioList = new ArrayList<>();
                List<EventResourceVO> videoList = new ArrayList<>();
                eventResourceDOList.forEach(eventResourceDO -> {
                    switch (eventResourceDO.getType()){
                    switch (eventResourceDO.getType()) {
                        case 1:
                            EventResourceVO picEventResourceVO = new EventResourceVO();
                            BeanUtils.copyProperties(eventResourceDO, picEventResourceVO);
@@ -1180,15 +1193,15 @@
    @Override
    public R eventToManage(PageEventManageDTO pageEventManageDTO) {
        //查询管理事件
        Page page = new Page(1,10);
        if(pageEventManageDTO.getPageNum()!=null) {
        Page page = new Page(1, 10);
        if (pageEventManageDTO.getPageNum() != null) {
            page.setCurrent(pageEventManageDTO.getPageNum());
        }
        if(pageEventManageDTO.getPageSize()!=null) {
        if (pageEventManageDTO.getPageSize() != null) {
            page.setSize(pageEventManageDTO.getPageSize());
        }
        IPage<EventVO> ipage = eventMapper.findToManageByPage(page, pageEventManageDTO);
        if(ipage!=null){
        if (ipage != null) {
            List<EventVO> eventVOList = ipage.getRecords();
            eventVOList.forEach(eventVO -> {
                List<EventResourceDO> eventResourceDOList =
@@ -1200,7 +1213,7 @@
                List<EventResourceVO> audioList = new ArrayList<>();
                List<EventResourceVO> videoList = new ArrayList<>();
                eventResourceDOList.forEach(eventResourceDO -> {
                    switch (eventResourceDO.getType()){
                    switch (eventResourceDO.getType()) {
                        case 1:
                            EventResourceVO picEventResourceVO = new EventResourceVO();
                            BeanUtils.copyProperties(eventResourceDO, picEventResourceVO);
@@ -1224,7 +1237,7 @@

                //查询网格员头像
                String imageUrl = eventMapper.getGridMemberImageUrl(eventVO.getGridMemberId());
                if(StringUtils.isNotEmpty(imageUrl)){
                if (StringUtils.isNotEmpty(imageUrl)) {
                    eventVO.setGridMemberImageUrl(imageUrl);
                }
            });
@@ -1236,24 +1249,24 @@
    @Override
    public R markEventInvalid(EventRevokeDTO eventRevokeDTO) {
        EventDO eventDO = this.getBaseMapper().selectById(eventRevokeDTO.getId());
        if(eventDO==null){
        if (eventDO == null) {
            return R.fail("事件不存在");
        }
        if(eventDO.getEventCategory()!=null) {
        if (eventDO.getEventCategory() != null) {
            if (eventDO.getEventCategory() == 1) {
                boolean canRevoke = eventDO.getEventDealStatus() == 3; //上报状态
                if (!canRevoke) {
                    return R.fail("当前事件不是上报状态，不允许标为无效");
                }
            }else if (eventDO.getEventCategory() == 2) {
            } else if (eventDO.getEventCategory() == 2) {
                boolean canRevoke = eventDO.getEventDealStatus() == 8; //发布状态
                if (!canRevoke) {
                    return R.fail("当前事件不是发布状态，不允许标为无效");
                }
            }else{
            } else {
                return R.fail("");
            }
        }else{
        } else {
            return R.fail("事件所属错误");
        }
        eventDO.setInvalid(false);
@@ -1263,8 +1276,8 @@
        eventDO.setProcessType(1);//网格员处理
        eventDO.setCommunityProcess(0);//非 社区处理
        int updated = this.getBaseMapper().updateById(eventDO);
        if(updated == 1){
            addTransferRecord(eventDO.getId(), eventRevokeDTO.getUserId(), eventRevokeDTO.getUserName(), 1,"标为无效", eventRevokeDTO.getCommunityId(), eventRevokeDTO.getCommunityName(), 4);
        if (updated == 1) {
            addTransferRecord(eventDO.getId(), eventRevokeDTO.getUserId(), eventRevokeDTO.getUserName(), 1, "标为无效", eventRevokeDTO.getCommunityId(), eventRevokeDTO.getCommunityName(), 4);
            return R.ok();
        }
        return R.fail();
@@ -1273,18 +1286,18 @@
    @Override
    public R republishInvalidEvent(CommonEventRepublishDTO commonEventRepublishDTO) {
        EventDO eventDO = this.getBaseMapper().selectById(commonEventRepublishDTO.getId());
        if(eventDO==null){
        if (eventDO == null) {
            return R.fail("事件不存在");
        }
        boolean canRepulish = eventDO.getEventDealStatus()==7; //已失效状态
        if(!canRepulish){
        boolean canRepulish = eventDO.getEventDealStatus() == 7; //已失效状态
        if (!canRepulish) {
            return R.fail("当前事件不是已失效状态，不能重新发布");
        }
        eventDO.setInvalid(true);
        int updated = this.getBaseMapper().updateById(eventDO);
        if(updated == 1){
            addTransferRecord(eventDO.getId(), commonEventRepublishDTO.getUserId(), commonEventRepublishDTO.getUserName(), 1,"重新发布事件成功",
                    commonEventRepublishDTO.getUserId(), commonEventRepublishDTO.getUserName(), 9 );
        if (updated == 1) {
            addTransferRecord(eventDO.getId(), commonEventRepublishDTO.getUserId(), commonEventRepublishDTO.getUserName(), 1, "重新发布事件成功",
                    commonEventRepublishDTO.getUserId(), commonEventRepublishDTO.getUserName(), 9);
            return R.ok();
        }
        return R.fail();
@@ -1297,7 +1310,7 @@
            return R.fail("事件不存在");
        }
        boolean canDealByCommunity = eventDO.getEventDealStatus() == 3;
        if(!canDealByCommunity){
        if (!canDealByCommunity) {
            return R.fail("事件当前不是上报状态");
        }

@@ -1309,20 +1322,20 @@
        Long reportToInDB = -1L;
        for (int i = 0; i < list.size(); i++) {
            EventTransferRecordDO eventTransferRecordDO = list.get(i);
            if(eventTransferRecordDO.getProcessType()!=null && eventTransferRecordDO.getProcessType()==2){
            if (eventTransferRecordDO.getProcessType() != null && eventTransferRecordDO.getProcessType() == 2) {
                reportToInDB = eventTransferRecordDO.getToId();
            }
        }
        if(commonEventDealDTO.getCommunityId()==null){
        if (commonEventDealDTO.getCommunityId() == null) {
            return R.fail("当前用户社区获取失败");
        }
        if(reportToInDB.longValue() != commonEventDealDTO.getCommunityId().longValue()){
        if (reportToInDB.longValue() != commonEventDealDTO.getCommunityId().longValue()) {
            return R.fail("用户上报的社区不是当前社区");
        }
        if(commonEventDealDTO.getNeedVerify()){
        if (commonEventDealDTO.getNeedVerify()) {
            eventDO.setEventProcessStatus(3);//待验证状态
            eventDO.setProcessType(1);//交给网格员处理-验证
        }else {
        } else {
            eventDO.setEventProcessStatus(2);//2已解决
        }
        eventDO.setUpdateBy(commonEventDealDTO.getUserId());
@@ -1334,15 +1347,15 @@
        eventDO.setProcessDesc(commonEventDealDTO.getProcessResult());

        int updated = this.getBaseMapper().updateById(eventDO);
        if(updated!=1){
        if (updated != 1) {
            return R.fail("更新事件状态失败");
        }
        EventTransferRecordDO transferRecordDO =
                addTransferRecord(eventDO.getId(), commonEventDealDTO.getUserId(), commonEventDealDTO.getUserName(),1,
                addTransferRecord(eventDO.getId(), commonEventDealDTO.getUserId(), commonEventDealDTO.getUserName(), 1,
                        "社区处理完成", commonEventDealDTO.getCommunityId(), commonEventDealDTO.getCommunityName(), 3);
        if(transferRecordDO!=null && transferRecordDO.getId()!=null){
        if (transferRecordDO != null && transferRecordDO.getId() != null) {
            //添加音频
            if(StringUtils.isNotEmpty(commonEventDealDTO.getAudio())){
            if (StringUtils.isNotEmpty(commonEventDealDTO.getAudio())) {
                EventResourceDO eventResourceDO = new EventResourceDO();
                eventResourceDO.setClassification(3);
                eventResourceDO.setType(2);
@@ -1351,12 +1364,12 @@
                eventResourceDO.setCreateBy(commonEventDealDTO.getUserId());
                eventResourceDO.setResourceTime(commonEventDealDTO.getAudioTime());
                int audioAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                if(audioAdd!=1){
                if (audioAdd != 1) {
                    throw new ServiceException("添加音频失败");
                }
            }
            //添加视频
            if(StringUtils.isNotEmpty(commonEventDealDTO.getVideo())){
            if (StringUtils.isNotEmpty(commonEventDealDTO.getVideo())) {
                EventResourceDO eventResourceDO = new EventResourceDO();
                eventResourceDO.setClassification(3);
                eventResourceDO.setType(3);
@@ -1365,12 +1378,12 @@
                eventResourceDO.setCreateBy(commonEventDealDTO.getUserId());
                eventResourceDO.setResourceTime(commonEventDealDTO.getVideoTime());
                int videoAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                if(videoAdd!=1){
                if (videoAdd != 1) {
                    throw new ServiceException("添加视频失败");
                }
            }
            //添加图片
            if(StringUtils.isNotEmpty(commonEventDealDTO.getPics())){
            if (StringUtils.isNotEmpty(commonEventDealDTO.getPics())) {
                String[] pica = commonEventDealDTO.getPics().split(",");
                for (int i = 0; i < pica.length; i++) {
                    EventResourceDO eventResourceDO = new EventResourceDO();
@@ -1380,7 +1393,7 @@
                    eventResourceDO.setRefId(transferRecordDO.getId());
                    eventResourceDO.setCreateBy(commonEventDealDTO.getUserId());
                    int picAdd = eventResourceService.getBaseMapper().insert(eventResourceDO);
                    if(picAdd!=1){
                    if (picAdd != 1) {
                        throw new ServiceException("添加图片失败");
                    }
                }
@@ -1389,26 +1402,26 @@
            EventDO eventDOToUpdate = this.getBaseMapper().selectById(commonEventDealDTO.getId());
            eventDOToUpdate.setProcessRecordId(transferRecordId);
            int transferRecordUpdated = this.getBaseMapper().updateById(eventDOToUpdate);
            if(transferRecordUpdated!=1){
            if (transferRecordUpdated != 1) {
                throw new ServiceException("更新事件处理流程失败");
            }
            return R.ok();
        }else{
        } else {
            throw new ServiceException("处理事件记录出错");
        }
    }

    @Override
    public R selectCommunityPublicity(PagePublicityEventCommunityDTO pagePublicityEventDTO) {
        Page page = new Page(1,10);
        if(pagePublicityEventDTO.getPageNum()!=null) {
        Page page = new Page(1, 10);
        if (pagePublicityEventDTO.getPageNum() != null) {
            page.setCurrent(pagePublicityEventDTO.getPageNum());
        }
        if(pagePublicityEventDTO.getPageSize()!=null) {
        if (pagePublicityEventDTO.getPageSize() != null) {
            page.setSize(pagePublicityEventDTO.getPageSize());
        }
        IPage<EventVO> ipage = eventMapper.findCommunityPublicityByPage(page, pagePublicityEventDTO);
        if(ipage!=null){
        if (ipage != null) {
            List<EventVO> eventVOList = ipage.getRecords();
            eventVOList.forEach(eventVO -> {
                List<EventResourceDO> eventResourceDOList =
@@ -1420,7 +1433,7 @@
                List<EventResourceVO> audioList = new ArrayList<>();
                List<EventResourceVO> videoList = new ArrayList<>();
                eventResourceDOList.forEach(eventResourceDO -> {
                    switch (eventResourceDO.getType()){
                    switch (eventResourceDO.getType()) {
                        case 1:
                            EventResourceVO picEventResourceVO = new EventResourceVO();
                            BeanUtils.copyProperties(eventResourceDO, picEventResourceVO);
@@ -1449,12 +1462,13 @@

    /**
     * 添加发布事件流转记录
     * @param eventId 事件ID
     * @param userId 操作用户ID
     *
     * @param eventId  事件ID
     * @param userId   操作用户ID
     * @param userName 操作用户姓名
     * @return 添加成功返回true， 否则返回false
     */
    private EventTransferRecordDO addReleaseRecord(Long eventId, Long userId, String userName){
    private EventTransferRecordDO addReleaseRecord(Long eventId, Long userId, String userName) {
        EventTransferRecordDO eventTransferRecordDO = new EventTransferRecordDO();
        eventTransferRecordDO.setFromType(1);
        eventTransferRecordDO.setFromId(userId);
@@ -1467,7 +1481,7 @@
        eventTransferRecordDO.setProcessResult("发布成功");
        eventTransferRecordDO.setProcessType(0);//初始状态
        int inserted = eventTransferRecordService.getBaseMapper().insert(eventTransferRecordDO);
        if(inserted!=1){
        if (inserted != 1) {
            throw new ServiceException("事件流转记录添加失败");
        }
        this.updateEventDealStatus(eventId);
@@ -1477,19 +1491,20 @@

    /**
     * 查询最后的流转记录，并添加事件流转记录
     *
     * @param eventId 事件ID
     * @param toId 流转到 ID
     * @param toName 流转到 名称
     * @param toType 发送类型
     * @param msg 流转消息
     * @param toId    流转到 ID
     * @param toName  流转到 名称
     * @param toType  发送类型
     * @param msg     流转消息
     * @return
     */
    private EventTransferRecordDO addTransferRecord(Long eventId, Long toId, String toName, Integer toType, String msg, Long processBy, String processByName, Integer processType){
    private EventTransferRecordDO addTransferRecord(Long eventId, Long toId, String toName, Integer toType, String msg, Long processBy, String processByName, Integer processType) {
        List<EventTransferRecordDO> list = eventTransferRecordService.getBaseMapper().selectList(new LambdaQueryWrapper<EventTransferRecordDO>()
                .eq(EventTransferRecordDO::getEventId, eventId)
                .orderByDesc(EventTransferRecordDO::getCreateAt)
        );
        if(list==null ||list.size()==0){
        if (list == null || list.size() == 0) {
            throw new ServiceException("事件流转记录异常");
        }
        EventTransferRecordDO lastRecord = list.get(0);
@@ -1507,10 +1522,10 @@
        eventTransferRecordDO.setProcessByName(processByName);
        eventTransferRecordDO.setProcessType(processType);
        int inserted = eventTransferRecordService.getBaseMapper().insert(eventTransferRecordDO);
        if(inserted==1) {
        if (inserted == 1) {
            this.updateEventDealStatus(eventId);
            return eventTransferRecordDO;
        }else{
        } else {
            throw new ServiceException("事件流转记录添加失败");
        }
    }
@@ -1531,32 +1546,34 @@

    /**
     * 根据子状态 查询用户事件处理状态
     *
     * @param eventId 事件ID
     */
    private EventDO  updateEventDealStatus(Long eventId){
    private EventDO updateEventDealStatus(Long eventId) {
        EventDO eventDO = this.getBaseMapper().selectById(eventId);
        Integer eventDealStatus = getEventDealStatus(eventDO);
        eventDO.setEventDealStatus(eventDealStatus);
        int updated = this.getBaseMapper().updateById(eventDO);
        if(updated == 1){
        if (updated == 1) {
            return eventDO;
        }else{
        } else {
            throw new ServiceException("更新事件处理状态错误");
        }
    }

    /**
     * 根据子状态 查询用户事件处理状态
     *
     * @param eventDO 事件
     */
    private Integer  getEventDealStatus(EventDO eventDO){
    private Integer getEventDealStatus(EventDO eventDO) {
        //1 待处理、2 待验证、3 已上报、4 已解决、5 草稿箱、6已撤销、7已失效、8已发布
        if(eventDO.getEventCategory()!=null) {
        if (eventDO.getEventCategory() != null) {
            if (eventDO.getEventCategory() == 1) {
                Integer event_status = eventDO.getEventStatus()!=null?eventDO.getEventStatus():-1;
                Integer event_process_status = eventDO.getEventProcessStatus()!=null?eventDO.getEventProcessStatus():-1;
                Integer process_type = eventDO.getProcessType()!=null?eventDO.getProcessType():-1;
                Integer community_process = eventDO.getCommunityProcess()!=null?eventDO.getCommunityProcess():-1;
                Integer event_status = eventDO.getEventStatus() != null ? eventDO.getEventStatus() : -1;
                Integer event_process_status = eventDO.getEventProcessStatus() != null ? eventDO.getEventProcessStatus() : -1;
                Integer process_type = eventDO.getProcessType() != null ? eventDO.getProcessType() : -1;
                Integer community_process = eventDO.getCommunityProcess() != null ? eventDO.getCommunityProcess() : -1;

                Integer eventDealStatus = -1;
                if (eventDO.getInvalid() != null && eventDO.getInvalid() == false) {
@@ -1565,23 +1582,23 @@
                } else if (event_status == 1) {
                    eventDealStatus = 5;
                    //"草稿箱"
                } else if ( event_status == 4) {
                } else if (event_status == 4) {
                    eventDealStatus = 6;
                    //"已撤销"
                } else if (event_status ==2){
                } else if (event_status == 2) {
                    if (event_process_status == 3) {
                        eventDealStatus = 2;
                        //"待验证"
                    }else if (event_process_status == 2) {
                    } else if (event_process_status == 2) {
                        eventDealStatus = 4;
                        //"已解决"
                    }else if ( community_process == 1 &&  process_type == 2) {
                    } else if (community_process == 1 && process_type == 2) {
                        eventDealStatus = 3;
                        //"已上报"
                    }else if ( event_process_status == 1 && process_type == 1) {
                    } else if (event_process_status == 1 && process_type == 1) {
                        eventDealStatus = 1;
                        //"待处理"
                    } 
                    }
                }
                return eventDealStatus;
            } else if (eventDO.getEventCategory() == 2) {
@@ -1603,21 +1620,173 @@

    /**
     * 后台管理-统计模块
     * @param communityId   社区id
     * @return  统计信息
     *
     * @param communityId 社区id
     * @return 统计信息
     */
    @Override
    public R eventStatistics(Long communityId){
    public R eventStatistics(Long communityId) {
        return R.ok(this.baseMapper.eventStatistics(communityId));
    }

    /**
     * 后台管理-网格员统计
     * @param statisticsAdminDTO    请求参数
     * @return  网格员统计信息
     *
     * @param statisticsAdminDTO 请求参数
     * @return 网格员统计信息
     */
    @Override
    public R gridMemberStatistics(MemberStatisticsAdminDTO statisticsAdminDTO){
        return R.ok(eventGridMemberRelationMapper.gridMemberStatistics(new Page(statisticsAdminDTO.getPageNum(),statisticsAdminDTO.getPageSize()),statisticsAdminDTO));
    public R gridMemberStatistics(MemberStatisticsAdminDTO statisticsAdminDTO) {
        return R.ok(eventGridMemberRelationMapper.gridMemberStatistics(new Page(statisticsAdminDTO.getPageNum(), statisticsAdminDTO.getPageSize()), statisticsAdminDTO));
    }

    @Override
    public R getNearByGrid(PageEventGridNearbyDTO pageEventGridNearbyDTO) {
        Page page = new Page(pageEventGridNearbyDTO.getPageNum(), pageEventGridNearbyDTO.getPageSize());
        String latLng = pageEventGridNearbyDTO.getHappentLatLng();
        if(!latLng.matches("^[\\-\\+]?((0|([1-8]\\d?))(\\.\\d{1,10})?|90(\\.0{1,10})?),[\\-\\+]?(0(\\.\\d{1,10})?|([1-9](\\d)?)(\\.\\d{1,10})?|1[0-7]\\d{1}(\\.\\d{1,10})?|180\\.0{1,10})$")){
            return R.fail("经纬度参数错误");
        }
        String latLngArr[] = latLng.split(",");
        try {
            Double lat = Double.valueOf(latLngArr[1]);
            Double lng = Double.valueOf(latLngArr[0]);
            List<EventGridDataAreaVO> gridList =
                    eventGridDataMapper.selectGridWithArea(page, pageEventGridNearbyDTO);
            if (gridList != null && gridList.size() > 0) {
                List<EventGridDataVO> rtEventGridList = new ArrayList<>();
                for (EventGridDataAreaVO eventGridDataDO : gridList) {
                    String data = eventGridDataDO.getData();
                    if(data!=null) {
                        List<LatLngVO> latLngList = LngLatUtils.getLatLngFromText(data);
                        boolean inGrid = LngLatUtils.isInPolygon(latLngList, lng, lat);
                        if (inGrid) {
                            EventGridDataVO eventGridDataVO = new EventGridDataVO();
                            BeanUtils.copyProperties(eventGridDataDO, eventGridDataVO);
                            rtEventGridList.add(eventGridDataVO);
                        }
                    }
                }
                return R.ok(rtEventGridList);
            } else {
                return R.ok("未找到社区");
            }
        }catch (Exception e){
            return R.fail(e.getMessage());
        }
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public R deleteEventBatch(EventDeleteDTO eventDeleteDTO) {
        List<Long> eventIds = eventDeleteDTO.getId();
        if (eventIds != null && eventIds.size() > 0) {
            R rt = null;
            Long userId = eventDeleteDTO.getUserId();
            for (Long id : eventIds) {
                EventDO eventDO = eventMapper.selectById(id);
                if (eventDO == null) {
                    throw new ServiceException("id为" + id + "的事件不存在");
                }
                if (eventDO.getEventStatus() != null &&
                        (eventDO.getEventStatus().intValue() == 1 || eventDO.getEventStatus().intValue() == 4)) {//草稿 或者 已撤销 的事件可以删除
                    eventDO.setEventStatus(3);//逻辑删除
                    eventDO.setUpdateBy(userId);
                    int updated = this.getBaseMapper().updateById(eventDO);
                    if (updated != 1) {
                        throw new ServiceException("删除事件失败");
                    }
                }
            }
            return R.ok();
        } else {
            return R.fail("参数错误");
        }

    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public R batchRepublishEvent(CommonEventBatchRepublishDTO commonEventBatchRepublishDTO) {
        List<Long> ids = commonEventBatchRepublishDTO.getId();
        if (ids != null && ids.size() > 0) {
            Long userId = commonEventBatchRepublishDTO.getUserId();
            String userName = commonEventBatchRepublishDTO.getUserName();
            for (Long id : ids) {
                EventDO eventDO = this.getBaseMapper().selectById(id);
                if (eventDO == null) {
                    throw new ServiceException("id为" + id + "的事件不存在");
                }
                boolean canRepublishByUser = eventDO.getEventStatus() != null &&
                        eventDO.getEventStatus() == 4 || eventDO.getEventStatus() == 1;
                if (!canRepublishByUser) {
                    throw new ServiceException("当前不是撤销/草稿状态");
                }
                eventDO.setEventStatus(2);//2 发布
                eventDO.setEventProcessStatus(1); //待解决
                eventDO.setProcessType(1);   //网格员处理
                eventDO.setUpdateBy(userId);
                int updated = this.getBaseMapper().updateById(eventDO);
                if (updated != 1) {
                    throw new ServiceException("更新事件状态失败");
                }
                addTransferRecord(eventDO.getId(), userId, userName, 1,
                        "重新发布已撤销事件", userId, userName, 8);
            }
            return R.ok();
        } else {
            return R.fail("参数错误");
        }
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public R batchMarkEventInvalid(EventBatchRevokeDTO eventBatchRevokeDTO) {
        List<Long> ids = eventBatchRevokeDTO.getId();
        if (ids != null && ids.size() > 0) {
            Long userId = eventBatchRevokeDTO.getUserId();
            String userName = eventBatchRevokeDTO.getUserName();
            Long communityId = eventBatchRevokeDTO.getCommunityId();
            String communityName = eventBatchRevokeDTO.getCommunityName();
            for (Long id : ids) {
                EventDO eventDO = this.getBaseMapper().selectById(id);
                if (eventDO == null) {
                    throw new ServiceException("id为" + id + "的事件不存在");
                }
                if (eventDO.getEventCategory() != null) {
                    if (eventDO.getEventCategory() == 1) {
                        boolean canRevoke = eventDO.getEventDealStatus() == 3; //上报状态
                        if (!canRevoke) {
                            throw new ServiceException("当前事件不是上报状态，不允许标为无效");
                        }
                    } else if (eventDO.getEventCategory() == 2) {
                        boolean canRevoke = eventDO.getEventDealStatus() == 8; //发布状态
                        if (!canRevoke) {
                            throw new ServiceException("当前事件不是发布状态，不允许标为无效");
                        }
                    } else {
                        throw new ServiceException("事件分类错误");
                    }
                } else {
                    throw new ServiceException("事件所属错误");
                }
                eventDO.setInvalid(false);
                //标为无效后， 交给网格员处理
                eventDO.setUpdateBy(userId);
                eventDO.setEventStatus(4);//4、撤销
                eventDO.setProcessType(1);//网格员处理
                eventDO.setCommunityProcess(0);//非 社区处理
                int updated = this.getBaseMapper().updateById(eventDO);
                if (updated == 1) {
                    addTransferRecord(eventDO.getId(), userId, userName, 1, "标为无效", communityId, communityName, 4);
                } else {
                    throw new ServiceException("事件流转信息添加错误");
                }
            }
            return R.ok();
        } else {
            return R.fail("参数错误");
        }
    }

    /**

 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/resources/mapper/EventGridDataMapper.xml

@@ -232,6 +232,14 @@
            LEFT JOIN com_act act ON gd.grid_community_id = act.community_id
        WHERE gd.grid_community_id = #{communityId}
    </select>
    <select id="selectGridWithArea" resultType="com.panzhihua.common.model.vos.grid.EventGridDataAreaVO"  parameterType="long">
        SELECT
            gd.id, gd.grid_name , ad.district_name AS zoneName, st.name AS gridStreetName,  act.name AS gridCommunityName, gd.data
        FROM event_grid_data gd LEFT JOIN com_mng_struct_area_district ad ON gd.zone_id = ad.district_adcode
            LEFT JOIN com_street st ON gd.grid_street_id = st.street_id
            LEFT JOIN com_act act ON gd.grid_community_id = act.community_id
        WHERE  gd.type=3
    </select>

    <delete id="removeGridRelationByGridId">
        delete from event_grid_member_relation where grid_id = #{gridId}

 springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/resources/mapper/EventMapper.xml

@@ -236,7 +236,7 @@
        <where>
            e.event_status != 3 AND e.event_category = 2
            <if test="pagePublicityEventDTO.communityId!=null">
                AND egd.grid_community_id = #{pageEventManageDTO.communityId}
                AND egd.grid_community_id = #{pagePublicityEventDTO.communityId}
            </if>
            <if test="pagePublicityEventDTO.eventDealStatus!=null">
                AND e.event_deal_status = #{pagePublicityEventDTO.eventDealStatus}
@@ -500,7 +500,7 @@
                )
            </if>
            <if test="pagePublicityEventCommunityDTO.communityId!=null">
                AND egd.grid_community_id = #{pageEventManageDTO.communityId}
                AND egd.grid_community_id = #{pagePublicityEventCommunityDTO.communityId}
            </if>
            <if test="pagePublicityEventCommunityDTO.eventDealStatus!=null">
                AND e.event_deal_status = #{pagePublicityEventCommunityDTO.eventDealStatus}