|
|
@ -24,6 +24,8 @@ import com.yxt.common.base.utils.StringUtils; |
|
|
|
import com.yxt.common.core.query.PagerQuery; |
|
|
|
import com.yxt.common.core.result.ResultBean; |
|
|
|
import com.yxt.common.core.vo.PagerVo; |
|
|
|
import com.yxt.messagecenter.api.message.AppScmMessageFlowableQuery; |
|
|
|
import com.yxt.messagecenter.api.message.MessageFeign; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
@ -55,6 +57,8 @@ public class BusTransferRecordsService extends MybatisBaseService<BusTransferRec |
|
|
|
private SysOrganizationFeign sysOrganizationFeign; |
|
|
|
@Autowired |
|
|
|
private SysUserRoleFeign sysUserRoleFeign; |
|
|
|
@Autowired |
|
|
|
private MessageFeign messageFeign; |
|
|
|
|
|
|
|
public PagerVo<BusTransferRecordsVo> pagerList(PagerQuery<BusTransferRecordsQuery> pq) { |
|
|
|
QueryWrapper<BusTransferRecords> qw = new QueryWrapper<>(); |
|
|
@ -259,6 +263,18 @@ public class BusTransferRecordsService extends MybatisBaseService<BusTransferRec |
|
|
|
busTransferRecordss.setTransferDeptSid(busTransferRecords.getReceiveDeptSid()); |
|
|
|
baseMapper.insert(busTransferRecordss); |
|
|
|
baseMapper.updateById(busTransferRecords); |
|
|
|
//消息推送
|
|
|
|
AppScmMessageFlowableQuery messageFlowableQuery = new AppScmMessageFlowableQuery(); |
|
|
|
List<String> recipientSidList = new ArrayList<>(); |
|
|
|
messageFlowableQuery.setRecipientSidList(recipientSidList); |
|
|
|
messageFlowableQuery.setMsgTitle("业务"); |
|
|
|
messageFlowableQuery.setMsgContent(busTransferRecords.getReceiveName() + "的发票交接已准备好,请前往交车准备进行确认"); |
|
|
|
messageFlowableQuery.setMsgSource("业务"); |
|
|
|
messageFlowableQuery.setApp_type("2"); |
|
|
|
messageFlowableQuery.setModuleSid("e25e13b5-f2ed-421f-bdb3-6f2eca2a3028"); |
|
|
|
messageFlowableQuery.setName("业务"); |
|
|
|
// 消息推送
|
|
|
|
messageFeign.sendAutoserviceMessage(messageFlowableQuery); |
|
|
|
} |
|
|
|
} |
|
|
|
return rb.success(); |
|
|
|