悟空CRM-基于jfinal+vue+ElementUI的前后端分离CRM系统

package com.kakarote.crm9.erp.oa.service; import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.StrUtil; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.util.TypeUtils; import com.jfinal.aop.Before; import com.jfinal.aop.Inject; import com.jfinal.kit.Kv; import com.jfinal.plugin.activerecord.Db; import com.jfinal.plugin.activerecord.Page; import com.jfinal.plugin.activerecord.Record; import com.jfinal.plugin.activerecord.SqlPara; import com.jfinal.plugin.activerecord.tx.Tx; import com.kakarote.crm9.common.config.paragetter.BasePageRequest; import com.kakarote.crm9.common.constant.BaseConstant; import com.kakarote.crm9.erp.admin.entity.AdminExamineLog; import com.kakarote.crm9.erp.admin.entity.AdminUser; import com.kakarote.crm9.erp.admin.service.AdminFieldService; import com.kakarote.crm9.erp.admin.service.AdminFileService; import com.kakarote.crm9.erp.crm.entity.CrmBusiness; import com.kakarote.crm9.erp.crm.entity.CrmContacts; import com.kakarote.crm9.erp.crm.entity.CrmContract; import com.kakarote.crm9.erp.crm.entity.CrmCustomer; import com.kakarote.crm9.erp.oa.common.OaEnum; import com.kakarote.crm9.erp.oa.entity.*; import com.kakarote.crm9.utils.*; import java.util.*; import java.util.concurrent.atomic.AtomicReference; public class OaExamineService{ //添加日志 @Inject private OaActionRecordService oaActionRecordService; @Inject private AdminFileService adminFileService; @Inject private AdminFieldService adminFieldService; public R myInitiate(BasePageRequest<Void> request){ JSONObject jsonObject = request.getJsonObject(); Long userId = BaseUtil.getUser().getUserId(); if(request.getPageType() == 0){ List<Record> recordList = Db.find(Db.getSqlPara("oa.examine.myInitiate", Kv.by("userId", userId).set("categoryId", jsonObject.getInteger("categoryId")).set("status", jsonObject.getInteger("checkStatus")).set("startTime", jsonObject.getDate("startTime")).set("endTime", jsonObject.getDate("endTime")))); transfer(recordList); return R.ok().put("data", recordList); }else{ Page<Record> recordList = Db.paginate(request.getPage(), request.getLimit(), Db.getSqlPara("oa.examine.myInitiate", Kv.by("userId", userId).set("categoryId", jsonObject.getInteger("categoryId")).set("status", jsonObject.getInteger("checkStatus")).set("startTime", jsonObject.getDate("startTime")).set("endTime", jsonObject.getDate("endTime")))); transfer(recordList.getList()); return R.ok().put("data", recordList); } } public R myOaExamine(BasePageRequest<OaExamine> request){ Long userId = BaseUtil.getUser().getUserId(); JSONObject jsonObject = request.getJsonObject(); if(request.getPageType() == 0){ List<Record> recordList = Db.find(Db.getSqlPara("oa.examine.myOaExamine", Kv.by("userId", userId).set("categoryId", jsonObject.getInteger("categoryId")).set("status", jsonObject.getInteger("status")).set("startTime", jsonObject.getDate("startTime")).set("endTime", jsonObject.getDate("endTime")))); transfer(recordList); return R.ok().put("data", recordList); }else{ Page<Record> recordList = Db.paginate(request.getPage(), request.getLimit(), Db.getSqlPara("oa.examine.myOaExamine", Kv.by("userId", userId).set("categoryId", jsonObject.getInteger("categoryId")).set("status", jsonObject.getInteger("status")).set("startTime", jsonObject.getDate("startTime")).set("endTime", jsonObject.getDate("endTime")))); transfer(recordList.getList()); return R.ok().put("data", recordList); } } public void transfer(List<Record> recordList){ recordList.forEach(record -> { setRelation(record); record.set("createUser", Db.findFirst("select user_id,realname,img from 72crm_admin_user where user_id = ?", record.getLong("create_user_id"))); String batchId = record.getStr("batch_id"); adminFileService.queryByBatchId(batchId, record); setCountRecord(record); List<Integer> roles = BaseUtil.getUser().getRoles(); Map<String,Integer> permission = new HashMap<>(); Long createUserId = record.getLong("create_user_id"); Integer examineStatus = record.getInt("examine_status"); Long userId = BaseUtil.getUser().getUserId(); if((userId.equals(BaseConstant.SUPER_ADMIN_USER_ID) && (examineStatus == 4 || examineStatus == 2)) || (createUserId.equals(BaseUtil.getUser().getUserId()) && (examineStatus == 4 || examineStatus == 2))){ permission.put("isUpdate", 1); }else{ permission.put("isUpdate", 0); } if(roles.contains(BaseConstant.SUPER_ADMIN_ROLE_ID) && examineStatus != 1){ permission.put("isDelete", 1); }else{ permission.put("isDelete", 0); } if(((userId.equals(BaseConstant.SUPER_ADMIN_USER_ID) || userId.equals(record.getLong("create_user_id"))) && (examineStatus == 0 || examineStatus == 3)) && examineStatus != 4){ permission.put("isChecked", 1); }else{ permission.put("isChecked", 0); } record.set("permission", permission); }); } private void setCountRecord(Record record){ Integer examineId = record.getInt("examine_id"); String categoryTitle = record.getStr("categoryTitle"); Integer count = Db.queryInt("select count(*) as count from 72crm_oa_examine_travel where examine_id = ?", examineId); StringBuilder causeTitle = new StringBuilder(); if(count > 0){ causeTitle.append(count); switch(categoryTitle){ case "出差审批": causeTitle.append("个行程，共"); if(record.get("duration") != null){ causeTitle.append(record.getInt("duration")); }else{ causeTitle.append(0); } causeTitle.append("天。"); break; case "差旅报销": causeTitle.append("个报销事项，共"); if(record.get("money") != null){ causeTitle.append(record.getInt("money")); }else{ causeTitle.append(0); } causeTitle.append("元。"); break; default: break; } } record.set("causeTitle", causeTitle.toString()); } @Before(Tx.class) public R setOaExamine(JSONObject jsonObject){ AdminUser user = BaseUtil.getUser(); OaExamine oaExamine = jsonObject.getObject("oaExamine", OaExamine.class); boolean oaAuth = AuthUtil.isOaAuth(OaEnum.EXAMINE_TYPE_KEY.getTypes(), oaExamine.getExamineId()); if(oaAuth){ return R.noAuth(); } if(oaExamine.getStartTime() != null && oaExamine.getEndTime() != null){ if((oaExamine.getStartTime().compareTo(oaExamine.getEndTime())) == 1){ return R.error("审批结束时间早于开始时间"); } } boolean bol; String batchId = StrUtil.isNotEmpty(oaExamine.getBatchId()) ? oaExamine.getBatchId() : IdUtil.simpleUUID(); adminFieldService.save(jsonObject.getJSONArray("field"), batchId); oaExamine.setBatchId(batchId); String checkUserIds = jsonObject.getString("checkUserId"); Integer categoryId = oaExamine.getCategoryId();