PublicWeChatPushMessageTemplate.java
10.6 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
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
package com.java110.job.task.wechat;
import com.alibaba.fastjson.JSONObject;
import com.java110.core.factory.GenerateCodeFactory;
import com.java110.core.log.LoggerFactory;
import com.java110.dto.community.CommunityDto;
import com.java110.dto.fee.FeeDto;
import com.java110.dto.oweFeeCallable.OweFeeCallableDto;
import com.java110.dto.owner.OwnerAppUserDto;
import com.java110.dto.reportFee.ReportOweFeeDto;
import com.java110.dto.task.TaskDto;
import com.java110.intf.fee.IFeeInnerServiceSMO;
import com.java110.intf.fee.IOweFeeCallableV1InnerServiceSMO;
import com.java110.intf.report.IReportOweFeeInnerServiceSMO;
import com.java110.intf.store.ISmallWeChatInnerServiceSMO;
import com.java110.intf.store.ISmallWechatAttrInnerServiceSMO;
import com.java110.intf.user.IOwnerAppUserInnerServiceSMO;
import com.java110.job.msgNotify.MsgNotifyFactory;
import com.java110.job.quartz.TaskSystemQuartz;
import com.java110.po.oweFeeCallable.OweFeeCallablePo;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.cache.UrlCache;
import com.java110.utils.constant.MappingConstant;
import com.java110.utils.constant.WechatConstant;
import com.java110.utils.util.DateUtil;
import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.slf4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @program: MicroCommunity
* @description: 微信公众号主动推送信息
* @author: zcc
* @create: 2020-06-15 13:35
**/
@Component
public class PublicWeChatPushMessageTemplate extends TaskSystemQuartz {
private static Logger logger = LoggerFactory.getLogger(PublicWeChatPushMessageTemplate.class);
@Autowired
private IFeeInnerServiceSMO feeInnerServiceSMOImpl;
@Autowired
private ISmallWeChatInnerServiceSMO smallWeChatInnerServiceSMOImpl;
@Autowired
private ISmallWechatAttrInnerServiceSMO smallWechatAttrInnerServiceSMOImpl;
@Autowired
private IOwnerAppUserInnerServiceSMO ownerAppUserInnerServiceSMOImpl;
@Autowired
private IReportOweFeeInnerServiceSMO reportOweFeeInnerServiceSMOImpl;
@Autowired
private RestTemplate outRestTemplate;
@Autowired
private IOweFeeCallableV1InnerServiceSMO oweFeeCallableV1InnerServiceSMOImpl;
//模板信息推送地址
private static String sendMsgUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=";
//模板id
private static String DEFAULT_TEMPLATE_ID = "ZF4j_ug2XW-UGwW1F-Gi4M1-51lpiu-PM89Oa6oZv6w";
@Override
protected void process(TaskDto taskDto) {
logger.debug("开始执行微信模板信息推送" + taskDto.toString());
// 获取项目
List<CommunityDto> communityDtos = getAllCommunity();
for (CommunityDto communityDto : communityDtos) {
try {
publishMsg(taskDto, communityDto);
} catch (Exception e) {
logger.error("推送消息失败", e);
}
}
}
private void publishMsg(TaskDto taskDto, CommunityDto communityDto) throws Exception {
ReportOweFeeDto reportOweFeeDto = new ReportOweFeeDto();
reportOweFeeDto.setCommunityId(communityDto.getCommunityId());
reportOweFeeDto.setHasOweFee("Y");
List<ReportOweFeeDto> reportOweFeeDtos = reportOweFeeInnerServiceSMOImpl.queryReportAllOweFees(reportOweFeeDto);
if (reportOweFeeDtos == null || reportOweFeeDtos.size() < 1) {
return;
}
OweFeeCallablePo oweFeeCallablePo = null;
List<OweFeeCallablePo> oweFeeCallablePos = new ArrayList<>();
String notifyWay = MappingCache.getValue(MappingConstant.ENV_DOMAIN, "DEFAULT_MSG_NOTIFY_WAY");
if (StringUtil.isEmpty(notifyWay) || MsgNotifyFactory.NOTIFY_WAY_WECHAT.equals(notifyWay)) {
notifyWay = OweFeeCallableDto.CALLABLE_WAY_WECHAT;
} else {
notifyWay = OweFeeCallableDto.CALLABLE_WAY_SMS;
}
for (ReportOweFeeDto fee : reportOweFeeDtos) {
if(StringUtil.isEmpty(fee.getOwnerId())){
continue;
}
oweFeeCallablePo = new OweFeeCallablePo();
oweFeeCallablePo.setAmountdOwed(fee.getAmountOwed());
oweFeeCallablePo.setCallableWay(notifyWay);
oweFeeCallablePo.setOfcId(GenerateCodeFactory.getGeneratorId("11"));
oweFeeCallablePo.setFeeId(fee.getFeeId());
oweFeeCallablePo.setFeeName(fee.getFeeName());
oweFeeCallablePo.setCommunityId(communityDto.getCommunityId());
oweFeeCallablePo.setConfigId(fee.getConfigId());
oweFeeCallablePo.setOwnerId(fee.getOwnerId());
oweFeeCallablePo.setOwnerName(fee.getOwnerName());
oweFeeCallablePo.setPayerObjId(fee.getPayerObjId());
oweFeeCallablePo.setPayerObjName(fee.getPayerObjName());
oweFeeCallablePo.setPayerObjType(fee.getPayerObjType());
oweFeeCallablePo.setRemark("系统自动催缴");
oweFeeCallablePo.setStaffId("-1");
oweFeeCallablePo.setStaffName("系统自动催缴");
oweFeeCallablePo.setState(OweFeeCallableDto.STATE_WAIT);
oweFeeCallablePo.setStartTime(fee.getEndTime());
oweFeeCallablePo.setEndTime(fee.getDeadlineTime());
oweFeeCallablePos.add(oweFeeCallablePo);
}
if (oweFeeCallablePos.size() < 1) {
return;
}
int flag = oweFeeCallableV1InnerServiceSMOImpl.saveOweFeeCallables(oweFeeCallablePos);
if (flag < 1) {
throw new IllegalArgumentException("保存催缴记录失败");
}
String oweUrl = "";
JSONObject content = null;
String oweRoomUrl = UrlCache.getOwnerUrl() + MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, WechatConstant.OWE_FEE_PAGE);
String oweCarUrl = UrlCache.getOwnerUrl() + MappingCache.getValue(WechatConstant.WECHAT_DOMAIN, WechatConstant.OWE_CAR_FEE_PAGE);
OweFeeCallablePo updateOweFeeCallablePo = null;
OwnerAppUserDto ownerAppUserDto = null;
ResultVo resultVo = null;
String userId = "";
//todo 根据房屋发送欠费信息
Map<String, List<OweFeeCallablePo>> roomOweFeeCallables = computeRoomOweFeeCallable(oweFeeCallablePos);
List<JSONObject> contents = null;
for (String key : roomOweFeeCallables.keySet()) {
userId = "";
contents = new ArrayList<>();
for (OweFeeCallablePo tmpOweFeeCallablePo : roomOweFeeCallables.get(key)) {
if (StringUtil.isEmpty(tmpOweFeeCallablePo.getOwnerId()) || tmpOweFeeCallablePo.getOwnerId().startsWith("-")) {
updateOweFeeCallablePo = new OweFeeCallablePo();
updateOweFeeCallablePo.setOfcId(tmpOweFeeCallablePo.getOfcId());
updateOweFeeCallablePo.setCommunityId(tmpOweFeeCallablePo.getCommunityId());
updateOweFeeCallablePo.setState(OweFeeCallableDto.STATE_FAIL);
updateOweFeeCallablePo.setRemark(tmpOweFeeCallablePo.getRemark() + "-业主不存在");
oweFeeCallableV1InnerServiceSMOImpl.updateOweFeeCallable(updateOweFeeCallablePo);
continue;
}
oweUrl = FeeDto.PAYER_OBJ_TYPE_ROOM.equals(tmpOweFeeCallablePo.getPayerObjType()) ? oweRoomUrl : oweCarUrl;
content = new JSONObject();
content.put("feeTypeName", tmpOweFeeCallablePo.getFeeName());
content.put("payerObjName", tmpOweFeeCallablePo.getPayerObjName());
content.put("billAmountOwed", tmpOweFeeCallablePo.getAmountdOwed());
content.put("date", DateUtil.dateTimeToDate(tmpOweFeeCallablePo.getStartTime()) + "~" + DateUtil.dateTimeToDate(tmpOweFeeCallablePo.getEndTime()));
content.put("url", oweUrl);
ownerAppUserDto = new OwnerAppUserDto();
ownerAppUserDto.setMemberId(tmpOweFeeCallablePo.getOwnerId());
ownerAppUserDto.setCommunityId(tmpOweFeeCallablePo.getCommunityId());
ownerAppUserDto.setAppType(OwnerAppUserDto.APP_TYPE_WECHAT);
List<OwnerAppUserDto> ownerAppUserDtos = ownerAppUserInnerServiceSMOImpl.queryOwnerAppUsers(ownerAppUserDto);
if (ownerAppUserDtos != null && !ownerAppUserDtos.isEmpty()) {
userId = ownerAppUserDtos.get(0).getUserId();
}
contents.add(content);
}
if (contents.isEmpty()) {
continue;
}
//todo 发送推送消息
resultVo = MsgNotifyFactory.sendOweFeeMsg(communityDto.getCommunityId(), userId, roomOweFeeCallables.get(key).get(0).getOwnerId(), contents);
for (OweFeeCallablePo tmpOweFeeCallablePo : roomOweFeeCallables.get(key)) {
if (StringUtil.isEmpty(tmpOweFeeCallablePo.getOwnerId()) || tmpOweFeeCallablePo.getOwnerId().startsWith("-")) {
continue;
}
updateOweFeeCallablePo = new OweFeeCallablePo();
updateOweFeeCallablePo.setOfcId(tmpOweFeeCallablePo.getOfcId());
updateOweFeeCallablePo.setCommunityId(tmpOweFeeCallablePo.getCommunityId());
if (resultVo.getCode() != ResultVo.CODE_OK) {
updateOweFeeCallablePo.setState(OweFeeCallableDto.STATE_FAIL);
updateOweFeeCallablePo.setRemark(tmpOweFeeCallablePo.getRemark() + "-" + resultVo.getMsg());
} else {
updateOweFeeCallablePo.setState(OweFeeCallableDto.STATE_COMPLETE);
}
oweFeeCallableV1InnerServiceSMOImpl.updateOweFeeCallable(updateOweFeeCallablePo);
}
}
}
/**
* 根据房屋
*
* @param oweFeeCallablePos
* @return
*/
private Map<String, List<OweFeeCallablePo>> computeRoomOweFeeCallable(List<OweFeeCallablePo> oweFeeCallablePos) {
Map<String, List<OweFeeCallablePo>> infos = new HashMap<>();
List<OweFeeCallablePo> tmps = null;
for (OweFeeCallablePo oweFeeCallablePo : oweFeeCallablePos) {
if (infos.containsKey(oweFeeCallablePo.getPayerObjId())) {
tmps = infos.get(oweFeeCallablePo.getPayerObjId());
tmps.add(oweFeeCallablePo);
continue;
}
tmps = new ArrayList<>();
tmps.add(oweFeeCallablePo);
infos.put(oweFeeCallablePo.getPayerObjId(), tmps);
}
return infos;
}
}