package com.changhong.epc.admin.service.mq;
|
|
import com.changhong.epc.admin.mapper.centen.AutoIDMapper;
|
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.constter.system.run.EpcRestInterface;
|
import com.iemsoft.framework.cloud.core.base.ResMsg;
|
import com.iemsoft.framework.cloud.core.thread.Keys;
|
import com.iemsoft.framework.cloud.core.thread.ThreadData;
|
import com.iemsoft.framework.cloud.core.tools.ObjectUtil;
|
import com.iemsoft.framework.cloud.core.tools.SpringUtil;
|
import com.iemsoft.framework.cloud.ribbon.RestInterface;
|
import org.apache.commons.lang3.math.NumberUtils;
|
import org.springframework.data.redis.connection.Message;
|
import org.springframework.data.redis.connection.MessageListener;
|
import org.springframework.ui.ModelMap;
|
|
import javax.annotation.Resource;
|
import java.util.Map;
|
import java.util.Objects;
|
|
import static com.changhong.epc.constter.form.utf.FormUrlConst.FORM_DATA_UPDATFORM;
|
import static com.changhong.epc.constter.system.SystemClients.SERVER_FORM;
|
|
//@Component
|
public class AutoFormConsumer implements MessageListener, DataSourceKey {
|
|
@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()
|
)
|
)
|
);
|
getFromRest(FORM_DATA_UPDATFORM, formDataEntity);
|
}
|
|
public Object getFromRest(String fs, Object parm) {
|
RestInterface restInterface = SpringUtil.getBean(SERVER_FORM.getBeanName(), RestInterface.class);
|
Object data = restInterface.post(fs, parm, ResMsg.class, EpcRestInterface.getEpcHeads()).getData();
|
return data;
|
}
|
|
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);
|
}
|
|
}
|
