package com.product.administration.service;
|
|
import com.product.administration.config.SystemCode;
|
import com.product.administration.config.CmnConst;
|
import com.product.administration.service.ide.IQuestionnaireService;
|
import com.product.common.lang.StringUtils;
|
import com.product.core.config.CoreConst;
|
import com.product.core.dao.BaseDao;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.exception.BaseException;
|
import com.product.core.permission.PermissionService;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.service.support.QueryFilterService;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.core.transfer.Transactional;
|
import com.product.core.websocket.service.WebsocketMesssageServiceThread;
|
import com.product.util.BaseUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Service;
|
|
import java.text.NumberFormat;
|
import java.util.Date;
|
|
/**
|
* Copyright LX
|
* @Title: QuestionnaireService
|
* @Project: product-server
|
* @date: 2021年04月22日 16:51
|
* @author: ZhouJie
|
* @Description: 问卷管理
|
*/
|
@Component
|
@Service
|
public class QuestionnaireService extends AbstractBaseService implements IQuestionnaireService {
|
@Autowired
|
public BaseDao baseDao;
|
@Autowired
|
PermissionService permissionService;
|
@Autowired
|
QueryFilterService queryFilterService;
|
/**
|
* @Date: 2021-04-22 17:25
|
* @Author: ZhouJie
|
* @Description: 保存问卷调查
|
*/
|
@Override
|
@Transactional
|
public String saveQuestionnaire(FieldSetEntity fs) throws BaseException {
|
FieldSetEntity fss = new FieldSetEntity();
|
fss.setTableName(CmnConst.PRODUCT_OA_QUESTIONNAIRE_MINE);
|
fss.setValue("voting_status",1);
|
if(StringUtils.isEmpty(fs.getString(CmnConst.UUID))){
|
fs.setValue("created_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fs.setValue("created_utc_datetime",new Date());
|
String uuid= baseDao.add(fs,false);
|
if(!StringUtils.isEmpty(uuid)){
|
DataTableEntity dt = fs.getSubDataTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE_SUB);
|
if(dt != null && dt.getRows()>0){
|
for (int i = 0; i < dt.getRows(); i++) {
|
FieldSetEntity fsub = dt.getFieldSetEntity(i);
|
fsub.setValue("questionnaire_uuid",fs.getString("uuid"));
|
baseDao.add(fsub);
|
}
|
}
|
// baseDao.add(dt);
|
}
|
return uuid;
|
} else {
|
fs.setValue("updated_by", SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fs.setValue("updated_utc_datetime",new Date());
|
baseDao.delete(CmnConst.PRODUCT_OA_QUESTIONNAIRE_SUB,"questionnaire_uuid=?",new Object[]{fs.getString("uuid")});
|
DataTableEntity dt = fs.getSubDataTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE_SUB);
|
if(dt != null && dt.getRows()>0){
|
for (int i = 0; i < dt.getRows(); i++) {
|
FieldSetEntity fsub = dt.getFieldSetEntity(i);
|
fsub.setValue("questionnaire_uuid",fs.getString("uuid"));
|
fsub.remove("id");
|
fsub.remove("uuid");
|
DataTableEntity dtt = fsub.getSubDataTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE_SUB_OPTION);
|
if(dtt != null && dtt.getRows()>0){
|
for (int j = 0; j < dtt.getRows(); j++) {
|
FieldSetEntity fssub = dtt.getFieldSetEntity(j);
|
fssub.remove("id");
|
fssub.remove("uuid");
|
}
|
}
|
baseDao.add(fsub);
|
}
|
}
|
baseDao.update(fs);
|
// baseDao.add(dt);
|
return fs.getString(CmnConst.UUID);
|
}
|
}
|
/**
|
* @description: 修改问卷详情
|
* @author: ZhouJie
|
* @date: 2021-05-21 13:54
|
*/
|
public FieldSetEntity QuestionnaireUpdateInfo(FieldSetEntity fs) throws BaseException {
|
FieldSetEntity fss = baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_QUESTIONNAIRE,fs.getUUID(),true);
|
DataTableEntity dt = baseDao.listTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE_SUB," questionnaire_uuid =? ",new Object[]{ fs.getUUID() },null,null,100,1,true);
|
fss.addSubDataTable(dt);
|
return fss;
|
}
|
|
/**
|
* @description: 修改问卷子表
|
* @author: ZhouJie
|
* @date: 2021-05-21 13:54
|
*/
|
@Override
|
@Transactional
|
public boolean questionnaireUpdateSub(FieldSetEntity fs) throws BaseException {
|
fs.setValue("updated_by",SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fs.setValue("updated_utc_datetime",new Date());
|
return baseDao.update(fs);
|
}
|
|
/**
|
* @Date: 2021-04-22 17:51
|
* @Author: ZhouJie
|
* @Description: 删除问卷调查
|
*/
|
@Override
|
@Transactional
|
public boolean deleteQuestionnaire(FieldSetEntity fs) throws BaseException {
|
String uuid = fs.getString(CmnConst.UUID);
|
String[] uuids = uuid.split(",");
|
baseDao.delete(CmnConst.PRODUCT_OA_QUESTIONNAIRE_MINE,BaseUtil.buildQuestionMarkFilter("questionnaire_uuid",uuids.length,true),uuids);
|
baseDao.delete(CmnConst.PRODUCT_OA_QUESTIONNAIRE_SUB,BaseUtil.buildQuestionMarkFilter("questionnaire_uuid",uuids.length,true),uuids);
|
return baseDao.delete(CmnConst.PRODUCT_OA_QUESTIONNAIRE,BaseUtil.buildQuestionMarkFilter(CmnConst.UUID,uuids.length,true),uuids);
|
}
|
/**
|
* @Date: 2021-04-22 17:51
|
* @Author: 郑盟
|
* @Description: 验证问卷调查接口权限
|
*/
|
public boolean verificationGetResults(FieldSetEntity fs) throws BaseException {
|
int id = SpringMVCContextHolder.getCurrentUser().getUser_id();
|
String user_id = String.valueOf(id);
|
String publisher_save_value = fs.getString("publisher_save_value");
|
if (user_id.equals(publisher_save_value)) {
|
return true;
|
}else {
|
String voters_save_value = ","+fs.getString("result_viewer_save_value")+",";
|
return voters_save_value.contains(","+user_id+",");
|
}
|
|
}
|
/**
|
* @Date: 2021-04-23 09:43
|
* @Author: ZhouJie
|
* @Description: 问卷调查列表
|
*/
|
public DataTableEntity Questionnairelist(FieldSetEntity fs) {
|
String queryFilter;
|
DataTableEntity subDataTable = fs.getSubDataTable("systemSeniorQueryString");
|
if(BaseUtil.dataTableIsEmpty(fs.getSubDataTable("systemSeniorQueryString"))){
|
queryFilter = "";
|
}else {
|
queryFilter = queryFilterService.getQueryFilter(fs) + " and ";
|
}
|
String filter = queryFilter + " created_by=? ";
|
int user_id = SpringMVCContextHolder.getCurrentUser().getUser_id();
|
DataTableEntity dt = baseDao.listTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE,filter,new Object[]{user_id},null,"created_utc_datetime desc",fs.getInteger(CmnConst.PAGESIZE),fs.getInteger(CmnConst.CPAGE));
|
baseDao.loadPromptData(dt);
|
return dt;
|
}
|
|
/**
|
* @Date: 2021-04-23 10:51
|
* @Author: ZhouJie
|
* @Description: 查看问卷调查详情
|
*/
|
public FieldSetEntity QuestionnaireInfo(FieldSetEntity fs) throws BaseException {
|
String uuid = fs.getUUID();
|
int user = SpringMVCContextHolder.getCurrentUser().getUser_id();
|
FieldSetEntity fsop = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_OA_QUESTIONNAIRE_MINE," questionnaire_uuid =? and vote_user=? ",new Object[]{uuid,user},false);
|
FieldSetEntity fss = baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_QUESTIONNAIRE,fs.getUUID(),true);
|
if(fsop!=null){
|
fss.setValue("is_vote",1);
|
fss.setValue("is_vote_save_value","已投");
|
}else{
|
fss.setValue("is_vote",0);
|
fss.setValue("is_vote_save_value","未投");
|
}
|
DataTableEntity dt = baseDao.listTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE_SUB," questionnaire_uuid =? ",new Object[]{ fs.getUUID() },null,null,25,1,true);
|
fss.addSubDataTable(dt);
|
DataTableEntity dtnew = new DataTableEntity();
|
dtnew.addFieldSetEntity(fss);
|
baseDao.loadPromptData(dtnew);
|
return dtnew.getFieldSetEntity(0);
|
}
|
/**
|
* @Date: 2021-04-23 17:51
|
* @Author: ZhouJie
|
* @Description: 问卷调查发布
|
*/
|
@Override
|
@Transactional
|
public boolean releaseQuestionnaire(FieldSetEntity fs) {
|
FieldSetEntity fss = baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_QUESTIONNAIRE, fs.getUUID(), false);
|
if("1".equals(fs.getString("type"))){
|
fs.setValue("is_publish",1);
|
fs.setValue("publisher",SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fs.setValue("pubdate",new Date());
|
saveQuestionnaire(fs);
|
WebsocketMesssageServiceThread.getInstance().appendMessage(
|
fs.getString("voters"),
|
fs.getString("questionnaire_title"),
|
fs.getString("questionnaire_title"),
|
SpringMVCContextHolder.getCurrentUser().getUser_id(),
|
CoreConst.SYSTEM_MESSAGE_TYPE_DEALT+"",
|
CmnConst.PRODUCT_OA_QUESTIONNAIRE_URL+"?"+ CmnConst.UUID+"="+fs.getString(CoreConst.UUID),
|
CmnConst.PRODUCT_OA_QUESTIONNAIRE,
|
fs.getUUID(),
|
SpringMVCContextHolder.getCurrentUser().getUser_id(),
|
0,
|
0
|
);
|
return true;
|
}else {
|
String uuid = fs.getString(CmnConst.UUID);
|
String[] uuids = uuid.split(",");
|
DataTableEntity dt = baseDao.listTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE,BaseUtil.buildQuestionMarkFilter(CmnConst.UUID,uuids.length,true),uuids);
|
if(dt!=null && dt.getRows()>0){
|
for (int i = 0; i < dt.getRows(); i++) {
|
FieldSetEntity fsl = dt.getFieldSetEntity(i);
|
fsl.setValue("is_publish",1);
|
fsl.setValue("publisher",SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fsl.setValue("pubdate",new Date());
|
baseDao.update(fsl);
|
}
|
}
|
WebsocketMesssageServiceThread.getInstance().appendMessage(
|
fss.getString("voters"),
|
fss.getString("questionnaire_title"),
|
fss.getString("questionnaire_title"),
|
SpringMVCContextHolder.getCurrentUser().getUser_id(),
|
CoreConst.SYSTEM_MESSAGE_TYPE_DEALT+"",
|
CmnConst.PRODUCT_OA_QUESTIONNAIRE_URL+"?"+ CmnConst.UUID+"="+fss.getString(CoreConst.UUID),
|
CmnConst.PRODUCT_OA_QUESTIONNAIRE,
|
fss.getUUID(),
|
fss.getInteger(CoreConst.CREATED_BY),
|
0,
|
0
|
);
|
return true;
|
}
|
}
|
/**
|
* @description: 问卷撤销发布
|
* @author: ZhouJie
|
* @date: 2021-05-13 17:22
|
*/
|
@Override
|
@Transactional
|
public boolean unreleaseQuestionnaire(FieldSetEntity fs) {
|
String uuid = fs.getString(CmnConst.UUID);
|
String[] uuids = uuid.split(",");
|
DataTableEntity dt = baseDao.listTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE,BaseUtil.buildQuestionMarkFilter(CmnConst.UUID,uuids.length,true),uuids);
|
if(dt!=null && dt.getRows()>0){
|
for (int i = 0; i < dt.getRows(); i++) {
|
FieldSetEntity fsl = dt.getFieldSetEntity(i);
|
fsl.setValue("is_publish",0);
|
fsl.setValue("publisher",SpringMVCContextHolder.getCurrentUser().getUser_id());
|
fsl.setValue("pubdate",new Date());
|
baseDao.update(fsl);
|
baseDao.delete(CmnConst.PRODUCT_OA_QUESTIONNAIRE_MINE," questionnaire_uuid=? ",new Object[]{fsl.getUUID()});
|
}
|
}
|
return true;
|
}
|
/**
|
* @Date: 2021-04-25 16:43
|
* @Author: ZhouJie
|
* @Description: 我的投票问卷列表
|
*/
|
public DataTableEntity QuestionnaireMinelist(FieldSetEntity fs) {
|
String queryFilter;
|
if(BaseUtil.dataTableIsEmpty(fs.getSubDataTable("systemSeniorQueryString"))){
|
queryFilter = "";
|
}else {
|
queryFilter = " and " + queryFilterService.getQueryFilter(fs);
|
}
|
StringBuffer sql = new StringBuffer();
|
sql.append(" SELECT * from product_oa_questionnaire where CONCAT(',',voters,',') LIKE ? and is_publish=1 ");
|
sql.append(queryFilter);
|
sql.append(" ORDER BY pubdate desc ");
|
String id ="%"+SpringMVCContextHolder.getCurrentUser().getUser_id()+"%";
|
DataTableEntity dt = baseDao.listTable(sql.toString(),new Object[]{ id },fs.getInteger(CmnConst.PAGESIZE),fs.getInteger(CmnConst.CPAGE));
|
if(dt!=null && dt.getRows()>0){
|
for (int i = 0; i < dt.getRows(); i++) {
|
FieldSetEntity fss = dt.getFieldSetEntity(i);
|
DataTableEntity dtt = baseDao.listTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE_MINE," questionnaire_uuid =? and vote_user=? ",new Object[]{fss.getUUID(),SpringMVCContextHolder.getCurrentUser().getUser_id()});
|
if(dtt!=null && dtt.getRows()>0){
|
fss.setValue("is_vote",1);
|
fss.setValue("is_vote_save_value","已投");
|
}else{
|
fss.setValue("is_vote",0);
|
fss.setValue("is_vote_save_value","未投");
|
}
|
}
|
}
|
baseDao.loadPromptData(dt);
|
return dt;
|
}
|
/**
|
* @Date: 2021-04-25 16:58
|
* @Author: ZhouJie
|
* @Description: 我的投票问卷结果
|
*/
|
public FieldSetEntity QuestionnaireMineInfo(FieldSetEntity fs) throws BaseException {
|
FieldSetEntity fss = baseDao.getFieldSetEntity(CmnConst.PRODUCT_OA_QUESTIONNAIRE,fs.getUUID(),true);
|
FieldSetEntity fsop = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_OA_QUESTIONNAIRE_MINE," questionnaire_uuid =? and vote_user=? ",new Object[]{fs.getUUID(),SpringMVCContextHolder.getCurrentUser().getUser_id()},false);
|
if(fsop!=null){
|
fss.setValue("is_vote",1);
|
fss.setValue("is_vote_save_value","已投");
|
}else{
|
fss.setValue("is_vote",0);
|
fss.setValue("is_vote_save_value","未投");
|
}
|
String voters = fss.getString("voters");
|
String[] split = voters.split(",");
|
int count = split.length;
|
DataTableEntity dt = baseDao.listTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE_SUB," questionnaire_uuid =? ",new Object[]{ fs.getUUID() },null,null,25,1,true);
|
if(dt!=null && dt.getRows()>0){
|
for (int i = 0; i < dt.getRows(); i++) {
|
FieldSetEntity fsub = dt.getFieldSetEntity(i);
|
int respondents = 0;//回答本题人数
|
String percentage = "";//选择题回答百分比
|
DataTableEntity dtmine = null;
|
if(fsub.getInteger("content_type")==1 || fsub.getInteger("content_type")==2){
|
DataTableEntity dtsubop = fsub.getSubDataTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE_SUB_OPTION);
|
if(dtsubop!=null && dtsubop.getRows()>0){
|
for (int j = 0; j < dtsubop.getRows(); j++) {
|
FieldSetEntity fsubop = dtsubop.getFieldSetEntity(j);
|
dtmine = baseDao.listTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE_MINE," questionnaire_uuid=? and subject_uuid=? and option_answer_uuid=?",new Object[]{fsub.getString("questionnaire_uuid"),fsub.getUUID(),fsubop.getUUID()});
|
respondents = dtmine.getRows();
|
NumberFormat nf = NumberFormat.getPercentInstance();
|
nf.setMinimumFractionDigits(2);//控制保留小数点后几位，2：表示保留2位小数点
|
percentage = nf.format(Double.valueOf(respondents)/Double.valueOf(count));
|
fsubop.setValue("count",count);
|
fsubop.setValue("respondents",respondents);
|
fsubop.setValue("percentage",percentage);
|
}
|
}
|
}else{
|
dtmine = baseDao.listTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE_MINE," questionnaire_uuid=? and subject_uuid=?",new Object[]{fsub.getString("questionnaire_uuid"),fsub.getUUID()});
|
respondents = dtmine.getRows();
|
fsub.setValue("count",count);
|
fsub.setValue("respondents",respondents);
|
fsub.setValue("percentage",percentage);
|
}
|
}
|
}
|
fss.addSubDataTable(dt);
|
DataTableEntity dtnew = new DataTableEntity();
|
dtnew.addFieldSetEntity(fss);
|
String questionnaireMineInfo = "QuestionnaireMineInfo";
|
if(fss==null){
|
throw new BaseException(SystemCode.SYSTEM_DELETE_QUESTIONNAIRE_MINE_INFO_FAIL.getValue(), SystemCode.SYSTEM_DELETE_QUESTIONNAIRE_MINE_INFO_FAIL.getText(), this.getClass(), questionnaireMineInfo);
|
}
|
baseDao.loadPromptData(dtnew);
|
return dtnew.getFieldSetEntity(0);
|
}
|
|
/**
|
* @description: 结果详情界面 具体答题人详情
|
* @author: ZhouJie
|
* @date: 2021-05-19 16:04
|
*/
|
public DataTableEntity QuestionnaireMineGetinfo(FieldSetEntity fs) throws BaseException {
|
String questionnaire_uuid = fs.getString("questionnaire_uuid");
|
String subject_uuid = fs.getString("subject_uuid");
|
String option_answer_uuid = fs.getString("option_answer_uuid");
|
String vote_user = fs.getString("vote_user");
|
String vote_user_selectString="";
|
System.out.println(vote_user);
|
if (!StringUtils.isEmpty(vote_user)) {
|
vote_user_selectString="and show_name='"+vote_user+"'";
|
}
|
StringBuffer str = new StringBuffer();
|
DataTableEntity dt = null;
|
if(!StringUtils.isEmpty(option_answer_uuid)){
|
str.append(" select case when lq.is_anonymous=1 then '匿名' else lm.show_name end vote_user,lop.option_num vote_contents,lm.voting_time vote_time from ");
|
str.append(" (select a.*,b.show_name from product_oa_questionnaire_mine a LEFT JOIN product_sys_staffs b on a.vote_user =b.user_id) lm,product_oa_questionnaire_sub_option lop,product_oa_questionnaire lq where ");
|
str.append(" lm.questionnaire_uuid=? and lm.subject_uuid=? and lm.option_answer_uuid=? and lop.uuid=? and lq.uuid=? "+vote_user_selectString);
|
dt = baseDao.listTable(str.toString(),new Object[]{questionnaire_uuid,subject_uuid,option_answer_uuid,option_answer_uuid,questionnaire_uuid},fs.getInteger(CmnConst.PAGESIZE),fs.getInteger(CmnConst.CPAGE));
|
}else{
|
str.append(" select case when lq.is_anonymous=1 then '匿名' else b.show_name end vote_user,a.answer_contents vote_contents,a.voting_time from product_oa_questionnaire_mine a LEFT JOIN product_sys_staffs b on a.vote_user =b.user_id ");
|
str.append(" ,product_oa_questionnaire lq where ");
|
str.append(" a.questionnaire_uuid=? and a.subject_uuid=? and lq.uuid=? "+vote_user_selectString);
|
dt = baseDao.listTable(str.toString(),new Object[]{questionnaire_uuid,subject_uuid,questionnaire_uuid},fs.getInteger(CmnConst.PAGESIZE),fs.getInteger(CmnConst.CPAGE));
|
}
|
baseDao.loadPromptData(dt);
|
return dt;
|
}
|
|
/**
|
* @description: 提交问卷
|
* @author: ZhouJie
|
* @date: 2021-05-12 14:14
|
*/
|
@Override
|
@Transactional
|
public String saveQuestionnairemine(FieldSetEntity fs) throws BaseException {
|
DataTableEntity dt = fs.getSubDataTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE_SUB);
|
if(dt != null && dt.getRows()>0){
|
for (int i = 0; i < dt.getRows(); i++) {
|
FieldSetEntity fsub = dt.getFieldSetEntity(i);
|
FieldSetEntity mine = new FieldSetEntity();
|
mine.setTableName(CmnConst.PRODUCT_OA_QUESTIONNAIRE_MINE);
|
if(fsub.getInteger("content_type")==1 || fsub.getInteger("content_type")==2){
|
DataTableEntity dtt = fsub.getSubDataTable(CmnConst.PRODUCT_OA_QUESTIONNAIRE_SUB_OPTION);
|
if(dtt != null && dtt.getRows()>0){
|
for (int j = 0; j < dtt.getRows(); j++) {
|
FieldSetEntity fsubop = dtt.getFieldSetEntity(j);
|
if(!StringUtils.isEmpty(fsub.getString("select_uuid")) && (fsub.getString("select_uuid")).indexOf((fsubop.getUUID()))!=-1){
|
mine.setValue("subject_uuid",fsubop.getString("parent_uuid"));
|
mine.setValue("questionnaire_uuid",fsub.getString("questionnaire_uuid"));
|
mine.setValue("option_answer_uuid",fsubop.getUUID());
|
mine.setValue("other_comments",fsubop.getString("write_content"));
|
mine.setValue("answer_contents",fsubop.getString("answer_contents"));
|
mine.setValue("vote_user",SpringMVCContextHolder.getCurrentUser().getUser_id());
|
mine.setValue("voting_time",new Date());
|
baseDao.add(mine);
|
}
|
}
|
}
|
}else{
|
mine.setValue("subject_uuid",fsub.getUUID());
|
mine.setValue("questionnaire_uuid",fsub.getString("questionnaire_uuid"));
|
mine.setValue("answer_contents",fsub.getString("answer_content"));
|
mine.setValue("vote_user",SpringMVCContextHolder.getCurrentUser().getUser_id());
|
mine.setValue("voting_time",new Date());
|
baseDao.add(mine);
|
}
|
}
|
}
|
return fs.getUUID();
|
}
|
|
|
}
|
