UserServiceImpl.java 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386
  1. package com.goafanti.user.service.impl;
  2. import com.goafanti.app.bo.UserBasicInfo;
  3. import com.goafanti.common.bo.OutUser;
  4. import com.goafanti.common.bo.userDaysBo;
  5. import com.goafanti.common.constant.AFTConstants;
  6. import com.goafanti.common.dao.*;
  7. import com.goafanti.common.enums.UserType;
  8. import com.goafanti.common.model.OrganizationIdentity;
  9. import com.goafanti.common.model.User;
  10. import com.goafanti.common.model.UserIdentity;
  11. import com.goafanti.common.utils.DateUtils;
  12. import com.goafanti.core.mybatis.BaseMybatisDao;
  13. import com.goafanti.core.mybatis.page.Pagination;
  14. import com.goafanti.core.shiro.token.TokenManager;
  15. import com.goafanti.customer.bo.LockingReleaseBo;
  16. import com.goafanti.user.bo.*;
  17. import com.goafanti.user.service.UserService;
  18. import org.apache.commons.lang3.StringUtils;
  19. import org.springframework.beans.factory.annotation.Autowired;
  20. import org.springframework.cache.annotation.Cacheable;
  21. import org.springframework.stereotype.Service;
  22. import org.springframework.transaction.annotation.Transactional;
  23. import java.text.ParseException;
  24. import java.util.HashMap;
  25. import java.util.List;
  26. import java.util.Map;
  27. import java.util.UUID;
  28. @Service
  29. public class UserServiceImpl extends BaseMybatisDao<UserMapper> implements UserService {
  30. @Autowired
  31. private UserMapper userMapper;
  32. @Autowired
  33. private OrganizationIdentityMapper organizationIdentityMapper;
  34. @Autowired
  35. private UserIdentityMapper userIdentityMapper;
  36. @Autowired
  37. private PatentInfoMapper patentInfoMapper;
  38. @Autowired
  39. private CopyrightInfoMapper copyrightInfoMapper;
  40. @Autowired
  41. private TechProjectMapper techProjectMapper;
  42. @Autowired
  43. private OrgIntellectualPropertyMapper orgIntellectualPropertyMapper;
  44. @Override
  45. @Transactional
  46. public User insertRegister(User user, String unitName, String userName) {
  47. userMapper.insert(user);
  48. if (null != user.getType() && UserType.ORGANIZATION.getCode().equals(user.getType())) {
  49. OrganizationIdentity organizationIdentity = new OrganizationIdentity();
  50. organizationIdentity.setUid(user.getId());
  51. organizationIdentity.setUnitName(StringUtils.isBlank(unitName) ? "" : unitName);
  52. organizationIdentity.setId(UUID.randomUUID().toString());
  53. organizationIdentity.setIdentityType(0);
  54. organizationIdentity.setAuditStatus(0);
  55. organizationIdentity.setProcess(0);
  56. organizationIdentity.setWrongCount(0);
  57. organizationIdentity.setListed(0);
  58. organizationIdentity.setListedType(0);
  59. organizationIdentityMapper.insert(organizationIdentity);
  60. }
  61. if (null != user.getType() && UserType.PERSONAL.getCode().equals(user.getType())) {
  62. UserIdentity ui = new UserIdentity();
  63. ui.setId(UUID.randomUUID().toString());
  64. ui.setUid(user.getId());
  65. ui.setAuditStatus(0);
  66. ui.setProcess(0);
  67. ui.setWrongCount(0);
  68. ui.setUsername(StringUtils.isBlank(userName) ? "" : userName);
  69. userIdentityMapper.insert(ui);
  70. }
  71. return user;
  72. }
  73. @Override
  74. public User selectByMobieAndType(String mobile, Integer type) {
  75. return userMapper.selectByMobieAndType(mobile, type);
  76. }
  77. @Override
  78. public User selectByPrimaryKey(String id) {
  79. return userMapper.selectByPrimaryKey(id);
  80. }
  81. @Override
  82. public int updateByPrimaryKeySelective(User u) {
  83. return userMapper.updateByPrimaryKeySelective(u);
  84. }
  85. @Override
  86. public User insert(User user) {
  87. userMapper.insert(user);
  88. return user;
  89. }
  90. @Override
  91. public UserPageHomeBo selectUserPageHomeBoByUserId(String uid) {
  92. UserPageHomeBo bo = userMapper.selectUserPageHomeBoByUserId(uid);
  93. bo.setPatentNum(patentInfoMapper.findPatentInfoNumByUid(uid));
  94. bo.setCopyrightNum(copyrightInfoMapper.findCopyrightInfoNumByUid(uid));
  95. bo.setTechProjectNum(techProjectMapper.findTechProjectNumByUid(uid));
  96. bo.setIntellectualPropertyNum(orgIntellectualPropertyMapper.findIntellectualPropertyNum(uid));
  97. return bo;
  98. }
  99. @Override
  100. public UserDownLoadBo selectUserDownLoadBoByUserId(String id) {
  101. return userMapper.selectUserDownLoadBoByUserId(id);
  102. }
  103. @Override
  104. public Pagination<OrgListBo> selectUserByAid(Integer number, String mobile, Integer auditStatus, String auditName,
  105. String email, String aid, String startCreateTime, String endCreateTime, Integer type, Integer pageNo,
  106. Integer pageSize) {
  107. Map<String, Object> params = new HashMap<>();
  108. if (StringUtils.isNotBlank(startCreateTime)) {
  109. try {
  110. params.put("startCreateTime", DateUtils.parseDate(startCreateTime, AFTConstants.YYYYMMDD));
  111. } catch (ParseException e) {
  112. throw new RuntimeException(e);
  113. }
  114. }
  115. if (StringUtils.isNotBlank(endCreateTime)) {
  116. try {
  117. params.put("endCreateTime",
  118. DateUtils.addDays(DateUtils.parseDate(endCreateTime, AFTConstants.YYYYMMDD), 1));
  119. } catch (ParseException e) {
  120. throw new RuntimeException(e);
  121. }
  122. }
  123. if (null != number) {
  124. params.put("number", number);
  125. }
  126. if (StringUtils.isNotBlank(mobile)) {
  127. params.put("mobile", mobile);
  128. }
  129. if (null != auditStatus) {
  130. params.put("auditStatus", auditStatus);
  131. }
  132. if (StringUtils.isNotBlank(auditName)) {
  133. params.put("auditName", auditName);
  134. }
  135. if (StringUtils.isNotBlank(email)) {
  136. params.put("email", email);
  137. }
  138. if (!TokenManager.hasRole(AFTConstants.SUPERADMIN)) {
  139. params.put("aid", aid);
  140. }
  141. if (pageNo == null || pageNo < 0) {
  142. pageNo = 1;
  143. }
  144. if (pageSize == null || pageSize < 0 || pageSize > 10) {
  145. pageSize = 10;
  146. }
  147. if (UserType.PERSONAL.getCode().equals(type)) {
  148. return (Pagination<OrgListBo>) findPage("findUserByAidWithParamsListByPage", "findUserByAidWithParamsCount",
  149. params, pageNo, pageSize);
  150. } else if (UserType.ORGANIZATION.getCode().equals(type)) {
  151. return (Pagination<OrgListBo>) findPage("findOrgByAidWithParamsListByPage", "findOrgByAidWithParamsCount",
  152. params, pageNo, pageSize);
  153. }
  154. return null;
  155. }
  156. @Override
  157. public List<OrgUnitNames> selectDemandUnitNames() {
  158. String aid = TokenManager.getAdminId();
  159. if (TokenManager.hasRole(AFTConstants.MANAGERADMIN)) {
  160. return organizationIdentityMapper.selectManagerUnitNames(aid);
  161. } else {
  162. if (TokenManager.hasRole(AFTConstants.SUPERADMIN)) {
  163. aid = null;
  164. }
  165. return organizationIdentityMapper.selectAllOrgIndentity(aid);
  166. }
  167. }
  168. @Override
  169. public List<UserNames> selectDemandUserNames() {
  170. String aid = TokenManager.getAdminId();
  171. if (TokenManager.hasRole(AFTConstants.MANAGERADMIN)) {
  172. return userIdentityMapper.selectManagerUserNames(aid);
  173. } else {
  174. if (TokenManager.hasRole(AFTConstants.SUPERADMIN)) {
  175. aid = null;
  176. }
  177. return userIdentityMapper.selectAllUserNames(aid);
  178. }
  179. }
  180. @Override
  181. public Map<String, String> selectAchievementUserOwner(String name) {
  182. String aid = TokenManager.getAdminId();
  183. if (TokenManager.hasRole(AFTConstants.MANAGERADMIN)) {
  184. return disposeAchievementUserOwner(userIdentityMapper.selectManagerAchievementUserOwner(aid, name));
  185. } else {
  186. if (TokenManager.hasRole(AFTConstants.SUPERADMIN) || TokenManager.hasRole(AFTConstants.TECHBROKER)
  187. || TokenManager.hasRole(AFTConstants.AUDITORADMIN)) {
  188. aid = null;
  189. }
  190. return disposeAchievementUserOwner(userIdentityMapper.selectAchievementUserOwner(aid, name));
  191. }
  192. }
  193. public List<OrgUnitNames> selectAchievementOrgOwner(String name) {
  194. String aid = TokenManager.getAdminId();
  195. if (TokenManager.hasRole(AFTConstants.MANAGERADMIN)) {
  196. return organizationIdentityMapper.selectManagerAchievementOrgOwner(aid, name);
  197. } else {
  198. if (TokenManager.hasRole(AFTConstants.SUPERADMIN) || TokenManager.hasRole(AFTConstants.TECHBROKER)
  199. || TokenManager.hasRole(AFTConstants.AUDITORADMIN)) {
  200. aid = null;
  201. }
  202. return organizationIdentityMapper.selectAchievementOrgOwner(aid, name);
  203. }
  204. }
  205. private Map<String, String> disposeAchievementUserOwner(List<UserNames> list) {
  206. Map<String, String> map = new HashMap<>();
  207. if (null != list && !list.isEmpty()) {
  208. for (UserNames u : list) {
  209. map.put(u.getUid(), u.getUsername() + " " + u.getMobile());
  210. }
  211. }
  212. return map;
  213. }
  214. @Override
  215. public String findUserNameByNameAndMobile(String name, String mobile) {
  216. return userMapper.findUserByNameAndMobile(name, mobile);
  217. }
  218. @Override
  219. public String findOrgNameByNameAndMobile(String name, String mobile) {
  220. return userMapper.findOrgByNameAndMobile(name, mobile);
  221. }
  222. @Override
  223. public UserPartnerDetailBo findUserPartnerDetail(String uid) {
  224. return userMapper.findUserPartnerDetail(uid);
  225. }
  226. @Override
  227. public OrgPartnerDetailBo findOrgPartnerDetail(String uid) {
  228. return userMapper.findOrgPartnerDetail(uid);
  229. }
  230. @Override
  231. public Pagination<StarListBo> listStar(Integer number, String engagedField, String username,
  232. String professionalTitle, String workUnit, Integer pNo, Integer pSize) {
  233. Map<String, Object> params = new HashMap<>();
  234. if (null != number) {
  235. params.put("number", number);
  236. }
  237. if (StringUtils.isNotBlank(engagedField)) {
  238. params.put("engagedField", engagedField);
  239. }
  240. if (StringUtils.isNotBlank(username)) {
  241. params.put("username", username);
  242. }
  243. if (StringUtils.isNotBlank(professionalTitle)) {
  244. params.put("professionalTitle", professionalTitle);
  245. }
  246. if (StringUtils.isNotBlank(workUnit)) {
  247. params.put("workUnit", workUnit);
  248. }
  249. if (pNo == null || pNo < 0) {
  250. pNo = 1;
  251. }
  252. if (pSize == null || pSize < 0 || pSize > 10) {
  253. pSize = 10;
  254. }
  255. return (Pagination<StarListBo>) findPage("findStarListByPage", "findStarCount", params, pNo, pSize);
  256. }
  257. @Override
  258. public Pagination<StarAndExpertListBo> listStarAndExpert(Integer number, String engagedField, String username,
  259. String professionalTitle, String workUnit, Integer pNo, Integer pSize) {
  260. Map<String, Object> params = new HashMap<>();
  261. if (null != number) {
  262. params.put("number", number);
  263. }
  264. if (StringUtils.isNotBlank(engagedField)) {
  265. params.put("engagedField", engagedField);
  266. }
  267. if (StringUtils.isNotBlank(username)) {
  268. params.put("username", username);
  269. }
  270. if (StringUtils.isNotBlank(professionalTitle)) {
  271. params.put("professionalTitle", professionalTitle);
  272. }
  273. if (StringUtils.isNotBlank(workUnit)) {
  274. params.put("workUnit", workUnit);
  275. }
  276. if (pNo == null || pNo < 0) {
  277. pNo = 1;
  278. }
  279. if (pSize == null || pSize < 0 || pSize > 10) {
  280. pSize = 10;
  281. }
  282. return (Pagination<StarAndExpertListBo>) findPage("findStarAndExpertListByPage", "findStarAndExpertCount",
  283. params, pNo, pSize);
  284. }
  285. @Override
  286. @Cacheable(value = "UserNumberCache", key = "'UserNumberCache:UID:'+#userId")
  287. public String selectNumberByPrimaryKey(String userId) {
  288. return String.valueOf(userMapper.selectNumberByPrimaryKey(userId));
  289. }
  290. @Override
  291. public List<UserPartnerDetailBo> findUserPartner() {
  292. return userMapper.findUserPartner();
  293. }
  294. @Override
  295. public UserBasicInfo selectBaseInfo() {
  296. if(TokenManager.getToken() instanceof User)return userMapper.selectBaseInfo(TokenManager.getUserId());
  297. return null;
  298. }
  299. @Override
  300. public User selectByNumber(String easemobName) {
  301. return userMapper.selectByNumber(easemobName);
  302. }
  303. @Override
  304. public List<User> selectUserByRoleName(String roleName1,String roleName2){
  305. return userMapper.selectUserByRoleName(roleName1,roleName2);
  306. }
  307. @Override
  308. public void pushReleaseUserChannel(List<userDaysBo> newCList,Integer type) {
  309. userMapper.updateReleaseUserChannel(newCList,type);
  310. }
  311. @Override
  312. public List<OutUser> getuser() {
  313. return userMapper.getAllUser();
  314. }
  315. @Override
  316. public void updateUserShareType(List<LockingReleaseBo> newList) {
  317. userMapper.updateUserShareType(newList);
  318. }
  319. @Override
  320. public List<LockingReleaseBo > selectSignReleaseUser(String id) {
  321. return userMapper.selectSignReleaseUser(id);
  322. }
  323. }