package com.zy.crm.manager.controller;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.mapper.Wrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.core.common.DateUtils;
import com.zy.crm.common.utils.FileSaveExampleUtil;
import com.zy.crm.manager.entity.*;
import com.zy.crm.manager.service.*;
import com.core.annotations.ManagerAuth;
import com.core.common.BaseRes;
import com.core.common.Cools;
import com.core.common.R;
import com.core.domain.KeyValueVo;
import com.zy.crm.common.web.BaseController;
import com.zy.crm.system.entity.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.*;

@RestController
public class PlanUrlController extends BaseController {

    @Autowired
    private PlanUrlService planUrlService;

    @Autowired
    private PlanService planService;

    @Autowired
    private PriOnline2Service priOnline2Service;

    @Autowired
    private PriQuoteService priQuoteService;

    @Autowired
    private PlanTypeService planTypeService;

    @Autowired
    private ProcessPermissionsService processPermissionsService;

    Integer PBN = 6;

    @RequestMapping(value = "/plan/url/view/file/auth")
    @ManagerAuth
    public R viewFile(@RequestParam("planId") String planId,@RequestParam("planIdI") String planIdI){
        List<FileSaveExampleUtil.FileDTO> fileDTOS = new ArrayList<>();
        if (Cools.isEmpty(planId)){
            return R.ok(fileDTOS);
        }
        Long id = Long.parseLong(planId);
        Long idPlanIdI = Long.parseLong(planIdI);
        Plan plan = planService.selectById(idPlanIdI);
        PlanType planType = planTypeService.selectById(plan.getPlanType());
        if (plan.getAssistantHostSign()==1){
            planType.setType(1);
        }
//        String savePath = "D:/crm/plan/file/"+id+"/"; // 指定保存文件的路径
        try{
            List<PlanUrl> planUrls = planUrlService.selectPlanUrlByPlanId(id,0,planType.getType(),0);
            for (PlanUrl planUrl : planUrls){
                FileSaveExampleUtil.FileDTO dto = new FileSaveExampleUtil.FileDTO(planUrl);
                fileDTOS.add(dto);
            }
//            List<FileSaveExampleUtil.FileDTO> fileDTOS = FileSaveExampleUtil.viewFileList(savePath);
            return R.ok(fileDTOS);
        }catch (Exception e){
            return R.error();
        }
    }

    @RequestMapping(value = "/plan/url/insert/file/auth")
    @ManagerAuth
    public R insertFile(@RequestParam("planId") String planId, @RequestParam("filename") String filename,
                        @RequestParam("filesize") Long filesize) {
        try {
            User user = getUser();
            String[] split = planId.split("-");
            Long id = Long.parseLong(split[1]);
            Long idPlan = Long.parseLong(split[2]);
            Plan plan = planService.selectById(idPlan);
            PlanType planType = planTypeService.selectById(plan.getPlanType());
            int status = 0;
            if (plan.getUserId().equals(getUserId())){
                status=1;
            }else {
                status=2;
            }
            if (plan.getAssistantHostSign()==1){
                planType.setType(1);
            }
            String url = "http://zhongyang-ftpserver.oss-cn-hangzhou.aliyuncs.com/" + filename;
            PlanUrl planUrl = new PlanUrl(id, url, filename, filesize,user.getNickname(),user.getId(),1,planType.getType(),status);
            planUrlService.insert(planUrl);
            return R.ok();
        } catch (Exception e) {
            System.out.println(e);
            return R.error();
        }
    }

    @RequestMapping(value = "/pri/online/url/view/file/auth")
    @ManagerAuth
    public R viewFilePriOnline(@RequestParam("planId") String planId,@RequestParam("planIdI") String planIdI){
        List<FileSaveExampleUtil.FileDTO> fileDTOS = new ArrayList<>();
        if (Cools.isEmpty(planId)){
            return R.ok(fileDTOS);
        }
        Long id = Long.parseLong(planId);
        Long idPlanIdI = Long.parseLong(planIdI);
        int planType =0;
        Plan plan = planService.selectById(idPlanIdI);
        if (plan.getAssistantHostSign()==1){
            planType=1;
        }else {
            if (!plan.getUserId().equals(getUserId())){
                List<ProcessPermissions> processPermissionsList = processPermissionsService.selectList(new EntityWrapper<ProcessPermissions>().eq("process_memo", 4).or().eq("process_memo", 5));//2：核价流程
                for (ProcessPermissions processPermissions:processPermissionsList){
                    if (getUserId().equals(processPermissions.getUserId())){
                        planType=PBN-processPermissions.getProcessMemo();
                        break;
                    }
                }
            }
        }
//        String savePath = "D:/crm/plan/file/"+id+"/"; // 指定保存文件的路径
        try{
            List<PlanUrl> planUrls = planUrlService.selectPlanUrlByPlanId(id,0,planType,0);
            for (PlanUrl planUrl : planUrls){
                if (!plan.getUserId().equals(getUserId())){
                    if (planUrl.getType()==3){
                        continue;
                    }
                }
                FileSaveExampleUtil.FileDTO dto = new FileSaveExampleUtil.FileDTO(planUrl);
                fileDTOS.add(dto);
            }
//            List<FileSaveExampleUtil.FileDTO> fileDTOS = FileSaveExampleUtil.viewFileList(savePath);
            return R.ok(fileDTOS);
        }catch (Exception e){
            return R.error();
        }
    }

    @RequestMapping(value = "/pri/online/url/insert/file/auth")
    @ManagerAuth
    public R insertFilePriOnline(@RequestParam("planId") String planId, @RequestParam("filename") String filename,
                                 @RequestParam("filesize") Long filesize) {
        try {
            User user = getUser();
            String[] split = planId.split("-");
            Long id = Long.parseLong(split[1]);
            Long idPriOnline = Long.parseLong(split[2]);
            PriOnline2 priOnline2 = priOnline2Service.selectById(idPriOnline);
            Plan plan = planService.selectById(priOnline2.getItemId());
            PlanType planType = planTypeService.selectById(plan.getPlanType());
            int status = 0;
            if (plan.getUserId().equals(getUserId())){
                status=1;
            }else {
                status=2;
            }
            if (plan.getAssistantHostSign()==1){
                planType.setType(1);
            }
            String url = "http://zhongyang-ftpserver.oss-cn-hangzhou.aliyuncs.com/" + filename;
            PlanUrl planUrl = new PlanUrl(id, url, filename, filesize,user.getNickname(),user.getId(),2,planType.getType(),status);
            planUrlService.insert(planUrl);
            return R.ok();
        } catch (Exception e) {
            System.out.println(e);
            return R.error();
        }
    }

    @RequestMapping(value = "/pri/quote/url/view/file/auth")
    @ManagerAuth
    public R viewFilePriQuote(@RequestParam("planId") String planId){
        List<FileSaveExampleUtil.FileDTO> fileDTOS = new ArrayList<>();
        if (Cools.isEmpty(planId)){
            return R.ok(fileDTOS);
        }
        Long id = Long.parseLong(planId);
//        String savePath = "D:/crm/plan/file/"+id+"/"; // 指定保存文件的路径
        try{
            List<PlanUrl> planUrls = planUrlService.selectPlanUrlByPlanId(id,0,0,0);
            for (PlanUrl planUrl : planUrls){
                FileSaveExampleUtil.FileDTO dto = new FileSaveExampleUtil.FileDTO(planUrl);
                fileDTOS.add(dto);
            }
//            List<FileSaveExampleUtil.FileDTO> fileDTOS = FileSaveExampleUtil.viewFileList(savePath);
            return R.ok(fileDTOS);
        }catch (Exception e){
            return R.error();
        }
    }

    @RequestMapping(value = "/pri/quote/url/insert/file/auth")
    @ManagerAuth
    public R insertFilePriQuote(@RequestParam("planId") String planId, @RequestParam("filename") String filename,
                                @RequestParam("filesize") Long filesize) {
        try {
            User user = getUser();
            String[] split = planId.split("-");
            Long id = Long.parseLong(split[1]);
            Long idPriQuote = Long.parseLong(split[2]);
            PriQuote priQuote = priQuoteService.selectById(idPriQuote);
            Plan plan = planService.selectById(priQuote.getItemId());
            PlanType planType = planTypeService.selectById(plan.getPlanType());
            int status = 0;
            if (plan.getUserId().equals(getUserId())){
                status=1;
            }else {
                status=2;
            }
            if (plan.getAssistantHostSign()==1){
                planType.setType(1);
            }
            String url = "http://zhongyang-ftpserver.oss-cn-hangzhou.aliyuncs.com/" + filename;
            PlanUrl planUrl = new PlanUrl(id, url, filename, filesize,user.getNickname(),user.getId(),3,planType.getType(),status);
            planUrlService.insert(planUrl);
            return R.ok();
        } catch (Exception e) {
            System.out.println(e);
            return R.error();
        }
    }


//    @RequestMapping(value = "/planUrl/{id}/auth")
//    @ManagerAuth
//    public R get(@PathVariable("id") String id) {
//        return R.ok(planUrlService.selectById(String.valueOf(id)));
//    }
//
//    @RequestMapping(value = "/planUrl/list/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<PlanUrl> wrapper = new EntityWrapper<>();
//        excludeTrash(param);
//        convert(param, wrapper);
//        allLike(PlanUrl.class, param.keySet(), wrapper, condition);
//        if (!Cools.isEmpty(orderByField)){wrapper.orderBy(humpToLine(orderByField), "asc".equals(orderByType));}
//        return R.ok(planUrlService.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);
//            }
//        }
//    }
//
//    @RequestMapping(value = "/planUrl/add/auth")
//    @ManagerAuth
//    public R add(PlanUrl planUrl) {
//        planUrlService.insert(planUrl);
//        return R.ok();
//    }
//
//	@RequestMapping(value = "/planUrl/update/auth")
//	@ManagerAuth
//    public R update(PlanUrl planUrl){
//        if (Cools.isEmpty(planUrl) || null==planUrl.getId()){
//            return R.error();
//        }
//        planUrlService.updateById(planUrl);
//        return R.ok();
//    }
//
//    @RequestMapping(value = "/planUrl/delete/auth")
//    @ManagerAuth
//    public R delete(@RequestParam(value="ids[]") Long[] ids){
//         for (Long id : ids){
//            planUrlService.deleteById(id);
//        }
//        return R.ok();
//    }
//
//    @RequestMapping(value = "/planUrl/export/auth")
//    @ManagerAuth
//    public R export(@RequestBody JSONObject param){
//        EntityWrapper<PlanUrl> wrapper = new EntityWrapper<>();
//        List<String> fields = JSONObject.parseArray(param.getJSONArray("fields").toJSONString(), String.class);
//        Map<String, Object> map = excludeTrash(param.getJSONObject("planUrl"));
//        convert(map, wrapper);
//        List<PlanUrl> list = planUrlService.selectList(wrapper);
//        return R.ok(exportSupport(list, fields));
//    }
//
//    @RequestMapping(value = "/planUrlQuery/auth")
//    @ManagerAuth
//    public R query(String condition) {
//        EntityWrapper<PlanUrl> wrapper = new EntityWrapper<>();
//        wrapper.like("id", condition);
//        Page<PlanUrl> page = planUrlService.selectPage(new Page<>(0, 10), wrapper);
//        List<Map<String, Object>> result = new ArrayList<>();
//        for (PlanUrl planUrl : page.getRecords()){
//            Map<String, Object> map = new HashMap<>();
//            map.put("id", planUrl.getId());
//            map.put("value", planUrl.getId());
//            result.add(map);
//        }
//        return R.ok(result);
//    }
//
//    @RequestMapping(value = "/planUrl/check/column/auth")
//    @ManagerAuth
//    public R query(@RequestBody JSONObject param) {
//        Wrapper<PlanUrl> wrapper = new EntityWrapper<PlanUrl>().eq(humpToLine(String.valueOf(param.get("key"))), param.get("val"));
//        if (null != planUrlService.selectOne(wrapper)){
//            return R.parse(BaseRes.REPEAT).add(getComment(PlanUrl.class, String.valueOf(param.get("key"))));
//        }
//        return R.ok();
//    }
//
//    @RequestMapping("/planUrl/all/get/kv")
//    @ManagerAuth
//    public R getDataKV(@RequestParam(required = false) String condition) {
//        List<KeyValueVo> vos = new ArrayList<>();
//        Wrapper<PlanUrl> wrapper = new EntityWrapper<PlanUrl>().andNew().like("id", condition).orderBy("create_time", false);
//        planUrlService.selectPage(new Page<>(1, 30), wrapper).getRecords().forEach(item -> vos.add(new KeyValueVo(String.valueOf(item.getId()), item.getId())));
//        return R.ok().add(vos);
//    }

}