优化投诉单功能

java110-bean/src/main/java/com/java110/dto/data/DatabusDataDto.java

@@ -33,6 +33,9 @@ public class DatabusDataDto extends PageDto implements Serializable {
     public static final String BUSINESS_TYPE_SEND_COMMUNITY_DATA_TO_IOT = "sendCommunityDataToIot";
 
 
+    public static final String BUSINESS_TYPE_SEND_COMPLAINT_NOTIFY_STAFF = "sendComplaintNotifyStaff"; // 发送投诉给员工
+
+
     private String businessTypeCd;
 
     private JSONObject data;

service-job/src/main/java/com/java110/job/adapt/complaint/SendComplaintNotifyStaffAdapt.java

@@ -0,0 +1,82 @@
+package com.java110.job.adapt.complaint;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.log.LoggerFactory;
+import com.java110.dto.complaint.ComplaintDto;
+import com.java110.dto.complaintTypeUser.ComplaintTypeUserDto;
+import com.java110.dto.system.Business;
+import com.java110.intf.store.IComplaintTypeUserV1InnerServiceSMO;
+import com.java110.intf.store.IComplaintV1InnerServiceSMO;
+import com.java110.job.adapt.DatabusAdaptImpl;
+import com.java110.job.adapt.Repair.MachineReturnRepairAdapt;
+import com.java110.job.msgNotify.MsgNotifyFactory;
+import com.java110.po.owner.RepairUserPo;
+import com.java110.utils.cache.MappingCache;
+import com.java110.utils.constant.MappingConstant;
+import com.java110.utils.util.ListUtil;
+import com.java110.utils.util.StringUtil;
+import org.slf4j.Logger;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 投诉单推送消息给员工
+ */
+
+@Component(value = "sendComplaintNotifyStaffAdapt")
+public class SendComplaintNotifyStaffAdapt extends DatabusAdaptImpl {
+
+    private static Logger logger = LoggerFactory.getLogger(SendComplaintNotifyStaffAdapt.class);
+
+
+    @Autowired
+    private IComplaintV1InnerServiceSMO complaintV1InnerServiceSMOImpl;
+
+    @Autowired
+    private IComplaintTypeUserV1InnerServiceSMO complaintTypeUserV1InnerServiceSMOImpl;
+
+
+    @Override
+    public void execute(Business business, List<Business> businesses) throws Exception {
+        JSONObject data = business.getData();
+
+        String complaintId = data.getString("complaintId");
+
+        if (StringUtil.isEmpty(complaintId)) {
+            return;
+        }
+
+
+        ComplaintDto complaintDto = new ComplaintDto();
+        complaintDto.setComplaintId(complaintId);
+        List<ComplaintDto> complaintDtos = complaintV1InnerServiceSMOImpl.queryComplaints(complaintDto);
+
+        if (ListUtil.isNull(complaintDtos)) {
+            return;
+        }
+
+        ComplaintTypeUserDto complaintTypeUserDto = new ComplaintTypeUserDto();
+        complaintTypeUserDto.setTypeCd(complaintDtos.get(0).getTypeCd());
+        List<ComplaintTypeUserDto> complaintTypeUserDtos = complaintTypeUserV1InnerServiceSMOImpl.queryComplaintTypeUsers(complaintTypeUserDto);
+
+        if (ListUtil.isNull(complaintTypeUserDtos)) {
+            return;
+        }
+
+        JSONObject content = new JSONObject();
+        content.put("complaintName", complaintDtos.get(0).getComplaintName());
+        content.put("orderId", complaintId);
+
+        String wechatUrl = MappingCache.getValue(MappingConstant.URL_DOMAIN, "STAFF_WECHAT_URL");
+        content.put("url", wechatUrl);
+
+        for(ComplaintTypeUserDto tmpComplaintTypeUserDto:complaintTypeUserDtos) {
+            MsgNotifyFactory.sendComplaintMsg(tmpComplaintTypeUserDto.getCommunityId(), tmpComplaintTypeUserDto.getStaffId(), content);
+        }
+
+    }
+
+}

service-job/src/main/java/com/java110/job/msgNotify/IMsgNotify.java

@@ -154,4 +154,13 @@ public interface IMsgNotify {
      * @return
      */
     ResultVo sendOaCreateStaffMsg(String communityId, String userId, JSONObject content);
+
+    /**
+     * 投诉通知 员工
+     * @param communityId
+     * @param userId
+     * @param content
+     * @return
+     */
+    ResultVo sendComplaintMsg(String communityId, String userId, JSONObject content);
 }

service-job/src/main/java/com/java110/job/msgNotify/MsgNotifyFactory.java

@@ -355,4 +355,25 @@ public class MsgNotifyFactory {
 
         return notify;
     }
+
+    /**
+     * 投诉通知消息
+     * @param communityId
+     * @param staffId
+     * @param content
+     */
+    public static ResultVo sendComplaintMsg(String communityId, String staffId, JSONObject content) {
+
+        ResultVo resultVo = null;
+        try {
+            IMsgNotify msgNotify = getMsgNotify();
+            resultVo = msgNotify.sendComplaintMsg(communityId, staffId, content);
+        } catch (Exception e) {
+            e.printStackTrace();
+            logger.error("通知 业主报修时 消息", e);
+            resultVo = new ResultVo(ResultVo.CODE_ERROR, e.getMessage());
+        }
+
+        return resultVo;
+    }
 }

service-job/src/main/java/com/java110/job/msgNotify/ali/AliMsgNotifyImpl.java

@@ -23,6 +23,7 @@ import com.java110.job.msgNotify.IMsgNotify;
 import com.java110.utils.cache.MappingCache;
 import com.java110.utils.util.Assert;
 import com.java110.utils.util.DateUtil;
+import com.java110.utils.util.ListUtil;
 import com.java110.utils.util.StringUtil;
 import com.java110.vo.ResultVo;
 import org.slf4j.Logger;
@@ -449,7 +450,7 @@ public class AliMsgNotifyImpl implements IMsgNotify {
         UserDto userDto = new UserDto();
         userDto.setUserId(userId);
         List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);
-        if (userDtos == null || userDtos.size() < 1) {
+        if (ListUtil.isNull(userDtos)) {
             throw new IllegalArgumentException("员工不存在");
         }
 
@@ -475,6 +476,72 @@ public class AliMsgNotifyImpl implements IMsgNotify {
         request.putQueryParameter("TemplateCode", templateCode);
 
 
+        JSONObject param = new JSONObject();
+        param.put("orderId", content.getString("orderId"));
+        request.putQueryParameter("TemplateParam", param.toString());
+
+        String resParam = "";
+        try {
+            CommonResponse response = client.getCommonResponse(request);
+            logger.debug("发送验证码信息：{}", response.getData());
+            resParam = response.getData();
+        } catch (Exception e) {
+            e.printStackTrace();
+            resParam = e.getMessage();
+            throw new IllegalArgumentException("短信工单失败" + e.getMessage());
+        } finally {
+            LogFactory.saveOutLog("SMS", param.toString(), new ResponseEntity(resParam, HttpStatus.OK));
+        }
+        return new ResultVo(ResultVo.CODE_OK, "成功");
+    }
+
+    /**
+     * 投诉通知员工
+     *
+     * @param communityId 小区
+     * @param userId      用户
+     * @param content     {
+     *                    complainName,
+     *                    orderId
+     *                    }
+     * @return
+     */
+    @Override
+    public ResultVo sendComplaintMsg(String communityId, String userId, JSONObject content) {
+        if (StringUtil.isEmpty(userId) || userId.startsWith("-")) {
+            throw new IllegalArgumentException("员工不存在,userId = " + userId);
+        }
+
+
+        UserDto userDto = new UserDto();
+        userDto.setUserId(userId);
+        List<UserDto> userDtos = userV1InnerServiceSMOImpl.queryUsers(userDto);
+        if (ListUtil.isNull(userDtos)) {
+            throw new IllegalArgumentException("员工不存在");
+        }
+
+
+        String accessKeyId = CommunitySettingFactory.getValue(communityId, "ALI_ACCESS_KEY_ID");
+        String accessSecret = CommunitySettingFactory.getValue(communityId, "ALI_ACCESS_SECRET");
+        String region = CommunitySettingFactory.getValue(communityId, "ALI_REGION");
+        String signName = CommunitySettingFactory.getValue(communityId, "ALI_SIGN_NAME");
+        String templateCode = CommunitySettingFactory.getValue(communityId, "ALI_COMPLAINT_TEMPLATE_CODE");
+        DefaultProfile profile = DefaultProfile.getProfile(region,
+                accessKeyId,
+                accessSecret);
+        IAcsClient client = new DefaultAcsClient(profile);
+
+        CommonRequest request = new CommonRequest();
+        request.setSysMethod(MethodType.POST);
+        request.setSysDomain("dysmsapi.aliyuncs.com");
+        request.setSysVersion("2017-05-25");
+        request.setSysAction("SendSms");
+        request.putQueryParameter("RegionId", region);
+        request.putQueryParameter("PhoneNumbers", userDtos.get(0).getTel());
+        request.putQueryParameter("SignName", signName);
+        request.putQueryParameter("TemplateCode", templateCode);
+
+
         JSONObject param = new JSONObject();
         param.put("orderId", content.getString("orderId"));
         request.putQueryParameter("TemplateParam", param.toString());

service-job/src/main/java/com/java110/job/msgNotify/wechat/WechatMsgNotifyImpl.java

@@ -19,6 +19,7 @@ import com.java110.job.msgNotify.MsgNotifyFactory;
 import com.java110.utils.cache.MappingCache;
 import com.java110.utils.constant.MappingConstant;
 import com.java110.utils.util.DateUtil;
+import com.java110.utils.util.ListUtil;
 import com.java110.utils.util.StringUtil;
 import com.java110.vo.ResultVo;
 import org.slf4j.Logger;
@@ -612,4 +613,54 @@ public class WechatMsgNotifyImpl implements IMsgNotify {
         JSONObject paramOut = JSONObject.parseObject(responseEntity.getBody());
         return new ResultVo(paramOut.getIntValue("errcode"), paramOut.getString("errmsg"));
     }
+
+    /**
+     * 投诉通知员工
+     *
+     * @param communityId 小区
+     * @param userId      用户
+     * @param content     {
+     *                    complainName
+     *                    }
+     * @return
+     */
+    @Override
+    public ResultVo sendComplaintMsg(String communityId, String userId, JSONObject content) {
+        String accessToken = wechatTemplateImpl.getAccessToken(communityId);
+
+        StaffAppAuthDto staffAppAuthDto = new StaffAppAuthDto();
+        staffAppAuthDto.setStaffId(userId);
+        staffAppAuthDto.setAppType("WECHAT");
+        List<StaffAppAuthDto> staffAppAuthDtos = staffAppAuthInnerServiceSMOImpl.queryStaffAppAuths(staffAppAuthDto);
+        if (ListUtil.isNull(staffAppAuthDtos)) {
+            throw new IllegalArgumentException("员工未认证，没有获取到微信openId");
+        }
+        String openId = staffAppAuthDtos.get(0).getOpenId();
+        Mapping mapping = MappingCache.getMapping(MappingConstant.WECHAT_DOMAIN, SPEC_CD_WECHAT_PROCESS_TEMPLATE);
+
+        if (mapping == null) {
+            throw new IllegalArgumentException("开发者账户编码映射未配置域为=" + MappingConstant.WECHAT_DOMAIN + ",键为=" + SPEC_CD_WECHAT_PROCESS_TEMPLATE);
+        }
+        String templateId = wechatTemplateImpl.getTemplateId(communityId, mapping.getValue(), mapping.getName(), templateKeys.get(SPEC_CD_WECHAT_PROCESS_TEMPLATE));
+
+        String url = sendMsgUrl + accessToken;
+
+        JSONObject data = new JSONObject();
+        PropertyFeeTemplateMessage templateMessage = new PropertyFeeTemplateMessage();
+        templateMessage.setTemplate_id(templateId);
+        templateMessage.setTouser(openId);
+        data.put("thing2", new Content("投诉单处理流程"));
+        data.put("time10", new Content(DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_B)));
+        data.put("thing9", new Content(content.getString("complaintName")));
+        templateMessage.setData(data);
+        //获取员工公众号地址
+        String wechatUrl = MappingCache.getValue(MappingConstant.URL_DOMAIN, "STAFF_WECHAT_URL");
+        templateMessage.setUrl(wechatUrl);
+        logger.info("发送模板消息内容:{}", JSON.toJSONString(templateMessage));
+        ResponseEntity<String> responseEntity = outRestTemplate.postForEntity(url, JSON.toJSONString(templateMessage), String.class);
+        logger.info("微信模板返回内容:{}", responseEntity);
+
+        JSONObject paramOut = JSONObject.parseObject(responseEntity.getBody());
+        return new ResultVo(paramOut.getIntValue("errcode"), paramOut.getString("errmsg"));
+    }
 }

service-store/src/main/java/com/java110/store/cmd/complaint/SaveComplaintCmd.java

@@ -28,6 +28,7 @@ import com.java110.dto.community.CommunityMemberDto;
 import com.java110.dto.complaint.ComplaintDto;
 import com.java110.dto.complaintEvent.ComplaintEventDto;
 import com.java110.dto.complaintType.ComplaintTypeDto;
+import com.java110.dto.data.DatabusDataDto;
 import com.java110.dto.file.FileDto;
 import com.java110.dto.room.RoomDto;
 import com.java110.dto.user.UserDto;
@@ -37,6 +38,7 @@ import com.java110.intf.community.ICommunityInnerServiceSMO;
 import com.java110.intf.community.ICommunityMemberV1InnerServiceSMO;
 import com.java110.intf.community.ICommunityV1InnerServiceSMO;
 import com.java110.intf.community.IRoomInnerServiceSMO;
+import com.java110.intf.job.IDataBusInnerServiceSMO;
 import com.java110.intf.store.IComplaintEventV1InnerServiceSMO;
 import com.java110.intf.store.IComplaintTypeV1InnerServiceSMO;
 import com.java110.intf.store.IComplaintV1InnerServiceSMO;
@@ -97,6 +99,9 @@ public class SaveComplaintCmd extends Cmd {
     @Autowired
     private IFileRelInnerServiceSMO fileRelInnerServiceSMOImpl;
 
+    @Autowired
+    private IDataBusInnerServiceSMO dataBusInnerServiceSMOImpl;
+
 
     @Override
     public void validate(CmdEvent event, ICmdDataFlowContext cmdDataFlowContext, JSONObject reqJson) {
@@ -186,6 +191,8 @@ public class SaveComplaintCmd extends Cmd {
         //todo 图片
         savePhone(reqJson, complaintPo);
 
+        //todo 发送消息给处理师傅
+        dataBusInnerServiceSMOImpl.databusData(new DatabusDataDto(DatabusDataDto.BUSINESS_TYPE_SEND_COMPLAINT_NOTIFY_STAFF,BeanConvertUtil.beanCovertJson(complaintPo)));
 
         cmdDataFlowContext.setResponseEntity(ResultVo.success());
     }