添加管家消息

src/main/java/com/huiju/estateagents/property/service/impl/TpTicketServiceImpl.java

@@ -11,7 +11,10 @@ import com.google.common.collect.Maps;
 import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.center.taUser.entity.TaUser;
 import com.huiju.estateagents.center.taUser.mapper.TaUserMapper;
+import com.huiju.estateagents.common.WxUtils;
+import com.huiju.estateagents.entity.TaMiniapp;
 import com.huiju.estateagents.entity.TaPerson;
+import com.huiju.estateagents.mapper.TaMiniappMapper;
 import com.huiju.estateagents.mapper.TaPersonMapper;
 import com.huiju.estateagents.property.common.Constant;
 import com.huiju.estateagents.property.dao.*;
@@ -21,11 +24,24 @@ import com.huiju.estateagents.property.mapper.TpRepairTypeMapper;
 import com.huiju.estateagents.property.model.*;
 import com.huiju.estateagents.property.service.TpTicketService;
 import com.huiju.estateagents.property.vo.TpTicketVO;
+import com.huiju.estateagents.redpack.entity.TaMpMiniapp;
+import com.huiju.estateagents.redpack.entity.TaMpPerson;
+import com.huiju.estateagents.redpack.mapper.TaMpMiniappMapper;
+import com.huiju.estateagents.redpack.mapper.TaMpPersonMapper;
+import com.huiju.estateagents.redpack.service.ITaMpPersonService;
+import com.huiju.estateagents.service.IMiniAppService;
 import com.huiju.estateagents.service.ISysSmsEventService;
+import com.huiju.estateagents.third.entity.TaMpInfo;
+import com.huiju.estateagents.third.service.ITaMpInfoService;
+import me.chanjar.weixin.common.error.WxErrorException;
+import me.chanjar.weixin.mp.api.WxMpService;
+import me.chanjar.weixin.mp.bean.kefu.WxMpKefuMessage;
+import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
 import org.apache.commons.lang3.StringUtils;
 import org.checkerframework.checker.units.qual.A;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -83,6 +99,27 @@ public class TpTicketServiceImpl extends ServiceImpl<TpTicketMapper, TpTicket> i
     @Autowired
     private ISysSmsEventService sysSmsEventService;
 
+    @Autowired
+    ITaMpInfoService iTaMpInfoService;
+
+    @Autowired
+    ITaMpPersonService iTaMpPersonService;
+
+    @Autowired
+    private IMiniAppService iMiniAppService;
+
+    @Autowired
+    WxUtils wxUtils;
+
+    @Value("${wx.miniapp.ticket}")
+    String miniAppTicket;
+
+    @Autowired
+    private TaMpMiniappMapper taMpMiniappMapper;
+
+    @Autowired
+    private TaMpPersonMapper taMpPersonMapper;
+
     @Override
     public ResponseBean ticketLiset(String parameter,Integer orgId) {
          ResponseBean response= new ResponseBean<>();
@@ -309,37 +346,53 @@ public class TpTicketServiceImpl extends ServiceImpl<TpTicketMapper, TpTicket> i
         queryWrapper.eq("id", ticketId);
         queryWrapper.eq("org_id", orgId);
         TpTicket ticket = tpTicketMapper.selectOne(queryWrapper);
-        Message message = new Message();
-        message.setOrgId(orgId);
-        message.setMessageType(ticket.getType());
-        message.setTicketId(ticket.getId());
-        message.setAdviceType("4");
-        message.setUuid(userID.toString());
-        message.setModelType("2");
-        message.setUuidType("2");
-        message.setSource("2");
-        message.setMessageContent("工单“" + ticket.getTicketTitle() + "”已被分配给您，点击查看并处理");
-        message.setStatus("1");
-        message.setReadStatus("0");
-        message.setCreateUser(user.toString());
-        message.setCreateDate(LocalDateTime.now());
-        message.setTicketId(ticketId);
-//        messageMapper.insert(message);
-        //如果分配给本人维护消息模板
-        if (null!=userID&userID.equals(user)){
-            message.setModelType("1");
-//            messageMapper.insert(message);
+        // 发送消息给管家的公众号
+        LambdaQueryWrapper<TaPerson> taPersonLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        taPersonLambdaQueryWrapper.eq(TaPerson::getOrgId,orgId);
+        taPersonLambdaQueryWrapper.eq(TaPerson::getUserId,taUser.getUserId());
+        TaPerson taPerson = taPersonMapper.selectOne(taPersonLambdaQueryWrapper);
+        if (null != taPerson){
+            LambdaQueryWrapper<TaMpMiniapp> taMpMiniappLambdaQueryWrapper = new LambdaQueryWrapper<>();
+            taMpMiniappLambdaQueryWrapper.eq(TaMpMiniapp::getMiniappPersonId,taPerson.getPersonId());
+            TaMpMiniapp taMpMiniapp = taMpMiniappMapper.selectOne(taMpMiniappLambdaQueryWrapper);
+            if (null != taMpMiniapp){
+                TaMpPerson taMpPerson = taMpPersonMapper.selectById(taMpMiniapp.getMpPersonId());
+                sendMpTicketMessage(ticket,taMpPerson);
+            }
+
         }
-        //分配成功后推送app
-        message.setUuidType("1");
-        message.setUuid(ticket.getCreateUser());
-        message.setMessageContent("工单“" + ticket.getTicketTitle() + "”已被分配给:"+taUser.getUserName());
-        message.setAdviceType("1");
-//        messageMapper.insert(message);
+
         response.addSuccess("成功");
         return response;
     }
 
+    /**
+     * 发送消息给管家
+     * @param ticket
+     * @param person
+     */
+    private void sendMpTicketMessage(TpTicket ticket,TaMpPerson person) {
+        WxMpService mpService = wxUtils.getMpService(ticket.getOrgId());
+
+        // 对应表数据
+        TaMpInfo mpInfo = iTaMpInfoService.getByOrgId(ticket.getOrgId());
+
+        TaMiniapp taMiniapp = iMiniAppService.getAppByOrg(mpInfo.getOrgId());
+
+        WxMpKefuMessage kefuMessage = WxMpKefuMessage.MINIPROGRAMPAGE().appId(taMiniapp.getMiniappId())
+                .toUser(person.getMpOpenid())
+                .title(taMiniapp.getName() + "有您的订单需要分配!")
+                .pagePath(miniAppTicket + ticket.getId() + "&mpOpenId=" + person.getMpOpenid() )
+                .thumbMediaId(mpInfo.getMiniappMedia())
+                .build();
+
+        try {
+            mpService.getKefuService().sendKefuMessage(kefuMessage);
+        } catch (WxErrorException e) {
+            e.printStackTrace();
+        }
+    }
+
     @Override
     public ResponseBean addWxRecord(String parameter, Integer user, Integer orgId) {
         ResponseBean response=new ResponseBean();

src/main/resources/application.yml

@@ -14,6 +14,7 @@ sms-service:
 wx:
   miniapp:
     index: /pages/ShouYe/index
+    ticket: pages/WuYe/BaoXiuDetail/index?id=
   mp:
     festivalH5: https://xs.ycjcjy.com/jierih5.html
     birthdayH5: https://xs.ycjcjy.com/shengrih5.html