fix

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/service/MessageApiService.java

@@ -24,4 +24,13 @@ public interface MessageApiService {
      * @param param
      */
     void dealWxMessage(String param);
+    /**
+     * 发送消费消息
+     * @param clerkId
+     * @param memberName
+     * @param arrivalTime
+     * @param pageUrl
+     * @return
+     */
+	Boolean sendFaceMessage(String clerkId, String memberName, String arrivalTime, String pageUrl);
 }

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

@@ -14,25 +14,32 @@ import com.gic.haoban.manage.api.dto.DepartmentDTO;
 import com.gic.haoban.manage.api.dto.GicClerkDTO;
 import com.gic.haoban.manage.api.dto.GicMessageDTO;
 import com.gic.haoban.manage.api.dto.QywxCallBackDTO;
+import com.gic.haoban.manage.api.dto.StaffClerkRelationDTO;
 import com.gic.haoban.manage.api.dto.StaffDTO;
 import com.gic.haoban.manage.api.dto.StaffDepartmentRelatedDTO;
 import com.gic.haoban.manage.api.dto.WxApplicationDTO;
+import com.gic.haoban.manage.api.dto.WxEnterpriseDTO;
 import com.gic.haoban.manage.api.enums.GicDataType;
 import com.gic.haoban.manage.api.enums.GicEditType;
 import com.gic.haoban.manage.api.enums.WxEditType;
 import com.gic.haoban.manage.api.service.DepartmentApiService;
 import com.gic.haoban.manage.api.service.MessageApiService;
 import com.gic.haoban.manage.api.service.StaffApiService;
+import com.gic.haoban.manage.api.service.StaffClerkRelationApiService;
 import com.gic.haoban.manage.service.config.Config;
 import com.gic.haoban.manage.service.entity.*;
 import com.gic.haoban.manage.service.service.*;
 import com.gic.mq.sdk.GicMQClient;
 import com.gic.thirdparty.api.dto.PicUploadResDTO;
 import com.gic.thirdparty.api.service.QQCloudPicService;
+import com.gic.wechat.api.dto.qywx.ItemDTO;
+import com.gic.wechat.api.dto.qywx.QywxXcxSendMessageDTO;
 import com.gic.wechat.api.service.qywx.QywxDepartmentApiService;
+import com.gic.wechat.api.service.qywx.QywxSuiteApiService;
 
 import java.io.InputStream;
 import java.net.URL;
+import java.util.ArrayList;
 import java.util.List;
 
 import org.apache.commons.io.IOUtils;
@@ -81,6 +88,15 @@ public class MessageApiServiceImpl implements MessageApiService {
     
     @Autowired
     private StoreService storeService;
+    
+    @Autowired
+    private StaffClerkRelationApiService staffClerkRelationApiService;
+    
+    @Autowired
+    private QywxSuiteApiService qywxSuiteApiService;
+    
+    @Autowired
+    private WxEnterpriseService wxEnterpriseService;
 
     @Override
     public void gicMessageReceive(GicMessageDTO gicMessageDTO) {
@@ -492,6 +508,45 @@ public class MessageApiServiceImpl implements MessageApiService {
         //DepartmentDTO departmentDTO = this.departmentService.getRootByEnterpriseId(wxEnterpriseId);
         return null;
     }
+    
+    @Override
+    public Boolean sendFaceMessage(String clerkId,String memberName,String arrivalTime,String pageUrl) {
+    	StaffClerkRelationDTO relation = staffClerkRelationApiService.getByClerkId(clerkId);
+    	WxEnterpriseDTO wxEnterprise = wxEnterpriseService.selectById(relation.getWxEnterpriseId());
+    	if(wxEnterprise == null){
+    		log.info("企业为空");
+    		return false;
+    	}
+		if(relation != null){
+			String userId =  relation.getWxUserId();
+			QywxXcxSendMessageDTO messageDTO = new QywxXcxSendMessageDTO();
+			List<ItemDTO> items = new ArrayList();;
+			ItemDTO dto1 = new ItemDTO();
+			ItemDTO dto2 = new ItemDTO();
+			ItemDTO dto3 = new ItemDTO();
+			dto1.setKey("事件");
+			dto1.setValue("人脸匹配");
+			dto2.setKey("会员");
+			dto2.setValue(memberName);
+			dto3.setKey("到店时间");
+			dto3.setValue(arrivalTime);
+			items.add(dto1);
+			items.add(dto2);
+			items.add(dto3);
+	        ArrayList<String> list = new ArrayList<>();
+	        list.add(userId);
+			messageDTO.setAppid(config.getAppid());
+	        messageDTO.setUserIds(list);
+	        messageDTO.setPage(pageUrl);
+	        messageDTO.setTitle("我的顾客通知");
+	        messageDTO.setItems(items);
+
+			boolean b = qywxSuiteApiService.sendMessage(wxEnterprise.getCorpid(),config.getWxSuiteid(), messageDTO);
+			return b;
+		}
+		return false;
+		
+	}
 
     public static void main(String[] args){
         String parentChain = "1_";