Compare commits
16 Commits
| Author | SHA1 | Date |
|---|---|---|
 zhangming
|
ec1e88f469 | 6 months ago |
|
zhangming
|
ed96226f09 | 8 months ago |
|
zhangming
|
70f4538f39 | 8 months ago |
|
zhangming
|
71072bae31 | 8 months ago |
|
zhangming
|
99e8691098 | 9 months ago |
|
zhangming
|
5dbe3ebe2d | 9 months ago |
|
zhangming
|
36c4b584ed | 10 months ago |
|
zhangming
|
6cf0af246f | 10 months ago |
|
zhangming
|
95b6eaa319 | 10 months ago |
|
zhangming
|
efbbff75c1 | 10 months ago |
|
zhangming
|
c968012e13 | 10 months ago |
|
zhangming
|
a0ec75702f | 11 months ago |
|
zhangming
|
2fc70db7c1 | 11 months ago |
|
zhangming
|
4754e06962 | 12 months ago |
|
zhangming
|
a5fe18cba4 | 1 year ago |
|
zhangming
|
f43ca57022 | 1 year ago |
@ -0,0 +1,30 @@
|
||||
<%@ page import="com.engine.kq.biz.KQWorkTime" %>
|
||||
<%@ page import="java.util.Map" %>
|
||||
<%@ page import="com.engine.kq.entity.WorkTimeEntity" %>
|
||||
<%@ page import="weaver.general.Util" %>
|
||||
<%@ page import="com.engine.kq.cmd.shiftmanagement.toolkit.ShiftManagementToolKit" %>
|
||||
<%
|
||||
String userId = request.getParameter("userId");
|
||||
String kqDate = request.getParameter("kqDate");
|
||||
try {
|
||||
|
||||
KQWorkTime kqWorkTime = new KQWorkTime();
|
||||
Map<String, Object> serialInfo = kqWorkTime.getSerialInfo(userId, kqDate, false);
|
||||
if (serialInfo != null && serialInfo.size() > 0) {
|
||||
int serialid = Util.getIntValue(Util.null2String(serialInfo.get(kqDate)), 0);
|
||||
out.println("serialid:" + serialid + "<br>");
|
||||
}
|
||||
|
||||
WorkTimeEntity workTime = kqWorkTime.getWorkTime(userId, kqDate);
|
||||
String bc = workTime.getSerialId();
|
||||
out.print("new serialid:" + bc + "<br>");
|
||||
|
||||
ShiftManagementToolKit shiftManagementToolKit = new ShiftManagementToolKit();
|
||||
String shiftOnOffWorkSections = shiftManagementToolKit.getShiftOnOffWorkSections(bc, 7);
|
||||
out.print("shiftOnOffWorkSections:" + shiftOnOffWorkSections + "<br>");
|
||||
shiftOnOffWorkSections = shiftManagementToolKit.getShiftOnOffWorkSections("51", 7);
|
||||
out.print("shiftOnOffWorkSections 51:" + shiftOnOffWorkSections + "<br>");
|
||||
} catch (Exception e) {
|
||||
out.print("get serialid error:" + e.getMessage());
|
||||
}
|
||||
%>
|
||||
@ -1,2 +1,4 @@
|
||||
# 餐补信息记录模块ID
|
||||
cbxxjl_modeid=82
|
||||
# 夜班补助指定班次
|
||||
night_shift_appoint_bc=51,52
|
||||
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,143 @@
|
||||
package weaver.interfaces.hostar.action;
|
||||
|
||||
import com.engine.hostar.thread.HandleCBDataThread;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.springframework.util.CollectionUtils;
|
||||
import weaver.conn.RecordSet;
|
||||
import weaver.general.BaseBean;
|
||||
import weaver.general.ThreadPoolUtil;
|
||||
import weaver.general.Util;
|
||||
import weaver.interfaces.workflow.action.Action;
|
||||
import weaver.soa.workflow.request.RequestInfo;
|
||||
|
||||
import java.time.LocalDate;
|
||||
import java.time.format.DateTimeFormatter;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Arrays;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Set;
|
||||
import java.util.concurrent.ExecutorService;
|
||||
|
||||
/**
|
||||
* @version 1.0
|
||||
* @Title ecology-9
|
||||
* @Company 泛微软件
|
||||
* @CreateDate 2024/8/30
|
||||
* @Description 处理餐补通用action
|
||||
* @Author AdminZm
|
||||
*/
|
||||
public class HandleCBCommonAction implements Action {
|
||||
|
||||
BaseBean baseBean = new BaseBean();
|
||||
|
||||
private String ryField;
|
||||
|
||||
private String ksrqField;
|
||||
|
||||
private String jsrqField;
|
||||
|
||||
@Override
|
||||
public String execute(RequestInfo requestInfo) {
|
||||
baseBean.writeLog("HandleCBCommonAction start:" + ryField + "、" + ksrqField + "、" + jsrqField);
|
||||
try {
|
||||
if (StringUtils.isEmpty(ryField) || StringUtils.isEmpty(ksrqField) || StringUtils.isEmpty(jsrqField)) {
|
||||
return Action.SUCCESS;
|
||||
}
|
||||
|
||||
int billid = requestInfo.getRequestManager().getBillid();
|
||||
String requestid = requestInfo.getRequestid();
|
||||
String billTableName = requestInfo.getRequestManager().getBillTableName();
|
||||
baseBean.writeLog("table info:" + billid + "、" + billTableName + "、" + requestid);
|
||||
RecordSet rs = new RecordSet();
|
||||
rs.execute("SELECT * FROM " + billTableName + " WHERE id = " + billid);
|
||||
if (rs.next()) {
|
||||
String ry = rs.getString(ryField);
|
||||
String ksrq = rs.getString(ksrqField);
|
||||
String jsrq = rs.getString(jsrqField);
|
||||
if (StringUtils.isEmpty(ry) || StringUtils.isEmpty(ksrq) || StringUtils.isEmpty(jsrq)) {
|
||||
return Action.SUCCESS;
|
||||
}
|
||||
|
||||
List<String> ryList = Arrays.asList(ry.split(","));
|
||||
List<String> allDates = getAllDates(ksrq, jsrq);
|
||||
if (CollectionUtils.isEmpty(ryList) || CollectionUtils.isEmpty(allDates)) {
|
||||
baseBean.writeLog("no user or date.");
|
||||
return Action.SUCCESS;
|
||||
}
|
||||
|
||||
// 获取责任制、排班次班次
|
||||
Set<String> zrzbcSet = new HashSet<>();
|
||||
Set<String> pbzbcSet = new HashSet<>();
|
||||
String acqSql = "select kqgroup, grouptype from uf_ZeroPointSubSft";
|
||||
rs.executeQuery(acqSql);
|
||||
while (rs.next()) {
|
||||
String kqgroup = Util.null2String(rs.getString("kqgroup"));
|
||||
String grouptype = Util.null2String(rs.getString("grouptype"));
|
||||
if (org.apache.commons.lang3.StringUtils.isNotBlank(kqgroup) && org.apache.commons.lang3.StringUtils.equals(grouptype, "0")) {
|
||||
zrzbcSet.addAll(Arrays.asList(kqgroup.split(",")));
|
||||
}
|
||||
if (org.apache.commons.lang3.StringUtils.isNotBlank(kqgroup) && org.apache.commons.lang3.StringUtils.equals(grouptype, "1")) {
|
||||
pbzbcSet.addAll(Arrays.asList(kqgroup.split(",")));
|
||||
}
|
||||
}
|
||||
|
||||
// 鸿仁驻点餐补指定人员不享受
|
||||
List<String> removeRes = new ArrayList<>();
|
||||
String acqNoOtherStatAllResSql = "select resourceid from uf_NoOtherStatAllRe where isdelete is null or isdelete = 0 ";
|
||||
rs.executeQuery(acqNoOtherStatAllResSql);
|
||||
while (rs.next()){
|
||||
String resourceid = Util.null2String(rs.getString("resourceid"));
|
||||
if (org.apache.commons.lang3.StringUtils.isNotBlank(resourceid) ) {
|
||||
removeRes.add(resourceid);
|
||||
}
|
||||
}
|
||||
|
||||
// 驻点餐补指定人员不享受
|
||||
List<String> noRes = new ArrayList<>();
|
||||
String acqNoResSql = "select resourceid from uf_NoStatAllRes where isdelete = 0 or isdelete is null";
|
||||
rs.executeQuery(acqNoResSql);
|
||||
while (rs.next()) {
|
||||
String resourceid = Util.null2String(rs.getString("resourceid"));
|
||||
if (org.apache.commons.lang3.StringUtils.isNotBlank(resourceid)) {
|
||||
noRes.add(resourceid);
|
||||
}
|
||||
}
|
||||
|
||||
//获取夜班班次
|
||||
List<String> nightShiftList = new ArrayList<>();
|
||||
String acqNightShiftSql = "select shift from uf_nightshiftmanage where isdelete is null or isdelete = 0";
|
||||
rs.executeQuery(acqNightShiftSql);
|
||||
while (rs.next()) {
|
||||
String shift = Util.null2String(rs.getString("shift"));
|
||||
if (org.apache.commons.lang3.StringUtils.isNotBlank(shift)) {
|
||||
nightShiftList.add(shift);
|
||||
}
|
||||
}
|
||||
|
||||
ExecutorService executorService = ThreadPoolUtil.getThreadPool("HandleCBDataThreadAction", "20");
|
||||
for (String userId : ryList) {
|
||||
for (String kqDate : allDates) {
|
||||
executorService.execute(new HandleCBDataThread(userId, kqDate, zrzbcSet, pbzbcSet, removeRes, nightShiftList, noRes));
|
||||
}
|
||||
}
|
||||
}
|
||||
baseBean.writeLog("HandleCBCommonAction end.");
|
||||
} catch (Exception e) {
|
||||
baseBean.writeLog("HandleCBCommonAction error:" + e.getMessage());
|
||||
}
|
||||
return Action.SUCCESS;
|
||||
}
|
||||
|
||||
public List<String> getAllDates(String startDate, String endDate) {
|
||||
List<String> result = new ArrayList<>();
|
||||
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
|
||||
LocalDate start = LocalDate.parse(startDate, formatter);
|
||||
LocalDate end = LocalDate.parse(endDate, formatter);
|
||||
while (!start.isAfter(end)) {
|
||||
result.add(start.format(formatter));
|
||||
start = start.plusDays(1);
|
||||
}
|
||||
return result;
|
||||
}
|
||||
}
|
||||
File diff suppressed because it is too large
Load Diff
Loading…
Reference in New Issue