企微群发

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/dao/mapper/chat/GroupChatPlanOwnerLogMapper.java

@@ -68,7 +68,7 @@ public interface GroupChatPlanOwnerLogMapper {
 
     void updateMsgid(@Param("id")Long id , @Param("msgid")String msgid) ;
 
-    void staffSendResult(@Param("staffId")String staffId, @Param("planId")Long planId, @Param("sendTime")Date sendTime, @Param("failRemark")String failRemark);
+    void staffSendResult(@Param("staffId")String staffId, @Param("planId")Long planId, @Param("sendTime")Date sendTime, @Param("failRemark")String failRemark ,  @Param("statusFlag")int statusFlag);
 
     int getTotalTask(@Param("enterpriseId")String enterpriseId , @Param("clerkId")String clerkId , @Param("time")Date time ) ;
 

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/chat/impl/GroupChatPlanServiceImpl.java

@@ -744,7 +744,13 @@ public class GroupChatPlanServiceImpl implements GroupChatPlanService {
         Long planId = qdto.getPlanId() ;
         String failRemark = qdto.getFailRemark() ;
         Date sendTime = qdto.getSendTime() ;
-        this.groupChatPlanOwnerLogMapper.staffSendResult(staffId,planId,sendTime,failRemark) ;
+        if(StringUtils.isNotBlank(failRemark)) {
+            this.groupChatPlanOwnerLogMapper.staffSendResult(staffId,planId,sendTime,failRemark,3) ;
+            logger.info("好办小程序发送失败={}",failRemark);
+            return;
+        }else {
+            this.groupChatPlanOwnerLogMapper.staffSendResult(staffId,planId,sendTime,failRemark,2) ;
+        }
         GroupChatPlanOwnerLogDTO  dto  = this.groupChatPlanOwnerLogService.getOwnerInfo(planId,staffId,null,wxEnterpriseId) ;
         this.updateMsgid(dto);
     }

haoban-manage3-service/src/main/resources/mapper/chat/GroupChatPlanOwnerLogMapper.xml

@@ -110,7 +110,7 @@
 		update tab_haoban_group_chat_plan_owner_log set send_status = 3 where owner_log_id = #{id}
 	</update>
 	<update id="staffSendResult">
-		update tab_haoban_group_chat_plan_owner_log set send_status = 2 , send_time = #{sendTime}  where plan_id = #{planId} and staff_id = #{staffId}
+		update tab_haoban_group_chat_plan_owner_log set send_status = #{statusFlag} , send_time = #{sendTime} , remark = #{failRemark} where plan_id = #{planId} and staff_id = #{staffId}
 	</update>
 
 	<!-- ============ 查询=============-->
@@ -324,14 +324,14 @@
 	</select>
     <select id="getTaskNum" resultType="java.lang.Integer">
 		select count(1) from (
-		select plan_id from tab_haoban_group_chat_plan_owner_log a LEFT JOIN tab_haoban_group_chat_plan b ON a.plan_id = b.plan_id
+		select a.plan_id from tab_haoban_group_chat_plan_owner_log a LEFT JOIN tab_haoban_group_chat_plan b ON a.plan_id = b.plan_id
 		where  a.enterprise_id =  #{enterpriseId}
 		  and a.store_id = #{storeId}
 		  <if test="null != clerkId">
 			  AND a.clerk_id = #{clerkId}
 		  </if>
 		  and b.end_time <![CDATA[ > ]]> now()
-		   AND a.send_status = 1 and a.delete_flag = 0 group by plan_id  ) t
+		   AND a.send_status = 1 and a.delete_flag = 0 group by a.plan_id  ) t
 	</select>
 
 </mapper>
\ No newline at end of file

haoban-manage3-wx/src/main/java/com/gic/haoban/manage/web/controller/haoban/GroupChatPlanController.java

@@ -122,6 +122,7 @@ public class GroupChatPlanController {
      */
     @RequestMapping("staff-send-result")
     public RestResponse<Void> staffSendResult(@RequestBody StaffSendResultQDTO qdto) {
+        logger.info("企微返回={}",JSONObject.toJSONString(qdto));
         this.groupChatPlanApiService.staffSendResult(qdto) ;
         return RestResponse.successResult();
     }