package com.changhong.epc.admin.controller.mq;

import com.changhong.epc.admin.service.mq.AutoFormConsumer;
import com.changhong.epc.constter.base.BaseConst;
import com.changhong.epc.constter.base.Context;
import com.iemsoft.framework.cloud.core.thread.ThreadData;
import com.iemsoft.framework.cloud.core.tools.JSONTool;
import com.iemsoft.framework.cloud.core.tools.ObjectUtil;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.connection.Message;
import org.springframework.ui.ModelMap;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

import java.util.Map;

@RestController
@Slf4j
public class AutoFormController implements BaseConst {

    @GetMapping("autoForm/{tenantId}/{companyId}")
    public Object autoFormId(@PathVariable String tenantId, @PathVariable Integer companyId){
        ThreadData.set(TENANT_ID, tenantId);
        ThreadData.set(COMPANY_ID, companyId);

        TestAutoFormConsumer test = new TestAutoFormConsumer();
        test.onMessage(new Message(){

            @Override
            public byte[] getBody() {
                return ObjectUtil.objectToByte(
                        Context.getMQParam(
                                new ModelMap("tenantID", tenantId)
                                        .addAttribute("formID", "Ug12TTbi")
                                        .addAttribute("id", "4")
                                        .addAttribute("field", "number_expend")
                                        .addAttribute("fieldKey", "Rt")
                                        .addAttribute("fieldSize", "8")
                        )
                );
            }

            @Override
            public byte[] getChannel() {
                return new byte[0];
            }
        }, new byte[0]);
        return test.getVal();
    }

    @Data
    class TestAutoFormConsumer extends AutoFormConsumer {

        private Object val;

        @Override
        public Object getFromRest(String fs, Object parm) {
            log.debug(fs);
            log.debug(JSONTool.toJson(parm));
            this.val = ((Map)parm).get("number_expend");
            return null;
        }


    }
}