|
@@ -103,14 +103,16 @@ public class BaseSaveServiceImpl implements IBaseSaveService {
|
|
buildBillRule(tableName, commitData, columns);
|
|
buildBillRule(tableName, commitData, columns);
|
|
commitData.put(pkName, maxId);
|
|
commitData.put(pkName, maxId);
|
|
rowResults.add(insertRow(tableName, commitData));
|
|
rowResults.add(insertRow(tableName, commitData));
|
|
- if (tableName.equals("urge_read_message")) {
|
|
|
|
|
|
+ if ("urge_read_message".equals(tableName)) {
|
|
receiveUserIds.add(commitData.getLong("receive_user_id"));
|
|
receiveUserIds.add(commitData.getLong("receive_user_id"));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
messageInfo.put("thing1", dataList.get(0).getString("message_title"));
|
|
messageInfo.put("thing1", dataList.get(0).getString("message_title"));
|
|
messageInfo.put("thing2", dataList.get(0).getString("send_user_name"));
|
|
messageInfo.put("thing2", dataList.get(0).getString("send_user_name"));
|
|
|
|
+ messageInfo.put("thing4", dataList.get(0).getString("message_title"));
|
|
|
|
+ messageInfo.put("thing5", dataList.get(0).getString("send_user_name"));
|
|
// 获取发文相关信息
|
|
// 获取发文相关信息
|
|
- if (tableName.equals("urge_read_message")) {
|
|
|
|
|
|
+ if ("urge_read_message".equals(tableName)) {
|
|
WxMsgDto wxMsgDto = new WxMsgDto();
|
|
WxMsgDto wxMsgDto = new WxMsgDto();
|
|
wxMsgDto.setIds(receiveUserIds);
|
|
wxMsgDto.setIds(receiveUserIds);
|
|
wxMsgDto.setParams(messageInfo);
|
|
wxMsgDto.setParams(messageInfo);
|