当一个订单多个机具归属一个库管员时,只要通知一次

This commit is contained in:
15856 2024-07-06 15:17:36 +08:00
parent ca683c727d
commit ff11afe15f
3 changed files with 16 additions and 13 deletions

View File

@ -1,10 +1,10 @@
package com.bonus.sgzb.app.controller; package com.bonus.sgzb.app.controller;
import com.bonus.sgzb.app.domain.AppVersion; import com.bonus.sgzb.app.domain.AppVersion;
import com.bonus.sgzb.app.domain.BackApplyInfo;
import com.bonus.sgzb.app.domain.CriticalData; import com.bonus.sgzb.app.domain.CriticalData;
import com.bonus.sgzb.app.domain.ToDoList; import com.bonus.sgzb.app.domain.ToDoList;
import com.bonus.sgzb.app.service.AppService; import com.bonus.sgzb.app.service.AppService;
import com.bonus.sgzb.common.core.exception.ServiceException;
import com.bonus.sgzb.common.core.web.domain.AjaxResult; import com.bonus.sgzb.common.core.web.domain.AjaxResult;
import com.bonus.sgzb.common.log.annotation.Log; import com.bonus.sgzb.common.log.annotation.Log;
import com.bonus.sgzb.common.log.enums.BusinessType; import com.bonus.sgzb.common.log.enums.BusinessType;
@ -52,12 +52,12 @@ public class AppController {
*/ */
@Log(title = "获取app版本信息", businessType = BusinessType.QUERY) @Log(title = "获取app版本信息", businessType = BusinessType.QUERY)
@GetMapping("/getVersion") @GetMapping("/getVersion")
public AjaxResult getVersion() { public AjaxResult getVersion(){
try { try {
List<AppVersion> list = service.getVersion(); List<AppVersion> list = service.getVersion();
return success(list); return success(list);
} catch (Exception e) { } catch (Exception e) {
throw new RuntimeException(e); throw new ServiceException();
} }
} }

View File

@ -272,27 +272,32 @@ public class TmTaskServiceImpl implements TmTaskService {
} }
private void smsNotification(LeaseApplyDetails details, String code) { private void smsNotification(LeaseApplyDetails details, String code) {
log.info("短信通知:{}", code);
TmTask tmTask = new TmTask(); TmTask tmTask = new TmTask();
tmTask.setId(details.getParenntId().toString()); tmTask.setId(details.getParenntId().toString());
//获取机具所属人员 //获取机具所属人员
List<TmTask> leaseDetailByParent = tmTaskMapper.getUserByParenntId(tmTask); List<TmTask> leaseDetailByParent = tmTaskMapper.getUserByParenntId(tmTask);
HashSet<String> set=new HashSet<>();
String message = "尊敬的用户,宁夏智慧仓储管理系统提醒您:您有一个领料单号为:" + code + "的领料申请待处理,请及时查看";
for (TmTask tmTaskNew : leaseDetailByParent) { for (TmTask tmTaskNew : leaseDetailByParent) {
//对手机号进行处理因为存在一种类型的机具归属多个人的情况 //对手机号进行处理因为存在一种类型的机具归属多个人的情况
log.info("短信通知人为:{}", tmTaskNew.getUserName()); log.info("短信通知人为:{}", tmTaskNew.getUserName());
if (tmTaskNew.getPhoneNumber() != null) { if (tmTaskNew.getPhoneNumber() != null) {
String[] phoneNumberList = tmTaskNew.getPhoneNumber().split(","); String[] phoneNumberList = tmTaskNew.getPhoneNumber().split(",");
String message = "尊敬的用户,宁夏智慧仓储管理系统提醒您:您有一个领料单号为:" + code + "的领料申请待处理,请及时查看";
for (int i = 0; i < phoneNumberList.length; i++) { for (int i = 0; i < phoneNumberList.length; i++) {
//当一个订单中包含多个机具归属一个管理员需要去重只需要通知一次就好了
set.add(phoneNumberList[i]);
}
}
}
for (String str :set) {
try { try {
remoteUserService.send(phoneNumberList[i], message); remoteUserService.send(str, message);
} catch (Exception e) { } catch (Exception e) {
log.info("手机号为:{}发送短信失败", phoneNumberList[i]); log.info("手机号为:{}发送短信失败",str);
} }
} }
} }
}
}
@Override @Override
public int updateLeaseTaskAuditInfoCq(TmTask record) { public int updateLeaseTaskAuditInfoCq(TmTask record) {
int result = 0; int result = 0;

View File

@ -5,9 +5,7 @@ import com.bonus.sgzb.common.core.web.controller.BaseController;
import com.bonus.sgzb.common.core.web.domain.AjaxResult; import com.bonus.sgzb.common.core.web.domain.AjaxResult;
import com.bonus.sgzb.common.log.annotation.Log; import com.bonus.sgzb.common.log.annotation.Log;
import com.bonus.sgzb.common.log.enums.BusinessType; import com.bonus.sgzb.common.log.enums.BusinessType;
import com.bonus.sgzb.material.domain.ProjUsingRecord;
import com.bonus.sgzb.material.domain.StorageStatus; import com.bonus.sgzb.material.domain.StorageStatus;
import com.bonus.sgzb.material.service.ProjUsingRecordService;
import com.bonus.sgzb.material.service.StorageStatusService; import com.bonus.sgzb.material.service.StorageStatusService;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
@ -52,7 +50,7 @@ public class StorageStatusController extends BaseController {
public void export(HttpServletResponse response, StorageStatus bean) public void export(HttpServletResponse response, StorageStatus bean)
{ {
List<StorageStatus> list = storageStatusService.getStorageStatusList(bean); List<StorageStatus> list = storageStatusService.getStorageStatusList(bean);
ExcelUtil<StorageStatus> util = new ExcelUtil<StorageStatus>(StorageStatus.class); ExcelUtil<StorageStatus> util = new ExcelUtil<>(StorageStatus.class);
util.exportExcel(response, list, "综合查询--工程机具使用"); util.exportExcel(response, list, "综合查询--工程机具使用");
} }