UserEndPoint.java 55 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168
  1. package com.yihu.ehr.basic.user.controller;
  2. import com.alibaba.fastjson.JSON;
  3. import com.fasterxml.jackson.databind.node.ObjectNode;
  4. import com.yihu.ehr.basic.dict.service.SystemDictEntryService;
  5. import com.yihu.ehr.basic.getui.ConstantUtil;
  6. import com.yihu.ehr.basic.org.model.OrgMemberRelation;
  7. import com.yihu.ehr.basic.org.service.OrgMemberRelationService;
  8. import com.yihu.ehr.basic.patient.service.DemographicService;
  9. import com.yihu.ehr.basic.security.service.UserSecurityService;
  10. import com.yihu.ehr.basic.user.dao.XUserTypeRolesRepository;
  11. import com.yihu.ehr.basic.user.entity.Roles;
  12. import com.yihu.ehr.basic.user.entity.UserTypeRoles;
  13. import com.yihu.ehr.basic.user.service.RoleUserService;
  14. import com.yihu.ehr.basic.user.service.RolesService;
  15. import com.yihu.ehr.commons.constants.BasicServiceApi;
  16. import com.yihu.ehr.constants.ServiceApi;
  17. import com.yihu.ehr.basic.user.entity.Doctors;
  18. import com.yihu.ehr.basic.user.entity.User;
  19. import com.yihu.ehr.basic.user.service.DoctorService;
  20. import com.yihu.ehr.basic.user.service.UserService;
  21. import com.yihu.ehr.constants.ApiVersion;
  22. import com.yihu.ehr.controller.EnvelopRestEndPoint;
  23. import com.yihu.ehr.entity.dict.SystemDictEntry;
  24. import com.yihu.ehr.entity.patient.DemographicInfo;
  25. import com.yihu.ehr.entity.security.UserKey;
  26. import com.yihu.ehr.entity.security.UserSecurity;
  27. import com.yihu.ehr.fastdfs.FastDFSUtil;
  28. import com.yihu.ehr.model.org.MJkzlOrgMemberRelation;
  29. import com.yihu.ehr.model.user.MH5Handshake;
  30. import com.yihu.ehr.model.user.MUser;
  31. import com.yihu.ehr.util.datetime.DateUtil;
  32. import com.yihu.ehr.util.id.BizObject;
  33. import com.yihu.ehr.util.log.LogService;
  34. import com.yihu.ehr.util.phonics.PinyinUtil;
  35. import com.yihu.ehr.util.rest.Envelop;
  36. import io.swagger.annotations.Api;
  37. import io.swagger.annotations.ApiOperation;
  38. import io.swagger.annotations.ApiParam;
  39. import org.apache.commons.codec.digest.DigestUtils;
  40. import org.apache.commons.lang.time.DateFormatUtils;
  41. import org.csource.common.MyException;
  42. import org.springframework.beans.factory.annotation.Autowired;
  43. import org.springframework.beans.factory.annotation.Value;
  44. import org.springframework.http.MediaType;
  45. import org.springframework.transaction.annotation.Propagation;
  46. import org.springframework.transaction.annotation.Transactional;
  47. import org.springframework.util.StringUtils;
  48. import org.springframework.web.bind.annotation.*;
  49. import javax.servlet.http.HttpServletRequest;
  50. import javax.servlet.http.HttpServletResponse;
  51. import java.io.*;
  52. import java.net.URLDecoder;
  53. import java.net.URLEncoder;
  54. import java.text.ParseException;
  55. import java.util.*;
  56. /**
  57. * @author zlf
  58. * @version 1.0
  59. * @created 2015.08.10 17:57
  60. */
  61. @RestController
  62. @RequestMapping(ApiVersion.Version1_0)
  63. @Api(value = "user", description = "用户管理", tags = {"用户管理"})
  64. public class UserEndPoint extends EnvelopRestEndPoint {
  65. @Value("${default.password}")
  66. private String default_password = "12345678";
  67. @Value("${h5.secret}")
  68. private String secret;
  69. @Value("${h5.appId}")
  70. private String appId;
  71. @Value("${jksr-app.orgcode}")
  72. private String orgcode;
  73. @Value("${jksr-app.registerRoleClientId}")
  74. public String registerRoleClientId;
  75. @Autowired
  76. private UserService userService;
  77. @Autowired
  78. private RoleUserService roleUserService;
  79. @Autowired
  80. private RolesService rolesService;
  81. @Autowired
  82. private UserSecurityService userSecurityService;
  83. @Autowired
  84. private SystemDictEntryService dictEntryService;
  85. @Autowired
  86. private FastDFSUtil fastDFSUtil;
  87. @Autowired
  88. private DoctorService doctorService;
  89. @Autowired
  90. private DemographicService demographicService;
  91. @Autowired
  92. private OrgMemberRelationService orgMemberRelationService;
  93. @Autowired
  94. private OrgMemberRelationService relationService;
  95. @Autowired
  96. private XUserTypeRolesRepository xUserTypeRolesRepository;
  97. @RequestMapping(value = ServiceApi.Users.Users, method = RequestMethod.GET)
  98. @ApiOperation(value = "获取用户列表", notes = "根据查询条件获取用户列表在前端表格展示")
  99. public List<MUser> searchUsers(
  100. @ApiParam(name = "fields", value = "返回的字段,为空返回全部字段", defaultValue = "")
  101. @RequestParam(value = "fields", required = false) String fields,
  102. @ApiParam(name = "filters", value = "过滤器,为空检索所有条件", defaultValue = "")
  103. @RequestParam(value = "filters", required = false) String filters,
  104. @ApiParam(name = "sorts", value = "排序,规则参见说明文档", defaultValue = "")
  105. @RequestParam(value = "sorts", required = false) String sorts,
  106. @ApiParam(name = "size", value = "分页大小", defaultValue = "15")
  107. @RequestParam(value = "size", required = false) int size,
  108. @ApiParam(name = "page", value = "页码", defaultValue = "1")
  109. @RequestParam(value = "page", required = false) int page,
  110. @ApiParam(name = "orgCode", value = "机构编码", defaultValue = "")
  111. @RequestParam(value = "orgCode", required = false) String orgCode,
  112. HttpServletRequest request,
  113. HttpServletResponse response) throws ParseException {
  114. List<User> userList = new ArrayList<>();
  115. if (!StringUtils.isEmpty(orgCode)) {
  116. String[] orgCodes = orgCode.split(",");
  117. String realName = "";
  118. String userType = "";
  119. if (!StringUtils.isEmpty(filters)) {
  120. boolean nameFlag = filters.contains("realName?");
  121. boolean typeFlag = filters.contains("userType=");
  122. if (nameFlag && typeFlag) {
  123. realName = filters.substring(filters.indexOf("?") + 1, filters.indexOf(";"));
  124. userType = filters.substring(filters.lastIndexOf("=") + 1, filters.lastIndexOf(";"));
  125. } else if (nameFlag) {
  126. realName = filters.substring(filters.indexOf("?") + 1, filters.indexOf(";"));
  127. } else if (typeFlag) {
  128. userType = filters.substring(filters.lastIndexOf("=") + 1, filters.lastIndexOf(";"));
  129. }
  130. }
  131. userList = userService.searchUsers(orgCodes, realName, userType, page, size);
  132. Long totalCount = userService.searchUsersCount(orgCodes, realName, userType);
  133. pagedResponse(request, response, totalCount, page, size);
  134. } else {
  135. userList = userService.search(fields, filters, sorts, page, size);
  136. pagedResponse(request, response, userService.getCount(filters), page, size);
  137. }
  138. return (List<MUser>) convertToModels(userList, new ArrayList<MUser>(userList.size()), MUser.class, fields);
  139. }
  140. @RequestMapping(value = ServiceApi.Users.Users, method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)
  141. @ApiOperation(value = "创建用户", notes = "重新绑定用户信息")
  142. public MUser createUser(
  143. @ApiParam(name = "user_json_data", value = "", defaultValue = "")
  144. @RequestBody String userJsonData) throws Exception {
  145. User user = toEntity(userJsonData, User.class);
  146. user.setId(getObjectId(BizObject.User));
  147. user.setCreateDate(new Date());
  148. if (!StringUtils.isEmpty(user.getPassword())) {
  149. user.setPassword(DigestUtils.md5Hex(user.getPassword()));
  150. } else {
  151. user.setPassword(DigestUtils.md5Hex(default_password));
  152. }
  153. String userType = user.getUserType();
  154. SystemDictEntry dict = dictEntryService.getDictEntry(15, userType);
  155. if (dict != null) {
  156. user.setDType(userType);
  157. }
  158. user.setActivated(true);
  159. user = userService.saveUser(user);
  160. return convertToModel(user, MUser.class, null);
  161. }
  162. @RequestMapping(value = ServiceApi.Users.Users, method = RequestMethod.PUT, consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)
  163. @ApiOperation(value = "修改用户", notes = "重新绑定用户信息")
  164. public MUser updateUser(
  165. @ApiParam(name = "user_json_data", value = "", defaultValue = "")
  166. @RequestBody String userJsonData) throws Exception {
  167. User user = toEntity(userJsonData, User.class);
  168. String userType = user.getUserType();
  169. SystemDictEntry dict = dictEntryService.getDictEntry(15, userType);
  170. if (dict != null) {
  171. user.setDType(userType);
  172. }
  173. userService.saveUser(user);
  174. //同时修改医生表及用户表信息
  175. Doctors doctors = doctorService.getByIdCardNo(user.getIdCardNo());
  176. if (!StringUtils.isEmpty(doctors)) {
  177. doctors.setName(user.getRealName());
  178. doctors.setPyCode(PinyinUtil.getPinYinHeadChar(user.getRealName(), false));
  179. doctors.setSex(user.getGender());
  180. doctors.setPhone(user.getTelephone());
  181. doctorService.save(doctors);
  182. }
  183. DemographicInfo demographicInfo = demographicService.getDemographicInfoByIdCardNo(user.getIdCardNo());
  184. if (!StringUtils.isEmpty(demographicInfo)) {
  185. demographicInfo.setName(user.getRealName());
  186. demographicInfo.setTelephoneNo("{\"联系电话\":\"" + user.getTelephone() + "\"}");
  187. demographicInfo.setGender(user.getGender());
  188. demographicInfo.setMartialStatus(user.getMartialStatus());
  189. demographicInfo.setBirthday(DateUtil.strToDate(user.getBirthday()));
  190. demographicService.save(demographicInfo);
  191. }
  192. return convertToModel(user, MUser.class);
  193. }
  194. @RequestMapping(value = ServiceApi.Users.UserAdmin, method = RequestMethod.GET)
  195. @ApiOperation(value = "根据id获取获取用户信息")
  196. public MUser getUser(
  197. @ApiParam(name = "user_id", value = "", defaultValue = "")
  198. @PathVariable(value = "user_id") String userId) {
  199. User user = userService.getUser(userId);
  200. MUser userModel = convertToModel(user, MUser.class);
  201. return userModel;
  202. }
  203. @RequestMapping(value = ServiceApi.Users.UserAdmin, method = RequestMethod.DELETE)
  204. @ApiOperation(value = "删除用户", notes = "根据id删除用户")
  205. public boolean deleteUser(
  206. @ApiParam(name = "user_id", value = "用户编号", defaultValue = "")
  207. @PathVariable(value = "user_id") String userId) throws Exception {
  208. userService.deleteUser(userId);
  209. return true;
  210. }
  211. @RequestMapping(value = ServiceApi.Users.UserAdmin, method = RequestMethod.PUT)
  212. @ApiOperation(value = "改变用户状态", notes = "根据id更新用户")
  213. public boolean activityUser(
  214. @ApiParam(name = "user_id", value = "id", defaultValue = "")
  215. @PathVariable(value = "user_id") String userId,
  216. @ApiParam(name = "activity", value = "激活状态", defaultValue = "")
  217. @RequestParam(value = "activity") boolean activity) throws Exception {
  218. userService.activityUser(userId, activity);
  219. return true;
  220. }
  221. @RequestMapping(value = ServiceApi.Users.User, method = RequestMethod.GET)
  222. @ApiOperation(value = "根据登录账号获取当前用户", notes = "根据登陆用户名及密码验证用户")
  223. public MUser getUserByLoginCode(
  224. @ApiParam(name = "user_name", value = "登录账号", defaultValue = "")
  225. @PathVariable(value = "user_name") String userName) {
  226. // 帐户:手机号,身份证号,登录账号
  227. List<User> users = userService.getUserForLogin(userName);
  228. if (users != null) {
  229. if (users.size() == 1) {
  230. MUser mUser = new MUser();
  231. List<OrgMemberRelation> memberRelations = orgMemberRelationService.findByField("userId", users.get(0).getId());
  232. mUser = convertToModel(users.get(0), MUser.class);
  233. if (memberRelations != null && memberRelations.size() > 0) {
  234. mUser.setPosition(memberRelations.get(0).getDutyName());
  235. mUser.setDepartment(memberRelations.get(0).getDeptName());
  236. }
  237. return mUser;
  238. }
  239. }
  240. return null;
  241. }
  242. @RequestMapping(value = ServiceApi.Users.UserAdminPassword, method = RequestMethod.PUT)
  243. @ApiOperation(value = "重设密码", notes = "用户忘记密码管理员帮助重新还原密码,初始密码12345678")
  244. public boolean resetPass(
  245. @ApiParam(name = "user_id", value = "id", defaultValue = "")
  246. @PathVariable(value = "user_id") String userId) throws Exception {
  247. userService.resetPass(userId);
  248. return true;
  249. }
  250. @RequestMapping(value = ServiceApi.Users.UserAdminPasswordReset, method = RequestMethod.PUT)
  251. @ApiOperation(value = "修改密码", notes = "根基传入的用户id和新的密码修改用户的密码")
  252. public boolean changePassWord(
  253. @ApiParam(name = "user_id", value = "user_id", defaultValue = "")
  254. @PathVariable(value = "user_id") String userId,
  255. @ApiParam(name = "password", value = "密码", defaultValue = "")
  256. @RequestParam(value = "password") String password) throws Exception {
  257. String hashPassWord = DigestUtils.md5Hex(password);
  258. userService.changePassWord(userId, hashPassWord);
  259. return true;
  260. }
  261. @RequestMapping(value = ServiceApi.Users.UserAdminKey, method = RequestMethod.PUT)
  262. @ApiOperation(value = "重新分配密钥", notes = "重新分配密钥")
  263. public Map<String, String> distributeKey(
  264. @ApiParam(name = "user_id", value = "登录帐号", defaultValue = "")
  265. @PathVariable(value = "user_id") String userId) throws Exception {
  266. User user = userService.getUser(userId);
  267. if (null == user) {
  268. return null;
  269. }
  270. UserSecurity userSecurity = userSecurityService.getKeyByUserId(userId, false);
  271. Map<String, String> keyMap = new HashMap<>();
  272. if (userSecurity != null) {
  273. // 删除原有的公私钥重新分配
  274. List<UserKey> userKeyList = userSecurityService.getKeyMapByUserId(userId);
  275. userSecurityService.deleteKey(userKeyList);
  276. }
  277. userSecurity = userSecurityService.createKeyByUserId(userId);
  278. String validTime = DateFormatUtils.format(userSecurity.getFromDate(), "yyyy-MM-dd")
  279. + "~" + DateFormatUtils.format(userSecurity.getExpiryDate(), "yyyy-MM-dd");
  280. keyMap.put("publicKey", userSecurity.getPublicKey());
  281. keyMap.put("validTime", validTime);
  282. keyMap.put("startTime", DateFormatUtils.format(userSecurity.getFromDate(), "yyyy-MM-dd"));
  283. return keyMap;
  284. }
  285. @RequestMapping(value = ServiceApi.Users.UserAdminKey, method = RequestMethod.GET)
  286. @ApiOperation(value = "查询用户公钥", notes = "查询用户公钥")
  287. public Envelop getKey(
  288. @ApiParam(name = "user_id", value = "登录帐号", defaultValue = "")
  289. @PathVariable(value = "user_id") String userId) throws Exception {
  290. Envelop envelop = new Envelop();
  291. User user = userService.getUser(userId);
  292. if (null == user) {
  293. envelop.setSuccessFlg(false);
  294. envelop.setErrorMsg("用户不存在");
  295. return envelop;
  296. }
  297. UserSecurity userSecurity = userSecurityService.getKeyByUserId(userId, false);
  298. if (null == userSecurity) {
  299. envelop.setSuccessFlg(false);
  300. envelop.setErrorMsg("请先获取公钥");
  301. return envelop;
  302. }
  303. Map<String, String> keyMap = new HashMap<>();
  304. String validTime = DateFormatUtils.format(userSecurity.getFromDate(), "yyyy-MM-dd")
  305. + "~" + DateFormatUtils.format(userSecurity.getExpiryDate(), "yyyy-MM-dd");
  306. keyMap.put("publicKey", userSecurity.getPublicKey());
  307. keyMap.put("validTime", validTime);
  308. keyMap.put("startTime", DateFormatUtils.format(userSecurity.getFromDate(), "yyyy-MM-dd"));
  309. envelop.setSuccessFlg(true);
  310. envelop.setObj(keyMap);
  311. return envelop;
  312. }
  313. /**
  314. * 根据登陆用户名及密码验证用户.
  315. *
  316. * @param userName
  317. * @param password
  318. */
  319. @RequestMapping(value = ServiceApi.Users.UserVerification, method = RequestMethod.GET)
  320. @ApiOperation(value = "根据登陆用户名及密码验证用户", notes = "根据登陆用户名及密码验证用户")
  321. public MUser getUserByNameAndPassword(
  322. @ApiParam(name = "user_name", value = "登录账号", defaultValue = "")
  323. @RequestParam(value = "user_name") String userName,
  324. @ApiParam(name = "password", value = "密码", defaultValue = "")
  325. @RequestParam(value = "password") String password) {
  326. User user = userService.loginVerification(userName, password);
  327. return convertToModel(user, MUser.class);
  328. }
  329. @RequestMapping(value = ServiceApi.Users.UserExistence, method = RequestMethod.GET)
  330. @ApiOperation(value = "判断登陆账户(用户名)是否存在")
  331. public boolean isUserNameExists(
  332. @ApiParam(name = "user_name", value = "user_name", defaultValue = "")
  333. @PathVariable(value = "user_name") String userName) {
  334. return userService.getUserByUserName(userName) != null;
  335. }
  336. @RequestMapping(value = ServiceApi.Users.UserIdCardNoExistence, method = RequestMethod.GET)
  337. @ApiOperation(value = "判断用户身份证号是否存在")
  338. public boolean isIdCardExists(
  339. @ApiParam(name = "id_card_no", value = "id_card_no", defaultValue = "")
  340. @RequestParam(value = "id_card_no") String idCardNo) {
  341. return userService.getUserByIdCardNo(idCardNo) != null;
  342. }
  343. // @RequestMapping(value = ServiceApi.Users.UserAdminContact, method = RequestMethod.DELETE)
  344. // @ApiOperation(value = "用户联系方式解绑", notes = "将用户电话或邮件地址设置为空")
  345. // public boolean delteContact(
  346. // @ApiParam(name = "user_id", value = "", defaultValue = "")
  347. // @PathVariable(value = "user_id") String userId,
  348. // @ApiParam(name = "type", value = "", defaultValue = "")
  349. // @RequestParam(value = "type") String type) {
  350. // User user = userManager.getUser(userId);
  351. // if (type.equals("tel")) {
  352. // user.setTelephone("");
  353. // } else {
  354. // user.setEmail("");
  355. // }
  356. //
  357. // userManager.saveUser(user);
  358. // return true;
  359. // }
  360. @RequestMapping(value = ServiceApi.Users.UserEmailNoExistence, method = RequestMethod.GET)
  361. @ApiOperation(value = "判断用户邮件是否存在")
  362. public boolean isEmailExists(@RequestParam(value = "email") String email) {
  363. return userService.getUserByEmail(email) != null;
  364. }
  365. @RequestMapping(value = ServiceApi.Users.UserTelephoneNoExistence, method = RequestMethod.GET)
  366. @ApiOperation(value = "判断用户电话号码是否存在")
  367. public boolean isTelephoneExists(@RequestParam(value = "telephone") String telephone) {
  368. return userService.getUserByTelephone(telephone) != null;
  369. }
  370. /**
  371. * 用户头像图片上传
  372. *
  373. * @return
  374. * @throws IOException
  375. */
  376. @RequestMapping(value = "/user/picture", method = RequestMethod.POST)
  377. @ApiOperation(value = "上传头像,把图片转成流的方式发送")
  378. public String uploadPicture(
  379. @ApiParam(name = "jsonData", value = "头像转化后的输入流")
  380. @RequestBody String jsonData) throws IOException {
  381. if (jsonData == null) {
  382. return null;
  383. }
  384. String date = URLDecoder.decode(jsonData, "UTF-8");
  385. String[] fileStreams = date.split(",");
  386. String is = URLDecoder.decode(fileStreams[0], "UTF-8").replace(" ", "+");
  387. byte[] in = Base64.getDecoder().decode(is);
  388. String pictureName = fileStreams[1].substring(0, fileStreams[1].length() - 1);
  389. String fileExtension = pictureName.substring(pictureName.lastIndexOf(".") + 1).toLowerCase();
  390. String description = null;
  391. if ((pictureName != null) && (pictureName.length() > 0)) {
  392. int dot = pictureName.lastIndexOf('.');
  393. if ((dot > -1) && (dot < (pictureName.length()))) {
  394. description = pictureName.substring(0, dot);
  395. }
  396. }
  397. String path = null;
  398. try {
  399. InputStream inputStream = new ByteArrayInputStream(in);
  400. ObjectNode objectNode = fastDFSUtil.upload(inputStream, fileExtension, description);
  401. String groupName = objectNode.get("groupName").toString();
  402. String remoteFileName = objectNode.get("remoteFileName").toString();
  403. // path = "{\"groupName\":" + groupName + ",\"remoteFileName\":" + remoteFileName + "}";
  404. path = groupName.substring(1, groupName.length() - 1) + ":" + remoteFileName.substring(1, remoteFileName.length() - 1);
  405. } catch (Exception e) {
  406. LogService.getLogger(User.class).error("人口头像图片上传失败;错误代码:" + e);
  407. }
  408. //返回文件路径
  409. return path;
  410. }
  411. /**
  412. * 用户头像图片下载
  413. *
  414. * @return
  415. * @throws IOException
  416. * @throws MyException
  417. */
  418. @RequestMapping(value = "/user/picture", method = RequestMethod.GET)
  419. @ApiOperation(value = "下载头像")
  420. public String downloadPicture(
  421. @ApiParam(name = "group_name", value = "分组", defaultValue = "")
  422. @RequestParam(value = "group_name") String groupName,
  423. @ApiParam(name = "remote_file_name", value = "服务器头像名称", defaultValue = "")
  424. @RequestParam(value = "remote_file_name") String remoteFileName) throws Exception {
  425. String imageStream = null;
  426. try {
  427. byte[] bytes = fastDFSUtil.download(groupName, remoteFileName);
  428. String fileStream = new String(Base64.getEncoder().encode(bytes));
  429. imageStream = URLEncoder.encode(fileStream, "UTF-8");
  430. } catch (IOException e) {
  431. e.printStackTrace();
  432. } catch (MyException e) {
  433. LogService.getLogger(User.class).error("人口头像图片下载失败;错误代码:" + e);
  434. }
  435. return imageStream;
  436. }
  437. @RequestMapping(value = ServiceApi.Users.UserPhoneExistence, method = RequestMethod.POST)
  438. @ApiOperation("获取已存在电话号码")
  439. public List idExistence(
  440. @ApiParam(name = "phones", value = "phones", defaultValue = "")
  441. @RequestBody String phones) throws Exception {
  442. List existPhones = userService.idExist(toEntity(phones, String[].class));
  443. return existPhones;
  444. }
  445. @RequestMapping(value = ServiceApi.Users.UserOnePhoneExistence, method = RequestMethod.GET)
  446. @ApiOperation("根据过滤条件判断是否存在")
  447. public boolean isExistence(
  448. @ApiParam(name = "filters", value = "filters", defaultValue = "")
  449. @RequestParam(value = "filters") String filters) throws Exception {
  450. List<User> user = userService.search("", filters, "", 1, 1);
  451. return user != null && user.size() > 0;
  452. }
  453. @RequestMapping(value = ServiceApi.Users.UserEmailExistence, method = RequestMethod.POST)
  454. @ApiOperation("获取已存在邮箱")
  455. public List emailsExistence(
  456. @ApiParam(name = "emails", value = "emails", defaultValue = "")
  457. @RequestBody String emails) throws Exception {
  458. List existPhones = userService.emailsExistence(toEntity(emails, String[].class));
  459. return existPhones;
  460. }
  461. @RequestMapping(value = ServiceApi.Users.UseridCardNoExistence, method = RequestMethod.POST)
  462. @ApiOperation("获取已存在身份证号码")
  463. public List idCardNoExistence(
  464. @ApiParam(name = "idCardNos", value = "idCardNos", defaultValue = "")
  465. @RequestBody String idCardNos) throws Exception {
  466. List existidCardNos = userService.idCardNosExist(toEntity(idCardNos, String[].class));
  467. return existidCardNos;
  468. }
  469. @RequestMapping(value = ServiceApi.Users.UserByIdCardNo, method = RequestMethod.GET)
  470. @ApiOperation("根据身份证号码获取用户id")
  471. public String getUserIdByIdCardNo(String idCardNo) {
  472. User user = userService.getUserByIdCardNo(idCardNo);
  473. return StringUtils.isEmpty(user) ? "" : user.getId();
  474. }
  475. @RequestMapping(value = ServiceApi.Users.UpdateSystemUser, method = RequestMethod.PUT, consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)
  476. @ApiOperation(value = "修改用户", notes = "账户体系-修改用户信息")
  477. public MUser UpdateSystemUser(
  478. @ApiParam(name = "user_json_data", value = "用户信息json", defaultValue = "")
  479. @RequestBody String userJsonData) throws Exception {
  480. User user = toEntity(userJsonData, User.class);
  481. String userType = user.getUserType();
  482. if (!StringUtils.isEmpty(userType)) {
  483. SystemDictEntry dict = dictEntryService.getDictEntry(15, userType);
  484. if (dict != null) {
  485. user.setDType(userType);
  486. }
  487. }
  488. userService.saveUser(user);
  489. return convertToModel(user, MUser.class);
  490. }
  491. @RequestMapping(value = ServiceApi.Users.UsersByTel, method = RequestMethod.GET, consumes = MediaType.APPLICATION_JSON_UTF8_VALUE)
  492. @ApiOperation(value = "根据手机号码查询用户信息", notes = "根据手机号码查询用户信息")
  493. public MUser getUserByTel(
  494. @ApiParam(name = "tel", value = "手机号码", defaultValue = "")
  495. @RequestParam(value = "tel") String tel) throws Exception {
  496. User user = userService.getUserByTelephone(tel);
  497. if (user == null) {
  498. return null;
  499. }
  500. MUser mUser = convertToModel(user, MUser.class);
  501. return mUser;
  502. }
  503. @RequestMapping(value = ServiceApi.Users.H5Handshake, method = RequestMethod.GET)
  504. @ApiOperation(value = "医疗服务:提供二次握手的URL", notes = "医疗服务:提供二次握手的URL")
  505. public MH5Handshake getH5Handshake(
  506. @ApiParam(name = "thirdPartyUserId", value = "第三方登录账号ID", defaultValue = "")
  507. @RequestParam(name = "thirdPartyUserId") String thirdPartyUserId,
  508. @ApiParam(name = "ts", value = "时间戳(相对于1970-1-1的毫秒数)", defaultValue = "")
  509. @RequestParam(name = "ts") String ts,
  510. @ApiParam(name = "sign", value = "签名串", defaultValue = "")
  511. @RequestParam(name = "sign") String sign) {
  512. MH5Handshake handshake = new MH5Handshake();
  513. //校验合法性
  514. if (!validSign(thirdPartyUserId, ts, sign)) {
  515. handshake.setCode("-100001");
  516. handshake.setMessage("签名校验失败");
  517. return handshake;
  518. }
  519. User user = userService.getUser(thirdPartyUserId);
  520. if (user == null) {
  521. handshake.setCode("-10000");
  522. handshake.setMessage("账号不存在");
  523. return handshake;
  524. }
  525. handshake.setCode("10000");
  526. handshake.setMessage("Yes");
  527. handshake.setUserName(user.getRealName());
  528. handshake.setCardNo(user.getIdCardNo());
  529. if (!StringUtils.isEmpty(user.getGender())) {
  530. handshake.setSex(Integer.parseInt(user.getGender()));
  531. }
  532. handshake.setTel(user.getTelephone());
  533. return handshake;
  534. }
  535. /**
  536. * 校验sign签名的合法性
  537. * 算法为:thirdPartyUserId的值+ts的值+appId+secret(健康之路分配给第三方的秘钥) 字符串串起来的做SHA1签名,
  538. * 最后将签名值转换为小写(其中加号表示字符串拼接,不代表实际字符)
  539. *
  540. * @param thirdPartyUserId 第三方登录账号ID
  541. * @param ts 时间戳
  542. * @param sign 签名串
  543. * @return 如果通过返回 <code>true</code>
  544. */
  545. private boolean validSign(String thirdPartyUserId, String ts, String sign) {
  546. String tempStr = new StringBuilder(thirdPartyUserId)
  547. .append(ts)
  548. .append(appId)
  549. .append(secret).toString();
  550. tempStr = DigestUtils.sha1Hex(tempStr).toLowerCase();
  551. if (tempStr.equals(sign)) {
  552. return true;
  553. }
  554. return false;
  555. }
  556. // ---------------------------- 适配zuul新代码 start -----------------------------------
  557. @RequestMapping(value = ServiceApi.Users.Save, method = RequestMethod.POST)
  558. @ApiOperation("保存")
  559. public Envelop save(
  560. @ApiParam(name = "user", value = "Json串")
  561. @RequestParam(value = "user") String user) throws Exception {
  562. User user1 = objectMapper.readValue(user, User.class);
  563. DemographicInfo demographicInfo = objectMapper.readValue(user, DemographicInfo.class);
  564. String msg = this.basicVerify(user1, false);
  565. if (!StringUtils.isEmpty(msg)) {
  566. return failed(msg);
  567. }
  568. //设置默认密码为身份证后八位
  569. if (!StringUtils.isEmpty(user1.getIdCardNo()) && user1.getIdCardNo().length() > 9) {
  570. String defaultPassword = user1.getIdCardNo().substring(user1.getIdCardNo().length() - 8);
  571. user1.setPassword(DigestUtils.md5Hex(defaultPassword));
  572. } else {
  573. user1.setPassword(DigestUtils.md5Hex(default_password));
  574. }
  575. //更新居民demographics表中居民信息(无则创建,有则更新)
  576. String telephone = "{\"联系电话\":\"telephone\"}";
  577. telephone = telephone.replace("telephone", user1.getTelephone());
  578. demographicInfo.setTelephoneNo(telephone);
  579. demographicInfo.setName(user1.getRealName());
  580. //新增家庭地址信息
  581. String homeAddress = "";
  582. if (!StringUtils.isEmpty(user1.getProvinceName())) {
  583. homeAddress += user1.getProvinceName();
  584. }
  585. if (!StringUtils.isEmpty(user1.getCityName())) {
  586. homeAddress += user1.getCityName();
  587. }
  588. if (!StringUtils.isEmpty(user1.getAreaName())) {
  589. homeAddress += user1.getAreaName();
  590. }
  591. if (!StringUtils.isEmpty(homeAddress)) {
  592. demographicInfo.setHomeAddress(homeAddress);
  593. }
  594. user1.setId(getObjectId(BizObject.User));
  595. user1.setCreateDate(new Date());
  596. String userType = user1.getUserType();
  597. SystemDictEntry dict = dictEntryService.getDictEntry(15, userType);
  598. if (dict != null) {
  599. user1.setUserType(userType);
  600. }
  601. user1.setActivated(true);
  602. User user2 = userService.save(user1, demographicInfo);
  603. return success(user2);
  604. }
  605. @RequestMapping(value = ServiceApi.Users.Update, method = RequestMethod.POST)
  606. @ApiOperation("更新")
  607. public Envelop update(
  608. @ApiParam(name = "user", value = "Json串")
  609. @RequestParam(value = "user") String user) throws Exception {
  610. User detailModel = toEntity(user, User.class);
  611. String msg = this.basicVerify(detailModel, true);
  612. if (!StringUtils.isEmpty(msg)) {
  613. return failed(msg);
  614. }
  615. //修改时先修改所属角色组再修改用户,修改角色组失败(修改失败)、修改用户失败 (回显角色组)
  616. String userType = detailModel.getUserType();
  617. SystemDictEntry dict = dictEntryService.getDictEntry(15, userType);
  618. if (dict != null) {
  619. detailModel.setUserType(userType);
  620. }
  621. //同时修改医生表及用户表信息
  622. Doctors doctor = doctorService.getByIdCardNo(detailModel.getIdCardNo());
  623. if (doctor != null) {
  624. doctor.setName(detailModel.getRealName());
  625. doctor.setPyCode(PinyinUtil.getPinYinHeadChar(detailModel.getRealName(), false));
  626. doctor.setSex(detailModel.getGender());
  627. doctor.setPhone(detailModel.getTelephone());
  628. }
  629. DemographicInfo demographicInfo = demographicService.getDemographicInfoByIdCardNo(detailModel.getIdCardNo());
  630. if (demographicInfo != null) {
  631. demographicInfo.setName(detailModel.getRealName());
  632. demographicInfo.setTelephoneNo("{\"联系电话\":\"" + detailModel.getTelephone() + "\"}");
  633. demographicInfo.setGender(detailModel.getGender());
  634. demographicInfo.setMartialStatus(detailModel.getMartialStatus());
  635. demographicInfo.setBirthday(DateUtil.strToDate(detailModel.getBirthday()));
  636. } else {
  637. demographicInfo = objectMapper.readValue(user, DemographicInfo.class);
  638. demographicInfo.setName(detailModel.getRealName());
  639. demographicInfo.setTelephoneNo("{\"联系电话\":\"" + detailModel.getTelephone() + "\"}");
  640. String homeAddress = "";
  641. if (!StringUtils.isEmpty(detailModel.getProvinceName())) {
  642. homeAddress += detailModel.getProvinceName();
  643. }
  644. if (!StringUtils.isEmpty(detailModel.getCityName())) {
  645. homeAddress += detailModel.getCityName();
  646. }
  647. if (!StringUtils.isEmpty(detailModel.getAreaName())) {
  648. homeAddress += detailModel.getAreaName();
  649. }
  650. if (!StringUtils.isEmpty(homeAddress)) {
  651. demographicInfo.setHomeAddress(homeAddress);
  652. }
  653. }
  654. User user1 = userService.update(detailModel, doctor, demographicInfo);
  655. return success(user1);
  656. }
  657. @RequestMapping(value = ServiceApi.Users.Check, method = RequestMethod.GET)
  658. @ApiOperation(value = "检查字段是否重复")
  659. public Boolean check(
  660. @ApiParam(name = "field", value = "检查字段", required = true)
  661. @RequestParam(value = "field") String field,
  662. @ApiParam(name = "value", value = "检查值", required = true)
  663. @RequestParam(value = "value") String value) {
  664. if (userService.findByField(field, value).size() <= 0) {
  665. return false;
  666. }
  667. return true;
  668. }
  669. @RequestMapping(value = ServiceApi.Users.ChangePassword, method = RequestMethod.POST)
  670. @ApiOperation(value = "修改密码")
  671. public Boolean passwordChange(
  672. @ApiParam(name = "userId", value = "用户ID", required = true)
  673. @RequestParam(value = "userId") String userId,
  674. @ApiParam(name = "password", value = "password", required = true)
  675. @RequestParam(value = "password") String password) {
  676. User user = userService.getUser(userId);
  677. if (null == user) {
  678. return false;
  679. }
  680. user.setPassword(DigestUtils.md5Hex(password));
  681. userService.save(user);
  682. return true;
  683. }
  684. @RequestMapping(value = ServiceApi.Users.DistributeSecurityKey, method = RequestMethod.POST)
  685. @ApiOperation(value = "分配密钥", notes = "重新分配密钥")
  686. public Map<String, String> distributeSecurityKey(
  687. @ApiParam(name = "userId", value = "用户ID")
  688. @RequestParam(value = "userId") String userId) throws Exception {
  689. User user = userService.getUser(userId);
  690. if (null == user) {
  691. return null;
  692. }
  693. UserSecurity userSecurity = userSecurityService.getKeyByUserId(userId, false);
  694. Map<String, String> keyMap = new HashMap<>();
  695. if (userSecurity != null) {
  696. // 删除原有的公私钥重新分配
  697. List<UserKey> userKeyList = userSecurityService.getKeyMapByUserId(userId);
  698. userSecurityService.deleteKey(userKeyList);
  699. }
  700. userSecurity = userSecurityService.createKeyByUserId(userId);
  701. String validTime = DateFormatUtils.format(userSecurity.getFromDate(), "yyyy-MM-dd")
  702. + "~" + DateFormatUtils.format(userSecurity.getExpiryDate(), "yyyy-MM-dd");
  703. keyMap.put("publicKey", userSecurity.getPublicKey());
  704. keyMap.put("validTime", validTime);
  705. keyMap.put("startTime", DateFormatUtils.format(userSecurity.getFromDate(), "yyyy-MM-dd"));
  706. return keyMap;
  707. }
  708. @RequestMapping(value = ServiceApi.Users.GetSecurityKey, method = RequestMethod.GET)
  709. @ApiOperation(value = "查询用户公钥", notes = "查询用户公钥")
  710. public Map<String, String> UserId(
  711. @ApiParam(name = "userId", value = "登录帐号")
  712. @RequestParam(value = "userId") String userId) throws Exception {
  713. User user = userService.getUser(userId);
  714. if (null == user) {
  715. return null;
  716. }
  717. UserSecurity userSecurity = userSecurityService.getKeyByUserId(userId, true);
  718. if (null == userSecurity) {
  719. return null;
  720. }
  721. Map<String, String> keyMap = new HashMap<>();
  722. String validTime = DateFormatUtils.format(userSecurity.getFromDate(), "yyyy-MM-dd")
  723. + "~" + DateFormatUtils.format(userSecurity.getExpiryDate(), "yyyy-MM-dd");
  724. keyMap.put("publicKey", userSecurity.getPublicKey());
  725. keyMap.put("validTime", validTime);
  726. keyMap.put("startTime", DateFormatUtils.format(userSecurity.getFromDate(), "yyyy-MM-dd"));
  727. return keyMap;
  728. }
  729. /**
  730. * 用户基本信息验证
  731. *
  732. * @param user
  733. * @return
  734. */
  735. private String basicVerify(User user, boolean update) {
  736. String errorMsg = "";
  737. if (StringUtils.isEmpty(user.getLoginCode())) {
  738. errorMsg += "账户不能为空!";
  739. }
  740. if (StringUtils.isEmpty(user.getRealName())) {
  741. errorMsg += "姓名不能为空!";
  742. }
  743. if (StringUtils.isEmpty(user.getIdCardNo())) {
  744. errorMsg += "身份证号不能为空!";
  745. }
  746. if (StringUtils.isEmpty(user.getEmail())) {
  747. errorMsg += "邮箱不能为空!";
  748. }
  749. if (StringUtils.isEmpty(user.getTelephone())) {
  750. errorMsg += "电话号码不能为空!";
  751. }
  752. if (StringUtils.isEmpty(user.getRole())) {
  753. errorMsg += "用户角色不能为空!";
  754. }
  755. if (!StringUtils.isEmpty(errorMsg)) {
  756. return errorMsg;
  757. }
  758. if (update) {
  759. List<User> oldUserList1 = userService.findByField("id", user.getId());
  760. if (oldUserList1.size() <= 0) {
  761. return "操作用户不存在";
  762. }
  763. User oldUser = oldUserList1.get(0);
  764. if (!user.getLoginCode().equals(oldUser.getLoginCode()) && userService.findByField("loginCode", user.getLoginCode()).size() > 0) {
  765. return "账户已存在";
  766. }
  767. if (!user.getIdCardNo().equals(oldUser.getIdCardNo()) && userService.findByField("idCardNo", user.getIdCardNo()).size() > 0) {
  768. return "身份证号已存在";
  769. }
  770. if (!user.getEmail().equals(oldUser.getEmail()) && userService.findByField("email", user.getEmail()).size() > 0) {
  771. return "邮箱已存在";
  772. }
  773. if (!user.getTelephone().equals(oldUser.getTelephone()) && userService.findByField("telephone", user.getTelephone()).size() > 0) {
  774. return "电话号码已存在";
  775. }
  776. } else {
  777. if (userService.findByField("loginCode", user.getLoginCode()).size() > 0) {
  778. return "账户已存在";
  779. }
  780. if (userService.findByField("idCardNo", user.getIdCardNo()).size() > 0) {
  781. return "身份证号已存在";
  782. }
  783. if (userService.findByField("email", user.getEmail()).size() > 0) {
  784. return "邮箱已存在";
  785. }
  786. if (userService.findByField("telephone", user.getTelephone()).size() > 0) {
  787. return "电话号码已存在";
  788. }
  789. }
  790. return errorMsg;
  791. }
  792. @RequestMapping(value = ServiceApi.Users.UsersOfApp, method = RequestMethod.POST)
  793. @Transactional(rollbackFor = Exception.class, propagation = Propagation.REQUIRED)
  794. @ApiOperation(value = "App用户注册信息-创建用户", notes = "App用户注册信息")
  795. public Envelop appCreateUser(
  796. @ApiParam(name = "userJsonData", required = true, value = "用户json", defaultValue = "")
  797. @RequestParam(value = "userJsonData") String userJsonData,
  798. @ApiParam(name = "appId", value = "应用id-健康上饶appid", defaultValue = "WYo0l73F8e")
  799. @RequestParam(value = "appId") String appId) throws Exception {
  800. Envelop envelop = new Envelop();
  801. User user = toEntity(userJsonData, User.class);
  802. if (StringUtils.isEmpty(user.getDemographicId())) {
  803. envelop.setErrorMsg("身份证不能为空");
  804. return envelop;
  805. }
  806. if (StringUtils.isEmpty(user.getTelephone())) {
  807. envelop.setErrorMsg("手机号不能为空");
  808. return envelop;
  809. }
  810. if (StringUtils.isEmpty(user.getPassword())) {
  811. envelop.setErrorMsg("密码不能为空");
  812. return envelop;
  813. }
  814. String userId = getObjectId(BizObject.User);
  815. user.setId(userId);
  816. user.setCreateDate(new Date());
  817. user.setIdCardNo(user.getDemographicId());
  818. if (!StringUtils.isEmpty(user.getPassword())) {
  819. user.setPassword(DigestUtils.md5Hex(user.getPassword()));
  820. } else {
  821. user.setPassword(DigestUtils.md5Hex(default_password));
  822. }
  823. user.setLoginCode(user.getDemographicId());
  824. user.setDType("Patient");
  825. user.setUserType(ConstantUtil.PATIENTUSERTYPEID);
  826. user.setActivated(true);
  827. if (userService.findByField("loginCode", user.getDemographicId()).size() > 0) {
  828. envelop.setErrorMsg("账户已存在");
  829. return envelop;
  830. }
  831. if (userService.findByField("demographicId", user.getDemographicId()).size() > 0) {
  832. envelop.setErrorMsg("身份证号已存在");
  833. return envelop;
  834. }
  835. if (userService.findByField("telephone", user.getTelephone()).size() > 0) {
  836. envelop.setErrorMsg("电话号码已存在");
  837. return envelop;
  838. }
  839. user = userService.saveUser(user);
  840. String[] appIds = registerRoleClientId.split(",");
  841. for (String rgAppId : appIds) {
  842. //根据用户类型、应用id判断是否关联角色,
  843. List<UserTypeRoles> list = xUserTypeRolesRepository.ListUserTypeRolesByTypeIdAndClientId(Integer.valueOf(ConstantUtil.PATIENTUSERTYPEID), rgAppId);
  844. if(null!=list && list.size()>0){
  845. //卫生人员初始化授权
  846. userService.initializationAuthorization(Integer.valueOf(ConstantUtil.PATIENTUSERTYPEID),userId);
  847. }else{
  848. // orgcode卫计委机构编码-PDY026797 添加居民的时候 默认 加到卫计委-居民角色中
  849. List<Roles> rolesList = rolesService.findByCodeAndAppIdAndOrgCode(Arrays.asList(new String[]{orgcode}), rgAppId, "Patient");
  850. Roles roles = new Roles();
  851. if (null != rolesList && rolesList.size() > 0) {
  852. roles = rolesList.get(0);
  853. } else {
  854. //如果角色不存在,为该应用创建居民角色
  855. roles.setAppId(appId);
  856. roles.setName("居民");
  857. roles.setCode("Patient");
  858. //上饶市卫计委机构
  859. roles.setOrgCode(orgcode);
  860. roles.setType("1");
  861. roles.setDescription("系统创建默认角色");
  862. roles = rolesService.save(roles);
  863. }
  864. //在org_member_relation 表里追加关联关系
  865. roleUserService.batchCreateRoleUsersRelation(userId, String.valueOf(roles.getId()));
  866. }
  867. }
  868. // 根据身份证号码查找居民,若不存在则创建居民。
  869. DemographicInfo demographicInfo = demographicService.getDemographicInfo(user.getDemographicId());
  870. if (null == demographicInfo) {
  871. demographicInfo = new DemographicInfo();
  872. demographicInfo.setIdCardNo(user.getIdCardNo());
  873. demographicInfo.setTelephoneNo("{\"联系电话\":\"" + user.getTelephone() + "\"}");
  874. demographicInfo.setName(user.getRealName());
  875. demographicInfo.setPassword(user.getPassword());
  876. demographicInfo.setRegisterTime(new Date());
  877. demographicService.savePatient(demographicInfo);
  878. }
  879. envelop.setObj(convertToModel(user, MUser.class, null));
  880. envelop.setSuccessFlg(true);
  881. return envelop;
  882. }
  883. @RequestMapping(value = ServiceApi.Users.changePasswordByTelephone, method = RequestMethod.POST)
  884. @ApiOperation(value = "手机号码-修改密码")
  885. public Envelop changePasswordByTelephone(
  886. @ApiParam(name = "telephone", value = "电话号码", required = true)
  887. @RequestParam(value = "telephone") String telephone,
  888. @ApiParam(name = "password", value = "password", required = true)
  889. @RequestParam(value = "password") String password) {
  890. Envelop envelop = new Envelop();
  891. User user = userService.getUserByTel(telephone);
  892. if (null == user) {
  893. envelop.setSuccessFlg(false);
  894. envelop.setErrorMsg("电话号码不存在!");
  895. return envelop;
  896. }
  897. user.setPassword(DigestUtils.md5Hex(password));
  898. user = userService.save(user);
  899. envelop.setSuccessFlg(true);
  900. envelop.setObj(user);
  901. return envelop;
  902. }
  903. @RequestMapping(value = ServiceApi.Users.changePasswordByOldPassword, method = RequestMethod.POST)
  904. @ApiOperation(value = "健康上饶-根据旧密码修改用户的密码", notes = "根据旧密码修改用户的密码信息")
  905. public Envelop updatePasswordByOldPwd(
  906. @ApiParam(name = "userId", value = "用户id", defaultValue = "")
  907. @RequestParam(value = "userId", required = false) String userId,
  908. @ApiParam(name = "passwordOld", value = "旧密码", defaultValue = "")
  909. @RequestParam(value = "passwordOld", required = false) String passwordOld,
  910. @ApiParam(name = "passwordNew", value = "新密码", defaultValue = "")
  911. @RequestParam(value = "passwordNew", required = false) String passwordNew) throws Exception {
  912. Envelop envelop = new Envelop();
  913. //获取用户信息,根据用户ID
  914. User user = userService.getUser(userId);
  915. if (user == null) {
  916. envelop.setSuccessFlg(false);
  917. envelop.setErrorMsg("对不起,该用户不存在,请确认!");
  918. return envelop;
  919. }
  920. //对旧密码进行MD5加密后,进行对比验证
  921. String hashPassWordOld = DigestUtils.md5Hex(passwordOld);
  922. if (org.apache.commons.lang3.StringUtils.equals(hashPassWordOld, user.getPassword().toString())) {
  923. //当验证通过后,进行新密码的更新在微服务中会将该密码信息进行MD5加密
  924. user.setPassword(DigestUtils.md5Hex(passwordNew));
  925. user = userService.save(user);
  926. if (null != user) {
  927. envelop.setSuccessFlg(true);
  928. envelop.setObj(user);
  929. } else {
  930. envelop.setSuccessFlg(false);
  931. envelop.setErrorMsg("密码修改失败,请联系管理员!");
  932. }
  933. } else {
  934. envelop.setSuccessFlg(false);
  935. envelop.setErrorMsg("对不起,原密码不正确,请确认!");
  936. }
  937. return envelop;
  938. }
  939. @RequestMapping(value = ServiceApi.Users.UsersOfAppPhoneExistence, method = RequestMethod.GET)
  940. @ApiOperation("根据过滤条件判断是否存在")
  941. public boolean UsersOfAppPhoneExistence(
  942. @ApiParam(name = "filters", value = "filters", defaultValue = "")
  943. @RequestParam(value = "filters") String filters) throws Exception {
  944. List<User> user = userService.search("", filters, "", 1, 1);
  945. return user != null && user.size() > 0;
  946. }
  947. @RequestMapping(value = ServiceApi.Users.updateUserTelePhone, method = RequestMethod.POST)
  948. @ApiOperation(value = "更换手机号码", notes = "更换手机号码")
  949. public Envelop updateUserTelePhone(
  950. @ApiParam(name = "userId", value = "用户id", defaultValue = "")
  951. @RequestParam(value = "userId", required = false) String userId,
  952. @ApiParam(name = "telePhoneNew", value = "新手机号码", defaultValue = "")
  953. @RequestParam(value = "telePhoneNew") String telePhoneNew) throws Exception {
  954. Envelop envelop = new Envelop();
  955. //获取用户信息,根据用户ID
  956. User user = userService.getUser(userId);
  957. if (user == null) {
  958. envelop.setSuccessFlg(false);
  959. envelop.setErrorMsg("对不起,该用户不存在,请确认!");
  960. return envelop;
  961. }
  962. //同时修改医生表及用户表信息
  963. Doctors doctor = doctorService.getByIdCardNo(user.getIdCardNo());
  964. if (doctor != null) {
  965. doctor.setPhone(telePhoneNew);
  966. }
  967. DemographicInfo demographicInfo = demographicService.getDemographicInfoByIdCardNo(user.getIdCardNo());
  968. if (demographicInfo != null) {
  969. demographicInfo.setTelephoneNo("{\"联系电话\":\"" + telePhoneNew + "\"}");
  970. } else {
  971. demographicInfo = objectMapper.readValue(JSON.toJSONString(user), DemographicInfo.class);
  972. demographicInfo.setTelephoneNo("{\"联系电话\":\"" + telePhoneNew + "\"}");
  973. }
  974. User user1 = userService.update(user, doctor, demographicInfo);
  975. envelop.setSuccessFlg(true);
  976. envelop.setObj(user);
  977. return envelop;
  978. }
  979. @RequestMapping(value = ServiceApi.Users.GetUserOfUsersOfApp, method = RequestMethod.GET)
  980. @ApiOperation(value = "公众健康服务-根据用户身份证号码或者电话号码,获取用户")
  981. public Envelop getUserOfUsersOfApp(
  982. @ApiParam(name = "userName", value = "身份证号码或者电话号码", defaultValue = "")
  983. @RequestParam(value = "userName") String userName) {
  984. Envelop envelop = new Envelop();
  985. List<User> userList = userService.getUserForLogin(userName);
  986. if (null != userList && userList.size() > 0) {
  987. User user = userList.get(0);
  988. envelop.setSuccessFlg(true);
  989. envelop.setObj(user);
  990. } else {
  991. envelop.setSuccessFlg(false);
  992. envelop.setErrorMsg("用户不存在!");
  993. }
  994. return envelop;
  995. }
  996. @RequestMapping(value = ServiceApi.Users.GetUserInfoAndRolesByUserIdOrCode, method = RequestMethod.GET)
  997. @ApiOperation(value = "用户id或者用户登录账号获取用户信息")
  998. public Envelop getUserInfoAndRolesByUserIdOrCode(
  999. @ApiParam(name = "userIdOrCode", value = "用户id或者用户登录账号")
  1000. @RequestParam(value = "userIdOrCode", required = false) String userIdOrCode,
  1001. @ApiParam(name = "appClientId", value = "应用id")
  1002. @RequestParam(value = "appClientId", required = true) String appClientId) throws Exception {
  1003. Envelop envelop = new Envelop();
  1004. User user;
  1005. MUser mUser = new MUser();
  1006. //获取用户信息
  1007. if (org.apache.commons.lang.StringUtils.isNotEmpty(userIdOrCode)) {
  1008. user = userService.getUser(userIdOrCode);
  1009. if (null == user) {
  1010. List<User> users = userService.getUserForLogin(userIdOrCode);
  1011. if (null != users && users.size() > 0) {
  1012. user = users.get(0);
  1013. } else {
  1014. envelop.setErrorMsg("用户不存在!");
  1015. envelop.setSuccessFlg(false);
  1016. return envelop;
  1017. }
  1018. }
  1019. } else {
  1020. envelop.setErrorMsg("用户id或者用户登录账号不能为空!");
  1021. envelop.setSuccessFlg(false);
  1022. return envelop;
  1023. }
  1024. //根据用户id和应用id获取角色
  1025. List<Map<String, Object>> roles = rolesService.findRolesByUserIdAndAppId(user.getId(), appClientId);
  1026. mUser = convertToModel(user, MUser.class, null);
  1027. //医生在总部库中的对应关系
  1028. MJkzlOrgMemberRelation mJkzlOrgMemberRelation = new MJkzlOrgMemberRelation();
  1029. List<OrgMemberRelation> memberRelationList = relationService.getByUserId(mUser.getId());
  1030. if (null != memberRelationList && memberRelationList.size() > 0) {
  1031. OrgMemberRelation orgMemberRelation = memberRelationList.get(0);
  1032. mJkzlOrgMemberRelation.setJkzlDoctorSn(orgMemberRelation.getJkzlDoctorSn());
  1033. mJkzlOrgMemberRelation.setJkzlDoctorUid(orgMemberRelation.getJkzlDoctorUid());
  1034. mJkzlOrgMemberRelation.setJkzlHosDeptId(orgMemberRelation.getJkzlHosDeptId());
  1035. mJkzlOrgMemberRelation.setJkzlUserId(orgMemberRelation.getJkzlUserId());
  1036. }
  1037. String jkzlOrgId = relationService.getJkzlOrgIds(mUser.getId());
  1038. mJkzlOrgMemberRelation.setJkzlHosId(jkzlOrgId);
  1039. mUser.setmJkzlOrgMemberRelation(mJkzlOrgMemberRelation);
  1040. envelop.setObj(mUser);
  1041. envelop.setDetailModelList(roles);
  1042. envelop.setSuccessFlg(true);
  1043. return envelop;
  1044. }
  1045. @RequestMapping(value = ServiceApi.Users.initializationAuthorization, method = RequestMethod.GET)
  1046. @ApiOperation(value = "根据用户类型id,用户id进行初始化授权")
  1047. public Envelop initializationAuthorization(
  1048. @ApiParam(name = "userTypeId", value = "用户类型id", defaultValue = "")
  1049. @RequestParam(value = "userTypeId",required =true) int userTypeId,
  1050. @ApiParam(name = "userId", value = "用户id", defaultValue = "")
  1051. @RequestParam(value = "userId",required =true) String userId) {
  1052. Envelop envelop = new Envelop();
  1053. boolean authorrizationFlag= userService.initializationAuthorization(userTypeId,userId);
  1054. if (authorrizationFlag) {
  1055. envelop.setSuccessFlg(true);
  1056. } else {
  1057. envelop.setSuccessFlg(false);
  1058. envelop.setErrorMsg("初始化授权失败!");
  1059. }
  1060. return envelop;
  1061. }
  1062. @RequestMapping(value = BasicServiceApi.Users.GetUserByLoginCode, method = RequestMethod.GET)
  1063. @ApiOperation(value = "政府服务平台-根据登录账号获取当前用户", notes = "政府服务平台-根据登陆用户名及密码验证用户(一个人可属于多个机构)")
  1064. public Envelop getUserInfoByLoginCode(
  1065. @ApiParam(name = "userName", value = "登录账号", defaultValue = "")
  1066. @PathVariable(value = "userName") String userName) {
  1067. Envelop envelop=new Envelop();
  1068. try {
  1069. // 帐户:手机号,身份证号,登录账号
  1070. List<User> users = userService.getUserForLogin(userName);
  1071. envelop.setObj(users);
  1072. if (users != null) {
  1073. if (users.size() == 1) {
  1074. List<OrgMemberRelation> memberRelations = orgMemberRelationService.findByField("userId", users.get(0).getId());
  1075. envelop.setSuccessFlg(true);
  1076. envelop.setDetailModelList(memberRelations);
  1077. }else {
  1078. envelop.setSuccessFlg(false);
  1079. envelop.setErrorMsg("账号重复,请联系管理员!");
  1080. }
  1081. }else {
  1082. envelop.setSuccessFlg(false);
  1083. envelop.setErrorMsg("该账号不存在,请确认或联系管理员!");
  1084. }
  1085. } catch (Exception e) {
  1086. envelop.setSuccessFlg(false);
  1087. envelop.setErrorMsg(e.getMessage());
  1088. e.printStackTrace();
  1089. }
  1090. return envelop;
  1091. }
  1092. }