SynchAPIController.java 5.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121
  1. package com.zhcs.dt.controller.system.user;
  2. import java.util.Calendar;
  3. import java.util.HashMap;
  4. import java.util.Map;
  5. import javax.annotation.Resource;
  6. import net.sf.json.JSONObject;
  7. import org.apache.shiro.crypto.hash.SimpleHash;
  8. import org.springframework.stereotype.Controller;
  9. import org.springframework.web.bind.annotation.RequestMapping;
  10. import com.zhcs.dt.controller.base.BaseController;
  11. import com.zhcs.dt.controller.system.login.Des;
  12. import com.zhcs.dt.service.fhoa.department.DepartmentManager;
  13. import com.zhcs.dt.service.system.user.UserManager;
  14. import com.zhcs.dt.util.AppUtil;
  15. import com.zhcs.dt.util.PageData;
  16. @Controller
  17. public class SynchAPIController extends BaseController {
  18. @Resource(name="userService")
  19. private UserManager userService;
  20. @Resource(name="departmentService")
  21. private DepartmentManager departmentService;
  22. @RequestMapping(value="/api")
  23. public Object api()throws Exception{
  24. PageData pd = new PageData();
  25. pd = this.getPageData();
  26. logger.warn("----------------用户同步数据:"+pd.get("data"));
  27. Calendar cal = Calendar.getInstance();
  28. int year = cal.get(Calendar.YEAR);//获取年份
  29. String department_table = "OA_DEPARTMENT_"+year;
  30. pd.put("table", department_table);
  31. Map<String,Object> map = new HashMap<String,Object>();
  32. try {
  33. JSONObject data = JSONObject.fromObject(pd.get("data"));
  34. if (data != null) {
  35. pd.put("userName", data.get("userAccount"));
  36. pd.put("name", data.get("userName"));
  37. //解密
  38. if (data.get("password")!=null && !data.get("password").equals("")) {
  39. Des desObj = new Des();
  40. String newPassword=desObj.strDec(data.getString("password"),"www","jsyhzx","com");
  41. String passwd = new SimpleHash("SHA-1", data.get("userAccount"), newPassword).toString(); //密码加密
  42. pd.put("password", passwd);
  43. }
  44. if(data.get("company_name").toString().trim().contains("苏通大桥") || data.get("company_name").toString().trim().contains("润扬大桥")
  45. || data.get("company_name").toString().trim().contains("泰州大桥")){
  46. pd.put("company_name", data.get("company_name").toString().trim()+"公司");
  47. }
  48. else{
  49. pd.put("company_name", data.get("company_name"));
  50. }
  51. pd.put("dep_name", data.get("dep_name"));
  52. pd.put("COMPANY_ID", data.get("company_id"));
  53. pd.put("ROAD_ID", data.get("dep_id"));
  54. if (!data.get("type").equals("1")) {
  55. if (data.get("company_id")!=null && !data.get("company_id").equals("")) {
  56. //判断公司是否存在
  57. pd.put("BIANMA", data.get("company_id"));
  58. if(null == departmentService.findByBianma2(pd)){
  59. pd.put("DEPARTMENT_ID", data.get("company_id"));
  60. pd.put("PARENT_ID", "0");
  61. pd.put("NAME", data.get("company_name"));
  62. departmentService.saveAPIrecord(pd);
  63. }
  64. }
  65. if (data.get("dep_id")!=null && !data.get("dep_id").equals("")) {
  66. //判断部门是否存在
  67. pd.put("BIANMA", data.get("dep_id"));
  68. if(null == departmentService.findByBianma2(pd)){
  69. pd.put("DEPARTMENT_ID", data.get("dep_id"));
  70. pd.put("PARENT_ID", data.get("company_id"));
  71. pd.put("NAME", data.get("dep_name"));
  72. departmentService.saveAPIrecord(pd);
  73. }
  74. }
  75. }
  76. //根据type(0新增 1删除 2修改)维护 sys_user 表数据
  77. if (data.get("type").equals("0")) {
  78. pd.put("USER_ID", this.get32UUID());
  79. pd.put("STATUS", "0");
  80. pd.put("SKIN", "no-skin");
  81. pd.put("ROLE_ID", "5be35d903d204f559077978e1215633f");
  82. //2019-11-12 用户对接
  83. if (data.get("company_id")!=null && data.get("company_id").equals("JSJKDW016")) {
  84. //路段管理员
  85. pd.put("ROLE_ID", "b98a12b47e5e46978346b593efd65597");
  86. }else {
  87. //路桥公司管理员
  88. pd.put("ROLE_ID", "5be35d903d204f559077978e1215633f");
  89. }
  90. userService.insertAPIUser(pd);
  91. }else if (data.get("type").equals("1")) {
  92. userService.deleteAPIUser(pd);
  93. }else if (data.get("type").equals("2")) {
  94. //2019-11-12 用户对接
  95. if (data.get("company_id")!=null && data.get("company_id").equals("JSJKDW016")) {
  96. pd.put("ROLE_ID", "b98a12b47e5e46978346b593efd65597");
  97. }else {
  98. pd.put("ROLE_ID", "5be35d903d204f559077978e1215633f");
  99. }
  100. pd.put("ROLE_ID", "5be35d903d204f559077978e1215633f");
  101. userService.editAPIUser(pd);
  102. }
  103. }
  104. map.put("msg", "success");
  105. } catch (Exception e) {
  106. logger.error(e.toString(), e);
  107. map.put("msg", "error");
  108. }
  109. return AppUtil.returnObject(new PageData(), map);
  110. }
  111. }