Browse Source

Merge branch 'dev_mess_party' into dev_temp

# Conflicts:
#	epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/ResiGroupOpenFeignClient.java
#	epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/fallback/ResiGroupOpenFeignClientFallback.java
master
liushaowen 5 years ago
parent
commit
d460f23689
  1. 8
      epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueServiceImpl.java
  2. 23
      epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/form/SendWxmpUpdateSubscribeFormDTO.java
  3. 8
      epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/ResiGroupOpenFeignClient.java
  4. 6
      epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/fallback/ResiGroupOpenFeignClientFallback.java
  5. 7
      epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/controller/ResiTopicController.java

8
epmet-module/gov-issue/gov-issue-server/src/main/java/com/epmet/service/impl/IssueServiceImpl.java

@ -511,7 +511,7 @@ public class IssueServiceImpl extends BaseServiceImpl<IssueDao, IssueEntity> imp
}else throw new RenException(topicInfo.getInternalMsg());
//发送站内信
//发送站内信
// UserMessageFormDTO msgObj = new UserMessageFormDTO();
// msgObj.setApp(ModuleConstants.APP_RESI);
// msgObj.setCustomerId(application.getCustomerId());
@ -524,7 +524,11 @@ public class IssueServiceImpl extends BaseServiceImpl<IssueDao, IssueEntity> imp
// epmetMessageOpenFeignClient.saveUserMessageList(msgList);
//对关注此话题的用户推送订阅
try {
resiGroupOpenFeignClient.sendWxmpUpdateSubscribe(token,app2update.getIssueId(),"shiftIssue");
SendWxmpUpdateSubscribeFormDTO formDTO = new SendWxmpUpdateSubscribeFormDTO();
formDTO.setTokenDto(token);
formDTO.setSourceId(app2update.getIssueId());
formDTO.setSourceType("shiftIssue");
resiGroupOpenFeignClient.sendWxmpUpdateSubscribe(formDTO);
}catch (Exception e){
logger.warn("话题转议题-发送订阅消息失败 错误信息:"+e.getMessage());
}

23
epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/dto/topic/form/SendWxmpUpdateSubscribeFormDTO.java

@ -0,0 +1,23 @@
package com.epmet.resi.group.dto.topic.form;
import com.epmet.commons.tools.security.dto.TokenDto;
import lombok.Data;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
import java.io.Serializable;
/**
* @description:
* @author: liushaowen
* @date: 2021/1/12 13:44
*/
@Data
public class SendWxmpUpdateSubscribeFormDTO implements Serializable {
@NotNull
private TokenDto tokenDto;
@NotBlank
private String sourceId;
@NotBlank
private String sourceType;
}

8
epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/ResiGroupOpenFeignClient.java

@ -2,7 +2,6 @@ package com.epmet.resi.group.feign;
import com.epmet.commons.tools.constant.ServiceConstant;
import com.epmet.commons.tools.security.dto.TokenDto;
import com.epmet.commons.tools.utils.Result;
import com.epmet.resi.group.dto.group.form.*;
import com.epmet.resi.group.dto.group.ResiGroupDTO;
@ -16,6 +15,7 @@ import com.epmet.resi.group.dto.topic.form.*;
import com.epmet.resi.group.dto.topic.result.*;
import com.epmet.resi.group.feign.fallback.ResiGroupOpenFeignClientFallback;
import com.epmet.resi.mine.dto.from.MyPartProjectsFormDTO;
import com.epmet.resi.group.dto.group.form.CreateGroupCodeFormDTO;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.http.MediaType;
import org.springframework.web.bind.annotation.PostMapping;
@ -24,6 +24,7 @@ import org.springframework.web.bind.annotation.RequestParam;
import java.util.HashMap;
import java.util.List;
import org.springframework.http.MediaType;
/**
* 本服务对外开放的API,其他服务通过引用此client调用该服务
@ -189,13 +190,10 @@ public interface ResiGroupOpenFeignClient {
/**
* @Description 发送内容更新类的微信订阅
* @param tokenDto
* @param sourceId
* @param sourceType
* @return void
* @Author liushaowen
* @Date 2021/1/12 11:22
*/
@PostMapping("resi/group/topic/sendwxmpupdatesubscribe")
void sendWxmpUpdateSubscribe(TokenDto tokenDto,String sourceId,String sourceType);
void sendWxmpUpdateSubscribe(@RequestBody SendWxmpUpdateSubscribeFormDTO fromDTO);
}

6
epmet-module/resi-group/resi-group-client/src/main/java/com/epmet/resi/group/feign/fallback/ResiGroupOpenFeignClientFallback.java

@ -132,8 +132,10 @@ public class ResiGroupOpenFeignClientFallback implements ResiGroupOpenFeignClien
return ModuleUtils.feignConError(ServiceConstant.RESI_GROUP_SERVER, "sendEvent",param);
}
@Override
public void sendWxmpUpdateSubscribe(TokenDto tokenDto, String sourceId, String sourceType) {
//不报错
public void sendWxmpUpdateSubscribe(SendWxmpUpdateSubscribeFormDTO fromDTO) {
}
}

7
epmet-module/resi-group/resi-group-server/src/main/java/com/epmet/modules/topic/controller/ResiTopicController.java

@ -359,16 +359,13 @@ public class ResiTopicController {
/**
* @Description 发送内容更新类的微信订阅
* @param tokenDto
* @param sourceId
* @param sourceType
* @return void
* @Author liushaowen
* @Date 2021/1/12 11:21
*/
@PostMapping("sendwxmpupdatesubscribe")
public void sendWxmpUpdateSubscribe(TokenDto tokenDto,String sourceId,String sourceType){
topicService.sendWxmpUpdateSubscribe(tokenDto,sourceId,sourceType);
public void sendWxmpUpdateSubscribe(@RequestBody SendWxmpUpdateSubscribeFormDTO fromDTO){
topicService.sendWxmpUpdateSubscribe(fromDTO.getTokenDto(),fromDTO.getSourceId(),fromDTO.getSourceType());
}

Loading…
Cancel
Save