111

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/AuditApiServiceImpl.java

@@ -30,8 +30,11 @@ import com.gic.haoban.common.utils.PageUtil;
 import com.gic.haoban.common.utils.UuidUtil;
 import com.gic.haoban.manage.api.dto.AuditDTO;
 import com.gic.haoban.manage.api.dto.StoreAddressDTO;
+import com.gic.haoban.manage.api.enums.AppPageType;
 import com.gic.haoban.manage.api.enums.StoreFieldEnum;
 import com.gic.haoban.manage.api.service.AuditApiService;
+import com.gic.haoban.manage.api.service.StaffDepartmentRelatedApiService;
+import com.gic.haoban.manage.service.config.Config;
 import com.gic.haoban.manage.service.dao.mapper.DepartmentMapper;
 import com.gic.haoban.manage.service.dao.mapper.StaffMapper;
 import com.gic.haoban.manage.service.dao.mapper.TabHaobanAuditMapper;
@@ -60,6 +63,10 @@ public class AuditApiServiceImpl implements AuditApiService{
 	private StoreService storeService;
 	@Autowired
 	private QywxSuiteApiService qywxSuiteApiService;
+	@Autowired
+	private Config config;
+	@Autowired
+	private StaffDepartmentRelatedApiService staffDepartmentRelatedApiService;
 	
 	@Override
 	public Page<AuditDTO> page(Integer auditType, String search,String wxEnterpriseId,
@@ -117,13 +124,15 @@ public class AuditApiServiceImpl implements AuditApiService{
 		String newValue = tab.getNewValue();
 		String changeField = tab.getChangeField();
 		this.editStoreInfo(storeId, changeField, oldValue, newValue);
-		//名字
-		String title = StoreFieldEnum.getValueName(changeField);
-		title = "["+title+"]"+"修改审核通过";
 		
-//		QywxXcxSendMessageDTO messageDTO = new QywxXcxSendMessageDTO();
-//		config.getWxSuiteid();
-//		qywxSuiteApiService.sendMessage("ww9ede832a84b7ae5f","ww2c34dc56739bb105", messageDTO);
+		
+		//发送消息
+		String title = "门店信息修改通知";
+		String content = StoreFieldEnum.getValueName(changeField);
+		content = "["+content+"]"+"修改审核通过";
+		TabHaobanAudit tab2 = auditMapper.selectByPrimaryKey(auditId);
+		String staffId = tab2.getCommitStaffId();
+		this.sendMessageByStaffId(staffId, storeId, title, content);
 	}
 	@Override
 	public void refuse(String auditId, String auditReason,String auditName) {
@@ -135,11 +144,16 @@ public class AuditApiServiceImpl implements AuditApiService{
 		tab.setAuditName(auditName);
 		auditMapper.updateByPrimaryKeySelective(tab);	
 		
-		
+		//发送消息
 		TabHaobanAudit tab2 = auditMapper.selectByPrimaryKey(auditId);
 		String changeField = tab2.getChangeField();
-		String title = StoreFieldEnum.getValueName(changeField);
-		title = "["+title+"]"+"被拒绝。拒绝理由："+auditReason;
+		String title = "门店信息修改通知";
+		String content = StoreFieldEnum.getValueName(changeField);
+		content = "["+content+"]"+"被拒绝。拒绝理由："+auditReason;
+		String staffId = tab2.getCommitStaffId();
+		String storeId = tab2.getCommitStoreId();
+		this.sendMessageByStaffId(staffId, storeId, title, content);
+		
 	}
 	@Override
 	public int  save(Integer auditType,String wxEnterpriseId, String enterpriseId,
@@ -260,4 +274,29 @@ public class AuditApiServiceImpl implements AuditApiService{
 		}
 		return EntityUtil.changeEntityByJSON(AuditDTO.class, tab);
 	}
+	
+	
+	public void sendMessageByStaffId(String staffId,String storeId,String title,String content){
+		TabHaobanStaff staff = staffMapper.selectByPrimaryKey(staffId);
+		if(staff == null){
+			logger.info("staff不存在");
+			return;
+		}
+		String wxUserId = staff.getWxUserId();
+		JSONObject jsonObject = new JSONObject();
+		jsonObject.put("storeId", storeId);
+		String data = jsonObject.toJSONString();
+		String pageUrl = staffDepartmentRelatedApiService.getPageUrl(AppPageType.STORE_DETAIL.getCode(), data);
+		
+		QywxXcxSendMessageDTO messageDTO = new QywxXcxSendMessageDTO();
+        ArrayList<String> list = new ArrayList<>();
+        list.add(wxUserId);
+		messageDTO.setAppid(config.getAppid());
+        messageDTO.setUserIds(list);
+        messageDTO.setPage(pageUrl);
+        messageDTO.setTitle(title);
+        messageDTO.setDescription(content);
+		boolean b = qywxSuiteApiService.sendMessage(config.getCorpid(), config.getSuiteId(), messageDTO);
+
+	}
 }