|
@@ -1,8 +1,6 @@
|
|
package com.persagy.fm.person.jms.handler;
|
|
package com.persagy.fm.person.jms.handler;
|
|
|
|
|
|
import com.google.gson.Gson;
|
|
import com.google.gson.Gson;
|
|
-import com.persagy.common.enums.ResponseCode;
|
|
|
|
-import com.persagy.common.exception.BusinessException;
|
|
|
|
import com.persagy.fm.common.jms.MsgBaseHandler;
|
|
import com.persagy.fm.common.jms.MsgBaseHandler;
|
|
import com.persagy.fm.department.constant.enums.DepTypeEnum;
|
|
import com.persagy.fm.department.constant.enums.DepTypeEnum;
|
|
import com.persagy.fm.department.model.Department;
|
|
import com.persagy.fm.department.model.Department;
|
|
@@ -24,7 +22,6 @@ import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.util.CollectionUtils;
|
|
import org.springframework.util.CollectionUtils;
|
|
|
|
|
|
-import java.io.IOException;
|
|
|
|
import java.util.Date;
|
|
import java.util.Date;
|
|
import java.util.List;
|
|
import java.util.List;
|
|
|
|
|
|
@@ -88,8 +85,6 @@ public class AccountMsgHandler {
|
|
// 更新人员的账号信息
|
|
// 更新人员的账号信息
|
|
if (person != null) {
|
|
if (person != null) {
|
|
person.setUsername(accountUpdateMsg.getUsername());
|
|
person.setUsername(accountUpdateMsg.getUsername());
|
|
- person.setName(accountUpdateMsg.getUsername());
|
|
|
|
- person.setNamePinyin(accountUpdateMsg.getUsername());
|
|
|
|
personService.updatePerson(person);
|
|
personService.updatePerson(person);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -130,10 +125,10 @@ public class AccountMsgHandler {
|
|
try {
|
|
try {
|
|
log.error("处理运维平台账号消息异常", e);
|
|
log.error("处理运维平台账号消息异常", e);
|
|
// 将消费失败的消息移除消息队列,避免重复消费
|
|
// 将消费失败的消息移除消息队列,避免重复消费
|
|
-// channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
|
|
|
|
|
|
+ // channel.basicReject(msg.getMessageProperties().getDeliveryTag(), false);
|
|
} catch (Exception ex) {
|
|
} catch (Exception ex) {
|
|
-// throw new BusinessException(ResponseCode.C0001.getCode(),
|
|
|
|
-// "账号消息从队列中移除失败," + ex.getMessage());
|
|
|
|
|
|
+ // throw new BusinessException(ResponseCode.C0001.getCode(),
|
|
|
|
+ // "账号消息从队列中移除失败," + ex.getMessage());
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|