MachinePropertyRightRegistration.java
7.33 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
package com.java110.job.adapt.propertyRightRegistration;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.factory.WechatFactory;
import com.java110.dto.privilege.BasePrivilegeDto;
import com.java110.dto.community.CommunityDto;
import com.java110.dto.wechat.SmallWeChatDto;
import com.java110.dto.wechat.SmallWechatAttrDto;
import com.java110.dto.user.StaffAppAuthDto;
import com.java110.dto.user.UserDto;
import com.java110.dto.system.Business;
import com.java110.dto.wechat.Content;
import com.java110.dto.wechat.Data;
import com.java110.dto.wechat.PropertyFeeTemplateMessage;
import com.java110.intf.community.ICommunityInnerServiceSMO;
import com.java110.intf.order.IPrivilegeInnerServiceSMO;
import com.java110.intf.store.ISmallWeChatInnerServiceSMO;
import com.java110.intf.store.ISmallWechatAttrInnerServiceSMO;
import com.java110.intf.user.*;
import com.java110.job.adapt.DatabusAdaptImpl;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.constant.MappingConstant;
import com.java110.utils.util.BeanConvertUtil;
import com.java110.utils.util.StringUtil;
import org.slf4j.Logger;
import com.java110.core.log.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
import java.util.List;
/**
* 产权登记适配器
*
* @author fqz
* @date 2021-10-21 14:07
*/
@Component(value = "machinePropertyRightRegistration")
public class MachinePropertyRightRegistration extends DatabusAdaptImpl {
@Autowired
private ICommunityInnerServiceSMO communityInnerServiceSMO;
@Autowired
private ISmallWeChatInnerServiceSMO smallWeChatInnerServiceSMOImpl;
@Autowired
private ISmallWechatAttrInnerServiceSMO smallWechatAttrInnerServiceSMOImpl;
@Autowired
private IPrivilegeInnerServiceSMO privilegeInnerServiceSMO;
@Autowired
private IStaffAppAuthInnerServiceSMO staffAppAuthInnerServiceSMO;
@Autowired
private RestTemplate outRestTemplate;
private static Logger logger = LoggerFactory.getLogger(MachinePropertyRightRegistration.class);
//模板信息推送地址
private static String sendMsgUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=";
@Override
public void execute(Business business, List<Business> businesses) {
JSONObject data = business.getData();
//查询项目信息
CommunityDto communityDto = new CommunityDto();
communityDto.setCommunityId(data.getString("communityId"));
List<CommunityDto> communityDtos = communityInnerServiceSMO.queryCommunitys(communityDto);
JSONObject paramIn = new JSONObject();
paramIn.put("prrId", data.getString("prrId"));
paramIn.put("name", data.getString("name"));
paramIn.put("createTime", data.getString("createTime"));
//给员工推送消息
publishMsg(paramIn, communityDtos.get(0));
}
/**
* 产权登记完成后给员工推送消息
*
* @param paramIn
* @param communityDto
*/
private void publishMsg(JSONObject paramIn, CommunityDto communityDto) {
//查询公众号配置
SmallWeChatDto smallWeChatDto = new SmallWeChatDto();
smallWeChatDto.setWeChatType("1100");
smallWeChatDto.setObjType(SmallWeChatDto.OBJ_TYPE_COMMUNITY);
smallWeChatDto.setObjId(communityDto.getCommunityId());
List<SmallWeChatDto> smallWeChatDtos = smallWeChatInnerServiceSMOImpl.querySmallWeChats(smallWeChatDto);
if (smallWeChatDto == null || smallWeChatDtos.size() <= 0) {
logger.info("未配置微信公众号信息,定时任务执行结束");
return;
}
SmallWeChatDto weChatDto = smallWeChatDtos.get(0);
SmallWechatAttrDto smallWechatAttrDto = new SmallWechatAttrDto();
smallWechatAttrDto.setCommunityId(communityDto.getCommunityId());
smallWechatAttrDto.setWechatId(weChatDto.getWeChatId());
smallWechatAttrDto.setSpecCd(SmallWechatAttrDto.SPEC_CD_WECHAT_PROCESS_TEMPLATE);
List<SmallWechatAttrDto> smallWechatAttrDtos = smallWechatAttrInnerServiceSMOImpl.querySmallWechatAttrs(smallWechatAttrDto);
if (smallWechatAttrDtos == null || smallWechatAttrDtos.size() <= 0) {
logger.info("未配置微信公众号消息模板");
return;
}
String templateId = smallWechatAttrDtos.get(0).getValue();
String accessToken = WechatFactory.getAccessToken(weChatDto.getAppId(), weChatDto.getAppSecret());
if (StringUtil.isEmpty(accessToken)) {
logger.info("推送微信模板,获取accessToken失败:{}", accessToken);
return;
}
// 根据特定权限查询 有该权限的 员工
BasePrivilegeDto basePrivilegeDto = new BasePrivilegeDto();
basePrivilegeDto.setResource("/wechatPropertyRightRegistrationNotice");
List<UserDto> userDtos = privilegeInnerServiceSMO.queryPrivilegeUsers(basePrivilegeDto);
String url = sendMsgUrl + accessToken;
if (userDtos != null && userDtos.size() > 0) {
for (UserDto userDto : userDtos) {
//根据 userId 查询到openId
StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto();
staffAppAuthDto.setStaffId(userDto.getUserId());
staffAppAuthDto.setAppType("WECHAT");
List<StaffAppAuthDto> staffAppAuthDtos = staffAppAuthInnerServiceSMO.queryStaffAppAuths(staffAppAuthDto);
if (staffAppAuthDtos != null && staffAppAuthDtos.size() > 0) {
String openId = staffAppAuthDtos.get(0).getOpenId();
Data data = new Data();
PropertyFeeTemplateMessage templateMessage = new PropertyFeeTemplateMessage();
templateMessage.setTemplate_id(templateId);
templateMessage.setTouser(openId);
data.setFirst(new Content("尊敬的员工，您好！有新的房屋产权登记申请需要您处理，申请信息如下："));
data.setKeyword1(new Content(paramIn.getString("prrId")));
data.setKeyword2(new Content("房屋产权登记申请"));
data.setKeyword3(new Content(paramIn.getString("name")));
data.setKeyword4(new Content(paramIn.getString("name") + "提交的房屋产权登记申请" + "\r\n" + "申请时间：" + paramIn.getString("createTime")));
data.setKeyword5(new Content("待审核"));
data.setRemark(new Content("请及时处理！"));
templateMessage.setData(BeanConvertUtil.beanCovertJson(data));
//获取员工公众号地址
String wechatUrl = MappingCache.getValue(MappingConstant.URL_DOMAIN,"STAFF_WECHAT_URL");
templateMessage.setUrl(wechatUrl);
logger.info("发送模板消息内容:{}", JSON.toJSONString(templateMessage));
ResponseEntity<String> responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class);
logger.info("微信模板返回内容:{}", responseEntity);
} else {
continue;
}
}
}
}
}