#

luxiaotao1123

2022-11-19 07fcb01a51bf4b9102b41e9223d66b16af9548f8

 src/main/java/com/zy/crm/manager/controller/PlanController.java

@@ -9,16 +9,29 @@
import com.core.common.Cools;
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.FollowerTableVo;
import com.zy.crm.manager.entity.Plan;
import com.zy.crm.manager.entity.PlanFoll;
import com.zy.crm.manager.service.PlanFollService;
import com.zy.crm.manager.service.PlanService;
import com.zy.crm.system.entity.User;
import com.zy.crm.system.service.UserService;
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
import org.apache.poi.ss.usermodel.DataFormatter;
import org.apache.poi.ss.usermodel.Sheet;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.InputStream;
import java.util.*;

@RestController
public class PlanController extends BaseController {
@@ -50,6 +63,13 @@
    @RequestMapping(value = "/plan/add/auth")
    @ManagerAuth
    public R add(Plan plan) {

        plan.setCreateBy(getUserId());
        plan.setCreateTime(new Date());
        plan.setUpdateBy(getUserId());
        plan.setUpdateTime(new Date());
        plan.setStatus(1);

        planService.insert(plan);
        return R.ok();
    }
@@ -60,6 +80,8 @@
        if (Cools.isEmpty(plan) || null==plan.getId()){
            return R.error();
        }
        plan.setUpdateBy(getUserId());
        plan.setUpdateTime(new Date());
        planService.updateById(plan);
        return R.ok();
    }
@@ -108,4 +130,103 @@
        return R.ok().add(vos);
    }

    /*************************************** 数据相关 ***********************************************/

    /**
     * excel导入
     */
    @PostMapping(value = "/plan/excel/import/auth")
    @ManagerAuth(memo = "甲方单位Excel导入")
//    @Transactional
    public R planExcelImport(MultipartFile file) throws IOException {
        InputStream inStream = file.getInputStream();
        String fileMime = file.getContentType();
        int excelVersion = 2007;
        if ("application/vnd.ms-excel".equals(fileMime)) {
            excelVersion = 2003;
        }
        Workbook book = null;
        if (excelVersion == 2003) {
            book = new HSSFWorkbook(inStream);
        }
        else {  // 当 excel 是 2007 时
            book = new XSSFWorkbook(inStream);
        }
        Sheet sheet = book.getSheetAt(0);
        int totalRows = sheet.getLastRowNum() + 1;    // 总
        Long userId = getUserId();
        Long hostId = getHostId();
        Long deptId = getDeptId();
        Date now = new Date();
        DataFormatter dataFormatter = new DataFormatter();
        for (int i = 2; i < totalRows; i++) {
        }
        return R.ok();
    }

    /**
     * excel导出
     */
    @PostMapping(value = "/plan/excel/export/auth")
    @ManagerAuth
    public void planExcelExport(HttpServletResponse response) throws IOException {

    }

    /******************************** 跟进人 ***************************************/

    @Autowired
    private PlanFollService planFollService;
    @Autowired
    private UserService userService;

    @RequestMapping(value = "/plan/followers/table/auth")
    @ManagerAuth
    public R planFollowersTable(@RequestParam("orderId") Long orderId) {
        List<PlanFoll> planFolls = planFollService.selectList(new EntityWrapper<PlanFoll>().eq("plan_id", orderId).orderBy("id", false));
        List<FollowerTableVo> result = new ArrayList<>();
        for (PlanFoll planFoll : planFolls) {
            User user = userService.selectById(planFoll.getUserId());
            FollowerTableVo vo = new FollowerTableVo();
            vo.setUserId(user.getId());
            vo.setUserName(user.getNickname());
            result.add(vo);
        }
        return R.ok().add(result);
    }

    @RequestMapping(value = "/plan/followers/add/auth")
    @ManagerAuth
    @Transactional
    public R planFollowersAdd(@RequestParam("orderId") Long orderId,
                               @RequestParam("followerIds[]") Long[] followerIds) {
        if (Cools.isEmpty(orderId, followerIds)) {
            return R.parse(BaseRes.PARAM);
        }
        for (Long userId : followerIds) {
            if (planFollService.selectCount(new EntityWrapper<PlanFoll>().eq("plan_id", orderId).eq("user_id", userId)) == 0) {
                PlanFoll planFoll = new PlanFoll();
                planFoll.setPlanId(orderId);
                planFoll.setUserId(userId);
                if (!planFollService.insert(planFoll)) {
                    throw new CoolException("添加失败，请联系管理员");
                }
            }
        }
        return R.ok("添加成功");
    }

    @RequestMapping(value = "/plan/followers/remove/auth")
    @ManagerAuth
    public R planFollowersRemove(@RequestParam("orderId") Long orderId,
                                  @RequestParam("userId") Long userId) {
        if (Cools.isEmpty(orderId, userId)) {
            return R.parse(BaseRes.PARAM);
        }
        if (!planFollService.delete(new EntityWrapper<PlanFoll>().eq("plan_id", orderId).eq("user_id", userId))) {
            throw new CoolException("删除失败，请联系管理员");
        }
        return R.ok("删除成功");
    }

}