工单，受理分配，正在处理，拒绝处理等接口.

CODE/smart-community/app-api/src/main/java/com/community/huiju/controller/TpTicketAndTransactionController.java

@@ -113,4 +113,46 @@ public class TpTicketAndTransactionController {
         return tpTicketManageDetails;
     }
 
+    @ApiOperation(value = "app端工单管理回复业主", notes = "app端工单管理回复业主")
+    @ApiImplicitParams({
+            @ApiImplicitParam(paramType = "body",dataType = "String",name = "parameter",value = "loginName:手机号,communityId:小区,content:对话内容，imageUrl:[]图片,ticketId:工单id，" +
+                    "status:工单状态（0:待分配  1:拒绝受理 2:待处理 3:正在处理 4:待评价 5:已评价 6:已终止）")
+    })
+    @RequestMapping(value = "/tpTicketManage/reply",method = RequestMethod.POST)
+    public ResponseBean tpTicketManageReply(@RequestBody String parameter) {
+        ResponseBean tpTicketManageReply= socialServiceI.tpTicketManageReply(parameter);
+        return tpTicketManageReply;
+    }
+
+    @ApiOperation(value = "app端工单管理受理分配", notes = "app端工单管理受理分配")
+    @ApiImplicitParams({
+            @ApiImplicitParam(paramType = "body",dataType = "String",name = "parameter",value = "loginName:手机号,communityId:小区,ticketId:工单id，" +
+                    "id:当前处理人id")
+    })
+    @RequestMapping(value = "/ticketManage/addRecord", method = RequestMethod.POST)
+    public ResponseBean ticketManageRecord(@RequestBody String parameter){
+        ResponseBean  responseBean = socialServiceI.ticketManageRecord(parameter);
+        return responseBean;
+    }
+
+    @ApiOperation(value = "app端工单管理拒绝处理", notes = "app端工单管理拒绝处理")
+    @ApiImplicitParams({
+            @ApiImplicitParam(paramType = "body",dataType = "String",name = "parameter",value = "loginName:手机号,communityId:小区,ticketId:工单id,textContent:拒绝的内容" )
+    })
+    @RequestMapping(value = "/updateTicketStatus", method = RequestMethod.POST)
+    public ResponseBean updateTicketStatus(@RequestBody String parameter, HttpSession session){
+        ResponseBean  responseBean = socialServiceI.updateTicketStatus(parameter);
+        return responseBean;
+    }
+
+    @ApiOperation(value = "app端工单管理处理完成", notes = "app端工单管理处理完成")
+    @ApiImplicitParams({
+            @ApiImplicitParam(paramType = "body",dataType = "String",name = "parameter",value = "loginName:手机号,communityId:小区,content:对话内容，imageUrl:[]图片,ticketId:工单id" )
+    })
+    @RequestMapping(value = "/updateTicket", method = RequestMethod.POST)
+    public ResponseBean updateTicket(@RequestBody String parameter){
+        ResponseBean  responseBean = socialServiceI.updateTicket(parameter);
+        return responseBean;
+    }
+
 }

CODE/smart-community/app-api/src/main/java/com/community/huiju/dao/TpMessageMapper.java

@@ -60,4 +60,10 @@ public interface TpMessageMapper {
      * @return
      */
     TpMessage selectBillinvoiceMessage(@Param("map") Map<String, Object> map);
+
+    /**
+     * 工单处理完成以后更新消状态
+     * @param ticketId
+     */
+    void updateTickMessageStatus(Integer ticketId);
 }

CODE/smart-community/app-api/src/main/java/com/community/huiju/service/SocialServiceI.java

@@ -281,4 +281,32 @@ public interface SocialServiceI {
 	 * @return
 	 */
 	ResponseBean tpTicketManageDetails(Integer tickedID,Integer communityId,String loginName);
+
+	/**
+	 * app端工单管理回复业主
+	 * @param parameter
+	 * @return
+	 */
+    ResponseBean tpTicketManageReply(String parameter);
+
+	/**
+	 * app端工单管理受理分配
+	 * @param parameter
+	 * @return
+	 */
+	ResponseBean ticketManageRecord(String parameter);
+
+	/**
+	 * app端工单管理拒绝处理
+	 * @param parameter
+	 * @return
+	 */
+	ResponseBean updateTicketStatus(String parameter);
+
+	/**
+	 * app端工单管理处理完成
+	 * @param parameter
+	 * @return
+	 */
+	ResponseBean updateTicket(String parameter);
 }

CODE/smart-community/app-api/src/main/java/com/community/huiju/service/impl/SocialServiceImpl.java

@@ -1234,4 +1234,269 @@ public class SocialServiceImpl implements SocialServiceI {
         response.addSuccess(ticketVO);
         return response;
     }
+
+    @Override
+    public ResponseBean tpTicketManageReply(String parameter) {
+        ResponseBean response=new ResponseBean();
+        JSONObject object= JSONObject.parseObject(parameter);
+        String loginName = object.getString("loginName");
+        Integer communityId =  object.getInteger("communityId");
+        /*查询在物业端的信息*/
+        TpUser tpUser= tpUserMapper.selectLoginName(loginName,communityId);
+
+        String  content = object.getString("content");
+        Integer  ticketId = object.getInteger("ticketId");
+        Integer  status = object.getInteger("status");
+
+        /*根据工单Id和状态查出工单记录ID*/
+        TpTicket  tpTicket= tpTicketMapper.selectByPrimaryKey(ticketId);
+        TpTicketRecord ticketRecord= tpTicketRecordMapper.selectTpTicketRecord(ticketId, Integer.valueOf(tpTicket.getStatus()));
+        TpTicketRecordComment tpTicketRecordComment= new TpTicketRecordComment();
+        tpTicketRecordComment.setCommunityId(communityId);
+        tpTicketRecordComment.setContent(content);
+        tpTicketRecordComment.setTicketId(ticketId);
+        tpTicketRecordComment.setTicketRecordId(ticketRecord.getId());
+        tpTicketRecordComment.setUuid(tpUser.getId());
+        tpTicketRecordComment.setUserType("0");
+        tpTicketRecordComment.setUserName(tpUser.getUserName());
+        tpTicketRecordComment.setCreateDate(new Date());
+        tpTicketRecordCommentMapper.insert(tpTicketRecordComment);
+        JSONArray contentImg = object.getJSONArray("imageUrl");
+        if (null!=contentImg){
+            String[] contentImgArray = contentImg.toArray(new String[]{});
+
+            for (String img : contentImgArray) {
+                TdImages tdImages = new TdImages();
+                tdImages.setImageUrl(img);
+                /*注意reply用于标记工单回复类的图片*/
+                tdImages.setType("reply");
+                tdImages.setUuid(tpTicketRecordComment.getId());
+                tdImages.setCreateTime(new Date());
+                tdImages.setCreateUser(tpUser.getId());
+                tdImagesMapper.insert(tdImages);
+            }
+        }
+        //1.5维护工单对话推送到app消息
+        TpMessage message = new TpMessage();
+        message.setCommunityId(communityId);
+        message.setMessageType(tpTicket.getType());
+        message.setTicketId(tpTicket.getId());
+        message.setAdviceType("1");
+        message.setUuid(tpTicket.getCreateUser());
+        message.setModelType("1");
+        message.setUuidType("1");
+        message.setSource("2");
+        message.setMessageContent("物业回复您:"+content);
+        message.setStatus("1");
+        message.setReadStatus("0");
+        message.setCreateUser(tpTicket.getCreateUser());
+        message.setCreateDate(new Date());
+        message.setTicketId(ticketId);
+        response.addSuccess("成功");
+        tpMessageMapper.insert(message);
+        return response;
+    }
+
+    @Override
+    public ResponseBean ticketManageRecord(String parameter) {
+        ResponseBean response=new ResponseBean();
+        JSONObject object= JSONObject.parseObject(parameter);
+        String loginName = object.getString("loginName");
+        Integer communityId =  object.getInteger("communityId");
+        Integer  ticketId = object.getInteger("ticketId");
+        /*当前处理人ID */
+        String  status = object.getString("status");
+        Integer  userID = object.getInteger("id");
+        /*查询在物业端的信息*/
+        TpUser tpUser= tpUserMapper.selectLoginName(loginName,communityId);
+
+        /**注意，这是受理人信息，不是当前用户信息*/
+        TpUser userName= tpUserMapper.selectByPrimaryKey(userID);
+        TpTicket tpTicket= new TpTicket();
+        tpTicket.setId(ticketId);
+        tpTicket.setStatus("3");
+        tpTicket.setTpUserId(userID);
+        tpTicket.setUpdateDate(new Date());
+        tpTicketMapper.updateByPrimaryKeySelective(tpTicket);
+
+        TpTicketRecord tpTicketRecord= new TpTicketRecord();
+        tpTicketRecord.setCommunityId(communityId);
+        tpTicketRecord.setTicketId(ticketId);
+        tpTicketRecord.setContent("您的联系单已经分配给物业处理人员" + userName.getUserName()+",联系方式:" + userName.getLoginName());
+        tpTicketRecord.setStatus("3");
+        tpTicketRecord.setCreateUser(tpUser.getId());
+        tpTicketRecord.setCreateDate(new Date());
+        tpTicketRecordMapper.insert(tpTicketRecord);
+
+        //待办模板
+        TpTicket ticket = tpTicketMapper.getTicketTpUserId(ticketId,communityId);
+        TpMessage message = new TpMessage();
+        message.setCommunityId(communityId);
+        message.setMessageType(ticket.getType());
+        message.setTicketId(ticket.getId());
+        message.setAdviceType("4");
+        message.setUuid(userID);
+        message.setModelType("2");
+        message.setUuidType("2");
+        message.setSource("2");
+        message.setMessageContent("工单“" + ticket.getTicketTitle() + "”已被分配给您，点击查看并处理");
+        message.setStatus("1");
+        message.setReadStatus("0");
+        message.setCreateUser(tpUser.getId());
+        message.setCreateDate(new Date());
+        message.setTicketId(ticketId);
+        tpMessageMapper.insert(message);
+        //如果分配给本人维护消息模板
+        if (null!=userID&userID.equals(tpUser.getId())){
+            message.setModelType("1");
+            tpMessageMapper.insert(message);
+        }
+        //分配成功后推送app
+        message.setUuidType("1");
+        message.setUuid(ticket.getCreateUser());
+        message.setMessageContent("工单“" + ticket.getTicketTitle() + "”已被分配给:"+userName.getUserName());
+        message.setAdviceType("1");
+        tpMessageMapper.insert(message);
+        response.addSuccess("成功");
+        return response;
+    }
+
+    @Override
+    public ResponseBean updateTicketStatus(String parameter) {
+        /*拒绝处理仅在待分配的情况下修改，由前台控制拒绝处理的按钮是否显示*/
+        ResponseBean response = new ResponseBean();
+        JSONObject object = JSONObject.parseObject(parameter);
+        String loginName = object.getString("loginName");
+        Integer communityId =  object.getInteger("communityId");
+        /**查询当前app用户在物业端的信息**/
+        TpUser tpUser =  tpUserMapper.selectLoginName(loginName,communityId);
+
+        Integer ticketId = object.getInteger("ticketId");
+        String textContent = object.getString("textContent");
+        TpTicket tpTicket = new TpTicket();
+        tpTicket.setId(ticketId);
+        tpTicket.setStatus("1");
+        tpTicket.setUpdateUser(tpUser.getId());
+        tpTicket.setUpdateDate(new Date());
+        tpTicketMapper.updateByPrimaryKeySelective(tpTicket);
+        /*查询当前处理人的名字*/
+
+        TpTicketRecord tpTicketRecord = new TpTicketRecord();
+        tpTicketRecord.setTicketId(ticketId);
+        tpTicketRecord.setContent("您的报修被物业人员" + tpUser.getUserName() + "拒绝接受理，原因:" + textContent + ",有问题可以联系" + tpUser.getUserName() + ":联系方式:" + tpUser.getLoginName());
+        tpTicketRecord.setCommunityId(communityId);
+        tpTicketRecord.setStatus("1");
+        tpTicketRecord.setCreateUser(tpUser.getId());
+        tpTicketRecord.setCreateDate(new Date());
+        tpTicketRecordMapper.insert(tpTicketRecord);
+        /*把内容添加到对话中*/
+        TpTicketRecordComment ticketRecordComment = new TpTicketRecordComment();
+        ticketRecordComment.setCommunityId(communityId);
+        ticketRecordComment.setTicketId(ticketId);
+        ticketRecordComment.setTicketRecordId(tpTicketRecord.getId());
+        ticketRecordComment.setUuid(tpUser.getId());
+        ticketRecordComment.setUserType("0");
+        ticketRecordComment.setContent("拒绝受理，原因——" + textContent);
+        ticketRecordComment.setUserName(tpUser.getUserName());
+        ticketRecordComment.setCreateDate(new Date());
+        tpTicketRecordCommentMapper.insert(ticketRecordComment);
+
+        //维护1.5版本
+        TpMessage message = new TpMessage();
+        TpTicket ticket = tpTicketMapper.getTicketTpUserId(ticketId,communityId);
+        message.setCommunityId(communityId);
+        message.setMessageType(ticket.getType());
+        message.setTicketId(ticket.getId());
+        message.setAdviceType("1");
+        message.setUuid(ticket.getCreateUser());
+        message.setModelType("1");
+        message.setUuidType("1");
+        message.setSource("2");
+        message.setMessageContent("您的工单“" + ticket.getTicketTitle() + "”已被拒绝受理");
+        message.setStatus("1");
+        message.setReadStatus("0");
+        message.setCreateUser(tpUser.getId());
+        message.setCreateDate(new Date());
+        message.setTicketId(ticketId);
+        tpMessageMapper.insert(message);
+        response.addSuccess("成功");
+        return response;
+    }
+
+    @Override
+    public ResponseBean updateTicket(String parameter) {
+        ResponseBean response=new ResponseBean();
+        JSONObject object= JSONObject.parseObject(parameter);
+        String loginName = object.getString("loginName");
+        Integer communityId =  object.getInteger("communityId");
+        /**查询当前app用户在物业端的信息**/
+        TpUser tpUser =  tpUserMapper.selectLoginName(loginName,communityId);
+
+        String  content = object.getString("content");
+        Integer  ticketId = object.getInteger("ticketId");
+        TpTicket tpTicket= new TpTicket();
+        tpTicket.setId(ticketId);
+        tpTicket.setStatus("4");
+        tpTicket.setUpdateDate(new Date());
+        tpTicketMapper.updateByPrimaryKeySelective(tpTicket);
+        /**维护工单处理表**/
+        TpTicketRecord tpTicketRecord = new TpTicketRecord();
+        tpTicketRecord.setCommunityId(communityId);
+        tpTicketRecord.setTicketId(ticketId);
+        TpTicket tpTicketUserID= tpTicketMapper.selectByPrimaryKey(ticketId);
+        tpTicketRecord.setContent("物业工作人员"+tpUser.getUserName()+"已经处理结束,如果没有问题请给好评,联系方式:"+tpUser.getLoginName());
+        tpTicketRecord.setStatus("4");
+        tpTicketRecord.setCreateUser(tpUser.getId());
+        tpTicketRecord.setCreateDate(new Date());
+        tpTicketRecordMapper.insert(tpTicketRecord);
+        /*维护对话*/
+        TpTicketRecordComment tpTicketRecordComment= new TpTicketRecordComment();
+        tpTicketRecordComment.setCommunityId(communityId);
+        tpTicketRecordComment.setTicketId(ticketId);
+        tpTicketRecordComment.setTicketRecordId(tpTicketRecord.getId());
+        tpTicketRecordComment.setUuid(tpUser.getId());
+        tpTicketRecordComment.setUserType("0");
+        tpTicketRecordComment.setContent("处理结果如下____"+content);
+        tpTicketRecordComment.setUserName(tpUser.getUserName());
+        tpTicketRecordComment.setCreateDate(new Date());
+        tpTicketRecordCommentMapper.insert(tpTicketRecordComment);
+        /* 传入图片*/
+        JSONArray contentImg = object.getJSONArray("imageUrl");
+        if (null!=contentImg){
+            String[] contentImgArray = contentImg.toArray(new String[]{});
+            for (String img : contentImgArray) {
+                TdImages tdImages = new TdImages();
+                tdImages.setImageUrl(img);
+                /*注意reply用于标记工单回复类的图片*/
+                tdImages.setType(Constant.REPLY);
+                tdImages.setUuid(tpTicketRecordComment.getId());
+                tdImages.setCreateTime(new Date());
+                tdImages.setCreateUser(tpUser.getId());
+                tdImagesMapper.insert(tdImages);
+            }
+        }
+        //分配成功后这只messgae消息表status为无效
+        tpMessageMapper.updateTickMessageStatus(ticketId);
+
+        // 处理完成后推送app
+        TpTicket ticket = tpTicketMapper.getTicketTpUserId(ticketId,tpUser.getCommunityId());
+        TpMessage message= new TpMessage();
+        message.setCommunityId(tpUser.getCommunityId());
+        message.setMessageType(ticket.getType());
+        message.setTicketId(ticket.getId());
+        message.setAdviceType("1");
+        message.setUuid(ticket.getCreateUser());
+        message.setModelType("1");
+        message.setUuidType("1");
+        message.setSource("2");
+        message.setMessageContent("您的工单“" + ticket.getTicketTitle() + "”已处理完成，请查看详情");
+        message.setStatus("1");
+        message.setReadStatus("0");
+        message.setCreateUser(tpUser.getId());
+        message.setCreateDate(new Date());
+        message.setTicketId(ticketId);
+        tpMessageMapper.insert(message);
+        response.addSuccess("成功");
+        return response;
+    }
 }

CODE/smart-community/app-api/src/main/resources/mapper/TpMessageMapper.xml

@@ -446,4 +446,15 @@
     and advice_type = 1
     and source = 2
   </select>
+
+  <update id="updateTickMessageStatus" >
+        update tp_message
+        set
+            status = 0
+        where
+        ticket_id = #{ticketId,jdbcType=INTEGER}
+        and model_type=2
+        order by create_date ASC
+        LIMIT 1
+    </update>
 </mapper>