package com.ltkj.tduck.service.impl;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.map.MapUtil;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ltkj.common.utils.ip.AddressUtils;
import com.ltkj.tduck.constant.CommonConstants;
import com.ltkj.tduck.domain.UserFormDataEntity;
import com.ltkj.tduck.mapper.UserFormDataMapper;
import com.ltkj.tduck.request.QueryFormResultRequest;
import com.ltkj.tduck.service.UserFormDataService;
import com.ltkj.tduck.service.UserFormItemService;
import com.ltkj.tduck.utils.CacheUtils;
import com.ltkj.tduck.utils.FormDataUtils;
import com.ltkj.tduck.utils.Result;
import com.ltkj.tduck.vo.FormDataTableVO;
import com.ltkj.tduck.vo.FormFieldVO;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

import static com.ltkj.tduck.constant.FormRedisKeyConstants.FORM_RESULT_NUMBER;


/**
 * 表单表单项(FormResult)表服务实现类
 *
 * @author smalljop
 * @since 2020-11-23 14:09:22
 */
@Service
@Slf4j
@RequiredArgsConstructor
public class UserFormDataServiceImpl extends ServiceImpl<UserFormDataMapper, UserFormDataEntity> implements UserFormDataService {

    private final UserFormItemService userFormItemService;
    private final CacheUtils redisUtils;
    private final FormDataUtils formDataUtils;


    @Override
    @Transactional(rollbackFor = Exception.class)
    public Map<String, Object> saveFormResult(UserFormDataEntity entity) {
        HashMap<String, Object> result = MapUtil.newHashMap();
        String formKey = entity.getFormKey();
        entity.setSubmitAddress(AddressUtils.getRealAddressByIP(entity.getSubmitRequestIp()));
        entity.setSerialNumber(redisUtils.incr(StrUtil.format(FORM_RESULT_NUMBER, formKey), CommonConstants.ConstantNumber.ONE));
        this.save(entity);
//        formDataUtils.syncSaveFormData(entity);
        result.put("id", entity.getId());
        return result;
    }


    /**
     * 下载表单结果中的附件
     *
     * @param request
     * @return
     */
//    @Override
//    public Result downloadFormResultFile(QueryFormResultRequest request) {
//        String uuid = IdUtil.simpleUUID();
//        List<UserFormItemEntity> userFormItemEntityList = userFormItemService.list(Wrappers.<UserFormItemEntity>lambdaQuery().eq(UserFormItemEntity::getFormKey, request.getFormKey()).in(UserFormItemEntity::getType, CollUtil.newArrayList(FormItemTypeEnum.UPLOAD.toString(), FormItemTypeEnum.IMAGE_UPLOAD.toString())));
//        //结果
//        List<Map> rows = null;
//        if (ObjectUtil.isNull(request.getCurrent()) && ObjectUtil.isNull(request.getSize())) {
//            rows = formDataUtils.searchAll(request);
//        } else {
//            FormDataTableVO formDataTableVO = this.listFormDataTable(request);
//            rows = formDataTableVO.getRows();
//        }
//        if (CollectionUtil.isEmpty(rows) || CollectionUtil.isEmpty(userFormItemEntityList)) {
//            return Result.failed("暂无收集附件，无法下载");
//        }
//        List<Map> finalRows = rows;
//        ThreadUtil.execAsync(() -> {
//            TimeInterval timer = DateUtil.timer();
//            List<String> paths = new ArrayList<>();
//            List<InputStream> ins = new ArrayList<>();
//            try {
//                finalRows.forEach(result -> {
//                    int index = 0;
//                    userFormItemEntityList.forEach(item -> {
//                        List<UploadResultStruct> uploadResults = JsonUtils.jsonToList(JsonUtils.objToJson(MapUtil.get(result, item.getFormItemId(), List.class)), UploadResultStruct.class);
//                        if (CollectionUtil.isNotEmpty(uploadResults)) {
//                            uploadResults.forEach(uFile -> {
//                                if (StrUtil.isNotBlank(uFile.getUrl())) {
//                                    paths.add(FileNameUtil.getName(uFile.getUrl()));
//                                    byte[] bytes = HttpUtil.downloadBytes(uFile.getUrl());
//                                    ins.add(IoUtil.toStream(bytes));
//                                }
//                            });
//                        }
//                    });
//                    AsyncProcessUtils.setProcess(uuid, ++index / finalRows.size());
//                });
//                // 压缩上传oss
//                ByteArrayOutputStream zipOutputStream = new ByteArrayOutputStream();
//                ZipUtil.zip(zipOutputStream, paths.toArray(new String[]{}), ins.toArray(new InputStream[]{}));
//                String downloadUrl = OssStorageFactory.getStorageService().upload(zipOutputStream.toByteArray(), StorageUtils.generateFileName("download", ".zip"));
//                AsyncProcessUtils.setProcess(uuid, downloadUrl);
//                log.info("export file cost time: {}", timer.interval());
//            } catch (Exception e) {
//                log.error("download file", e);
//            }
//        });
//        return Result.success(uuid);
//    }
//
//
    @Override
    public FormDataTableVO listFormDataTable(QueryFormResultRequest request) {
        return formDataUtils.search(request);
    }
//
//
//    @Override
//    public Boolean deleteByIds(List<String> dataIdList, String formKey) {
//        baseMapper.deleteBatchIds(dataIdList);
//        formDataUtils.asyncDeleteEsDocument(dataIdList, formKey);
//        return true;
//    }
//
//    @Override
//    public Boolean updateFormResult(UserFormDataEntity entity) {
//        UserFormDataEntity dataEntity = this.getById(entity.getId());
//        dataEntity.setOriginalData(entity.getOriginalData());
//        dataEntity.setUpdateBy(entity.getUpdateBy());
//        boolean update = this.updateById(dataEntity);
//        // 查询数据 同步到es 避免数据变空被覆盖
//        formDataUtils.asyncUpdateEsDocument(dataEntity);
//        return update;
//    }

    @Override
    public Result getFormDataDetails(String dataId) {
        Map<String, Object> result =new HashMap<>();
        UserFormDataEntity dataEntity = this.getById(dataId);
        List<FormFieldVO> formFields = userFormItemService.listFormFields(dataEntity.getFormKey());
        // 表单字段
        result.put("formFields", formFields);
        // 表单填写数据
        if (ObjectUtil.isNotNull(dataEntity)) {
            Map<String, Object> originalData = dataEntity.getOriginalData();
            dataEntity.setOriginalData(null);
            originalData.putAll(BeanUtil.beanToMap(dataEntity, false, true));
            result.put("formData", originalData);
        }
        return Result.success(result);
    }
}