派发服务指令工单时发送websocket

This commit is contained in:
1378012178@qq.com 2026-01-12 16:59:58 +08:00
parent 6e2d793c18
commit 944858c74e
1 changed files with 105 additions and 78 deletions

View File

@ -13,6 +13,7 @@ import com.nu.modules.config.sendorderrule.entity.SendOrderRuleSub;
import com.nu.modules.config.sendorderrule.service.ISendOrderRuleService;
import com.nu.modules.config.sendorderrule.service.ISendOrderRuleSubService;
import com.nu.modules.sysconfig.ISysConfigApi;
import com.nu.websocket.SdWebsocket;
import lombok.extern.slf4j.Slf4j;
import org.apache.shiro.SecurityUtils;
import org.jeecg.common.api.vo.Result;
@ -29,7 +30,7 @@ import java.util.stream.Collectors;
/**
* @Description: 服务指令工单主表
* @Author: caolei
* @Date: 2025-11-18
* @Date: 2025-11-18
* @Version: V1.0
*/
@Service
@ -50,6 +51,9 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
List<SendOrderRuleSub> ruleSubList;
private String allowedTimeout;
@Autowired
private SdWebsocket sdWebsocket;
/**
* 获取容错时长
*
@ -62,7 +66,7 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
allowedTimeout = json.getString("configValue");
}
}
if(allowedTimeout == null || allowedTimeout.equals("")){
if (allowedTimeout == null || allowedTimeout.equals("")) {
allowedTimeout = "0";
}
}
@ -70,8 +74,8 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
/**
* 获取派单规则
*/
private void getSendOrderRule(){
if(sendOrderRule == null){
private void getSendOrderRule() {
if (sendOrderRule == null) {
QueryWrapper<SendOrderRule> qw = new QueryWrapper<>();
qw.eq("iz_enabled", "Y");
sendOrderRule = sendOrderRuleService.getOne(qw);
@ -85,26 +89,28 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
/**
* 获取在线有指令权限的员工并获取员工的接单上限收益服务时长单次
*
* @param directiveId
* @return
*/
private List<DirectiveOrder> getEmpPermissionAndOnline(String directiveId, String employeeIds, Date startTime){
return baseMapper.getEmpPermissionAndOnline(directiveId,employeeIds,startTime);
private List<DirectiveOrder> getEmpPermissionAndOnline(String directiveId, String employeeIds, Date startTime) {
return baseMapper.getEmpPermissionAndOnline(directiveId, employeeIds, startTime);
}
/**
* 获取长者指定所有护理员
*
* @param elderId
* @return
*/
private Map<String,String> getEmpOrderly(String elderId){
private Map<String, String> getEmpOrderly(String elderId) {
Map<String, String> map = null;
DirectiveOrder orders = baseMapper.getEmpOrderly(elderId);
if(orders!=null){
if (orders != null) {
String empIds = orders.getEmployeeIds();
if(empIds!=null&&!empIds.equals("")){
if (empIds != null && !empIds.equals("")) {
String[] pairs = empIds.split(",");
if(pairs.length>0){
if (pairs.length > 0) {
map = new HashMap<>();
for (String pair : pairs) {
map.put(pair, pair);
@ -117,34 +123,51 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
/**
* 指令池批量生成工单-定时调用
*
* @return
*/
@Override
public Result<?> generateOrdersBatch(){
public Result<?> generateOrdersBatch() {
//获取派单规则
getSendOrderRule();
getAllowedTimeout();
List<DirectiveOrder> ordersList = baseMapper.queryDataPoolList(null);
for(int i=0;i<ordersList.size();i++){
for (int i = 0; i < ordersList.size(); i++) {
DirectiveOrder orders = ordersList.get(i);
generateOrdersSub(orders);
//todo
//发送websocket消息
try {
// 发送数据
JSONObject message = new JSONObject();
message.put("type", "directiveOrder");//消息类型
message.put("timestamp", System.currentTimeMillis());
message.put("from", "system");//发送者
message.put("to", orders.getEmployeeId());//接收用户
message.put("data", orders);//业务数据
String messageJson = message.toJSONString();
//发送给单个用户
sdWebsocket.sendMessage(orders.getEmployeeId(), messageJson);
log.info("【ws消息推送】发送给用户 {}: {}", orders.getEmployeeId(), messageJson);
} catch (Exception e) {
log.error("ws发送消息失败", e);
}
}
return Result.OK();
}
/**
* 获取工单子表数据并进行处理
*
* @param orders
*/
private void generateOrdersSub(DirectiveOrder orders){
System.out.println("护理单元:"+orders.getNuId()+",服务时间"+orders.getStartTime());
private void generateOrdersSub(DirectiveOrder orders) {
System.out.println("护理单元:" + orders.getNuId() + ",服务时间" + orders.getStartTime());
List<DirectiveOrderSub> ordersSubList = ordersSubService.queryDataPoolSubList(orders);
String directiveIds = ordersSubList.stream().map(DirectiveOrderSub::getDirectiveId).collect(Collectors.joining(","));
if(orders.getIzPackage().equals("N")){
if (orders.getIzPackage().equals("N")) {
//获取满足条件的员工
DirectiveOrder employee = employeeScreening(directiveIds,orders.getElderId(),null,orders.getStartTime());
if(employee!=null){
DirectiveOrder employee = employeeScreening(directiveIds, orders.getElderId(), null, orders.getStartTime());
if (employee != null) {
String orderNo = getOrderNo();
orders.setOrderNo(orderNo);
orders.setEmployeeId(employee.getEmployeeId());
@ -157,7 +180,7 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
orders.setOptNames(employee.getEmployeeName());
orders.setServiceAllowedTimeout(allowedTimeout);
this.save(orders);//生成工单主表
for(int i=0;i<ordersSubList.size();i++){
for (int i = 0; i < ordersSubList.size(); i++) {
DirectiveOrderSub ordersSub = ordersSubList.get(i);
ordersSub.setOrderNo(getOrderSubNo(orderNo));
ordersSub.setMainId(orders.getId());
@ -169,17 +192,17 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
ordersSubService.save(ordersSub);//生成工单子表
}
baseMapper.updatePoolIzOrder(orders.getPoolId());
System.out.println("护理单元:"+orders.getNuId()+",服务时间:"+orders.getStartTime()+",服务员工:"+employee.getEmployeeName()+",获得积分:"+employee.getLevel());
System.out.println("护理单元:" + orders.getNuId() + ",服务时间:" + orders.getStartTime() + ",服务员工:" + employee.getEmployeeName() + ",获得积分:" + employee.getLevel());
System.out.println("");
System.out.println("");
System.out.println("");
}
}else{
} else {
List<DirectiveOrder> emps = baseMapper.getPermissionEmps(directiveIds);//获取服务标签中的员工和数量
emps.removeIf(data -> data.getOwnCn() < ordersSubList.size());//删除没有权限的数据
String employeeIds = emps.stream().map(DirectiveOrder::getEmployeeId).collect(Collectors.joining(","));
DirectiveOrder employee = employeeScreening(directiveIds,orders.getElderId(),employeeIds,orders.getStartTime());
if(employee!=null){
DirectiveOrder employee = employeeScreening(directiveIds, orders.getElderId(), employeeIds, orders.getStartTime());
if (employee != null) {
String orderNo = getOrderNo();
orders.setOrderNo(orderNo);
orders.setEmployeeId(employee.getEmployeeId());
@ -192,7 +215,7 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
orders.setOptNames(employee.getEmployeeName());
orders.setServiceAllowedTimeout(allowedTimeout);
this.save(orders);//生成工单主表
for(int i=0;i<ordersSubList.size();i++){
for (int i = 0; i < ordersSubList.size(); i++) {
DirectiveOrderSub ordersSub = ordersSubList.get(i);
ordersSub.setOrderNo(getOrderSubNo(orderNo));
ordersSub.setMainId(orders.getId());
@ -204,7 +227,7 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
ordersSubService.save(ordersSub);//生成工单子表
}
baseMapper.updatePoolIzOrder(orders.getPoolId());
System.out.println("护理单元:"+orders.getNuId()+",服务时间:"+orders.getStartTime()+",服务员工:"+employee.getEmployeeName()+",获得积分:"+employee.getLevel());
System.out.println("护理单元:" + orders.getNuId() + ",服务时间:" + orders.getStartTime() + ",服务员工:" + employee.getEmployeeName() + ",获得积分:" + employee.getLevel());
System.out.println("");
System.out.println("");
System.out.println("");
@ -215,9 +238,10 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
/**
* 获取满足条件的员工
*
* @return
*/
private DirectiveOrder employeeScreening(String directiveIds, String elderId, String employeeIds, Date startTime){
private DirectiveOrder employeeScreening(String directiveIds, String elderId, String employeeIds, Date startTime) {
if (sendOrderRule.getRuleCode().equals("1")) {
//按优先级
return getByPriority(directiveIds, elderId, startTime, employeeIds);
@ -235,49 +259,49 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
* @return
*/
private DirectiveOrder getByPriority(String directiveIds, String elderId, Date startTime, String employeeIds) {
List<DirectiveOrder> empList = getEmpPermissionAndOnline(directiveIds,employeeIds,startTime);
List<DirectiveOrder> empList = getEmpPermissionAndOnline(directiveIds, employeeIds, startTime);
if (empList.size() > 0) {
for(int i=0;i<empList.size();i++){
for (int i = 0; i < empList.size(); i++) {
DirectiveOrder emp = empList.get(i);
System.out.println("员工信息:"+emp.getEmployeeName()+","+emp.getOrderCap()+","+emp.getOrderNum()+","+emp.getTotalDuration()+","+emp.getTotalComPrice()+","+emp.getMaxTime()+","+emp.getOwnCn()+","+emp.getIzFree());
System.out.println("员工信息:" + emp.getEmployeeName() + "," + emp.getOrderCap() + "," + emp.getOrderNum() + "," + emp.getTotalDuration() + "," + emp.getTotalComPrice() + "," + emp.getMaxTime() + "," + emp.getOwnCn() + "," + emp.getIzFree());
}
if(ruleSubList.size()>0){
for(SendOrderRuleSub ruleSub : ruleSubList){
if (ruleSubList.size() > 0) {
for (SendOrderRuleSub ruleSub : ruleSubList) {
switch (ruleSub.getRuleCode()) {
case 1:
//空闲积分
sortByIzFree(empList,ruleSub.getCoefficient());
sortByIzFree(empList, ruleSub.getCoefficient());
break;
case 2:
//专员积分
sortByOrderly(empList,ruleSub.getCoefficient(),elderId);
sortByOrderly(empList, ruleSub.getCoefficient(), elderId);
break;
case 3:
//单次积分
sortByNumAndSetLevel(empList,ruleSub.getCoefficient());
sortByNumAndSetLevel(empList, ruleSub.getCoefficient());
break;
case 4:
//收益积分
sortByPriceAndSetLevel(empList,ruleSub.getCoefficient());
sortByPriceAndSetLevel(empList, ruleSub.getCoefficient());
break;
case 5:
//服务时长积分
sortByDurationAndSetLevel(empList,ruleSub.getCoefficient());
sortByDurationAndSetLevel(empList, ruleSub.getCoefficient());
break;
case 6:
//最后接单时间积分
sortByMaxTimeAndSetLevel(empList,ruleSub.getCoefficient());
sortByMaxTimeAndSetLevel(empList, ruleSub.getCoefficient());
break;
case 7:
//超出上限积分
sortByLimit(empList,ruleSub.getCoefficient());
sortByLimit(empList, ruleSub.getCoefficient());
break;
}
}
//获取员工信息
sortEmpList(empList);
return empList.get(0);
}else{
} else {
//随机获取一个员工
Random random = new Random();
return empList.get(random.nextInt(empList.size()));
@ -292,17 +316,17 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
* @return
*/
private DirectiveOrder getByHeadCount(String directiveIds, String elderId, Date startTime, String employeeIds) {
List<DirectiveOrder> empList = getEmpPermissionAndOnline(directiveIds,employeeIds,startTime);
List<DirectiveOrder> empList = getEmpPermissionAndOnline(directiveIds, employeeIds, startTime);
if (empList.size() > 0) {
List<DirectiveOrder> newList = new ArrayList();
newList.addAll(empList);
for(int i=0;i<empList.size();i++){
for (int i = 0; i < empList.size(); i++) {
DirectiveOrder emp = empList.get(i);
System.out.println("员工信息:"+emp.getEmployeeName()+","+emp.getOrderCap()+","+emp.getOrderNum()+","+emp.getTotalDuration()+","+emp.getTotalComPrice()+","+emp.getMaxTime()+","+emp.getOwnCn()+","+emp.getIzFree());
System.out.println("员工信息:" + emp.getEmployeeName() + "," + emp.getOrderCap() + "," + emp.getOrderNum() + "," + emp.getTotalDuration() + "," + emp.getTotalComPrice() + "," + emp.getMaxTime() + "," + emp.getOwnCn() + "," + emp.getIzFree());
}
//****************获取指定护理员工列表不指定的排除掉=============================>
getByOrderly(empList,elderId);
getByOrderly(empList, elderId);
if (empList.size() > 0) {
if (ruleSubList.size() > 0) {
for (SendOrderRuleSub ruleSub : ruleSubList) {
@ -341,7 +365,7 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
Random random = new Random();
return empList.get(random.nextInt(empList.size()));
}
}else{
} else {
//随机获取一个员工
Random random = new Random();
return newList.get(random.nextInt(newList.size()));
@ -363,7 +387,7 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
empLevel = empLevel + empList.size() * coefficient; //提高N等级
emp.setLevel(empLevel);
}
System.out.println("员工获取空闲积分信息:"+emp.getEmployeeId()+"-"+emp.getEmployeeName()+"["+emp.getLevel()+"]");
System.out.println("员工获取空闲积分信息:" + emp.getEmployeeId() + "-" + emp.getEmployeeName() + "[" + emp.getLevel() + "]");
}
}
@ -385,7 +409,7 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
emp.setLevel(empLevel);
}
}
System.out.println("员工获取指定护理积分信息:"+emp.getEmployeeId()+"-"+emp.getEmployeeName()+"["+emp.getLevel()+"]");
System.out.println("员工获取指定护理积分信息:" + emp.getEmployeeId() + "-" + emp.getEmployeeName() + "[" + emp.getLevel() + "]");
}
}
@ -403,10 +427,10 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
// 为level字段顺序赋值1,2,3...
for (int i = 0; i < sortedEmployees.size(); i++) {
DirectiveOrder emp = sortedEmployees.get(i);
Integer levle = emp.getLevel()*coefficient + i + 1;
Integer levle = emp.getLevel() * coefficient + i + 1;
emp.setLevel(levle);
System.out.println("员工获取工单数积分信息:"+emp.getEmployeeId()+"-"+emp.getEmployeeName()+"["+emp.getLevel()+"]");
System.out.println("员工获取工单数积分信息:" + emp.getEmployeeId() + "-" + emp.getEmployeeName() + "[" + emp.getLevel() + "]");
}
// 如果需要返回新列表可以返回sortedEmployees
// 如果要在原列表上修改可以清空原列表并添加所有元素
@ -428,10 +452,10 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
// 为level字段顺序赋值1,2,3...
for (int i = 0; i < sortedEmployees.size(); i++) {
DirectiveOrder emp = sortedEmployees.get(i);
Integer levle = emp.getLevel()*coefficient + i + 1;
Integer levle = emp.getLevel() * coefficient + i + 1;
emp.setLevel(levle);
System.out.println("员工获取工单收益积分信息:"+emp.getEmployeeId()+"-"+emp.getEmployeeName()+"["+emp.getLevel()+"]");
System.out.println("员工获取工单收益积分信息:" + emp.getEmployeeId() + "-" + emp.getEmployeeName() + "[" + emp.getLevel() + "]");
}
// 如果需要返回新列表可以返回sortedEmployees
@ -454,10 +478,10 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
// 为level字段顺序赋值1,2,3...
for (int i = 0; i < sortedEmployees.size(); i++) {
DirectiveOrder emp = sortedEmployees.get(i);
Integer levle = emp.getLevel()*coefficient + i + 1;
Integer levle = emp.getLevel() * coefficient + i + 1;
emp.setLevel(levle);
System.out.println("员工获取服务时长积分信息:"+emp.getEmployeeId()+"-"+emp.getEmployeeName()+"["+emp.getLevel()+"]");
System.out.println("员工获取服务时长积分信息:" + emp.getEmployeeId() + "-" + emp.getEmployeeName() + "[" + emp.getLevel() + "]");
}
// 如果需要返回新列表可以返回sortedEmployees
@ -483,10 +507,10 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
// 为level字段顺序赋值1,2,3...
for (int i = 0; i < sortedEmployees.size(); i++) {
DirectiveOrder emp = sortedEmployees.get(i);
Integer levle = emp.getLevel()*coefficient + i + 1;
Integer levle = emp.getLevel() * coefficient + i + 1;
emp.setLevel(levle);
System.out.println("员工获取派单时间积分信息:"+emp.getEmployeeId()+"-"+emp.getEmployeeName()+"["+emp.getLevel()+"]");
System.out.println("员工获取派单时间积分信息:" + emp.getEmployeeId() + "-" + emp.getEmployeeName() + "[" + emp.getLevel() + "]");
}
// 如果需要返回新列表可以返回sortedEmployees
@ -508,7 +532,7 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
Integer levle = emp.getLevel() + empList.size() * coefficient;
emp.setLevel(levle);
System.out.println("员工获取单上限积分信息:"+emp.getEmployeeId()+"-"+emp.getEmployeeName()+"["+emp.getLevel()+"]");
System.out.println("员工获取单上限积分信息:" + emp.getEmployeeId() + "-" + emp.getEmployeeName() + "[" + emp.getLevel() + "]");
}
}
}
@ -527,9 +551,9 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
// 如果要在原列表上修改可以清空原列表并添加所有元素
empList.clear();
empList.addAll(sortedEmployees);
for(int i=0;i<empList.size();i++){
for (int i = 0; i < empList.size(); i++) {
DirectiveOrder emp = empList.get(i);
System.out.println("员工获取总积分信息:"+emp.getEmployeeId()+"-"+emp.getEmployeeName()+"["+emp.getLevel()+"]");
System.out.println("员工获取总积分信息:" + emp.getEmployeeId() + "-" + emp.getEmployeeName() + "[" + emp.getLevel() + "]");
}
}
@ -554,17 +578,18 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
}
empList.clear();
empList.addAll(newList);
for(int i=0;i<empList.size();i++){
for (int i = 0; i < empList.size(); i++) {
DirectiveOrder emp = empList.get(i);
System.out.println("获取指定护理员工信息:"+emp.getEmployeeId()+"-"+emp.getEmployeeName());
System.out.println("获取指定护理员工信息:" + emp.getEmployeeId() + "-" + emp.getEmployeeName());
}
}
/**
* 获取单号
*
* @return
*/
private String getOrderNo(){
private String getOrderNo() {
JSONObject deptInfo = sysBaseAPI.getDeptInfo();
String deptCode = deptInfo.getString("code");
String today = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));
@ -577,23 +602,24 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
qw.last("limit 1");
DirectiveOrder entity = this.getOne(qw);
int todayNo = 0;
if(entity!=null){
if (entity != null) {
String orderNo = entity.getOrderNo();
if(orderNo!=null&&!orderNo.equals("")){
if (orderNo != null && !orderNo.equals("")) {
String todayNoStr = orderNo.substring(todayPrefix.length());
todayNo = Integer.parseInt(todayNoStr);
}
}
todayNo = todayNo +1;
todayNo = todayNo + 1;
String frontNo = String.format("%04d", todayNo);
return todayPrefix+frontNo;
return todayPrefix + frontNo;
}
/**
* 获取子单号
*
* @return
*/
private String getOrderSubNo(String mainOrderNo){
private String getOrderSubNo(String mainOrderNo) {
QueryWrapper<DirectiveOrderSub> qw = new QueryWrapper<>();
qw.likeRight("order_no", mainOrderNo);
qw.select("order_no");
@ -601,53 +627,54 @@ public class DirectiveOrderServiceImpl extends ServiceImpl<DirectiveOrderMapper,
qw.last("limit 1");
DirectiveOrderSub entity = ordersSubService.getOne(qw);
int todayNo = 0;
if(entity!=null){
if (entity != null) {
String orderNo = entity.getOrderNo();
if(orderNo!=null&&!orderNo.equals("")){
if (orderNo != null && !orderNo.equals("")) {
String todayNoStr = orderNo.substring(mainOrderNo.length());
todayNo = Integer.parseInt(todayNoStr);
}
}
todayNo = todayNo +1;
todayNo = todayNo + 1;
String frontNo = String.format("%03d", todayNo);
return mainOrderNo+frontNo;
return mainOrderNo + frontNo;
}
/**
* 生成即时服务指令工单
*
* @param directiveOrder
* @return
*/
@Override
public Map<String, Object> generateOrdersInstant(DirectiveOrder directiveOrder){
public Map<String, Object> generateOrdersInstant(DirectiveOrder directiveOrder) {
Map<String, Object> map = new HashMap<>();
map.put("success",true);
map.put("message","操作成功");
map.put("success", true);
map.put("message", "操作成功");
String orderType = directiveOrder.getOrderType();
if(orderType.equals("1")){
if (orderType.equals("1")) {
//护理即时
directiveOrder.setTableName("nu_biz_nu_care_directive_plan_instant");
}
if(orderType.equals("2")){
if (orderType.equals("2")) {
//医疗即时
directiveOrder.setTableName("nu_biz_nu_medical_directive_plan_instant");
}
if(orderType.equals("3")){
if (orderType.equals("3")) {
//仓库即时
directiveOrder.setTableName("nu_biz_nu_invoicing_directive_plan_instant");
}
if(orderType.equals("4")){
if (orderType.equals("4")) {
//后勤即时
directiveOrder.setTableName("nu_biz_nu_logistics_directive_plan_instant");
}
DirectiveOrder directiveInfo = baseMapper.getDirectiveById(directiveOrder);
if(directiveOrder.getTriggerMode().equals("1")){
if (directiveOrder.getTriggerMode().equals("1")) {
//直接派单给发起人
LoginUser sysUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
String employeeId = sysUser.getEmployessId();
}else{
} else {
//按规则派单
getSendOrderRule();