AdminSuperviserApiController.java 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352
  1. package com.goafanti.admin.controller;
  2. import java.util.ArrayList;
  3. import java.util.Calendar;
  4. import java.util.List;
  5. import java.util.UUID;
  6. import javax.annotation.Resource;
  7. import javax.servlet.http.HttpServletRequest;
  8. import org.springframework.beans.BeanUtils;
  9. import org.springframework.beans.factory.annotation.Autowired;
  10. import org.springframework.stereotype.Controller;
  11. import org.springframework.web.bind.annotation.RequestMapping;
  12. import org.springframework.web.bind.annotation.RequestMethod;
  13. import org.springframework.web.bind.annotation.RequestParam;
  14. import com.alibaba.fastjson.JSON;
  15. import com.alibaba.fastjson.JSONArray;
  16. import com.alibaba.fastjson.JSONObject;
  17. import com.goafanti.admin.bo.AdminListBo;
  18. import com.goafanti.admin.bo.AdminLocationBo;
  19. import com.goafanti.admin.service.AdminLocationService;
  20. import com.goafanti.admin.service.NewAdminService;
  21. import com.goafanti.common.bo.Result;
  22. import com.goafanti.common.constant.AFTConstants;
  23. import com.goafanti.common.constant.ErrorConstants;
  24. import com.goafanti.common.controller.CertifyApiController;
  25. import com.goafanti.common.dao.AdminMapper;
  26. import com.goafanti.common.model.Admin;
  27. import com.goafanti.common.model.AdminLocation;
  28. import com.goafanti.common.utils.PasswordUtil;
  29. import com.goafanti.common.utils.StringUtils;
  30. import com.goafanti.core.shiro.token.TokenManager;
  31. import com.goafanti.user.service.UserService;
  32. @Controller
  33. @RequestMapping(value = "api/admin/superviser")
  34. public class AdminSuperviserApiController extends CertifyApiController {
  35. @Resource
  36. private NewAdminService newAdminService;
  37. @Resource(name = "passwordUtil")
  38. private PasswordUtil passwordUtil;
  39. @Resource
  40. private AdminLocationService adminLocationService;
  41. @Resource
  42. private UserService userService;
  43. @Autowired
  44. private AdminMapper adminMapper;
  45. /**管理员列表*/
  46. @RequestMapping(value = "/adminList", method = RequestMethod.GET)
  47. public Result adminList(AdminListBo alb, String rid, String pageNo,
  48. String pageSize) {
  49. Result res = new Result();
  50. Integer pNo = 1;
  51. Integer pSize = 10;
  52. if (StringUtils.isNumeric(pageSize)) {
  53. pSize = Integer.parseInt(pageSize);
  54. }
  55. if (StringUtils.isNumeric(pageNo)) {
  56. pNo = Integer.parseInt(pageNo);
  57. }
  58. res.setData(newAdminService.listAdmin(alb,rid, pNo, pSize));
  59. return res;
  60. }
  61. /**
  62. * 新增管理员
  63. */
  64. @RequestMapping(value = "/insertAdmin", method = RequestMethod.POST)
  65. public Result insertAdmin(@RequestParam(value = "roles[]", required = false) String[] roleIds, String data) {
  66. Result res = new Result();
  67. JSONObject jo = (JSONObject) JSON.parse(data);
  68. if (roleIds==null||roleIds.length<=0) {
  69. res.getError().add(buildError("","角色不能为空"));
  70. return res;
  71. }
  72. if (null != jo) {
  73. Admin admin = jo.toJavaObject(Admin.class);
  74. if (StringUtils.isBlank(admin.getMobile())) {
  75. res.getError().add(buildError(ErrorConstants.PARAM_EMPTY_ERROR, "登录帐号为空", "登录帐号"));
  76. return res;
  77. }
  78. if (StringUtils.isBlank(admin.getName())) {
  79. res.getError().add(buildError(ErrorConstants.PARAM_EMPTY_ERROR, "用户名为空", "用户名"));
  80. return res;
  81. }
  82. Admin a = newAdminService.selectByMobile(admin.getMobile().trim());
  83. if (null != a) {
  84. res.getError().add(buildError(ErrorConstants.USER_ALREADY_EXIST, "当前用户已注册!"));
  85. return res;
  86. }
  87. Admin ad = new Admin();
  88. BeanUtils.copyProperties(admin, ad);
  89. /*ad.setId(UUID.randomUUID().toString());*/
  90. Calendar now = Calendar.getInstance();
  91. now.set(Calendar.MILLISECOND, 0);
  92. ad.setCreateTime(now.getTime());
  93. if (StringUtils.isBlank(ad.getPassword())) {
  94. ad.setPassword(AFTConstants.INITIALPASSWORD);
  95. }
  96. ad.setPassword(passwordUtil.getEncryptPwd(ad));
  97. List<String> roles = new ArrayList<String>();
  98. if (roleIds != null && roleIds.length > 0) {
  99. for (String role : roleIds) {
  100. roles.add(role);
  101. }
  102. }
  103. res.setData(newAdminService.insertNewAdmin(ad,roles));
  104. }
  105. return res;
  106. }
  107. /**
  108. * 修改管理员信息
  109. */
  110. @RequestMapping(value = "/updateAdmin", method = RequestMethod.POST)
  111. public Result updateAdmin(@RequestParam(value = "roles[]", required = false) String[] roleIds, String data) {
  112. Result res = new Result();
  113. JSONObject jo = (JSONObject) JSON.parse(data);
  114. if (null != jo) {
  115. Admin admin = jo.toJavaObject(Admin.class);
  116. if (null == admin.getId()) {
  117. res.getError().add(buildError(ErrorConstants.PARAM_ERROR, "", "用户id"));
  118. return res;
  119. }
  120. if (null == admin.getMobile()) {
  121. res.getError().add(buildError(ErrorConstants.PARAM_EMPTY_ERROR, "登录帐号为空", "登录帐号"));
  122. return res;
  123. }
  124. if (null == admin.getName()) {
  125. res.getError().add(buildError(ErrorConstants.PARAM_EMPTY_ERROR, "用户名为空", "用户名"));
  126. return res;
  127. }
  128. Admin aa = newAdminService.selectByMobile(admin.getMobile().trim());
  129. if (null != aa && !admin.getId().equals(aa.getId())) {
  130. res.getError().add(buildError(ErrorConstants.USER_ALREADY_EXIST, "当前用户已注册!"));
  131. return res;
  132. }
  133. Admin a = newAdminService.selectByPrimaryKey(admin.getId());
  134. if (null == a) {
  135. res.getError().add(buildError(ErrorConstants.PARAM_ERROR, "", "用户id"));
  136. return res;
  137. }
  138. //*********用户编号判断**************
  139. String sdepNo=adminMapper.selectUserNoBySuperiorId(admin.getSuperiorId());
  140. int Count=adminMapper.selectCountBySuperiorId(admin.getSuperiorId());
  141. if((Count+1)>99){
  142. res.getError().add(buildError("","每层最多存在99个子类"));
  143. return res;
  144. }
  145. if(Count<10){
  146. String dep=sdepNo+"0"+Count;
  147. String sid=adminMapper.selectIdByUserNo(dep);
  148. while(sid!=null){
  149. Count=(Count+1)%100;
  150. if(Count>=10){
  151. dep=sdepNo+Count;
  152. }else{
  153. dep=sdepNo+"0"+Count;
  154. }
  155. sid=adminMapper.selectIdByUserNo(dep);
  156. }
  157. admin.setUserNo(dep);
  158. }
  159. if(Count>=10){
  160. String dep=sdepNo+Count;
  161. String sid=adminMapper.selectIdByUserNo(dep);
  162. while(sid!=null){
  163. Count=(Count+1)%100;
  164. dep=sdepNo+Count;
  165. sid=adminMapper.selectIdByUserNo(dep);
  166. }
  167. admin.setUserNo(dep);
  168. }
  169. Admin ad = new Admin();
  170. BeanUtils.copyProperties(admin, ad);
  171. res = disposeAdminLocationList(res, jo, ad);
  172. if (!res.getError().isEmpty()) {
  173. return res;
  174. }
  175. List<String> roles = new ArrayList<String>();
  176. if (roleIds != null && roleIds.length > 0) {
  177. for (String role : roleIds) {
  178. roles.add(role);
  179. }
  180. }
  181. res.setData(newAdminService.updateByPrimaryKeySelective(ad, roles));
  182. }
  183. return res;
  184. }
  185. /**
  186. * 重置管理员密码
  187. */
  188. @RequestMapping(value = "/resetPwd", method = RequestMethod.POST)
  189. public Result resetPwd(String id) {
  190. Result res = new Result();
  191. if (StringUtils.isBlank(id)) {
  192. res.getError().add(buildError(ErrorConstants.PARAM_ERROR, "", "用户id"));
  193. return res;
  194. }
  195. Admin admin = newAdminService.selectByPrimaryKey(id);
  196. if (null == admin) {
  197. res.getError().add(buildError(ErrorConstants.PARAM_ERROR, "", "用户id"));
  198. return res;
  199. }
  200. Admin a = new Admin();
  201. a.setId(admin.getId());
  202. a.setCreateTime(admin.getCreateTime());
  203. a.setPassword(AFTConstants.INITIALPASSWORD);
  204. a.setPassword(passwordUtil.getEncryptPwd(a));
  205. res.setData(newAdminService.updateByPrimaryKey(a));
  206. return res;
  207. }
  208. private Result disposeAdminLocationList(Result res, JSONObject jo, Admin ad) {
  209. JSONArray locations = jo.getJSONArray("locations");
  210. if (null == locations || locations.size()<1){
  211. return res;
  212. }
  213. List<AdminLocation> adminLocationList = new ArrayList<>();
  214. AdminLocation al = null;
  215. Boolean areaAdminFlag = false;
  216. List<Integer> locationList = null;
  217. if (TokenManager.hasRole(AFTConstants.AREAADMIN)) {
  218. locationList = new ArrayList<>();
  219. areaAdminFlag = true;
  220. }
  221. for (int i = 0; i < locations.size(); i++) {
  222. AdminLocationBo alb = locations.getJSONObject(i).toJavaObject(AdminLocationBo.class);
  223. Integer province = alb.getProvince();
  224. String city = alb.getCity();
  225. if (null == province) {
  226. res.getError().add(buildError(ErrorConstants.PARAM_EMPTY_ERROR, "省份为空", "所在省份"));
  227. return res;
  228. }
  229. if (province.intValue() > AFTConstants.PROVINCEMAXNUM) {
  230. res.getError().add(buildError(ErrorConstants.PARAM_ERROR, "", "所在省份"));
  231. return res;
  232. }
  233. if (areaAdminFlag) {
  234. locationList.add(province);
  235. }
  236. if (!StringUtils.isBlank(city)) {
  237. String[] arr = city.trim().split(",|,");
  238. if (null != arr && arr.length > 0) {
  239. for (String s : arr) {
  240. Integer c = Integer.valueOf(s);
  241. if (c.intValue() > AFTConstants.CITYMAXNUM) {
  242. res.getError().add(buildError(ErrorConstants.PARAM_ERROR, "", "所在市"));
  243. return res;
  244. }
  245. adminLocationList.add(disposeAdminLocation(al, ad, province, c));
  246. if (areaAdminFlag) {
  247. locationList.add(c);
  248. }
  249. }
  250. }
  251. } else {
  252. adminLocationList.add(disposeAdminLocation(al, ad, province, null));
  253. }
  254. }
  255. if (areaAdminFlag) {
  256. List<Integer> albList = disposeAdminLocationBo();
  257. if (!albList.containsAll(locationList)) {
  258. res.getError().add(buildError("", "所选所在地区域不在负责区域,无法添加或修改"));
  259. return res;
  260. }
  261. }
  262. res.setData(adminLocationList);
  263. return res;
  264. }
  265. private AdminLocation disposeAdminLocation(AdminLocation al, Admin ad, Integer province, Integer c) {
  266. al = new AdminLocation();
  267. al.setId(UUID.randomUUID().toString());
  268. al.setAdminId(ad.getId());
  269. al.setProvince(province);
  270. if (null != c) {
  271. al.setCity(c);
  272. }
  273. return al;
  274. }
  275. private List<Integer> disposeAdminLocationBo() {
  276. List<AdminLocationBo> alb = adminLocationService.findLocation(TokenManager.getAdminId());
  277. List<Integer> albList = null;
  278. if (!alb.isEmpty()) {
  279. Integer albProvince = null;
  280. albList = new ArrayList<>();
  281. for (AdminLocationBo bo : alb) {
  282. albProvince = bo.getProvince();
  283. albList.add(albProvince);
  284. if (!StringUtils.isBlank(bo.getCity())) {
  285. String[] albArr = bo.getCity().trim().split(",|,");
  286. if (null != albArr && albArr.length > 0) {
  287. for (String ss : albArr) {
  288. albList.add(Integer.valueOf(ss));
  289. }
  290. }
  291. }
  292. }
  293. }
  294. return albList;
  295. }
  296. /** 图片上传 **/
  297. @RequestMapping(value = "/uploadAdminImg", method = RequestMethod.POST)
  298. public Result uploadCustomerImg(HttpServletRequest req,String sign){
  299. Result res = new Result();
  300. res.setData(handleFile(res, "/customer_sys_file/", false, req, sign));
  301. return res;
  302. }
  303. /**新增获取ID**/
  304. @RequestMapping(value = "/newId", method = RequestMethod.POST)
  305. public Result newId(){
  306. Result res = new Result();
  307. res.setData(UUID.randomUUID().toString());
  308. return res;
  309. }
  310. /**编辑页面信息获取**/
  311. @RequestMapping(value = "/selectAllByid", method = RequestMethod.POST)
  312. public Result selectAllByid(String id){
  313. Result res = new Result();
  314. res.setData(newAdminService.selectAllByid(id));
  315. return res;
  316. }
  317. /**删除用户**/
  318. @RequestMapping(value = "/deleteById", method = RequestMethod.POST)
  319. public Result deleteById(String id){
  320. Result res = new Result();
  321. newAdminService.deleteById(id);
  322. return res;
  323. }
  324. }