Browse Source

党群管理数接口调整+后台管理调整

feature/syp_points
songyunpeng 5 years ago
parent
commit
0449566e3c
  1. 4
      esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/feign/PartyGroupFeignClient.java
  2. 4
      esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/feign/fallback/PartyGroupFeignClientFallback.java
  3. 5
      esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/service/impl/PartyGroupServiceImpl.java
  4. 10
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-client/src/main/java/com/elink/esua/epdc/dto/constant/PartyGroupConstant.java
  5. 27
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-client/src/main/java/com/elink/esua/epdc/dto/form/PartyGroupListFormDTO.java
  6. 12
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/controller/AppPartyGroupController.java
  7. 2
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/dao/PartyGroupDao.java
  8. 3
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/dao/PartyGroupOfficialsDao.java
  9. 4
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/dao/PartyTopicDao.java
  10. 8
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/dao/PartyTopicUserAttitudeDao.java
  11. 5
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/entity/PartyGroupOfficialsEntity.java
  12. 3
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/PartyGroupService.java
  13. 8
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/PartyTopicService.java
  14. 8
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/PartyTopicUserAttitudeService.java
  15. 40
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/impl/PartyGroupOfficialsServiceImpl.java
  16. 13
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/impl/PartyGroupServiceImpl.java
  17. 7
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/impl/PartyTopicCommentServiceImpl.java
  18. 49
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/impl/PartyTopicServiceImpl.java
  19. 5
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/impl/PartyTopicUserAttitudeServiceImpl.java
  20. 2
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/resources/mapper/PartyGroupDao.xml
  21. 2
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/resources/mapper/PartyGroupOfficialsDao.xml
  22. 13
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/resources/mapper/PartyTopicDao.xml
  23. 3
      esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/resources/mapper/PartyTopicUserAttitudeDao.xml

4
esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/feign/PartyGroupFeignClient.java

@ -31,8 +31,8 @@ public interface PartyGroupFeignClient {
* @Param [] * @Param []
* @return com.elink.esua.epdc.commons.tools.utils.Result<java.util.List<com.elink.esua.epdc.dto.result.PartyGroupResultDTO>> * @return com.elink.esua.epdc.commons.tools.utils.Result<java.util.List<com.elink.esua.epdc.dto.result.PartyGroupResultDTO>>
**/ **/
@GetMapping(value = "partyGroup/group/list/{userId}", consumes = MediaType.APPLICATION_JSON_VALUE) @GetMapping(value = "partyGroup/group/list", consumes = MediaType.APPLICATION_JSON_VALUE)
Result<List<PartyGroupResultDTO>> list(@PathVariable("userId") String userId); Result<List<PartyGroupResultDTO>> list(PartyGroupListFormDTO partyGroupListFormDTO);
/** /**
* @Description 网格长列表 * @Description 网格长列表

4
esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/feign/fallback/PartyGroupFeignClientFallback.java

@ -22,8 +22,8 @@ import java.util.List;
public class PartyGroupFeignClientFallback implements PartyGroupFeignClient { public class PartyGroupFeignClientFallback implements PartyGroupFeignClient {
@Override @Override
public Result<List<PartyGroupResultDTO>> list(String userId) { public Result<List<PartyGroupResultDTO>> list(PartyGroupListFormDTO partyGroupListFormDTO) {
return ModuleUtils.feignConError(ServiceConstant.EPDC_PARTY_GROUP_SERVER, "list",userId); return ModuleUtils.feignConError(ServiceConstant.EPDC_PARTY_GROUP_SERVER, "list",partyGroupListFormDTO);
} }
@Override @Override

5
esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/service/impl/PartyGroupServiceImpl.java

@ -34,7 +34,10 @@ public class PartyGroupServiceImpl implements PartyGroupService {
if(userDetail==null){ if(userDetail==null){
return new Result<List<PartyGroupResultDTO>>().error("未登录"); return new Result<List<PartyGroupResultDTO>>().error("未登录");
} }
return partyGroupFeignClient.list(userDetail.getUserId()); PartyGroupListFormDTO partyGroupListFormDTO = new PartyGroupListFormDTO();
partyGroupListFormDTO.setUserId(userDetail.getUserId());
partyGroupListFormDTO.setGridId(String.valueOf(userDetail.getGridId()));
return partyGroupFeignClient.list(partyGroupListFormDTO);
} }
@Override @Override

10
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-client/src/main/java/com/elink/esua/epdc/dto/constant/PartyGroupConstant.java

@ -20,4 +20,14 @@ public interface PartyGroupConstant {
*/ */
String PARTY_GROUP_IDENTITY_FLAG = "0"; String PARTY_GROUP_IDENTITY_FLAG = "0";
/**
* 点赞
*/
String TOPIC_SUPPORT = "0";
/**
* 取消点赞
*/
String TOPIC_CANCEL_SUPPORT = "2";
} }

27
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-client/src/main/java/com/elink/esua/epdc/dto/form/PartyGroupListFormDTO.java

@ -0,0 +1,27 @@
package com.elink.esua.epdc.dto.form;
import lombok.Data;
import java.io.Serializable;
/**
* @Author songyunpeng
* @Date 2020/6/3 16:24
*/
@Data
public class PartyGroupListFormDTO implements Serializable {
private static final long serialVersionUID = -3034807666143092535L;
/**
* 用户ID
*/
private String userId;
/**
* 用户所在网格ID
*/
private String gridId;
}

12
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/controller/AppPartyGroupController.java

@ -2,11 +2,15 @@ package com.elink.esua.epdc.controller;
import com.elink.esua.epdc.commons.tools.utils.Result; import com.elink.esua.epdc.commons.tools.utils.Result;
import com.elink.esua.epdc.dto.form.PartyGroupListFormDTO;
import com.elink.esua.epdc.dto.form.PartyUserJoinGroupFormDTO; import com.elink.esua.epdc.dto.form.PartyUserJoinGroupFormDTO;
import com.elink.esua.epdc.dto.result.PartyGroupResultDTO; import com.elink.esua.epdc.dto.result.PartyGroupResultDTO;
import com.elink.esua.epdc.service.PartyGroupService; import com.elink.esua.epdc.service.PartyGroupService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List; import java.util.List;
@ -29,9 +33,9 @@ public class AppPartyGroupController {
* @Param [] * @Param []
* @return com.elink.esua.epdc.commons.tools.utils.Result<java.util.List<com.elink.esua.epdc.dto.result.PartyGroupResultDTO>> * @return com.elink.esua.epdc.commons.tools.utils.Result<java.util.List<com.elink.esua.epdc.dto.result.PartyGroupResultDTO>>
**/ **/
@GetMapping("list/{userId}") @GetMapping("list")
public Result<List<PartyGroupResultDTO>> list(@PathVariable("userId") String userId){ public Result<List<PartyGroupResultDTO>> list(@RequestBody PartyGroupListFormDTO partyGroupListFormDTO){
List<PartyGroupResultDTO> data = partyGroupService.getAllPartyGroup(userId); List<PartyGroupResultDTO> data = partyGroupService.getAllPartyGroup(partyGroupListFormDTO);
return new Result<List<PartyGroupResultDTO>>().ok(data); return new Result<List<PartyGroupResultDTO>>().ok(data);
} }

2
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/dao/PartyGroupDao.java

@ -65,7 +65,7 @@ public interface PartyGroupDao extends BaseDao<PartyGroupEntity> {
* @Param [] * @Param []
* @return java.util.List<com.elink.esua.epdc.dto.result.PartyGroupResultDTO> * @return java.util.List<com.elink.esua.epdc.dto.result.PartyGroupResultDTO>
**/ **/
List<PartyGroupResultDTO> getAllPartyGroup(String userId); List<PartyGroupResultDTO> getAllPartyGroup(String userId,String streetId);
/** /**
* @Description 根据党群名获取党群 * @Description 根据党群名获取党群
* @Author songyunpeng * @Author songyunpeng

3
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/dao/PartyGroupOfficialsDao.java

@ -18,6 +18,7 @@
package com.elink.esua.epdc.dao; package com.elink.esua.epdc.dao;
import com.elink.esua.epdc.commons.mybatis.dao.BaseDao; import com.elink.esua.epdc.commons.mybatis.dao.BaseDao;
import com.elink.esua.epdc.dto.PartyGroupOfficialsDTO;
import com.elink.esua.epdc.dto.form.PartyGroupOfficialsFormDTO; import com.elink.esua.epdc.dto.form.PartyGroupOfficialsFormDTO;
import com.elink.esua.epdc.dto.result.PartyGroupOfficialsResultDTO; import com.elink.esua.epdc.dto.result.PartyGroupOfficialsResultDTO;
import com.elink.esua.epdc.entity.PartyGroupOfficialsEntity; import com.elink.esua.epdc.entity.PartyGroupOfficialsEntity;
@ -41,7 +42,7 @@ public interface PartyGroupOfficialsDao extends BaseDao<PartyGroupOfficialsEntit
* @Param [params] * @Param [params]
* @return java.util.List<com.elink.esua.epdc.dto.PartyGroupOfficialsDTO> * @return java.util.List<com.elink.esua.epdc.dto.PartyGroupOfficialsDTO>
**/ **/
List<PartyGroupOfficialsEntity> selectListOfPartyGroupOfficialsDTO(Map<String, Object> params); List<PartyGroupOfficialsDTO> selectListOfPartyGroupOfficialsDTO(Map<String, Object> params);
/** /**
* @Description 官小带个长 接口 * @Description 官小带个长 接口
* @Author songyunpeng * @Author songyunpeng

4
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/dao/PartyTopicDao.java

@ -68,7 +68,7 @@ public interface PartyTopicDao extends BaseDao<PartyTopicEntity> {
* @Param [topicId] * @Param [topicId]
* @return void * @return void
**/ **/
void updateCommentNum(String id); void updateCommentNum(String id, Integer num);
/** /**
* @Description 更新点赞数 * @Description 更新点赞数
* @Author songyunpeng * @Author songyunpeng
@ -76,5 +76,5 @@ public interface PartyTopicDao extends BaseDao<PartyTopicEntity> {
* @Param [topicId] * @Param [topicId]
* @return void * @return void
**/ **/
void updateSupportNum(String id); void updateSupportNum(String id,Integer num);
} }

8
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/dao/PartyTopicUserAttitudeDao.java

@ -38,4 +38,12 @@ public interface PartyTopicUserAttitudeDao extends BaseDao<PartyTopicUserAttitud
* @return com.elink.esua.epdc.dto.PartyTopicUserAttitudeDTO * @return com.elink.esua.epdc.dto.PartyTopicUserAttitudeDTO
**/ **/
PartyTopicUserAttitudeDTO getPartyTopicUserAttitudeDTO(String topicId, String userId); PartyTopicUserAttitudeDTO getPartyTopicUserAttitudeDTO(String topicId, String userId);
/**
* @Description 物理删除
* @Author songyunpeng
* @Date 2020/6/5
* @Param [partyTopicUserAttitudeEntity]
* @return void
**/
Boolean realDelete(PartyTopicUserAttitudeEntity partyTopicUserAttitudeEntity);
} }

5
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/entity/PartyGroupOfficialsEntity.java

@ -40,10 +40,7 @@ public class PartyGroupOfficialsEntity extends BaseEpdcEntity {
*/ */
private String partyGroupId; private String partyGroupId;
/**
* 党群名
*/
private String partyGroupName;
/** /**
* 姓名 * 姓名

3
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/PartyGroupService.java

@ -23,6 +23,7 @@ import com.elink.esua.epdc.commons.tools.utils.Result;
import com.elink.esua.epdc.dto.PartyGroupDTO; import com.elink.esua.epdc.dto.PartyGroupDTO;
import com.elink.esua.epdc.dto.PartyGroupListDTO; import com.elink.esua.epdc.dto.PartyGroupListDTO;
import com.elink.esua.epdc.dto.UserDTO; import com.elink.esua.epdc.dto.UserDTO;
import com.elink.esua.epdc.dto.form.PartyGroupListFormDTO;
import com.elink.esua.epdc.dto.form.PartyUserJoinGroupFormDTO; import com.elink.esua.epdc.dto.form.PartyUserJoinGroupFormDTO;
import com.elink.esua.epdc.dto.result.PartyGroupResultDTO; import com.elink.esua.epdc.dto.result.PartyGroupResultDTO;
import com.elink.esua.epdc.entity.PartyGroupEntity; import com.elink.esua.epdc.entity.PartyGroupEntity;
@ -128,7 +129,7 @@ public interface PartyGroupService extends BaseService<PartyGroupEntity> {
* @Param [] * @Param []
* @return java.util.List<com.elink.esua.epdc.dto.result.PartyGroupResultDTO> * @return java.util.List<com.elink.esua.epdc.dto.result.PartyGroupResultDTO>
**/ **/
List<PartyGroupResultDTO> getAllPartyGroup(String userId); List<PartyGroupResultDTO> getAllPartyGroup(PartyGroupListFormDTO partyGroupListFormDTO);
/** /**
* @Description 加入党群 * @Description 加入党群
* @Author songyunpeng * @Author songyunpeng

8
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/PartyTopicService.java

@ -131,21 +131,21 @@ public interface PartyTopicService extends BaseService<PartyTopicEntity> {
**/ **/
Result saveTopic(PartyTopicSubmitFormDTO formDto); Result saveTopic(PartyTopicSubmitFormDTO formDto);
/** /**
* @Description 评论数+1 * @Description 评论数
* @Author songyunpeng * @Author songyunpeng
* @Date 2020/6/3 * @Date 2020/6/3
* @Param [topicId] * @Param [topicId]
* @return void * @return void
**/ **/
void updateCommentNum(String topicId); void updateCommentNum(String topicId,Integer num);
/** /**
* @Description 点赞+1 * @Description 点赞
* @Author songyunpeng * @Author songyunpeng
* @Date 2020/6/3 * @Date 2020/6/3
* @Param [topicId] * @Param [topicId]
* @return void * @return void
**/ **/
void updateSupportNum(String topicId); void updateSupportNum(String topicId,Integer num);
/** /**
* @Description 点赞点踩 * @Description 点赞点踩
* @Author songyunpeng * @Author songyunpeng

8
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/PartyTopicUserAttitudeService.java

@ -100,4 +100,12 @@ public interface PartyTopicUserAttitudeService extends BaseService<PartyTopicUse
* @return com.elink.esua.epdc.dto.PartyTopicUserAttitudeDTO * @return com.elink.esua.epdc.dto.PartyTopicUserAttitudeDTO
**/ **/
PartyTopicUserAttitudeDTO getPartyTopicUserAttitudeDTO(String topicId, String useId); PartyTopicUserAttitudeDTO getPartyTopicUserAttitudeDTO(String topicId, String useId);
/**
* @Description 物理删除
* @Author songyunpeng
* @Date 2020/6/5
* @Param [partyTopicUserAttitudeEntity]
* @return void
**/
Boolean realDelete(PartyTopicUserAttitudeEntity partyTopicUserAttitudeEntity);
} }

40
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/impl/PartyGroupOfficialsServiceImpl.java

@ -42,6 +42,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
@ -89,12 +90,36 @@ public class PartyGroupOfficialsServiceImpl extends BaseServiceImpl<PartyGroupOf
@Override @Override
public PartyGroupOfficialsDTO get(String id) { public PartyGroupOfficialsDTO get(String id) {
PartyGroupOfficialsEntity entity = baseDao.selectById(id); PartyGroupOfficialsEntity entity = baseDao.selectById(id);
return ConvertUtils.sourceToTarget(entity, PartyGroupOfficialsDTO.class); PartyGroupOfficialsDTO partyGroupOfficialsDTO = ConvertUtils.sourceToTarget(entity, PartyGroupOfficialsDTO.class);
//取全部部门ID的后三级
String[] deptIds = entity.getAllDeptIds().split(",");
List<Long> allDeptIdsShow = new ArrayList<>(deptIds.length-1);
for(int i = 1;i<deptIds.length;i++){
allDeptIdsShow.add(Long.parseLong(deptIds[i]));
}
partyGroupOfficialsDTO.setAllDeptIdsShow(allDeptIdsShow);
return partyGroupOfficialsDTO;
} }
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void save(PartyGroupOfficialsDTO dto) { public void save(PartyGroupOfficialsDTO dto) {
//处理部门信息
this.setDeptInfo(dto);
PartyGroupOfficialsEntity entity = ConvertUtils.sourceToTarget(dto, PartyGroupOfficialsEntity.class);
insert(entity);
}
@Override
@Transactional(rollbackFor = Exception.class)
public void update(PartyGroupOfficialsDTO dto) {
//处理部门信息
this.setDeptInfo(dto);
PartyGroupOfficialsEntity entity = ConvertUtils.sourceToTarget(dto, PartyGroupOfficialsEntity.class);
updateById(entity);
}
private void setDeptInfo(PartyGroupOfficialsDTO dto) {
//处理gridID //处理gridID
if (dto.getAllDeptIdsShow().size()!= NumConstant.THREE) { if (dto.getAllDeptIdsShow().size()!= NumConstant.THREE) {
throw new RenException("请选择网格!"); throw new RenException("请选择网格!");
@ -117,15 +142,6 @@ public class PartyGroupOfficialsServiceImpl extends BaseServiceImpl<PartyGroupOf
dto.setParentDeptIds(deptDTO.getParentDeptIds()); dto.setParentDeptIds(deptDTO.getParentDeptIds());
dto.setParentDeptNames(deptDTO.getParentDeptNames()); dto.setParentDeptNames(deptDTO.getParentDeptNames());
} }
PartyGroupOfficialsEntity entity = ConvertUtils.sourceToTarget(dto, PartyGroupOfficialsEntity.class);
insert(entity);
}
@Override
@Transactional(rollbackFor = Exception.class)
public void update(PartyGroupOfficialsDTO dto) {
PartyGroupOfficialsEntity entity = ConvertUtils.sourceToTarget(dto, PartyGroupOfficialsEntity.class);
updateById(entity);
} }
@Override @Override
@ -140,8 +156,8 @@ public class PartyGroupOfficialsServiceImpl extends BaseServiceImpl<PartyGroupOf
//赋值当前用户的所在部门 //赋值当前用户的所在部门
params.put("deptIdList", SecurityUser.getUser().getDeptIdList()); params.put("deptIdList", SecurityUser.getUser().getDeptIdList());
IPage<PartyGroupOfficialsDTO> page = getPage(params); IPage<PartyGroupOfficialsDTO> page = getPage(params);
List<PartyGroupOfficialsEntity> list = baseDao.selectListOfPartyGroupOfficialsDTO(params); List<PartyGroupOfficialsDTO> list = baseDao.selectListOfPartyGroupOfficialsDTO(params);
return new PageData<>(ConvertUtils.sourceToTarget(list,PartyGroupOfficialsDTO.class), page.getTotal()); return new PageData<>(list, page.getTotal());
} }
@Override @Override

13
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/impl/PartyGroupServiceImpl.java

@ -27,6 +27,7 @@ import com.elink.esua.epdc.commons.tools.utils.ConvertUtils;
import com.elink.esua.epdc.commons.tools.utils.Result; import com.elink.esua.epdc.commons.tools.utils.Result;
import com.elink.esua.epdc.dao.PartyGroupDao; import com.elink.esua.epdc.dao.PartyGroupDao;
import com.elink.esua.epdc.dto.*; import com.elink.esua.epdc.dto.*;
import com.elink.esua.epdc.dto.form.PartyGroupListFormDTO;
import com.elink.esua.epdc.dto.form.PartyUserJoinGroupFormDTO; import com.elink.esua.epdc.dto.form.PartyUserJoinGroupFormDTO;
import com.elink.esua.epdc.dto.result.PartyGroupResultDTO; import com.elink.esua.epdc.dto.result.PartyGroupResultDTO;
import com.elink.esua.epdc.entity.PartyGroupEntity; import com.elink.esua.epdc.entity.PartyGroupEntity;
@ -256,8 +257,16 @@ public class PartyGroupServiceImpl extends BaseServiceImpl<PartyGroupDao, PartyG
} }
@Override @Override
public List<PartyGroupResultDTO> getAllPartyGroup(String userId) { public List<PartyGroupResultDTO> getAllPartyGroup(PartyGroupListFormDTO partyGroupListFormDTO) {
return baseDao.getAllPartyGroup(userId); //根据网格ID获取街道ID
Result<ParentAndAllDeptDTO> parentResult = adminFeignClient.getParentAndAllDept(partyGroupListFormDTO.getGridId());
if (!parentResult.success() || parentResult.getData() == null) {
throw new RenException("获取用户部门信息失败");
}
ParentAndAllDeptDTO parentAndAllDeptDTO = parentResult.getData();
String allDeptIds = parentAndAllDeptDTO.getAllDeptIds();
String[] allDeptIdList = allDeptIds.split(",");
return baseDao.getAllPartyGroup(partyGroupListFormDTO.getUserId(),allDeptIdList[1]);
} }
@Override @Override

7
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/impl/PartyTopicCommentServiceImpl.java

@ -111,6 +111,11 @@ public class PartyTopicCommentServiceImpl extends BaseServiceImpl<PartyTopicComm
@Override @Override
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
public void delete(String[] ids) { public void delete(String[] ids) {
//更新话题评论数
PartyTopicCommentDTO partyTopicCommentDTO = get(ids[0]);
for(String id : ids){
partyTopicService.updateCommentNum(partyTopicCommentDTO.getTopicId(),-1);
}
// 逻辑删除(@TableLogic 注解) // 逻辑删除(@TableLogic 注解)
baseDao.deleteBatchIds(Arrays.asList(ids)); baseDao.deleteBatchIds(Arrays.asList(ids));
} }
@ -158,7 +163,7 @@ public class PartyTopicCommentServiceImpl extends BaseServiceImpl<PartyTopicComm
baseDao.updateReplyCount(formDto.getFaCommentId()); baseDao.updateReplyCount(formDto.getFaCommentId());
} }
// 评论数加1 // 评论数加1
partyTopicService.updateCommentNum(formDto.getTopicId()); partyTopicService.updateCommentNum(formDto.getTopicId(),1);
return new Result(); return new Result();
} }

49
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/impl/PartyTopicServiceImpl.java

@ -22,6 +22,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
import com.elink.esua.epdc.commons.mybatis.service.impl.BaseServiceImpl; import com.elink.esua.epdc.commons.mybatis.service.impl.BaseServiceImpl;
import com.elink.esua.epdc.commons.tools.constant.FieldConstant; import com.elink.esua.epdc.commons.tools.constant.FieldConstant;
import com.elink.esua.epdc.commons.tools.constant.NumConstant; import com.elink.esua.epdc.commons.tools.constant.NumConstant;
import com.elink.esua.epdc.commons.tools.exception.RenException;
import com.elink.esua.epdc.commons.tools.page.PageData; import com.elink.esua.epdc.commons.tools.page.PageData;
import com.elink.esua.epdc.commons.tools.utils.ConvertUtils; import com.elink.esua.epdc.commons.tools.utils.ConvertUtils;
import com.elink.esua.epdc.commons.tools.utils.Result; import com.elink.esua.epdc.commons.tools.utils.Result;
@ -30,6 +31,7 @@ import com.elink.esua.epdc.dto.GroupTopicCloseFormDTO;
import com.elink.esua.epdc.dto.PartyTopicDTO; import com.elink.esua.epdc.dto.PartyTopicDTO;
import com.elink.esua.epdc.dto.PartyTopicUserAttitudeDTO; import com.elink.esua.epdc.dto.PartyTopicUserAttitudeDTO;
import com.elink.esua.epdc.dto.PartyUserGroupDTO; import com.elink.esua.epdc.dto.PartyUserGroupDTO;
import com.elink.esua.epdc.dto.constant.PartyGroupConstant;
import com.elink.esua.epdc.dto.form.PartyTopicFormDTO; import com.elink.esua.epdc.dto.form.PartyTopicFormDTO;
import com.elink.esua.epdc.dto.form.PartyTopicSubmitFormDTO; import com.elink.esua.epdc.dto.form.PartyTopicSubmitFormDTO;
import com.elink.esua.epdc.dto.form.TopicStatementFormDTO; import com.elink.esua.epdc.dto.form.TopicStatementFormDTO;
@ -177,30 +179,45 @@ public class PartyTopicServiceImpl extends BaseServiceImpl<PartyTopicDao, PartyT
} }
@Override @Override
public void updateCommentNum(String topicId) { public void updateCommentNum(String topicId,Integer num) {
baseDao.updateCommentNum(topicId); baseDao.updateCommentNum(topicId,num);
} }
@Override @Override
public void updateSupportNum(String topicId) { public void updateSupportNum(String topicId,Integer num) {
baseDao.updateSupportNum(topicId); baseDao.updateSupportNum(topicId,num);
} }
@Override @Override
@Transactional(rollbackFor = Exception.class)
public void statement(TopicStatementFormDTO formDto) { public void statement(TopicStatementFormDTO formDto) {
//防连击! //先根据用户和话题获取点赞点踩表数据
PartyTopicUserAttitudeDTO partyTopicUserAttitudeDTO = partyTopicUserAttitudeService.getPartyTopicUserAttitudeDTO(formDto.getTopicId(),formDto.getUserId()); PartyTopicUserAttitudeDTO partyTopicUserAttitudeDTO = partyTopicUserAttitudeService.getPartyTopicUserAttitudeDTO(formDto.getTopicId(),formDto.getUserId());
if(partyTopicUserAttitudeDTO!=null){ //判断用户操作
return; if(PartyGroupConstant.TOPIC_SUPPORT.equals(formDto.getAttitude())){//点赞
} if(partyTopicUserAttitudeDTO!=null){
//插入点赞点踩表 throw new RenException("不能重复点赞");
PartyTopicUserAttitudeEntity partyTopicUserAttitudeEntity = new PartyTopicUserAttitudeEntity(); }
partyTopicUserAttitudeEntity.setPartyTopicId(formDto.getTopicId()); PartyTopicUserAttitudeEntity partyTopicUserAttitudeEntity = new PartyTopicUserAttitudeEntity();
partyTopicUserAttitudeEntity.setAttitudeFlag(formDto.getAttitude()); //插入点赞点踩表
partyTopicUserAttitudeEntity.setUserId(formDto.getUserId()); partyTopicUserAttitudeEntity.setPartyTopicId(formDto.getTopicId());
if(partyTopicUserAttitudeService.insert(partyTopicUserAttitudeEntity)){ partyTopicUserAttitudeEntity.setAttitudeFlag(formDto.getAttitude());
//更新话题点赞数 partyTopicUserAttitudeEntity.setUserId(formDto.getUserId());
updateSupportNum(formDto.getTopicId()); if(partyTopicUserAttitudeService.insert(partyTopicUserAttitudeEntity)){
//更新话题点赞数
updateSupportNum(formDto.getTopicId(),1);
}
}else if(PartyGroupConstant.TOPIC_CANCEL_SUPPORT.equals(formDto.getAttitude())){
if(partyTopicUserAttitudeDTO==null){
throw new RenException("已取消点赞");
}
//删除点赞点踩数据
PartyTopicUserAttitudeEntity partyTopicUserAttitudeEntity = new PartyTopicUserAttitudeEntity();
partyTopicUserAttitudeEntity.setId(partyTopicUserAttitudeDTO.getId());
if(partyTopicUserAttitudeService.realDelete(partyTopicUserAttitudeEntity)){
//更新话题点赞数
updateSupportNum(formDto.getTopicId(),-1);
}
} }
} }

5
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/java/com/elink/esua/epdc/service/impl/PartyTopicUserAttitudeServiceImpl.java

@ -103,4 +103,9 @@ public class PartyTopicUserAttitudeServiceImpl extends BaseServiceImpl<PartyTopi
return baseDao.getPartyTopicUserAttitudeDTO(topicId,userId); return baseDao.getPartyTopicUserAttitudeDTO(topicId,userId);
} }
@Override
public Boolean realDelete(PartyTopicUserAttitudeEntity partyTopicUserAttitudeEntity) {
return baseDao.realDelete(partyTopicUserAttitudeEntity);
}
} }

2
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/resources/mapper/PartyGroupDao.xml

@ -100,7 +100,7 @@
if(t1.ID is not null ,1,0) as isJoin if(t1.ID is not null ,1,0) as isJoin
from epdc_party_group t from epdc_party_group t
left join epdc_party_user_group t1 on t1.PARTY_GROUP_ID = t.ID and t1.DEL_FLAG ='0' and t1.USER_ID=#{userId} left join epdc_party_user_group t1 on t1.PARTY_GROUP_ID = t.ID and t1.DEL_FLAG ='0' and t1.USER_ID=#{userId}
where t.DEL_FLAG ='0' and t.STATE ='0' order by t.CREATED_TIME desc where t.DEL_FLAG ='0' and t.STATE ='0' and t.DEPT_ID = #{streetId} order by t.CREATED_TIME desc
</select> </select>
<select id="getPartyGroupDTOByName" resultType="com.elink.esua.epdc.dto.PartyGroupDTO"> <select id="getPartyGroupDTOByName" resultType="com.elink.esua.epdc.dto.PartyGroupDTO">
select ID from epdc_party_group where PARTY_GROUP_NAME = #{partyGroupName} and DEL_FLAG='0' limit 1; select ID from epdc_party_group where PARTY_GROUP_NAME = #{partyGroupName} and DEL_FLAG='0' limit 1;

2
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/resources/mapper/PartyGroupOfficialsDao.xml

@ -28,7 +28,7 @@
</resultMap> </resultMap>
<select id="selectListOfPartyGroupOfficialsDTO" resultMap="partyGroupOfficialsMap"> <select id="selectListOfPartyGroupOfficialsDTO" resultType="com.elink.esua.epdc.dto.PartyGroupOfficialsDTO">
select select
t.ID, t.ID,
t.PARTY_GROUP_ID, t.PARTY_GROUP_ID,

13
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/resources/mapper/PartyTopicDao.xml

@ -67,8 +67,8 @@
t.UPDATED_TIME t.UPDATED_TIME
from epdc_party_topic t from epdc_party_topic t
where t.DEL_FLAG ='0' where t.DEL_FLAG ='0'
<if test="partyGroupId!=null and partyGroupId!=''"> <if test="groupId!=null and groupId!=''">
and t.PARTY_GROUP_ID = #{partyGroupId} and t.PARTY_GROUP_ID = #{groupId}
</if> </if>
<if test="topicModule!=null and topicModule!=''"> <if test="topicModule!=null and topicModule!=''">
and t.TOPIC_MODULE = #{topicModule} and t.TOPIC_MODULE = #{topicModule}
@ -187,14 +187,15 @@
<if test="topicType != null and topicType != ''"> <if test="topicType != null and topicType != ''">
and t.TOPIC_MODULE = #{topicType} and t.TOPIC_MODULE = #{topicType}
</if> </if>
order by t.CREATED_TIME desc
LIMIT #{pageIndex},#{pageSize} LIMIT #{pageIndex},#{pageSize}
</select> </select>
<update id="updateCommentNum" parameterType="java.lang.String"> <update id="updateCommentNum">
UPDATE epdc_party_topic SET COMMENT_NUM = COMMENT_NUM + 1 WHERE ID = #{id} UPDATE epdc_party_topic SET COMMENT_NUM = COMMENT_NUM + #{num} WHERE ID = #{id}
</update> </update>
<update id="updateSupportNum" parameterType="java.lang.String"> <update id="updateSupportNum">
UPDATE epdc_party_topic SET SUPPORT_NUM = SUPPORT_NUM + 1 WHERE ID = #{id} UPDATE epdc_party_topic SET SUPPORT_NUM = SUPPORT_NUM + #{num} WHERE ID = #{id}
</update> </update>
</mapper> </mapper>

3
esua-epdc/epdc-module/epdc-party-group/epdc-party-group-server/src/main/resources/mapper/PartyTopicUserAttitudeDao.xml

@ -15,6 +15,9 @@
<result property="updatedBy" column="UPDATED_BY"/> <result property="updatedBy" column="UPDATED_BY"/>
<result property="updatedTime" column="UPDATED_TIME"/> <result property="updatedTime" column="UPDATED_TIME"/>
</resultMap> </resultMap>
<delete id="realDelete">
delete from epdc_party_topic_user_attitude where id = #{id}
</delete>
<select id="getPartyTopicUserAttitudeDTO" resultType="com.elink.esua.epdc.dto.PartyTopicUserAttitudeDTO"> <select id="getPartyTopicUserAttitudeDTO" resultType="com.elink.esua.epdc.dto.PartyTopicUserAttitudeDTO">
select id from epdc_party_topic_user_attitude where PARTY_TOPIC_ID = #{topicId} and USER_ID = #{userId} select id from epdc_party_topic_user_attitude where PARTY_TOPIC_ID = #{topicId} and USER_ID = #{userId}
</select> </select>

Loading…
Cancel
Save