five-groups
/
five-groups-couplet
4
0
Fork 0
Code Issues Pull Requests 2 Packages Projects Releases Wiki Activity

fix: 代码丢失找回

server_five_liuyunhu
lijiayao 2024-04-06 09:59:38 +08:00
parent 9e8106ab46
commit 5bf55e27f3
1 changed files with 24 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
couplet-modules/couplet-business/src/main/java/com/couplet/business/server/service/impl/FenceServiceImpl.java
View File

@ -38,40 +38,56 @@ public class FenceServiceImpl extends ServiceImpl<FenceMapper, Fence> implements
*/ */
@Autowired @Autowired
private StringRedisTemplate redisTemplate; private StringRedisTemplate redisTemplate;
/**
* 远程调用队列服务
*/
@Autowired
private RemoteFenceService remoteFenceService;
@Override @Override
public List<Fence> pageQuery(FenceConfig fenceConfig) { public List<Fence> pageQuery(FenceConfig fenceConfig) {
List<Fence> list= fenceMapper.pageQuery(fenceConfig); List<Fence> list = fenceMapper.pageQuery(fenceConfig);
return list; return list;
} }
@Override @Override
public void changeFenceStatus(FenceUpdateRequest fenceUpdateRequest) { public void changeFenceStatus(FenceUpdateRequest fenceUpdateRequest) {
String username = SecurityUtils.getUsername();
fenceUpdateRequest.setCrateName(username);
fenceMapper.changeFence(fenceUpdateRequest); fenceMapper.changeFence(fenceUpdateRequest);
/**
* 电子围栏发送改变
*/
redisTemplate.opsForValue().set("changeFenceStatus", JSON.toJSONString(fenceUpdateRequest), 10, TimeUnit.MINUTES);
remoteFenceService.fenceQueue(fenceUpdateRequest);
} }
/** /**
* 业务实现:添加围栏 * 业务实现:添加围栏
*
* @param request * @param request
* @param fenceRequest * @param fenceRequest
*/ */
@Override @Override
public void fenceInsert(HttpServletRequest request, FenceRequest fenceRequest) { public void fenceInsert(HttpServletRequest request, FenceRequest fenceRequest) {
String username = SecurityUtils.getUsername();
fenceRequest.setCrateName(username);
//先添加围栏 //先添加围栏
int a= fenceMapper.insertFence(fenceRequest); fenceMapper.insertFence(fenceRequest);
String[] logoIds = fenceRequest.getLogoIds(); String[] logoIds = fenceRequest.getLogoIds();
String[] parts = new String[0]; String[] parts = new String[0];
for (String logoId : logoIds) { for (String logoId : logoIds) {
//把前台传入的字符串分割成数组 //把前台传入的字符串分割成数组
parts = logoId.split(","); parts = logoId.split(",");
//再添加围栏和标识中间表 //再添加围栏和标识中间表
fenAndLogoService.addBach(fenceRequest.getFenceId(),parts); fenAndLogoService.addBach(fenceRequest.getFenceId(), parts);
} }
/**
* 电子围栏发送改变
*/
redisTemplate.opsForValue().set("fenceInsert", JSON.toJSONString(fenceRequest), 10, TimeUnit.MINUTES);
} }
@Override @Override