Commit 47d98f1d authored by shangtx's avatar shangtx

fix: 短信修改,添加参数

parent b92681be
package com.onsiteservice.common.service; package com.onsiteservice.common.service;
import com.alibaba.fastjson.JSONObject;
import com.onsiteservice.common.redis.RedisUtils; import com.onsiteservice.common.redis.RedisUtils;
import com.onsiteservice.util.aliyun.SmsUtils; import com.onsiteservice.util.aliyun.SmsUtils;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
...@@ -9,6 +10,7 @@ import org.springframework.stereotype.Service; ...@@ -9,6 +10,7 @@ import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.Map;
/** /**
* 业务短信服务 * 业务短信服务
...@@ -67,39 +69,39 @@ public class CommonSmsService { ...@@ -67,39 +69,39 @@ public class CommonSmsService {
return; return;
} }
try { try {
smsUtils.send(sign, changePhoneTmpCode, code, phone); smsUtils.send(sign, changePhoneTmpCode, JSONObject.toJSONString(Map.of("code", code)), phone);
} catch (Exception e) { } catch (Exception e) {
log.error("发送短信错误", e); log.error("发送短信错误", e);
} }
} }
public void payable(String phone) { public void payable(String phone, String servicePhone, String serviceName) {
if (StringUtils.isEmpty(phone)) { if (StringUtils.isEmpty(phone)) {
return; return;
} }
try { try {
smsUtils.send(sign, payableTmpCode, null, phone); smsUtils.send(sign, payableTmpCode, JSONObject.toJSONString(Map.of("phone", servicePhone, "name", serviceName)), phone);
} catch (Exception e) { } catch (Exception e) {
log.error("发送短信错误", e); log.error("发送短信错误", e);
} }
} }
public void dispatched(String phone) { public void dispatched(String phone, String servicePhone, String serviceName) {
if (StringUtils.isEmpty(phone)) { if (StringUtils.isEmpty(phone)) {
return; return;
} }
try { try {
smsUtils.send(sign, dispatchedTmpCode, null, phone); smsUtils.send(sign, dispatchedTmpCode, JSONObject.toJSONString(Map.of("phone", servicePhone, "name", serviceName)), phone);
} catch (Exception e) { } catch (Exception e) {
log.error("发送短信错误", e); log.error("发送短信错误", e);
} }
} }
public void redispatched(String phone) { public void redispatched(String phone, String servicePhone, String serviceName) {
if (StringUtils.isEmpty(phone)) { if (StringUtils.isEmpty(phone)) {
return; return;
} }
try { try {
smsUtils.send(sign, redispatchedTmpCode, null, phone); smsUtils.send(sign, redispatchedTmpCode, JSONObject.toJSONString(Map.of("phone", servicePhone, "name", serviceName)), phone);
} catch (Exception e) { } catch (Exception e) {
log.error("发送短信错误", e); log.error("发送短信错误", e);
} }
...@@ -116,23 +118,23 @@ public class CommonSmsService { ...@@ -116,23 +118,23 @@ public class CommonSmsService {
} }
} }
public void valuator(String phone) { public void valuator(String phone, String servicePhone, String serviceName) {
if (StringUtils.isEmpty(phone)) { if (StringUtils.isEmpty(phone)) {
return; return;
} }
try { try {
smsUtils.send(sign, valuatorTmpCode, null, phone); smsUtils.send(sign, valuatorTmpCode, JSONObject.toJSONString(Map.of("phone", servicePhone, "name", serviceName)), phone);
} catch (Exception e) { } catch (Exception e) {
log.error("发送短信错误", e); log.error("发送短信错误", e);
} }
} }
public void revaluator(String phone) { public void revaluator(String phone, String servicePhone, String serviceName) {
if (StringUtils.isEmpty(phone)) { if (StringUtils.isEmpty(phone)) {
return; return;
} }
try { try {
smsUtils.send(sign, revaluatorTmpCode, null, phone); smsUtils.send(sign, revaluatorTmpCode, JSONObject.toJSONString(Map.of("phone", servicePhone, "name", serviceName)), phone);
} catch (Exception e) { } catch (Exception e) {
log.error("发送短信错误", e); log.error("发送短信错误", e);
} }
......
...@@ -108,7 +108,7 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> { ...@@ -108,7 +108,7 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> {
// 记录估价员指派时间 // 记录估价员指派时间
serviceValuatorAssignMapper.insertSelective(buildServiceValuatorAssign(dto, userId)); serviceValuatorAssignMapper.insertSelective(buildServiceValuatorAssign(dto, userId));
// 通知用户 // 通知用户
commonSmsService.valuator(serviceOrder.getPhone()); commonSmsService.valuator(serviceOrder.getPhone(), user.getPhone(), serviceOrder.getServiceName());
String description = String.format(ServiceOrderStatusEnum.VALUATION.getMsg(), user.getName(), valuatorUser.getUserName()); String description = String.format(ServiceOrderStatusEnum.VALUATION.getMsg(), user.getName(), valuatorUser.getUserName());
recordComponent.recordProcess(serviceOrder.getId(), ServiceOrderStatusEnum.VALUATION.getStatus(), description, recordComponent.recordProcess(serviceOrder.getId(), ServiceOrderStatusEnum.VALUATION.getStatus(), description,
...@@ -143,7 +143,7 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> { ...@@ -143,7 +143,7 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> {
// 设置新的估计员世间 // 设置新的估计员世间
serviceValuatorAssignMapper.insertSelective(buildServiceValuatorAssign(dto, userId)); serviceValuatorAssignMapper.insertSelective(buildServiceValuatorAssign(dto, userId));
// 通知用户 // 通知用户
commonSmsService.revaluator(serviceOrder.getPhone()); commonSmsService.revaluator(serviceOrder.getPhone(), user.getPhone(), serviceOrder.getServiceName());
String description = String.format(ServiceOrderStatusEnum.REVALUATION.getMsg(), user.getName(), valuatorUser.getUserName()); String description = String.format(ServiceOrderStatusEnum.REVALUATION.getMsg(), user.getName(), valuatorUser.getUserName());
recordComponent.recordProcess(serviceOrder.getId(), ServiceOrderStatusEnum.REVALUATION.getStatus(), description, recordComponent.recordProcess(serviceOrder.getId(), ServiceOrderStatusEnum.REVALUATION.getStatus(), description,
sourceEnum, valuatorUser.getId(), dto.getRemark(), dto.getExpectArrivalTime()); sourceEnum, valuatorUser.getId(), dto.getRemark(), dto.getExpectArrivalTime());
...@@ -184,7 +184,7 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> { ...@@ -184,7 +184,7 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> {
try { try {
// 发短信 // 发短信
log.info("sendOrder send msg to phone: {}", serviceOrder.getPhone()); log.info("sendOrder send msg to phone: {}", serviceOrder.getPhone());
commonSmsService.payable(serviceOrder.getPhone()); commonSmsService.payable(serviceOrder.getPhone(), user.getPhone(), serviceOrder.getServiceName());
} catch (Exception e) { } catch (Exception e) {
log.error("sendOrder error, ", e); log.error("sendOrder error, ", e);
} }
...@@ -226,7 +226,7 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> { ...@@ -226,7 +226,7 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> {
serviceOrder.setModifyBy(userId); serviceOrder.setModifyBy(userId);
int result = serviceOrderMapper.updateByConditionSelective(serviceOrder, c); int result = serviceOrderMapper.updateByConditionSelective(serviceOrder, c);
commonSmsService.dispatched(serviceOrder.getPhone()); commonSmsService.dispatched(serviceOrder.getPhone(), user.getPhone(), serviceOrder.getServiceName());
if (result == 1) { if (result == 1) {
// 记录维修工时间 // 记录维修工时间
...@@ -263,7 +263,7 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> { ...@@ -263,7 +263,7 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> {
int result = serviceWorkerAssignMapper.insertSelective(buildServiceWorkerAssign(dto, serviceOrder, userId)); int result = serviceWorkerAssignMapper.insertSelective(buildServiceWorkerAssign(dto, serviceOrder, userId));
commonSmsService.redispatched(serviceOrder.getPhone()); commonSmsService.redispatched(serviceOrder.getPhone(), user.getPhone(), serviceOrder.getServiceName());
if (result == 1) { if (result == 1) {
String description = String.format(ServiceOrderStatusEnum.REDISPATCH.getMsg(), user.getName(), serviceWorker.getName()); String description = String.format(ServiceOrderStatusEnum.REDISPATCH.getMsg(), user.getName(), serviceWorker.getName());
...@@ -293,10 +293,10 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> { ...@@ -293,10 +293,10 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> {
if (!isUser && !isAdmin) { if (!isUser && !isAdmin) {
throw new ServiceException(BizCodeEnum.NO_AUTH_FINISH_ORDER); throw new ServiceException(BizCodeEnum.NO_AUTH_FINISH_ORDER);
} }
user = new WorkUser(miniUser.getId(), miniUser.getUserName(), isAdmin); user = new WorkUser(miniUser.getId(), miniUser.getUserName(), isAdmin, miniUser.getPhone());
} else { } else {
var sysUser = sysUserMapper.selectByPrimaryKey(userId); var sysUser = sysUserMapper.selectByPrimaryKey(userId);
user = new WorkUser(sysUser.getId(), sysUser.getRealName(), true); user = new WorkUser(sysUser.getId(), sysUser.getRealName(), true, sysUser.getPhone());
} }
Condition c = buildOrderStatusCondition(serviceOrder); Condition c = buildOrderStatusCondition(serviceOrder);
...@@ -343,13 +343,13 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> { ...@@ -343,13 +343,13 @@ public class ServiceOrderService extends AbstractMapper<ServiceOrder> {
throw new ServiceException(biz); throw new ServiceException(biz);
} }
return new WorkUser(user.getId(), user.getUserName(), user.getRoleType().equals(ServiceUserTypeEnum.ADMIN.getId())); return new WorkUser(user.getId(), user.getUserName(), user.getRoleType().equals(ServiceUserTypeEnum.ADMIN.getId()), user.getPhone());
} }
SysUser sysUser = sysUserMapper.selectByPrimaryKey(userId); SysUser sysUser = sysUserMapper.selectByPrimaryKey(userId);
if (Objects.isNull(sysUser)) { if (Objects.isNull(sysUser)) {
throw new ServiceException(biz); throw new ServiceException(biz);
} }
return new WorkUser(sysUser.getId(), sysUser.getRealName(), true); return new WorkUser(sysUser.getId(), sysUser.getRealName(), true, sysUser.getPhone());
} }
......
...@@ -12,4 +12,6 @@ public class WorkUser { ...@@ -12,4 +12,6 @@ public class WorkUser {
private String name; private String name;
// 是否是客服 // 是否是客服
private Boolean isAdmin; private Boolean isAdmin;
private String phone;
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment