| | |
| | | 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.manager.service.CstmrFollService; |
| | | import com.zy.crm.manager.service.CstmrService; |
| | | import com.zy.crm.manager.service.CstmrTypeService; |
| | | import com.zy.crm.system.entity.Dept; |
| | | 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.DeptService; |
| | | import com.zy.crm.system.service.DicService; |
| | | import com.zy.crm.system.service.UserService; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import lombok.val; |
| | | import org.apache.poi.hssf.usermodel.HSSFWorkbook; |
| | | import org.apache.poi.ss.usermodel.DataFormatter; |
| | | import org.apache.poi.ss.usermodel.Row; |
| | |
| | | import org.springframework.web.multipart.MultipartFile; |
| | | |
| | | import javax.servlet.http.HttpServletResponse; |
| | | import java.io.IOException; |
| | | import java.io.InputStream; |
| | | import java.io.*; |
| | | import java.lang.reflect.Array; |
| | | import java.util.*; |
| | | |
| | | @Slf4j |
| | |
| | | private CstmrTypeService cstmrTypeService; |
| | | @Autowired |
| | | private DicService dicService; |
| | | @Autowired |
| | | private DeptService deptService; |
| | | |
| | | @RequestMapping(value = "/cstmr/{id}/auth") |
| | | @ManagerAuth |
| | |
| | | @ManagerAuth |
| | | public R page(@RequestParam(defaultValue = "1") Integer curr, |
| | | @RequestParam(defaultValue = "10") Integer limit, |
| | | @RequestParam(required = false) String followerName, |
| | | @RequestParam(required = false) String conditionName, |
| | | @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) |
| | | List<Integer> ids = new ArrayList<>(); |
| | | if (!Cools.isEmpty(followerName)){ |
| | | User username = userService.selectOne(new EntityWrapper<User>().eq("username", followerName)); |
| | | if (!Cools.isEmpty(username)){ |
| | | List<Integer> cstmrIds = cstmrFollService.selectCstmrIdUserId(username.getId().intValue()); |
| | | for (Integer id : cstmrIds){ |
| | | ids.add(id); |
| | | } |
| | | }else { |
| | | return R.error("未查询到跟进人信息!"); |
| | | } |
| | | } |
| | | if (!Cools.isEmpty(conditionName)){ |
| | | switch (conditionName){ |
| | | case "director": |
| | | try { |
| | | condition=userService.selectOne(new EntityWrapper<User>().eq("username", condition)).getId().toString(); |
| | | }catch (Exception e){ |
| | | conditionName = null; |
| | | } |
| | | break; |
| | | default: |
| | | |
| | | } |
| | | } |
| | | return R.ok(cstmrService.getPage3(new Page<>(curr, limit) |
| | | , getHostId() |
| | | , deptId == null ? null : String.valueOf(deptId) |
| | | , userId == null ? getUserId() : userId |
| | | , Cools.isEmpty(followerName) ? null : ids |
| | | , conditionName |
| | | , condition) |
| | | ); |
| | | } |
| | |
| | | @RequestMapping(value = "/cstmr/delete/auth") |
| | | @ManagerAuth |
| | | public R delete(@RequestParam(value="ids[]") Long[] ids){ |
| | | for (Long id : ids){ |
| | | for (Long id : ids){ |
| | | cstmrService.deleteById(id); |
| | | } |
| | | return R.ok(); |
| | | } |
| | | |
| | | |
| | | |
| | | @RequestMapping(value = "/cstmrQuery/auth") |
| | | @ManagerAuth |
| | |
| | | return R.ok("添加成功"); |
| | | } |
| | | |
| | | |
| | | @RequestMapping(value = "/cstmr/followers/add/json") |
| | | @ManagerAuth |
| | | @Transactional |
| | | public R cstmrFollowersAddJson(@RequestBody() Map map) { |
| | | long cstmrId = Long.valueOf(String.valueOf(map.get("cstmrId"))); |
| | | long followerIds = Long.valueOf(String.valueOf(map.get("followerIds"))); |
| | | if (Cools.isEmpty(cstmrId, followerIds)) { |
| | | return R.parse(BaseRes.PARAM); |
| | | } |
| | | CstmrFoll cstmrFoll = new CstmrFoll(); |
| | | cstmrFoll.setCstmrId(cstmrId); |
| | | cstmrFoll.setUserId(followerIds); |
| | | if (!cstmrFollService.insert(cstmrFoll)) { |
| | | throw new CoolException("添加失败,请联系管理员"); |
| | | } |
| | | return R.ok("添加成功"); |
| | | } |
| | | |
| | | @RequestMapping(value = "/cstmr/followers/remove/auth") |
| | | @ManagerAuth |
| | | public R cstmrFollowersRemove(@RequestParam("cstmrId") Long cstmrId, |
| | |
| | | @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<>(); |
| | | Wrapper<Cstmr> wrapper = new EntityWrapper<Cstmr>().andNew().like("name", condition).or().like("uuid", condition).orderBy("create_time", false); |
| | | cstmrService.selectPage(new Page<>(1, 30), wrapper).getRecords().forEach(item -> vos.add(new KeyValueVo(item.getName(), item.getId()))); |
| | | page.getRecords().forEach(item -> vos.add(new KeyValueVo(item.getName(), item.getId()))); |
| | | return R.ok().add(vos); |
| | | } |
| | | |
| | | @RequestMapping("/cstmr/file/import") |
| | | @Transactional |
| | | public R fileImport() throws IOException { |
| | | File file = new File("D:\\tmp\\跟进人.xls"); |
| | | InputStream inStream = new FileInputStream(file); |
| | | int excelVersion = 2007; |
| | | Workbook book = null; |
| | | book = new HSSFWorkbook(inStream); |
| | | Sheet sheet = book.getSheetAt(0); |
| | | int totalRows = sheet.getLastRowNum() + 1; // 总 |
| | | DataFormatter dataFormatter = new DataFormatter(); |
| | | for (int i = 1; i < totalRows; i++) { |
| | | System.out.println(i); |
| | | Row row = sheet.getRow(i); |
| | | // 客户代号 |
| | | String username = dataFormatter.formatCellValue(row.getCell(0)); |
| | | System.out.println(username); |
| | | if (username.equals("甘全") || username.equals("陆晓东") |
| | | || username.equals("张天林") || username.equals("陈鹏") || username.equals("赵雪生") |
| | | || username.equals("张俊良(离职)") |
| | | ) { continue;} |
| | | String cstmrUuid = dataFormatter.formatCellValue(row.getCell(2)); |
| | | System.out.println(cstmrUuid); |
| | | |
| | | User user = userService.selectOne(new EntityWrapper<User>().eq("nickname", username)); |
| | | if (null == user) { |
| | | throw new CoolException(username + "错误"); |
| | | } |
| | | Cstmr cstmr = cstmrService.selectByUuid(null, cstmrUuid); |
| | | if (null == cstmr) { |
| | | throw new CoolException(cstmrUuid + "错误"); |
| | | } |
| | | CstmrFoll cstmrFoll = new CstmrFoll(); |
| | | cstmrFoll.setCstmrId(cstmr.getId()); |
| | | cstmrFoll.setUserId(user.getId()); |
| | | if (!cstmrFollService.insert(cstmrFoll)) { |
| | | throw new CoolException("添加失败,请联系管理员"); |
| | | } |
| | | } |
| | | return R.ok(); |
| | | } |
| | | |
| | | } |