|
|
|
@ -562,6 +562,9 @@ public class StockTakingServiceImpl implements StockTakingService { |
|
|
|
SendQyWxMessageThreadPool.execute(() -> { |
|
|
|
// 获取盘点人员
|
|
|
|
// UserByPort originator = PublicConfig.FindUserById(mainRecord.getOriginator(), userKey, token);
|
|
|
|
// 获取用户的用工关系
|
|
|
|
// int emptype = originator.getEmptype();
|
|
|
|
// if (emptype <= 10) {
|
|
|
|
// String workwechat = originator.getWorkwechat();
|
|
|
|
// if (workwechat == null || "".equals(workwechat)) {
|
|
|
|
// workwechat = originator.getWechat();
|
|
|
|
@ -569,15 +572,17 @@ public class StockTakingServiceImpl implements StockTakingService { |
|
|
|
JSONObject jsonObject = qyWxOperationService.sendQyWxToStockTakingMessage("PangFuZhen,", mainId, normalMinId, userAgent, userKey, token); |
|
|
|
// JSONObject jsonObject = qyWxOperationService.sendQyWxToStockTakingMessage(workwechat, mainId, normalMinId, userAgent, userKey, token);
|
|
|
|
// 将当前返回结果保存到redis中
|
|
|
|
if (jsonObject != null) { |
|
|
|
Map<String, Object> QyWxMessageMap = new HashMap<>(); |
|
|
|
QyWxMessageMap.put("MsgId", jsonObject.getString("msgid")); |
|
|
|
QyWxMessageMap.put("responseCode", jsonObject.getString("response_code")); |
|
|
|
// if (jsonObject != null) {
|
|
|
|
// Map<String, Object> QyWxMessageMap = new HashMap<>();
|
|
|
|
// QyWxMessageMap.put("MsgId", jsonObject.getString("msgid"));
|
|
|
|
// QyWxMessageMap.put("responseCode", jsonObject.getString("response_code"));
|
|
|
|
// key user:300450:QyWxOut:1
|
|
|
|
redisPool.getRedisTemplateByDb(14).opsForHash().putAll("user:" + userToken.getNumber() + ":QyWxStockTakingCompleteId:" + mainId, QyWxMessageMap); |
|
|
|
// redisPool.getRedisTemplateByDb(14).opsForHash().putAll("user:" + userToken.getNumber() + ":QyWxStockTakingCompleteId:" + mainId, QyWxMessageMap);
|
|
|
|
// 设置过期时间为三天
|
|
|
|
redisPool.getRedisTemplateByDb(14).expire("user:" + userToken.getNumber() + ":QyWxStockTakingCompleteId:" + mainId, 72, TimeUnit.HOURS); |
|
|
|
} |
|
|
|
// redisPool.getRedisTemplateByDb(14).expire("user:" + userToken.getNumber() + ":QyWxStockTakingCompleteId:" + mainId, 72, TimeUnit.HOURS);
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
|
|
|
|
}); |
|
|
|
} else { |
|
|
|
map.put("state", 1); |
|
|
|
@ -1123,10 +1128,14 @@ public class StockTakingServiceImpl implements StockTakingService { |
|
|
|
// 获取responseCode(key为申请人number)
|
|
|
|
Integer originator = mainRecord.getOriginator(); |
|
|
|
UserByPort userByPort = PublicConfig.FindUserById(originator, userKey, token); |
|
|
|
int emptype = userByPort.getEmptype(); |
|
|
|
if (emptype <= 10) { |
|
|
|
//获取申请人信息
|
|
|
|
String key = "user:" + userByPort.getNumber() + ":QyWxStockTakingCompleteId:" + mainId; |
|
|
|
String responseCode = (String) redisPool.getRedisTemplateByDb(14).opsForHash().get(key, "responseCode"); |
|
|
|
qyWxOperationService.updateButtonTemplateCardToUnEnable(responseCode, userToken.getName(), "处理", userAgent); |
|
|
|
} |
|
|
|
|
|
|
|
}); |
|
|
|
|
|
|
|
return result; |
|
|
|
@ -1847,6 +1856,8 @@ public class StockTakingServiceImpl implements StockTakingService { |
|
|
|
SendQyWxMessageThreadPool.execute(() -> { |
|
|
|
// 获取盘点人员
|
|
|
|
// UserByPort originator = PublicConfig.FindUserById(mainRecord.getOriginator(), userKey, token);
|
|
|
|
// int emptype = originator.getEmptype();
|
|
|
|
// if(emptype <= 10){
|
|
|
|
// String workwechat = originator.getWorkwechat();
|
|
|
|
// if (workwechat == null || "".equals(workwechat)) {
|
|
|
|
// workwechat = originator.getWechat();
|
|
|
|
@ -1854,15 +1865,17 @@ public class StockTakingServiceImpl implements StockTakingService { |
|
|
|
JSONObject jsonObject = qyWxOperationService.sendQyWxToStockTakingMessage("PangFuZhen,", ObjectFormatUtil.toInteger(mainId), normalMinId, userAgent, userKey, token); |
|
|
|
// JSONObject jsonObject = qyWxOperationService.sendQyWxToStockTakingMessage(workwechat, ObjectFormatUtil.toInteger(mainId), normalMinId, userAgent, userKey, token);
|
|
|
|
// 将当前返回结果保存到redis中
|
|
|
|
if (jsonObject != null) { |
|
|
|
Map<String, Object> QyWxMessageMap = new HashMap<>(); |
|
|
|
QyWxMessageMap.put("MsgId", jsonObject.getString("msgid")); |
|
|
|
QyWxMessageMap.put("responseCode", jsonObject.getString("response_code")); |
|
|
|
// if (jsonObject != null) {
|
|
|
|
// Map<String, Object> QyWxMessageMap = new HashMap<>();
|
|
|
|
// QyWxMessageMap.put("MsgId", jsonObject.getString("msgid"));
|
|
|
|
// QyWxMessageMap.put("responseCode", jsonObject.getString("response_code"));
|
|
|
|
// key user:300450:QyWxOut:1
|
|
|
|
redisPool.getRedisTemplateByDb(14).opsForHash().putAll("user:" + approver_user.getNumber() + ":QyWxStockTakingCompleteId:" + mainId, QyWxMessageMap); |
|
|
|
// redisPool.getRedisTemplateByDb(14).opsForHash().putAll("user:" + approver_user.getNumber() + ":QyWxStockTakingCompleteId:" + mainId, QyWxMessageMap);
|
|
|
|
// 设置过期时间为三天
|
|
|
|
redisPool.getRedisTemplateByDb(14).expire("user:" + approver_user.getNumber() + ":QyWxStockTakingCompleteId:" + mainId, 72, TimeUnit.HOURS); |
|
|
|
} |
|
|
|
// redisPool.getRedisTemplateByDb(14).expire("user:" + approver_user.getNumber() + ":QyWxStockTakingCompleteId:" + mainId, 72, TimeUnit.HOURS);
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
|
|
|
|
}); |
|
|
|
|
|
|
|
} else { |
|
|
|
@ -2718,6 +2731,8 @@ public class StockTakingServiceImpl implements StockTakingService { |
|
|
|
map.put("minIds", minIds); |
|
|
|
StringBuilder departMentHeadQyWxName = new StringBuilder(); |
|
|
|
UserByPort userByPort = PublicConfig.FindUserById(ObjectFormatUtil.toInteger(originator), userKey, token); |
|
|
|
int emptype = userByPort.getEmptype(); |
|
|
|
if (emptype <= 10) { |
|
|
|
String workwechat = userByPort.getWorkwechat(); |
|
|
|
if (workwechat == null || "".equals(workwechat)) { |
|
|
|
workwechat = userByPort.getWechat(); |
|
|
|
@ -2725,6 +2740,8 @@ public class StockTakingServiceImpl implements StockTakingService { |
|
|
|
// departMentHeadQyWxName.append(workwechat+",");
|
|
|
|
departMentHeadQyWxName.append("PangFuZhen,"); |
|
|
|
JSONObject jsonObject = qyWxOperationService.sendCcStockTakingTransferMessageToHead(departMentHeadQyWxName.toString(), map, userToken, finalMainRecord, userAgent, userKey, token); |
|
|
|
} |
|
|
|
|
|
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
@ -2906,6 +2923,8 @@ public class StockTakingServiceImpl implements StockTakingService { |
|
|
|
SendQyWxMessageThreadPool.execute((Runnable) () -> { |
|
|
|
// 获取盘点人员
|
|
|
|
UserByPort originator = PublicConfig.FindUserById(mainRecord.getOriginator(), userkey, token); |
|
|
|
int emptype = originator.getEmptype(); |
|
|
|
if (emptype <= 10) { |
|
|
|
// String workwechat = originator.getWorkwechat();
|
|
|
|
// if(workwechat == null || "".equals(workwechat)){
|
|
|
|
// workwechat = originator.getWechat();
|
|
|
|
@ -2923,6 +2942,8 @@ public class StockTakingServiceImpl implements StockTakingService { |
|
|
|
// 设置过期时间为三天
|
|
|
|
redisPool.getRedisTemplateByDb(14).expire("user:" + originator.getNumber() + ":QyWxStockTakingCompleteId:" + mainId, 72, TimeUnit.HOURS); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
}); |
|
|
|
|
|
|
|
} else { |
|
|
|
@ -2930,12 +2951,16 @@ public class StockTakingServiceImpl implements StockTakingService { |
|
|
|
SendQyWxMessageThreadPool.execute(() -> { |
|
|
|
// 获取盘点人员
|
|
|
|
UserByPort originator = PublicConfig.FindUserById(mainRecord.getOriginator(), userkey, token); |
|
|
|
int emptype = originator.getEmptype(); |
|
|
|
if(emptype<= 10){ |
|
|
|
// String workwechat = originator.getWorkwechat();
|
|
|
|
// if(workwechat == null || "".equals(workwechat)){
|
|
|
|
// workwechat = originator.getWechat();
|
|
|
|
// }
|
|
|
|
qyWxOperationService.sendStockTakingErrMessageToHead("PangFuZhen,", errIds, mainRecord, null, userAgent, userkey, token); |
|
|
|
// qyWxOperationService.sendStockTakingErrMessageToHead(workwechat, errIds, mainRecord, null, userAgent,userkey,token);
|
|
|
|
} |
|
|
|
|
|
|
|
}); |
|
|
|
} |
|
|
|
} else { |
|
|
|
|