|
@@ -164,17 +164,20 @@ public class TaShareChildRecordServiceImpl extends ServiceImpl<TaShareChildRecor
|
164
|
164
|
taShareChildRecordMapper.insert(taShareChildRecord);
|
165
|
165
|
if (taShareRecord.getJoinPeople().equals(taShareActivity.getGroupBuyPeople())){
|
166
|
166
|
//发送微信模板消息所有人都发送
|
167
|
|
- sendWxMessage(taShareRecord,orgId,taShareActivity);
|
|
167
|
+ try{
|
|
168
|
+ sendWxMessage(taShareRecord,orgId,taShareActivity);
|
|
169
|
+ }catch (Exception e){}
|
168
|
170
|
|
169
|
171
|
//生成团员核销码和改状态拼团成功
|
170
|
172
|
changeChildRecord(taShareChildRecord.getRecordId(),orgId,taShareChildRecord.getGroupActivityId());
|
171
|
173
|
//生成团长核销码和拼团成功
|
172
|
174
|
taShareRecord.setVerificationCode(String.valueOf(taShareRecord.getRecordId()+System.currentTimeMillis()));
|
173
|
175
|
taShareRecord.setVerificationStatus(CommConstant.STATUS_UNACCALIMED);
|
|
176
|
+ taShareRecord.setStatus(CommConstant.STATUS_UNACCALIMED);
|
174
|
177
|
}
|
175
|
178
|
tashareRecordmapper.updateById(taShareRecord);
|
176
|
179
|
Map<String,Object> map = new HashMap<>();
|
177
|
|
- map.put("taShareChildRecord",taShareChildRecord);
|
|
180
|
+ map.put("taShareChildRecord",taShareChildRecordMapper.selectById(taShareChildRecord.getChildRecordId()));
|
178
|
181
|
map.put("taShareRecord",taShareRecord);
|
179
|
182
|
return ResponseBean.success(map);
|
180
|
183
|
}
|
|
@@ -186,11 +189,13 @@ public class TaShareChildRecordServiceImpl extends ServiceImpl<TaShareChildRecor
|
186
|
189
|
* @param taShareActivity
|
187
|
190
|
*/
|
188
|
191
|
private void sendWxMessage(TaShareRecord taShareRecord, Integer orgId, TaShareActivity taShareActivity) {
|
|
192
|
+ String link = "/pages/activity/detail/assemble?id="+taShareRecord.getGroupActivityId()+"&recordId="+taShareRecord.getRecordId();
|
189
|
193
|
//发送给发起者
|
190
|
|
- TaPerson taPerson = taPersonMapper.selectById(taShareRecord.getRecordId());
|
191
|
|
- //--todo
|
192
|
|
- String link = "/pages/activity/detail/assistance?id="+taShareRecord.getGroupActivityId()+"&initiateId="+taShareRecord.getRecordId();
|
193
|
|
- miniAppService.sendHelpMessage(taPerson,link,"助力成功",taShareActivity.getActivityName(),LocalDateTime.now());
|
|
194
|
+ TaPerson taPerson = taPersonMapper.selectById(taShareRecord.getPersonId());
|
|
195
|
+ if (null != taPerson){
|
|
196
|
+ miniAppService.sendHelpMessage(taPerson,link,"助力成功",taShareActivity.getActivityName(),LocalDateTime.now());
|
|
197
|
+ }
|
|
198
|
+
|
194
|
199
|
//批量发送给助力者
|
195
|
200
|
QueryWrapper<TaShareChildRecord> taShareChildRecordQueryWrapper = new QueryWrapper<>();
|
196
|
201
|
taShareChildRecordQueryWrapper.eq("org_id",orgId);
|
|
@@ -199,7 +204,9 @@ public class TaShareChildRecordServiceImpl extends ServiceImpl<TaShareChildRecor
|
199
|
204
|
List<TaShareChildRecord> shareChildRecordList = taShareChildRecordMapper.selectList(taShareChildRecordQueryWrapper);
|
200
|
205
|
shareChildRecordList.forEach(e -> {
|
201
|
206
|
TaPerson toTaPerson = taPersonMapper.selectById(e.getPersonId());
|
202
|
|
- miniAppService.sendHelpMessage(toTaPerson,link,"助力成功",taShareActivity.getActivityName(),LocalDateTime.now());
|
|
207
|
+ if (null != toTaPerson){
|
|
208
|
+ miniAppService.sendHelpMessage(toTaPerson,link,"助力成功",taShareActivity.getActivityName(),LocalDateTime.now());
|
|
209
|
+ }
|
203
|
210
|
});
|
204
|
211
|
}
|
205
|
212
|
|
|
@@ -218,6 +225,7 @@ public class TaShareChildRecordServiceImpl extends ServiceImpl<TaShareChildRecor
|
218
|
225
|
shareChildRecordList.forEach(e -> {
|
219
|
226
|
e.setVerificationCode(String.valueOf(e.getChildRecordId()+System.currentTimeMillis()));
|
220
|
227
|
e.setVerificationStatus(CommConstant.STATUS_UNACCALIMED);
|
|
228
|
+ e.setStatus(CommConstant.STATUS_UNACCALIMED);
|
221
|
229
|
});
|
222
|
230
|
this.updateBatchById(shareChildRecordList);
|
223
|
231
|
}
|