| | |
| | | import com.core.annotations.ManagerAuth; |
| | | import com.core.common.BaseRes; |
| | | import com.core.common.Cools; |
| | | import com.core.common.DateUtils; |
| | | import com.core.common.R; |
| | | import com.core.domain.KeyValueVo; |
| | | import com.core.exception.CoolException; |
| | | import com.zy.crm.common.web.BaseController; |
| | | import com.zy.crm.manager.controller.result.CstmrFollowerTableVo; |
| | | import com.zy.crm.manager.controller.result.FollowerTableVo; |
| | | import com.zy.crm.manager.entity.Cstmr; |
| | | import com.zy.crm.manager.entity.CstmrFoll; |
| | | import com.zy.crm.manager.entity.CstmrType; |
| | |
| | | import com.zy.crm.manager.service.CstmrService; |
| | | import com.zy.crm.manager.service.CstmrTypeService; |
| | | import com.zy.crm.system.entity.Dic; |
| | | import com.zy.crm.system.entity.Role; |
| | | import com.zy.crm.system.entity.User; |
| | | import com.zy.crm.system.service.DicService; |
| | | import com.zy.crm.system.service.UserService; |
| | |
| | | return R.ok(cstmrService.selectById(String.valueOf(id))); |
| | | } |
| | | |
| | | @RequestMapping(value = "/cstmr/list/auth") |
| | | @RequestMapping(value = "/cstmr/page/auth") |
| | | @ManagerAuth |
| | | public R list(@RequestParam(defaultValue = "1")Integer curr, |
| | | @RequestParam(defaultValue = "10")Integer limit, |
| | | @RequestParam(required = false)String orderByField, |
| | | @RequestParam(required = false)String orderByType, |
| | | @RequestParam(required = false)String condition, |
| | | @RequestParam Map<String, Object> param){ |
| | | EntityWrapper<Cstmr> wrapper = new EntityWrapper<>(); |
| | | excludeTrash(param); |
| | | convert(param, wrapper); |
| | | hostEq(wrapper); |
| | | allLike(Cstmr.class, param.keySet(), wrapper, condition); |
| | | if (!Cools.isEmpty(orderByField)){wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));} else { |
| | | wrapper.orderBy("create_time", false); |
| | | } |
| | | if (!Cools.isEmpty(param.get("dept_id"))) { |
| | | return R.ok(cstmrService.getPage(new Page<>(curr, limit) |
| | | , getHostId() |
| | | , String.valueOf(param.get("dept_id")) |
| | | , condition) |
| | | ); |
| | | } else { |
| | | if (Cools.isEmpty(param.get("user_id"))) { |
| | | wrapper.andNew(); |
| | | wrapper.eq("user_id", getUserId()); |
| | | } |
| | | return R.ok(cstmrService.selectPage(new Page<>(curr, limit), wrapper)); |
| | | } |
| | | } |
| | | |
| | | private <T> void convert(Map<String, Object> map, EntityWrapper<T> wrapper){ |
| | | for (Map.Entry<String, Object> entry : map.entrySet()){ |
| | | String val = String.valueOf(entry.getValue()); |
| | | if (val.contains(RANGE_TIME_LINK)){ |
| | | String[] dates = val.split(RANGE_TIME_LINK); |
| | | wrapper.ge(entry.getKey(), DateUtils.convert(dates[0])); |
| | | wrapper.le(entry.getKey(), DateUtils.convert(dates[1])); |
| | | } else { |
| | | wrapper.like(entry.getKey(), val); |
| | | } |
| | | } |
| | | public R page(@RequestParam(defaultValue = "1") Integer curr, |
| | | @RequestParam(defaultValue = "10") Integer limit, |
| | | @RequestParam(required = false) String condition, |
| | | @RequestParam(required = false, value = "dept_id") Long deptId, |
| | | @RequestParam(required = false, value = "user_id") Long userId){ |
| | | return R.ok(cstmrService.getPage(new Page<>(curr, limit) |
| | | , getHostId() |
| | | , deptId == null ? null : String.valueOf(deptId) |
| | | , userId == null ? getUserId() : userId |
| | | , condition) |
| | | ); |
| | | } |
| | | |
| | | @RequestMapping(value = "/cstmr/add/auth") |
| | |
| | | cstmrService.deleteById(id); |
| | | } |
| | | return R.ok(); |
| | | } |
| | | |
| | | @RequestMapping(value = "/cstmr/export/auth") |
| | | @ManagerAuth |
| | | public R export(@RequestBody JSONObject param){ |
| | | EntityWrapper<Cstmr> wrapper = new EntityWrapper<>(); |
| | | List<String> fields = JSONObject.parseArray(param.getJSONArray("fields").toJSONString(), String.class); |
| | | Map<String, Object> map = excludeTrash(param.getJSONObject("cstmr")); |
| | | convert(map, wrapper); |
| | | List<Cstmr> list = cstmrService.selectList(wrapper); |
| | | return R.ok(exportSupport(list, fields)); |
| | | } |
| | | |
| | | @RequestMapping(value = "/cstmrQuery/auth") |
| | |
| | | @RequestMapping(value = "/cstmr/followers/table/auth") |
| | | @ManagerAuth |
| | | public R cstmrFollowersTable(@RequestParam("cstmrId") Long cstmrId) { |
| | | List<CstmrFoll> cstmrFolls = cstmrFollService.selectList(new EntityWrapper<CstmrFoll>().eq("cstmr_id", cstmrId)); |
| | | List<CstmrFollowerTableVo> result = new ArrayList<>(); |
| | | List<CstmrFoll> cstmrFolls = cstmrFollService.selectList(new EntityWrapper<CstmrFoll>().eq("cstmr_id", cstmrId).orderBy("id", false)); |
| | | List<FollowerTableVo> result = new ArrayList<>(); |
| | | for (CstmrFoll cstmrFoll : cstmrFolls) { |
| | | User user = userService.selectById(cstmrFoll.getUserId()); |
| | | CstmrFollowerTableVo vo = new CstmrFollowerTableVo(); |
| | | FollowerTableVo vo = new FollowerTableVo(); |
| | | vo.setUserId(user.getId()); |
| | | vo.setUserName(user.getNickname()); |
| | | result.add(vo); |
| | |
| | | return R.ok("添加成功"); |
| | | } |
| | | |
| | | @RequestMapping(value = "/cstmr/followers/remove/auth") |
| | | @ManagerAuth |
| | | public R cstmrFollowersRemove(@RequestParam("cstmrId") Long cstmrId, |
| | | @RequestParam("userId") Long userId) { |
| | | if (Cools.isEmpty(cstmrId, userId)) { |
| | | return R.parse(BaseRes.PARAM); |
| | | } |
| | | if (!cstmrFollService.delete(new EntityWrapper<CstmrFoll>().eq("cstmr_id", cstmrId).eq("user_id", userId))) { |
| | | throw new CoolException("删除失败,请联系管理员"); |
| | | } |
| | | return R.ok("删除成功"); |
| | | } |
| | | |
| | | @RequestMapping("/cstmr/all/get/kv") |
| | | @ManagerAuth |
| | | public R getDataKV(@RequestParam(required = false) String condition) { |
| | | User user = getUser(); assert user != null; |
| | | Role role = getRole(); assert role != null; |
| | | Page<Cstmr> page = cstmrService.getPage(new Page<>(1, 30) |
| | | , getHostId() |
| | | , role.judgeLeader() ? String.valueOf(user.getDeptId()) : null |
| | | , user.getId() |
| | | , condition); |
| | | List<KeyValueVo> vos = new ArrayList<>(); |
| | | page.getRecords().forEach(item -> vos.add(new KeyValueVo(item.getName(), item.getId()))); |
| | | return R.ok().add(vos); |
| | | } |
| | | |
| | | } |