绑定code的消息推送

haoban-manage3-web/src/main/java/com/gic/haoban/manage/web/controller/ClerkController.java

@@ -12,6 +12,8 @@ import org.springframework.web.bind.annotation.RestController;
 
 import cn.hutool.core.collection.CollectionUtil;
 
+import com.alibaba.csp.sentinel.util.StringUtil;
+import com.alibaba.fastjson.JSONObject;
 import com.gic.clerk.api.dto.ClerkDTO;
 import com.gic.clerk.api.service.ClerkService;
 import com.gic.commons.util.EntityUtil;
@@ -19,6 +21,7 @@ import com.gic.haoban.common.utils.HaobanResponse;
 import com.gic.haoban.manage.api.dto.DepartmentDTO;
 import com.gic.haoban.manage.api.dto.StaffDTO;
 import com.gic.haoban.manage.api.dto.StaffDepartmentRelatedDTO;
+import com.gic.haoban.manage.api.enums.AppPageType;
 import com.gic.haoban.manage.api.service.DepartmentApiService;
 import com.gic.haoban.manage.api.service.StaffApiService;
 import com.gic.haoban.manage.api.service.StaffDepartmentRelatedApiService;
@@ -93,7 +96,7 @@ public class ClerkController extends WebBaseController{
 			return resultResponse(HaoBanErrCode.ERR_2);
 		}
 		StaffDepartmentRelatedDTO staffDepartmentRelatedDTO = staffDepartmentRelatedApiService.getByStaffDepartmentRelatedId(fromStaffDepartmentRelatedId);
-
+		String oldClerkCode = staffDepartmentRelatedDTO.getClerkCode();
 		//将指定人绑定clerkCode
 		StaffDepartmentRelatedDTO dto = new StaffDepartmentRelatedDTO();
 		dto.setStaffDepartmentRelatedId(fromStaffDepartmentRelatedId);
@@ -125,6 +128,23 @@ public class ClerkController extends WebBaseController{
 				clerkService.updateClerk(clerkDTO);
 			}
 		}
+		
+		//发送消息
+		if(StringUtil.isNotBlank(oldClerkCode)){
+			//发送消息
+            ClerkDTO leader = clerkService.getClerkLeaderByStoreId(storeId);
+            String clerkId = leader.getClerkId();
+			String storeName = departmentDTO.getDepartmentName();
+			String staffName = staffDTO.getStaffName();
+			String leaderName = leader.getClerkName();
+			String clerkCode = oldClerkCode;
+			String content = "【"+leaderName+"】:【"+storeName+"】"+staffName+"导购code:"+clerkCode+"已解绑，请重新分配会员！";
+			JSONObject jsonObject = new JSONObject();
+			jsonObject.put("storeId", storeId);
+			String data = jsonObject.toJSONString();
+			String pageUrl = staffDepartmentRelatedApiService.getPageUrl(AppPageType.MEMBER_LIST.getCode(), data);
+			staffDepartmentRelatedApiService.sendSingleMessage(clerkId, "分配会员通知", content, pageUrl);
+		}
 		return resultResponse(HaoBanErrCode.ERR_1);
 	}