diff --git a/ruoyi-admin/src/main/java/com/ruoyi/business/controller/BusAgentInfoController.java b/ruoyi-admin/src/main/java/com/ruoyi/business/controller/BusAgentInfoController.java index 7890688..d22b1c6 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/business/controller/BusAgentInfoController.java +++ b/ruoyi-admin/src/main/java/com/ruoyi/business/controller/BusAgentInfoController.java @@ -5,6 +5,7 @@ import com.ruoyi.business.domain.BusStoreInfo; import com.ruoyi.business.service.IBusAgentInfoService; import com.ruoyi.business.service.IBusStoreInfoService; import com.ruoyi.common.annotation.Log; +import com.ruoyi.common.annotation.RepeatSubmit; import com.ruoyi.common.core.controller.BaseController; import com.ruoyi.common.core.domain.AjaxResult; import com.ruoyi.common.core.domain.entity.SysDept; @@ -150,7 +151,7 @@ public class BusAgentInfoController extends BaseController { // @PreAuthorize("@ss.hasPermi('system:info:edit')") @Log(title = "代理管理", businessType = BusinessType.UPDATE) @PutMapping - @Transactional + @RepeatSubmit public AjaxResult edit(@RequestBody BusAgentInfo busAgentInfo) { LoginUser user = SecurityUtils.getLoginUser(); BusAgentInfo busAgentInfo1 = busAgentInfoService.selectBusAgentInfoById(user.getUserId()); diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java index 8b13a73..fa05326 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiConsumer.java @@ -228,7 +228,7 @@ public class AiConsumer { }catch (Exception e){ e.printStackTrace(); log.error("营销事件推出-下次继续====================="); - throw new ServiceException("营销事件推出-下次继续"); + throw new ServiceException("营销事件推出-下次继续:"+busOrderInfo.getOrderNo()); } System.out.println(("一共耗时time: " + (System.currentTimeMillis() - startTime) / 1000 + " s")); } diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java index 9d3e9cb..c9a4c76 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/AiServiceImpl.java @@ -319,7 +319,6 @@ public class AiServiceImpl implements IAiService { @Override @Transactional(rollbackFor = ServiceException.class) public void sendSmsTask(String content, BusOrderInfo busOrderInfo) { - lock.lock(); try { String limitNum = Optional.ofNullable(redisTemplate.opsForValue().get("limitNum")).orElse(null); BusSmsInfo busSmsInfo1 = busSmsInfoMapper.selectBusSmsInfoByNum(limitNum); @@ -351,10 +350,8 @@ public class AiServiceImpl implements IAiService { } } catch (Exception e) { e.printStackTrace(); - log.error("建立sendSmsTask错误: ",e.getMessage()); + log.error(busOrderInfo.getOrderNo()+"建立sendSmsTask错误: "+e.getMessage()); throw new ServiceException("短信发送失败!"); - }finally { - lock.unlock(); } } diff --git a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/BusAgentInfoServiceImpl.java b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/BusAgentInfoServiceImpl.java index 0dc34a7..e1c3c91 100644 --- a/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/BusAgentInfoServiceImpl.java +++ b/ruoyi-system/src/main/java/com/ruoyi/business/service/impl/BusAgentInfoServiceImpl.java @@ -191,19 +191,25 @@ public class BusAgentInfoServiceImpl implements IBusAgentInfoService recordService.insertBusIntegralRecord(record); busAgentInfoMapper.updateBusAgentInfo(busAgentInfo); + BusAgentInfo temp1 = busAgentInfoMapper.selectBusAgentInfoById(busAgentInfo.getSuperiorAgentCode()); BusIntegralRecord record1 = new BusIntegralRecord(); record1.setAccount(busAgentInfo.getSuperiorAgentAccount()); record1.setUpdateType("出账"); record1.setCreateUser(busAgentInfo.getAgentAccount()); // record1.setIntegralUpdateNum(busAgentInfo.getAiDurationBalance1()); if(busAgentInfo.getAiDurationBalance1()!=0){ + if(temp1.getAiDurationBalance()