| | |
|---|
| | | public void send2Mq() {
|
|---|
| | | String s = JSONObject.toJSONString(this);
|
|---|
| | | log.info(s);
|
|---|
| | | MqResult mqResult = DbUtils.mqClient.asyncProduce(this);
|
|---|
| | | MqResult mqResult = DbUtils.mqClient.syncProduce(this);
|
|---|
| | | SysDispenseLogs logByMqEntity = DbUtils.dispenseLogsService.getLogByMqEntity(this);
|
|---|
| | | if (logByMqEntity == null) {
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | | String code = mqResult.getCode();
|
|---|
| | | logByMqEntity.setPageNo(pageNo.get()).setMsgCode(code);
|
|---|
| | | logByMqEntity.setPages(pages.get()).setTotal(totalSize.get()).setPageSize(pageSize.get());
|
|---|
| | | if (!code.equalsIgnoreCase(Constant.SUCCESSCODE)) {
|
|---|
| | | logByMqEntity.setStatus("false");
|
|---|
| | | }
|
|---|
