企微消息

suishenbang-system/src/main/java/com/dgtly/system/mapper/SysUserMapper.java

@@ -196,4 +196,6 @@ public interface SysUserMapper
     Map<String,Object> selectLoginNamesByCostumerCode1(String[] customerCodes);
 
     String getCustomNameByCode(String code);
+
+    String selectSyncDateUser(@Param("type") Integer type);
 }

suishenbang-system/src/main/java/com/dgtly/system/service/ISysUserService.java

@@ -259,4 +259,6 @@ public interface ISysUserService
     List<SysUser> selectUserByOrgCode(String orgCode);
 
     String getCustomNameByCode(String code);
+
+    String selectSyncDateUser(Integer type);
 }

suishenbang-system/src/main/java/com/dgtly/system/service/impl/SysUserServiceImpl.java

@@ -637,4 +637,8 @@ public class SysUserServiceImpl implements ISysUserService
         return userMapper.getCustomNameByCode(code);
     }
 
+    @Override
+    public String selectSyncDateUser(Integer type) {
+        return userMapper.selectSyncDateUser(type);
+    }
 }

suishenbang-system/src/main/resources/mapper/system/SysUserMapper.xml

@@ -431,4 +431,9 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 	<select id="getCustomNameByCode" resultType="java.lang.String" >
 		select customer_name  from order_sales_customer where customer_id=#{code} limit 1
 	</select>
+
+	<select id="selectSyncDateUser" resultType="java.lang.String" >
+		select GROUP_CONCAT(su.login_name SEPARATOR '|') touser from sys_user su
+		left join sys_user_sync_data sus on sus.user_id = su.user_id  where sus.type = #{type}
+	</select>
 </mapper> 

suishenbang-wxportal/suishenbang-wxportal-api/src/main/java/com/dgtly/wxportal/controller/WxController.java

@@ -154,6 +154,29 @@ public class WxController extends ApiBaseController {
         return AjaxResult.success();
     }
 
+    @ApiOperation(value = "同步数据失败",
+            notes = "" )
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "params" , paramType = "path")
+    })
+    @RequestMapping("sendSyncDataMessage")
+    public Object sendSyncDataMessage(String jobId) {
+        String message;
+        Integer type = 1;
+        if ("salesOrderCustomerJob".equalsIgnoreCase(jobId)) {
+            message = "经销商销售目标与达成，随身邦执行同步失败请检查";
+        } else if ("salesOrderGroupJob".equalsIgnoreCase(jobId)) {
+            message = "部门级别销售目标与达成，随身邦执行同步失败请检查";
+            type = 2;
+        } else {
+            return AjaxResult.error("error for jobId " + jobId);
+        }
+        logger.info("sendSyncDataMessage jobId ：" + jobId);
+        String users = sysUserService.selectSyncDateUser(type);
+        qyWxSendMessageUtil.sendApproveProcessMessage(users, message, "15");
+        return AjaxResult.success();
+    }
+
     @ApiOperation(value = "加急审批通过",
             notes = "" )
     @ApiImplicitParams({

suishenbang-wxportal/suishenbang-wxportal-common/src/main/java/com/dgtly/wxportal/service/impl/WxMagnetServiceImpl.java

@@ -205,7 +205,7 @@ public class WxMagnetServiceImpl implements IWxMagnetService
     @Override
     public List<WxMagnet> selectMagnetByUserId(String userId, String cw, String salesLevel) {
         List<WxMagnet> list;
-        if (null != cw && null != salesLevel && "customer_level".equals(salesLevel)) {
+        if (StringUtils.isNotEmpty(cw) && null != salesLevel && "customer_level".equals(salesLevel)) {
             String roleId = cw.equals("1") ? configService.selectConfigByKey("libang.customer.roleid") : configService.selectConfigByKey("libang.cw.roleid");
             list = wxMagnetMapper.selectMagnetByCw(userId, roleId);
         } else {