package com.malk.taisen.controller;

/**
 * 错误抛出与拦截详见 CatchException
 */

import com.alibaba.fastjson.JSON;
import com.malk.server.aliwork.YDConf;
import com.malk.server.aliwork.YDParam;
import com.malk.server.common.McR;
import com.malk.service.aliwork.YDClient;
import com.malk.service.aliwork.YDService;
import com.malk.utils.UtilDateTime;
import com.malk.utils.UtilMap;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Collections;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

@Slf4j
@RestController
@RequestMapping
public class TSController {

    @Autowired
    private YDClient ydClient;

    @Autowired
    private YDConf ydConf;

    @PostMapping("test11")
    McR test11() {


        // 丢行处理

        // 孙静
//        String tId = "f54bb1ab-e989-4b61-ad9b-7cd9e2dab69b";
//        String sId = "62f796fd-b35d-4db8-85ad-c14dbc2050ad";

        // 陈黛珠
//        String tId = "96af9edc-83cb-4027-9687-8ec0e1cbd4eb";
//        String sId = "5005d16d-a392-43a6-bdcb-c1ae93d30deb";

        // 陈豹
        String tId = "640cff6e-89fb-4d50-9c45-aa2fcf8b06d5";
        String sId = "13dfaba7-7f27-4f51-bcb6-5c8d71b758c1";

        Map formData = ydClient.queryData(YDParam.builder()
                        .formInstanceId(tId)
                        .build(),
                YDConf.FORM_QUERY.retrieve_id).getFormData();
        List<Map> details = ((List<Map>) formData.get("tableField_l6lmxo5r")).stream().map(item -> {
            item.put("associationFormField_l6vk2yxg", JSON.parse(item.get("associationFormField_l6vk2yxg_id").toString()));
            // 关联申请
//            List<Map> dataList = (List<Map>) ydClient.queryData(YDParam.builder()
//                            .formUuid("FORM-78766VC1KTX2HZQ6E6IR3CYXWUFU3RO8RGN6L6")
//                            .searchFieldJson(JSON.toJSONString(UtilMap.map("employeeField_l82gi80j, numberField_l6ngrh2h", formData.get("employeeField_l843wfsm_id"), Arrays.asList(item.get("numberField_l6lmxo60"), item.get("numberField_l6lmxo60")))))
//                            .build(),
//                    YDConf.FORM_QUERY.retrieve_search_form).getData();
//            item.put("associationFormField_l6napwww", ydConf.associationForm("FORM-78766VC1KTX2HZQ6E6IR3CYXWUFU3RO8RGN6L6", dataList.get(0).get("formInstanceId").toString(), "深圳", null, false));
            return item;
        }).collect(Collectors.toList());

        Map updateForm = UtilMap.map("tableField_l6lmxo5r", details);
        ydClient.operateData(YDParam.builder()
                .formInstanceId(sId)
                .updateFormDataJson(JSON.toJSONString(updateForm)).build(), YDConf.FORM_OPERATION.update);

        return McR.success(formData);
    }

    // 当前表税率为0处理
    @PostMapping("test13")
    McR test13() {

        String fid = "0fa54443-8253-4f70-b1b7-18850e20a683";

        Map formData = ydClient.queryData(YDParam.builder()
                .formInstanceId(fid)
                .build(), YDConf.FORM_QUERY.retrieve_id).getFormData();
        List<Map> details = (List<Map>) formData.get("tableField_l6lmxo5r");

        details.forEach(item -> {

//            if (UtilString.isBlankCompatNull(String.valueOf(item.get("numberField_l6lmxo61")))) {
//                item.put("numberField_l6lmxo61", 0);
//            }
//            item.put("associationFormField_l6vk2yxg", JSON.parse(String.valueOf(item.get("associationFormField_l6vk2yxg_id"))));
//            item.put("associationFormField_l6napwww", JSON.parse(String.valueOf(item.get("associationFormField_l6napwww_id"))));

            log.info("xxxx, {}", item.get("numberField_l6lmxo61"));
        });

        Map updateForm = UtilMap.map("tableField_l6lmxo5r", details);

//        ydClient.operateData(YDParam.builder()
//                .formInstanceId(fid)
//                .updateFormDataJson(JSON.toJSONString(updateForm)).build(), YDConf.FORM_OPERATION.update);

        return McR.success(updateForm);
    }

    @Autowired
    private YDService ydService;

    // 变更记录
    @PostMapping("changed")
    McR changed() {

        for (int i = 1; i <= 40; i++) {

            List<Map> dataList = (List<Map>) ydClient.queryData(YDParam.builder()
                    .formUuid("FORM-UX866Q61LRK2LACIB8A6M6T1ZOLM2VY5NYB6LZ")
                    .pageNumber(i)
                    .currentPage(i)
                    .build(), YDConf.FORM_QUERY.retrieve_search_form).getData();

            Map<String, List<Map>> record = ydClient.queryData(YDParam.builder()
                    .formUuid("FROM-UX866Q61LRK2LACIB8A6M6T1ZOLM2VY5NYB6LZ")
                    .formInstanceIdList(dataList.stream().map(item -> String.valueOf(item.get("formInstanceId"))).collect(Collectors.toList()))
                    .build(), YDConf.FORM_QUERY.retrieve_changed).getOperationLogMap();
            for (String id : record.keySet()) {

                Map form = dataList.stream().filter(item -> item.get("formInstanceId").equals(id)).findAny().get();
                Map data = (Map) form.get("formData");
                Map formData = UtilMap.map("associationFormField_lnukdrl8", ydConf.associationForm("FORM-UX866Q61LRK2LACIB8A6M6T1ZOLM2VY5NYB6LZ", id, String.valueOf(form.get("title")), null, true));
                formData.put("textField_lnulmox7", data.get("textField_l7a7bf8d"));
                formData.put("employeeField_lnulmox8", data.get("employeeField_l843wfsm_id"));

                List<Map> details = record.get(id).stream().map(item -> UtilMap.map("textField_lnukfzeh, textField_lnukfzei, textField_lnukfzej, textField_lnukfzel, textField_lnukfzek, textField_lnukfzem",
                        item.get("currentText"), item.get("preText"), item.get("gmtModified"), item.get("componentName"), item.get("operationType"), UtilMap.getMap(item, "operator").get("displayName")))
                        .collect(Collectors.toList());
                formData.put("tableField_lnukfzeg", details);
                ydClient.operateData(YDParam.builder()
                        .formUuid("FORM-4W8667D1440FEE4PFEX586YVOCEN3EXFDKUNLB1")
                        .formDataJson(JSON.toJSONString(formData))
                        .build(), YDConf.FORM_OPERATION.create);
            }

        }

        return McR.success();
    }


    /// 广舜临时修改
    @PostMapping("gc")
    McR gc() {


//        ydClient.operateData(YDParam.builder()
//                .formInstanceId("39e50d18-fcd4-4b19-b825-23d421a255ff")
//                .updateFormDataJson(JSON.toJSONString(UtilMap.map("textField_llalwnd7", "HA0051C")))
//                .build(), YDConf.FORM_OPERATION.update);

        List<Map> dataList = (List<Map>) ydClient.queryData(YDParam.builder()
                .formUuid("FORM-08866RA1SPVC8CISDK79NBIXH4ZT3CBF61MKL0")
                .dynamicOrder(JSON.toJSONString(UtilMap.map("gmt_create", "+")))
                .build(), YDConf.FORM_QUERY.retrieve_search_process).getData();

        Collections.reverse(dataList);

        int i = 1;
        for (Map formData : dataList) {

            String newS = String.valueOf(UtilMap.getMap(formData, "data").get("textField_llalwnd7"));
            if (UtilMap.getMap(formData, "data").containsKey("textField_lmu9nuzp")) {
                newS += "-" + String.valueOf(UtilMap.getMap(formData, "data").get("textField_lmu9nuzp"));
            } else {
                newS += "-" + "M";
            }
            if (i > 9) {
                newS += "00" + i;
            } else {
                newS += "000" + i;
            }
            newS += UtilDateTime.format(new Date(Long.valueOf(String.valueOf(UtilMap.getMap(formData, "data").get("dateField_llabt1ft")))), "yyMMdd");

            log.info("xxxx, {}, ", newS);
            ydClient.operateData(YDParam.builder()
                    .formInstanceId(String.valueOf(formData.get("processInstanceId")))
                    .updateFormDataJson(JSON.toJSONString(UtilMap.map("textField_lkkmaxdw, serialNumberField_lnlu5r43", newS, newS)))
                    .build(), YDConf.FORM_OPERATION.update);
            i++;
//
        }
        return McR.success();
    }


    @PostMapping("test")
    McR test() {

        log.info("xxxx, {}");
        return McR.success();
    }
}