package com.ltkj.web.tduck;

import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.ltkj.common.core.domain.AjaxResult;
import com.ltkj.common.utils.SecurityUtils;
import com.ltkj.common.utils.http.HttpUtils;
import com.ltkj.tduck.domain.UserFormDataEntity;
import com.ltkj.tduck.domain.UserFormViewCountEntity;
import com.ltkj.tduck.request.QueryFormResultRequest;
import com.ltkj.tduck.service.UserFormDataService;
import com.ltkj.tduck.service.UserFormViewCountService;
import com.ltkj.tduck.utils.Result;
import com.ltkj.tduck.utils.ValidatorUtils;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;

import javax.annotation.security.PermitAll;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;


/**
 * 表单数据
 *
 * @author : smalljop
 * @description : 表单数据页 当前用户自己使用接口
 * @create : 2020-11-18 18:17
 **/

@Slf4j
@RestController
@RequiredArgsConstructor
@RequestMapping("/user/form/data")
public class UserFormResultController {
    private final UserFormDataService formResultService;
//    private final UserFormSettingService userFormSettingService;
//    private final FormDataImportUtils formDataImportUtils;
//    private final FormDataExportUtils formDataExportUtils;
//    private final UserFormService userFormService;
    private final UserFormViewCountService userFormViewCountService;
//    private final MailService mailService;
//    private final WxMpUserMsgService userMsgService;
    private final ConcurrentMap<String, Integer> viewFormMap = new ConcurrentHashMap<>();



    /**
     * 根据体检号获取问卷记录
     */
    @GetMapping("getRecordByTjNumber")
    public AjaxResult getRecordByTjNumber(String tjNumber) {
        LambdaQueryWrapper<UserFormDataEntity> wq=new LambdaQueryWrapper<>();
        wq.eq(UserFormDataEntity::getTjNumber,tjNumber);
        final List<UserFormDataEntity> list = formResultService.list(wq);
        AjaxResult ajaxResult = new AjaxResult();
        ajaxResult.put("code", 200);
        ajaxResult.put("data", list);
        ajaxResult.put("msg", null);
        return ajaxResult;
    }


    /***
     * 查看表单
     * 记录查看的IP 统计查看用户数
     */
    @GetMapping("view/{formKey}")
    @PermitAll
    public Result<Void> viewForm(HttpServletRequest request, @PathVariable("formKey") String formKey) {
        if (viewFormMap.containsKey(formKey)) {
            userFormViewCountService.increment(formKey);
        } else {
            // 不存在则添加
            Long count = userFormViewCountService.count(formKey);
            if (count == 0) {
                UserFormViewCountEntity entity = new UserFormViewCountEntity();
                entity.setFormKey(formKey);
                entity.setCount(1L);
                userFormViewCountService.save(entity);
            }
            viewFormMap.put(formKey, 1);
        }
        return Result.success();
    }

    /**
     * 查询数据
     *
     * @param request 查询条件
     * @return 数据
     */
    @PostMapping("query")
    public Result queryFormDataTable(@RequestBody QueryFormResultRequest request) {
//        FormAuthUtils.hasPermission(request.getFormKey());
        return Result.success(formResultService.listFormDataTable(request));
    }

    /**
     * 获取某条数据详情
     *
     * @param dataId 数据ID
     * @return 数据详情
     */
    @GetMapping("details/{dataId}")
    @PermitAll
    public Result getFormDataDetails(@PathVariable("dataId") String dataId) {
        return formResultService.getFormDataDetails(dataId);
    }
//
//
//    /**
//     * 填写附件导出
//     *
//     * @param request 请求
//     * @return 文件
//     */
//    @PostMapping("/download/file")
//    public Result downloadFormResultFile(@RequestBody QueryFormResultRequest request) {
//        return formResultService.downloadFormResultFile(request);
//    }

    /**
     * 填写
     *
     * @param entity  填写数据
     * @param request 请求
     * @return
     */
    @PostMapping("/create")
    public AjaxResult createFormResult(@RequestBody UserFormDataEntity entity, HttpServletRequest request) {
        ValidatorUtils.validateEntity(entity);
        entity.setSubmitRequestIp(HttpUtils.getIpAddr(request));
        // 如果已经登陆了也记录用户信息 try catch 避免抛出异常
        entity.setCreateBy(SecurityUtils.getUserId() != null ? String.valueOf(SecurityUtils.getUserId()) : null);
        Map<String, Object> result = formResultService.saveFormResult(entity);
        return AjaxResult.success(result);
    }


    /**
     * 公开填写
     *
     * @param entity  填写数据
     * @param request 请求
     */
    @PostMapping("/public/create")
    @PermitAll
    public Result<Map<String, Object>> createPublicFormResult(@RequestBody UserFormDataEntity entity, HttpServletRequest request) {

        ValidatorUtils.validateEntity(entity);
        entity.setSubmitRequestIp(HttpUtils.getIpAddr(request));
//        Result<Boolean> userFormSettingStatus = userFormSettingService.getUserFormWriteSettingStatus(entity.getFormKey(), entity.getSubmitRequestIp(), entity.getWxOpenId(), CommonConstants.ConstantNumber.ONE);
//        if (StrUtil.isNotBlank(userFormSettingStatus.getMsg())) {
//            return Result.failed(userFormSettingStatus.getMsg());
//        }
        // 如果已经登陆了也记录用户信息 try catch 避免抛出异常
        entity.setCreateBy(SecurityUtils.getUserId() != null ? String.valueOf(SecurityUtils.getUserId()) : null);
        Map<String, Object> result = formResultService.saveFormResult(entity);
//        ThreadUtil.execAsync(() -> {
//            sendWriteResultNotify(entity.getFormKey());
//        });
        return Result.success(result);
//        return Result.success();
    }

//
//    /**
//     * 批量删除
//     *
//     * @param formKey    表单key
//     * @param dataIdList 数据ID
//     * @return Result
//     */
//    @PostMapping("/delete/{formKey}")
//    public Result deleteFormData(@RequestBody List<String> dataIdList, @PathVariable("formKey") String formKey) {
//        formResultService.deleteByIds(dataIdList, formKey);
//        return Result.success();
//    }


//    /**
//     * 更新
//     *
//     * @param entity  填写数据
//     * @param request 请求
//     * @return Result
//     */
//    @PostMapping("/update")
//    @PermitAll
//    public Result<Void> updateFormResult(@RequestBody UserFormDataEntity entity, HttpServletRequest request) {
//        ValidatorUtils.validateEntity(entity);
//        try {
//            entity.setUpdateBy(String.valueOf(SecurityUtils.getUserId()));
//        } catch (Exception ignored) {
//        }
//        formResultService.updateFormResult(entity);
//        return Result.success();
//    }
//
//    /**
//     * 下载导入模板
//     *
//     * @param response 响应
//     * @param formKey  表单key
//     */
//    @GetMapping("/import/template")
//    public void downloadImportTemplate(HttpServletResponse response, String formKey) {
//        formDataImportUtils.importTemplateExcel(response, formKey);
//    }
//
//    /**
//     * 导出表单数据
//     */
//    @PostMapping("export")
//    public void exportFormData(@RequestBody ExportRequest.FormData exportRequest) {
//        formDataExportUtils.exportData(exportRequest);
//    }
//
//    /**
//     * 导入表单数据
//     *
//     * @param file 文件
//     * @return Result
//     */
//    @PostMapping("import")
//    public Result importFormData(@RequestParam("file") MultipartFile file, UserFormDataEntity dataEntity) throws IOException {
//        return Result.success(formDataImportUtils.importFile(file.getInputStream(), dataEntity.getFormKey()));
//    }
//
//
//    private void sendWriteResultNotify(String formKey) {
//        FormSettingSchemaStruct formSettingSchema = userFormSettingService.getFormSettingSchema(formKey);
//        if (ObjectUtil.isNull(formSettingSchema)) {
//            return;
//        }
//        UserFormEntity form = userFormService.getByKey(formKey);
//        if (StrUtil.isNotBlank(formSettingSchema.getNewWriteNotifyEmail())) {
//            mailService.sendTemplateHtmlMail(formSettingSchema.getNewWriteNotifyEmail(), "新回复通知", "mail/form-write-notify", MapUtil.of("projectName", form.getName()));
//        }
//
//        if (StrUtil.isNotBlank(formSettingSchema.getNewWriteNotifyWx())) {
//            List<String> openIdList = StrUtil.splitTrim(formSettingSchema.getNewWriteNotifyWx(), ";");
//            openIdList.stream().forEach(openId -> {
//                userMsgService.sendKfTextMsg("", openId, "收到新的反馈，请去Pc端查看");
//            });
//        }
//    }

}