修改商户余额资金流水

src/main/java/com/pangding/web/authority/service/impl/CompanyMsgServiceImpl.java

 package com.pangding.web.authority.service.impl;
 
 import com.pangding.web.authority.dao.CompanyMsgDao;
+import com.pangding.web.authority.dao.DeviceDao;
 import com.pangding.web.authority.dao.UserDao;
 import com.pangding.web.authority.service.CompanyMsgService;
 import com.pangding.web.partner.mq.PartnerProcedure;
 import com.pangding.web.partner.vo.req.SoundContentVo;
 import com.pangding.web.vo.system.req.CompanyMsgReqVo;
+import com.pangding.web.vo.system.req.DeviceReqVo;
 import com.pangding.web.vo.system.req.authority.UserReqVo;
 import com.pangding.web.vo.system.res.CompanyMsgResVo;
+import com.pangding.web.vo.system.res.DeviceResVo;
 import com.pangding.web.vo.system.res.authority.UserResVo;
+import com.yanzuoguang.util.helper.StringHelper;
 import com.yanzuoguang.util.vo.PageSizeData;
 import com.yanzuoguang.util.vo.ResponseResult;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -24,6 +28,8 @@ public class CompanyMsgServiceImpl implements CompanyMsgService{
     @Autowired
     private UserDao userDao;
     @Autowired
+    private DeviceDao deviceDao;
+    @Autowired
     private PartnerProcedure partnerProcedure;
 
 
@@ -50,6 +56,14 @@ public class CompanyMsgServiceImpl implements CompanyMsgService{
                 partnerProcedure.sendSoundContent(userResList.get(i).getId(), soundContentVo);
             }
         }
+
+        DeviceReqVo deviceReqVo = new DeviceReqVo();
+        deviceReqVo.setCompanyId(reqVo.getCompanyId());
+        DeviceResVo deviceResVo = deviceDao.load(deviceReqVo, DeviceResVo.class);
+        if(StringHelper.isEmpty(deviceResVo)){
+
+        }
+
         return ResponseResult.result("处理成功");
     }