| | |
| | | }
|
| | |
|
| | | @Override
|
| | | public void addUnreadDeviceMsg(String type, String device, int platform, int msgCount) {
|
| | | public void addUnreadDeviceMsg(String type, String device, int platform, int msgCount, String msg,Date msgTime) {
|
| | | MsgDeviceReadState state = msgDeviceReadStateMapper.selectByDeviceAndPlatformAndType(device, platform, type);
|
| | | if (state != null) {
|
| | | MsgDeviceReadState update = new MsgDeviceReadState();
|
| | | update.setId(state.getId());
|
| | | update.setUnReadCount(state.getUnReadCount() + msgCount);
|
| | | update.setUpdateTime(new Date());
|
| | | update.setLatestContent(msg);
|
| | | update.setLatestContentTime(msgTime);
|
| | | msgDeviceReadStateMapper.updateByPrimaryKeySelective(update);
|
| | | } else {//
|
| | | } else {
|
| | | state = new MsgDeviceReadState();
|
| | | state.setCreateTime(new Date());
|
| | | state.setDevice(device);
|
| | |
| | | state.setType(type);
|
| | | state.setUnReadCount(msgCount);
|
| | | state.setUpdateTime(new Date());
|
| | | state.setLatestContent(msg);
|
| | | state.setLatestContentTime(msgTime);
|
| | | msgDeviceReadStateMapper.insertSelective(state);
|
| | | }
|
| | | }
|
| | |
| | | return totalCount;
|
| | | }
|
| | |
|
| | | @Override
|
| | | public int getUnReadCount(String device, int platform, String type) {
|
| | | MsgDeviceReadState state = getByDeviceAndPlatformAndType(type, device, platform);
|
| | | if (state == null)
|
| | | return 0;
|
| | | return state.getUnReadCount() == null ? 0 : state.getUnReadCount();
|
| | | }
|
| | |
|
| | | }
|