|
@@ -4,6 +4,7 @@ import com.ruoyi.common.core.domain.entity.SysDept;
|
|
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
|
|
import com.ruoyi.common.utils.DateUtils;
|
|
|
import com.ruoyi.common.utils.SecurityUtils;
|
|
|
+import com.ruoyi.common.utils.jPush.JPushToolUtil;
|
|
|
import com.ruoyi.framework.manager.AsyncManager;
|
|
|
import com.ruoyi.framework.manager.factory.AsyncFactory;
|
|
|
import com.ruoyi.system.domain.projectV2.ZsyzFj;
|
|
@@ -15,6 +16,7 @@ import com.ruoyi.system.mapper.projectV2.ZsyzFjMapper;
|
|
|
import com.ruoyi.system.mapper.projectV2.ZsyzLcjlMapper;
|
|
|
import com.ruoyi.system.mapper.projectV2.ZsyzQyxxMapper;
|
|
|
import com.ruoyi.system.mapper.projectV2.ZsyzSbbzbMapper;
|
|
|
+import com.ruoyi.system.service.ISysUserService;
|
|
|
import com.ruoyi.system.service.projectV2.IZsyzQyxxService;
|
|
|
import com.ruoyi.system.service.projectV2.common.ISendSmsConfigService;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
@@ -22,6 +24,7 @@ import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
|
|
import java.util.List;
|
|
|
+import java.util.stream.Collectors;
|
|
|
|
|
|
import static com.ruoyi.common.constant.CommonConstants.*;
|
|
|
|
|
@@ -45,6 +48,8 @@ public class ZsyzQyxxServiceImpl implements IZsyzQyxxService {
|
|
|
|
|
|
@Autowired
|
|
|
private ISendSmsConfigService sendSmsConfigService;
|
|
|
+ @Autowired
|
|
|
+ private ISysUserService sysUserService;
|
|
|
|
|
|
/**
|
|
|
* 查询招商引资_签约信息
|
|
@@ -113,7 +118,7 @@ public class ZsyzQyxxServiceImpl implements IZsyzQyxxService {
|
|
|
SysDept dept = SecurityUtils.getLoginUser().getUser().getDept();
|
|
|
ZsyzLcjl zsyzLcjl = new ZsyzLcjl();
|
|
|
zsyzLcjl.setXmId(zsyzSbbzb.getId());
|
|
|
- zsyzLcjl.setXmmc(zsyzQyxx.getXmmc());
|
|
|
+ zsyzLcjl.setXmmc(zsyzQyxx.getXmxsmc());
|
|
|
zsyzLcjl.setXmbh(zsyzQyxx.getXmbh());
|
|
|
zsyzLcjl.setDeptId(dept.getDeptId());
|
|
|
String deptName = dept.getDeptName();
|
|
@@ -129,6 +134,17 @@ public class ZsyzQyxxServiceImpl implements IZsyzQyxxService {
|
|
|
if (sendSmsConfigs != null){
|
|
|
AsyncManager.me().execute(AsyncFactory.sendSms(sendSmsConfigs,"SMS_271500071"));
|
|
|
}
|
|
|
+
|
|
|
+ //发极光推送
|
|
|
+ List<SysUser> sysUsers = sysUserService.selectUserByDeptId(100L);
|
|
|
+ String notificationTitle = "消息通知";
|
|
|
+ String msgTitle = "签约审核";
|
|
|
+ String msgContent = "您有一条签约审核信息,请及时处理!";
|
|
|
+ String jPushVO = "";
|
|
|
+ List<String> listS = sysUsers.stream().map(SysUser::getJgId).collect(Collectors.toList());
|
|
|
+ String[] registrationId = (String[]) listS.toArray();
|
|
|
+ JPushToolUtil.sendToRegistrationId(notificationTitle,msgTitle,msgContent,jPushVO,registrationId);
|
|
|
+
|
|
|
return count;
|
|
|
|
|
|
}
|
|
@@ -172,6 +188,38 @@ public class ZsyzQyxxServiceImpl implements IZsyzQyxxService {
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ //插入流程记录表
|
|
|
+ SysDept dept = SecurityUtils.getLoginUser().getUser().getDept();
|
|
|
+ ZsyzLcjl zsyzLcjl = new ZsyzLcjl();
|
|
|
+ zsyzLcjl.setXmId(zsyzSbbzb.getId());
|
|
|
+ zsyzLcjl.setXmmc(zsyzQyxx.getXmxsmc());
|
|
|
+ zsyzLcjl.setXmbh(zsyzQyxx.getXmbh());
|
|
|
+ zsyzLcjl.setDeptId(dept.getDeptId());
|
|
|
+ String deptName = dept.getDeptName();
|
|
|
+ zsyzLcjl.setDeptName(deptName);
|
|
|
+ zsyzLcjl.setProgress(THR);
|
|
|
+ zsyzLcjl.setXmStatus(ONE);
|
|
|
+ zsyzLcjlMapper.insertZsyzLcjl(zsyzLcjl);
|
|
|
+
|
|
|
+ //发送短信
|
|
|
+ SendSmsConfig sendSmsConfig = new SendSmsConfig();
|
|
|
+ sendSmsConfig.setProgress(ONE);
|
|
|
+ List<SendSmsConfig> sendSmsConfigs = sendSmsConfigService.selectSendSmsConfigList(sendSmsConfig);
|
|
|
+ if (sendSmsConfigs != null){
|
|
|
+ AsyncManager.me().execute(AsyncFactory.sendSms(sendSmsConfigs,"SMS_271500071"));
|
|
|
+ }
|
|
|
+
|
|
|
+ //发极光推送
|
|
|
+ List<SysUser> sysUsers = sysUserService.selectUserByDeptId(100L);
|
|
|
+ String notificationTitle = "消息通知";
|
|
|
+ String msgTitle = "签约审核";
|
|
|
+ String msgContent = "您有一条签约审核信息,请及时处理!";
|
|
|
+ String jPushVO = "";
|
|
|
+ List<String> listS = sysUsers.stream().map(SysUser::getJgId).collect(Collectors.toList());
|
|
|
+ String[] registrationId = (String[]) listS.toArray();
|
|
|
+ JPushToolUtil.sendToRegistrationId(notificationTitle,msgTitle,msgContent,jPushVO,registrationId);
|
|
|
+
|
|
|
return count;
|
|
|
}
|
|
|
|