package com.changhong.epc.parsing.service.mq;

import com.changhong.epc.bean.form.FormDataEntity;
import com.changhong.epc.constter.base.BaseConst;
import com.changhong.epc.constter.base.Context;
import com.changhong.epc.constter.system.DataSourceKey;
import com.changhong.epc.parsing.mapper.centen.AutoIDMapper;
import com.changhong.epc.parsing.service.util.IFromOperate;
import com.iemsoft.framework.cloud.core.thread.Keys;
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.extern.slf4j.Slf4j;
import org.apache.commons.lang3.math.NumberUtils;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.stereotype.Component;
import org.springframework.ui.ModelMap;

import javax.annotation.Resource;
import java.util.Map;
import java.util.Objects;

@Component
@Slf4j
public class AutoFormConsumer implements MessageListener, DataSourceKey {

    @Resource
    private IFromOperate fromOperate;

    @Resource
    private AutoIDMapper autoIDMapper;

    @Override
    public void onMessage(Message message, byte[] pattern) {
        ThreadData.set(BaseConst.DATA_SOURCE, ADMIN_DATA_SOURCE);
        Context.MQParam<Map<String, Object>> param = ObjectUtil.byteToObject(message.getBody(), Context.MQParam.class);
        ThreadData.set(BaseConst.TENANT_ID, param.getTenantId());
        ThreadData.set(BaseConst.COMPANY_ID, NumberUtils.createInteger(param.getCompanyId()));
        ThreadData.set(BaseConst.OPEN_ID, param.getOpenId());
        ThreadData.set(Keys.USER_ID, param.getOpenId());
        FormDataEntity formDataEntity = new FormDataEntity();
        formDataEntity.setFormId(Objects.toString(param.getData().get("formID")));
        formDataEntity.setTenantId(param.getTenantId());
        formDataEntity.setDataRowNum(NumberUtils.createInteger(Objects.toString(param.getData().get("id"))));
        formDataEntity.setMap(
                new ModelMap(
                        Objects.toString(param.getData().get("field"))
                        , getNumber(Objects.toString(param.getData().get("fieldKey"))
                            , NumberUtils.toInt(Objects.toString(param.getData().get("fieldSize")))
                            , formDataEntity.getDataRowNum()
                        )
                )
        );
        log.debug("回写序列编号租户:{}, 公司:{}, 表单:{}, 主键:{}, 内容:{}"
                , param.getTenantId(), param.getCompanyId(), formDataEntity.getFormId(), formDataEntity.getDataRowNum(), JSONTool.toJson(formDataEntity.getMap()));
        fromOperate.updateFormData(formDataEntity);
    }

    private String getNumber(String fieldKey, Integer size, Integer dataRowNum) {
//        Long val = redisTemplate.opsForValue().increment(fieldKey, 1);
        Integer val = autoIDMapper.getAutoID(fieldKey);
        return String.format("%s%0"+size+"d", fieldKey, val);
    }

}